replicator

Documentation

Index

• type Option
  • func WithLocalStorage(v *engine.StorageEngine) Option
  • func WithLogger(v *logger.Logger) Option
  • func WithPutTimeout(v time.Duration) Option
  • func WithRemoteSender(v *putsvc.RemoteSender) Option
• type Replicator
  • func New(opts ...Option) *Replicator
  • func (p *Replicator) HandleTask(ctx context.Context, task *Task, res TaskResult)
• type Task
  • func (t *Task) WithCopiesNumber(v uint32) *Task
  • func (t *Task) WithNodes(v []netmap.NodeInfo) *Task
  • func (t *Task) WithObjectAddress(v oid.Address) *Task
• type TaskResult

Types

type Option

type Option func(*cfg)

Option is an option for Policer constructor.

func WithLocalStorage

func WithLocalStorage(v *engine.StorageEngine) Option

WithLocalStorage returns option to set local object storage of Replicator.

func WithLogger

func WithLogger(v *logger.Logger) Option

WithLogger returns option to set Logger of Replicator.

func WithPutTimeout

func WithPutTimeout(v time.Duration) Option

WithPutTimeout returns option to set Put timeout of Replicator.

func WithRemoteSender

func WithRemoteSender(v *putsvc.RemoteSender) Option

WithRemoteSender returns option to set remote object sender of Replicator.

type Replicator

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

Replicator represents the utility that replicates local objects to remote nodes.

func New

func New(opts ...Option) *Replicator

New creates, initializes and returns Replicator instance.

func (*Replicator) HandleTask

func (p *Replicator) HandleTask(ctx context.Context, task *Task, res TaskResult)

HandleTask executes replication task inside invoking goroutine. Passes all the nodes that accepted the replication to the TaskResult.

type Task

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

Task represents group of Replicator task parameters.

func (*Task) WithCopiesNumber

func (t *Task) WithCopiesNumber(v uint32) *Task

WithCopiesNumber sets number of copies to replicate.

func (*Task) WithNodes

func (t *Task) WithNodes(v []netmap.NodeInfo) *Task

WithNodes sets a list of potential object holders.

func (*Task) WithObjectAddress

func (t *Task) WithObjectAddress(v oid.Address) *Task

WithObjectAddress sets address of local object.

type TaskResult

type TaskResult interface {
	// SubmitSuccessfulReplication must save successful
	// replication result. ID is a netmap identification
	// of a node that accepted the replica.
	SubmitSuccessfulReplication(id uint64)
}

TaskResult is a replication result interface.