pub_sub

Documentation

Index

• Variables
• type ChannelPubSub
  • func NewPubSubHandlerChannel(config gochannel.Config) ChannelPubSub
  • func (p ChannelPubSub) Publish(topic string, msg *message.Message) error
  • func (p ChannelPubSub) Subscribe(topic string, cb func(messages <-chan *message.Message)) error
• type DBSubscriptionClient
• type IDBSubscriptionClient
• type ITopicPubSubClient
• type TopicPubSubClient

Variables

var ChannelPubSubDefaultConfig = gochannel.Config{
	OutputChannelBuffer:            10,
	Persistent:                     true,
	BlockPublishUntilSubscriberAck: false,
}

Types

type ChannelPubSub

type ChannelPubSub struct {
	Client *gochannel.GoChannel
}

func NewPubSubHandlerChannel

func NewPubSubHandlerChannel(config gochannel.Config) ChannelPubSub

NewPubSubHandlerChannel this handler uses Watermill's go channels implementation as message engine

func (ChannelPubSub) Publish

func (p ChannelPubSub) Publish(topic string, msg *message.Message) error

func (ChannelPubSub) Subscribe

func (p ChannelPubSub) Subscribe(topic string, cb func(messages <-chan *message.Message)) error

type DBSubscriptionClient

type DBSubscriptionClient struct {
	Client IDBSubscriptionClient
}

type IDBSubscriptionClient

type IDBSubscriptionClient interface {
	Subscribe(query interface{}, handler func(message *json.RawMessage, err error) error) error
	Unsubscribe() error
	Start() error
	Stop() error
}

type ITopicPubSubClient

type ITopicPubSubClient interface {
	Subscribe(string, func(messages <-chan *message.Message)) error
	Publish(string, *message.Message) error
}

type TopicPubSubClient

type TopicPubSubClient struct {
	Client ITopicPubSubClient
}