queue

Documentation

Index

• type ConsumeOption
• type ConsumeOptionFunc
• type Consumer
• type ProduceOption
• type ProduceOptionFunc
• type Queue

Types

type ConsumeOption

type ConsumeOption struct{}

type ConsumeOptionFunc

type ConsumeOptionFunc func(o *ConsumeOption)

type Consumer

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

type ProduceOption

type ProduceOption struct{}

type ProduceOptionFunc

type ProduceOptionFunc func(o *ProduceOption)

type Queue

type Queue interface {
	Produce(ctx context.Context, msg interface{}, opts ...ProduceOptionFunc) error
	Consume(consumer Consumer)
	Shutdown() error
}