multicast

package
v2.3.0+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 11, 2018 License: MIT Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidFCnt = errors.New("invalid frame-counter value")
)

Errors

Functions

func EnqueueQueueItem

func EnqueueQueueItem(p *redis.Pool, db sqlx.Ext, qi storage.MulticastQueueItem) error

EnqueueQueueItem selects the gateways that must be used to cover all devices within the multicast-group and creates a queue-item for each individial gateway. Note that an enqueue action increments the frame-counter of the multicast-group.

func GetMinimumGatewaySet

func GetMinimumGatewaySet(rxInfoSets []storage.DeviceGatewayRXInfoSet) ([]lorawan.EUI64, error)

GetMinimumGatewaySet returns the minimum set of gateways to cover all devices.

func HandleScheduleNextQueueItem

func HandleScheduleNextQueueItem(db sqlx.Ext, mg storage.MulticastGroup) error

HandleScheduleNextQueueItem handles the scheduling of the next queue-item for the given multicast-group.

func HandleScheduleQueueItem

func HandleScheduleQueueItem(db sqlx.Ext, qi storage.MulticastQueueItem) error

HandleScheduleQueueItem handles the scheduling of the given queue-item.

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL