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