Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewDataSetReadySubscriber ¶
func NewDataSetReadySubscriber(deps WakeDependencies) (taskengine.MessageHandler, error)
func NewReplacementActivatedSubscriber ¶
func NewReplacementActivatedSubscriber(deps WakeDependencies) (taskengine.MessageHandler, error)
Types ¶
type Dependencies ¶
type Dependencies struct {
Repositories *repository.Repositories
Storage synapse.StorageClient
Selector *bindingtask.Selector
Messenger *taskengine.Messenger
Logger *slog.Logger
}
type Handler ¶
type Handler struct {
*taskengine.FuncHandler
// contains filtered or unexported fields
}
func NewHandler ¶
func NewHandler(deps Dependencies) (*Handler, error)
type WakeDependencies ¶
type WakeDependencies struct{ Scheduler *taskengine.Scheduler }
Click to show internal directories.
Click to hide internal directories.