Documentation
¶
Index ¶
- func NewContentCommittedSubscriber(coordinator *CopyCoordinator) (taskengine.MessageHandler, error)
- func NewDataSetReadySubscriber(coordinator *CopyCoordinator) (taskengine.MessageHandler, error)
- func NewFailCopyReceiver(coordinator *CopyCoordinator) (taskengine.MessageHandler, error)
- func NewStartCopyTransferReceiver(coordinator *CopyCoordinator) (taskengine.MessageHandler, error)
- type CoordinatorDependencies
- type CopyCoordinator
- type EventPublisher
- type PlanDependencies
- type PlanHandler
- type PullDependencies
- type PullHandler
- type ReadyDataSetResolver
- type StoreDependencies
- type StoreHandler
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewContentCommittedSubscriber ¶
func NewContentCommittedSubscriber(coordinator *CopyCoordinator) (taskengine.MessageHandler, error)
func NewDataSetReadySubscriber ¶
func NewDataSetReadySubscriber(coordinator *CopyCoordinator) (taskengine.MessageHandler, error)
func NewFailCopyReceiver ¶
func NewFailCopyReceiver(coordinator *CopyCoordinator) (taskengine.MessageHandler, error)
func NewStartCopyTransferReceiver ¶
func NewStartCopyTransferReceiver(coordinator *CopyCoordinator) (taskengine.MessageHandler, error)
Types ¶
type CoordinatorDependencies ¶
type CoordinatorDependencies struct {
Repositories *repository.Repositories
CacheGate *cacheaccess.Gate
Scheduler *taskengine.Scheduler
Messenger *taskengine.Messenger
}
type CopyCoordinator ¶
type CopyCoordinator struct {
// contains filtered or unexported fields
}
func NewCopyCoordinator ¶
func NewCopyCoordinator(deps CoordinatorDependencies) (*CopyCoordinator, error)
type EventPublisher ¶
type PlanDependencies ¶
type PlanDependencies struct {
Coordinator *CopyCoordinator
Cache cache.Cache
}
type PlanHandler ¶
type PlanHandler struct {
*taskengine.FuncHandler
*CopyCoordinator
// contains filtered or unexported fields
}
func NewPlanHandler ¶
func NewPlanHandler(deps PlanDependencies) (*PlanHandler, error)
type PullDependencies ¶
type PullDependencies struct {
Coordinator *CopyCoordinator
Resolver ReadyDataSetResolver
Cache cache.Cache
ParkedPieces synapse.ParkedPieceChecker
CommitMaxBacklog int
}
type PullHandler ¶
type PullHandler struct {
*taskengine.FuncHandler
*CopyCoordinator
// contains filtered or unexported fields
}
func NewPullHandler ¶
func NewPullHandler(deps PullDependencies) (*PullHandler, error)
type ReadyDataSetResolver ¶
type ReadyDataSetResolver interface {
ExecutionIdentity(context.Context, *model.StorageDataSet) (storagepipeline.ExecutionIdentity, error)
OpenReadyDataSet(context.Context, *model.StorageDataSet) (synapse.DataSetTarget, error)
}
type StoreDependencies ¶
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 ¶
type StoreHandler struct {
*taskengine.FuncHandler
*CopyCoordinator
// contains filtered or unexported fields
}
func NewStoreHandler ¶
func NewStoreHandler(deps StoreDependencies) (*StoreHandler, error)
Click to show internal directories.
Click to hide internal directories.