Help us shape the future of Go! Take the 2026 Go Developer Survey

bucketprovision

package
v0.1.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 29, 2026 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

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 }

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL