kq

type ConsumeHandle func(key, value string) error

type ConsumeHandler interface {
	Consume(key, value string) error
}

type KqConf struct {
	service.ServiceConf
	Brokers    []string
	Group      string
	Topic      string
	Offset     string `json:",options=first|last,default=last"`
	Conns      int    `json:",default=1"`
	Consumers  int    `json:",default=8"`
	Processors int    `json:",default=8"`
	MinBytes   int    `json:",default=10240"`    // 10K
	MaxBytes   int    `json:",default=10485760"` // 10M
}

type PushOption func(options *chunkOptions)

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

type QueueOption func(*queueOptions)