option

May 1, 2022

Changes in this version

+ type Auth struct

+ AccessKey string

+ SecretKey string

+ type Consumer struct

+ Auth *Auth

+ BatchSize int

+ BroadCastModel bool

+ Id string

+ type ConsumerFunc func(*Consumer)

+ func ConsumerWithAuth(auth *Auth) ConsumerFunc

+ func ConsumerWithBatchSize(batchSize int) ConsumerFunc

+ func ConsumerWithBroadCastModel(broadCastModel bool) ConsumerFunc

+ func ConsumerWithId(id string) ConsumerFunc

+ type Producer struct

+ Auth *Auth

+ type ProducerFunc func(*Producer)

+ func ProducerWithAuth(auth *Auth) ProducerFunc