pubsub

Documentation

Index

• type Message
• type Publisher
  • func New() *Publisher
  • func (p *Publisher) Publish(message Message)
  • func (p *Publisher) Subscribe(c context.Context, receiver Receiver)
• type Receiver

Types

type Message

type Message struct {
	// ID identifies this message.
	ID string `json:"id,omitempty"`

	// Data is the actual data in the entry.
	Data []byte `json:"data"`

	// Labels represents the key-value pairs the entry is labeled with.
	Labels map[string]string `json:"labels,omitempty"`
}

Message defines a published message.

type Publisher

type Publisher struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func New

func New() *Publisher

New creates an in-memory publisher.

func (*Publisher) Publish

func (p *Publisher) Publish(message Message)

func (*Publisher) Subscribe

func (p *Publisher) Subscribe(c context.Context, receiver Receiver)

type Receiver

type Receiver func(Message)

Receiver receives published messages.