replication

Documentation

Index

• type DataHandle
• type DumpHandle
• type OnData
• type OnDump
• type OnDumpSuccess
• type OnPulse
• type PulseHandle
• type Replicator
  • func NewReplicator() *Replicator
  • func (r *Replicator) Init(ctx context.Context) error
  • func (r *Replicator) Start(ctx context.Context) error
  • func (r *Replicator) Stop(ctc context.Context) error
  • func (r *Replicator) SubscribeOnData(handle DataHandle)
  • func (r *Replicator) SubscribeOnDump(handle DumpHandle)
  • func (r *Replicator) SubscribeOnPulse(handle PulseHandle)
• type SuccessHandle

Types

type DataHandle

type DataHandle func(uint32, *record.Material)

type DumpHandle

type DumpHandle func(tx *pg.Tx, pub OnDumpSuccess) error

type OnData

type OnData interface {
	SubscribeOnData(handle DataHandle)
}

type OnDump

type OnDump interface {
	SubscribeOnDump(DumpHandle)
}

type OnDumpSuccess

type OnDumpSuccess interface {
	Subscribe(SuccessHandle)
}

type OnPulse

type OnPulse interface {
	SubscribeOnPulse(handle PulseHandle)
}

type PulseHandle

type PulseHandle func(pn insolar.PulseNumber, entropy insolar.Entropy, timestamp int64)

type Replicator

type Replicator struct {
	Configurator     configuration.Configurator `inject:""`
	ConnectionHolder db.ConnectionHolder        `inject:""`

	sync.RWMutex
	// contains filtered or unexported fields
}

func NewReplicator

func NewReplicator() *Replicator

func (*Replicator) Init

func (r *Replicator) Init(ctx context.Context) error

func (*Replicator) Start

func (r *Replicator) Start(ctx context.Context) error

func (*Replicator) Stop

func (r *Replicator) Stop(ctc context.Context) error

func (*Replicator) SubscribeOnData

func (r *Replicator) SubscribeOnData(handle DataHandle)

func (*Replicator) SubscribeOnDump

func (r *Replicator) SubscribeOnDump(handle DumpHandle)

func (*Replicator) SubscribeOnPulse

func (r *Replicator) SubscribeOnPulse(handle PulseHandle)

type SuccessHandle

type SuccessHandle func()