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
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrInvalidFCnt = errors.New("invalid frame-counter value")
)
Errors
Functions ¶
func EnqueueQueueItem ¶
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.
Click to show internal directories.
Click to hide internal directories.