queue

Documentation

Index

• Variables
• type CallOptions
• type ConsumeHandle
  • func (ch ConsumeHandle) Consume(ctx context.Context, k, v []byte) error
• type Consumer
• type Pusher

Variables

var ErrNotSupport = errors.New("not support")

Types

type CallOptions

type CallOptions func(interface{})

type ConsumeHandle

type ConsumeHandle func(ctx context.Context, key, value []byte) error

func (ConsumeHandle) Consume

func (ch ConsumeHandle) Consume(ctx context.Context, k, v []byte) error

type Consumer

type Consumer interface {
	Consume(ctx context.Context, key, value []byte) error
}

type Pusher

type Pusher interface {
	io.Closer
	Push(ctx context.Context, key, body []byte, opts ...CallOptions) (interface{}, error)
	Name() string
}