Versions in this module Expand all Collapse all v0 v0.10.0 Jul 10, 2020 Changes in this version + type Address = refs.Address + type AddressStore interface + SelfAddr func() (multiaddr.Multiaddr, error) + type CID = refs.CID + type ContainerActualityChecker interface + Actual func(ctx context.Context, cid CID) bool + type EpochReceiver interface + Epoch func() uint64 + type LocationDetectorParams struct + ResultTimeout time.Duration + TaskChanCap int + type Manager interface + HandleEpoch func(ctx context.Context, epoch uint64) + Process func(ctx context.Context) + func NewManager(p ManagerParams) (Manager, error) + type ManagerParams struct + ExpansionRate float64 + GarbageChanCap int + InitPoolSize int + Interval time.Duration + PlacementHonorerEnabled bool + PushTaskTimeout time.Duration + ReplicateTaskChanCap int + RestoreTaskChanCap int + type MultiSolver interface + func NewMultiSolver(p MultiSolverParams) (MultiSolver, error) + type MultiSolverParams struct + Placement placement.Component + type Object = object.Object + type ObjectCleaner interface + Del func(Address) error + type ObjectLocation struct + Node multiaddr.Multiaddr + WeightGreater bool + type ObjectLocationDetector interface + Process func(ctx context.Context) chan<- Address + Subscribe func(ch chan<- *ObjectLocationRecord) + func NewLocationDetector(p *LocationDetectorParams) (ObjectLocationDetector, error) + type ObjectLocationRecord struct + Locations []ObjectLocation + ReservationRatio int + type ObjectLocator interface + LocateObject func(ctx context.Context, objAddr Address) ([]multiaddr.Multiaddr, error) + type ObjectPool interface + Pop func() (Address, error) + Undone func() int + Update func([]Address) + func NewObjectPool() ObjectPool + type ObjectReceptacle interface + Put func(ctx context.Context, params ObjectStoreParams) error + type ObjectReplicator interface + Process func(ctx context.Context) chan<- *ReplicateTask + Subscribe func(ch chan<- *ReplicateResult) + func NewReplicator(p ObjectReplicatorParams) (ObjectReplicator, error) + type ObjectReplicatorParams struct + ResultTimeout time.Duration + TaskChanCap int + type ObjectRestorer interface + Process func(ctx context.Context) chan<- Address + Subscribe func(ch chan<- Address) + func NewObjectRestorer(p *ObjectRestorerParams) (ObjectRestorer, error) + type ObjectRestorerParams struct + ResultTimeout time.Duration + TaskChanCap int + type ObjectSource interface + Get func(ctx context.Context, addr Address) (*Object, error) + type ObjectStoreParams struct + Handler func(ObjectLocation, bool) + Nodes []ObjectLocation + type ObjectVerificationParams struct + Handler func(valid bool, obj *Object) + LocalInvalid bool + Node multiaddr.Multiaddr + type ObjectVerifier interface + Verify func(ctx context.Context, params *ObjectVerificationParams) bool + type OwnerID = object.OwnerID + type PlacementHonorer interface + Process func(ctx context.Context) chan<- *ObjectLocationRecord + Subscribe func(ch chan<- *ObjectLocationRecord) + func NewPlacementHonorer(p PlacementHonorerParams) (PlacementHonorer, error) + type PlacementHonorerParams struct + ResultTimeout time.Duration + TaskChanCap int + type PresenceChecker interface + Has func(address Address) (bool, error) + type RemoteStorageSelector interface + SelectRemoteStorages func(ctx context.Context, addr Address, excl ...multiaddr.Multiaddr) ([]ObjectLocation, error) + type ReplicateResult struct + NewStorages []multiaddr.Multiaddr + type ReplicateTask struct + ExcludeNodes []multiaddr.Multiaddr + Shortage int + type ReservationRatioReceiver interface + ReservationRatio func(ctx context.Context, objAddr Address) (int, error) + type Scheduler interface + SelectForReplication func(limit int) ([]Address, error) + func NewReplicationScheduler(p SchedulerParams) (Scheduler, error) + type SchedulerParams struct + type StorageValidator interface + Process func(ctx context.Context) chan<- *ObjectLocationRecord + SubscribeGarbage func(ch chan<- Address) + SubscribeReplication func(ch chan<- *ReplicateTask) + func NewStorageValidator(p StorageValidatorParams) (StorageValidator, error) + type StorageValidatorParams struct + AddrStore AddressStore + ResultTimeout time.Duration + TaskChanCap int + type WeightComparator interface + CompareWeight func(ctx context.Context, addr Address, node multiaddr.Multiaddr) int
Go to main page