queue

package

v1.1.5 Latest Latest Go to latest Published: Nov 26, 2020 License: MIT Imports: 6 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

This section is empty.

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

Topic encapsulates the message queue topic

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

New creates a message queue topic

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

Publish writes an AVRO encoded Snapshot to the topic

func (t *Topic) Stop()

Stop cleanly closes the topic

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.