test

package
v1.0.1 Latest Latest
Warning

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

 Go to latest Published: May 30, 2018 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func MustFlushRedis 

func MustFlushRedis(p *redis.Pool)

MustFlushRedis flushes the Redis storage.

func MustResetDB 

func MustResetDB(db *common.DBLogger)

MustResetDB re-applies all database migrations.

func NewNetworkServerPool 

func NewNetworkServerPool(client *NetworkServerClient) nsclient.Pool

NewNetworkServerPool creates a network-server client pool which always returns the given client on Get.

Types

type Config 

type Config struct {
	PostgresDSN  string
	RedisURL     string
	MQTTServer   string
	MQTTUsername string
	MQTTPassword string
}

Config contains the test configuration.

func GetConfig 

func GetConfig() *Config

GetConfig returns the test configuration.

type NetworkServerClient 

type NetworkServerClient struct {
	CreateServiceProfileChan     chan ns.CreateServiceProfileRequest
	CreateServiceProfileResponse ns.CreateServiceProfileResponse

	GetServiceProfileChan     chan ns.GetServiceProfileRequest
	GetServiceProfileResponse ns.GetServiceProfileResponse

	UpdateServiceProfileChan     chan ns.UpdateServiceProfileRequest
	UpdateServiceProfileResponse ns.UpdateServiceProfileResponse

	DeleteServiceProfileChan     chan ns.DeleteServiceProfileRequest
	DeleteServiceProfileResponse ns.DeleteServiceProfileResponse

	CreateRoutingProfileChan     chan ns.CreateRoutingProfileRequest
	CreateRoutingProfileResponse ns.CreateRoutingProfileResponse

	GetRoutingProfileChan     chan ns.GetRoutingProfileRequest
	GetRoutingProfileResponse ns.GetRoutingProfileResponse

	UpdateRoutingProfileChan     chan ns.UpdateRoutingProfileRequest
	UpdateRoutingProfileResponse ns.UpdateRoutingProfileResponse

	DeleteRoutingProfileChan     chan ns.DeleteRoutingProfileRequest
	DeleteRoutingProfileResponse ns.DeleteRoutingProfileResponse

	CreateDeviceProfileChan     chan ns.CreateDeviceProfileRequest
	CreateDeviceProfileResponse ns.CreateDeviceProfileResponse

	GetDeviceProfileChan     chan ns.GetDeviceProfileRequest
	GetDeviceProfileResponse ns.GetDeviceProfileResponse

	UpdateDeviceProfileChan     chan ns.UpdateDeviceProfileRequest
	UpdateDeviceProfileResponse ns.UpdateDeviceProfileResponse

	DeleteDeviceProfileChan     chan ns.DeleteDeviceProfileRequest
	DeleteDeviceProfileResponse ns.DeleteDeviceProfileResponse

	CreateDeviceChan     chan ns.CreateDeviceRequest
	CreateDeviceResponse ns.CreateDeviceResponse

	GetDeviceChan     chan ns.GetDeviceRequest
	GetDeviceResponse ns.GetDeviceResponse

	UpdateDeviceChan     chan ns.UpdateDeviceRequest
	UpdateDeviceResponse ns.UpdateDeviceResponse

	DeleteDeviceChan     chan ns.DeleteDeviceRequest
	DeleteDeviceResponse ns.DeleteDeviceResponse

	ActivateDeviceChan     chan ns.ActivateDeviceRequest
	ActivateDeviceResponse ns.ActivateDeviceResponse

	DeactivateDeviceChan     chan ns.DeactivateDeviceRequest
	DeactivateDeviceResponse ns.DeactivateDeviceResponse

	GetDeviceActivationChan     chan ns.GetDeviceActivationRequest
	GetDeviceActivationResponse ns.GetDeviceActivationResponse

	GetRandomDevAddrChan     chan ns.GetRandomDevAddrRequest
	GetRandomDevAddrResponse ns.GetRandomDevAddrResponse

	CreateMACCommandQueueItemChan     chan ns.CreateMACCommandQueueItemRequest
	CreateMACCommandQueueItemResponse ns.CreateMACCommandQueueItemResponse

	SendProprietaryPayloadChan     chan ns.SendProprietaryPayloadRequest
	SendProprietaryPayloadResponse ns.SendProprietaryPayloadResponse

	CreateGatewayChan     chan ns.CreateGatewayRequest
	CreateGatewayResponse ns.CreateGatewayResponse

	GetGatewayChan     chan ns.GetGatewayRequest
	GetGatewayResponse ns.GetGatewayResponse

	UpdateGatewayChan     chan ns.UpdateGatewayRequest
	UpdateGatewayResponse ns.UpdateGatewayResponse

	DeleteGatewayChan     chan ns.DeleteGatewayRequest
	DeleteGatewayResponse ns.DeleteGatewayResponse

	GetGatewayStatsChan     chan ns.GetGatewayStatsRequest
	GetGatewayStatsResponse ns.GetGatewayStatsResponse

	CreateGatewayProfileChan     chan ns.CreateGatewayProfileRequest
	CreateGatewayProfileResponse ns.CreateGatewayProfileResponse

	GetGatewayProfileChan     chan ns.GetGatewayProfileRequest
	GetGatewayProfileResponse ns.GetGatewayProfileResponse

	UpdateGatewayProfileChan     chan ns.UpdateGatewayProfileRequest
	UpdateGatewayProfileResponse ns.UpdateGatewayProfileResponse

	DeleteGatewayProfileChan     chan ns.DeleteGatewayProfileRequest
	DeleteGatewayProfileResponse ns.DeleteGatewayProfileResponse

	CreateDeviceQueueItemChan     chan ns.CreateDeviceQueueItemRequest
	CreateDeviceQueueItemResponse ns.CreateDeviceQueueItemResponse

	FlushDeviceQueueForDevEUIChan     chan ns.FlushDeviceQueueForDevEUIRequest
	FlushDeviceQueueForDevEUIResponse ns.FlushDeviceQueueForDevEUIResponse

	GetDeviceQueueItemsForDevEUIChan     chan ns.GetDeviceQueueItemsForDevEUIRequest
	GetDeviceQueueItemsForDevEUIResponse ns.GetDeviceQueueItemsForDevEUIResponse

	GetNextDownlinkFCntForDevEUIChan     chan ns.GetNextDownlinkFCntForDevEUIRequest
	GetNextDownlinkFCntForDevEUIResponse ns.GetNextDownlinkFCntForDevEUIResponse

	GetVersionResponse ns.GetVersionResponse
}

