mq

Documentation

Index

• type Clienter
• type Publisher
  • func NewPublisher(topic string, client Clienter) Publisher
• type SubscribeHandler
• type Subscriber
  • func NewSubscriber(c Clienter) Subscriber

Types

type Clienter

type Clienter interface {
	Publish(ctx context.Context, sub string, msg interface{}) error
	Subscribe(topic string, h SubscribeHandler, queue ...string) error
}

type Publisher

type Publisher interface {
	Publish(ctx context.Context, msg interface{}) error
}

func NewPublisher

func NewPublisher(topic string, client Clienter) Publisher

type SubscribeHandler

type SubscribeHandler func(ctx context.Context, data []byte) error

type Subscriber

type Subscriber interface {
	Register(topic string, h SubscribeHandler, queue ...string) error
}

func NewSubscriber

func NewSubscriber(c Clienter) Subscriber