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) AddTask(t *Task)
  • func (p *Replicator) HandleTask(ctx context.Context, task *Task)
  • func (p *Replicator) Run(ctx context.Context)
• type Task
  • func (t *Task) WithCopiesNumber(v uint32) *Task
  • func (t *Task) WithNodes(v netmap.Nodes) *Task
  • func (t *Task) WithObjectAddress(v *addressSDK.Address) *Task

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) AddTask

func (p *Replicator) AddTask(t *Task)

AddTask pushes replication task to Replicator queue.

If task queue is full, log message is written.

func (*Replicator) HandleTask

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

HandleTask executes replication task inside invoking goroutine.

func (*Replicator) Run

func (p *Replicator) Run(ctx context.Context)

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.Nodes) *Task

WithNodes sets list of potential object holders.

func (*Task) WithObjectAddress

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

WithObjectAddress sets address of local object.