bridge

Documentation

Index

• Variables
• type Bridge
  • func New(cfg *config.Config, logger zerolog.Logger) (*Bridge, error)
  • func (b *Bridge) Close() error
  • func (b *Bridge) Delay() uint32
  • func (b *Bridge) Dumping() bool
  • func (b *Bridge) Run() <-chan error
  • func (b *Bridge) Running() bool

Variables

var ErrRuleNotExist = errors.New("rule is not exist")

Types

type Bridge

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

func New

func New(cfg *config.Config, logger zerolog.Logger) (*Bridge, error)

func (*Bridge) Close

func (b *Bridge) Close() error

func (*Bridge) Delay

func (b *Bridge) Delay() uint32

func (*Bridge) Dumping

func (b *Bridge) Dumping() bool

func (*Bridge) Run

func (b *Bridge) Run() <-chan error

Run syncs the data from MySQL and inserts to Tarantool until closed or meets errors.

Returns closed channel with all errors or an empty channel.

func (*Bridge) Running

func (b *Bridge) Running() bool