test

Documentation

Overview

Package test contains testing utilities usable by all subpackages of networkserver excluding itself.

Index

• Variables
• func HandleApplicationUplinkQueueTest(t *testing.T, q ApplicationUplinkQueue, consumerIDs []string)
• func HandleDeviceRegistryTest(t *testing.T, reg DeviceRegistry)
• func HandleDownlinkTaskQueueTest(t *testing.T, q DownlinkTaskQueue, consumerIDs []string)
• func NewRedisApplicationUplinkQueue(ctx context.Context) (ApplicationUplinkQueue, func())
• func NewRedisDeviceRegistry(ctx context.Context) (DeviceRegistry, func())
• func NewRedisDownlinkTaskQueue(ctx context.Context) (DownlinkTaskQueue, func())
• func NewRedisScheduledDownlinkMatcher(ctx context.Context) (ScheduledDownlinkMatcher, func())
• func NewRedisUplinkDeduplicator(ctx context.Context) (UplinkDeduplicator, func())
• type TaskPopFuncResponse

Variables

var (
	CacheTTL           = (1 << 6) * test.Delay
	DefaultMACSettings = DefaultConfig.DefaultMACSettings.Parse()
)

Functions

func HandleApplicationUplinkQueueTest

func HandleApplicationUplinkQueueTest(t *testing.T, q ApplicationUplinkQueue, consumerIDs []string)

HandleApplicationUplinkQueueTest runs a ApplicationUplinkQueue test suite on reg.

func HandleDeviceRegistryTest

func HandleDeviceRegistryTest(t *testing.T, reg DeviceRegistry)

HandleDeviceRegistryTest runs a DeviceRegistry test suite on reg.

func HandleDownlinkTaskQueueTest

func HandleDownlinkTaskQueueTest(t *testing.T, q DownlinkTaskQueue, consumerIDs []string)

HandleDownlinkTaskQueueTest runs a DownlinkTaskQueue test suite on reg.

func NewRedisApplicationUplinkQueue

func NewRedisApplicationUplinkQueue(ctx context.Context) (ApplicationUplinkQueue, func())

func NewRedisDeviceRegistry

func NewRedisDeviceRegistry(ctx context.Context) (DeviceRegistry, func())

func NewRedisDownlinkTaskQueue

func NewRedisDownlinkTaskQueue(ctx context.Context) (DownlinkTaskQueue, func())

func NewRedisScheduledDownlinkMatcher

func NewRedisScheduledDownlinkMatcher(ctx context.Context) (ScheduledDownlinkMatcher, func())

func NewRedisUplinkDeduplicator

func NewRedisUplinkDeduplicator(ctx context.Context) (UplinkDeduplicator, func())

Types

type TaskPopFuncResponse

type TaskPopFuncResponse struct {
	Time  time.Time
	Error error
}