client

Documentation

Index

• type PubSubClient
  • func New(confCtx *config.Context) *PubSubClient
  • func (p *PubSubClient) Close()
  • func (p *PubSubClient) Publish(topic string, message string)
  • func (p *PubSubClient) Subscribe(topic string)

Types

type PubSubClient

type PubSubClient struct {
	Notifications chan []string
	// contains filtered or unexported fields
}

func New

func New(confCtx *config.Context) *PubSubClient

func (*PubSubClient) Close

func (p *PubSubClient) Close()

func (*PubSubClient) Publish

func (p *PubSubClient) Publish(topic string, message string)

guaranteed to never block, but can lose all but the latest message per topic

func (*PubSubClient) Subscribe

func (p *PubSubClient) Subscribe(topic string)