consumer

type BatchGetLog struct {
	Count int64     `json:"count"`
	Next  string    `json:"next"`
	Logs  []LogData `json:"logs"`
}

type Client struct {
	AccessKeyID     string
	AccessKeySecret string
	SecurityToken   string
	RequestTimeOut  time.Duration
	RetryTimeOut    time.Duration
	HTTPClient      *http.Client
	RegionName      string
	ProjectId       string
	// contains filtered or unexported fields
}

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

type Cursor struct {
	Cursor string `json:"cursor"`
}

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

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

type ILogConsumerCheckPointTracker interface {
	SaveCheckPoint(persistent bool) error
	GetCheckPoint() string
	GetCurrentCursor() string
}

type ILogConsumerProcessor interface {
	Initialize(shardId string)
	Process(logGroups []LogData, checkPointTracker ILogConsumerCheckPointTracker) string
	Shutdown(checkPointTracker ILogConsumerCheckPointTracker) error
}

type ILogConsumerProcessorFactory interface {
	GeneratorProcessor() ILogConsumerProcessor
}

type ILogConsumerSTSToken interface {
	// GetSTSTokenConfig SDK会定期从此方法中获取临时AK, 临时SK, 临时securityToken. 如果临时认证信息有变化, 在此方法中实现即可
	GetSTSTokenConfig() STSTokenConfig
}

type LogConsumerClientAdapter struct {
	ILogConsumerSTSToken ILogConsumerSTSToken
	// contains filtered or unexported fields
}

type LogConsumerConfig struct {
	RegionName        string
	ProjectId         string
	LogGroupId        string
	LogStreamId       string
	AccessKeyId       string
	AccessKeySecret   string
	ConsumerGroupName string

	SecurityToken        string
	ILogConsumerSTSToken ILogConsumerSTSToken
	StartTimeNs          time.Time
	EndTimeNs            time.Time
	FetchIntervalMillis  int64

	BatchSize int
	// contains filtered or unexported fields
}

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

type LogData struct {
	Labels map[string]string `json:"labels"`
}

type LogShardConsumer struct {
	ConsumerStatus string
	// contains filtered or unexported fields
}

type STSTokenConfig struct {
	AccessKeyId     string
	AccessKeySecret string
	SecurityToken   string
}

type ShardCheckPoint struct {
	Shard      string `json:"shard_id"`
	Checkpoint int64  `json:"checkpoint"`
	UpdateTime int64  `json:"update_time"`
	Consumer   string `json:"consumer_name"`
}

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