replicator

type MetricsRegister interface {
	IncInFlightRequest()
	DecInFlightRequest()
	IncProcessedObjects()
	AddPayloadSize(size int64)
}

type Option func(*cfg)

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

type Task struct {
	// NumCopies is the number of copies to replicate.
	NumCopies uint32
	// Addr is the address of the local object.
	Addr oid.Address
	// Obj is the object to avoid fetching it from the local storage.
	Obj *objectSDK.Object
	// Nodes is a list of potential object holders.
	Nodes []netmap.NodeInfo

	Container containerSDK.Container
}

type TaskResult interface {
	// SubmitSuccessfulReplication submits the successful object replication
	// to the given node.
	SubmitSuccessfulReplication(netmap.NodeInfo)
}