Documentation ¶
Index ¶
- Variables
- func ParseTimeStamp(tso uint64) uint64
- type BinlogTailer
- 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
Constants ¶
This section is empty.
Variables ¶
View Source
var (
BinlogCheckInterval = time.Second
)
Functions ¶
func ParseTimeStamp ¶
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
Click to show internal directories.
Click to hide internal directories.