Versions in this module Expand all Collapse all v0 v0.0.2 Dec 19, 2025 v0.0.1 Dec 17, 2025 Changes in this version + type Config struct + MaxQueueSize int + MaxWorkers int + type ServiceRegistrationWorker struct + func NewServiceRegistrationWorker(bus *bus.Provider, serviceRegistry serviceregistry.ServiceRegistryInterface) *ServiceRegistrationWorker + func (w *ServiceRegistrationWorker) Start(ctx context.Context) + type UpstreamWorker struct + func NewUpstreamWorker(bus *bus.Provider, toolManager tool.ManagerInterface) *UpstreamWorker + func (w *UpstreamWorker) Start(ctx context.Context) + type Worker struct + func New(busProvider *bus.Provider, cfg *Config) *Worker + func (w *Worker) Start(ctx context.Context) + func (w *Worker) Stop()
Go to main page