NetworkServerClient is a test network-server client.

func NewNetworkServerClient 

func NewNetworkServerClient() *NetworkServerClient

NewNetworkServerClient creates a new NetworkServerClient.

func (*NetworkServerClient) ActivateDevice 

func (n *NetworkServerClient) ActivateDevice(ctx context.Context, in *ns.ActivateDeviceRequest, opts ...grpc.CallOption) (*ns.ActivateDeviceResponse, error)

ActivateDevice method.

func (*NetworkServerClient) CreateDevice 

func (n *NetworkServerClient) CreateDevice(ctx context.Context, in *ns.CreateDeviceRequest, opts ...grpc.CallOption) (*ns.CreateDeviceResponse, error)

CreateDevice method.

func (*NetworkServerClient) CreateDeviceProfile 

func (n *NetworkServerClient) CreateDeviceProfile(ctx context.Context, in *ns.CreateDeviceProfileRequest, opts ...grpc.CallOption) (*ns.CreateDeviceProfileResponse, error)

CreateDeviceProfile method.

func (NetworkServerClient) CreateDeviceQueueItem 

func (n NetworkServerClient) CreateDeviceQueueItem(ctx context.Context, in *ns.CreateDeviceQueueItemRequest, opts ...grpc.CallOption) (*ns.CreateDeviceQueueItemResponse, error)

