worker

type DecorateFunction func(fx.Hook) fx.Hook

type Decorator struct {
	Key      string
	Decorate DecorateFunction
}

type Registry interface {
	Workers() []Worker
	Enable(names ...string) error
	Disable(names ...string) error
	EnableAll()
	DisableAll()
	Start(ctx context.Context) error
	Stop(ctx context.Context) error
	// contains filtered or unexported methods
}

type RegistryParams struct {
	fx.In
	fx.Shutdowner
	Workers    []Worker    `group:"workers"`
	Decorators []Decorator `group:"worker_decorators"`
	Logger     *zap.SugaredLogger
}

type RegistryResult struct {
	fx.Out
	Registry Registry
}

type Worker interface {
	Key() string
	Enabled() bool
	Started() bool
	// contains filtered or unexported methods
}