dataset

type EnsureDependencies struct {
	Repositories *repository.Repositories
	Storage      synapse.StorageClient
	Messenger    *taskengine.Messenger

	Logger *slog.Logger
}

type EnsureHandler struct {
	*taskengine.FuncHandler
	// contains filtered or unexported fields
}

type EnsureReceiverDependencies struct {
	Scheduler *taskengine.Scheduler
	Identity  storagepipeline.ExecutionIdentity
}

type RetireDependencies struct {
	Repositories *repository.Repositories
	Terminator   synapse.ServiceTerminator
	Epochs       synapse.ChainEpochReader

	Logger *slog.Logger
}

type RetireHandler struct {
	*taskengine.FuncHandler
	// contains filtered or unexported fields
}

type RetireReceiverDependencies struct{ Scheduler *taskengine.Scheduler }