multicast

Documentation

Index

• Variables
• func EnqueueQueueItem(ctx context.Context, db sqlx.Ext, qi storage.MulticastQueueItem) error
• func GetMinimumGatewaySet(rxInfoSets []storage.DeviceGatewayRXInfoSet) ([]lorawan.EUI64, error)
• func HandleScheduleQueueItem(ctx context.Context, db sqlx.Ext, qi storage.MulticastQueueItem) error
• func Setup(conf config.Config) error

Variables

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

Errors

Functions

func EnqueueQueueItem

func EnqueueQueueItem(ctx context.Context, 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 HandleScheduleQueueItem

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

HandleScheduleQueueItem handles the scheduling of the given queue-item.

func Setup

func Setup(conf config.Config) error

Setup sets up the multicast package.