tidb_kafka

Documentation

Index

• Variables
• func ParseTimeStamp(tso uint64) uint64
• type BinlogTailer
  • func NewBinlogTailer(serverID uint32, config *gCfg.SourceTiDBConfig, emitter core.Emitter, ...) (*BinlogTailer, error)
  • func (t *BinlogTailer) Close()
  • func (t *BinlogTailer) Start() error
  • func (t *BinlogTailer) Wait()
• type DBOffsetStore
  • func (s *DBOffsetStore) Clear(group string, topic []string)
  • func (s *DBOffsetStore) Close() error
  • func (s *DBOffsetStore) CommitOffset(req *offsets.OffsetCommitRequest) (*offsets.OffsetCommitResponse, error)
  • func (s *DBOffsetStore) FetchOffset(req *offsets.OffsetFetchRequest) (*offsets.OffsetFetchResponse, error)
• type KafkaOffsetStoreFactory
  • func NewKafkaOffsetStoreFactory(config *config.SourceProbeCfg) *KafkaOffsetStoreFactory
  • func (f *KafkaOffsetStoreFactory) GenOffsetStore(c *sarama_cluster.Consumer) sarama_cluster.OffsetStore

Variables

var (
	BinlogCheckInterval = time.Second
)

Functions

func ParseTimeStamp

func ParseTimeStamp(tso uint64) uint64

Types

type BinlogTailer

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

func NewBinlogTailer

func NewBinlogTailer(
	serverID uint32,
	config *gCfg.SourceTiDBConfig,
	emitter core.Emitter,
	binlogChecker binlog_checker.BinlogChecker,
) (*BinlogTailer, error)

func (*BinlogTailer) Close

func (t *BinlogTailer) Close()

func (*BinlogTailer) Start

func (t *BinlogTailer) Start() error

func (*BinlogTailer) Wait

func (t *BinlogTailer) Wait()

type DBOffsetStore

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

func (*DBOffsetStore) Clear

func (s *DBOffsetStore) Clear(group string, topic []string)

func (*DBOffsetStore) Close

func (s *DBOffsetStore) Close() error

func (*DBOffsetStore) CommitOffset

func (s *DBOffsetStore) CommitOffset(req *offsets.OffsetCommitRequest) (*offsets.OffsetCommitResponse, error)

func (*DBOffsetStore) FetchOffset

func (s *DBOffsetStore) FetchOffset(req *offsets.OffsetFetchRequest) (*offsets.OffsetFetchResponse, error)

type KafkaOffsetStoreFactory

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

func NewKafkaOffsetStoreFactory

func NewKafkaOffsetStoreFactory(config *config.SourceProbeCfg) *KafkaOffsetStoreFactory

func (*KafkaOffsetStoreFactory) GenOffsetStore

func (f *KafkaOffsetStoreFactory) GenOffsetStore(c *sarama_cluster.Consumer) sarama_cluster.OffsetStore