bridge

package

v1.0.0 Latest Latest Go to latest Published: Nov 9, 2020 License: MIT Imports: 19 Imported by: 0

Details

This section is empty.

View Source

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

This section is empty.

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

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

func (b *Bridge) Close() error

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.