queue

Documentation

Index

• type Topic
  • func New(ctx context.Context, projectID string, topicName string) (*Topic, report.Span)
  • func (t *Topic) Publish(ctx context.Context, s *gauge.Snapshot) report.Span
  • func (t *Topic) Stop()
  • func (t *Topic) Subscribe(ctx context.Context, consumerGroup string, ...) error

Types

type Topic

type Topic struct {
	ProjectID string
	// contains filtered or unexported fields
}

Topic encapsulates the message queue topic

func New

func New(ctx context.Context, projectID string, topicName string) (*Topic, report.Span)

New creates a message queue topic

func (*Topic) Publish

func (t *Topic) Publish(ctx context.Context, s *gauge.Snapshot) report.Span

Publish writes an AVRO encoded Snapshot to the topic

func (*Topic) Stop

func (t *Topic) Stop()

Stop cleanly closes the topic

func (*Topic) Subscribe

func (t *Topic) Subscribe(ctx context.Context, consumerGroup string,
	fn func(ctx context.Context, err error, s *gauge.Snapshot) error) error

Subscribe reads AVRO encoded snapshots from the topic and decodes them

Note a zero length consumerGroup means auto-generate the pubsub subscription string and delete once done.