CreateDeviceQueueItem method.

func (*NetworkServerClient) CreateGateway 

func (n *NetworkServerClient) CreateGateway(ctx context.Context, in *ns.CreateGatewayRequest, opts ...grpc.CallOption) (*ns.CreateGatewayResponse, error)

CreateGateway method.

func (*NetworkServerClient) CreateGatewayProfile 

func (n *NetworkServerClient) CreateGatewayProfile(ctx context.Context, in *ns.CreateGatewayProfileRequest, opts ...grpc.CallOption) (*ns.CreateGatewayProfileResponse, error)

CreateGatewayProfile method.

func (*NetworkServerClient) CreateMACCommandQueueItem 

func (n *NetworkServerClient) CreateMACCommandQueueItem(ctx context.Context, in *ns.CreateMACCommandQueueItemRequest, opts ...grpc.CallOption) (*ns.CreateMACCommandQueueItemResponse, error)

CreateMACCommandQueueItem method.

func (*NetworkServerClient) CreateRoutingProfile 

func (n *NetworkServerClient) CreateRoutingProfile(ctx context.Context, in *ns.CreateRoutingProfileRequest, opts ...grpc.CallOption) (*ns.CreateRoutingProfileResponse, error)

CreateRoutingProfile method.

func (*NetworkServerClient) CreateServiceProfile 

func (n *NetworkServerClient) CreateServiceProfile(ctx context.Context, in *ns.CreateServiceProfileRequest, opts ...grpc.CallOption) (*ns.CreateServiceProfileResponse, error)

CreateServiceProfile method.

func (*NetworkServerClient) DeactivateDevice 

func (n *NetworkServerClient) DeactivateDevice(ctx context.Context, in *ns.DeactivateDeviceRequest, opts ...grpc.CallOption) (*ns.DeactivateDeviceResponse, error)

DeactivateDevice method.

func (*NetworkServerClient) DeleteDevice 

func (n *NetworkServerClient) DeleteDevice(ctx context.Context, in *ns.DeleteDeviceRequest, opts ...grpc.CallOption) (*ns.DeleteDeviceResponse, error)

DeleteDevice method.

func (*NetworkServerClient) DeleteDeviceProfile 

func (n *NetworkServerClient) DeleteDeviceProfile(ctx context.Context, in *ns.DeleteDeviceProfileRequest, opts ...grpc.CallOption) (*ns.DeleteDeviceProfileResponse, error)

DeleteDeviceProfile method.

func (*NetworkServerClient) DeleteGateway 

func (n *NetworkServerClient) DeleteGateway(ctx context.Context, in *ns.DeleteGatewayRequest, opts ...grpc.CallOption) (*ns.DeleteGatewayResponse, error)

DeleteGateway method.

func (*NetworkServerClient) DeleteGatewayProfile 

func (n *NetworkServerClient) DeleteGatewayProfile(ctx context.Context, in *ns.DeleteGatewayProfileRequest, opts ...grpc.CallOption) (*ns.DeleteGatewayProfileResponse, error)

DeleteGatewayProfile method.

func (*NetworkServerClient) DeleteRoutingProfile 

func (n *NetworkServerClient) DeleteRoutingProfile(ctx context.Context, in *ns.DeleteRoutingProfileRequest, opts ...grpc.CallOption) (*ns.DeleteRoutingProfileResponse, error)

DeleteRoutingProfile method.

func (*NetworkServerClient) DeleteServiceProfile 

func (n *NetworkServerClient) DeleteServiceProfile(ctx context.Context, in *ns.DeleteServiceProfileRequest, opts ...grpc.CallOption) (*ns.DeleteServiceProfileResponse, error)

DeleteServiceProfile method.

func (NetworkServerClient) FlushDeviceQueueForDevEUI 

