consumer

Documentation

Index

• Constants
• type Config
  • func GetDefaultConsumerConfig() *Config
• type Consumer
  • func NewConsumer(ctx context.Context, conf *Config, ...) (Consumer, error)

Constants

const (
	ConsumeFromBegin = "begin"
	ConsumeFromEnd   = "end"
)

Types

type Config

type Config struct {
	common.LoggerConfig
	common.ClientConfig
	ProjectID                      string
	TopicIDList                    []string
	ConsumerGroupName              string
	ConsumerName                   string
	ConsumeFrom                    string
	HeartbeatIntervalInSecond      int
	DataFetchIntervalInMillisecond int64
	FlushCheckpointIntervalSecond  int
	MaxFetchLogGroupCount          int
	OrderedConsume                 bool
}

func GetDefaultConsumerConfig

func GetDefaultConsumerConfig() *Config

type Consumer

type Consumer interface {
	ResetAccessKeyToken(accessKeyID, accessKeySecret, securityToken string)
	Start() error
	Stop()
}

func NewConsumer

func NewConsumer(ctx context.Context, conf *Config, f func(topicID string, shardID int, l *pb.LogGroupList)) (Consumer, error)