queue

Documentation

Index

• type Consumer
• type ProduceResponse
• type Queue

Types

type Consumer

type Consumer func(context.Context, interface{}) (reject, retry bool, err error)

type ProduceResponse

type ProduceResponse struct {
	Partition int32
	Offset    uint64
}

type Queue

type Queue interface {
	Produce(ctx context.Context, msg interface{}) (ProduceResponse, error)
	Consume(params interface{}) error
	Shutdown() error
}