control

type BasicTarget struct {
	Store cadata.Store
}

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

type Cost struct {
	// Post is the cost to Post a blob
	Post float64
	// Get is the cost to retreive a blob
	Get float64
	// Delete is the cost to delete a blob
	Delete float64
	// List is the cost to list n blobs
	List func(n int) float64
	// BlobSecond is the cost to store 1 blob for 1 second
	BlobSecond float64
}

type Op struct {
	ID  cadata.ID
	Src ReadOnlyStore
}

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

type ReadOnlySet interface {
	cadata.Lister
	cadata.Exister
}

type ReadOnlyStore interface {
	cadata.Getter
	cadata.Lister
}

type Sink struct {
	Locus    [32]byte
	MaxCount int64
	Cost     Cost

	// BatchSize is the size of batches passed to flush.
	// If BatchSize == 0. Then there is no batching for the Sink.
	// If BatchSize < 0.  Then the magnitude is interpretted as the maximum number of concurrent operations.
	BatchSize int
	// BatchDelay is the longest an operation should be queued in a batch before pre-emptively
	// flushing a batch below BatchSize.
	BatchDelay time.Duration
	Target     Target
}

type Source struct {
	Set              ReadOnlySet
	ExpectedReplicas float64
}

type Target interface {
	// Actual returns a read only store with the actual content of the sink.
	Actual() ReadOnlyStore
	// FlushFunc is called to apply a batch of point operations to the target.
	Flush(ctx context.Context, ops []Op) error
	// Refresh is called to resync a target.
	Refresh(ctx context.Context, src ReadOnlyStore, desired ReadOnlySet) error
}