slavesync

Documentation

Index

• type Manager
  • func NewManager(ctx context.Context, apMq *aggmq.MQ, configSource config.Source) *Manager
  • func (m *Manager) Run()

Types

type Manager

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

Manager defines slave syncer manager

func NewManager

func NewManager(ctx context.Context, apMq *aggmq.MQ, configSource config.Source) *Manager

NewManager creates new slave syncer manager

func (*Manager) Run

func (m *Manager) Run()

Run runs the slave syncer manager