Skip to content
GitLab
Explore
Sign in
Primary navigation
Search or go to…
Project
H
HARMONY
Manage
Activity
Members
Labels
Plan
Issues
Issue boards
Milestones
Wiki
Requirements
Code
Merge requests
Repository
Branches
Commits
Tags
Repository graph
Compare revisions
Snippets
Locked files
Build
Pipelines
Jobs
Pipeline schedules
Test cases
Artifacts
Deploy
Releases
Package registry
Container registry
Model registry
Operate
Environments
Terraform modules
Monitor
Incidents
Analyze
Value stream analytics
Contributor analytics
CI/CD analytics
Repository analytics
Code review analytics
Issue analytics
Insights
Model experiments
Help
Help
Support
GitLab documentation
Compare GitLab plans
GitLab community forum
Contribute to GitLab
Provide feedback
Keyboard shortcuts
?
Snippets
Groups
Projects
Show more breadcrumbs
Amel Abdic
HARMONY
Commits
fb1da7cb
Commit
fb1da7cb
authored
Dec 28, 2023
by
jensilo
Browse files
Options
Downloads
Patches
Plain Diff
change name to conform to naming scheme for project
parent
8c3d568f
No related branches found
No related tags found
No related merge requests found
Changes
3
Show whitespace changes
Inline
Side-by-side
Showing
3 changed files
src/app/eiffel/web.go
+1
-1
1 addition, 1 deletion
src/app/eiffel/web.go
src/core/event/event.go
+2
-2
2 additions, 2 deletions
src/core/event/event.go
src/core/event/event_test.go
+20
-20
20 additions, 20 deletions
src/core/event/event_test.go
with
23 additions
and
23 deletions
src/app/eiffel/web.go
+
1
−
1
View file @
fb1da7cb
...
@@ -128,7 +128,7 @@ func subscribeEvents(appCtx *hctx.AppCtx) {
...
@@ -128,7 +128,7 @@ func subscribeEvents(appCtx *hctx.AppCtx) {
}
}
return
nil
return
nil
},
event
.
Default
Event
Priority
)
},
event
.
DefaultPriority
)
}
}
func
registerNavigation
(
appCtx
*
hctx
.
AppCtx
,
webCtx
*
web
.
Ctx
)
{
func
registerNavigation
(
appCtx
*
hctx
.
AppCtx
,
webCtx
*
web
.
Ctx
)
{
...
...
This diff is collapsed.
Click to expand it.
src/core/event/event.go
+
2
−
2
View file @
fb1da7cb
...
@@ -10,11 +10,11 @@ import (
...
@@ -10,11 +10,11 @@ import (
const
Pkg
=
"sys.event"
const
Pkg
=
"sys.event"
// Default
Event
Priority can be used as a general default priority for an event subscriber.
// DefaultPriority can be used as a general default priority for an event subscriber.
// The priority is used to determine the order in which subscribers are called.
// The priority is used to determine the order in which subscribers are called.
// A higher priority means that the subscriber is called earlier.
// A higher priority means that the subscriber is called earlier.
// If you do not care about the order in which subscribers are called, use this constant.
// If you do not care about the order in which subscribers are called, use this constant.
const
Default
Event
Priority
=
0
const
DefaultPriority
=
0
// BufferSize is the size of the buffer for event channels.
// BufferSize is the size of the buffer for event channels.
// The buffer size is used when creating channels for events.
// The buffer size is used when creating channels for events.
...
...
This diff is collapsed.
Click to expand it.
src/core/event/event_test.go
+
20
−
20
View file @
fb1da7cb
...
@@ -65,7 +65,7 @@ func TestBasicEventSubscribing(t *testing.T) {
...
@@ -65,7 +65,7 @@ func TestBasicEventSubscribing(t *testing.T) {
return
nil
return
nil
}
}
em
.
Subscribe
(
"test.event"
,
subscriberFunc
,
Default
Event
Priority
)
em
.
Subscribe
(
"test.event"
,
subscriberFunc
,
DefaultPriority
)
event
:=
newMockEvent
(
"test.event"
)
event
:=
newMockEvent
(
"test.event"
)
dc
:=
make
(
chan
[]
error
)
dc
:=
make
(
chan
[]
error
)
...
@@ -90,8 +90,8 @@ func TestBasicEventSubscribing(t *testing.T) {
...
@@ -90,8 +90,8 @@ func TestBasicEventSubscribing(t *testing.T) {
return
nil
return
nil
}
}
em
.
Subscribe
(
"test.event.multiple"
,
subscriberFunc
,
Default
Event
Priority
)
em
.
Subscribe
(
"test.event.multiple"
,
subscriberFunc
,
DefaultPriority
)
em
.
Subscribe
(
"test.event.multiple"
,
subscriberFunc
,
Default
Event
Priority
)
em
.
Subscribe
(
"test.event.multiple"
,
subscriberFunc
,
DefaultPriority
)
event
:=
newMockEvent
(
"test.event.multiple"
)
event
:=
newMockEvent
(
"test.event.multiple"
)
dc
:=
make
(
chan
[]
error
)
dc
:=
make
(
chan
[]
error
)
...
@@ -111,7 +111,7 @@ func TestBasicEventSubscribing(t *testing.T) {
...
@@ -111,7 +111,7 @@ func TestBasicEventSubscribing(t *testing.T) {
return
nil
return
nil
}
}
em
.
Subscribe
(
"test.event.fire"
,
subscriberFunc
,
Default
Event
Priority
)
em
.
Subscribe
(
"test.event.fire"
,
subscriberFunc
,
DefaultPriority
)
event
:=
newMockEvent
(
"test.event.fire"
)
event
:=
newMockEvent
(
"test.event.fire"
)
em
.
Publish
(
event
,
nil
)
em
.
Publish
(
event
,
nil
)
...
@@ -124,7 +124,7 @@ func TestBasicEventSubscribing(t *testing.T) {
...
@@ -124,7 +124,7 @@ func TestBasicEventSubscribing(t *testing.T) {
return
nil
return
nil
}
}
em
.
Subscribe
(
"test.event.channel"
,
subscriberFunc
,
Default
Event
Priority
)
em
.
Subscribe
(
"test.event.channel"
,
subscriberFunc
,
DefaultPriority
)
event
:=
newMockEvent
(
"test.event.channel"
)
event
:=
newMockEvent
(
"test.event.channel"
)
dc
:=
make
(
chan
[]
error
)
dc
:=
make
(
chan
[]
error
)
...
@@ -206,7 +206,7 @@ func TestBasicPublishing(t *testing.T) {
...
@@ -206,7 +206,7 @@ func TestBasicPublishing(t *testing.T) {
em
.
Subscribe
(
"test.event.payload"
,
func
(
e
Event
,
args
*
PublishArgs
)
error
{
em
.
Subscribe
(
"test.event.payload"
,
func
(
e
Event
,
args
*
PublishArgs
)
error
{
e
.
Payload
()
.
(
*
mockPayload
)
.
data
=
"modified"
e
.
Payload
()
.
(
*
mockPayload
)
.
data
=
"modified"
return
nil
return
nil
},
Default
Event
Priority
)
},
DefaultPriority
)
event
:=
newMockEvent
(
"test.event.payload"
)
event
:=
newMockEvent
(
"test.event.payload"
)
dc
:=
make
(
chan
[]
error
)
dc
:=
make
(
chan
[]
error
)
...
@@ -227,12 +227,12 @@ func TestBasicPublishing(t *testing.T) {
...
@@ -227,12 +227,12 @@ func TestBasicPublishing(t *testing.T) {
em
.
Subscribe
(
"test.event.multiple"
,
func
(
e
Event
,
args
*
PublishArgs
)
error
{
em
.
Subscribe
(
"test.event.multiple"
,
func
(
e
Event
,
args
*
PublishArgs
)
error
{
received
=
append
(
received
,
1
)
received
=
append
(
received
,
1
)
return
nil
return
nil
},
Default
Event
Priority
)
},
DefaultPriority
)
em
.
Subscribe
(
"test.event.multiple"
,
func
(
e
Event
,
args
*
PublishArgs
)
error
{
em
.
Subscribe
(
"test.event.multiple"
,
func
(
e
Event
,
args
*
PublishArgs
)
error
{
received
=
append
(
received
,
2
)
received
=
append
(
received
,
2
)
return
nil
return
nil
},
Default
Event
Priority
)
},
DefaultPriority
)
event
:=
newMockEvent
(
"test.event.multiple"
)
event
:=
newMockEvent
(
"test.event.multiple"
)
dc
:=
make
(
chan
[]
error
)
dc
:=
make
(
chan
[]
error
)
...
@@ -254,7 +254,7 @@ func TestErrorHandling(t *testing.T) {
...
@@ -254,7 +254,7 @@ func TestErrorHandling(t *testing.T) {
em
.
Subscribe
(
"test.event.error"
,
func
(
e
Event
,
args
*
PublishArgs
)
error
{
em
.
Subscribe
(
"test.event.error"
,
func
(
e
Event
,
args
*
PublishArgs
)
error
{
return
fmt
.
Errorf
(
"test error"
)
return
fmt
.
Errorf
(
"test error"
)
},
Default
Event
Priority
)
},
DefaultPriority
)
event
:=
newMockEvent
(
"test.event.error"
)
event
:=
newMockEvent
(
"test.event.error"
)
dc
:=
make
(
chan
[]
error
)
dc
:=
make
(
chan
[]
error
)
...
@@ -272,11 +272,11 @@ func TestErrorHandling(t *testing.T) {
...
@@ -272,11 +272,11 @@ func TestErrorHandling(t *testing.T) {
em
.
Subscribe
(
"test.event.error"
,
func
(
e
Event
,
args
*
PublishArgs
)
error
{
em
.
Subscribe
(
"test.event.error"
,
func
(
e
Event
,
args
*
PublishArgs
)
error
{
return
fmt
.
Errorf
(
"test error"
)
return
fmt
.
Errorf
(
"test error"
)
},
Default
Event
Priority
)
},
DefaultPriority
)
em
.
Subscribe
(
"test.event.error"
,
func
(
e
Event
,
args
*
PublishArgs
)
error
{
em
.
Subscribe
(
"test.event.error"
,
func
(
e
Event
,
args
*
PublishArgs
)
error
{
return
fmt
.
Errorf
(
"test error"
)
return
fmt
.
Errorf
(
"test error"
)
},
Default
Event
Priority
)
},
DefaultPriority
)
event
:=
newMockEvent
(
"test.event.error"
)
event
:=
newMockEvent
(
"test.event.error"
)
dc
:=
make
(
chan
[]
error
)
dc
:=
make
(
chan
[]
error
)
...
@@ -294,7 +294,7 @@ func TestErrorHandling(t *testing.T) {
...
@@ -294,7 +294,7 @@ func TestErrorHandling(t *testing.T) {
em
.
Subscribe
(
"test.event.panic"
,
func
(
e
Event
,
args
*
PublishArgs
)
error
{
em
.
Subscribe
(
"test.event.panic"
,
func
(
e
Event
,
args
*
PublishArgs
)
error
{
panic
(
"test panic"
)
panic
(
"test panic"
)
},
Default
Event
Priority
)
},
DefaultPriority
)
event
:=
newMockEvent
(
"test.event.panic"
)
event
:=
newMockEvent
(
"test.event.panic"
)
dc
:=
make
(
chan
[]
error
)
dc
:=
make
(
chan
[]
error
)
...
@@ -312,15 +312,15 @@ func TestErrorHandling(t *testing.T) {
...
@@ -312,15 +312,15 @@ func TestErrorHandling(t *testing.T) {
em
.
Subscribe
(
"test.event.panic"
,
func
(
e
Event
,
args
*
PublishArgs
)
error
{
em
.
Subscribe
(
"test.event.panic"
,
func
(
e
Event
,
args
*
PublishArgs
)
error
{
panic
(
"test panic"
)
panic
(
"test panic"
)
},
Default
Event
Priority
)
},
DefaultPriority
)
em
.
Subscribe
(
"test.event.panic"
,
func
(
e
Event
,
args
*
PublishArgs
)
error
{
em
.
Subscribe
(
"test.event.panic"
,
func
(
e
Event
,
args
*
PublishArgs
)
error
{
return
fmt
.
Errorf
(
"test error"
)
return
fmt
.
Errorf
(
"test error"
)
},
Default
Event
Priority
)
},
DefaultPriority
)
em
.
Subscribe
(
"test.event.panic"
,
func
(
e
Event
,
args
*
PublishArgs
)
error
{
em
.
Subscribe
(
"test.event.panic"
,
func
(
e
Event
,
args
*
PublishArgs
)
error
{
return
nil
return
nil
},
Default
Event
Priority
)
},
DefaultPriority
)
event
:=
newMockEvent
(
"test.event.panic"
)
event
:=
newMockEvent
(
"test.event.panic"
)
dc
:=
make
(
chan
[]
error
)
dc
:=
make
(
chan
[]
error
)
...
@@ -340,12 +340,12 @@ func TestErrorHandling(t *testing.T) {
...
@@ -340,12 +340,12 @@ func TestErrorHandling(t *testing.T) {
em
.
Subscribe
(
"test.event.panic"
,
func
(
e
Event
,
args
*
PublishArgs
)
error
{
em
.
Subscribe
(
"test.event.panic"
,
func
(
e
Event
,
args
*
PublishArgs
)
error
{
panic
(
"test panic"
)
panic
(
"test panic"
)
},
Default
Event
Priority
)
},
DefaultPriority
)
em
.
Subscribe
(
"test.event.panic"
,
func
(
e
Event
,
args
*
PublishArgs
)
error
{
em
.
Subscribe
(
"test.event.panic"
,
func
(
e
Event
,
args
*
PublishArgs
)
error
{
received
=
true
received
=
true
return
nil
return
nil
},
Default
Event
Priority
)
},
DefaultPriority
)
event
:=
newMockEvent
(
"test.event.panic"
)
event
:=
newMockEvent
(
"test.event.panic"
)
dc
:=
make
(
chan
[]
error
)
dc
:=
make
(
chan
[]
error
)
...
@@ -374,7 +374,7 @@ func TestConcurrentOperations(t *testing.T) {
...
@@ -374,7 +374,7 @@ func TestConcurrentOperations(t *testing.T) {
em
.
Subscribe
(
"test.event.concurrent.publish"
,
func
(
e
Event
,
args
*
PublishArgs
)
error
{
em
.
Subscribe
(
"test.event.concurrent.publish"
,
func
(
e
Event
,
args
*
PublishArgs
)
error
{
atomic
.
AddInt32
(
&
count
,
1
)
atomic
.
AddInt32
(
&
count
,
1
)
return
nil
return
nil
},
Default
Event
Priority
)
},
DefaultPriority
)
var
wg
sync
.
WaitGroup
var
wg
sync
.
WaitGroup
for
i
:=
0
;
i
<
100
;
i
++
{
for
i
:=
0
;
i
<
100
;
i
++
{
...
@@ -412,7 +412,7 @@ func TestConcurrentOperations(t *testing.T) {
...
@@ -412,7 +412,7 @@ func TestConcurrentOperations(t *testing.T) {
em
.
Subscribe
(
fmt
.
Sprintf
(
"test.event.concurrent.subscribe.%d"
,
num
),
func
(
e
Event
,
args
*
PublishArgs
)
error
{
em
.
Subscribe
(
fmt
.
Sprintf
(
"test.event.concurrent.subscribe.%d"
,
num
),
func
(
e
Event
,
args
*
PublishArgs
)
error
{
atomic
.
AddInt32
(
&
count
,
1
)
atomic
.
AddInt32
(
&
count
,
1
)
return
nil
return
nil
},
Default
Event
Priority
)
},
DefaultPriority
)
}(
i
)
}(
i
)
}
}
wg
.
Wait
()
wg
.
Wait
()
...
@@ -449,7 +449,7 @@ func TestConcurrentOperations(t *testing.T) {
...
@@ -449,7 +449,7 @@ func TestConcurrentOperations(t *testing.T) {
em
.
Subscribe
(
fmt
.
Sprintf
(
"test.event.concurrent.mixed.%d"
,
c
),
func
(
e
Event
,
args
*
PublishArgs
)
error
{
em
.
Subscribe
(
fmt
.
Sprintf
(
"test.event.concurrent.mixed.%d"
,
c
),
func
(
e
Event
,
args
*
PublishArgs
)
error
{
atomic
.
AddInt32
(
&
subCount
,
1
)
atomic
.
AddInt32
(
&
subCount
,
1
)
return
nil
return
nil
},
Default
Event
Priority
)
},
DefaultPriority
)
event
:=
newMockEvent
(
fmt
.
Sprintf
(
"test.event.concurrent.mixed.%d"
,
c
))
event
:=
newMockEvent
(
fmt
.
Sprintf
(
"test.event.concurrent.mixed.%d"
,
c
))
dc
:=
make
(
chan
[]
error
)
dc
:=
make
(
chan
[]
error
)
...
...
This diff is collapsed.
Click to expand it.
Preview
0%
Loading
Try again
or
attach a new file
.
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Save comment
Cancel
Please
sign in
to comment