transfer

type CoordinatorDependencies struct {
	Repositories *repository.Repositories
	CacheGate    *cacheaccess.Gate
	Scheduler    *taskengine.Scheduler
	Messenger    *taskengine.Messenger
}

type CopyCoordinator struct {
	// contains filtered or unexported fields
}

type EventPublisher interface {
	Publish(string, map[string]any)
}

type PlanDependencies struct {
	Coordinator *CopyCoordinator
	Cache       cache.Cache
}

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

type PullDependencies struct {
	Coordinator      *CopyCoordinator
	Resolver         ReadyDataSetResolver
	Cache            cache.Cache
	ParkedPieces     synapse.ParkedPieceChecker
	CommitMaxBacklog int
}

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

type ReadyDataSetResolver interface {
	ExecutionIdentity(context.Context, *model.StorageDataSet) (storagepipeline.ExecutionIdentity, error)
	OpenReadyDataSet(context.Context, *model.StorageDataSet) (synapse.DataSetTarget, error)
}

type StoreDependencies struct {
	Coordinator       *CopyCoordinator
	Resolver          ReadyDataSetResolver
	Cache             cache.Cache
	CacheGate         *cacheaccess.Gate
	Events            EventPublisher
	ParkedPieces      synapse.ParkedPieceChecker
	CommitMaxBacklog  int
	UploadConcurrency int
	Logger            *slog.Logger
}

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