The highest tagged major version is v6.

subqueue

package

v3.0.0 Latest Latest Go to latest Published: Aug 24, 2019 License: Apache-2.0 Imports: 1 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

Package subqueue is internal implementation of awsiotdev package. It implements offline queueing of MQTT subscription.

This section is empty.

This section is empty.

This section is empty.

type OperationType int32

OperationType represents type of the operation.

const (
	// Subscribe requests a new subscription.
	Subscribe OperationType = iota
	// Unsubscribe requests stopping the subscription.
	Unsubscribe
)

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

Queue manages queued subscription operations.

func New() *Queue

New returns a queue of subscription operations.

func (s *Queue) Enqueue(d *Subscription)

Enqueue pushes a subscription operation to the queue.

func (s *Queue) Len() int

Len returns the number of messages in the queue.

func (s *Queue) Pop() *Subscription

Pop gets the oldest subscription operation in the queue and drops it.

type Subscription struct {
	Type  OperationType
	Topic string
	Cb    mqtt.MessageHandler
}

Subscription stores a request of subscription operation.