Versions in this module Expand all Collapse all v1 v1.0.1 Jun 17, 2018 v1.0.0 May 28, 2018 Changes in this version + func MustFlushRedis(p *redis.Pool) + func MustPrefillRedisPool(p *redis.Pool, count int) + func MustResetDB(db *common.DBLogger) + func NewApplicationServerPool(client *ApplicationClient) asclient.Pool + func NewJoinServerPool(client jsclient.Client) jsclient.Pool + type ApplicationClient struct + HandleDataUpChan chan as.HandleUplinkDataRequest + HandleDataUpErr error + HandleDataUpResponse as.HandleUplinkDataResponse + HandleDownlinkACKChan chan as.HandleDownlinkACKRequest + HandleDownlinkACKErr error + HandleDownlinkACKResponse as.HandleDownlinkACKResponse + HandleErrorChan chan as.HandleErrorRequest + HandleErrorResponse as.HandleErrorResponse + HandleProprietaryUpChan chan as.HandleProprietaryUplinkRequest + HandleProprietaryUpErr error + HandleProprietaryUpResponse as.HandleProprietaryUplinkResponse + func NewApplicationClient() *ApplicationClient + func (t *ApplicationClient) HandleDownlinkACK(ctx context.Context, in *as.HandleDownlinkACKRequest, opts ...grpc.CallOption) (*as.HandleDownlinkACKResponse, error) + func (t *ApplicationClient) HandleError(ctx context.Context, in *as.HandleErrorRequest, opts ...grpc.CallOption) (*as.HandleErrorResponse, error) + func (t *ApplicationClient) HandleProprietaryUplink(ctx context.Context, in *as.HandleProprietaryUplinkRequest, ...) (*as.HandleProprietaryUplinkResponse, error) + func (t *ApplicationClient) HandleUplinkData(ctx context.Context, in *as.HandleUplinkDataRequest, opts ...grpc.CallOption) (*as.HandleUplinkDataResponse, error) + type ApplicationServerPool struct + Client as.ApplicationServerClient + GetHostname string + func (p *ApplicationServerPool) Get(hostname string, caCert, tlsCert, tlsKey []byte) (as.ApplicationServerClient, error) + type Config struct + PostgresDSN string + RedisURL string + func GetConfig() *Config + type GatewayBackend struct + GatewayConfigPacketChan chan gw.GatewayConfigPacket + TXPacketChan chan gw.TXPacket + func NewGatewayBackend() *GatewayBackend + func (b *GatewayBackend) Close() error + func (b *GatewayBackend) RXPacketChan() chan gw.RXPacket + func (b *GatewayBackend) SendGatewayConfigPacket(config gw.GatewayConfigPacket) error + func (b *GatewayBackend) SendTXPacket(txPacket gw.TXPacket) error + func (b *GatewayBackend) StatsPacketChan() chan gw.GatewayStatsPacket + type JoinServerClient struct + JoinAnsPayload backend.JoinAnsPayload + JoinReqError error + JoinReqPayloadChan chan backend.JoinReqPayload + func NewJoinServerClient() *JoinServerClient + func (c *JoinServerClient) JoinReq(pl backend.JoinReqPayload) (backend.JoinAnsPayload, error) + type JoinServerPool struct + Client jsclient.Client + GetJoinEUI lorawan.EUI64 + func (p *JoinServerPool) Get(joinEUI lorawan.EUI64) (jsclient.Client, error) + type NetworkControllerClient struct + HandleDataUpMACCommandChan chan nc.HandleDataUpMACCommandRequest + HandleDataUpMACCommandResponse nc.HandleDataUpMACCommandResponse + HandleRXInfoChan chan nc.HandleRXInfoRequest + HandleRXInfoResponse nc.HandleRXInfoResponse + func NewNetworkControllerClient() *NetworkControllerClient + func (t *NetworkControllerClient) HandleDataUpMACCommand(ctx context.Context, in *nc.HandleDataUpMACCommandRequest, ...) (*nc.HandleDataUpMACCommandResponse, error) + func (t *NetworkControllerClient) HandleRXInfo(ctx context.Context, in *nc.HandleRXInfoRequest, opts ...grpc.CallOption) (*nc.HandleRXInfoResponse, error)
Go to main page