input

Documentation

Index

• type Mongo
  • func NewMongo(conf *config.MongoSrConfig) *Mongo
  • func (m *Mongo) Cancel() context.CancelFunc
  • func (m *Mongo) Ctx() context.Context
  • func (m *Mongo) StartChangeStream()
• type MyEventHandler
  • func NewMysql(conf *config.MysqlSrConfig) *MyEventHandler
  • func (h *MyEventHandler) AckGTIDSet() mysql.GTIDSet
  • func (h *MyEventHandler) C() *canal.Canal
  • func (h *MyEventHandler) Cancel() context.CancelFunc
  • func (h *MyEventHandler) Ctx() context.Context
  • func (h *MyEventHandler) OnPosSynced(pos mysql.Position, set mysql.GTIDSet, force bool) error
  • func (h *MyEventHandler) OnRow(e *canal.RowsEvent) error
  • func (h *MyEventHandler) String() string
• type Mysql
• type StreamObject

Types

type Mongo

type Mongo struct {
	*config.Mongo

	Client       *mongo.Client
	ChangeStream *mongo.ChangeStream

	OutputType string
	Config     *config.MongoSrConfig
	// contains filtered or unexported fields
}

func NewMongo

func NewMongo(conf *config.MongoSrConfig) *Mongo

func (*Mongo) Cancel

func (m *Mongo) Cancel() context.CancelFunc

func (*Mongo) Ctx

func (m *Mongo) Ctx() context.Context

func (*Mongo) StartChangeStream

func (m *Mongo) StartChangeStream()

type MyEventHandler

type MyEventHandler struct {
	canal.DummyEventHandler

	StartPosition string
	// contains filtered or unexported fields
}

func NewMysql

func NewMysql(conf *config.MysqlSrConfig) *MyEventHandler

func (*MyEventHandler) AckGTIDSet

func (h *MyEventHandler) AckGTIDSet() mysql.GTIDSet

func (*MyEventHandler) C

func (h *MyEventHandler) C() *canal.Canal

func (*MyEventHandler) Cancel

func (h *MyEventHandler) Cancel() context.CancelFunc

func (*MyEventHandler) Ctx

func (h *MyEventHandler) Ctx() context.Context

func (*MyEventHandler) OnPosSynced

func (h *MyEventHandler) OnPosSynced(pos mysql.Position, set mysql.GTIDSet, force bool) error

func (*MyEventHandler) OnRow

func (h *MyEventHandler) OnRow(e *canal.RowsEvent) error

func (*MyEventHandler) String

func (h *MyEventHandler) String() string

type Mysql

type Mysql struct {
	*config.Mysql
}

type StreamObject

type StreamObject struct {
	Id                *msg.WatchId `bson:"_id"`
	OperationType     string
	FullDocument      map[string]interface{}
	Ns                msg.NS
	UpdateDescription map[string]interface{}
	DocumentKey       map[string]interface{}
	ClusterTime       primitive.Timestamp
}