sync

Documentation

Index

• Variables
• type Process
  • func NewProcess(peer cluster.Peer, manager cluster.Manager, delayConfig *managerConfig.Delay, ...) *Process
  • func (p *Process) Close() error
  • func (p *Process) Delay() time.Duration
  • func (p *Process) Name() string
  • func (p *Process) Process(ctx context.Context) error
  • func (p *Process) RunNumbers() uint64
• type Sync
  • func NewSync(m cluster.Manager, delayConfig *manager.Delay, syncConfig *syncConfig.Config, ...) *Sync

Variables

var Component = &component.Component{
	Name: "cluster.sync",
	Dependencies: component.Components{
		sync.Component,
		repeater.Component,
		grpc.Component,
	},
	Init: component.StepFunc(func(container container.Container) error {
		return container.Provide(NewSync)
	}),
	Execute: component.StepFunc(func(container container.Container) error {
		return container.Invoke(func(m cluster.Manager, sync *Sync) {
			m.OnAddPeer().Subscribe(sync.onAddPeer)
			m.OnDeletingPeer().Subscribe(sync.onDeletingPeer)
		})
	}),
}

Types

type Process

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

func NewProcess

func NewProcess(
	peer cluster.Peer,
	manager cluster.Manager,
	delayConfig *managerConfig.Delay,
	grpcConfig *grpcClient.Config,
	syncConfig *syncConfig.Config,
	logger logger.Logger,
	closer closer.Closer,
) *Process

func (*Process) Close

func (p *Process) Close() error

func (*Process) Delay

func (p *Process) Delay() time.Duration

func (*Process) Name

func (p *Process) Name() string

func (*Process) Process

func (p *Process) Process(ctx context.Context) error

func (*Process) RunNumbers

func (p *Process) RunNumbers() uint64

type Sync

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

func NewSync

func NewSync(
	m cluster.Manager,
	delayConfig *manager.Delay,
	syncConfig *syncConfig.Config,
	grpcConfig *grpc.Config,
	repeater repeater.Repeater,
	logger logger.Logger,
	closer closer.Closer,
) *Sync