Documentation ¶
Index ¶
- Variables
- func RegisterDiscoveryServer(s *grpc.Server, srv DiscoveryServer)
- func RegisterRouterServer(s *grpc.Server, srv RouterServer)
- type Announcement
- func (*Announcement) Descriptor() ([]byte, []int)
- func (m *Announcement) GetCertificate() string
- func (m *Announcement) GetId() string
- func (m *Announcement) GetNetAddress() string
- func (m *Announcement) GetPublicKey() string
- func (m *Announcement) GetServiceName() string
- func (m *Announcement) GetServiceVersion() string
- func (a *Announcement) GetTLSConfig() (*tls.Config, error)
- func (m *Announcement) Marshal() (dAtA []byte, err error)
- func (m *Announcement) MarshalTo(dAtA []byte) (int, error)
- func (m *Announcement) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Announcement) ProtoMessage()
- func (m *Announcement) Reset()
- func (m *Announcement) Size() (n int)
- func (m *Announcement) String() string
- func (m *Announcement) Unmarshal(dAtA []byte) error
- func (m *Announcement) XXX_DiscardUnknown()
- func (m *Announcement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Announcement) XXX_Merge(src proto.Message)
- func (m *Announcement) XXX_Size() int
- func (m *Announcement) XXX_Unmarshal(b []byte) error
- type DiscoveryClient
- type DiscoveryServer
- type DownlinkMessage
- func (*DownlinkMessage) Descriptor() ([]byte, []int)
- func (m *DownlinkMessage) GetGatewayConfiguration() *GatewayTxConfiguration
- func (m *DownlinkMessage) GetPayload() []byte
- func (m *DownlinkMessage) GetProtocolConfiguration() *ProtocolTxConfiguration
- func (m *DownlinkMessage) GetTrace() *Trace
- func (m *DownlinkMessage) Marshal() (dAtA []byte, err error)
- func (m *DownlinkMessage) MarshalTo(dAtA []byte) (int, error)
- func (m *DownlinkMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DownlinkMessage) ProtoMessage()
- func (m *DownlinkMessage) Reset()
- func (m *DownlinkMessage) Size() (n int)
- func (m *DownlinkMessage) String() string
- func (m *DownlinkMessage) Unmarshal(dAtA []byte) error
- func (m *DownlinkMessage) XXX_DiscardUnknown()
- func (m *DownlinkMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DownlinkMessage) XXX_Merge(src proto.Message)
- func (m *DownlinkMessage) XXX_Size() int
- func (m *DownlinkMessage) XXX_Unmarshal(b []byte) error
- type FrequencyPlan
- type GatewayRxMetadata
- func (*GatewayRxMetadata) Descriptor() ([]byte, []int)
- func (m *GatewayRxMetadata) GetAntennas() []*GatewayRxMetadata_Antenna
- func (m *GatewayRxMetadata) GetChannel() uint32
- func (m *GatewayRxMetadata) GetEncryptedTime() []byte
- func (m *GatewayRxMetadata) GetFrequency() uint64
- func (m *GatewayRxMetadata) GetGatewayId() string
- func (m *GatewayRxMetadata) GetGatewayTrusted() bool
- func (m *GatewayRxMetadata) GetLocation() *LocationMetadata
- func (m *GatewayRxMetadata) GetRfChain() uint32
- func (m *GatewayRxMetadata) GetRssi() float32
- func (m *GatewayRxMetadata) GetSnr() float32
- func (m *GatewayRxMetadata) GetTime() int64
- func (m *GatewayRxMetadata) GetTimestamp() uint32
- func (m *GatewayRxMetadata) Marshal() (dAtA []byte, err error)
- func (m *GatewayRxMetadata) MarshalTo(dAtA []byte) (int, error)
- func (m *GatewayRxMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GatewayRxMetadata) ProtoMessage()
- func (m *GatewayRxMetadata) Reset()
- func (m *GatewayRxMetadata) Size() (n int)
- func (m *GatewayRxMetadata) String() string
- func (m *GatewayRxMetadata) Unmarshal(dAtA []byte) error
- func (m *GatewayRxMetadata) XXX_DiscardUnknown()
- func (m *GatewayRxMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GatewayRxMetadata) XXX_Merge(src proto.Message)
- func (m *GatewayRxMetadata) XXX_Size() int
- func (m *GatewayRxMetadata) XXX_Unmarshal(b []byte) error
- type GatewayRxMetadata_Antenna
- func (*GatewayRxMetadata_Antenna) Descriptor() ([]byte, []int)
- func (m *GatewayRxMetadata_Antenna) GetAntenna() uint32
- func (m *GatewayRxMetadata_Antenna) GetChannel() uint32
- func (m *GatewayRxMetadata_Antenna) GetChannelRssi() float32
- func (m *GatewayRxMetadata_Antenna) GetEncryptedTime() []byte
- func (m *GatewayRxMetadata_Antenna) GetFineTime() int64
- func (m *GatewayRxMetadata_Antenna) GetFrequencyOffset() int64
- func (m *GatewayRxMetadata_Antenna) GetRssi() float32
- func (m *GatewayRxMetadata_Antenna) GetRssiStandardDeviation() float32
- func (m *GatewayRxMetadata_Antenna) GetSnr() float32
- func (m *GatewayRxMetadata_Antenna) Marshal() (dAtA []byte, err error)
- func (m *GatewayRxMetadata_Antenna) MarshalTo(dAtA []byte) (int, error)
- func (m *GatewayRxMetadata_Antenna) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GatewayRxMetadata_Antenna) ProtoMessage()
- func (m *GatewayRxMetadata_Antenna) Reset()
- func (m *GatewayRxMetadata_Antenna) Size() (n int)
- func (m *GatewayRxMetadata_Antenna) String() string
- func (m *GatewayRxMetadata_Antenna) Unmarshal(dAtA []byte) error
- func (m *GatewayRxMetadata_Antenna) XXX_DiscardUnknown()
- func (m *GatewayRxMetadata_Antenna) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GatewayRxMetadata_Antenna) XXX_Merge(src proto.Message)
- func (m *GatewayRxMetadata_Antenna) XXX_Size() int
- func (m *GatewayRxMetadata_Antenna) XXX_Unmarshal(b []byte) error
- type GatewayTxConfiguration
- func (*GatewayTxConfiguration) Descriptor() ([]byte, []int)
- func (m *GatewayTxConfiguration) GetFrequency() uint64
- func (m *GatewayTxConfiguration) GetFrequencyDeviation() uint32
- func (m *GatewayTxConfiguration) GetPolarizationInversion() bool
- func (m *GatewayTxConfiguration) GetPower() int32
- func (m *GatewayTxConfiguration) GetRfChain() uint32
- func (m *GatewayTxConfiguration) GetTimestamp() uint32
- func (m *GatewayTxConfiguration) Marshal() (dAtA []byte, err error)
- func (m *GatewayTxConfiguration) MarshalTo(dAtA []byte) (int, error)
- func (m *GatewayTxConfiguration) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GatewayTxConfiguration) ProtoMessage()
- func (m *GatewayTxConfiguration) Reset()
- func (m *GatewayTxConfiguration) Size() (n int)
- func (m *GatewayTxConfiguration) String() string
- func (m *GatewayTxConfiguration) Unmarshal(dAtA []byte) error
- func (m *GatewayTxConfiguration) XXX_DiscardUnknown()
- func (m *GatewayTxConfiguration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GatewayTxConfiguration) XXX_Merge(src proto.Message)
- func (m *GatewayTxConfiguration) XXX_Size() int
- func (m *GatewayTxConfiguration) XXX_Unmarshal(b []byte) error
- type GetRequest
- func (*GetRequest) Descriptor() ([]byte, []int)
- func (m *GetRequest) GetId() string
- func (m *GetRequest) GetServiceName() string
- func (m *GetRequest) Marshal() (dAtA []byte, err error)
- func (m *GetRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetRequest) ProtoMessage()
- func (m *GetRequest) Reset()
- func (m *GetRequest) Size() (n int)
- func (m *GetRequest) String() string
- func (m *GetRequest) Unmarshal(dAtA []byte) error
- func (m *GetRequest) XXX_DiscardUnknown()
- func (m *GetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetRequest) XXX_Merge(src proto.Message)
- func (m *GetRequest) XXX_Size() int
- func (m *GetRequest) XXX_Unmarshal(b []byte) error
- type LoRaWANMetadata
- func (*LoRaWANMetadata) Descriptor() ([]byte, []int)
- func (m *LoRaWANMetadata) GetBitRate() uint32
- func (m *LoRaWANMetadata) GetCodingRate() string
- func (m *LoRaWANMetadata) GetDataRate() string
- func (m *LoRaWANMetadata) GetFCnt() uint32
- func (m *LoRaWANMetadata) GetFrequencyPlan() FrequencyPlan
- func (m *LoRaWANMetadata) GetModulation() Modulation
- func (m *LoRaWANMetadata) Marshal() (dAtA []byte, err error)
- func (m *LoRaWANMetadata) MarshalTo(dAtA []byte) (int, error)
- func (m *LoRaWANMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LoRaWANMetadata) ProtoMessage()
- func (m *LoRaWANMetadata) Reset()
- func (m *LoRaWANMetadata) Size() (n int)
- func (m *LoRaWANMetadata) String() string
- func (m *LoRaWANMetadata) Unmarshal(dAtA []byte) error
- func (m *LoRaWANMetadata) XXX_DiscardUnknown()
- func (m *LoRaWANMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LoRaWANMetadata) XXX_Merge(src proto.Message)
- func (m *LoRaWANMetadata) XXX_Size() int
- func (m *LoRaWANMetadata) XXX_Unmarshal(b []byte) error
- type LoRaWANTxConfiguration
- func (*LoRaWANTxConfiguration) Descriptor() ([]byte, []int)
- func (m *LoRaWANTxConfiguration) GetBitRate() uint32
- func (m *LoRaWANTxConfiguration) GetCodingRate() string
- func (m *LoRaWANTxConfiguration) GetDataRate() string
- func (m *LoRaWANTxConfiguration) GetFCnt() uint32
- func (m *LoRaWANTxConfiguration) GetModulation() Modulation
- func (m *LoRaWANTxConfiguration) Marshal() (dAtA []byte, err error)
- func (m *LoRaWANTxConfiguration) MarshalTo(dAtA []byte) (int, error)
- func (m *LoRaWANTxConfiguration) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LoRaWANTxConfiguration) ProtoMessage()
- func (m *LoRaWANTxConfiguration) Reset()
- func (m *LoRaWANTxConfiguration) Size() (n int)
- func (m *LoRaWANTxConfiguration) String() string
- func (m *LoRaWANTxConfiguration) Unmarshal(dAtA []byte) error
- func (m *LoRaWANTxConfiguration) XXX_DiscardUnknown()
- func (m *LoRaWANTxConfiguration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LoRaWANTxConfiguration) XXX_Merge(src proto.Message)
- func (m *LoRaWANTxConfiguration) XXX_Size() int
- func (m *LoRaWANTxConfiguration) XXX_Unmarshal(b []byte) error
- type LocationMetadata
- func (*LocationMetadata) Descriptor() ([]byte, []int)
- func (m *LocationMetadata) GetAccuracy() int32
- func (m *LocationMetadata) GetAltitude() int32
- func (m *LocationMetadata) GetLatitude() float32
- func (m *LocationMetadata) GetLongitude() float32
- func (m *LocationMetadata) GetSource() LocationMetadata_LocationSource
- func (m *LocationMetadata) GetTime() int64
- func (m *LocationMetadata) Marshal() (dAtA []byte, err error)
- func (m *LocationMetadata) MarshalTo(dAtA []byte) (int, error)
- func (m *LocationMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LocationMetadata) ProtoMessage()
- func (m *LocationMetadata) Reset()
- func (m *LocationMetadata) Size() (n int)
- func (m *LocationMetadata) String() string
- func (m *LocationMetadata) Unmarshal(dAtA []byte) error
- func (m *LocationMetadata) Validate() bool
- func (m *LocationMetadata) XXX_DiscardUnknown()
- func (m *LocationMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LocationMetadata) XXX_Merge(src proto.Message)
- func (m *LocationMetadata) XXX_Size() int
- func (m *LocationMetadata) XXX_Unmarshal(b []byte) error
- type LocationMetadata_LocationSource
- type Modulation
- type ProtocolRxMetadata
- func (*ProtocolRxMetadata) Descriptor() ([]byte, []int)
- func (m *ProtocolRxMetadata) GetLorawan() *LoRaWANMetadata
- func (m *ProtocolRxMetadata) Marshal() (dAtA []byte, err error)
- func (m *ProtocolRxMetadata) MarshalTo(dAtA []byte) (int, error)
- func (m *ProtocolRxMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ProtocolRxMetadata) ProtoMessage()
- func (m *ProtocolRxMetadata) Reset()
- func (m *ProtocolRxMetadata) Size() (n int)
- func (m *ProtocolRxMetadata) String() string
- func (m *ProtocolRxMetadata) Unmarshal(dAtA []byte) error
- func (m *ProtocolRxMetadata) XXX_DiscardUnknown()
- func (m *ProtocolRxMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProtocolRxMetadata) XXX_Merge(src proto.Message)
- func (m *ProtocolRxMetadata) XXX_Size() int
- func (m *ProtocolRxMetadata) XXX_Unmarshal(b []byte) error
- type ProtocolTxConfiguration
- func (*ProtocolTxConfiguration) Descriptor() ([]byte, []int)
- func (m *ProtocolTxConfiguration) GetLorawan() *LoRaWANTxConfiguration
- func (m *ProtocolTxConfiguration) Marshal() (dAtA []byte, err error)
- func (m *ProtocolTxConfiguration) MarshalTo(dAtA []byte) (int, error)
- func (m *ProtocolTxConfiguration) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ProtocolTxConfiguration) ProtoMessage()
- func (m *ProtocolTxConfiguration) Reset()
- func (m *ProtocolTxConfiguration) Size() (n int)
- func (m *ProtocolTxConfiguration) String() string
- func (m *ProtocolTxConfiguration) Unmarshal(dAtA []byte) error
- func (m *ProtocolTxConfiguration) XXX_DiscardUnknown()
- func (m *ProtocolTxConfiguration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProtocolTxConfiguration) XXX_Merge(src proto.Message)
- func (m *ProtocolTxConfiguration) XXX_Size() int
- func (m *ProtocolTxConfiguration) XXX_Unmarshal(b []byte) error
- type RouterClient
- type RouterServer
- type Router_GatewayStatusClient
- type Router_GatewayStatusServer
- type Router_SubscribeClient
- type Router_SubscribeServer
- type Router_UplinkClient
- type Router_UplinkServer
- type StatusMessage
- func (*StatusMessage) Descriptor() ([]byte, []int)
- func (m *StatusMessage) GetBootTime() int64
- func (m *StatusMessage) GetBridge() string
- func (m *StatusMessage) GetContactEmail() string
- func (m *StatusMessage) GetDescription() string
- func (m *StatusMessage) GetDsp() uint32
- func (m *StatusMessage) GetFpga() uint32
- func (m *StatusMessage) GetFrequencyPlan() string
- func (m *StatusMessage) GetGatewayTrusted() bool
- func (m *StatusMessage) GetHal() string
- func (m *StatusMessage) GetIp() []string
- func (m *StatusMessage) GetLPps() uint32
- func (m *StatusMessage) GetLmNw() uint32
- func (m *StatusMessage) GetLmOk() uint32
- func (m *StatusMessage) GetLmSt() uint32
- func (m *StatusMessage) GetLocation() *LocationMetadata
- func (m *StatusMessage) GetMessages() []string
- func (m *StatusMessage) GetOs() *StatusMessage_OSMetrics
- func (m *StatusMessage) GetPlatform() string
- func (m *StatusMessage) GetRouter() string
- func (m *StatusMessage) GetRtt() uint32
- func (m *StatusMessage) GetRxIn() uint32
- func (m *StatusMessage) GetRxOk() uint32
- func (m *StatusMessage) GetTime() int64
- func (m *StatusMessage) GetTimestamp() uint32
- func (m *StatusMessage) GetTxIn() uint32
- func (m *StatusMessage) GetTxOk() uint32
- func (m *StatusMessage) Marshal() (dAtA []byte, err error)
- func (m *StatusMessage) MarshalTo(dAtA []byte) (int, error)
- func (m *StatusMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StatusMessage) ProtoMessage()
- func (m *StatusMessage) Reset()
- func (m *StatusMessage) Size() (n int)
- func (m *StatusMessage) String() string
- func (m *StatusMessage) Unmarshal(dAtA []byte) error
- func (m *StatusMessage) XXX_DiscardUnknown()
- func (m *StatusMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StatusMessage) XXX_Merge(src proto.Message)
- func (m *StatusMessage) XXX_Size() int
- func (m *StatusMessage) XXX_Unmarshal(b []byte) error
- type StatusMessage_OSMetrics
- func (*StatusMessage_OSMetrics) Descriptor() ([]byte, []int)
- func (m *StatusMessage_OSMetrics) GetCpuPercentage() float32
- func (m *StatusMessage_OSMetrics) GetLoad_1() float32
- func (m *StatusMessage_OSMetrics) GetLoad_15() float32
- func (m *StatusMessage_OSMetrics) GetLoad_5() float32
- func (m *StatusMessage_OSMetrics) GetMemoryPercentage() float32
- func (m *StatusMessage_OSMetrics) GetTemperature() float32
- func (m *StatusMessage_OSMetrics) Marshal() (dAtA []byte, err error)
- func (m *StatusMessage_OSMetrics) MarshalTo(dAtA []byte) (int, error)
- func (m *StatusMessage_OSMetrics) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StatusMessage_OSMetrics) ProtoMessage()
- func (m *StatusMessage_OSMetrics) Reset()
- func (m *StatusMessage_OSMetrics) Size() (n int)
- func (m *StatusMessage_OSMetrics) String() string
- func (m *StatusMessage_OSMetrics) Unmarshal(dAtA []byte) error
- func (m *StatusMessage_OSMetrics) XXX_DiscardUnknown()
- func (m *StatusMessage_OSMetrics) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StatusMessage_OSMetrics) XXX_Merge(src proto.Message)
- func (m *StatusMessage_OSMetrics) XXX_Size() int
- func (m *StatusMessage_OSMetrics) XXX_Unmarshal(b []byte) error
- type Trace
- func (*Trace) Descriptor() ([]byte, []int)
- func (m *Trace) GetEvent() string
- func (m *Trace) GetId() string
- func (m *Trace) GetMetadata() map[string]string
- func (m *Trace) GetParents() []*Trace
- func (m *Trace) GetServiceId() string
- func (m *Trace) GetServiceName() string
- func (m *Trace) GetTime() int64
- func (m *Trace) Marshal() (dAtA []byte, err error)
- func (m *Trace) MarshalTo(dAtA []byte) (int, error)
- func (m *Trace) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Trace) ProtoMessage()
- func (m *Trace) Reset()
- func (m *Trace) Size() (n int)
- func (m *Trace) String() string
- func (m *Trace) Unmarshal(dAtA []byte) error
- func (m *Trace) XXX_DiscardUnknown()
- func (m *Trace) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Trace) XXX_Merge(src proto.Message)
- func (m *Trace) XXX_Size() int
- func (m *Trace) XXX_Unmarshal(b []byte) error
- type UnimplementedDiscoveryServer
- type UnimplementedRouterServer
- type UplinkMessage
- func (*UplinkMessage) Descriptor() ([]byte, []int)
- func (m *UplinkMessage) GetGatewayMetadata() *GatewayRxMetadata
- func (m *UplinkMessage) GetPayload() []byte
- func (m *UplinkMessage) GetProtocolMetadata() *ProtocolRxMetadata
- func (m *UplinkMessage) GetTrace() *Trace
- func (m *UplinkMessage) Marshal() (dAtA []byte, err error)
- func (m *UplinkMessage) MarshalTo(dAtA []byte) (int, error)
- func (m *UplinkMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*UplinkMessage) ProtoMessage()
- func (m *UplinkMessage) Reset()
- func (m *UplinkMessage) Size() (n int)
- func (m *UplinkMessage) String() string
- func (m *UplinkMessage) Unmarshal(dAtA []byte) error
- func (m *UplinkMessage) XXX_DiscardUnknown()
- func (m *UplinkMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UplinkMessage) XXX_Merge(src proto.Message)
- func (m *UplinkMessage) XXX_Size() int
- func (m *UplinkMessage) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthDiscovery = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowDiscovery = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupDiscovery = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthRouter = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowRouter = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupRouter = fmt.Errorf("proto: unexpected end of group") )
var FrequencyPlan_name = map[int32]string{
0: "EU_863_870",
1: "US_902_928",
2: "CN_779_787",
3: "EU_433",
4: "AU_915_928",
5: "CN_470_510",
6: "AS_923",
61: "AS_920_923",
62: "AS_923_925",
7: "KR_920_923",
8: "IN_865_867",
9: "RU_864_870",
}
var FrequencyPlan_value = map[string]int32{
"EU_863_870": 0,
"US_902_928": 1,
"CN_779_787": 2,
"EU_433": 3,
"AU_915_928": 4,
"CN_470_510": 5,
"AS_923": 6,
"AS_920_923": 61,
"AS_923_925": 62,
"KR_920_923": 7,
"IN_865_867": 8,
"RU_864_870": 9,
}
var LocationMetadata_LocationSource_name = map[int32]string{
0: "UNKNOWN",
1: "GPS",
2: "CONFIG",
3: "REGISTRY",
4: "IP_GEOLOCATION",
}
var LocationMetadata_LocationSource_value = map[string]int32{
"UNKNOWN": 0,
"GPS": 1,
"CONFIG": 2,
"REGISTRY": 3,
"IP_GEOLOCATION": 4,
}
var Modulation_name = map[int32]string{
0: "LORA",
1: "FSK",
}
var Modulation_value = map[string]int32{
"LORA": 0,
"FSK": 1,
}
Functions ¶
func RegisterDiscoveryServer ¶
func RegisterDiscoveryServer(s *grpc.Server, srv DiscoveryServer)
func RegisterRouterServer ¶
func RegisterRouterServer(s *grpc.Server, srv RouterServer)
Types ¶
type Announcement ¶
type Announcement struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` ServiceName string `protobuf:"bytes,2,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"` ServiceVersion string `protobuf:"bytes,3,opt,name=service_version,json=serviceVersion,proto3" json:"service_version,omitempty"` NetAddress string `protobuf:"bytes,11,opt,name=net_address,json=netAddress,proto3" json:"net_address,omitempty"` PublicKey string `protobuf:"bytes,12,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"` Certificate string `protobuf:"bytes,13,opt,name=certificate,proto3" json:"certificate,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Announcement) Descriptor ¶
func (*Announcement) Descriptor() ([]byte, []int)
func (*Announcement) GetCertificate ¶
func (m *Announcement) GetCertificate() string
func (*Announcement) GetId ¶
func (m *Announcement) GetId() string
func (*Announcement) GetNetAddress ¶
func (m *Announcement) GetNetAddress() string
func (*Announcement) GetPublicKey ¶
func (m *Announcement) GetPublicKey() string
func (*Announcement) GetServiceName ¶
func (m *Announcement) GetServiceName() string
func (*Announcement) GetServiceVersion ¶
func (m *Announcement) GetServiceVersion() string
func (*Announcement) GetTLSConfig ¶
func (a *Announcement) GetTLSConfig() (*tls.Config, error)
GetTLSConfig returns the TLS config for the announcement.
func (*Announcement) Marshal ¶
func (m *Announcement) Marshal() (dAtA []byte, err error)
func (*Announcement) MarshalToSizedBuffer ¶
func (m *Announcement) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Announcement) ProtoMessage ¶
func (*Announcement) ProtoMessage()
func (*Announcement) Reset ¶
func (m *Announcement) Reset()
func (*Announcement) Size ¶
func (m *Announcement) Size() (n int)
func (*Announcement) String ¶
func (m *Announcement) String() string
func (*Announcement) Unmarshal ¶
func (m *Announcement) Unmarshal(dAtA []byte) error
func (*Announcement) XXX_DiscardUnknown ¶
func (m *Announcement) XXX_DiscardUnknown()
func (*Announcement) XXX_Marshal ¶
func (m *Announcement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Announcement) XXX_Merge ¶
func (m *Announcement) XXX_Merge(src proto.Message)
func (*Announcement) XXX_Size ¶
func (m *Announcement) XXX_Size() int
func (*Announcement) XXX_Unmarshal ¶
func (m *Announcement) XXX_Unmarshal(b []byte) error
type DiscoveryClient ¶
type DiscoveryClient interface {
Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*Announcement, error)
}
DiscoveryClient is the client API for Discovery service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewDiscoveryClient ¶
func NewDiscoveryClient(cc *grpc.ClientConn) DiscoveryClient
type DiscoveryServer ¶
type DiscoveryServer interface {
Get(context.Context, *GetRequest) (*Announcement, error)
}
DiscoveryServer is the server API for Discovery service.
type DownlinkMessage ¶
type DownlinkMessage struct { Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"` // ProtocolMessage message = 2; ProtocolConfiguration *ProtocolTxConfiguration `protobuf:"bytes,11,opt,name=protocol_configuration,json=protocolConfiguration,proto3" json:"protocol_configuration,omitempty"` GatewayConfiguration *GatewayTxConfiguration `protobuf:"bytes,12,opt,name=gateway_configuration,json=gatewayConfiguration,proto3" json:"gateway_configuration,omitempty"` Trace *Trace `protobuf:"bytes,21,opt,name=trace,proto3" json:"trace,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DownlinkMessage) Descriptor ¶
func (*DownlinkMessage) Descriptor() ([]byte, []int)
func (*DownlinkMessage) GetGatewayConfiguration ¶
func (m *DownlinkMessage) GetGatewayConfiguration() *GatewayTxConfiguration
func (*DownlinkMessage) GetPayload ¶
func (m *DownlinkMessage) GetPayload() []byte
func (*DownlinkMessage) GetProtocolConfiguration ¶
func (m *DownlinkMessage) GetProtocolConfiguration() *ProtocolTxConfiguration
func (*DownlinkMessage) GetTrace ¶
func (m *DownlinkMessage) GetTrace() *Trace
func (*DownlinkMessage) Marshal ¶
func (m *DownlinkMessage) Marshal() (dAtA []byte, err error)
func (*DownlinkMessage) MarshalToSizedBuffer ¶
func (m *DownlinkMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DownlinkMessage) ProtoMessage ¶
func (*DownlinkMessage) ProtoMessage()
func (*DownlinkMessage) Reset ¶
func (m *DownlinkMessage) Reset()
func (*DownlinkMessage) Size ¶
func (m *DownlinkMessage) Size() (n int)
func (*DownlinkMessage) String ¶
func (m *DownlinkMessage) String() string
func (*DownlinkMessage) Unmarshal ¶
func (m *DownlinkMessage) Unmarshal(dAtA []byte) error
func (*DownlinkMessage) XXX_DiscardUnknown ¶
func (m *DownlinkMessage) XXX_DiscardUnknown()
func (*DownlinkMessage) XXX_Marshal ¶
func (m *DownlinkMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DownlinkMessage) XXX_Merge ¶
func (m *DownlinkMessage) XXX_Merge(src proto.Message)
func (*DownlinkMessage) XXX_Size ¶
func (m *DownlinkMessage) XXX_Size() int
func (*DownlinkMessage) XXX_Unmarshal ¶
func (m *DownlinkMessage) XXX_Unmarshal(b []byte) error
type FrequencyPlan ¶
type FrequencyPlan int32
const ( FrequencyPlan_EU_863_870 FrequencyPlan = 0 FrequencyPlan_US_902_928 FrequencyPlan = 1 FrequencyPlan_CN_779_787 FrequencyPlan = 2 FrequencyPlan_EU_433 FrequencyPlan = 3 FrequencyPlan_AU_915_928 FrequencyPlan = 4 FrequencyPlan_CN_470_510 FrequencyPlan = 5 FrequencyPlan_AS_923 FrequencyPlan = 6 FrequencyPlan_AS_920_923 FrequencyPlan = 61 FrequencyPlan_AS_923_925 FrequencyPlan = 62 FrequencyPlan_KR_920_923 FrequencyPlan = 7 FrequencyPlan_IN_865_867 FrequencyPlan = 8 FrequencyPlan_RU_864_870 FrequencyPlan = 9 )
func (FrequencyPlan) EnumDescriptor ¶
func (FrequencyPlan) EnumDescriptor() ([]byte, []int)
func (FrequencyPlan) String ¶
func (x FrequencyPlan) String() string
type GatewayRxMetadata ¶
type GatewayRxMetadata struct { GatewayId string `protobuf:"bytes,1,opt,name=gateway_id,json=gatewayId,proto3" json:"gateway_id,omitempty"` GatewayTrusted bool `protobuf:"varint,2,opt,name=gateway_trusted,json=gatewayTrusted,proto3" json:"gateway_trusted,omitempty"` Timestamp uint32 `protobuf:"varint,11,opt,name=timestamp,proto3" json:"timestamp,omitempty"` Time int64 `protobuf:"varint,12,opt,name=time,proto3" json:"time,omitempty"` EncryptedTime []byte `protobuf:"bytes,13,opt,name=encrypted_time,json=encryptedTime,proto3" json:"encrypted_time,omitempty"` RfChain uint32 `protobuf:"varint,21,opt,name=rf_chain,json=rfChain,proto3" json:"rf_chain,omitempty"` Channel uint32 `protobuf:"varint,22,opt,name=channel,proto3" json:"channel,omitempty"` Antennas []*GatewayRxMetadata_Antenna `protobuf:"bytes,30,rep,name=antennas,proto3" json:"antennas,omitempty"` Frequency uint64 `protobuf:"varint,31,opt,name=frequency,proto3" json:"frequency,omitempty"` Rssi float32 `protobuf:"fixed32,32,opt,name=rssi,proto3" json:"rssi,omitempty"` Snr float32 `protobuf:"fixed32,33,opt,name=snr,proto3" json:"snr,omitempty"` Location *LocationMetadata `protobuf:"bytes,41,opt,name=location,proto3" json:"location,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GatewayRxMetadata) Descriptor ¶
func (*GatewayRxMetadata) Descriptor() ([]byte, []int)
func (*GatewayRxMetadata) GetAntennas ¶
func (m *GatewayRxMetadata) GetAntennas() []*GatewayRxMetadata_Antenna
func (*GatewayRxMetadata) GetChannel ¶
func (m *GatewayRxMetadata) GetChannel() uint32
func (*GatewayRxMetadata) GetEncryptedTime ¶
func (m *GatewayRxMetadata) GetEncryptedTime() []byte
func (*GatewayRxMetadata) GetFrequency ¶
func (m *GatewayRxMetadata) GetFrequency() uint64
func (*GatewayRxMetadata) GetGatewayId ¶
func (m *GatewayRxMetadata) GetGatewayId() string
func (*GatewayRxMetadata) GetGatewayTrusted ¶
func (m *GatewayRxMetadata) GetGatewayTrusted() bool
func (*GatewayRxMetadata) GetLocation ¶
func (m *GatewayRxMetadata) GetLocation() *LocationMetadata
func (*GatewayRxMetadata) GetRfChain ¶
func (m *GatewayRxMetadata) GetRfChain() uint32
func (*GatewayRxMetadata) GetRssi ¶
func (m *GatewayRxMetadata) GetRssi() float32
func (*GatewayRxMetadata) GetSnr ¶
func (m *GatewayRxMetadata) GetSnr() float32
func (*GatewayRxMetadata) GetTime ¶
func (m *GatewayRxMetadata) GetTime() int64
func (*GatewayRxMetadata) GetTimestamp ¶
func (m *GatewayRxMetadata) GetTimestamp() uint32
func (*GatewayRxMetadata) Marshal ¶
func (m *GatewayRxMetadata) Marshal() (dAtA []byte, err error)
func (*GatewayRxMetadata) MarshalTo ¶
func (m *GatewayRxMetadata) MarshalTo(dAtA []byte) (int, error)
func (*GatewayRxMetadata) MarshalToSizedBuffer ¶
func (m *GatewayRxMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GatewayRxMetadata) ProtoMessage ¶
func (*GatewayRxMetadata) ProtoMessage()
func (*GatewayRxMetadata) Reset ¶
func (m *GatewayRxMetadata) Reset()
func (*GatewayRxMetadata) Size ¶
func (m *GatewayRxMetadata) Size() (n int)
func (*GatewayRxMetadata) String ¶
func (m *GatewayRxMetadata) String() string
func (*GatewayRxMetadata) Unmarshal ¶
func (m *GatewayRxMetadata) Unmarshal(dAtA []byte) error
func (*GatewayRxMetadata) XXX_DiscardUnknown ¶
func (m *GatewayRxMetadata) XXX_DiscardUnknown()
func (*GatewayRxMetadata) XXX_Marshal ¶
func (m *GatewayRxMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GatewayRxMetadata) XXX_Merge ¶
func (m *GatewayRxMetadata) XXX_Merge(src proto.Message)
func (*GatewayRxMetadata) XXX_Size ¶
func (m *GatewayRxMetadata) XXX_Size() int
func (*GatewayRxMetadata) XXX_Unmarshal ¶
func (m *GatewayRxMetadata) XXX_Unmarshal(b []byte) error
type GatewayRxMetadata_Antenna ¶
type GatewayRxMetadata_Antenna struct { Antenna uint32 `protobuf:"varint,1,opt,name=antenna,proto3" json:"antenna,omitempty"` Channel uint32 `protobuf:"varint,2,opt,name=channel,proto3" json:"channel,omitempty"` Rssi float32 `protobuf:"fixed32,3,opt,name=rssi,proto3" json:"rssi,omitempty"` ChannelRssi float32 `protobuf:"fixed32,5,opt,name=channel_rssi,json=channelRssi,proto3" json:"channel_rssi,omitempty"` RssiStandardDeviation float32 `` /* 128-byte string literal not displayed */ FrequencyOffset int64 `protobuf:"varint,7,opt,name=frequency_offset,json=frequencyOffset,proto3" json:"frequency_offset,omitempty"` Snr float32 `protobuf:"fixed32,4,opt,name=snr,proto3" json:"snr,omitempty"` EncryptedTime []byte `protobuf:"bytes,10,opt,name=encrypted_time,json=encryptedTime,proto3" json:"encrypted_time,omitempty"` FineTime int64 `protobuf:"varint,11,opt,name=fine_time,json=fineTime,proto3" json:"fine_time,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GatewayRxMetadata_Antenna) Descriptor ¶
func (*GatewayRxMetadata_Antenna) Descriptor() ([]byte, []int)
func (*GatewayRxMetadata_Antenna) GetAntenna ¶
func (m *GatewayRxMetadata_Antenna) GetAntenna() uint32
func (*GatewayRxMetadata_Antenna) GetChannel ¶
func (m *GatewayRxMetadata_Antenna) GetChannel() uint32
func (*GatewayRxMetadata_Antenna) GetChannelRssi ¶
func (m *GatewayRxMetadata_Antenna) GetChannelRssi() float32
func (*GatewayRxMetadata_Antenna) GetEncryptedTime ¶
func (m *GatewayRxMetadata_Antenna) GetEncryptedTime() []byte
func (*GatewayRxMetadata_Antenna) GetFineTime ¶
func (m *GatewayRxMetadata_Antenna) GetFineTime() int64
func (*GatewayRxMetadata_Antenna) GetFrequencyOffset ¶
func (m *GatewayRxMetadata_Antenna) GetFrequencyOffset() int64
func (*GatewayRxMetadata_Antenna) GetRssi ¶
func (m *GatewayRxMetadata_Antenna) GetRssi() float32
func (*GatewayRxMetadata_Antenna) GetRssiStandardDeviation ¶
func (m *GatewayRxMetadata_Antenna) GetRssiStandardDeviation() float32
func (*GatewayRxMetadata_Antenna) GetSnr ¶
func (m *GatewayRxMetadata_Antenna) GetSnr() float32
func (*GatewayRxMetadata_Antenna) Marshal ¶
func (m *GatewayRxMetadata_Antenna) Marshal() (dAtA []byte, err error)
func (*GatewayRxMetadata_Antenna) MarshalTo ¶
func (m *GatewayRxMetadata_Antenna) MarshalTo(dAtA []byte) (int, error)
func (*GatewayRxMetadata_Antenna) MarshalToSizedBuffer ¶
func (m *GatewayRxMetadata_Antenna) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GatewayRxMetadata_Antenna) ProtoMessage ¶
func (*GatewayRxMetadata_Antenna) ProtoMessage()
func (*GatewayRxMetadata_Antenna) Reset ¶
func (m *GatewayRxMetadata_Antenna) Reset()
func (*GatewayRxMetadata_Antenna) Size ¶
func (m *GatewayRxMetadata_Antenna) Size() (n int)
func (*GatewayRxMetadata_Antenna) String ¶
func (m *GatewayRxMetadata_Antenna) String() string
func (*GatewayRxMetadata_Antenna) Unmarshal ¶
func (m *GatewayRxMetadata_Antenna) Unmarshal(dAtA []byte) error
func (*GatewayRxMetadata_Antenna) XXX_DiscardUnknown ¶
func (m *GatewayRxMetadata_Antenna) XXX_DiscardUnknown()
func (*GatewayRxMetadata_Antenna) XXX_Marshal ¶
func (m *GatewayRxMetadata_Antenna) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GatewayRxMetadata_Antenna) XXX_Merge ¶
func (m *GatewayRxMetadata_Antenna) XXX_Merge(src proto.Message)
func (*GatewayRxMetadata_Antenna) XXX_Size ¶
func (m *GatewayRxMetadata_Antenna) XXX_Size() int
func (*GatewayRxMetadata_Antenna) XXX_Unmarshal ¶
func (m *GatewayRxMetadata_Antenna) XXX_Unmarshal(b []byte) error
type GatewayTxConfiguration ¶
type GatewayTxConfiguration struct { Timestamp uint32 `protobuf:"varint,11,opt,name=timestamp,proto3" json:"timestamp,omitempty"` RfChain uint32 `protobuf:"varint,21,opt,name=rf_chain,json=rfChain,proto3" json:"rf_chain,omitempty"` Frequency uint64 `protobuf:"varint,22,opt,name=frequency,proto3" json:"frequency,omitempty"` Power int32 `protobuf:"varint,23,opt,name=power,proto3" json:"power,omitempty"` PolarizationInversion bool `` /* 126-byte string literal not displayed */ FrequencyDeviation uint32 `protobuf:"varint,32,opt,name=frequency_deviation,json=frequencyDeviation,proto3" json:"frequency_deviation,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GatewayTxConfiguration) Descriptor ¶
func (*GatewayTxConfiguration) Descriptor() ([]byte, []int)
func (*GatewayTxConfiguration) GetFrequency ¶
func (m *GatewayTxConfiguration) GetFrequency() uint64
func (*GatewayTxConfiguration) GetFrequencyDeviation ¶
func (m *GatewayTxConfiguration) GetFrequencyDeviation() uint32
func (*GatewayTxConfiguration) GetPolarizationInversion ¶
func (m *GatewayTxConfiguration) GetPolarizationInversion() bool
func (*GatewayTxConfiguration) GetPower ¶
func (m *GatewayTxConfiguration) GetPower() int32
func (*GatewayTxConfiguration) GetRfChain ¶
func (m *GatewayTxConfiguration) GetRfChain() uint32
func (*GatewayTxConfiguration) GetTimestamp ¶
func (m *GatewayTxConfiguration) GetTimestamp() uint32
func (*GatewayTxConfiguration) Marshal ¶
func (m *GatewayTxConfiguration) Marshal() (dAtA []byte, err error)
func (*GatewayTxConfiguration) MarshalTo ¶
func (m *GatewayTxConfiguration) MarshalTo(dAtA []byte) (int, error)
func (*GatewayTxConfiguration) MarshalToSizedBuffer ¶
func (m *GatewayTxConfiguration) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GatewayTxConfiguration) ProtoMessage ¶
func (*GatewayTxConfiguration) ProtoMessage()
func (*GatewayTxConfiguration) Reset ¶
func (m *GatewayTxConfiguration) Reset()
func (*GatewayTxConfiguration) Size ¶
func (m *GatewayTxConfiguration) Size() (n int)
func (*GatewayTxConfiguration) String ¶
func (m *GatewayTxConfiguration) String() string
func (*GatewayTxConfiguration) Unmarshal ¶
func (m *GatewayTxConfiguration) Unmarshal(dAtA []byte) error
func (*GatewayTxConfiguration) XXX_DiscardUnknown ¶
func (m *GatewayTxConfiguration) XXX_DiscardUnknown()
func (*GatewayTxConfiguration) XXX_Marshal ¶
func (m *GatewayTxConfiguration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GatewayTxConfiguration) XXX_Merge ¶
func (m *GatewayTxConfiguration) XXX_Merge(src proto.Message)
func (*GatewayTxConfiguration) XXX_Size ¶
func (m *GatewayTxConfiguration) XXX_Size() int
func (*GatewayTxConfiguration) XXX_Unmarshal ¶
func (m *GatewayTxConfiguration) XXX_Unmarshal(b []byte) error
type GetRequest ¶
type GetRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` ServiceName string `protobuf:"bytes,2,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetRequest) Descriptor ¶
func (*GetRequest) Descriptor() ([]byte, []int)
func (*GetRequest) GetId ¶
func (m *GetRequest) GetId() string
func (*GetRequest) GetServiceName ¶
func (m *GetRequest) GetServiceName() string
func (*GetRequest) Marshal ¶
func (m *GetRequest) Marshal() (dAtA []byte, err error)
func (*GetRequest) MarshalToSizedBuffer ¶
func (m *GetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetRequest) ProtoMessage ¶
func (*GetRequest) ProtoMessage()
func (*GetRequest) Reset ¶
func (m *GetRequest) Reset()
func (*GetRequest) Size ¶
func (m *GetRequest) Size() (n int)
func (*GetRequest) String ¶
func (m *GetRequest) String() string
func (*GetRequest) Unmarshal ¶
func (m *GetRequest) Unmarshal(dAtA []byte) error
func (*GetRequest) XXX_DiscardUnknown ¶
func (m *GetRequest) XXX_DiscardUnknown()
func (*GetRequest) XXX_Marshal ¶
func (m *GetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetRequest) XXX_Merge ¶
func (m *GetRequest) XXX_Merge(src proto.Message)
func (*GetRequest) XXX_Size ¶
func (m *GetRequest) XXX_Size() int
func (*GetRequest) XXX_Unmarshal ¶
func (m *GetRequest) XXX_Unmarshal(b []byte) error
type LoRaWANMetadata ¶
type LoRaWANMetadata struct { Modulation Modulation `protobuf:"varint,11,opt,name=modulation,proto3,enum=router.Modulation" json:"modulation,omitempty"` DataRate string `protobuf:"bytes,12,opt,name=data_rate,json=dataRate,proto3" json:"data_rate,omitempty"` BitRate uint32 `protobuf:"varint,13,opt,name=bit_rate,json=bitRate,proto3" json:"bit_rate,omitempty"` CodingRate string `protobuf:"bytes,14,opt,name=coding_rate,json=codingRate,proto3" json:"coding_rate,omitempty"` FCnt uint32 `protobuf:"varint,15,opt,name=f_cnt,json=fCnt,proto3" json:"f_cnt,omitempty"` FrequencyPlan FrequencyPlan `` /* 128-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*LoRaWANMetadata) Descriptor ¶
func (*LoRaWANMetadata) Descriptor() ([]byte, []int)
func (*LoRaWANMetadata) GetBitRate ¶
func (m *LoRaWANMetadata) GetBitRate() uint32
func (*LoRaWANMetadata) GetCodingRate ¶
func (m *LoRaWANMetadata) GetCodingRate() string
func (*LoRaWANMetadata) GetDataRate ¶
func (m *LoRaWANMetadata) GetDataRate() string
func (*LoRaWANMetadata) GetFCnt ¶
func (m *LoRaWANMetadata) GetFCnt() uint32
func (*LoRaWANMetadata) GetFrequencyPlan ¶
func (m *LoRaWANMetadata) GetFrequencyPlan() FrequencyPlan
func (*LoRaWANMetadata) GetModulation ¶
func (m *LoRaWANMetadata) GetModulation() Modulation
func (*LoRaWANMetadata) Marshal ¶
func (m *LoRaWANMetadata) Marshal() (dAtA []byte, err error)
func (*LoRaWANMetadata) MarshalToSizedBuffer ¶
func (m *LoRaWANMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*LoRaWANMetadata) ProtoMessage ¶
func (*LoRaWANMetadata) ProtoMessage()
func (*LoRaWANMetadata) Reset ¶
func (m *LoRaWANMetadata) Reset()
func (*LoRaWANMetadata) Size ¶
func (m *LoRaWANMetadata) Size() (n int)
func (*LoRaWANMetadata) String ¶
func (m *LoRaWANMetadata) String() string
func (*LoRaWANMetadata) Unmarshal ¶
func (m *LoRaWANMetadata) Unmarshal(dAtA []byte) error
func (*LoRaWANMetadata) XXX_DiscardUnknown ¶
func (m *LoRaWANMetadata) XXX_DiscardUnknown()
func (*LoRaWANMetadata) XXX_Marshal ¶
func (m *LoRaWANMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LoRaWANMetadata) XXX_Merge ¶
func (m *LoRaWANMetadata) XXX_Merge(src proto.Message)
func (*LoRaWANMetadata) XXX_Size ¶
func (m *LoRaWANMetadata) XXX_Size() int
func (*LoRaWANMetadata) XXX_Unmarshal ¶
func (m *LoRaWANMetadata) XXX_Unmarshal(b []byte) error
type LoRaWANTxConfiguration ¶
type LoRaWANTxConfiguration struct { Modulation Modulation `protobuf:"varint,11,opt,name=modulation,proto3,enum=router.Modulation" json:"modulation,omitempty"` DataRate string `protobuf:"bytes,12,opt,name=data_rate,json=dataRate,proto3" json:"data_rate,omitempty"` BitRate uint32 `protobuf:"varint,13,opt,name=bit_rate,json=bitRate,proto3" json:"bit_rate,omitempty"` CodingRate string `protobuf:"bytes,14,opt,name=coding_rate,json=codingRate,proto3" json:"coding_rate,omitempty"` FCnt uint32 `protobuf:"varint,15,opt,name=f_cnt,json=fCnt,proto3" json:"f_cnt,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*LoRaWANTxConfiguration) Descriptor ¶
func (*LoRaWANTxConfiguration) Descriptor() ([]byte, []int)
func (*LoRaWANTxConfiguration) GetBitRate ¶
func (m *LoRaWANTxConfiguration) GetBitRate() uint32
func (*LoRaWANTxConfiguration) GetCodingRate ¶
func (m *LoRaWANTxConfiguration) GetCodingRate() string
func (*LoRaWANTxConfiguration) GetDataRate ¶
func (m *LoRaWANTxConfiguration) GetDataRate() string
func (*LoRaWANTxConfiguration) GetFCnt ¶
func (m *LoRaWANTxConfiguration) GetFCnt() uint32
func (*LoRaWANTxConfiguration) GetModulation ¶
func (m *LoRaWANTxConfiguration) GetModulation() Modulation
func (*LoRaWANTxConfiguration) Marshal ¶
func (m *LoRaWANTxConfiguration) Marshal() (dAtA []byte, err error)
func (*LoRaWANTxConfiguration) MarshalTo ¶
func (m *LoRaWANTxConfiguration) MarshalTo(dAtA []byte) (int, error)
func (*LoRaWANTxConfiguration) MarshalToSizedBuffer ¶
func (m *LoRaWANTxConfiguration) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*LoRaWANTxConfiguration) ProtoMessage ¶
func (*LoRaWANTxConfiguration) ProtoMessage()
func (*LoRaWANTxConfiguration) Reset ¶
func (m *LoRaWANTxConfiguration) Reset()
func (*LoRaWANTxConfiguration) Size ¶
func (m *LoRaWANTxConfiguration) Size() (n int)
func (*LoRaWANTxConfiguration) String ¶
func (m *LoRaWANTxConfiguration) String() string
func (*LoRaWANTxConfiguration) Unmarshal ¶
func (m *LoRaWANTxConfiguration) Unmarshal(dAtA []byte) error
func (*LoRaWANTxConfiguration) XXX_DiscardUnknown ¶
func (m *LoRaWANTxConfiguration) XXX_DiscardUnknown()
func (*LoRaWANTxConfiguration) XXX_Marshal ¶
func (m *LoRaWANTxConfiguration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LoRaWANTxConfiguration) XXX_Merge ¶
func (m *LoRaWANTxConfiguration) XXX_Merge(src proto.Message)
func (*LoRaWANTxConfiguration) XXX_Size ¶
func (m *LoRaWANTxConfiguration) XXX_Size() int
func (*LoRaWANTxConfiguration) XXX_Unmarshal ¶
func (m *LoRaWANTxConfiguration) XXX_Unmarshal(b []byte) error
type LocationMetadata ¶
type LocationMetadata struct { Time int64 `protobuf:"varint,1,opt,name=time,proto3" json:"time,omitempty"` Latitude float32 `protobuf:"fixed32,2,opt,name=latitude,proto3" json:"latitude,omitempty"` Longitude float32 `protobuf:"fixed32,3,opt,name=longitude,proto3" json:"longitude,omitempty"` Altitude int32 `protobuf:"varint,4,opt,name=altitude,proto3" json:"altitude,omitempty"` Accuracy int32 `protobuf:"varint,5,opt,name=accuracy,proto3" json:"accuracy,omitempty"` Source LocationMetadata_LocationSource `protobuf:"varint,6,opt,name=source,proto3,enum=router.LocationMetadata_LocationSource" json:"source,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*LocationMetadata) Descriptor ¶
func (*LocationMetadata) Descriptor() ([]byte, []int)
func (*LocationMetadata) GetAccuracy ¶
func (m *LocationMetadata) GetAccuracy() int32
func (*LocationMetadata) GetAltitude ¶
func (m *LocationMetadata) GetAltitude() int32
func (*LocationMetadata) GetLatitude ¶
func (m *LocationMetadata) GetLatitude() float32
func (*LocationMetadata) GetLongitude ¶
func (m *LocationMetadata) GetLongitude() float32
func (*LocationMetadata) GetSource ¶
func (m *LocationMetadata) GetSource() LocationMetadata_LocationSource
func (*LocationMetadata) GetTime ¶
func (m *LocationMetadata) GetTime() int64
func (*LocationMetadata) Marshal ¶
func (m *LocationMetadata) Marshal() (dAtA []byte, err error)
func (*LocationMetadata) MarshalToSizedBuffer ¶
func (m *LocationMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*LocationMetadata) ProtoMessage ¶
func (*LocationMetadata) ProtoMessage()
func (*LocationMetadata) Reset ¶
func (m *LocationMetadata) Reset()
func (*LocationMetadata) Size ¶
func (m *LocationMetadata) Size() (n int)
func (*LocationMetadata) String ¶
func (m *LocationMetadata) String() string
func (*LocationMetadata) Unmarshal ¶
func (m *LocationMetadata) Unmarshal(dAtA []byte) error
func (*LocationMetadata) Validate ¶
func (m *LocationMetadata) Validate() bool
Validate validates the location.
func (*LocationMetadata) XXX_DiscardUnknown ¶
func (m *LocationMetadata) XXX_DiscardUnknown()
func (*LocationMetadata) XXX_Marshal ¶
func (m *LocationMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LocationMetadata) XXX_Merge ¶
func (m *LocationMetadata) XXX_Merge(src proto.Message)
func (*LocationMetadata) XXX_Size ¶
func (m *LocationMetadata) XXX_Size() int
func (*LocationMetadata) XXX_Unmarshal ¶
func (m *LocationMetadata) XXX_Unmarshal(b []byte) error
type LocationMetadata_LocationSource ¶
type LocationMetadata_LocationSource int32
const ( LocationMetadata_UNKNOWN LocationMetadata_LocationSource = 0 LocationMetadata_GPS LocationMetadata_LocationSource = 1 LocationMetadata_CONFIG LocationMetadata_LocationSource = 2 LocationMetadata_REGISTRY LocationMetadata_LocationSource = 3 LocationMetadata_IP_GEOLOCATION LocationMetadata_LocationSource = 4 )
func (LocationMetadata_LocationSource) EnumDescriptor ¶
func (LocationMetadata_LocationSource) EnumDescriptor() ([]byte, []int)
func (LocationMetadata_LocationSource) String ¶
func (x LocationMetadata_LocationSource) String() string
type Modulation ¶
type Modulation int32
const ( Modulation_LORA Modulation = 0 Modulation_FSK Modulation = 1 )
func (Modulation) EnumDescriptor ¶
func (Modulation) EnumDescriptor() ([]byte, []int)
func (Modulation) String ¶
func (x Modulation) String() string
type ProtocolRxMetadata ¶
type ProtocolRxMetadata struct { Lorawan *LoRaWANMetadata `protobuf:"bytes,1,opt,name=lorawan,proto3" json:"lorawan,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ProtocolRxMetadata) Descriptor ¶
func (*ProtocolRxMetadata) Descriptor() ([]byte, []int)
func (*ProtocolRxMetadata) GetLorawan ¶
func (m *ProtocolRxMetadata) GetLorawan() *LoRaWANMetadata
func (*ProtocolRxMetadata) Marshal ¶
func (m *ProtocolRxMetadata) Marshal() (dAtA []byte, err error)
func (*ProtocolRxMetadata) MarshalTo ¶
func (m *ProtocolRxMetadata) MarshalTo(dAtA []byte) (int, error)
func (*ProtocolRxMetadata) MarshalToSizedBuffer ¶
func (m *ProtocolRxMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ProtocolRxMetadata) ProtoMessage ¶
func (*ProtocolRxMetadata) ProtoMessage()
func (*ProtocolRxMetadata) Reset ¶
func (m *ProtocolRxMetadata) Reset()
func (*ProtocolRxMetadata) Size ¶
func (m *ProtocolRxMetadata) Size() (n int)
func (*ProtocolRxMetadata) String ¶
func (m *ProtocolRxMetadata) String() string
func (*ProtocolRxMetadata) Unmarshal ¶
func (m *ProtocolRxMetadata) Unmarshal(dAtA []byte) error
func (*ProtocolRxMetadata) XXX_DiscardUnknown ¶
func (m *ProtocolRxMetadata) XXX_DiscardUnknown()
func (*ProtocolRxMetadata) XXX_Marshal ¶
func (m *ProtocolRxMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProtocolRxMetadata) XXX_Merge ¶
func (m *ProtocolRxMetadata) XXX_Merge(src proto.Message)
func (*ProtocolRxMetadata) XXX_Size ¶
func (m *ProtocolRxMetadata) XXX_Size() int
func (*ProtocolRxMetadata) XXX_Unmarshal ¶
func (m *ProtocolRxMetadata) XXX_Unmarshal(b []byte) error
type ProtocolTxConfiguration ¶
type ProtocolTxConfiguration struct { Lorawan *LoRaWANTxConfiguration `protobuf:"bytes,1,opt,name=lorawan,proto3" json:"lorawan,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ProtocolTxConfiguration) Descriptor ¶
func (*ProtocolTxConfiguration) Descriptor() ([]byte, []int)
func (*ProtocolTxConfiguration) GetLorawan ¶
func (m *ProtocolTxConfiguration) GetLorawan() *LoRaWANTxConfiguration
func (*ProtocolTxConfiguration) Marshal ¶
func (m *ProtocolTxConfiguration) Marshal() (dAtA []byte, err error)
func (*ProtocolTxConfiguration) MarshalTo ¶
func (m *ProtocolTxConfiguration) MarshalTo(dAtA []byte) (int, error)
func (*ProtocolTxConfiguration) MarshalToSizedBuffer ¶
func (m *ProtocolTxConfiguration) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ProtocolTxConfiguration) ProtoMessage ¶
func (*ProtocolTxConfiguration) ProtoMessage()
func (*ProtocolTxConfiguration) Reset ¶
func (m *ProtocolTxConfiguration) Reset()
func (*ProtocolTxConfiguration) Size ¶
func (m *ProtocolTxConfiguration) Size() (n int)
func (*ProtocolTxConfiguration) String ¶
func (m *ProtocolTxConfiguration) String() string
func (*ProtocolTxConfiguration) Unmarshal ¶
func (m *ProtocolTxConfiguration) Unmarshal(dAtA []byte) error
func (*ProtocolTxConfiguration) XXX_DiscardUnknown ¶
func (m *ProtocolTxConfiguration) XXX_DiscardUnknown()
func (*ProtocolTxConfiguration) XXX_Marshal ¶
func (m *ProtocolTxConfiguration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProtocolTxConfiguration) XXX_Merge ¶
func (m *ProtocolTxConfiguration) XXX_Merge(src proto.Message)
func (*ProtocolTxConfiguration) XXX_Size ¶
func (m *ProtocolTxConfiguration) XXX_Size() int
func (*ProtocolTxConfiguration) XXX_Unmarshal ¶
func (m *ProtocolTxConfiguration) XXX_Unmarshal(b []byte) error
type RouterClient ¶
type RouterClient interface { GatewayStatus(ctx context.Context, opts ...grpc.CallOption) (Router_GatewayStatusClient, error) Uplink(ctx context.Context, opts ...grpc.CallOption) (Router_UplinkClient, error) Subscribe(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (Router_SubscribeClient, error) }
RouterClient is the client API for Router service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewRouterClient ¶
func NewRouterClient(cc *grpc.ClientConn) RouterClient
type RouterServer ¶
type RouterServer interface { GatewayStatus(Router_GatewayStatusServer) error Uplink(Router_UplinkServer) error Subscribe(*types.Empty, Router_SubscribeServer) error }
RouterServer is the server API for Router service.
type Router_GatewayStatusClient ¶
type Router_GatewayStatusClient interface { Send(*StatusMessage) error CloseAndRecv() (*types.Empty, error) grpc.ClientStream }
type Router_GatewayStatusServer ¶
type Router_GatewayStatusServer interface { SendAndClose(*types.Empty) error Recv() (*StatusMessage, error) grpc.ServerStream }
type Router_SubscribeClient ¶
type Router_SubscribeClient interface { Recv() (*DownlinkMessage, error) grpc.ClientStream }
type Router_SubscribeServer ¶
type Router_SubscribeServer interface { Send(*DownlinkMessage) error grpc.ServerStream }
type Router_UplinkClient ¶
type Router_UplinkClient interface { Send(*UplinkMessage) error CloseAndRecv() (*types.Empty, error) grpc.ClientStream }
type Router_UplinkServer ¶
type Router_UplinkServer interface { SendAndClose(*types.Empty) error Recv() (*UplinkMessage, error) grpc.ServerStream }
type StatusMessage ¶
type StatusMessage struct { Timestamp uint32 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` Time int64 `protobuf:"varint,2,opt,name=time,proto3" json:"time,omitempty"` GatewayTrusted bool `protobuf:"varint,3,opt,name=gateway_trusted,json=gatewayTrusted,proto3" json:"gateway_trusted,omitempty"` BootTime int64 `protobuf:"varint,4,opt,name=boot_time,json=bootTime,proto3" json:"boot_time,omitempty"` Ip []string `protobuf:"bytes,11,rep,name=ip,proto3" json:"ip,omitempty"` Platform string `protobuf:"bytes,12,opt,name=platform,proto3" json:"platform,omitempty"` ContactEmail string `protobuf:"bytes,13,opt,name=contact_email,json=contactEmail,proto3" json:"contact_email,omitempty"` Description string `protobuf:"bytes,14,opt,name=description,proto3" json:"description,omitempty"` FrequencyPlan string `protobuf:"bytes,15,opt,name=frequency_plan,json=frequencyPlan,proto3" json:"frequency_plan,omitempty"` Bridge string `protobuf:"bytes,16,opt,name=bridge,proto3" json:"bridge,omitempty"` Router string `protobuf:"bytes,17,opt,name=router,proto3" json:"router,omitempty"` Fpga uint32 `protobuf:"varint,18,opt,name=fpga,proto3" json:"fpga,omitempty"` Dsp uint32 `protobuf:"varint,19,opt,name=dsp,proto3" json:"dsp,omitempty"` Hal string `protobuf:"bytes,20,opt,name=hal,proto3" json:"hal,omitempty"` Location *LocationMetadata `protobuf:"bytes,21,opt,name=location,proto3" json:"location,omitempty"` Rtt uint32 `protobuf:"varint,31,opt,name=rtt,proto3" json:"rtt,omitempty"` RxIn uint32 `protobuf:"varint,41,opt,name=rx_in,json=rxIn,proto3" json:"rx_in,omitempty"` RxOk uint32 `protobuf:"varint,42,opt,name=rx_ok,json=rxOk,proto3" json:"rx_ok,omitempty"` TxIn uint32 `protobuf:"varint,43,opt,name=tx_in,json=txIn,proto3" json:"tx_in,omitempty"` TxOk uint32 `protobuf:"varint,44,opt,name=tx_ok,json=txOk,proto3" json:"tx_ok,omitempty"` LmOk uint32 `protobuf:"varint,45,opt,name=lm_ok,json=lmOk,proto3" json:"lm_ok,omitempty"` LmSt uint32 `protobuf:"varint,46,opt,name=lm_st,json=lmSt,proto3" json:"lm_st,omitempty"` LmNw uint32 `protobuf:"varint,47,opt,name=lm_nw,json=lmNw,proto3" json:"lm_nw,omitempty"` LPps uint32 `protobuf:"varint,48,opt,name=l_pps,json=lPps,proto3" json:"l_pps,omitempty"` Os *StatusMessage_OSMetrics `protobuf:"bytes,51,opt,name=os,proto3" json:"os,omitempty"` Messages []string `protobuf:"bytes,52,rep,name=messages,proto3" json:"messages,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StatusMessage) Descriptor ¶
func (*StatusMessage) Descriptor() ([]byte, []int)
func (*StatusMessage) GetBootTime ¶
func (m *StatusMessage) GetBootTime() int64
func (*StatusMessage) GetBridge ¶
func (m *StatusMessage) GetBridge() string
func (*StatusMessage) GetContactEmail ¶
func (m *StatusMessage) GetContactEmail() string
func (*StatusMessage) GetDescription ¶
func (m *StatusMessage) GetDescription() string
func (*StatusMessage) GetDsp ¶
func (m *StatusMessage) GetDsp() uint32
func (*StatusMessage) GetFpga ¶
func (m *StatusMessage) GetFpga() uint32
func (*StatusMessage) GetFrequencyPlan ¶
func (m *StatusMessage) GetFrequencyPlan() string
func (*StatusMessage) GetGatewayTrusted ¶
func (m *StatusMessage) GetGatewayTrusted() bool
func (*StatusMessage) GetHal ¶
func (m *StatusMessage) GetHal() string
func (*StatusMessage) GetIp ¶
func (m *StatusMessage) GetIp() []string
func (*StatusMessage) GetLPps ¶
func (m *StatusMessage) GetLPps() uint32
func (*StatusMessage) GetLmNw ¶
func (m *StatusMessage) GetLmNw() uint32
func (*StatusMessage) GetLmOk ¶
func (m *StatusMessage) GetLmOk() uint32
func (*StatusMessage) GetLmSt ¶
func (m *StatusMessage) GetLmSt() uint32
func (*StatusMessage) GetLocation ¶
func (m *StatusMessage) GetLocation() *LocationMetadata
func (*StatusMessage) GetMessages ¶
func (m *StatusMessage) GetMessages() []string
func (*StatusMessage) GetOs ¶
func (m *StatusMessage) GetOs() *StatusMessage_OSMetrics
func (*StatusMessage) GetPlatform ¶
func (m *StatusMessage) GetPlatform() string
func (*StatusMessage) GetRouter ¶
func (m *StatusMessage) GetRouter() string
func (*StatusMessage) GetRtt ¶
func (m *StatusMessage) GetRtt() uint32
func (*StatusMessage) GetRxIn ¶
func (m *StatusMessage) GetRxIn() uint32
func (*StatusMessage) GetRxOk ¶
func (m *StatusMessage) GetRxOk() uint32
func (*StatusMessage) GetTime ¶
func (m *StatusMessage) GetTime() int64
func (*StatusMessage) GetTimestamp ¶
func (m *StatusMessage) GetTimestamp() uint32
func (*StatusMessage) GetTxIn ¶
func (m *StatusMessage) GetTxIn() uint32
func (*StatusMessage) GetTxOk ¶
func (m *StatusMessage) GetTxOk() uint32
func (*StatusMessage) Marshal ¶
func (m *StatusMessage) Marshal() (dAtA []byte, err error)
func (*StatusMessage) MarshalToSizedBuffer ¶
func (m *StatusMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StatusMessage) ProtoMessage ¶
func (*StatusMessage) ProtoMessage()
func (*StatusMessage) Reset ¶
func (m *StatusMessage) Reset()
func (*StatusMessage) Size ¶
func (m *StatusMessage) Size() (n int)
func (*StatusMessage) String ¶
func (m *StatusMessage) String() string
func (*StatusMessage) Unmarshal ¶
func (m *StatusMessage) Unmarshal(dAtA []byte) error
func (*StatusMessage) XXX_DiscardUnknown ¶
func (m *StatusMessage) XXX_DiscardUnknown()
func (*StatusMessage) XXX_Marshal ¶
func (m *StatusMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StatusMessage) XXX_Merge ¶
func (m *StatusMessage) XXX_Merge(src proto.Message)
func (*StatusMessage) XXX_Size ¶
func (m *StatusMessage) XXX_Size() int
func (*StatusMessage) XXX_Unmarshal ¶
func (m *StatusMessage) XXX_Unmarshal(b []byte) error
type StatusMessage_OSMetrics ¶
type StatusMessage_OSMetrics struct { Load_1 float32 `protobuf:"fixed32,1,opt,name=load_1,json=load1,proto3" json:"load_1,omitempty"` Load_5 float32 `protobuf:"fixed32,2,opt,name=load_5,json=load5,proto3" json:"load_5,omitempty"` Load_15 float32 `protobuf:"fixed32,3,opt,name=load_15,json=load15,proto3" json:"load_15,omitempty"` CpuPercentage float32 `protobuf:"fixed32,11,opt,name=cpu_percentage,json=cpuPercentage,proto3" json:"cpu_percentage,omitempty"` MemoryPercentage float32 `protobuf:"fixed32,21,opt,name=memory_percentage,json=memoryPercentage,proto3" json:"memory_percentage,omitempty"` Temperature float32 `protobuf:"fixed32,31,opt,name=temperature,proto3" json:"temperature,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StatusMessage_OSMetrics) Descriptor ¶
func (*StatusMessage_OSMetrics) Descriptor() ([]byte, []int)
func (*StatusMessage_OSMetrics) GetCpuPercentage ¶
func (m *StatusMessage_OSMetrics) GetCpuPercentage() float32
func (*StatusMessage_OSMetrics) GetLoad_1 ¶
func (m *StatusMessage_OSMetrics) GetLoad_1() float32
func (*StatusMessage_OSMetrics) GetLoad_15 ¶
func (m *StatusMessage_OSMetrics) GetLoad_15() float32
func (*StatusMessage_OSMetrics) GetLoad_5 ¶
func (m *StatusMessage_OSMetrics) GetLoad_5() float32
func (*StatusMessage_OSMetrics) GetMemoryPercentage ¶
func (m *StatusMessage_OSMetrics) GetMemoryPercentage() float32
func (*StatusMessage_OSMetrics) GetTemperature ¶
func (m *StatusMessage_OSMetrics) GetTemperature() float32
func (*StatusMessage_OSMetrics) Marshal ¶
func (m *StatusMessage_OSMetrics) Marshal() (dAtA []byte, err error)
func (*StatusMessage_OSMetrics) MarshalTo ¶
func (m *StatusMessage_OSMetrics) MarshalTo(dAtA []byte) (int, error)
func (*StatusMessage_OSMetrics) MarshalToSizedBuffer ¶
func (m *StatusMessage_OSMetrics) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StatusMessage_OSMetrics) ProtoMessage ¶
func (*StatusMessage_OSMetrics) ProtoMessage()
func (*StatusMessage_OSMetrics) Reset ¶
func (m *StatusMessage_OSMetrics) Reset()
func (*StatusMessage_OSMetrics) Size ¶
func (m *StatusMessage_OSMetrics) Size() (n int)
func (*StatusMessage_OSMetrics) String ¶
func (m *StatusMessage_OSMetrics) String() string
func (*StatusMessage_OSMetrics) Unmarshal ¶
func (m *StatusMessage_OSMetrics) Unmarshal(dAtA []byte) error
func (*StatusMessage_OSMetrics) XXX_DiscardUnknown ¶
func (m *StatusMessage_OSMetrics) XXX_DiscardUnknown()
func (*StatusMessage_OSMetrics) XXX_Marshal ¶
func (m *StatusMessage_OSMetrics) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StatusMessage_OSMetrics) XXX_Merge ¶
func (m *StatusMessage_OSMetrics) XXX_Merge(src proto.Message)
func (*StatusMessage_OSMetrics) XXX_Size ¶
func (m *StatusMessage_OSMetrics) XXX_Size() int
func (*StatusMessage_OSMetrics) XXX_Unmarshal ¶
func (m *StatusMessage_OSMetrics) XXX_Unmarshal(b []byte) error
type Trace ¶
type Trace struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Time int64 `protobuf:"varint,2,opt,name=time,proto3" json:"time,omitempty"` ServiceId string `protobuf:"bytes,3,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"` ServiceName string `protobuf:"bytes,4,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"` Event string `protobuf:"bytes,5,opt,name=event,proto3" json:"event,omitempty"` Metadata map[string]string `` /* 157-byte string literal not displayed */ Parents []*Trace `protobuf:"bytes,11,rep,name=parents,proto3" json:"parents,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Trace) Descriptor ¶
func (*Trace) GetMetadata ¶
func (*Trace) GetParents ¶
func (*Trace) GetServiceId ¶
func (*Trace) GetServiceName ¶
func (*Trace) ProtoMessage ¶
func (*Trace) ProtoMessage()
func (*Trace) XXX_DiscardUnknown ¶
func (m *Trace) XXX_DiscardUnknown()
func (*Trace) XXX_Marshal ¶
func (*Trace) XXX_Unmarshal ¶
type UnimplementedDiscoveryServer ¶
type UnimplementedDiscoveryServer struct { }
UnimplementedDiscoveryServer can be embedded to have forward compatible implementations.
func (*UnimplementedDiscoveryServer) Get ¶
func (*UnimplementedDiscoveryServer) Get(ctx context.Context, req *GetRequest) (*Announcement, error)
type UnimplementedRouterServer ¶
type UnimplementedRouterServer struct { }
UnimplementedRouterServer can be embedded to have forward compatible implementations.
func (*UnimplementedRouterServer) GatewayStatus ¶
func (*UnimplementedRouterServer) GatewayStatus(srv Router_GatewayStatusServer) error
func (*UnimplementedRouterServer) Subscribe ¶
func (*UnimplementedRouterServer) Subscribe(req *types.Empty, srv Router_SubscribeServer) error
func (*UnimplementedRouterServer) Uplink ¶
func (*UnimplementedRouterServer) Uplink(srv Router_UplinkServer) error
type UplinkMessage ¶
type UplinkMessage struct { Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"` // ProtocolMessage message = 2; ProtocolMetadata *ProtocolRxMetadata `protobuf:"bytes,11,opt,name=protocol_metadata,json=protocolMetadata,proto3" json:"protocol_metadata,omitempty"` GatewayMetadata *GatewayRxMetadata `protobuf:"bytes,12,opt,name=gateway_metadata,json=gatewayMetadata,proto3" json:"gateway_metadata,omitempty"` Trace *Trace `protobuf:"bytes,21,opt,name=trace,proto3" json:"trace,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*UplinkMessage) Descriptor ¶
func (*UplinkMessage) Descriptor() ([]byte, []int)
func (*UplinkMessage) GetGatewayMetadata ¶
func (m *UplinkMessage) GetGatewayMetadata() *GatewayRxMetadata
func (*UplinkMessage) GetPayload ¶
func (m *UplinkMessage) GetPayload() []byte
func (*UplinkMessage) GetProtocolMetadata ¶
func (m *UplinkMessage) GetProtocolMetadata() *ProtocolRxMetadata
func (*UplinkMessage) GetTrace ¶
func (m *UplinkMessage) GetTrace() *Trace
func (*UplinkMessage) Marshal ¶
func (m *UplinkMessage) Marshal() (dAtA []byte, err error)
func (*UplinkMessage) MarshalToSizedBuffer ¶
func (m *UplinkMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*UplinkMessage) ProtoMessage ¶
func (*UplinkMessage) ProtoMessage()
func (*UplinkMessage) Reset ¶
func (m *UplinkMessage) Reset()
func (*UplinkMessage) Size ¶
func (m *UplinkMessage) Size() (n int)
func (*UplinkMessage) String ¶
func (m *UplinkMessage) String() string
func (*UplinkMessage) Unmarshal ¶
func (m *UplinkMessage) Unmarshal(dAtA []byte) error
func (*UplinkMessage) XXX_DiscardUnknown ¶
func (m *UplinkMessage) XXX_DiscardUnknown()
func (*UplinkMessage) XXX_Marshal ¶
func (m *UplinkMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UplinkMessage) XXX_Merge ¶
func (m *UplinkMessage) XXX_Merge(src proto.Message)
func (*UplinkMessage) XXX_Size ¶
func (m *UplinkMessage) XXX_Size() int
func (*UplinkMessage) XXX_Unmarshal ¶
func (m *UplinkMessage) XXX_Unmarshal(b []byte) error