24
var Library = &library{}
25
27
>
return libraryName
28
>
}
29
30
>
func (l *library) NexusServices() []*nexus.Service {
library.go
31
>
return []*nexus.Service{NewTestServiceNexusService()}
32
>
}
33
34
>
func (l *library) NexusServiceProcessors() []*chasm.NexusServiceProcessor {
library.go
35
>
return []*chasm.NexusServiceProcessor{NewTestServiceNexusServiceProcessor()}
36
>
}
37
38
>
func (l *library) Components() []*chasm.RegistrableComponent {
library.go
39
>
return []*chasm.RegistrableComponent{
40
>
chasm.NewRegistrableComponent[*PayloadStore](
41
>
componentName,
42
>
chasm.WithBusinessIDAlias("PayloadStoreId"),
43
>
chasm.WithSearchAttributes(
44
>
PayloadTotalCountSearchAttribute,
45
>
PayloadTotalSizeSearchAttribute,
46
>
ExecutionStatusSearchAttribute,
47
>
chasm.SearchAttributeTaskQueue,
48
>
),
49
>
chasm.WithContextValues(map[any]any{
50
>
componentCtxKey: componentCtxVal,
51
>
}),
52
>
),
53
>
}
54
>
}
55
56
>
func (l *library) Tasks() []*chasm.RegistrableTask {
library.go
57
>
return []*chasm.RegistrableTask{
58
>
chasm.NewRegistrablePureTask(
59
>
"payloadTTLPureTask",
60
>
&PayloadTTLPureTaskHandler{},
61
>
),
62
>
chasm.NewRegistrableSideEffectTask(
63
>
"payloadTTLSideEffectTask",
64
>
&PayloadTTLSideEffectTaskHandler{},
65
>
),
66
>
}
67
>
}