consumer

Documentation

Index

• Constants
• type ConsumeData
• type Consumer
  • func NewConsumer(http *http.Http) *Consumer
  • func (c *Consumer) Consume(data *ConsumeData) ([]byte, error)
  • func (c *Consumer) Create() ([]byte, error)
  • func (c *Consumer) Messages() ([]byte, error)

Constants

const (
	CacheConstomerIdPrefix = "hik_cloud_customer_id_"
)

Types

type ConsumeData

type ConsumeData struct {
	ConsumerId string `c:"consumerId" json:"consumer_id"`            //消费者ID
	AutoCommit bool   `c:"autoCommit, omitempty" json:"auto_commit"` //是否自动提交偏移量，默认false
}

type Consumer

type Consumer struct {
	Http *http.Http
}

func NewConsumer

func NewConsumer(http *http.Http) *Consumer

func (*Consumer) Consume

func (c *Consumer) Consume(data *ConsumeData) ([]byte, error)

func (*Consumer) Create

func (c *Consumer) Create() ([]byte, error)

func (*Consumer) Messages

func (c *Consumer) Messages() ([]byte, error)