output

Documentation

Index

• type MQMessage
• type Output
  • func NewOutput(sub *conf.Subscribe) (Output, error)

Types

type MQMessage

type MQMessage struct {
	Schema      string                 `json:"schema"`
	Table       string                 `json:"table"`
	Operation   string                 `json:"operation"`
	Data        map[string]interface{} `json:"data"`
	OperateTime int64                  `json:"operateTime"`
}

type Output

type Output interface {
	// Handle row data
	Write(wal ...*model.WalData) error
	Close()
}

Output for write wal data

func NewOutput

func NewOutput(sub *conf.Subscribe) (Output, error)

NewOutput create new output