multicast

Documentation

Index

• Variables
• func EnqueueQueueItem(p *redis.Pool, db sqlx.Ext, qi storage.MulticastQueueItem) error
• func GetMinimumGatewaySet(rxInfoSets []storage.DeviceGatewayRXInfoSet) ([]lorawan.EUI64, error)
• func HandleScheduleNextQueueItem(db sqlx.Ext, mg storage.MulticastGroup) error
• func HandleScheduleQueueItem(db sqlx.Ext, qi storage.MulticastQueueItem) error

Variables

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.