Documentation
¶
Index ¶
- Variables
- func RegisterRouterManagerServer(s *grpc.Server, srv RouterManagerServer)
- func RegisterRouterServer(s *grpc.Server, srv RouterServer)
- type DeviceActivationRequest
- func (*DeviceActivationRequest) Descriptor() ([]byte, []int)
- func (this *DeviceActivationRequest) Equal(that interface{}) bool
- func (m *DeviceActivationRequest) GetActivationMetadata() *protocol.ActivationMetadata
- func (m *DeviceActivationRequest) GetAppEUI() (eui types.AppEUI)
- func (m *DeviceActivationRequest) GetDevEUI() (eui types.DevEUI)
- func (m *DeviceActivationRequest) GetGatewayMetadata() gateway.RxMetadata
- func (m *DeviceActivationRequest) GetMessage() *protocol.Message
- func (m *DeviceActivationRequest) GetPayload() []byte
- func (m *DeviceActivationRequest) GetProtocolMetadata() protocol.RxMetadata
- func (m *DeviceActivationRequest) GetTrace() *trace.Trace
- func (m *DeviceActivationRequest) Marshal() (dAtA []byte, err error)
- func (m *DeviceActivationRequest) MarshalPayload() error
- func (m *DeviceActivationRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *DeviceActivationRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DeviceActivationRequest) ProtoMessage()
- func (m *DeviceActivationRequest) Reset()
- func (m *DeviceActivationRequest) Size() (n int)
- func (this *DeviceActivationRequest) String() string
- func (m *DeviceActivationRequest) Unmarshal(dAtA []byte) error
- func (m *DeviceActivationRequest) UnmarshalPayload() error
- func (m *DeviceActivationRequest) Validate() error
- func (m *DeviceActivationRequest) XXX_DiscardUnknown()
- func (m *DeviceActivationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeviceActivationRequest) XXX_Merge(src proto.Message)
- func (m *DeviceActivationRequest) XXX_Size() int
- func (m *DeviceActivationRequest) XXX_Unmarshal(b []byte) error
- type DeviceActivationResponse
- func (*DeviceActivationResponse) Descriptor() ([]byte, []int)
- func (this *DeviceActivationResponse) Equal(that interface{}) bool
- func (m *DeviceActivationResponse) Marshal() (dAtA []byte, err error)
- func (m *DeviceActivationResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *DeviceActivationResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DeviceActivationResponse) ProtoMessage()
- func (m *DeviceActivationResponse) Reset()
- func (m *DeviceActivationResponse) Size() (n int)
- func (this *DeviceActivationResponse) String() string
- func (m *DeviceActivationResponse) Unmarshal(dAtA []byte) error
- func (m *DeviceActivationResponse) XXX_DiscardUnknown()
- func (m *DeviceActivationResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeviceActivationResponse) XXX_Merge(src proto.Message)
- func (m *DeviceActivationResponse) XXX_Size() int
- func (m *DeviceActivationResponse) XXX_Unmarshal(b []byte) error
- type DownlinkMessage
- func (*DownlinkMessage) Descriptor() ([]byte, []int)
- func (this *DownlinkMessage) Equal(that interface{}) bool
- func (m *DownlinkMessage) GetGatewayConfiguration() gateway.TxConfiguration
- func (m *DownlinkMessage) GetMessage() *protocol.Message
- func (m *DownlinkMessage) GetPayload() []byte
- func (m *DownlinkMessage) GetProtocolConfiguration() protocol.TxConfiguration
- func (m *DownlinkMessage) GetTrace() *trace.Trace
- func (m *DownlinkMessage) Marshal() (dAtA []byte, err error)
- func (m *DownlinkMessage) MarshalPayload() 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 (this *DownlinkMessage) String() string
- func (m *DownlinkMessage) Unmarshal(dAtA []byte) error
- func (m *DownlinkMessage) UnmarshalPayload() error
- func (m *DownlinkMessage) Validate() 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 GatewayStatusRequest
- func (*GatewayStatusRequest) Descriptor() ([]byte, []int)
- func (this *GatewayStatusRequest) Equal(that interface{}) bool
- func (m *GatewayStatusRequest) GetGatewayID() string
- func (m *GatewayStatusRequest) Marshal() (dAtA []byte, err error)
- func (m *GatewayStatusRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GatewayStatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GatewayStatusRequest) ProtoMessage()
- func (m *GatewayStatusRequest) Reset()
- func (m *GatewayStatusRequest) Size() (n int)
- func (this *GatewayStatusRequest) String() string
- func (m *GatewayStatusRequest) Unmarshal(dAtA []byte) error
- func (m *GatewayStatusRequest) XXX_DiscardUnknown()
- func (m *GatewayStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GatewayStatusRequest) XXX_Merge(src proto.Message)
- func (m *GatewayStatusRequest) XXX_Size() int
- func (m *GatewayStatusRequest) XXX_Unmarshal(b []byte) error
- type GatewayStatusResponse
- func (*GatewayStatusResponse) Descriptor() ([]byte, []int)
- func (this *GatewayStatusResponse) Equal(that interface{}) bool
- func (m *GatewayStatusResponse) GetLastSeen() int64
- func (m *GatewayStatusResponse) GetStatus() gateway.Status
- func (m *GatewayStatusResponse) Marshal() (dAtA []byte, err error)
- func (m *GatewayStatusResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GatewayStatusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GatewayStatusResponse) ProtoMessage()
- func (m *GatewayStatusResponse) Reset()
- func (m *GatewayStatusResponse) Size() (n int)
- func (this *GatewayStatusResponse) String() string
- func (m *GatewayStatusResponse) Unmarshal(dAtA []byte) error
- func (m *GatewayStatusResponse) XXX_DiscardUnknown()
- func (m *GatewayStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GatewayStatusResponse) XXX_Merge(src proto.Message)
- func (m *GatewayStatusResponse) XXX_Size() int
- func (m *GatewayStatusResponse) XXX_Unmarshal(b []byte) error
- type RouterClient
- type RouterManagerClient
- type RouterManagerServer
- type RouterServer
- type Router_GatewayStatusClient
- type Router_GatewayStatusServer
- type Router_SubscribeClient
- type Router_SubscribeServer
- type Router_UplinkClient
- type Router_UplinkServer
- type Status
- func (*Status) Descriptor() ([]byte, []int)
- func (this *Status) Equal(that interface{}) bool
- func (m *Status) GetActivations() *api.Rates
- func (m *Status) GetComponent() *api.ComponentStats
- func (m *Status) GetConnectedBrokers() uint32
- func (m *Status) GetConnectedGateways() uint32
- func (m *Status) GetDownlink() *api.Rates
- func (m *Status) GetGatewayStatus() *api.Rates
- func (m *Status) GetSystem() *api.SystemStats
- func (m *Status) GetUplink() *api.Rates
- func (m *Status) Marshal() (dAtA []byte, err error)
- func (m *Status) MarshalTo(dAtA []byte) (int, error)
- func (m *Status) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Status) ProtoMessage()
- func (m *Status) Reset()
- func (m *Status) Size() (n int)
- func (this *Status) String() string
- func (m *Status) Unmarshal(dAtA []byte) error
- func (m *Status) XXX_DiscardUnknown()
- func (m *Status) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Status) XXX_Merge(src proto.Message)
- func (m *Status) XXX_Size() int
- func (m *Status) XXX_Unmarshal(b []byte) error
- type StatusRequest
- func (*StatusRequest) Descriptor() ([]byte, []int)
- func (this *StatusRequest) Equal(that interface{}) bool
- func (m *StatusRequest) Marshal() (dAtA []byte, err error)
- func (m *StatusRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *StatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StatusRequest) ProtoMessage()
- func (m *StatusRequest) Reset()
- func (m *StatusRequest) Size() (n int)
- func (this *StatusRequest) String() string
- func (m *StatusRequest) Unmarshal(dAtA []byte) error
- func (m *StatusRequest) XXX_DiscardUnknown()
- func (m *StatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StatusRequest) XXX_Merge(src proto.Message)
- func (m *StatusRequest) XXX_Size() int
- func (m *StatusRequest) XXX_Unmarshal(b []byte) error
- type SubscribeRequest
- func (*SubscribeRequest) Descriptor() ([]byte, []int)
- func (this *SubscribeRequest) Equal(that interface{}) bool
- func (m *SubscribeRequest) Marshal() (dAtA []byte, err error)
- func (m *SubscribeRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *SubscribeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SubscribeRequest) ProtoMessage()
- func (m *SubscribeRequest) Reset()
- func (m *SubscribeRequest) Size() (n int)
- func (this *SubscribeRequest) String() string
- func (m *SubscribeRequest) Unmarshal(dAtA []byte) error
- func (m *SubscribeRequest) XXX_DiscardUnknown()
- func (m *SubscribeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SubscribeRequest) XXX_Merge(src proto.Message)
- func (m *SubscribeRequest) XXX_Size() int
- func (m *SubscribeRequest) XXX_Unmarshal(b []byte) error
- type UnimplementedRouterManagerServer
- type UnimplementedRouterServer
- func (*UnimplementedRouterServer) Activate(ctx context.Context, req *DeviceActivationRequest) (*DeviceActivationResponse, error)
- func (*UnimplementedRouterServer) GatewayStatus(srv Router_GatewayStatusServer) error
- func (*UnimplementedRouterServer) Subscribe(req *SubscribeRequest, srv Router_SubscribeServer) error
- func (*UnimplementedRouterServer) Uplink(srv Router_UplinkServer) error
- type UplinkMessage
- func (*UplinkMessage) Descriptor() ([]byte, []int)
- func (this *UplinkMessage) Equal(that interface{}) bool
- func (m *UplinkMessage) GetGatewayMetadata() gateway.RxMetadata
- func (m *UplinkMessage) GetMessage() *protocol.Message
- func (m *UplinkMessage) GetPayload() []byte
- func (m *UplinkMessage) GetProtocolMetadata() protocol.RxMetadata
- func (m *UplinkMessage) GetTrace() *trace.Trace
- func (m *UplinkMessage) Marshal() (dAtA []byte, err error)
- func (m *UplinkMessage) MarshalPayload() 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 (this *UplinkMessage) String() string
- func (m *UplinkMessage) Unmarshal(dAtA []byte) error
- func (m *UplinkMessage) UnmarshalPayload() error
- func (m *UplinkMessage) Validate() 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 ¶
Functions ¶
func RegisterRouterManagerServer ¶
func RegisterRouterManagerServer(s *grpc.Server, srv RouterManagerServer)
func RegisterRouterServer ¶
func RegisterRouterServer(s *grpc.Server, srv RouterServer)
Types ¶
type DeviceActivationRequest ¶
type DeviceActivationRequest struct { Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"` Message *protocol.Message `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` DevEUI github_com_TheThingsNetwork_ttn_core_types.DevEUI `` /* 131-byte string literal not displayed */ AppEUI github_com_TheThingsNetwork_ttn_core_types.AppEUI `` /* 131-byte string literal not displayed */ ProtocolMetadata protocol.RxMetadata `protobuf:"bytes,21,opt,name=protocol_metadata,json=protocolMetadata,proto3" json:"protocol_metadata"` GatewayMetadata gateway.RxMetadata `protobuf:"bytes,22,opt,name=gateway_metadata,json=gatewayMetadata,proto3" json:"gateway_metadata"` ActivationMetadata *protocol.ActivationMetadata `protobuf:"bytes,23,opt,name=activation_metadata,json=activationMetadata,proto3" json:"activation_metadata,omitempty"` Trace *trace.Trace `protobuf:"bytes,31,opt,name=trace,proto3" json:"trace,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedDeviceActivationRequest ¶
func NewPopulatedDeviceActivationRequest(r randyRouter, easy bool) *DeviceActivationRequest
func (*DeviceActivationRequest) Descriptor ¶
func (*DeviceActivationRequest) Descriptor() ([]byte, []int)
func (*DeviceActivationRequest) Equal ¶
func (this *DeviceActivationRequest) Equal(that interface{}) bool
func (*DeviceActivationRequest) GetActivationMetadata ¶
func (m *DeviceActivationRequest) GetActivationMetadata() *protocol.ActivationMetadata
func (*DeviceActivationRequest) GetAppEUI ¶
func (m *DeviceActivationRequest) GetAppEUI() (eui types.AppEUI)
func (*DeviceActivationRequest) GetDevEUI ¶
func (m *DeviceActivationRequest) GetDevEUI() (eui types.DevEUI)
func (*DeviceActivationRequest) GetGatewayMetadata ¶
func (m *DeviceActivationRequest) GetGatewayMetadata() gateway.RxMetadata
func (*DeviceActivationRequest) GetMessage ¶
func (m *DeviceActivationRequest) GetMessage() *protocol.Message
func (*DeviceActivationRequest) GetPayload ¶
func (m *DeviceActivationRequest) GetPayload() []byte
func (*DeviceActivationRequest) GetProtocolMetadata ¶
func (m *DeviceActivationRequest) GetProtocolMetadata() protocol.RxMetadata
func (*DeviceActivationRequest) GetTrace ¶
func (m *DeviceActivationRequest) GetTrace() *trace.Trace
func (*DeviceActivationRequest) Marshal ¶
func (m *DeviceActivationRequest) Marshal() (dAtA []byte, err error)
func (*DeviceActivationRequest) MarshalPayload ¶
func (m *DeviceActivationRequest) MarshalPayload() error
MarshalPayload marshals the Message into Payload if Payload is nil
func (*DeviceActivationRequest) MarshalTo ¶
func (m *DeviceActivationRequest) MarshalTo(dAtA []byte) (int, error)
func (*DeviceActivationRequest) MarshalToSizedBuffer ¶
func (m *DeviceActivationRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DeviceActivationRequest) ProtoMessage ¶
func (*DeviceActivationRequest) ProtoMessage()
func (*DeviceActivationRequest) Reset ¶
func (m *DeviceActivationRequest) Reset()
func (*DeviceActivationRequest) Size ¶
func (m *DeviceActivationRequest) Size() (n int)
func (*DeviceActivationRequest) String ¶
func (this *DeviceActivationRequest) String() string
func (*DeviceActivationRequest) Unmarshal ¶
func (m *DeviceActivationRequest) Unmarshal(dAtA []byte) error
func (*DeviceActivationRequest) UnmarshalPayload ¶
func (m *DeviceActivationRequest) UnmarshalPayload() error
UnmarshalPayload unmarshals the Payload into Message if Message is nil
func (*DeviceActivationRequest) Validate ¶
func (m *DeviceActivationRequest) Validate() error
Validate implements the api.Validator interface
func (*DeviceActivationRequest) XXX_DiscardUnknown ¶
func (m *DeviceActivationRequest) XXX_DiscardUnknown()
func (*DeviceActivationRequest) XXX_Marshal ¶
func (m *DeviceActivationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeviceActivationRequest) XXX_Merge ¶
func (m *DeviceActivationRequest) XXX_Merge(src proto.Message)
func (*DeviceActivationRequest) XXX_Size ¶
func (m *DeviceActivationRequest) XXX_Size() int
func (*DeviceActivationRequest) XXX_Unmarshal ¶
func (m *DeviceActivationRequest) XXX_Unmarshal(b []byte) error
type DeviceActivationResponse ¶
type DeviceActivationResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedDeviceActivationResponse ¶
func NewPopulatedDeviceActivationResponse(r randyRouter, easy bool) *DeviceActivationResponse
func (*DeviceActivationResponse) Descriptor ¶
func (*DeviceActivationResponse) Descriptor() ([]byte, []int)
func (*DeviceActivationResponse) Equal ¶
func (this *DeviceActivationResponse) Equal(that interface{}) bool
func (*DeviceActivationResponse) Marshal ¶
func (m *DeviceActivationResponse) Marshal() (dAtA []byte, err error)
func (*DeviceActivationResponse) MarshalTo ¶
func (m *DeviceActivationResponse) MarshalTo(dAtA []byte) (int, error)
func (*DeviceActivationResponse) MarshalToSizedBuffer ¶
func (m *DeviceActivationResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DeviceActivationResponse) ProtoMessage ¶
func (*DeviceActivationResponse) ProtoMessage()
func (*DeviceActivationResponse) Reset ¶
func (m *DeviceActivationResponse) Reset()
func (*DeviceActivationResponse) Size ¶
func (m *DeviceActivationResponse) Size() (n int)
func (*DeviceActivationResponse) String ¶
func (this *DeviceActivationResponse) String() string
func (*DeviceActivationResponse) Unmarshal ¶
func (m *DeviceActivationResponse) Unmarshal(dAtA []byte) error
func (*DeviceActivationResponse) XXX_DiscardUnknown ¶
func (m *DeviceActivationResponse) XXX_DiscardUnknown()
func (*DeviceActivationResponse) XXX_Marshal ¶
func (m *DeviceActivationResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeviceActivationResponse) XXX_Merge ¶
func (m *DeviceActivationResponse) XXX_Merge(src proto.Message)
func (*DeviceActivationResponse) XXX_Size ¶
func (m *DeviceActivationResponse) XXX_Size() int
func (*DeviceActivationResponse) XXX_Unmarshal ¶
func (m *DeviceActivationResponse) XXX_Unmarshal(b []byte) error
type DownlinkMessage ¶
type DownlinkMessage struct { Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"` Message *protocol.Message `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` ProtocolConfiguration protocol.TxConfiguration `protobuf:"bytes,11,opt,name=protocol_configuration,json=protocolConfiguration,proto3" json:"protocol_configuration"` GatewayConfiguration gateway.TxConfiguration `protobuf:"bytes,12,opt,name=gateway_configuration,json=gatewayConfiguration,proto3" json:"gateway_configuration"` Trace *trace.Trace `protobuf:"bytes,21,opt,name=trace,proto3" json:"trace,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedDownlinkMessage ¶
func NewPopulatedDownlinkMessage(r randyRouter, easy bool) *DownlinkMessage
func (*DownlinkMessage) Descriptor ¶
func (*DownlinkMessage) Descriptor() ([]byte, []int)
func (*DownlinkMessage) Equal ¶
func (this *DownlinkMessage) Equal(that interface{}) bool
func (*DownlinkMessage) GetGatewayConfiguration ¶
func (m *DownlinkMessage) GetGatewayConfiguration() gateway.TxConfiguration
func (*DownlinkMessage) GetMessage ¶
func (m *DownlinkMessage) GetMessage() *protocol.Message
func (*DownlinkMessage) GetPayload ¶
func (m *DownlinkMessage) GetPayload() []byte
func (*DownlinkMessage) GetProtocolConfiguration ¶
func (m *DownlinkMessage) GetProtocolConfiguration() protocol.TxConfiguration
func (*DownlinkMessage) GetTrace ¶
func (m *DownlinkMessage) GetTrace() *trace.Trace
func (*DownlinkMessage) Marshal ¶
func (m *DownlinkMessage) Marshal() (dAtA []byte, err error)
func (*DownlinkMessage) MarshalPayload ¶
func (m *DownlinkMessage) MarshalPayload() error
MarshalPayload marshals the Message into Payload if Payload is nil
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 (this *DownlinkMessage) String() string
func (*DownlinkMessage) Unmarshal ¶
func (m *DownlinkMessage) Unmarshal(dAtA []byte) error
func (*DownlinkMessage) UnmarshalPayload ¶
func (m *DownlinkMessage) UnmarshalPayload() error
UnmarshalPayload unmarshals the Payload into Message if Message is nil
func (*DownlinkMessage) Validate ¶
func (m *DownlinkMessage) Validate() error
Validate implements the api.Validator interface
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 GatewayStatusRequest ¶
type GatewayStatusRequest struct { GatewayID string `protobuf:"bytes,1,opt,name=gateway_id,json=gatewayId,proto3" json:"gateway_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_sizecache int32 `json:"-"` }
message GatewayStatusRequest is used to request the status of a gateway from this Router
func NewPopulatedGatewayStatusRequest ¶
func NewPopulatedGatewayStatusRequest(r randyRouter, easy bool) *GatewayStatusRequest
func (*GatewayStatusRequest) Descriptor ¶
func (*GatewayStatusRequest) Descriptor() ([]byte, []int)
func (*GatewayStatusRequest) Equal ¶
func (this *GatewayStatusRequest) Equal(that interface{}) bool
func (*GatewayStatusRequest) GetGatewayID ¶
func (m *GatewayStatusRequest) GetGatewayID() string
func (*GatewayStatusRequest) Marshal ¶
func (m *GatewayStatusRequest) Marshal() (dAtA []byte, err error)
func (*GatewayStatusRequest) MarshalTo ¶
func (m *GatewayStatusRequest) MarshalTo(dAtA []byte) (int, error)
func (*GatewayStatusRequest) MarshalToSizedBuffer ¶
func (m *GatewayStatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GatewayStatusRequest) ProtoMessage ¶
func (*GatewayStatusRequest) ProtoMessage()
func (*GatewayStatusRequest) Reset ¶
func (m *GatewayStatusRequest) Reset()
func (*GatewayStatusRequest) Size ¶
func (m *GatewayStatusRequest) Size() (n int)
func (*GatewayStatusRequest) String ¶
func (this *GatewayStatusRequest) String() string
func (*GatewayStatusRequest) Unmarshal ¶
func (m *GatewayStatusRequest) Unmarshal(dAtA []byte) error
func (*GatewayStatusRequest) XXX_DiscardUnknown ¶
func (m *GatewayStatusRequest) XXX_DiscardUnknown()
func (*GatewayStatusRequest) XXX_Marshal ¶
func (m *GatewayStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GatewayStatusRequest) XXX_Merge ¶
func (m *GatewayStatusRequest) XXX_Merge(src proto.Message)
func (*GatewayStatusRequest) XXX_Size ¶
func (m *GatewayStatusRequest) XXX_Size() int
func (*GatewayStatusRequest) XXX_Unmarshal ¶
func (m *GatewayStatusRequest) XXX_Unmarshal(b []byte) error
type GatewayStatusResponse ¶
type GatewayStatusResponse struct { LastSeen int64 `protobuf:"varint,1,opt,name=last_seen,json=lastSeen,proto3" json:"last_seen,omitempty"` Status gateway.Status `protobuf:"bytes,2,opt,name=status,proto3" json:"status"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedGatewayStatusResponse ¶
func NewPopulatedGatewayStatusResponse(r randyRouter, easy bool) *GatewayStatusResponse
func (*GatewayStatusResponse) Descriptor ¶
func (*GatewayStatusResponse) Descriptor() ([]byte, []int)
func (*GatewayStatusResponse) Equal ¶
func (this *GatewayStatusResponse) Equal(that interface{}) bool
func (*GatewayStatusResponse) GetLastSeen ¶
func (m *GatewayStatusResponse) GetLastSeen() int64
func (*GatewayStatusResponse) GetStatus ¶
func (m *GatewayStatusResponse) GetStatus() gateway.Status
func (*GatewayStatusResponse) Marshal ¶
func (m *GatewayStatusResponse) Marshal() (dAtA []byte, err error)
func (*GatewayStatusResponse) MarshalTo ¶
func (m *GatewayStatusResponse) MarshalTo(dAtA []byte) (int, error)
func (*GatewayStatusResponse) MarshalToSizedBuffer ¶
func (m *GatewayStatusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GatewayStatusResponse) ProtoMessage ¶
func (*GatewayStatusResponse) ProtoMessage()
func (*GatewayStatusResponse) Reset ¶
func (m *GatewayStatusResponse) Reset()
func (*GatewayStatusResponse) Size ¶
func (m *GatewayStatusResponse) Size() (n int)
func (*GatewayStatusResponse) String ¶
func (this *GatewayStatusResponse) String() string
func (*GatewayStatusResponse) Unmarshal ¶
func (m *GatewayStatusResponse) Unmarshal(dAtA []byte) error
func (*GatewayStatusResponse) XXX_DiscardUnknown ¶
func (m *GatewayStatusResponse) XXX_DiscardUnknown()
func (*GatewayStatusResponse) XXX_Marshal ¶
func (m *GatewayStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GatewayStatusResponse) XXX_Merge ¶
func (m *GatewayStatusResponse) XXX_Merge(src proto.Message)
func (*GatewayStatusResponse) XXX_Size ¶
func (m *GatewayStatusResponse) XXX_Size() int
func (*GatewayStatusResponse) XXX_Unmarshal ¶
func (m *GatewayStatusResponse) XXX_Unmarshal(b []byte) error
type RouterClient ¶
type RouterClient interface { // Gateway streams status messages to Router GatewayStatus(ctx context.Context, opts ...grpc.CallOption) (Router_GatewayStatusClient, error) // Gateway streams uplink messages to Router Uplink(ctx context.Context, opts ...grpc.CallOption) (Router_UplinkClient, error) // Gateway subscribes to downlink messages from Router // It is possible to open multiple subscriptions (but not recommended). // If you do this, you are responsible for de-duplication of downlink messages. Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (Router_SubscribeClient, error) // Gateway requests device activation Activate(ctx context.Context, in *DeviceActivationRequest, opts ...grpc.CallOption) (*DeviceActivationResponse, 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 RouterManagerClient ¶
type RouterManagerClient interface { // Gateway owner or network operator requests Gateway status from Router Manager // Deprecated: Use monitor API (NOC) instead of this GatewayStatus(ctx context.Context, in *GatewayStatusRequest, opts ...grpc.CallOption) (*GatewayStatusResponse, error) // Network operator requests Router status GetStatus(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*Status, error) }
RouterManagerClient is the client API for RouterManager service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewRouterManagerClient ¶
func NewRouterManagerClient(cc *grpc.ClientConn) RouterManagerClient
type RouterManagerServer ¶
type RouterManagerServer interface { // Gateway owner or network operator requests Gateway status from Router Manager // Deprecated: Use monitor API (NOC) instead of this GatewayStatus(context.Context, *GatewayStatusRequest) (*GatewayStatusResponse, error) // Network operator requests Router status GetStatus(context.Context, *StatusRequest) (*Status, error) }
RouterManagerServer is the server API for RouterManager service.
type RouterServer ¶
type RouterServer interface { // Gateway streams status messages to Router GatewayStatus(Router_GatewayStatusServer) error // Gateway streams uplink messages to Router Uplink(Router_UplinkServer) error // Gateway subscribes to downlink messages from Router // It is possible to open multiple subscriptions (but not recommended). // If you do this, you are responsible for de-duplication of downlink messages. Subscribe(*SubscribeRequest, Router_SubscribeServer) error // Gateway requests device activation Activate(context.Context, *DeviceActivationRequest) (*DeviceActivationResponse, error) }
RouterServer is the server API for Router service.
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 Status ¶
type Status struct { System *api.SystemStats `protobuf:"bytes,1,opt,name=system,proto3" json:"system,omitempty"` Component *api.ComponentStats `protobuf:"bytes,2,opt,name=component,proto3" json:"component,omitempty"` GatewayStatus *api.Rates `protobuf:"bytes,11,opt,name=gateway_status,json=gatewayStatus,proto3" json:"gateway_status,omitempty"` Uplink *api.Rates `protobuf:"bytes,12,opt,name=uplink,proto3" json:"uplink,omitempty"` Downlink *api.Rates `protobuf:"bytes,13,opt,name=downlink,proto3" json:"downlink,omitempty"` Activations *api.Rates `protobuf:"bytes,14,opt,name=activations,proto3" json:"activations,omitempty"` // Connections ConnectedGateways uint32 `protobuf:"varint,21,opt,name=connected_gateways,json=connectedGateways,proto3" json:"connected_gateways,omitempty"` ConnectedBrokers uint32 `protobuf:"varint,22,opt,name=connected_brokers,json=connectedBrokers,proto3" json:"connected_brokers,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_sizecache int32 `json:"-"` }
message Status is the response to the StatusRequest
func NewPopulatedStatus ¶
func (*Status) Descriptor ¶
func (*Status) GetActivations ¶
func (*Status) GetComponent ¶
func (m *Status) GetComponent() *api.ComponentStats
func (*Status) GetConnectedBrokers ¶
func (*Status) GetConnectedGateways ¶
func (*Status) GetDownlink ¶
func (*Status) GetGatewayStatus ¶
func (*Status) GetSystem ¶
func (m *Status) GetSystem() *api.SystemStats
func (*Status) MarshalToSizedBuffer ¶
func (*Status) ProtoMessage ¶
func (*Status) ProtoMessage()
func (*Status) XXX_DiscardUnknown ¶
func (m *Status) XXX_DiscardUnknown()
func (*Status) XXX_Marshal ¶
func (*Status) XXX_Unmarshal ¶
type StatusRequest ¶
type StatusRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_sizecache int32 `json:"-"` }
message StatusRequest is used to request the status of this Router
func NewPopulatedStatusRequest ¶
func NewPopulatedStatusRequest(r randyRouter, easy bool) *StatusRequest
func (*StatusRequest) Descriptor ¶
func (*StatusRequest) Descriptor() ([]byte, []int)
func (*StatusRequest) Equal ¶
func (this *StatusRequest) Equal(that interface{}) bool
func (*StatusRequest) Marshal ¶
func (m *StatusRequest) Marshal() (dAtA []byte, err error)
func (*StatusRequest) MarshalToSizedBuffer ¶
func (m *StatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StatusRequest) ProtoMessage ¶
func (*StatusRequest) ProtoMessage()
func (*StatusRequest) Reset ¶
func (m *StatusRequest) Reset()
func (*StatusRequest) Size ¶
func (m *StatusRequest) Size() (n int)
func (*StatusRequest) String ¶
func (this *StatusRequest) String() string
func (*StatusRequest) Unmarshal ¶
func (m *StatusRequest) Unmarshal(dAtA []byte) error
func (*StatusRequest) XXX_DiscardUnknown ¶
func (m *StatusRequest) XXX_DiscardUnknown()
func (*StatusRequest) XXX_Marshal ¶
func (m *StatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StatusRequest) XXX_Merge ¶
func (m *StatusRequest) XXX_Merge(src proto.Message)
func (*StatusRequest) XXX_Size ¶
func (m *StatusRequest) XXX_Size() int
func (*StatusRequest) XXX_Unmarshal ¶
func (m *StatusRequest) XXX_Unmarshal(b []byte) error
type SubscribeRequest ¶
type SubscribeRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedSubscribeRequest ¶
func NewPopulatedSubscribeRequest(r randyRouter, easy bool) *SubscribeRequest
func (*SubscribeRequest) Descriptor ¶
func (*SubscribeRequest) Descriptor() ([]byte, []int)
func (*SubscribeRequest) Equal ¶
func (this *SubscribeRequest) Equal(that interface{}) bool
func (*SubscribeRequest) Marshal ¶
func (m *SubscribeRequest) Marshal() (dAtA []byte, err error)
func (*SubscribeRequest) MarshalToSizedBuffer ¶
func (m *SubscribeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SubscribeRequest) ProtoMessage ¶
func (*SubscribeRequest) ProtoMessage()
func (*SubscribeRequest) Reset ¶
func (m *SubscribeRequest) Reset()
func (*SubscribeRequest) Size ¶
func (m *SubscribeRequest) Size() (n int)
func (*SubscribeRequest) String ¶
func (this *SubscribeRequest) String() string
func (*SubscribeRequest) Unmarshal ¶
func (m *SubscribeRequest) Unmarshal(dAtA []byte) error
func (*SubscribeRequest) XXX_DiscardUnknown ¶
func (m *SubscribeRequest) XXX_DiscardUnknown()
func (*SubscribeRequest) XXX_Marshal ¶
func (m *SubscribeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SubscribeRequest) XXX_Merge ¶
func (m *SubscribeRequest) XXX_Merge(src proto.Message)
func (*SubscribeRequest) XXX_Size ¶
func (m *SubscribeRequest) XXX_Size() int
func (*SubscribeRequest) XXX_Unmarshal ¶
func (m *SubscribeRequest) XXX_Unmarshal(b []byte) error
type UnimplementedRouterManagerServer ¶
type UnimplementedRouterManagerServer struct { }
UnimplementedRouterManagerServer can be embedded to have forward compatible implementations.
func (*UnimplementedRouterManagerServer) GatewayStatus ¶
func (*UnimplementedRouterManagerServer) GatewayStatus(ctx context.Context, req *GatewayStatusRequest) (*GatewayStatusResponse, error)
func (*UnimplementedRouterManagerServer) GetStatus ¶
func (*UnimplementedRouterManagerServer) GetStatus(ctx context.Context, req *StatusRequest) (*Status, error)
type UnimplementedRouterServer ¶
type UnimplementedRouterServer struct { }
UnimplementedRouterServer can be embedded to have forward compatible implementations.
func (*UnimplementedRouterServer) Activate ¶
func (*UnimplementedRouterServer) Activate(ctx context.Context, req *DeviceActivationRequest) (*DeviceActivationResponse, error)
func (*UnimplementedRouterServer) GatewayStatus ¶
func (*UnimplementedRouterServer) GatewayStatus(srv Router_GatewayStatusServer) error
func (*UnimplementedRouterServer) Subscribe ¶
func (*UnimplementedRouterServer) Subscribe(req *SubscribeRequest, 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"` Message *protocol.Message `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` ProtocolMetadata protocol.RxMetadata `protobuf:"bytes,11,opt,name=protocol_metadata,json=protocolMetadata,proto3" json:"protocol_metadata"` GatewayMetadata gateway.RxMetadata `protobuf:"bytes,12,opt,name=gateway_metadata,json=gatewayMetadata,proto3" json:"gateway_metadata"` Trace *trace.Trace `protobuf:"bytes,21,opt,name=trace,proto3" json:"trace,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedUplinkMessage ¶
func NewPopulatedUplinkMessage(r randyRouter, easy bool) *UplinkMessage
func (*UplinkMessage) Descriptor ¶
func (*UplinkMessage) Descriptor() ([]byte, []int)
func (*UplinkMessage) Equal ¶
func (this *UplinkMessage) Equal(that interface{}) bool
func (*UplinkMessage) GetGatewayMetadata ¶
func (m *UplinkMessage) GetGatewayMetadata() gateway.RxMetadata
func (*UplinkMessage) GetMessage ¶
func (m *UplinkMessage) GetMessage() *protocol.Message
func (*UplinkMessage) GetPayload ¶
func (m *UplinkMessage) GetPayload() []byte
func (*UplinkMessage) GetProtocolMetadata ¶
func (m *UplinkMessage) GetProtocolMetadata() protocol.RxMetadata
func (*UplinkMessage) GetTrace ¶
func (m *UplinkMessage) GetTrace() *trace.Trace
func (*UplinkMessage) Marshal ¶
func (m *UplinkMessage) Marshal() (dAtA []byte, err error)
func (*UplinkMessage) MarshalPayload ¶
func (m *UplinkMessage) MarshalPayload() error
MarshalPayload marshals the Message into Payload if Payload is nil
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 (this *UplinkMessage) String() string
func (*UplinkMessage) Unmarshal ¶
func (m *UplinkMessage) Unmarshal(dAtA []byte) error
func (*UplinkMessage) UnmarshalPayload ¶
func (m *UplinkMessage) UnmarshalPayload() error
UnmarshalPayload unmarshals the Payload into Message if Message is nil
func (*UplinkMessage) Validate ¶
func (m *UplinkMessage) Validate() error
Validate implements the api.Validator interface
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