tmq

type Assignment struct {
	VGroupID int32 `json:"vgroup_id"`
	Offset   int64 `json:"offset"`
	Begin    int64 `json:"begin"`
	End      int64 `json:"end"`
}

type Column struct {
	Name   string `json:"name"`
	Type   int    `json:"type"`
	Length int    `json:"length"`
}

type ConfigMap map[string]ConfigValue

type ConfigValue interface{}

type CreateItem struct {
	TableName string `json:"tableName"`
	Using     string `json:"using"`
	TagNum    int    `json:"tagNum"`
	Tags      []*Tag `json:"tags"`
}

type Data struct {
	TableName string
	Data      [][]driver.Value
}

type DataMessage struct {
	TopicPartition TopicPartition
	// contains filtered or unexported fields
}

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

type Event interface {
	String() string
}

type Message interface {
	Topic() string
	DBName() string
	Value() interface{}
	Offset() int64
}

type Meta struct {
	Type          string        `json:"type"`
	TableName     string        `json:"tableName"`
	TableType     string        `json:"tableType"`
	CreateList    []*CreateItem `json:"createList"`
	Columns       []*Column     `json:"columns"`
	Using         string        `json:"using"`
	TagNum        int           `json:"tagNum"`
	Tags          []*Tag        `json:"tags"`
	TableNameList []string      `json:"tableNameList"`
	AlterType     int           `json:"alterType"`
	ColName       string        `json:"colName"`
	ColNewName    string        `json:"colNewName"`
	ColType       int           `json:"colType"`
	ColLength     int           `json:"colLength"`
	ColValue      string        `json:"colValue"`
	ColValueNull  bool          `json:"colValueNull"`
}

type MetaData struct {
	Meta *Meta
	Data []*Data
}

type MetaDataMessage struct {
	TopicPartition TopicPartition
	// contains filtered or unexported fields
}

type MetaMessage struct {
	TopicPartition TopicPartition
	// contains filtered or unexported fields
}

type Offset int64

type Tag struct {
	Name  string      `json:"name"`
	Type  int         `json:"type"`
	Value interface{} `json:"value"`
}

type TopicPartition struct {
	Topic     *string
	Partition int32
	Offset    Offset
	Metadata  *string
	Error     error
}