func (n NetworkServerClient) FlushDeviceQueueForDevEUI(ctx context.Context, in *ns.FlushDeviceQueueForDevEUIRequest, opts ...grpc.CallOption) (*ns.FlushDeviceQueueForDevEUIResponse, error)

FlushDeviceQueueForDevEUI method.

func (*NetworkServerClient) GetDevice 

func (n *NetworkServerClient) GetDevice(ctx context.Context, in *ns.GetDeviceRequest, opts ...grpc.CallOption) (*ns.GetDeviceResponse, error)

GetDevice method.

func (*NetworkServerClient) GetDeviceActivation 

func (n *NetworkServerClient) GetDeviceActivation(ctx context.Context, in *ns.GetDeviceActivationRequest, opts ...grpc.CallOption) (*ns.GetDeviceActivationResponse, error)

GetDeviceActivation method.

func (*NetworkServerClient) GetDeviceProfile 

func (n *NetworkServerClient) GetDeviceProfile(ctx context.Context, in *ns.GetDeviceProfileRequest, opts ...grpc.CallOption) (*ns.GetDeviceProfileResponse, error)

GetDeviceProfile method.

func (NetworkServerClient) GetDeviceQueueItemsForDevEUI 

func (n NetworkServerClient) GetDeviceQueueItemsForDevEUI(ctx context.Context, in *ns.GetDeviceQueueItemsForDevEUIRequest, opts ...grpc.CallOption) (*ns.GetDeviceQueueItemsForDevEUIResponse, error)

GetDeviceQueueItemsForDevEUI method.

func (*NetworkServerClient) GetGateway 

func (n *NetworkServerClient) GetGateway(ctx context.Context, in *ns.GetGatewayRequest, opts ...grpc.CallOption) (*ns.GetGatewayResponse, error)

GetGateway method.

func (*NetworkServerClient) GetGatewayProfile 

func (n *NetworkServerClient) GetGatewayProfile(ctx context.Context, in *ns.GetGatewayProfileRequest, opts ...grpc.CallOption) (*ns.GetGatewayProfileResponse, error)

GetGatewayProfile method.

func (*NetworkServerClient) GetGatewayStats 

func (n *NetworkServerClient) GetGatewayStats(ctx context.Context, in *ns.GetGatewayStatsRequest, opts ...grpc.CallOption) (*ns.GetGatewayStatsResponse, error)

GetGatewayStats method.

func (NetworkServerClient) GetNextDownlinkFCntForDevEUI 

func (n NetworkServerClient) GetNextDownlinkFCntForDevEUI(ctx context.Context, in *ns.GetNextDownlinkFCntForDevEUIRequest, opts ...grpc.CallOption) (*ns.GetNextDownlinkFCntForDevEUIResponse, error)

GetNextDownlinkFCntForDevEUI method.

func (*NetworkServerClient) GetRandomDevAddr 

func (n *NetworkServerClient) GetRandomDevAddr(ctx context.Context, in *ns.GetRandomDevAddrRequest, opts ...grpc.CallOption) (*ns.GetRandomDevAddrResponse, error)

GetRandomDevAddr method.

func (*NetworkServerClient) GetRoutingProfile 

func (n *NetworkServerClient) GetRoutingProfile(ctx context.Context, in *ns.GetRoutingProfileRequest, opts ...grpc.CallOption) (*ns.GetRoutingProfileResponse, error)

GetRoutingProfile method.

func (*NetworkServerClient) GetServiceProfile 

func (n *NetworkServerClient) GetServiceProfile(ctx context.Context, in *ns.GetServiceProfileRequest, opts ...grpc.CallOption) (*ns.GetServiceProfileResponse, error)

GetServiceProfile method.

func (NetworkServerClient) GetVersion 

func (n NetworkServerClient) GetVersion(ctx context.Context, in *ns.GetVersionRequest, opts ...grpc.CallOption) (*ns.GetVersionResponse, error)

GetVersion method.

func (NetworkServerClient) MigrateChannelConfigurationToGatewayProfile 

