Versions in this module Expand all Collapse all v0 v0.1.1 Oct 29, 2026 v0.1.0 Oct 20, 2026 Changes in this version + 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 struct + Admission *providerselect.Admission + CopyIndex int + DataSet *storage.DataSetRef + Provider idtypes.OnChainID + type Resolver struct + func NewResolver(deps ResolverDependencies) *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 struct + Repositories *repository.Repositories + Storage synapse.StorageClient + type SelectedBinding struct + Admission *providerselect.Admission + CopyIndex int + Target synapse.StorageTarget + type Selector struct + func NewSelector(deps SelectorDependencies) (*Selector, error) + func (h *Selector) SelectBucketBindings(ctx context.Context, bucket *model.Bucket, targetCount int) ([]SelectedBinding, error) + type SelectorDependencies struct + AnchorProviderTier providerselect.Tier + Observability *observability.Service + Repositories *repository.Repositories + Resolver *Resolver + Storage synapse.StorageClient
Go to main page