Versions in this module Expand all Collapse all v3 v3.30.1 Oct 10, 2024 Changes in this version + const ErrorOther + const OffsetInvalid + type Assignment struct + Begin int64 + End int64 + Offset int64 + VGroupID int32 + type Column struct + Length int + Name string + Type int + type ConfigMap map[string]ConfigValue + func (m ConfigMap) Clone() ConfigMap + func (m ConfigMap) Get(key string, defval ConfigValue) (ConfigValue, error) + type ConfigValue interface + type CreateItem struct + TableName string + TagNum int + Tags []*Tag + Using string + type Data struct + Data [][]driver.Value + TableName string + type DataMessage struct + TopicPartition TopicPartition + func (m *DataMessage) DBName() string + func (m *DataMessage) Offset() Offset + func (m *DataMessage) SetData(data []*Data) + func (m *DataMessage) SetDbName(dbName string) + func (m *DataMessage) SetOffset(offset Offset) + func (m *DataMessage) SetTopic(topic string) + func (m *DataMessage) String() string + func (m *DataMessage) Topic() string + func (m *DataMessage) Value() interface{} + type Error struct + func NewTMQError(code int, str string) Error + func NewTMQErrorWithErr(err error) Error + func (e Error) Code() int + func (e Error) Error() string + func (e Error) String() string + type Event interface + String func() string + type Message interface + DBName func() string + Offset func() int64 + Topic func() string + Value func() interface{} + type Meta struct + AlterType int + ColLength int + ColName string + ColNewName string + ColType int + ColValue string + ColValueNull bool + Columns []*Column + CreateList []*CreateItem + TableName string + TableNameList []string + TableType string + TagNum int + Tags []*Tag + Type string + Using string + type MetaData struct + Data []*Data + Meta *Meta + type MetaDataMessage struct + TopicPartition TopicPartition + func (m *MetaDataMessage) DBName() string + func (m *MetaDataMessage) Offset() Offset + func (m *MetaDataMessage) SetDbName(dbName string) + func (m *MetaDataMessage) SetMetaData(metaData *MetaData) + func (m *MetaDataMessage) SetOffset(offset Offset) + func (m *MetaDataMessage) SetTopic(topic string) + func (m *MetaDataMessage) String() string + func (m *MetaDataMessage) Topic() string + func (m *MetaDataMessage) Value() interface{} + type MetaMessage struct + TopicPartition TopicPartition + func (m *MetaMessage) DBName() string + func (m *MetaMessage) Offset() Offset + func (m *MetaMessage) SetDbName(dbName string) + func (m *MetaMessage) SetMeta(meta *Meta) + func (m *MetaMessage) SetOffset(offset Offset) + func (m *MetaMessage) SetTopic(topic string) + func (m *MetaMessage) String() string + func (m *MetaMessage) Topic() string + func (m *MetaMessage) Value() interface{} + type Offset int64 + func (o Offset) String() string + func (o Offset) Valid() bool + type Tag struct + Name string + Type int + Value interface{} + type TopicPartition struct + Error error + Metadata *string + Offset Offset + Partition int32 + Topic *string + func (p TopicPartition) String() string
Go to main page