mq

Documentation

Index

• type Message
• type Publisher
• type PublisherFactory
• type SubscriberRegister

Types

type Message

type Message interface {
	Body() []byte
	Ack() error
	NoAck() error
	ID() string
}

type Publisher

type Publisher interface {
	Publish(ctx context.Context, body []byte) error
}

type PublisherFactory

type PublisherFactory interface {
	NewPublisher(topic string) (Publisher, error)
}

type SubscriberRegister

type SubscriberRegister interface {
	Subscribe(ctx context.Context, subscription string, onMessage func(message Message) error) error
}