Versions in this module Expand all Collapse all v0 v0.1.4 Jul 23, 2019 Changes in this version + const BEGIN_CURSOR + const CONSUME_PROCESSING + const CONSUME_PROCESSING_DONE + const END_CURSOR + const INITIALIZING + const INITIALIZING_DONE + const PULL_PROCESSING + const PULL_PROCESSING_DONE + const SHUTDOWN_COMPLETE + const SPECIAL_TIMER_CURSOR + func Contain(obj interface{}, target interface{}) bool + func GetLogCount(logGroupList *sls.LogGroupList) int + func GetLogGroupCount(logGroupList *sls.LogGroupList) int + func IntSliceReflectEqual(a, b []int) bool + func Min(a, b int64) int64 + func Set(slc []int) []int + func Subtract(a []int, b []int) (diffSlice []int) + func TimeToSleepInMillsecond(intervalTime, lastCheckTime int64, condition bool) + func TimeToSleepInSecond(intervalTime, lastCheckTime int64, condition bool) + type ConsumerCheckPointTracker struct + type ConsumerClient struct + type ConsumerHeatBeat struct + type ConsumerWorker struct + Logger log.Logger + func InitConsumerWorker(option LogHubConfig, do func(int, *sls.LogGroupList) string) *ConsumerWorker + func (consumerWorker *ConsumerWorker) Start() + func (consumerWorker *ConsumerWorker) StopAndWait() + type LogHubConfig struct + AccessKeyID string + AccessKeySecret string + AllowLogLevel string + ConsumerGroupName string + ConsumerName string + CursorPosition string + CursorStartTime int64 + DataFetchIntervalInMs int64 + Endpoint string + HeartbeatIntervalInSecond int + InOrder bool + IsJsonType bool + LogCompass bool + LogFileName string + LogMaxBackups int + LogMaxSize int + Logstore string + MaxFetchLogGroupCount int + Project string + type ShardConsumerWorker struct