queue

Documentation

Index

• type ConsumeHandle
• type ConsumeHandler
• type MessageQueue
• type Pusher
• type Sender

Types

type ConsumeHandle

type ConsumeHandle func(ctx context.Context, topic string, key, message []byte) error

type ConsumeHandler

type ConsumeHandler interface {
	Consume(ctx context.Context, topic string, key, message []byte) error
}

type MessageQueue

type MessageQueue interface {
	Name() string
	Start(context.Context) error
	Stop(context.Context) error
}

A MessageQueue interface represents a message queue.

type Pusher

type Pusher interface {
	Name() string
	Push(ctx context.Context, key, value []byte) error
	Close() error
}

A Pusher interface wraps the method Push.

type Sender

type Sender interface {
	Name() string
	Send(ctx context.Context, header map[string]interface{}, exchange string, routeKey string, msg []byte) error
	Close() error
}