pubsub

Documentation

Index

• func NewLocalPubSub(id string) *localPubSub
• func NewNatsPubSub(id string) *natsPubSub
• type Message
  • func NewMessage(data interface{}) *Message
  • func (m *Message) Ack() error
  • func (m *Message) Data() interface{}
  • func (m *Message) SetAckFunc(f func() error)
  • func (m *Message) SetTopic(topic Topic)
  • func (m *Message) String() string
  • func (m *Message) Topic() Topic
• type PubSub
• type Topic

Functions

func NewLocalPubSub

func NewLocalPubSub(id string) *localPubSub

func NewNatsPubSub

func NewNatsPubSub(id string) *natsPubSub

Types

type Message

type Message struct {
	// contains filtered or unexported fields
}

func NewMessage

func NewMessage(data interface{}) *Message

func (*Message) Ack

func (m *Message) Ack() error

func (*Message) Data

func (m *Message) Data() interface{}

func (*Message) SetAckFunc

func (m *Message) SetAckFunc(f func() error)

func (*Message) SetTopic

func (m *Message) SetTopic(topic Topic)

func (*Message) String

func (m *Message) String() string

func (*Message) Topic

func (m *Message) Topic() Topic

type PubSub

type PubSub interface {
	Publish(ctx context.Context, topic Topic, msg *Message) error
	Subscribe(ctx context.Context, topic Topic) (ch <-chan *Message, unsubscribe func())
}

type Topic

type Topic string