queue

Documentation

Index

• type Message
  • func (m *Message) Ack(ctx context.Context) error
• type Queue
  • func NewQueue(streamName string, subject string, config config.Configuration, ...) (Queue, error)

Types

type Message

type Message struct {
	Data []byte `json:"data"`
	// contains filtered or unexported fields
}

func (*Message) Ack

func (m *Message) Ack(ctx context.Context) error

type Queue

type Queue interface {
	Publish(ctx context.Context, msg *Message) error
	Subscribe(ctx context.Context, ch chan *Message) error
	Unsubscribe(ctx context.Context) error
	StreamName() string
	Subject() string
}

func NewQueue

func NewQueue(
	streamName string,
	subject string,
	config config.Configuration,
	instance instance.Instance,
) (Queue, error)

NewQueue initializes the queue client