option

Documentation

Index

• type Auth
• type Consumer
• type ConsumerFunc
  • func ConsumerWithAuth(auth *Auth) ConsumerFunc
  • func ConsumerWithBatchSize(batchSize int) ConsumerFunc
  • func ConsumerWithBroadCastModel(broadCastModel bool) ConsumerFunc
  • func ConsumerWithId(id string) ConsumerFunc
• type Producer
• type ProducerFunc
  • func ProducerWithAuth(auth *Auth) ProducerFunc

Types

type Auth

type Auth struct {
	AccessKey string
	SecretKey string
}

type Consumer

type Consumer struct {
	Id             string
	BroadCastModel bool
	BatchSize      int
	Auth           *Auth
}

type ConsumerFunc

type ConsumerFunc func(*Consumer)

func ConsumerWithAuth

func ConsumerWithAuth(auth *Auth) ConsumerFunc

func ConsumerWithBatchSize

func ConsumerWithBatchSize(batchSize int) ConsumerFunc

func ConsumerWithBroadCastModel

func ConsumerWithBroadCastModel(broadCastModel bool) ConsumerFunc

func ConsumerWithId

func ConsumerWithId(id string) ConsumerFunc

type Producer

type Producer struct {
	Auth *Auth
}

type ProducerFunc

type ProducerFunc func(*Producer)

func ProducerWithAuth

func ProducerWithAuth(auth *Auth) ProducerFunc