51
}
52
53
>
func NewRegistry(logger log.Logger) *Registry {
registry.go
54
>
return &Registry{
55
>
libraries: make(map[string]Library),
56
>
rcByFqn: make(map[string]*RegistrableComponent),
57
>
rcByID: make(map[uint32]*RegistrableComponent),
58
>
rcByGoType: make(map[reflect.Type]*RegistrableComponent),
59
>
rtByFqn: make(map[string]*RegistrableTask),
60
>
rtByID: make(map[uint32]*RegistrableTask),
61
>
rtByGoType: make(map[reflect.Type]*RegistrableTask),
62
>
rcContextValues: make(map[any]valueWithFqn),
63
>
nexusServices: make(map[string]*nexus.Service),
64
>
NexusEndpointProcessor: NewNexusEndpointProcessor(),
65
>
logger: logger,
66
>
}
67
>
}
68
69
func (r *Registry) Register(lib Library) error {