func (n NetworkServerClient) MigrateChannelConfigurationToGatewayProfile(ctx context.Context, in *ns.MigrateChannelConfigurationToGatewayProfileRequest, opts ...grpc.CallOption) (*ns.MigrateChannelConfigurationToGatewayProfileResponse, error)

MigrateChannelConfigurationToGatewayProfile method.

func (*NetworkServerClient) MigrateNodeToDeviceSession 

func (n *NetworkServerClient) MigrateNodeToDeviceSession(ctx context.Context, in *ns.MigrateNodeToDeviceSessionRequest, opts ...grpc.CallOption) (*ns.MigrateNodeToDeviceSessionResponse, error)

MigrateNodeToDeviceSession is not implemented.

func (*NetworkServerClient) SendProprietaryPayload 

func (n *NetworkServerClient) SendProprietaryPayload(ctx context.Context, in *ns.SendProprietaryPayloadRequest, opts ...grpc.CallOption) (*ns.SendProprietaryPayloadResponse, error)

SendProprietaryPayload method.

func (NetworkServerClient) StreamFrameLogsForDevice 

func (n NetworkServerClient) StreamFrameLogsForDevice(ctx context.Context, in *ns.StreamFrameLogsForDeviceRequest, opts ...grpc.CallOption) (ns.NetworkServer_StreamFrameLogsForDeviceClient, error)

StreamFrameLogsForDevice method.

func (NetworkServerClient) StreamFrameLogsForGateway 

func (n NetworkServerClient) StreamFrameLogsForGateway(ctx context.Context, in *ns.StreamFrameLogsForGatewayRequest, opts ...grpc.CallOption) (ns.NetworkServer_StreamFrameLogsForGatewayClient, error)

StreamFrameLogsForGateway method.

func (*NetworkServerClient) UpdateDevice 

func (n *NetworkServerClient) UpdateDevice(ctx context.Context, in *ns.UpdateDeviceRequest, opts ...grpc.CallOption) (*ns.UpdateDeviceResponse, error)

UpdateDevice method.

func (*NetworkServerClient) UpdateDeviceProfile 

func (n *NetworkServerClient) UpdateDeviceProfile(ctx context.Context, in *ns.UpdateDeviceProfileRequest, opts ...grpc.CallOption) (*ns.UpdateDeviceProfileResponse, error)

UpdateDeviceProfile method.

func (*NetworkServerClient) UpdateGateway 

func (n *NetworkServerClient) UpdateGateway(ctx context.Context, in *ns.UpdateGatewayRequest, opts ...grpc.CallOption) (*ns.UpdateGatewayResponse, error)

UpdateGateway method.

func (*NetworkServerClient) UpdateGatewayProfile 

func (n *NetworkServerClient) UpdateGatewayProfile(ctx context.Context, in *ns.UpdateGatewayProfileRequest, opts ...grpc.CallOption) (*ns.UpdateGatewayProfileResponse, error)

UpdateGatewayProfile method.

func (*NetworkServerClient) UpdateRoutingProfile 

func (n *NetworkServerClient) UpdateRoutingProfile(ctx context.Context, in *ns.UpdateRoutingProfileRequest, opts ...grpc.CallOption) (*ns.UpdateRoutingProfileResponse, error)

UpdateRoutingProfile method.

func (*NetworkServerClient) UpdateServiceProfile 

func (n *NetworkServerClient) UpdateServiceProfile(ctx context.Context, in *ns.UpdateServiceProfileRequest, opts ...grpc.CallOption) (*ns.UpdateServiceProfileResponse, error)

UpdateServiceProfile method.

type NetworkServerPool 

type NetworkServerPool struct {
	Client      ns.NetworkServerClient
	GetHostname string
}

NetworkServerPool is a network-server pool for testing.

func (*NetworkServerPool) Get 

func (p *NetworkServerPool) Get(hostname string, caCert, tlsCert, tlsKey []byte) (ns.NetworkServerClient, error)

Get returns the Client.

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.