Versions in this module Expand all Collapse all v1 v1.0.0 Oct 30, 2019 Changes in this version + func GetConfig() config.Config + func MustFlushRedis(p *redis.Pool) + func MustPrefillRedisPool(p *redis.Pool, count int) + func MustResetDB(db *sqlx.DB) + func NewApplicationServerPool(client *ApplicationClient) asclient.Pool + type ApplicationClient struct + HandleDataUpChan chan as.HandleUplinkDataRequest + HandleDataUpErr error + HandleDataUpResponse empty.Empty + HandleDownlinkACKChan chan as.HandleDownlinkACKRequest + HandleDownlinkACKErr error + HandleDownlinkACKResponse empty.Empty + HandleErrorChan chan as.HandleErrorRequest + HandleErrorResponse empty.Empty + HandleGatewayStatsChan chan as.HandleGatewayStatsRequest + HandleGatewayStatsResponse empty.Empty + HandleProprietaryUpChan chan as.HandleProprietaryUplinkRequest + HandleProprietaryUpErr error + HandleProprietaryUpResponse empty.Empty + SetDeviceLocationChan chan as.SetDeviceLocationRequest + SetDeviceLocationErrror error + SetDeviceLocationResponse empty.Empty + SetDeviceStatusChan chan as.SetDeviceStatusRequest + SetDeviceStatusError error + SetDeviceStatusResponse empty.Empty + func NewApplicationClient() *ApplicationClient + func (t *ApplicationClient) HandleDownlinkACK(ctx context.Context, in *as.HandleDownlinkACKRequest, opts ...grpc.CallOption) (*empty.Empty, error) + func (t *ApplicationClient) HandleError(ctx context.Context, in *as.HandleErrorRequest, opts ...grpc.CallOption) (*empty.Empty, error) + func (t *ApplicationClient) HandleGatewayStats(ctx context.Context, in *as.HandleGatewayStatsRequest, opts ...grpc.CallOption) (*empty.Empty, error) + func (t *ApplicationClient) HandleProprietaryUplink(ctx context.Context, in *as.HandleProprietaryUplinkRequest, ...) (*empty.Empty, error) + func (t *ApplicationClient) HandleUplinkData(ctx context.Context, in *as.HandleUplinkDataRequest, opts ...grpc.CallOption) (*empty.Empty, error) + func (t *ApplicationClient) SetDeviceLocation(ctx context.Context, in *as.SetDeviceLocationRequest, opts ...grpc.CallOption) (*empty.Empty, error) + func (t *ApplicationClient) SetDeviceStatus(ctx context.Context, in *as.SetDeviceStatusRequest, opts ...grpc.CallOption) (*empty.Empty, error) + type ApplicationServerPool struct + Client as.ApplicationServerServiceClient + GetHostname string + func (p *ApplicationServerPool) Get(hostname string, caCert, tlsCert, tlsKey []byte) (as.ApplicationServerServiceClient, error) + type Config struct + MQTTPassword string + MQTTServer string + MQTTUsername string + PostgresDSN string + RedisURL string + type GatewayBackend struct + GatewayConfigPacketChan chan gw.GatewayConfiguration + TXPacketChan chan gw.DownlinkFrame + func NewGatewayBackend() *GatewayBackend + func (b *GatewayBackend) Close() error + func (b *GatewayBackend) DownlinkTXAckChan() chan gw.DownlinkTXAck + func (b *GatewayBackend) RXPacketChan() chan gw.UplinkFrame + func (b *GatewayBackend) SendGatewayConfigPacket(config gw.GatewayConfiguration) error + func (b *GatewayBackend) SendTXPacket(txPacket gw.DownlinkFrame) error + func (b *GatewayBackend) StatsPacketChan() chan gw.GatewayStats + type GeolocationClient struct + ResolveMultiFrameTDOAChan chan geo.ResolveMultiFrameTDOARequest + ResolveMultiFrameTDOAResponse geo.ResolveMultiFrameTDOAResponse + ResolveTDOAChan chan geo.ResolveTDOARequest + ResolveTDOAResponse geo.ResolveTDOAResponse + func NewGeolocationClient() *GeolocationClient + func (g *GeolocationClient) ResolveMultiFrameTDOA(ctx context.Context, in *geo.ResolveMultiFrameTDOARequest, ...) (*geo.ResolveMultiFrameTDOAResponse, error) + func (g *GeolocationClient) ResolveTDOA(ctx context.Context, in *geo.ResolveTDOARequest, opts ...grpc.CallOption) (*geo.ResolveTDOAResponse, error) + type NetworkControllerClient struct + HandleDataUpMACCommandChan chan nc.HandleUplinkMACCommandRequest + HandleDataUpMACCommandResponse empty.Empty + HandleRXInfoChan chan nc.HandleUplinkMetaDataRequest + HandleRXInfoResponse empty.Empty + func NewNetworkControllerClient() *NetworkControllerClient + func (t *NetworkControllerClient) HandleUplinkMACCommand(ctx context.Context, in *nc.HandleUplinkMACCommandRequest, ...) (*empty.Empty, error) + func (t *NetworkControllerClient) HandleUplinkMetaData(ctx context.Context, in *nc.HandleUplinkMetaDataRequest, ...) (*empty.Empty, error)
Go to main page