queue

Documentation

Index

• Variables
• type Message
• type NewQueueOpts
• type Queue
• type QueueMessageReceivedBody
• type QueueMessageSentBody

Variables

var (
	ErrClosed = errors.New("queue connection closed")
)

Types

type Message

type Message struct {
	Body         []byte
	Internal     interface{}
	TimesRetried int64
}

type NewQueueOpts

type NewQueueOpts struct {
	Username      string
	Password      string
	Host          string
	Port          string
	PrefetchCount uint64
}

type Queue

type Queue interface {
	Start(ctx context.Context, queueName string) error
	Close(ctx context.Context)
	Publish(ctx context.Context, msg []byte) error
	Notify(ctx context.Context, wg *sync.WaitGroup) error
	Subscribe(ctx context.Context, msgs chan<- Message, wg *sync.WaitGroup) error
	Ack(ctx context.Context, msg Message) error
	Nack(ctx context.Context, msg Message, requeue bool) error
}

type QueueMessageReceivedBody

type QueueMessageReceivedBody struct {
	Event *bridge.BridgeMessageReceived
	ID    int
}

type QueueMessageSentBody

type QueueMessageSentBody struct {
	Event *bridge.BridgeMessageSent
	ID    int
}