Help us shape the future of Go! Take the 2026 Go Developer Survey

binding

package
v0.1.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 29, 2026 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ReadReadyDataSet

func ReadReadyDataSet(ctx context.Context, tx *repository.Repositories, id int64) (*model.StorageDataSet, error)

func SelectionFailed

func SelectionFailed(err error) bool

func SelectionNeedsWait

func SelectionNeedsWait(err error) bool

func SelectionSettlement

func SelectionSettlement(taskID int64, err error) taskengine.Settlement

SelectionSettlement saves the decision with the task's fenced transition.

func SelectionWait

func SelectionWait(err error) (reason, message string)

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

func (h *Selector) SelectBucketBindings(ctx context.Context, bucket *model.Bucket, targetCount int) ([]SelectedBinding, error)

type SelectorDependencies

type SelectorDependencies struct {
	Repositories       *repository.Repositories
	Storage            synapse.StorageClient
	Observability      *observability.Service
	AnchorProviderTier providerselect.Tier
	Resolver           *Resolver
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL