Versions in this module Expand all Collapse all v1 v1.0.2 Jul 4, 2018 Changes in this version + func MustFlushRedis(p *redis.Pool) + func MustResetDB(db *common.DBLogger) + func NewNetworkServerPool(client *NetworkServerClient) nsclient.Pool + type Config struct + MQTTPassword string + MQTTServer string + MQTTUsername string + PostgresDSN string + RedisURL string + func GetConfig() *Config + type NetworkServerClient struct + ActivateDeviceChan chan ns.ActivateDeviceRequest + ActivateDeviceResponse ns.ActivateDeviceResponse + CreateDeviceChan chan ns.CreateDeviceRequest + CreateDeviceProfileChan chan ns.CreateDeviceProfileRequest + CreateDeviceProfileResponse ns.CreateDeviceProfileResponse + CreateDeviceQueueItemChan chan ns.CreateDeviceQueueItemRequest + CreateDeviceQueueItemResponse ns.CreateDeviceQueueItemResponse + CreateDeviceResponse ns.CreateDeviceResponse + CreateGatewayChan chan ns.CreateGatewayRequest + CreateGatewayProfileChan chan ns.CreateGatewayProfileRequest + CreateGatewayProfileResponse ns.CreateGatewayProfileResponse + CreateGatewayResponse ns.CreateGatewayResponse + CreateMACCommandQueueItemChan chan ns.CreateMACCommandQueueItemRequest + CreateMACCommandQueueItemResponse ns.CreateMACCommandQueueItemResponse + CreateRoutingProfileChan chan ns.CreateRoutingProfileRequest + CreateRoutingProfileResponse ns.CreateRoutingProfileResponse + CreateServiceProfileChan chan ns.CreateServiceProfileRequest + CreateServiceProfileResponse ns.CreateServiceProfileResponse + DeactivateDeviceChan chan ns.DeactivateDeviceRequest + DeactivateDeviceResponse ns.DeactivateDeviceResponse + DeleteDeviceChan chan ns.DeleteDeviceRequest + DeleteDeviceProfileChan chan ns.DeleteDeviceProfileRequest + DeleteDeviceProfileResponse ns.DeleteDeviceProfileResponse + DeleteDeviceResponse ns.DeleteDeviceResponse + DeleteGatewayChan chan ns.DeleteGatewayRequest + DeleteGatewayProfileChan chan ns.DeleteGatewayProfileRequest + DeleteGatewayProfileResponse ns.DeleteGatewayProfileResponse + DeleteGatewayResponse ns.DeleteGatewayResponse + DeleteRoutingProfileChan chan ns.DeleteRoutingProfileRequest + DeleteRoutingProfileResponse ns.DeleteRoutingProfileResponse + DeleteServiceProfileChan chan ns.DeleteServiceProfileRequest + DeleteServiceProfileResponse ns.DeleteServiceProfileResponse + FlushDeviceQueueForDevEUIChan chan ns.FlushDeviceQueueForDevEUIRequest + FlushDeviceQueueForDevEUIResponse ns.FlushDeviceQueueForDevEUIResponse + GetDeviceActivationChan chan ns.GetDeviceActivationRequest + GetDeviceActivationResponse ns.GetDeviceActivationResponse + GetDeviceChan chan ns.GetDeviceRequest + GetDeviceProfileChan chan ns.GetDeviceProfileRequest + GetDeviceProfileResponse ns.GetDeviceProfileResponse + GetDeviceQueueItemsForDevEUIChan chan ns.GetDeviceQueueItemsForDevEUIRequest + GetDeviceQueueItemsForDevEUIResponse ns.GetDeviceQueueItemsForDevEUIResponse + GetDeviceResponse ns.GetDeviceResponse + GetGatewayChan chan ns.GetGatewayRequest + GetGatewayProfileChan chan ns.GetGatewayProfileRequest + GetGatewayProfileResponse ns.GetGatewayProfileResponse + GetGatewayResponse ns.GetGatewayResponse + GetGatewayStatsChan chan ns.GetGatewayStatsRequest + GetGatewayStatsResponse ns.GetGatewayStatsResponse + GetNextDownlinkFCntForDevEUIChan chan ns.GetNextDownlinkFCntForDevEUIRequest + GetNextDownlinkFCntForDevEUIResponse ns.GetNextDownlinkFCntForDevEUIResponse + GetRandomDevAddrChan chan ns.GetRandomDevAddrRequest + GetRandomDevAddrResponse ns.GetRandomDevAddrResponse + GetRoutingProfileChan chan ns.GetRoutingProfileRequest + GetRoutingProfileResponse ns.GetRoutingProfileResponse + GetServiceProfileChan chan ns.GetServiceProfileRequest + GetServiceProfileResponse ns.GetServiceProfileResponse + GetVersionResponse ns.GetVersionResponse + SendProprietaryPayloadChan chan ns.SendProprietaryPayloadRequest + SendProprietaryPayloadResponse ns.SendProprietaryPayloadResponse + UpdateDeviceChan chan ns.UpdateDeviceRequest + UpdateDeviceProfileChan chan ns.UpdateDeviceProfileRequest + UpdateDeviceProfileResponse ns.UpdateDeviceProfileResponse + UpdateDeviceResponse ns.UpdateDeviceResponse + UpdateGatewayChan chan ns.UpdateGatewayRequest + UpdateGatewayProfileChan chan ns.UpdateGatewayProfileRequest + UpdateGatewayProfileResponse ns.UpdateGatewayProfileResponse + UpdateGatewayResponse ns.UpdateGatewayResponse + UpdateRoutingProfileChan chan ns.UpdateRoutingProfileRequest + UpdateRoutingProfileResponse ns.UpdateRoutingProfileResponse + UpdateServiceProfileChan chan ns.UpdateServiceProfileRequest + UpdateServiceProfileResponse ns.UpdateServiceProfileResponse + func NewNetworkServerClient() *NetworkServerClient + func (n *NetworkServerClient) ActivateDevice(ctx context.Context, in *ns.ActivateDeviceRequest, opts ...grpc.CallOption) (*ns.ActivateDeviceResponse, error) + func (n *NetworkServerClient) CreateDevice(ctx context.Context, in *ns.CreateDeviceRequest, opts ...grpc.CallOption) (*ns.CreateDeviceResponse, error) + func (n *NetworkServerClient) CreateDeviceProfile(ctx context.Context, in *ns.CreateDeviceProfileRequest, ...) (*ns.CreateDeviceProfileResponse, error) + func (n *NetworkServerClient) CreateGateway(ctx context.Context, in *ns.CreateGatewayRequest, opts ...grpc.CallOption) (*ns.CreateGatewayResponse, error) + func (n *NetworkServerClient) CreateGatewayProfile(ctx context.Context, in *ns.CreateGatewayProfileRequest, ...) (*ns.CreateGatewayProfileResponse, error) + func (n *NetworkServerClient) CreateMACCommandQueueItem(ctx context.Context, in *ns.CreateMACCommandQueueItemRequest, ...) (*ns.CreateMACCommandQueueItemResponse, error) + func (n *NetworkServerClient) CreateRoutingProfile(ctx context.Context, in *ns.CreateRoutingProfileRequest, ...) (*ns.CreateRoutingProfileResponse, error) + func (n *NetworkServerClient) CreateServiceProfile(ctx context.Context, in *ns.CreateServiceProfileRequest, ...) (*ns.CreateServiceProfileResponse, error) + func (n *NetworkServerClient) DeactivateDevice(ctx context.Context, in *ns.DeactivateDeviceRequest, opts ...grpc.CallOption) (*ns.DeactivateDeviceResponse, error) + func (n *NetworkServerClient) DeleteDevice(ctx context.Context, in *ns.DeleteDeviceRequest, opts ...grpc.CallOption) (*ns.DeleteDeviceResponse, error) + func (n *NetworkServerClient) DeleteDeviceProfile(ctx context.Context, in *ns.DeleteDeviceProfileRequest, ...) (*ns.DeleteDeviceProfileResponse, error) + func (n *NetworkServerClient) DeleteGateway(ctx context.Context, in *ns.DeleteGatewayRequest, opts ...grpc.CallOption) (*ns.DeleteGatewayResponse, error) + func (n *NetworkServerClient) DeleteGatewayProfile(ctx context.Context, in *ns.DeleteGatewayProfileRequest, ...) (*ns.DeleteGatewayProfileResponse, error) + func (n *NetworkServerClient) DeleteRoutingProfile(ctx context.Context, in *ns.DeleteRoutingProfileRequest, ...) (*ns.DeleteRoutingProfileResponse, error) + func (n *NetworkServerClient) DeleteServiceProfile(ctx context.Context, in *ns.DeleteServiceProfileRequest, ...) (*ns.DeleteServiceProfileResponse, error) + func (n *NetworkServerClient) GetDevice(ctx context.Context, in *ns.GetDeviceRequest, opts ...grpc.CallOption) (*ns.GetDeviceResponse, error) + func (n *NetworkServerClient) GetDeviceActivation(ctx context.Context, in *ns.GetDeviceActivationRequest, ...) (*ns.GetDeviceActivationResponse, error) + func (n *NetworkServerClient) GetDeviceProfile(ctx context.Context, in *ns.GetDeviceProfileRequest, opts ...grpc.CallOption) (*ns.GetDeviceProfileResponse, error) + func (n *NetworkServerClient) GetGateway(ctx context.Context, in *ns.GetGatewayRequest, opts ...grpc.CallOption) (*ns.GetGatewayResponse, error) + func (n *NetworkServerClient) GetGatewayProfile(ctx context.Context, in *ns.GetGatewayProfileRequest, opts ...grpc.CallOption) (*ns.GetGatewayProfileResponse, error) + func (n *NetworkServerClient) GetGatewayStats(ctx context.Context, in *ns.GetGatewayStatsRequest, opts ...grpc.CallOption) (*ns.GetGatewayStatsResponse, error) + func (n *NetworkServerClient) GetRandomDevAddr(ctx context.Context, in *ns.GetRandomDevAddrRequest, opts ...grpc.CallOption) (*ns.GetRandomDevAddrResponse, error) + func (n *NetworkServerClient) GetRoutingProfile(ctx context.Context, in *ns.GetRoutingProfileRequest, opts ...grpc.CallOption) (*ns.GetRoutingProfileResponse, error) + func (n *NetworkServerClient) GetServiceProfile(ctx context.Context, in *ns.GetServiceProfileRequest, opts ...grpc.CallOption) (*ns.GetServiceProfileResponse, error) + func (n *NetworkServerClient) MigrateNodeToDeviceSession(ctx context.Context, in *ns.MigrateNodeToDeviceSessionRequest, ...) (*ns.MigrateNodeToDeviceSessionResponse, error) + func (n *NetworkServerClient) SendProprietaryPayload(ctx context.Context, in *ns.SendProprietaryPayloadRequest, ...) (*ns.SendProprietaryPayloadResponse, error) + func (n *NetworkServerClient) UpdateDevice(ctx context.Context, in *ns.UpdateDeviceRequest, opts ...grpc.CallOption) (*ns.UpdateDeviceResponse, error) + func (n *NetworkServerClient) UpdateDeviceProfile(ctx context.Context, in *ns.UpdateDeviceProfileRequest, ...) (*ns.UpdateDeviceProfileResponse, error) + func (n *NetworkServerClient) UpdateGateway(ctx context.Context, in *ns.UpdateGatewayRequest, opts ...grpc.CallOption) (*ns.UpdateGatewayResponse, error) + func (n *NetworkServerClient) UpdateGatewayProfile(ctx context.Context, in *ns.UpdateGatewayProfileRequest, ...) (*ns.UpdateGatewayProfileResponse, error) + func (n *NetworkServerClient) UpdateRoutingProfile(ctx context.Context, in *ns.UpdateRoutingProfileRequest, ...) (*ns.UpdateRoutingProfileResponse, error) + func (n *NetworkServerClient) UpdateServiceProfile(ctx context.Context, in *ns.UpdateServiceProfileRequest, ...) (*ns.UpdateServiceProfileResponse, error) + func (n NetworkServerClient) CreateDeviceQueueItem(ctx context.Context, in *ns.CreateDeviceQueueItemRequest, ...) (*ns.CreateDeviceQueueItemResponse, error) + func (n NetworkServerClient) FlushDeviceQueueForDevEUI(ctx context.Context, in *ns.FlushDeviceQueueForDevEUIRequest, ...) (*ns.FlushDeviceQueueForDevEUIResponse, error) + func (n NetworkServerClient) GetDeviceQueueItemsForDevEUI(ctx context.Context, in *ns.GetDeviceQueueItemsForDevEUIRequest, ...) (*ns.GetDeviceQueueItemsForDevEUIResponse, error) + func (n NetworkServerClient) GetNextDownlinkFCntForDevEUI(ctx context.Context, in *ns.GetNextDownlinkFCntForDevEUIRequest, ...) (*ns.GetNextDownlinkFCntForDevEUIResponse, error) + func (n NetworkServerClient) GetVersion(ctx context.Context, in *ns.GetVersionRequest, opts ...grpc.CallOption) (*ns.GetVersionResponse, error) + func (n NetworkServerClient) MigrateChannelConfigurationToGatewayProfile(ctx context.Context, in *ns.MigrateChannelConfigurationToGatewayProfileRequest, ...) (*ns.MigrateChannelConfigurationToGatewayProfileResponse, error) + func (n NetworkServerClient) StreamFrameLogsForDevice(ctx context.Context, in *ns.StreamFrameLogsForDeviceRequest, ...) (ns.NetworkServer_StreamFrameLogsForDeviceClient, error) + func (n NetworkServerClient) StreamFrameLogsForGateway(ctx context.Context, in *ns.StreamFrameLogsForGatewayRequest, ...) (ns.NetworkServer_StreamFrameLogsForGatewayClient, error) + type NetworkServerPool struct + Client ns.NetworkServerClient + GetHostname string + func (p *NetworkServerPool) Get(hostname string, caCert, tlsCert, tlsKey []byte) (ns.NetworkServerClient, error)