Documentation
¶
Index ¶
- func CurrentIdentity(client synapse.StorageClient) storagepipeline.ExecutionIdentity
- func DataSetRefIDs(binding *model.StorageDataSet, ref storage.DataSetRef) (idtypes.OnChainID, idtypes.OnChainID, error)
- func DataSetResultIDs(binding *model.StorageDataSet, result *storage.CreateDataSetResult) (idtypes.OnChainID, idtypes.OnChainID, error)
- func ReadReadyDataSet(ctx context.Context, tx *repository.Repositories, id int64) (*model.StorageDataSet, error)
- func RecordedIdentity(ctx context.Context, repos *repository.Repositories, ...) (storagepipeline.ExecutionIdentity, error)
- func SelectionFailed(err error) bool
- func SelectionNeedsWait(err error) bool
- func SelectionSettlement(taskID int64, err error) taskengine.Settlement
- func SelectionWait(err error) (reason, message string)
- func SelectionWaitSettlement(taskID int64, err error) taskengine.Settlement
- func ValidateSelection(ctx context.Context, repos *repository.Repositories, bucketID int64, ...) error
- type Plan
- type Resolver
- func (h *Resolver) ExecutionIdentity(ctx context.Context, binding *model.StorageDataSet) (storagepipeline.ExecutionIdentity, error)
- func (h *Resolver) OpenBindingTarget(ctx context.Context, bucketName string, binding *model.StorageDataSet) (synapse.StorageTarget, error)
- func (h *Resolver) OpenReadyDataSet(ctx context.Context, binding *model.StorageDataSet) (synapse.DataSetTarget, error)
- type ResolverDependencies
- type SelectedBinding
- type Selector
- type SelectorDependencies
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CurrentIdentity ¶
func CurrentIdentity(client synapse.StorageClient) storagepipeline.ExecutionIdentity
func DataSetRefIDs ¶
func DataSetRefIDs(binding *model.StorageDataSet, ref storage.DataSetRef) (idtypes.OnChainID, idtypes.OnChainID, error)
func DataSetResultIDs ¶
func DataSetResultIDs(binding *model.StorageDataSet, result *storage.CreateDataSetResult) (idtypes.OnChainID, idtypes.OnChainID, error)
func ReadReadyDataSet ¶
func ReadReadyDataSet(ctx context.Context, tx *repository.Repositories, id int64) (*model.StorageDataSet, error)
func RecordedIdentity ¶
func RecordedIdentity(ctx context.Context, repos *repository.Repositories, binding *model.StorageDataSet) (storagepipeline.ExecutionIdentity, error)
func SelectionFailed ¶
func SelectionNeedsWait ¶
func SelectionSettlement ¶
func SelectionSettlement(taskID int64, err error) taskengine.Settlement
SelectionSettlement saves the decision with the task's fenced transition.
func SelectionWait ¶
func SelectionWaitSettlement ¶
func SelectionWaitSettlement(taskID int64, err error) taskengine.Settlement
SelectionWaitSettlement records changed waiting decisions, not every poll.
func ValidateSelection ¶
func ValidateSelection(ctx context.Context, repos *repository.Repositories, bucketID int64, plan []Plan) error
Types ¶
type Plan ¶
type Plan struct {
Admission *providerselect.Admission
CopyIndex int
Provider idtypes.OnChainID
DataSet *storage.DataSetRef
}
type Resolver ¶
type Resolver struct {
// contains filtered or unexported fields
}
Resolver opens execution-side targets and verifies their immutable identity.
func NewResolver ¶
func NewResolver(deps ResolverDependencies) *Resolver
func (*Resolver) ExecutionIdentity ¶
func (h *Resolver) ExecutionIdentity(ctx context.Context, binding *model.StorageDataSet) (storagepipeline.ExecutionIdentity, error)
func (*Resolver) OpenBindingTarget ¶
func (h *Resolver) OpenBindingTarget(ctx context.Context, bucketName string, binding *model.StorageDataSet) (synapse.StorageTarget, error)
func (*Resolver) OpenReadyDataSet ¶
func (h *Resolver) OpenReadyDataSet(ctx context.Context, binding *model.StorageDataSet) (synapse.DataSetTarget, error)
type ResolverDependencies ¶
type ResolverDependencies struct {
Repositories *repository.Repositories
Storage synapse.StorageClient
}
type SelectedBinding ¶
type SelectedBinding struct {
Admission *providerselect.Admission
CopyIndex int
Target synapse.StorageTarget
}
type Selector ¶
type Selector struct {
// contains filtered or unexported fields
}
func NewSelector ¶
func NewSelector(deps SelectorDependencies) (*Selector, error)
func (*Selector) SelectBucketBindings ¶
type SelectorDependencies ¶
type SelectorDependencies struct {
Repositories *repository.Repositories
Storage synapse.StorageClient
Observability *observability.Service
AnchorProviderTier providerselect.Tier
Resolver *Resolver
}
Click to show internal directories.
Click to hide internal directories.