Documentation ¶
Overview ¶
Package core is a generated protocol buffer package.
It is generated from these files:
application.proto broker.proto broker_manager.proto collector.proto core.proto handler.proto handler_manager.proto lorawan.proto router.proto
It has these top-level messages:
DataAppReq DataAppRes JoinAppReq JoinAppRes DataBrokerReq DataBrokerRes JoinBrokerReq JoinBrokerRes ValidateOTAABrokerReq ValidateOTAABrokerRes UpsertABPBrokerReq UpsertABPBrokerRes BrokerDevice ValidateTokenBrokerReq ValidateTokenBrokerRes GetApplicationsCollectorReq GetApplicationsCollectorRes CollectorApplication AddApplicationCollectorReq AddApplicationCollectorRes RemoveApplicationCollectorReq RemoveApplicationCollectorRes Metadata StatsMetadata DataUpHandlerReq DataUpHandlerRes DataDownHandlerReq DataDownHandlerRes JoinHandlerReq JoinHandlerRes UpsertOTAAHandlerReq UpsertOTAAHandlerRes UpsertABPHandlerReq UpsertABPHandlerRes ListDevicesHandlerReq ListDevicesHandlerRes HandlerABPDevice HandlerOTAADevice GetDefaultDeviceReq GetDefaultDeviceRes SetDefaultDeviceReq GetPayloadFunctionsReq GetPayloadFunctionsRes SetPayloadFunctionsReq SetPayloadFunctionsRes TestPayloadFunctionsReq TestPayloadFunctionsRes SetDefaultDeviceRes LoRaWANData LoRaWANMHDR LoRaWANMACPayload LoRaWANFHDR LoRaWANFCtrl LoRaWANJoinRequest LoRaWANJoinAccept LoRaWANDLSettings DataRouterReq DataRouterRes StatsReq StatsRes JoinRouterReq JoinRouterRes
Index ¶
- Constants
- Variables
- func NewLoRaWANData(reqPayload *LoRaWANData, uplink bool) (lorawan.PHYPayload, error)
- func RegisterAppServer(s *grpc.Server, srv AppServer)
- func RegisterBrokerManagerServer(s *grpc.Server, srv BrokerManagerServer)
- func RegisterBrokerServer(s *grpc.Server, srv BrokerServer)
- func RegisterCollectorManagerServer(s *grpc.Server, srv CollectorManagerServer)
- func RegisterHandlerManagerServer(s *grpc.Server, srv HandlerManagerServer)
- func RegisterHandlerServer(s *grpc.Server, srv HandlerServer)
- func RegisterRouterServer(s *grpc.Server, srv RouterServer)
- func ValidateLoRaWANData(data *LoRaWANData) (*LoRaWANMACPayload, *LoRaWANMHDR, *LoRaWANFHDR, *LoRaWANFCtrl, error)
- type ABPSubAppReq
- type AddApplicationCollectorReq
- func (*AddApplicationCollectorReq) Descriptor() ([]byte, []int)
- func (m *AddApplicationCollectorReq) Marshal() (data []byte, err error)
- func (m *AddApplicationCollectorReq) MarshalTo(data []byte) (int, error)
- func (*AddApplicationCollectorReq) ProtoMessage()
- func (m *AddApplicationCollectorReq) Reset()
- func (m *AddApplicationCollectorReq) Size() (n int)
- func (m *AddApplicationCollectorReq) String() string
- func (m *AddApplicationCollectorReq) Unmarshal(data []byte) error
- type AddApplicationCollectorRes
- func (*AddApplicationCollectorRes) Descriptor() ([]byte, []int)
- func (m *AddApplicationCollectorRes) Marshal() (data []byte, err error)
- func (m *AddApplicationCollectorRes) MarshalTo(data []byte) (int, error)
- func (*AddApplicationCollectorRes) ProtoMessage()
- func (m *AddApplicationCollectorRes) Reset()
- func (m *AddApplicationCollectorRes) Size() (n int)
- func (m *AddApplicationCollectorRes) String() string
- func (m *AddApplicationCollectorRes) Unmarshal(data []byte) error
- type AppClient
- type AppMetadata
- type AppServer
- type AuthBrokerClient
- type AuthHandlerClient
- type BrokerClient
- type BrokerDevice
- func (*BrokerDevice) Descriptor() ([]byte, []int)
- func (m *BrokerDevice) Marshal() (data []byte, err error)
- func (m *BrokerDevice) MarshalTo(data []byte) (int, error)
- func (*BrokerDevice) ProtoMessage()
- func (m *BrokerDevice) Reset()
- func (m *BrokerDevice) Size() (n int)
- func (m *BrokerDevice) String() string
- func (m *BrokerDevice) Unmarshal(data []byte) error
- type BrokerManagerClient
- type BrokerManagerServer
- type BrokerServer
- type CollectorApplication
- func (*CollectorApplication) Descriptor() ([]byte, []int)
- func (m *CollectorApplication) Marshal() (data []byte, err error)
- func (m *CollectorApplication) MarshalTo(data []byte) (int, error)
- func (*CollectorApplication) ProtoMessage()
- func (m *CollectorApplication) Reset()
- func (m *CollectorApplication) Size() (n int)
- func (m *CollectorApplication) String() string
- func (m *CollectorApplication) Unmarshal(data []byte) error
- type CollectorManagerClient
- type CollectorManagerServer
- type DataAppReq
- func (*DataAppReq) Descriptor() ([]byte, []int)
- func (m *DataAppReq) GetMetadata() []*Metadata
- func (m *DataAppReq) Marshal() (data []byte, err error)
- func (m *DataAppReq) MarshalTo(data []byte) (int, error)
- func (*DataAppReq) ProtoMessage()
- func (m *DataAppReq) Reset()
- func (m *DataAppReq) Size() (n int)
- func (m *DataAppReq) String() string
- func (m *DataAppReq) Unmarshal(data []byte) error
- type DataAppRes
- func (*DataAppRes) Descriptor() ([]byte, []int)
- func (m *DataAppRes) Marshal() (data []byte, err error)
- func (m *DataAppRes) MarshalTo(data []byte) (int, error)
- func (*DataAppRes) ProtoMessage()
- func (m *DataAppRes) Reset()
- func (m *DataAppRes) Size() (n int)
- func (m *DataAppRes) String() string
- func (m *DataAppRes) Unmarshal(data []byte) error
- type DataBrokerReq
- func (*DataBrokerReq) Descriptor() ([]byte, []int)
- func (m *DataBrokerReq) GetMetadata() *Metadata
- func (m *DataBrokerReq) GetPayload() *LoRaWANData
- func (m *DataBrokerReq) Marshal() (data []byte, err error)
- func (m *DataBrokerReq) MarshalTo(data []byte) (int, error)
- func (*DataBrokerReq) ProtoMessage()
- func (m *DataBrokerReq) Reset()
- func (m *DataBrokerReq) Size() (n int)
- func (m *DataBrokerReq) String() string
- func (m *DataBrokerReq) Unmarshal(data []byte) error
- type DataBrokerRes
- func (*DataBrokerRes) Descriptor() ([]byte, []int)
- func (m *DataBrokerRes) GetMetadata() *Metadata
- func (m *DataBrokerRes) GetPayload() *LoRaWANData
- func (m *DataBrokerRes) Marshal() (data []byte, err error)
- func (m *DataBrokerRes) MarshalTo(data []byte) (int, error)
- func (*DataBrokerRes) ProtoMessage()
- func (m *DataBrokerRes) Reset()
- func (m *DataBrokerRes) Size() (n int)
- func (m *DataBrokerRes) String() string
- func (m *DataBrokerRes) Unmarshal(data []byte) error
- type DataDownAppReq
- type DataDownHandlerReq
- func (*DataDownHandlerReq) Descriptor() ([]byte, []int)
- func (m *DataDownHandlerReq) Marshal() (data []byte, err error)
- func (m *DataDownHandlerReq) MarshalTo(data []byte) (int, error)
- func (*DataDownHandlerReq) ProtoMessage()
- func (m *DataDownHandlerReq) Reset()
- func (m *DataDownHandlerReq) Size() (n int)
- func (m *DataDownHandlerReq) String() string
- func (m *DataDownHandlerReq) Unmarshal(data []byte) error
- type DataDownHandlerRes
- func (*DataDownHandlerRes) Descriptor() ([]byte, []int)
- func (m *DataDownHandlerRes) Marshal() (data []byte, err error)
- func (m *DataDownHandlerRes) MarshalTo(data []byte) (int, error)
- func (*DataDownHandlerRes) ProtoMessage()
- func (m *DataDownHandlerRes) Reset()
- func (m *DataDownHandlerRes) Size() (n int)
- func (m *DataDownHandlerRes) String() string
- func (m *DataDownHandlerRes) Unmarshal(data []byte) error
- type DataRouterReq
- func (*DataRouterReq) Descriptor() ([]byte, []int)
- func (m *DataRouterReq) GetMetadata() *Metadata
- func (m *DataRouterReq) GetPayload() *LoRaWANData
- func (m *DataRouterReq) Marshal() (data []byte, err error)
- func (m *DataRouterReq) MarshalTo(data []byte) (int, error)
- func (*DataRouterReq) ProtoMessage()
- func (m *DataRouterReq) Reset()
- func (m *DataRouterReq) Size() (n int)
- func (m *DataRouterReq) String() string
- func (m *DataRouterReq) Unmarshal(data []byte) error
- type DataRouterRes
- func (*DataRouterRes) Descriptor() ([]byte, []int)
- func (m *DataRouterRes) GetMetadata() *Metadata
- func (m *DataRouterRes) GetPayload() *LoRaWANData
- func (m *DataRouterRes) Marshal() (data []byte, err error)
- func (m *DataRouterRes) MarshalTo(data []byte) (int, error)
- func (*DataRouterRes) ProtoMessage()
- func (m *DataRouterRes) Reset()
- func (m *DataRouterRes) Size() (n int)
- func (m *DataRouterRes) String() string
- func (m *DataRouterRes) Unmarshal(data []byte) error
- type DataUpAppReq
- type DataUpHandlerReq
- func (*DataUpHandlerReq) Descriptor() ([]byte, []int)
- func (m *DataUpHandlerReq) GetMetadata() *Metadata
- func (m *DataUpHandlerReq) Marshal() (data []byte, err error)
- func (m *DataUpHandlerReq) MarshalTo(data []byte) (int, error)
- func (*DataUpHandlerReq) ProtoMessage()
- func (m *DataUpHandlerReq) Reset()
- func (m *DataUpHandlerReq) Size() (n int)
- func (m *DataUpHandlerReq) String() string
- func (m *DataUpHandlerReq) Unmarshal(data []byte) error
- type DataUpHandlerRes
- func (*DataUpHandlerRes) Descriptor() ([]byte, []int)
- func (m *DataUpHandlerRes) GetMetadata() *Metadata
- func (m *DataUpHandlerRes) GetPayload() *LoRaWANData
- func (m *DataUpHandlerRes) Marshal() (data []byte, err error)
- func (m *DataUpHandlerRes) MarshalTo(data []byte) (int, error)
- func (*DataUpHandlerRes) ProtoMessage()
- func (m *DataUpHandlerRes) Reset()
- func (m *DataUpHandlerRes) Size() (n int)
- func (m *DataUpHandlerRes) String() string
- func (m *DataUpHandlerRes) Unmarshal(data []byte) error
- type GetApplicationsCollectorReq
- func (*GetApplicationsCollectorReq) Descriptor() ([]byte, []int)
- func (m *GetApplicationsCollectorReq) Marshal() (data []byte, err error)
- func (m *GetApplicationsCollectorReq) MarshalTo(data []byte) (int, error)
- func (*GetApplicationsCollectorReq) ProtoMessage()
- func (m *GetApplicationsCollectorReq) Reset()
- func (m *GetApplicationsCollectorReq) Size() (n int)
- func (m *GetApplicationsCollectorReq) String() string
- func (m *GetApplicationsCollectorReq) Unmarshal(data []byte) error
- type GetApplicationsCollectorRes
- func (*GetApplicationsCollectorRes) Descriptor() ([]byte, []int)
- func (m *GetApplicationsCollectorRes) GetApplications() []*CollectorApplication
- func (m *GetApplicationsCollectorRes) Marshal() (data []byte, err error)
- func (m *GetApplicationsCollectorRes) MarshalTo(data []byte) (int, error)
- func (*GetApplicationsCollectorRes) ProtoMessage()
- func (m *GetApplicationsCollectorRes) Reset()
- func (m *GetApplicationsCollectorRes) Size() (n int)
- func (m *GetApplicationsCollectorRes) String() string
- func (m *GetApplicationsCollectorRes) Unmarshal(data []byte) error
- type GetDefaultDeviceReq
- func (*GetDefaultDeviceReq) Descriptor() ([]byte, []int)
- func (m *GetDefaultDeviceReq) Marshal() (data []byte, err error)
- func (m *GetDefaultDeviceReq) MarshalTo(data []byte) (int, error)
- func (*GetDefaultDeviceReq) ProtoMessage()
- func (m *GetDefaultDeviceReq) Reset()
- func (m *GetDefaultDeviceReq) Size() (n int)
- func (m *GetDefaultDeviceReq) String() string
- func (m *GetDefaultDeviceReq) Unmarshal(data []byte) error
- type GetDefaultDeviceRes
- func (*GetDefaultDeviceRes) Descriptor() ([]byte, []int)
- func (m *GetDefaultDeviceRes) Marshal() (data []byte, err error)
- func (m *GetDefaultDeviceRes) MarshalTo(data []byte) (int, error)
- func (*GetDefaultDeviceRes) ProtoMessage()
- func (m *GetDefaultDeviceRes) Reset()
- func (m *GetDefaultDeviceRes) Size() (n int)
- func (m *GetDefaultDeviceRes) String() string
- func (m *GetDefaultDeviceRes) Unmarshal(data []byte) error
- type GetPayloadFunctionsReq
- func (*GetPayloadFunctionsReq) Descriptor() ([]byte, []int)
- func (m *GetPayloadFunctionsReq) Marshal() (data []byte, err error)
- func (m *GetPayloadFunctionsReq) MarshalTo(data []byte) (int, error)
- func (*GetPayloadFunctionsReq) ProtoMessage()
- func (m *GetPayloadFunctionsReq) Reset()
- func (m *GetPayloadFunctionsReq) Size() (n int)
- func (m *GetPayloadFunctionsReq) String() string
- func (m *GetPayloadFunctionsReq) Unmarshal(data []byte) error
- type GetPayloadFunctionsRes
- func (*GetPayloadFunctionsRes) Descriptor() ([]byte, []int)
- func (m *GetPayloadFunctionsRes) Marshal() (data []byte, err error)
- func (m *GetPayloadFunctionsRes) MarshalTo(data []byte) (int, error)
- func (*GetPayloadFunctionsRes) ProtoMessage()
- func (m *GetPayloadFunctionsRes) Reset()
- func (m *GetPayloadFunctionsRes) Size() (n int)
- func (m *GetPayloadFunctionsRes) String() string
- func (m *GetPayloadFunctionsRes) Unmarshal(data []byte) error
- type HandlerABPDevice
- func (*HandlerABPDevice) Descriptor() ([]byte, []int)
- func (m *HandlerABPDevice) Marshal() (data []byte, err error)
- func (m *HandlerABPDevice) MarshalTo(data []byte) (int, error)
- func (*HandlerABPDevice) ProtoMessage()
- func (m *HandlerABPDevice) Reset()
- func (m *HandlerABPDevice) Size() (n int)
- func (m *HandlerABPDevice) String() string
- func (m *HandlerABPDevice) Unmarshal(data []byte) error
- type HandlerClient
- type HandlerManagerClient
- type HandlerManagerServer
- type HandlerOTAADevice
- func (*HandlerOTAADevice) Descriptor() ([]byte, []int)
- func (m *HandlerOTAADevice) Marshal() (data []byte, err error)
- func (m *HandlerOTAADevice) MarshalTo(data []byte) (int, error)
- func (*HandlerOTAADevice) ProtoMessage()
- func (m *HandlerOTAADevice) Reset()
- func (m *HandlerOTAADevice) Size() (n int)
- func (m *HandlerOTAADevice) String() string
- func (m *HandlerOTAADevice) Unmarshal(data []byte) error
- type HandlerServer
- type JoinAppReq
- func (*JoinAppReq) Descriptor() ([]byte, []int)
- func (m *JoinAppReq) GetMetadata() []*Metadata
- func (m *JoinAppReq) Marshal() (data []byte, err error)
- func (m *JoinAppReq) MarshalTo(data []byte) (int, error)
- func (*JoinAppReq) ProtoMessage()
- func (m *JoinAppReq) Reset()
- func (m *JoinAppReq) Size() (n int)
- func (m *JoinAppReq) String() string
- func (m *JoinAppReq) Unmarshal(data []byte) error
- type JoinAppRes
- func (*JoinAppRes) Descriptor() ([]byte, []int)
- func (m *JoinAppRes) Marshal() (data []byte, err error)
- func (m *JoinAppRes) MarshalTo(data []byte) (int, error)
- func (*JoinAppRes) ProtoMessage()
- func (m *JoinAppRes) Reset()
- func (m *JoinAppRes) Size() (n int)
- func (m *JoinAppRes) String() string
- func (m *JoinAppRes) Unmarshal(data []byte) error
- type JoinBrokerReq
- func (*JoinBrokerReq) Descriptor() ([]byte, []int)
- func (m *JoinBrokerReq) GetMetadata() *Metadata
- func (m *JoinBrokerReq) Marshal() (data []byte, err error)
- func (m *JoinBrokerReq) MarshalTo(data []byte) (int, error)
- func (*JoinBrokerReq) ProtoMessage()
- func (m *JoinBrokerReq) Reset()
- func (m *JoinBrokerReq) Size() (n int)
- func (m *JoinBrokerReq) String() string
- func (m *JoinBrokerReq) Unmarshal(data []byte) error
- type JoinBrokerRes
- func (*JoinBrokerRes) Descriptor() ([]byte, []int)
- func (m *JoinBrokerRes) GetMetadata() *Metadata
- func (m *JoinBrokerRes) GetPayload() *LoRaWANJoinAccept
- func (m *JoinBrokerRes) Marshal() (data []byte, err error)
- func (m *JoinBrokerRes) MarshalTo(data []byte) (int, error)
- func (*JoinBrokerRes) ProtoMessage()
- func (m *JoinBrokerRes) Reset()
- func (m *JoinBrokerRes) Size() (n int)
- func (m *JoinBrokerRes) String() string
- func (m *JoinBrokerRes) Unmarshal(data []byte) error
- type JoinHandlerReq
- func (*JoinHandlerReq) Descriptor() ([]byte, []int)
- func (m *JoinHandlerReq) GetMetadata() *Metadata
- func (m *JoinHandlerReq) Marshal() (data []byte, err error)
- func (m *JoinHandlerReq) MarshalTo(data []byte) (int, error)
- func (*JoinHandlerReq) ProtoMessage()
- func (m *JoinHandlerReq) Reset()
- func (m *JoinHandlerReq) Size() (n int)
- func (m *JoinHandlerReq) String() string
- func (m *JoinHandlerReq) Unmarshal(data []byte) error
- type JoinHandlerRes
- func (*JoinHandlerRes) Descriptor() ([]byte, []int)
- func (m *JoinHandlerRes) GetMetadata() *Metadata
- func (m *JoinHandlerRes) GetPayload() *LoRaWANJoinAccept
- func (m *JoinHandlerRes) Marshal() (data []byte, err error)
- func (m *JoinHandlerRes) MarshalTo(data []byte) (int, error)
- func (*JoinHandlerRes) ProtoMessage()
- func (m *JoinHandlerRes) Reset()
- func (m *JoinHandlerRes) Size() (n int)
- func (m *JoinHandlerRes) String() string
- func (m *JoinHandlerRes) Unmarshal(data []byte) error
- type JoinRouterReq
- func (*JoinRouterReq) Descriptor() ([]byte, []int)
- func (m *JoinRouterReq) GetMetadata() *Metadata
- func (m *JoinRouterReq) Marshal() (data []byte, err error)
- func (m *JoinRouterReq) MarshalTo(data []byte) (int, error)
- func (*JoinRouterReq) ProtoMessage()
- func (m *JoinRouterReq) Reset()
- func (m *JoinRouterReq) Size() (n int)
- func (m *JoinRouterReq) String() string
- func (m *JoinRouterReq) Unmarshal(data []byte) error
- type JoinRouterRes
- func (*JoinRouterRes) Descriptor() ([]byte, []int)
- func (m *JoinRouterRes) GetMetadata() *Metadata
- func (m *JoinRouterRes) GetPayload() *LoRaWANJoinAccept
- func (m *JoinRouterRes) Marshal() (data []byte, err error)
- func (m *JoinRouterRes) MarshalTo(data []byte) (int, error)
- func (*JoinRouterRes) ProtoMessage()
- func (m *JoinRouterRes) Reset()
- func (m *JoinRouterRes) Size() (n int)
- func (m *JoinRouterRes) String() string
- func (m *JoinRouterRes) Unmarshal(data []byte) error
- type ListDevicesHandlerReq
- func (*ListDevicesHandlerReq) Descriptor() ([]byte, []int)
- func (m *ListDevicesHandlerReq) Marshal() (data []byte, err error)
- func (m *ListDevicesHandlerReq) MarshalTo(data []byte) (int, error)
- func (*ListDevicesHandlerReq) ProtoMessage()
- func (m *ListDevicesHandlerReq) Reset()
- func (m *ListDevicesHandlerReq) Size() (n int)
- func (m *ListDevicesHandlerReq) String() string
- func (m *ListDevicesHandlerReq) Unmarshal(data []byte) error
- type ListDevicesHandlerRes
- func (*ListDevicesHandlerRes) Descriptor() ([]byte, []int)
- func (m *ListDevicesHandlerRes) GetABP() []*HandlerABPDevice
- func (m *ListDevicesHandlerRes) GetOTAA() []*HandlerOTAADevice
- func (m *ListDevicesHandlerRes) Marshal() (data []byte, err error)
- func (m *ListDevicesHandlerRes) MarshalTo(data []byte) (int, error)
- func (*ListDevicesHandlerRes) ProtoMessage()
- func (m *ListDevicesHandlerRes) Reset()
- func (m *ListDevicesHandlerRes) Size() (n int)
- func (m *ListDevicesHandlerRes) String() string
- func (m *ListDevicesHandlerRes) Unmarshal(data []byte) error
- type LoRaWANDLSettings
- func (*LoRaWANDLSettings) Descriptor() ([]byte, []int)
- func (m *LoRaWANDLSettings) Marshal() (data []byte, err error)
- func (m *LoRaWANDLSettings) MarshalTo(data []byte) (int, error)
- func (*LoRaWANDLSettings) ProtoMessage()
- func (m *LoRaWANDLSettings) Reset()
- func (m *LoRaWANDLSettings) Size() (n int)
- func (m *LoRaWANDLSettings) String() string
- func (m *LoRaWANDLSettings) Unmarshal(data []byte) error
- type LoRaWANData
- func (*LoRaWANData) Descriptor() ([]byte, []int)
- func (m *LoRaWANData) GetMACPayload() *LoRaWANMACPayload
- func (m *LoRaWANData) GetMHDR() *LoRaWANMHDR
- func (m *LoRaWANData) Marshal() (data []byte, err error)
- func (m *LoRaWANData) MarshalTo(data []byte) (int, error)
- func (*LoRaWANData) ProtoMessage()
- func (m *LoRaWANData) Reset()
- func (m *LoRaWANData) Size() (n int)
- func (m *LoRaWANData) String() string
- func (m *LoRaWANData) Unmarshal(data []byte) error
- type LoRaWANFCtrl
- func (*LoRaWANFCtrl) Descriptor() ([]byte, []int)
- func (m *LoRaWANFCtrl) Marshal() (data []byte, err error)
- func (m *LoRaWANFCtrl) MarshalTo(data []byte) (int, error)
- func (*LoRaWANFCtrl) ProtoMessage()
- func (m *LoRaWANFCtrl) Reset()
- func (m *LoRaWANFCtrl) Size() (n int)
- func (m *LoRaWANFCtrl) String() string
- func (m *LoRaWANFCtrl) Unmarshal(data []byte) error
- type LoRaWANFHDR
- func (*LoRaWANFHDR) Descriptor() ([]byte, []int)
- func (m *LoRaWANFHDR) GetFCtrl() *LoRaWANFCtrl
- func (m *LoRaWANFHDR) Marshal() (data []byte, err error)
- func (m *LoRaWANFHDR) MarshalTo(data []byte) (int, error)
- func (*LoRaWANFHDR) ProtoMessage()
- func (m *LoRaWANFHDR) Reset()
- func (m *LoRaWANFHDR) Size() (n int)
- func (m *LoRaWANFHDR) String() string
- func (m *LoRaWANFHDR) Unmarshal(data []byte) error
- type LoRaWANJoinAccept
- func (*LoRaWANJoinAccept) Descriptor() ([]byte, []int)
- func (m *LoRaWANJoinAccept) Marshal() (data []byte, err error)
- func (m *LoRaWANJoinAccept) MarshalTo(data []byte) (int, error)
- func (*LoRaWANJoinAccept) ProtoMessage()
- func (m *LoRaWANJoinAccept) Reset()
- func (m *LoRaWANJoinAccept) Size() (n int)
- func (m *LoRaWANJoinAccept) String() string
- func (m *LoRaWANJoinAccept) Unmarshal(data []byte) error
- type LoRaWANJoinRequest
- func (*LoRaWANJoinRequest) Descriptor() ([]byte, []int)
- func (m *LoRaWANJoinRequest) Marshal() (data []byte, err error)
- func (m *LoRaWANJoinRequest) MarshalTo(data []byte) (int, error)
- func (*LoRaWANJoinRequest) ProtoMessage()
- func (m *LoRaWANJoinRequest) Reset()
- func (m *LoRaWANJoinRequest) Size() (n int)
- func (m *LoRaWANJoinRequest) String() string
- func (m *LoRaWANJoinRequest) Unmarshal(data []byte) error
- type LoRaWANMACPayload
- func (*LoRaWANMACPayload) Descriptor() ([]byte, []int)
- func (m *LoRaWANMACPayload) GetFHDR() *LoRaWANFHDR
- func (m *LoRaWANMACPayload) Marshal() (data []byte, err error)
- func (m *LoRaWANMACPayload) MarshalTo(data []byte) (int, error)
- func (*LoRaWANMACPayload) ProtoMessage()
- func (m *LoRaWANMACPayload) Reset()
- func (m *LoRaWANMACPayload) Size() (n int)
- func (m *LoRaWANMACPayload) String() string
- func (m *LoRaWANMACPayload) Unmarshal(data []byte) error
- type LoRaWANMHDR
- func (*LoRaWANMHDR) Descriptor() ([]byte, []int)
- func (m *LoRaWANMHDR) Marshal() (data []byte, err error)
- func (m *LoRaWANMHDR) MarshalTo(data []byte) (int, error)
- func (*LoRaWANMHDR) ProtoMessage()
- func (m *LoRaWANMHDR) Reset()
- func (m *LoRaWANMHDR) Size() (n int)
- func (m *LoRaWANMHDR) String() string
- func (m *LoRaWANMHDR) Unmarshal(data []byte) error
- type Metadata
- func (*Metadata) Descriptor() ([]byte, []int)
- func (m *Metadata) Marshal() (data []byte, err error)
- func (m *Metadata) MarshalTo(data []byte) (int, error)
- func (*Metadata) ProtoMessage()
- func (m *Metadata) Reset()
- func (m *Metadata) Size() (n int)
- func (m *Metadata) String() string
- func (m *Metadata) Unmarshal(data []byte) error
- type OTAAAppReq
- type RemoveApplicationCollectorReq
- func (*RemoveApplicationCollectorReq) Descriptor() ([]byte, []int)
- func (m *RemoveApplicationCollectorReq) Marshal() (data []byte, err error)
- func (m *RemoveApplicationCollectorReq) MarshalTo(data []byte) (int, error)
- func (*RemoveApplicationCollectorReq) ProtoMessage()
- func (m *RemoveApplicationCollectorReq) Reset()
- func (m *RemoveApplicationCollectorReq) Size() (n int)
- func (m *RemoveApplicationCollectorReq) String() string
- func (m *RemoveApplicationCollectorReq) Unmarshal(data []byte) error
- type RemoveApplicationCollectorRes
- func (*RemoveApplicationCollectorRes) Descriptor() ([]byte, []int)
- func (m *RemoveApplicationCollectorRes) Marshal() (data []byte, err error)
- func (m *RemoveApplicationCollectorRes) MarshalTo(data []byte) (int, error)
- func (*RemoveApplicationCollectorRes) ProtoMessage()
- func (m *RemoveApplicationCollectorRes) Reset()
- func (m *RemoveApplicationCollectorRes) Size() (n int)
- func (m *RemoveApplicationCollectorRes) String() string
- func (m *RemoveApplicationCollectorRes) Unmarshal(data []byte) error
- type RouterClient
- type RouterServer
- type SetDefaultDeviceReq
- func (*SetDefaultDeviceReq) Descriptor() ([]byte, []int)
- func (m *SetDefaultDeviceReq) Marshal() (data []byte, err error)
- func (m *SetDefaultDeviceReq) MarshalTo(data []byte) (int, error)
- func (*SetDefaultDeviceReq) ProtoMessage()
- func (m *SetDefaultDeviceReq) Reset()
- func (m *SetDefaultDeviceReq) Size() (n int)
- func (m *SetDefaultDeviceReq) String() string
- func (m *SetDefaultDeviceReq) Unmarshal(data []byte) error
- type SetDefaultDeviceRes
- func (*SetDefaultDeviceRes) Descriptor() ([]byte, []int)
- func (m *SetDefaultDeviceRes) Marshal() (data []byte, err error)
- func (m *SetDefaultDeviceRes) MarshalTo(data []byte) (int, error)
- func (*SetDefaultDeviceRes) ProtoMessage()
- func (m *SetDefaultDeviceRes) Reset()
- func (m *SetDefaultDeviceRes) Size() (n int)
- func (m *SetDefaultDeviceRes) String() string
- func (m *SetDefaultDeviceRes) Unmarshal(data []byte) error
- type SetPayloadFunctionsReq
- func (*SetPayloadFunctionsReq) Descriptor() ([]byte, []int)
- func (m *SetPayloadFunctionsReq) Marshal() (data []byte, err error)
- func (m *SetPayloadFunctionsReq) MarshalTo(data []byte) (int, error)
- func (*SetPayloadFunctionsReq) ProtoMessage()
- func (m *SetPayloadFunctionsReq) Reset()
- func (m *SetPayloadFunctionsReq) Size() (n int)
- func (m *SetPayloadFunctionsReq) String() string
- func (m *SetPayloadFunctionsReq) Unmarshal(data []byte) error
- type SetPayloadFunctionsRes
- func (*SetPayloadFunctionsRes) Descriptor() ([]byte, []int)
- func (m *SetPayloadFunctionsRes) Marshal() (data []byte, err error)
- func (m *SetPayloadFunctionsRes) MarshalTo(data []byte) (int, error)
- func (*SetPayloadFunctionsRes) ProtoMessage()
- func (m *SetPayloadFunctionsRes) Reset()
- func (m *SetPayloadFunctionsRes) Size() (n int)
- func (m *SetPayloadFunctionsRes) String() string
- func (m *SetPayloadFunctionsRes) Unmarshal(data []byte) error
- type StatsMetadata
- func (*StatsMetadata) Descriptor() ([]byte, []int)
- func (m *StatsMetadata) Marshal() (data []byte, err error)
- func (m StatsMetadata) MarshalBinary() ([]byte, error)
- func (m *StatsMetadata) MarshalTo(data []byte) (int, error)
- func (*StatsMetadata) ProtoMessage()
- func (m *StatsMetadata) Reset()
- func (m *StatsMetadata) Size() (n int)
- func (m *StatsMetadata) String() string
- func (m *StatsMetadata) Unmarshal(data []byte) error
- func (m *StatsMetadata) UnmarshalBinary(data []byte) error
- type StatsReq
- func (*StatsReq) Descriptor() ([]byte, []int)
- func (m *StatsReq) GetMetadata() *StatsMetadata
- func (m *StatsReq) Marshal() (data []byte, err error)
- func (m *StatsReq) MarshalTo(data []byte) (int, error)
- func (*StatsReq) ProtoMessage()
- func (m *StatsReq) Reset()
- func (m *StatsReq) Size() (n int)
- func (m *StatsReq) String() string
- func (m *StatsReq) Unmarshal(data []byte) error
- type StatsRes
- func (*StatsRes) Descriptor() ([]byte, []int)
- func (m *StatsRes) Marshal() (data []byte, err error)
- func (m *StatsRes) MarshalTo(data []byte) (int, error)
- func (*StatsRes) ProtoMessage()
- func (m *StatsRes) Reset()
- func (m *StatsRes) Size() (n int)
- func (m *StatsRes) String() string
- func (m *StatsRes) Unmarshal(data []byte) error
- type TestPayloadFunctionsReq
- func (*TestPayloadFunctionsReq) Descriptor() ([]byte, []int)
- func (m *TestPayloadFunctionsReq) Marshal() (data []byte, err error)
- func (m *TestPayloadFunctionsReq) MarshalTo(data []byte) (int, error)
- func (*TestPayloadFunctionsReq) ProtoMessage()
- func (m *TestPayloadFunctionsReq) Reset()
- func (m *TestPayloadFunctionsReq) Size() (n int)
- func (m *TestPayloadFunctionsReq) String() string
- func (m *TestPayloadFunctionsReq) Unmarshal(data []byte) error
- type TestPayloadFunctionsRes
- func (*TestPayloadFunctionsRes) Descriptor() ([]byte, []int)
- func (m *TestPayloadFunctionsRes) Marshal() (data []byte, err error)
- func (m *TestPayloadFunctionsRes) MarshalTo(data []byte) (int, error)
- func (*TestPayloadFunctionsRes) ProtoMessage()
- func (m *TestPayloadFunctionsRes) Reset()
- func (m *TestPayloadFunctionsRes) Size() (n int)
- func (m *TestPayloadFunctionsRes) String() string
- func (m *TestPayloadFunctionsRes) Unmarshal(data []byte) error
- type UpsertABPBrokerReq
- func (*UpsertABPBrokerReq) Descriptor() ([]byte, []int)
- func (m *UpsertABPBrokerReq) Marshal() (data []byte, err error)
- func (m *UpsertABPBrokerReq) MarshalTo(data []byte) (int, error)
- func (*UpsertABPBrokerReq) ProtoMessage()
- func (m *UpsertABPBrokerReq) Reset()
- func (m *UpsertABPBrokerReq) Size() (n int)
- func (m *UpsertABPBrokerReq) String() string
- func (m *UpsertABPBrokerReq) Unmarshal(data []byte) error
- type UpsertABPBrokerRes
- func (*UpsertABPBrokerRes) Descriptor() ([]byte, []int)
- func (m *UpsertABPBrokerRes) Marshal() (data []byte, err error)
- func (m *UpsertABPBrokerRes) MarshalTo(data []byte) (int, error)
- func (*UpsertABPBrokerRes) ProtoMessage()
- func (m *UpsertABPBrokerRes) Reset()
- func (m *UpsertABPBrokerRes) Size() (n int)
- func (m *UpsertABPBrokerRes) String() string
- func (m *UpsertABPBrokerRes) Unmarshal(data []byte) error
- type UpsertABPHandlerReq
- func (*UpsertABPHandlerReq) Descriptor() ([]byte, []int)
- func (m *UpsertABPHandlerReq) Marshal() (data []byte, err error)
- func (m *UpsertABPHandlerReq) MarshalTo(data []byte) (int, error)
- func (*UpsertABPHandlerReq) ProtoMessage()
- func (m *UpsertABPHandlerReq) Reset()
- func (m *UpsertABPHandlerReq) Size() (n int)
- func (m *UpsertABPHandlerReq) String() string
- func (m *UpsertABPHandlerReq) Unmarshal(data []byte) error
- type UpsertABPHandlerRes
- func (*UpsertABPHandlerRes) Descriptor() ([]byte, []int)
- func (m *UpsertABPHandlerRes) Marshal() (data []byte, err error)
- func (m *UpsertABPHandlerRes) MarshalTo(data []byte) (int, error)
- func (*UpsertABPHandlerRes) ProtoMessage()
- func (m *UpsertABPHandlerRes) Reset()
- func (m *UpsertABPHandlerRes) Size() (n int)
- func (m *UpsertABPHandlerRes) String() string
- func (m *UpsertABPHandlerRes) Unmarshal(data []byte) error
- type UpsertOTAAHandlerReq
- func (*UpsertOTAAHandlerReq) Descriptor() ([]byte, []int)
- func (m *UpsertOTAAHandlerReq) Marshal() (data []byte, err error)
- func (m *UpsertOTAAHandlerReq) MarshalTo(data []byte) (int, error)
- func (*UpsertOTAAHandlerReq) ProtoMessage()
- func (m *UpsertOTAAHandlerReq) Reset()
- func (m *UpsertOTAAHandlerReq) Size() (n int)
- func (m *UpsertOTAAHandlerReq) String() string
- func (m *UpsertOTAAHandlerReq) Unmarshal(data []byte) error
- type UpsertOTAAHandlerRes
- func (*UpsertOTAAHandlerRes) Descriptor() ([]byte, []int)
- func (m *UpsertOTAAHandlerRes) Marshal() (data []byte, err error)
- func (m *UpsertOTAAHandlerRes) MarshalTo(data []byte) (int, error)
- func (*UpsertOTAAHandlerRes) ProtoMessage()
- func (m *UpsertOTAAHandlerRes) Reset()
- func (m *UpsertOTAAHandlerRes) Size() (n int)
- func (m *UpsertOTAAHandlerRes) String() string
- func (m *UpsertOTAAHandlerRes) Unmarshal(data []byte) error
- type ValidateOTAABrokerReq
- func (*ValidateOTAABrokerReq) Descriptor() ([]byte, []int)
- func (m *ValidateOTAABrokerReq) Marshal() (data []byte, err error)
- func (m *ValidateOTAABrokerReq) MarshalTo(data []byte) (int, error)
- func (*ValidateOTAABrokerReq) ProtoMessage()
- func (m *ValidateOTAABrokerReq) Reset()
- func (m *ValidateOTAABrokerReq) Size() (n int)
- func (m *ValidateOTAABrokerReq) String() string
- func (m *ValidateOTAABrokerReq) Unmarshal(data []byte) error
- type ValidateOTAABrokerRes
- func (*ValidateOTAABrokerRes) Descriptor() ([]byte, []int)
- func (m *ValidateOTAABrokerRes) Marshal() (data []byte, err error)
- func (m *ValidateOTAABrokerRes) MarshalTo(data []byte) (int, error)
- func (*ValidateOTAABrokerRes) ProtoMessage()
- func (m *ValidateOTAABrokerRes) Reset()
- func (m *ValidateOTAABrokerRes) Size() (n int)
- func (m *ValidateOTAABrokerRes) String() string
- func (m *ValidateOTAABrokerRes) Unmarshal(data []byte) error
- type ValidateTokenBrokerReq
- func (*ValidateTokenBrokerReq) Descriptor() ([]byte, []int)
- func (m *ValidateTokenBrokerReq) Marshal() (data []byte, err error)
- func (m *ValidateTokenBrokerReq) MarshalTo(data []byte) (int, error)
- func (*ValidateTokenBrokerReq) ProtoMessage()
- func (m *ValidateTokenBrokerReq) Reset()
- func (m *ValidateTokenBrokerReq) Size() (n int)
- func (m *ValidateTokenBrokerReq) String() string
- func (m *ValidateTokenBrokerReq) Unmarshal(data []byte) error
- type ValidateTokenBrokerRes
- func (*ValidateTokenBrokerRes) Descriptor() ([]byte, []int)
- func (m *ValidateTokenBrokerRes) Marshal() (data []byte, err error)
- func (m *ValidateTokenBrokerRes) MarshalTo(data []byte) (int, error)
- func (*ValidateTokenBrokerRes) ProtoMessage()
- func (m *ValidateTokenBrokerRes) Reset()
- func (m *ValidateTokenBrokerRes) Size() (n int)
- func (m *ValidateTokenBrokerRes) String() string
- func (m *ValidateTokenBrokerRes) Unmarshal(data []byte) error
Constants ¶
const (
RelaxFcntCheck uint32 = 1 << iota
)
Variables ¶
var ( ErrInvalidLengthApplication = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowApplication = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthBroker = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowBroker = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthBrokerManager = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowBrokerManager = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthCollector = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowCollector = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthCore = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowCore = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthHandler = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowHandler = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthHandlerManager = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowHandlerManager = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthLorawan = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowLorawan = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthRouter = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowRouter = fmt.Errorf("proto: integer overflow") )
Functions ¶
func NewLoRaWANData ¶
func NewLoRaWANData(reqPayload *LoRaWANData, uplink bool) (lorawan.PHYPayload, error)
NewLoRaWANData converts a LoRaWANData to a brocaar/lorawan.PHYPayload
func RegisterAppServer ¶
func RegisterBrokerManagerServer ¶
func RegisterBrokerManagerServer(s *grpc.Server, srv BrokerManagerServer)
func RegisterBrokerServer ¶
func RegisterBrokerServer(s *grpc.Server, srv BrokerServer)
func RegisterCollectorManagerServer ¶
func RegisterCollectorManagerServer(s *grpc.Server, srv CollectorManagerServer)
func RegisterHandlerManagerServer ¶
func RegisterHandlerManagerServer(s *grpc.Server, srv HandlerManagerServer)
func RegisterHandlerServer ¶
func RegisterHandlerServer(s *grpc.Server, srv HandlerServer)
func RegisterRouterServer ¶
func RegisterRouterServer(s *grpc.Server, srv RouterServer)
func ValidateLoRaWANData ¶
func ValidateLoRaWANData(data *LoRaWANData) (*LoRaWANMACPayload, *LoRaWANMHDR, *LoRaWANFHDR, *LoRaWANFCtrl, error)
ValidateLoRaWANData makes sure that the provided lorawanData reference is valid by checking if All required parameters are present and conform.
Types ¶
type ABPSubAppReq ¶
type ABPSubAppReq struct { DevAddr string `json:"devaddr"` NwkSKey string `json:"nwkskey"` AppSKey string `json:"appskey"` }
ABPSubAppReq defines the shape of the request made by an application to the handler
type AddApplicationCollectorReq ¶
type AddApplicationCollectorReq struct { AppEUI []byte `protobuf:"bytes,1,opt,name=AppEUI,json=appEUI,proto3" json:"AppEUI,omitempty"` AppAccessKey string `protobuf:"bytes,2,opt,name=AppAccessKey,json=appAccessKey,proto3" json:"AppAccessKey,omitempty"` }
func (*AddApplicationCollectorReq) Descriptor ¶
func (*AddApplicationCollectorReq) Descriptor() ([]byte, []int)
func (*AddApplicationCollectorReq) Marshal ¶
func (m *AddApplicationCollectorReq) Marshal() (data []byte, err error)
func (*AddApplicationCollectorReq) MarshalTo ¶
func (m *AddApplicationCollectorReq) MarshalTo(data []byte) (int, error)
func (*AddApplicationCollectorReq) ProtoMessage ¶
func (*AddApplicationCollectorReq) ProtoMessage()
func (*AddApplicationCollectorReq) Reset ¶
func (m *AddApplicationCollectorReq) Reset()
func (*AddApplicationCollectorReq) Size ¶
func (m *AddApplicationCollectorReq) Size() (n int)
func (*AddApplicationCollectorReq) String ¶
func (m *AddApplicationCollectorReq) String() string
func (*AddApplicationCollectorReq) Unmarshal ¶
func (m *AddApplicationCollectorReq) Unmarshal(data []byte) error
type AddApplicationCollectorRes ¶
type AddApplicationCollectorRes struct { }
func (*AddApplicationCollectorRes) Descriptor ¶
func (*AddApplicationCollectorRes) Descriptor() ([]byte, []int)
func (*AddApplicationCollectorRes) Marshal ¶
func (m *AddApplicationCollectorRes) Marshal() (data []byte, err error)
func (*AddApplicationCollectorRes) MarshalTo ¶
func (m *AddApplicationCollectorRes) MarshalTo(data []byte) (int, error)
func (*AddApplicationCollectorRes) ProtoMessage ¶
func (*AddApplicationCollectorRes) ProtoMessage()
func (*AddApplicationCollectorRes) Reset ¶
func (m *AddApplicationCollectorRes) Reset()
func (*AddApplicationCollectorRes) Size ¶
func (m *AddApplicationCollectorRes) Size() (n int)
func (*AddApplicationCollectorRes) String ¶
func (m *AddApplicationCollectorRes) String() string
func (*AddApplicationCollectorRes) Unmarshal ¶
func (m *AddApplicationCollectorRes) Unmarshal(data []byte) error
type AppClient ¶
type AppClient interface { HandleData(ctx context.Context, in *DataAppReq, opts ...grpc.CallOption) (*DataAppRes, error) HandleJoin(ctx context.Context, in *JoinAppReq, opts ...grpc.CallOption) (*JoinAppRes, error) }
func NewAppClient ¶
func NewAppClient(cc *grpc.ClientConn) AppClient
type AppMetadata ¶
type AppMetadata struct { Frequency float32 `json:"frequency"` DataRate string `json:"datarate"` CodingRate string `json:"codingrate"` Timestamp uint32 `json:"gateway_timestamp"` Time string `json:"gateway_time,omitempty"` Channel uint32 `json:"channel"` ServerTime string `json:"server_time"` Rssi int32 `json:"rssi"` Lsnr float32 `json:"lsnr"` RFChain uint32 `json:"rfchain"` CRCStatus int32 `json:"crc"` Modulation string `json:"modulation"` GatewayEUI string `json:"gateway_eui"` Altitude int32 `json:"altitude"` Longitude float32 `json:"longitude"` Latitude float32 `json:"latitude"` }
AppMetadata represents gathered metadata that are sent to gateways
func ProtoMetaToAppMeta ¶
func ProtoMetaToAppMeta(srcs ...*Metadata) []AppMetadata
ProtoMetaToAppMeta converts a set of Metadata generate with Protobuf to a set of valid AppMetadata ready to be marshaled to json
type AppServer ¶
type AppServer interface { HandleData(context.Context, *DataAppReq) (*DataAppRes, error) HandleJoin(context.Context, *JoinAppReq) (*JoinAppRes, error) }
type AuthBrokerClient ¶
type AuthBrokerClient interface { BrokerClient BrokerManagerClient }
AuthBrokerClient gathers both BrokerClient & BrokerManagerClient interfaces
type AuthHandlerClient ¶
type AuthHandlerClient interface { HandlerClient HandlerManagerClient }
AuthHandlerClient gathers both HandlerClient & HandlerManagerClient interfaces
type BrokerClient ¶
type BrokerClient interface { HandleData(ctx context.Context, in *DataBrokerReq, opts ...grpc.CallOption) (*DataBrokerRes, error) HandleJoin(ctx context.Context, in *JoinBrokerReq, opts ...grpc.CallOption) (*JoinBrokerRes, error) }
func NewBrokerClient ¶
func NewBrokerClient(cc *grpc.ClientConn) BrokerClient
type BrokerDevice ¶
type BrokerDevice struct { DevEUI []byte `protobuf:"bytes,1,opt,name=DevEUI,json=devEUI,proto3" json:"DevEUI,omitempty"` DevAddr []byte `protobuf:"bytes,2,opt,name=DevAddr,json=devAddr,proto3" json:"DevAddr,omitempty"` NwkSKey []byte `protobuf:"bytes,3,opt,name=NwkSKey,json=nwkSKey,proto3" json:"NwkSKey,omitempty"` }
func (*BrokerDevice) Descriptor ¶
func (*BrokerDevice) Descriptor() ([]byte, []int)
func (*BrokerDevice) Marshal ¶
func (m *BrokerDevice) Marshal() (data []byte, err error)
func (*BrokerDevice) ProtoMessage ¶
func (*BrokerDevice) ProtoMessage()
func (*BrokerDevice) Reset ¶
func (m *BrokerDevice) Reset()
func (*BrokerDevice) Size ¶
func (m *BrokerDevice) Size() (n int)
func (*BrokerDevice) String ¶
func (m *BrokerDevice) String() string
func (*BrokerDevice) Unmarshal ¶
func (m *BrokerDevice) Unmarshal(data []byte) error
type BrokerManagerClient ¶
type BrokerManagerClient interface { ValidateOTAA(ctx context.Context, in *ValidateOTAABrokerReq, opts ...grpc.CallOption) (*ValidateOTAABrokerRes, error) UpsertABP(ctx context.Context, in *UpsertABPBrokerReq, opts ...grpc.CallOption) (*UpsertABPBrokerRes, error) ValidateToken(ctx context.Context, in *ValidateTokenBrokerReq, opts ...grpc.CallOption) (*ValidateTokenBrokerRes, error) }
func NewBrokerManagerClient ¶
func NewBrokerManagerClient(cc *grpc.ClientConn) BrokerManagerClient
type BrokerManagerServer ¶
type BrokerManagerServer interface { ValidateOTAA(context.Context, *ValidateOTAABrokerReq) (*ValidateOTAABrokerRes, error) UpsertABP(context.Context, *UpsertABPBrokerReq) (*UpsertABPBrokerRes, error) ValidateToken(context.Context, *ValidateTokenBrokerReq) (*ValidateTokenBrokerRes, error) }
type BrokerServer ¶
type BrokerServer interface { HandleData(context.Context, *DataBrokerReq) (*DataBrokerRes, error) HandleJoin(context.Context, *JoinBrokerReq) (*JoinBrokerRes, error) }
type CollectorApplication ¶
type CollectorApplication struct {
AppEUI []byte `protobuf:"bytes,1,opt,name=AppEUI,json=appEUI,proto3" json:"AppEUI,omitempty"`
}
func (*CollectorApplication) Descriptor ¶
func (*CollectorApplication) Descriptor() ([]byte, []int)
func (*CollectorApplication) Marshal ¶
func (m *CollectorApplication) Marshal() (data []byte, err error)
func (*CollectorApplication) MarshalTo ¶
func (m *CollectorApplication) MarshalTo(data []byte) (int, error)
func (*CollectorApplication) ProtoMessage ¶
func (*CollectorApplication) ProtoMessage()
func (*CollectorApplication) Reset ¶
func (m *CollectorApplication) Reset()
func (*CollectorApplication) Size ¶
func (m *CollectorApplication) Size() (n int)
func (*CollectorApplication) String ¶
func (m *CollectorApplication) String() string
func (*CollectorApplication) Unmarshal ¶
func (m *CollectorApplication) Unmarshal(data []byte) error
type CollectorManagerClient ¶
type CollectorManagerClient interface { GetApplications(ctx context.Context, in *GetApplicationsCollectorReq, opts ...grpc.CallOption) (*GetApplicationsCollectorRes, error) AddApplication(ctx context.Context, in *AddApplicationCollectorReq, opts ...grpc.CallOption) (*AddApplicationCollectorRes, error) RemoveApplication(ctx context.Context, in *RemoveApplicationCollectorReq, opts ...grpc.CallOption) (*RemoveApplicationCollectorRes, error) }
func NewCollectorManagerClient ¶
func NewCollectorManagerClient(cc *grpc.ClientConn) CollectorManagerClient
type CollectorManagerServer ¶
type CollectorManagerServer interface { GetApplications(context.Context, *GetApplicationsCollectorReq) (*GetApplicationsCollectorRes, error) AddApplication(context.Context, *AddApplicationCollectorReq) (*AddApplicationCollectorRes, error) RemoveApplication(context.Context, *RemoveApplicationCollectorReq) (*RemoveApplicationCollectorRes, error) }
type DataAppReq ¶
type DataAppReq struct { AppEUI []byte `protobuf:"bytes,1,opt,name=AppEUI,json=appEUI,proto3" json:"AppEUI,omitempty"` DevEUI []byte `protobuf:"bytes,2,opt,name=DevEUI,json=devEUI,proto3" json:"DevEUI,omitempty"` FPort uint32 `protobuf:"varint,10,opt,name=FPort,json=fPort,proto3" json:"FPort,omitempty"` FCnt uint32 `protobuf:"varint,11,opt,name=FCnt,json=fCnt,proto3" json:"FCnt,omitempty"` Payload []byte `protobuf:"bytes,20,opt,name=Payload,json=payload,proto3" json:"Payload,omitempty"` Metadata []*Metadata `protobuf:"bytes,30,rep,name=Metadata,json=metadata" json:"Metadata,omitempty"` }
func (*DataAppReq) Descriptor ¶
func (*DataAppReq) Descriptor() ([]byte, []int)
func (*DataAppReq) GetMetadata ¶
func (m *DataAppReq) GetMetadata() []*Metadata
func (*DataAppReq) Marshal ¶
func (m *DataAppReq) Marshal() (data []byte, err error)
func (*DataAppReq) ProtoMessage ¶
func (*DataAppReq) ProtoMessage()
func (*DataAppReq) Reset ¶
func (m *DataAppReq) Reset()
func (*DataAppReq) Size ¶
func (m *DataAppReq) Size() (n int)
func (*DataAppReq) String ¶
func (m *DataAppReq) String() string
func (*DataAppReq) Unmarshal ¶
func (m *DataAppReq) Unmarshal(data []byte) error
type DataAppRes ¶
type DataAppRes struct { }
func (*DataAppRes) Descriptor ¶
func (*DataAppRes) Descriptor() ([]byte, []int)
func (*DataAppRes) Marshal ¶
func (m *DataAppRes) Marshal() (data []byte, err error)
func (*DataAppRes) ProtoMessage ¶
func (*DataAppRes) ProtoMessage()
func (*DataAppRes) Reset ¶
func (m *DataAppRes) Reset()
func (*DataAppRes) Size ¶
func (m *DataAppRes) Size() (n int)
func (*DataAppRes) String ¶
func (m *DataAppRes) String() string
func (*DataAppRes) Unmarshal ¶
func (m *DataAppRes) Unmarshal(data []byte) error
type DataBrokerReq ¶
type DataBrokerReq struct { Payload *LoRaWANData `protobuf:"bytes,1,opt,name=Payload,json=payload" json:"Payload,omitempty"` Metadata *Metadata `protobuf:"bytes,2,opt,name=Metadata,json=metadata" json:"Metadata,omitempty"` }
func (*DataBrokerReq) Descriptor ¶
func (*DataBrokerReq) Descriptor() ([]byte, []int)
func (*DataBrokerReq) GetMetadata ¶
func (m *DataBrokerReq) GetMetadata() *Metadata
func (*DataBrokerReq) GetPayload ¶
func (m *DataBrokerReq) GetPayload() *LoRaWANData
func (*DataBrokerReq) Marshal ¶
func (m *DataBrokerReq) Marshal() (data []byte, err error)
func (*DataBrokerReq) ProtoMessage ¶
func (*DataBrokerReq) ProtoMessage()
func (*DataBrokerReq) Reset ¶
func (m *DataBrokerReq) Reset()
func (*DataBrokerReq) Size ¶
func (m *DataBrokerReq) Size() (n int)
func (*DataBrokerReq) String ¶
func (m *DataBrokerReq) String() string
func (*DataBrokerReq) Unmarshal ¶
func (m *DataBrokerReq) Unmarshal(data []byte) error
type DataBrokerRes ¶
type DataBrokerRes struct { Payload *LoRaWANData `protobuf:"bytes,1,opt,name=Payload,json=payload" json:"Payload,omitempty"` Metadata *Metadata `protobuf:"bytes,2,opt,name=Metadata,json=metadata" json:"Metadata,omitempty"` }
func (*DataBrokerRes) Descriptor ¶
func (*DataBrokerRes) Descriptor() ([]byte, []int)
func (*DataBrokerRes) GetMetadata ¶
func (m *DataBrokerRes) GetMetadata() *Metadata
func (*DataBrokerRes) GetPayload ¶
func (m *DataBrokerRes) GetPayload() *LoRaWANData
func (*DataBrokerRes) Marshal ¶
func (m *DataBrokerRes) Marshal() (data []byte, err error)
func (*DataBrokerRes) ProtoMessage ¶
func (*DataBrokerRes) ProtoMessage()
func (*DataBrokerRes) Reset ¶
func (m *DataBrokerRes) Reset()
func (*DataBrokerRes) Size ¶
func (m *DataBrokerRes) Size() (n int)
func (*DataBrokerRes) String ¶
func (m *DataBrokerRes) String() string
func (*DataBrokerRes) Unmarshal ¶
func (m *DataBrokerRes) Unmarshal(data []byte) error
type DataDownAppReq ¶
type DataDownAppReq struct { Payload []byte `json:"payload"` FPort uint8 `json:"port,omitempty"` TTL string `json:"ttl"` }
DataDownAppReq represents downlink messages sent by applications
type DataDownHandlerReq ¶
type DataDownHandlerReq struct { AppEUI []byte `protobuf:"bytes,1,opt,name=AppEUI,json=appEUI,proto3" json:"AppEUI,omitempty"` DevEUI []byte `protobuf:"bytes,2,opt,name=DevEUI,json=devEUI,proto3" json:"DevEUI,omitempty"` Payload []byte `protobuf:"bytes,20,opt,name=Payload,json=payload,proto3" json:"Payload,omitempty"` TTL string `protobuf:"bytes,30,opt,name=TTL,json=tTL,proto3" json:"TTL,omitempty"` }
func (*DataDownHandlerReq) Descriptor ¶
func (*DataDownHandlerReq) Descriptor() ([]byte, []int)
func (*DataDownHandlerReq) Marshal ¶
func (m *DataDownHandlerReq) Marshal() (data []byte, err error)
func (*DataDownHandlerReq) MarshalTo ¶
func (m *DataDownHandlerReq) MarshalTo(data []byte) (int, error)
func (*DataDownHandlerReq) ProtoMessage ¶
func (*DataDownHandlerReq) ProtoMessage()
func (*DataDownHandlerReq) Reset ¶
func (m *DataDownHandlerReq) Reset()
func (*DataDownHandlerReq) Size ¶
func (m *DataDownHandlerReq) Size() (n int)
func (*DataDownHandlerReq) String ¶
func (m *DataDownHandlerReq) String() string
func (*DataDownHandlerReq) Unmarshal ¶
func (m *DataDownHandlerReq) Unmarshal(data []byte) error
type DataDownHandlerRes ¶
type DataDownHandlerRes struct { }
func (*DataDownHandlerRes) Descriptor ¶
func (*DataDownHandlerRes) Descriptor() ([]byte, []int)
func (*DataDownHandlerRes) Marshal ¶
func (m *DataDownHandlerRes) Marshal() (data []byte, err error)
func (*DataDownHandlerRes) MarshalTo ¶
func (m *DataDownHandlerRes) MarshalTo(data []byte) (int, error)
func (*DataDownHandlerRes) ProtoMessage ¶
func (*DataDownHandlerRes) ProtoMessage()
func (*DataDownHandlerRes) Reset ¶
func (m *DataDownHandlerRes) Reset()
func (*DataDownHandlerRes) Size ¶
func (m *DataDownHandlerRes) Size() (n int)
func (*DataDownHandlerRes) String ¶
func (m *DataDownHandlerRes) String() string
func (*DataDownHandlerRes) Unmarshal ¶
func (m *DataDownHandlerRes) Unmarshal(data []byte) error
type DataRouterReq ¶
type DataRouterReq struct { GatewayID []byte `protobuf:"bytes,1,opt,name=GatewayID,json=gatewayID,proto3" json:"GatewayID,omitempty"` Payload *LoRaWANData `protobuf:"bytes,2,opt,name=Payload,json=payload" json:"Payload,omitempty"` Metadata *Metadata `protobuf:"bytes,3,opt,name=Metadata,json=metadata" json:"Metadata,omitempty"` }
func (*DataRouterReq) Descriptor ¶
func (*DataRouterReq) Descriptor() ([]byte, []int)
func (*DataRouterReq) GetMetadata ¶
func (m *DataRouterReq) GetMetadata() *Metadata
func (*DataRouterReq) GetPayload ¶
func (m *DataRouterReq) GetPayload() *LoRaWANData
func (*DataRouterReq) Marshal ¶
func (m *DataRouterReq) Marshal() (data []byte, err error)
func (*DataRouterReq) ProtoMessage ¶
func (*DataRouterReq) ProtoMessage()
func (*DataRouterReq) Reset ¶
func (m *DataRouterReq) Reset()
func (*DataRouterReq) Size ¶
func (m *DataRouterReq) Size() (n int)
func (*DataRouterReq) String ¶
func (m *DataRouterReq) String() string
func (*DataRouterReq) Unmarshal ¶
func (m *DataRouterReq) Unmarshal(data []byte) error
type DataRouterRes ¶
type DataRouterRes struct { Payload *LoRaWANData `protobuf:"bytes,1,opt,name=Payload,json=payload" json:"Payload,omitempty"` Metadata *Metadata `protobuf:"bytes,2,opt,name=Metadata,json=metadata" json:"Metadata,omitempty"` }
func (*DataRouterRes) Descriptor ¶
func (*DataRouterRes) Descriptor() ([]byte, []int)
func (*DataRouterRes) GetMetadata ¶
func (m *DataRouterRes) GetMetadata() *Metadata
func (*DataRouterRes) GetPayload ¶
func (m *DataRouterRes) GetPayload() *LoRaWANData
func (*DataRouterRes) Marshal ¶
func (m *DataRouterRes) Marshal() (data []byte, err error)
func (*DataRouterRes) ProtoMessage ¶
func (*DataRouterRes) ProtoMessage()
func (*DataRouterRes) Reset ¶
func (m *DataRouterRes) Reset()
func (*DataRouterRes) Size ¶
func (m *DataRouterRes) Size() (n int)
func (*DataRouterRes) String ¶
func (m *DataRouterRes) String() string
func (*DataRouterRes) Unmarshal ¶
func (m *DataRouterRes) Unmarshal(data []byte) error
type DataUpAppReq ¶
type DataUpAppReq struct { Payload []byte `json:"payload"` Fields map[string]interface{} `json:"fields,omitempty"` FPort uint8 `json:"port,omitempty"` FCnt uint32 `json:"counter"` DevEUI string `json:"dev_eui"` Metadata []AppMetadata `json:"metadata"` }
DataUpAppReq represents the actual payloads sent to application on uplink
type DataUpHandlerReq ¶
type DataUpHandlerReq struct { AppEUI []byte `protobuf:"bytes,1,opt,name=AppEUI,json=appEUI,proto3" json:"AppEUI,omitempty"` DevEUI []byte `protobuf:"bytes,2,opt,name=DevEUI,json=devEUI,proto3" json:"DevEUI,omitempty"` FCnt uint32 `protobuf:"varint,10,opt,name=FCnt,json=fCnt,proto3" json:"FCnt,omitempty"` FPort uint32 `protobuf:"varint,11,opt,name=FPort,json=fPort,proto3" json:"FPort,omitempty"` MType uint32 `protobuf:"varint,12,opt,name=MType,json=mType,proto3" json:"MType,omitempty"` FCntUpReset bool `protobuf:"varint,13,opt,name=FCntUpReset,json=fCntUpReset,proto3" json:"FCntUpReset,omitempty"` Payload []byte `protobuf:"bytes,20,opt,name=Payload,json=payload,proto3" json:"Payload,omitempty"` Metadata *Metadata `protobuf:"bytes,30,opt,name=Metadata,json=metadata" json:"Metadata,omitempty"` }
func (*DataUpHandlerReq) Descriptor ¶
func (*DataUpHandlerReq) Descriptor() ([]byte, []int)
func (*DataUpHandlerReq) GetMetadata ¶
func (m *DataUpHandlerReq) GetMetadata() *Metadata
func (*DataUpHandlerReq) Marshal ¶
func (m *DataUpHandlerReq) Marshal() (data []byte, err error)
func (*DataUpHandlerReq) ProtoMessage ¶
func (*DataUpHandlerReq) ProtoMessage()
func (*DataUpHandlerReq) Reset ¶
func (m *DataUpHandlerReq) Reset()
func (*DataUpHandlerReq) Size ¶
func (m *DataUpHandlerReq) Size() (n int)
func (*DataUpHandlerReq) String ¶
func (m *DataUpHandlerReq) String() string
func (*DataUpHandlerReq) Unmarshal ¶
func (m *DataUpHandlerReq) Unmarshal(data []byte) error
type DataUpHandlerRes ¶
type DataUpHandlerRes struct { Payload *LoRaWANData `protobuf:"bytes,20,opt,name=Payload,json=payload" json:"Payload,omitempty"` Metadata *Metadata `protobuf:"bytes,30,opt,name=Metadata,json=metadata" json:"Metadata,omitempty"` }
func (*DataUpHandlerRes) Descriptor ¶
func (*DataUpHandlerRes) Descriptor() ([]byte, []int)
func (*DataUpHandlerRes) GetMetadata ¶
func (m *DataUpHandlerRes) GetMetadata() *Metadata
func (*DataUpHandlerRes) GetPayload ¶
func (m *DataUpHandlerRes) GetPayload() *LoRaWANData
func (*DataUpHandlerRes) Marshal ¶
func (m *DataUpHandlerRes) Marshal() (data []byte, err error)
func (*DataUpHandlerRes) ProtoMessage ¶
func (*DataUpHandlerRes) ProtoMessage()
func (*DataUpHandlerRes) Reset ¶
func (m *DataUpHandlerRes) Reset()
func (*DataUpHandlerRes) Size ¶
func (m *DataUpHandlerRes) Size() (n int)
func (*DataUpHandlerRes) String ¶
func (m *DataUpHandlerRes) String() string
func (*DataUpHandlerRes) Unmarshal ¶
func (m *DataUpHandlerRes) Unmarshal(data []byte) error
type GetApplicationsCollectorReq ¶
type GetApplicationsCollectorReq struct { }
func (*GetApplicationsCollectorReq) Descriptor ¶
func (*GetApplicationsCollectorReq) Descriptor() ([]byte, []int)
func (*GetApplicationsCollectorReq) Marshal ¶
func (m *GetApplicationsCollectorReq) Marshal() (data []byte, err error)
func (*GetApplicationsCollectorReq) MarshalTo ¶
func (m *GetApplicationsCollectorReq) MarshalTo(data []byte) (int, error)
func (*GetApplicationsCollectorReq) ProtoMessage ¶
func (*GetApplicationsCollectorReq) ProtoMessage()
func (*GetApplicationsCollectorReq) Reset ¶
func (m *GetApplicationsCollectorReq) Reset()
func (*GetApplicationsCollectorReq) Size ¶
func (m *GetApplicationsCollectorReq) Size() (n int)
func (*GetApplicationsCollectorReq) String ¶
func (m *GetApplicationsCollectorReq) String() string
func (*GetApplicationsCollectorReq) Unmarshal ¶
func (m *GetApplicationsCollectorReq) Unmarshal(data []byte) error
type GetApplicationsCollectorRes ¶
type GetApplicationsCollectorRes struct {
Applications []*CollectorApplication `protobuf:"bytes,1,rep,name=Applications,json=applications" json:"Applications,omitempty"`
}
func (*GetApplicationsCollectorRes) Descriptor ¶
func (*GetApplicationsCollectorRes) Descriptor() ([]byte, []int)
func (*GetApplicationsCollectorRes) GetApplications ¶
func (m *GetApplicationsCollectorRes) GetApplications() []*CollectorApplication
func (*GetApplicationsCollectorRes) Marshal ¶
func (m *GetApplicationsCollectorRes) Marshal() (data []byte, err error)
func (*GetApplicationsCollectorRes) MarshalTo ¶
func (m *GetApplicationsCollectorRes) MarshalTo(data []byte) (int, error)
func (*GetApplicationsCollectorRes) ProtoMessage ¶
func (*GetApplicationsCollectorRes) ProtoMessage()
func (*GetApplicationsCollectorRes) Reset ¶
func (m *GetApplicationsCollectorRes) Reset()
func (*GetApplicationsCollectorRes) Size ¶
func (m *GetApplicationsCollectorRes) Size() (n int)
func (*GetApplicationsCollectorRes) String ¶
func (m *GetApplicationsCollectorRes) String() string
func (*GetApplicationsCollectorRes) Unmarshal ¶
func (m *GetApplicationsCollectorRes) Unmarshal(data []byte) error
type GetDefaultDeviceReq ¶
type GetDefaultDeviceReq struct { Token string `protobuf:"bytes,1,opt,name=Token,json=token,proto3" json:"Token,omitempty"` AppEUI []byte `protobuf:"bytes,2,opt,name=AppEUI,json=appEUI,proto3" json:"AppEUI,omitempty"` }
func (*GetDefaultDeviceReq) Descriptor ¶
func (*GetDefaultDeviceReq) Descriptor() ([]byte, []int)
func (*GetDefaultDeviceReq) Marshal ¶
func (m *GetDefaultDeviceReq) Marshal() (data []byte, err error)
func (*GetDefaultDeviceReq) MarshalTo ¶
func (m *GetDefaultDeviceReq) MarshalTo(data []byte) (int, error)
func (*GetDefaultDeviceReq) ProtoMessage ¶
func (*GetDefaultDeviceReq) ProtoMessage()
func (*GetDefaultDeviceReq) Reset ¶
func (m *GetDefaultDeviceReq) Reset()
func (*GetDefaultDeviceReq) Size ¶
func (m *GetDefaultDeviceReq) Size() (n int)
func (*GetDefaultDeviceReq) String ¶
func (m *GetDefaultDeviceReq) String() string
func (*GetDefaultDeviceReq) Unmarshal ¶
func (m *GetDefaultDeviceReq) Unmarshal(data []byte) error
type GetDefaultDeviceRes ¶
type GetDefaultDeviceRes struct {
AppKey []byte `protobuf:"bytes,1,opt,name=AppKey,json=appKey,proto3" json:"AppKey,omitempty"`
}
func (*GetDefaultDeviceRes) Descriptor ¶
func (*GetDefaultDeviceRes) Descriptor() ([]byte, []int)
func (*GetDefaultDeviceRes) Marshal ¶
func (m *GetDefaultDeviceRes) Marshal() (data []byte, err error)
func (*GetDefaultDeviceRes) MarshalTo ¶
func (m *GetDefaultDeviceRes) MarshalTo(data []byte) (int, error)
func (*GetDefaultDeviceRes) ProtoMessage ¶
func (*GetDefaultDeviceRes) ProtoMessage()
func (*GetDefaultDeviceRes) Reset ¶
func (m *GetDefaultDeviceRes) Reset()
func (*GetDefaultDeviceRes) Size ¶
func (m *GetDefaultDeviceRes) Size() (n int)
func (*GetDefaultDeviceRes) String ¶
func (m *GetDefaultDeviceRes) String() string
func (*GetDefaultDeviceRes) Unmarshal ¶
func (m *GetDefaultDeviceRes) Unmarshal(data []byte) error
type GetPayloadFunctionsReq ¶
type GetPayloadFunctionsReq struct { Token string `protobuf:"bytes,1,opt,name=Token,json=token,proto3" json:"Token,omitempty"` AppEUI []byte `protobuf:"bytes,2,opt,name=AppEUI,json=appEUI,proto3" json:"AppEUI,omitempty"` }
func (*GetPayloadFunctionsReq) Descriptor ¶
func (*GetPayloadFunctionsReq) Descriptor() ([]byte, []int)
func (*GetPayloadFunctionsReq) Marshal ¶
func (m *GetPayloadFunctionsReq) Marshal() (data []byte, err error)
func (*GetPayloadFunctionsReq) MarshalTo ¶
func (m *GetPayloadFunctionsReq) MarshalTo(data []byte) (int, error)
func (*GetPayloadFunctionsReq) ProtoMessage ¶
func (*GetPayloadFunctionsReq) ProtoMessage()
func (*GetPayloadFunctionsReq) Reset ¶
func (m *GetPayloadFunctionsReq) Reset()
func (*GetPayloadFunctionsReq) Size ¶
func (m *GetPayloadFunctionsReq) Size() (n int)
func (*GetPayloadFunctionsReq) String ¶
func (m *GetPayloadFunctionsReq) String() string
func (*GetPayloadFunctionsReq) Unmarshal ¶
func (m *GetPayloadFunctionsReq) Unmarshal(data []byte) error
type GetPayloadFunctionsRes ¶
type GetPayloadFunctionsRes struct { Decoder string `protobuf:"bytes,1,opt,name=Decoder,json=decoder,proto3" json:"Decoder,omitempty"` Converter string `protobuf:"bytes,2,opt,name=Converter,json=converter,proto3" json:"Converter,omitempty"` Validator string `protobuf:"bytes,3,opt,name=Validator,json=validator,proto3" json:"Validator,omitempty"` }
func (*GetPayloadFunctionsRes) Descriptor ¶
func (*GetPayloadFunctionsRes) Descriptor() ([]byte, []int)
func (*GetPayloadFunctionsRes) Marshal ¶
func (m *GetPayloadFunctionsRes) Marshal() (data []byte, err error)
func (*GetPayloadFunctionsRes) MarshalTo ¶
func (m *GetPayloadFunctionsRes) MarshalTo(data []byte) (int, error)
func (*GetPayloadFunctionsRes) ProtoMessage ¶
func (*GetPayloadFunctionsRes) ProtoMessage()
func (*GetPayloadFunctionsRes) Reset ¶
func (m *GetPayloadFunctionsRes) Reset()
func (*GetPayloadFunctionsRes) Size ¶
func (m *GetPayloadFunctionsRes) Size() (n int)
func (*GetPayloadFunctionsRes) String ¶
func (m *GetPayloadFunctionsRes) String() string
func (*GetPayloadFunctionsRes) Unmarshal ¶
func (m *GetPayloadFunctionsRes) Unmarshal(data []byte) error
type HandlerABPDevice ¶
type HandlerABPDevice struct { DevAddr []byte `protobuf:"bytes,2,opt,name=DevAddr,json=devAddr,proto3" json:"DevAddr,omitempty"` NwkSKey []byte `protobuf:"bytes,3,opt,name=NwkSKey,json=nwkSKey,proto3" json:"NwkSKey,omitempty"` AppSKey []byte `protobuf:"bytes,4,opt,name=AppSKey,json=appSKey,proto3" json:"AppSKey,omitempty"` FCntUp uint32 `protobuf:"varint,5,opt,name=FCntUp,json=fCntUp,proto3" json:"FCntUp,omitempty"` FCntDown uint32 `protobuf:"varint,6,opt,name=FCntDown,json=fCntDown,proto3" json:"FCntDown,omitempty"` Flags uint32 `protobuf:"varint,7,opt,name=Flags,json=flags,proto3" json:"Flags,omitempty"` }
func (*HandlerABPDevice) Descriptor ¶
func (*HandlerABPDevice) Descriptor() ([]byte, []int)
func (*HandlerABPDevice) Marshal ¶
func (m *HandlerABPDevice) Marshal() (data []byte, err error)
func (*HandlerABPDevice) ProtoMessage ¶
func (*HandlerABPDevice) ProtoMessage()
func (*HandlerABPDevice) Reset ¶
func (m *HandlerABPDevice) Reset()
func (*HandlerABPDevice) Size ¶
func (m *HandlerABPDevice) Size() (n int)
func (*HandlerABPDevice) String ¶
func (m *HandlerABPDevice) String() string
func (*HandlerABPDevice) Unmarshal ¶
func (m *HandlerABPDevice) Unmarshal(data []byte) error
type HandlerClient ¶
type HandlerClient interface { HandleDataUp(ctx context.Context, in *DataUpHandlerReq, opts ...grpc.CallOption) (*DataUpHandlerRes, error) HandleDataDown(ctx context.Context, in *DataDownHandlerReq, opts ...grpc.CallOption) (*DataDownHandlerRes, error) HandleJoin(ctx context.Context, in *JoinHandlerReq, opts ...grpc.CallOption) (*JoinHandlerRes, error) }
func NewHandlerClient ¶
func NewHandlerClient(cc *grpc.ClientConn) HandlerClient
type HandlerManagerClient ¶
type HandlerManagerClient interface { UpsertOTAA(ctx context.Context, in *UpsertOTAAHandlerReq, opts ...grpc.CallOption) (*UpsertOTAAHandlerRes, error) UpsertABP(ctx context.Context, in *UpsertABPHandlerReq, opts ...grpc.CallOption) (*UpsertABPHandlerRes, error) ListDevices(ctx context.Context, in *ListDevicesHandlerReq, opts ...grpc.CallOption) (*ListDevicesHandlerRes, error) GetDefaultDevice(ctx context.Context, in *GetDefaultDeviceReq, opts ...grpc.CallOption) (*GetDefaultDeviceRes, error) SetDefaultDevice(ctx context.Context, in *SetDefaultDeviceReq, opts ...grpc.CallOption) (*SetDefaultDeviceRes, error) GetPayloadFunctions(ctx context.Context, in *GetPayloadFunctionsReq, opts ...grpc.CallOption) (*GetPayloadFunctionsRes, error) SetPayloadFunctions(ctx context.Context, in *SetPayloadFunctionsReq, opts ...grpc.CallOption) (*SetPayloadFunctionsRes, error) TestPayloadFunctions(ctx context.Context, in *TestPayloadFunctionsReq, opts ...grpc.CallOption) (*TestPayloadFunctionsRes, error) }
func NewHandlerManagerClient ¶
func NewHandlerManagerClient(cc *grpc.ClientConn) HandlerManagerClient
type HandlerManagerServer ¶
type HandlerManagerServer interface { UpsertOTAA(context.Context, *UpsertOTAAHandlerReq) (*UpsertOTAAHandlerRes, error) UpsertABP(context.Context, *UpsertABPHandlerReq) (*UpsertABPHandlerRes, error) ListDevices(context.Context, *ListDevicesHandlerReq) (*ListDevicesHandlerRes, error) GetDefaultDevice(context.Context, *GetDefaultDeviceReq) (*GetDefaultDeviceRes, error) SetDefaultDevice(context.Context, *SetDefaultDeviceReq) (*SetDefaultDeviceRes, error) GetPayloadFunctions(context.Context, *GetPayloadFunctionsReq) (*GetPayloadFunctionsRes, error) SetPayloadFunctions(context.Context, *SetPayloadFunctionsReq) (*SetPayloadFunctionsRes, error) TestPayloadFunctions(context.Context, *TestPayloadFunctionsReq) (*TestPayloadFunctionsRes, error) }
type HandlerOTAADevice ¶
type HandlerOTAADevice struct { DevEUI []byte `protobuf:"bytes,1,opt,name=DevEUI,json=devEUI,proto3" json:"DevEUI,omitempty"` DevAddr []byte `protobuf:"bytes,2,opt,name=DevAddr,json=devAddr,proto3" json:"DevAddr,omitempty"` NwkSKey []byte `protobuf:"bytes,3,opt,name=NwkSKey,json=nwkSKey,proto3" json:"NwkSKey,omitempty"` AppSKey []byte `protobuf:"bytes,4,opt,name=AppSKey,json=appSKey,proto3" json:"AppSKey,omitempty"` AppKey []byte `protobuf:"bytes,5,opt,name=AppKey,json=appKey,proto3" json:"AppKey,omitempty"` FCntUp uint32 `protobuf:"varint,7,opt,name=FCntUp,json=fCntUp,proto3" json:"FCntUp,omitempty"` FCntDown uint32 `protobuf:"varint,8,opt,name=FCntDown,json=fCntDown,proto3" json:"FCntDown,omitempty"` }
func (*HandlerOTAADevice) Descriptor ¶
func (*HandlerOTAADevice) Descriptor() ([]byte, []int)
func (*HandlerOTAADevice) Marshal ¶
func (m *HandlerOTAADevice) Marshal() (data []byte, err error)
func (*HandlerOTAADevice) MarshalTo ¶
func (m *HandlerOTAADevice) MarshalTo(data []byte) (int, error)
func (*HandlerOTAADevice) ProtoMessage ¶
func (*HandlerOTAADevice) ProtoMessage()
func (*HandlerOTAADevice) Reset ¶
func (m *HandlerOTAADevice) Reset()
func (*HandlerOTAADevice) Size ¶
func (m *HandlerOTAADevice) Size() (n int)
func (*HandlerOTAADevice) String ¶
func (m *HandlerOTAADevice) String() string
func (*HandlerOTAADevice) Unmarshal ¶
func (m *HandlerOTAADevice) Unmarshal(data []byte) error
type HandlerServer ¶
type HandlerServer interface { HandleDataUp(context.Context, *DataUpHandlerReq) (*DataUpHandlerRes, error) HandleDataDown(context.Context, *DataDownHandlerReq) (*DataDownHandlerRes, error) HandleJoin(context.Context, *JoinHandlerReq) (*JoinHandlerRes, error) }
type JoinAppReq ¶
type JoinAppReq struct { AppEUI []byte `protobuf:"bytes,1,opt,name=AppEUI,json=appEUI,proto3" json:"AppEUI,omitempty"` DevEUI []byte `protobuf:"bytes,2,opt,name=DevEUI,json=devEUI,proto3" json:"DevEUI,omitempty"` Metadata []*Metadata `protobuf:"bytes,30,rep,name=Metadata,json=metadata" json:"Metadata,omitempty"` }
func (*JoinAppReq) Descriptor ¶
func (*JoinAppReq) Descriptor() ([]byte, []int)
func (*JoinAppReq) GetMetadata ¶
func (m *JoinAppReq) GetMetadata() []*Metadata
func (*JoinAppReq) Marshal ¶
func (m *JoinAppReq) Marshal() (data []byte, err error)
func (*JoinAppReq) ProtoMessage ¶
func (*JoinAppReq) ProtoMessage()
func (*JoinAppReq) Reset ¶
func (m *JoinAppReq) Reset()
func (*JoinAppReq) Size ¶
func (m *JoinAppReq) Size() (n int)
func (*JoinAppReq) String ¶
func (m *JoinAppReq) String() string
func (*JoinAppReq) Unmarshal ¶
func (m *JoinAppReq) Unmarshal(data []byte) error
type JoinAppRes ¶
type JoinAppRes struct { }
func (*JoinAppRes) Descriptor ¶
func (*JoinAppRes) Descriptor() ([]byte, []int)
func (*JoinAppRes) Marshal ¶
func (m *JoinAppRes) Marshal() (data []byte, err error)
func (*JoinAppRes) ProtoMessage ¶
func (*JoinAppRes) ProtoMessage()
func (*JoinAppRes) Reset ¶
func (m *JoinAppRes) Reset()
func (*JoinAppRes) Size ¶
func (m *JoinAppRes) Size() (n int)
func (*JoinAppRes) String ¶
func (m *JoinAppRes) String() string
func (*JoinAppRes) Unmarshal ¶
func (m *JoinAppRes) Unmarshal(data []byte) error
type JoinBrokerReq ¶
type JoinBrokerReq struct { AppEUI []byte `protobuf:"bytes,1,opt,name=AppEUI,json=appEUI,proto3" json:"AppEUI,omitempty"` DevEUI []byte `protobuf:"bytes,2,opt,name=DevEUI,json=devEUI,proto3" json:"DevEUI,omitempty"` DevNonce []byte `protobuf:"bytes,3,opt,name=DevNonce,json=devNonce,proto3" json:"DevNonce,omitempty"` MIC []byte `protobuf:"bytes,4,opt,name=MIC,json=mIC,proto3" json:"MIC,omitempty"` Metadata *Metadata `protobuf:"bytes,5,opt,name=Metadata,json=metadata" json:"Metadata,omitempty"` }
func (*JoinBrokerReq) Descriptor ¶
func (*JoinBrokerReq) Descriptor() ([]byte, []int)
func (*JoinBrokerReq) GetMetadata ¶
func (m *JoinBrokerReq) GetMetadata() *Metadata
func (*JoinBrokerReq) Marshal ¶
func (m *JoinBrokerReq) Marshal() (data []byte, err error)
func (*JoinBrokerReq) ProtoMessage ¶
func (*JoinBrokerReq) ProtoMessage()
func (*JoinBrokerReq) Reset ¶
func (m *JoinBrokerReq) Reset()
func (*JoinBrokerReq) Size ¶
func (m *JoinBrokerReq) Size() (n int)
func (*JoinBrokerReq) String ¶
func (m *JoinBrokerReq) String() string
func (*JoinBrokerReq) Unmarshal ¶
func (m *JoinBrokerReq) Unmarshal(data []byte) error
type JoinBrokerRes ¶
type JoinBrokerRes struct { Payload *LoRaWANJoinAccept `protobuf:"bytes,1,opt,name=Payload,json=payload" json:"Payload,omitempty"` DevAddr []byte `protobuf:"bytes,2,opt,name=DevAddr,json=devAddr,proto3" json:"DevAddr,omitempty"` Metadata *Metadata `protobuf:"bytes,3,opt,name=Metadata,json=metadata" json:"Metadata,omitempty"` }
func (*JoinBrokerRes) Descriptor ¶
func (*JoinBrokerRes) Descriptor() ([]byte, []int)
func (*JoinBrokerRes) GetMetadata ¶
func (m *JoinBrokerRes) GetMetadata() *Metadata
func (*JoinBrokerRes) GetPayload ¶
func (m *JoinBrokerRes) GetPayload() *LoRaWANJoinAccept
func (*JoinBrokerRes) Marshal ¶
func (m *JoinBrokerRes) Marshal() (data []byte, err error)
func (*JoinBrokerRes) ProtoMessage ¶
func (*JoinBrokerRes) ProtoMessage()
func (*JoinBrokerRes) Reset ¶
func (m *JoinBrokerRes) Reset()
func (*JoinBrokerRes) Size ¶
func (m *JoinBrokerRes) Size() (n int)
func (*JoinBrokerRes) String ¶
func (m *JoinBrokerRes) String() string
func (*JoinBrokerRes) Unmarshal ¶
func (m *JoinBrokerRes) Unmarshal(data []byte) error
type JoinHandlerReq ¶
type JoinHandlerReq struct { AppEUI []byte `protobuf:"bytes,1,opt,name=AppEUI,json=appEUI,proto3" json:"AppEUI,omitempty"` DevEUI []byte `protobuf:"bytes,2,opt,name=DevEUI,json=devEUI,proto3" json:"DevEUI,omitempty"` DevNonce []byte `protobuf:"bytes,10,opt,name=DevNonce,json=devNonce,proto3" json:"DevNonce,omitempty"` MIC []byte `protobuf:"bytes,11,opt,name=MIC,json=mIC,proto3" json:"MIC,omitempty"` Metadata *Metadata `protobuf:"bytes,30,opt,name=Metadata,json=metadata" json:"Metadata,omitempty"` }
func (*JoinHandlerReq) Descriptor ¶
func (*JoinHandlerReq) Descriptor() ([]byte, []int)
func (*JoinHandlerReq) GetMetadata ¶
func (m *JoinHandlerReq) GetMetadata() *Metadata
func (*JoinHandlerReq) Marshal ¶
func (m *JoinHandlerReq) Marshal() (data []byte, err error)
func (*JoinHandlerReq) ProtoMessage ¶
func (*JoinHandlerReq) ProtoMessage()
func (*JoinHandlerReq) Reset ¶
func (m *JoinHandlerReq) Reset()
func (*JoinHandlerReq) Size ¶
func (m *JoinHandlerReq) Size() (n int)
func (*JoinHandlerReq) String ¶
func (m *JoinHandlerReq) String() string
func (*JoinHandlerReq) Unmarshal ¶
func (m *JoinHandlerReq) Unmarshal(data []byte) error
type JoinHandlerRes ¶
type JoinHandlerRes struct { DevAddr []byte `protobuf:"bytes,1,opt,name=DevAddr,json=devAddr,proto3" json:"DevAddr,omitempty"` Payload *LoRaWANJoinAccept `protobuf:"bytes,20,opt,name=Payload,json=payload" json:"Payload,omitempty"` NwkSKey []byte `protobuf:"bytes,21,opt,name=NwkSKey,json=nwkSKey,proto3" json:"NwkSKey,omitempty"` Metadata *Metadata `protobuf:"bytes,30,opt,name=Metadata,json=metadata" json:"Metadata,omitempty"` }
func (*JoinHandlerRes) Descriptor ¶
func (*JoinHandlerRes) Descriptor() ([]byte, []int)
func (*JoinHandlerRes) GetMetadata ¶
func (m *JoinHandlerRes) GetMetadata() *Metadata
func (*JoinHandlerRes) GetPayload ¶
func (m *JoinHandlerRes) GetPayload() *LoRaWANJoinAccept
func (*JoinHandlerRes) Marshal ¶
func (m *JoinHandlerRes) Marshal() (data []byte, err error)
func (*JoinHandlerRes) ProtoMessage ¶
func (*JoinHandlerRes) ProtoMessage()
func (*JoinHandlerRes) Reset ¶
func (m *JoinHandlerRes) Reset()
func (*JoinHandlerRes) Size ¶
func (m *JoinHandlerRes) Size() (n int)
func (*JoinHandlerRes) String ¶
func (m *JoinHandlerRes) String() string
func (*JoinHandlerRes) Unmarshal ¶
func (m *JoinHandlerRes) Unmarshal(data []byte) error
type JoinRouterReq ¶
type JoinRouterReq struct { GatewayID []byte `protobuf:"bytes,1,opt,name=GatewayID,json=gatewayID,proto3" json:"GatewayID,omitempty"` AppEUI []byte `protobuf:"bytes,2,opt,name=AppEUI,json=appEUI,proto3" json:"AppEUI,omitempty"` DevEUI []byte `protobuf:"bytes,3,opt,name=DevEUI,json=devEUI,proto3" json:"DevEUI,omitempty"` DevNonce []byte `protobuf:"bytes,4,opt,name=DevNonce,json=devNonce,proto3" json:"DevNonce,omitempty"` MIC []byte `protobuf:"bytes,5,opt,name=MIC,json=mIC,proto3" json:"MIC,omitempty"` Metadata *Metadata `protobuf:"bytes,6,opt,name=Metadata,json=metadata" json:"Metadata,omitempty"` }
func (*JoinRouterReq) Descriptor ¶
func (*JoinRouterReq) Descriptor() ([]byte, []int)
func (*JoinRouterReq) GetMetadata ¶
func (m *JoinRouterReq) GetMetadata() *Metadata
func (*JoinRouterReq) Marshal ¶
func (m *JoinRouterReq) Marshal() (data []byte, err error)
func (*JoinRouterReq) ProtoMessage ¶
func (*JoinRouterReq) ProtoMessage()
func (*JoinRouterReq) Reset ¶
func (m *JoinRouterReq) Reset()
func (*JoinRouterReq) Size ¶
func (m *JoinRouterReq) Size() (n int)
func (*JoinRouterReq) String ¶
func (m *JoinRouterReq) String() string
func (*JoinRouterReq) Unmarshal ¶
func (m *JoinRouterReq) Unmarshal(data []byte) error
type JoinRouterRes ¶
type JoinRouterRes struct { Payload *LoRaWANJoinAccept `protobuf:"bytes,1,opt,name=Payload,json=payload" json:"Payload,omitempty"` Metadata *Metadata `protobuf:"bytes,2,opt,name=Metadata,json=metadata" json:"Metadata,omitempty"` }
func (*JoinRouterRes) Descriptor ¶
func (*JoinRouterRes) Descriptor() ([]byte, []int)
func (*JoinRouterRes) GetMetadata ¶
func (m *JoinRouterRes) GetMetadata() *Metadata
func (*JoinRouterRes) GetPayload ¶
func (m *JoinRouterRes) GetPayload() *LoRaWANJoinAccept
func (*JoinRouterRes) Marshal ¶
func (m *JoinRouterRes) Marshal() (data []byte, err error)
func (*JoinRouterRes) ProtoMessage ¶
func (*JoinRouterRes) ProtoMessage()
func (*JoinRouterRes) Reset ¶
func (m *JoinRouterRes) Reset()
func (*JoinRouterRes) Size ¶
func (m *JoinRouterRes) Size() (n int)
func (*JoinRouterRes) String ¶
func (m *JoinRouterRes) String() string
func (*JoinRouterRes) Unmarshal ¶
func (m *JoinRouterRes) Unmarshal(data []byte) error
type ListDevicesHandlerReq ¶
type ListDevicesHandlerReq struct { Token string `protobuf:"bytes,1,opt,name=Token,json=token,proto3" json:"Token,omitempty"` AppEUI []byte `protobuf:"bytes,2,opt,name=AppEUI,json=appEUI,proto3" json:"AppEUI,omitempty"` }
func (*ListDevicesHandlerReq) Descriptor ¶
func (*ListDevicesHandlerReq) Descriptor() ([]byte, []int)
func (*ListDevicesHandlerReq) Marshal ¶
func (m *ListDevicesHandlerReq) Marshal() (data []byte, err error)
func (*ListDevicesHandlerReq) MarshalTo ¶
func (m *ListDevicesHandlerReq) MarshalTo(data []byte) (int, error)
func (*ListDevicesHandlerReq) ProtoMessage ¶
func (*ListDevicesHandlerReq) ProtoMessage()
func (*ListDevicesHandlerReq) Reset ¶
func (m *ListDevicesHandlerReq) Reset()
func (*ListDevicesHandlerReq) Size ¶
func (m *ListDevicesHandlerReq) Size() (n int)
func (*ListDevicesHandlerReq) String ¶
func (m *ListDevicesHandlerReq) String() string
func (*ListDevicesHandlerReq) Unmarshal ¶
func (m *ListDevicesHandlerReq) Unmarshal(data []byte) error
type ListDevicesHandlerRes ¶
type ListDevicesHandlerRes struct { OTAA []*HandlerOTAADevice `protobuf:"bytes,1,rep,name=OTAA,json=oTAA" json:"OTAA,omitempty"` ABP []*HandlerABPDevice `protobuf:"bytes,2,rep,name=ABP,json=aBP" json:"ABP,omitempty"` }
func (*ListDevicesHandlerRes) Descriptor ¶
func (*ListDevicesHandlerRes) Descriptor() ([]byte, []int)
func (*ListDevicesHandlerRes) GetABP ¶
func (m *ListDevicesHandlerRes) GetABP() []*HandlerABPDevice
func (*ListDevicesHandlerRes) GetOTAA ¶
func (m *ListDevicesHandlerRes) GetOTAA() []*HandlerOTAADevice
func (*ListDevicesHandlerRes) Marshal ¶
func (m *ListDevicesHandlerRes) Marshal() (data []byte, err error)
func (*ListDevicesHandlerRes) MarshalTo ¶
func (m *ListDevicesHandlerRes) MarshalTo(data []byte) (int, error)
func (*ListDevicesHandlerRes) ProtoMessage ¶
func (*ListDevicesHandlerRes) ProtoMessage()
func (*ListDevicesHandlerRes) Reset ¶
func (m *ListDevicesHandlerRes) Reset()
func (*ListDevicesHandlerRes) Size ¶
func (m *ListDevicesHandlerRes) Size() (n int)
func (*ListDevicesHandlerRes) String ¶
func (m *ListDevicesHandlerRes) String() string
func (*ListDevicesHandlerRes) Unmarshal ¶
func (m *ListDevicesHandlerRes) Unmarshal(data []byte) error
type LoRaWANDLSettings ¶
type LoRaWANDLSettings struct { RX1DRoffset uint32 `protobuf:"varint,1,opt,name=RX1DRoffset,json=rX1DRoffset,proto3" json:"RX1DRoffset,omitempty"` RX2DataRate uint32 `protobuf:"varint,2,opt,name=RX2DataRate,json=rX2DataRate,proto3" json:"RX2DataRate,omitempty"` }
func (*LoRaWANDLSettings) Descriptor ¶
func (*LoRaWANDLSettings) Descriptor() ([]byte, []int)
func (*LoRaWANDLSettings) Marshal ¶
func (m *LoRaWANDLSettings) Marshal() (data []byte, err error)
func (*LoRaWANDLSettings) MarshalTo ¶
func (m *LoRaWANDLSettings) MarshalTo(data []byte) (int, error)
func (*LoRaWANDLSettings) ProtoMessage ¶
func (*LoRaWANDLSettings) ProtoMessage()
func (*LoRaWANDLSettings) Reset ¶
func (m *LoRaWANDLSettings) Reset()
func (*LoRaWANDLSettings) Size ¶
func (m *LoRaWANDLSettings) Size() (n int)
func (*LoRaWANDLSettings) String ¶
func (m *LoRaWANDLSettings) String() string
func (*LoRaWANDLSettings) Unmarshal ¶
func (m *LoRaWANDLSettings) Unmarshal(data []byte) error
type LoRaWANData ¶
type LoRaWANData struct { MHDR *LoRaWANMHDR `protobuf:"bytes,1,opt,name=MHDR,json=mHDR" json:"MHDR,omitempty"` MACPayload *LoRaWANMACPayload `protobuf:"bytes,2,opt,name=MACPayload,json=mACPayload" json:"MACPayload,omitempty"` MIC []byte `protobuf:"bytes,3,opt,name=MIC,json=mIC,proto3" json:"MIC,omitempty"` }
Uplink & Downlink Data (confirmed or unconfirmed)
func (*LoRaWANData) Descriptor ¶
func (*LoRaWANData) Descriptor() ([]byte, []int)
func (*LoRaWANData) GetMACPayload ¶
func (m *LoRaWANData) GetMACPayload() *LoRaWANMACPayload
func (*LoRaWANData) GetMHDR ¶
func (m *LoRaWANData) GetMHDR() *LoRaWANMHDR
func (*LoRaWANData) Marshal ¶
func (m *LoRaWANData) Marshal() (data []byte, err error)
func (*LoRaWANData) ProtoMessage ¶
func (*LoRaWANData) ProtoMessage()
func (*LoRaWANData) Reset ¶
func (m *LoRaWANData) Reset()
func (*LoRaWANData) Size ¶
func (m *LoRaWANData) Size() (n int)
func (*LoRaWANData) String ¶
func (m *LoRaWANData) String() string
func (*LoRaWANData) Unmarshal ¶
func (m *LoRaWANData) Unmarshal(data []byte) error
type LoRaWANFCtrl ¶
type LoRaWANFCtrl struct { ADR bool `protobuf:"varint,1,opt,name=ADR,json=aDR,proto3" json:"ADR,omitempty"` ADRAckReq bool `protobuf:"varint,2,opt,name=ADRAckReq,json=aDRAckReq,proto3" json:"ADRAckReq,omitempty"` Ack bool `protobuf:"varint,3,opt,name=Ack,json=ack,proto3" json:"Ack,omitempty"` FPending bool `protobuf:"varint,4,opt,name=FPending,json=fPending,proto3" json:"FPending,omitempty"` FOptsLen []byte `protobuf:"bytes,5,opt,name=FOptsLen,json=fOptsLen,proto3" json:"FOptsLen,omitempty"` }
func (*LoRaWANFCtrl) Descriptor ¶
func (*LoRaWANFCtrl) Descriptor() ([]byte, []int)
func (*LoRaWANFCtrl) Marshal ¶
func (m *LoRaWANFCtrl) Marshal() (data []byte, err error)
func (*LoRaWANFCtrl) ProtoMessage ¶
func (*LoRaWANFCtrl) ProtoMessage()
func (*LoRaWANFCtrl) Reset ¶
func (m *LoRaWANFCtrl) Reset()
func (*LoRaWANFCtrl) Size ¶
func (m *LoRaWANFCtrl) Size() (n int)
func (*LoRaWANFCtrl) String ¶
func (m *LoRaWANFCtrl) String() string
func (*LoRaWANFCtrl) Unmarshal ¶
func (m *LoRaWANFCtrl) Unmarshal(data []byte) error
type LoRaWANFHDR ¶
type LoRaWANFHDR struct { DevAddr []byte `protobuf:"bytes,1,opt,name=DevAddr,json=devAddr,proto3" json:"DevAddr,omitempty"` FCtrl *LoRaWANFCtrl `protobuf:"bytes,2,opt,name=FCtrl,json=fCtrl" json:"FCtrl,omitempty"` FCnt uint32 `protobuf:"varint,3,opt,name=FCnt,json=fCnt,proto3" json:"FCnt,omitempty"` FOpts [][]byte `protobuf:"bytes,4,rep,name=FOpts,json=fOpts" json:"FOpts,omitempty"` }
func (*LoRaWANFHDR) Descriptor ¶
func (*LoRaWANFHDR) Descriptor() ([]byte, []int)
func (*LoRaWANFHDR) GetFCtrl ¶
func (m *LoRaWANFHDR) GetFCtrl() *LoRaWANFCtrl
func (*LoRaWANFHDR) Marshal ¶
func (m *LoRaWANFHDR) Marshal() (data []byte, err error)
func (*LoRaWANFHDR) ProtoMessage ¶
func (*LoRaWANFHDR) ProtoMessage()
func (*LoRaWANFHDR) Reset ¶
func (m *LoRaWANFHDR) Reset()
func (*LoRaWANFHDR) Size ¶
func (m *LoRaWANFHDR) Size() (n int)
func (*LoRaWANFHDR) String ¶
func (m *LoRaWANFHDR) String() string
func (*LoRaWANFHDR) Unmarshal ¶
func (m *LoRaWANFHDR) Unmarshal(data []byte) error
type LoRaWANJoinAccept ¶
type LoRaWANJoinAccept struct {
Payload []byte `protobuf:"bytes,1,opt,name=Payload,json=payload,proto3" json:"Payload,omitempty"`
}
func (*LoRaWANJoinAccept) Descriptor ¶
func (*LoRaWANJoinAccept) Descriptor() ([]byte, []int)
func (*LoRaWANJoinAccept) Marshal ¶
func (m *LoRaWANJoinAccept) Marshal() (data []byte, err error)
func (*LoRaWANJoinAccept) MarshalTo ¶
func (m *LoRaWANJoinAccept) MarshalTo(data []byte) (int, error)
func (*LoRaWANJoinAccept) ProtoMessage ¶
func (*LoRaWANJoinAccept) ProtoMessage()
func (*LoRaWANJoinAccept) Reset ¶
func (m *LoRaWANJoinAccept) Reset()
func (*LoRaWANJoinAccept) Size ¶
func (m *LoRaWANJoinAccept) Size() (n int)
func (*LoRaWANJoinAccept) String ¶
func (m *LoRaWANJoinAccept) String() string
func (*LoRaWANJoinAccept) Unmarshal ¶
func (m *LoRaWANJoinAccept) Unmarshal(data []byte) error
type LoRaWANJoinRequest ¶
type LoRaWANJoinRequest struct { DevEUI []byte `protobuf:"bytes,1,opt,name=DevEUI,json=devEUI,proto3" json:"DevEUI,omitempty"` AppEUI []byte `protobuf:"bytes,2,opt,name=AppEUI,json=appEUI,proto3" json:"AppEUI,omitempty"` DevNonce []byte `protobuf:"bytes,3,opt,name=DevNonce,json=devNonce,proto3" json:"DevNonce,omitempty"` }
func (*LoRaWANJoinRequest) Descriptor ¶
func (*LoRaWANJoinRequest) Descriptor() ([]byte, []int)
func (*LoRaWANJoinRequest) Marshal ¶
func (m *LoRaWANJoinRequest) Marshal() (data []byte, err error)
func (*LoRaWANJoinRequest) MarshalTo ¶
func (m *LoRaWANJoinRequest) MarshalTo(data []byte) (int, error)
func (*LoRaWANJoinRequest) ProtoMessage ¶
func (*LoRaWANJoinRequest) ProtoMessage()
func (*LoRaWANJoinRequest) Reset ¶
func (m *LoRaWANJoinRequest) Reset()
func (*LoRaWANJoinRequest) Size ¶
func (m *LoRaWANJoinRequest) Size() (n int)
func (*LoRaWANJoinRequest) String ¶
func (m *LoRaWANJoinRequest) String() string
func (*LoRaWANJoinRequest) Unmarshal ¶
func (m *LoRaWANJoinRequest) Unmarshal(data []byte) error
type LoRaWANMACPayload ¶
type LoRaWANMACPayload struct { FHDR *LoRaWANFHDR `protobuf:"bytes,1,opt,name=FHDR,json=fHDR" json:"FHDR,omitempty"` FPort uint32 `protobuf:"varint,2,opt,name=FPort,json=fPort,proto3" json:"FPort,omitempty"` FRMPayload []byte `protobuf:"bytes,3,opt,name=FRMPayload,json=fRMPayload,proto3" json:"FRMPayload,omitempty"` }
func (*LoRaWANMACPayload) Descriptor ¶
func (*LoRaWANMACPayload) Descriptor() ([]byte, []int)
func (*LoRaWANMACPayload) GetFHDR ¶
func (m *LoRaWANMACPayload) GetFHDR() *LoRaWANFHDR
func (*LoRaWANMACPayload) Marshal ¶
func (m *LoRaWANMACPayload) Marshal() (data []byte, err error)
func (*LoRaWANMACPayload) MarshalTo ¶
func (m *LoRaWANMACPayload) MarshalTo(data []byte) (int, error)
func (*LoRaWANMACPayload) ProtoMessage ¶
func (*LoRaWANMACPayload) ProtoMessage()
func (*LoRaWANMACPayload) Reset ¶
func (m *LoRaWANMACPayload) Reset()
func (*LoRaWANMACPayload) Size ¶
func (m *LoRaWANMACPayload) Size() (n int)
func (*LoRaWANMACPayload) String ¶
func (m *LoRaWANMACPayload) String() string
func (*LoRaWANMACPayload) Unmarshal ¶
func (m *LoRaWANMACPayload) Unmarshal(data []byte) error
type LoRaWANMHDR ¶
type LoRaWANMHDR struct { MType uint32 `protobuf:"varint,1,opt,name=MType,json=mType,proto3" json:"MType,omitempty"` Major uint32 `protobuf:"varint,2,opt,name=Major,json=major,proto3" json:"Major,omitempty"` }
func (*LoRaWANMHDR) Descriptor ¶
func (*LoRaWANMHDR) Descriptor() ([]byte, []int)
func (*LoRaWANMHDR) Marshal ¶
func (m *LoRaWANMHDR) Marshal() (data []byte, err error)
func (*LoRaWANMHDR) ProtoMessage ¶
func (*LoRaWANMHDR) ProtoMessage()
func (*LoRaWANMHDR) Reset ¶
func (m *LoRaWANMHDR) Reset()
func (*LoRaWANMHDR) Size ¶
func (m *LoRaWANMHDR) Size() (n int)
func (*LoRaWANMHDR) String ¶
func (m *LoRaWANMHDR) String() string
func (*LoRaWANMHDR) Unmarshal ¶
func (m *LoRaWANMHDR) Unmarshal(data []byte) error
type Metadata ¶
type Metadata struct { DutyRX1 uint32 `protobuf:"varint,1,opt,name=DutyRX1,json=dutyRX1,proto3" json:"DutyRX1,omitempty"` DutyRX2 uint32 `protobuf:"varint,2,opt,name=DutyRX2,json=dutyRX2,proto3" json:"DutyRX2,omitempty"` Frequency float32 `protobuf:"fixed32,3,opt,name=Frequency,json=frequency,proto3" json:"Frequency,omitempty"` DataRate string `protobuf:"bytes,4,opt,name=DataRate,json=dataRate,proto3" json:"DataRate,omitempty"` CodingRate string `protobuf:"bytes,5,opt,name=CodingRate,json=codingRate,proto3" json:"CodingRate,omitempty"` Timestamp uint32 `protobuf:"varint,6,opt,name=Timestamp,json=timestamp,proto3" json:"Timestamp,omitempty"` Rssi int32 `protobuf:"varint,7,opt,name=Rssi,json=rssi,proto3" json:"Rssi,omitempty"` Lsnr float32 `protobuf:"fixed32,8,opt,name=Lsnr,json=lsnr,proto3" json:"Lsnr,omitempty"` PayloadSize uint32 `protobuf:"varint,9,opt,name=PayloadSize,json=payloadSize,proto3" json:"PayloadSize,omitempty"` Time string `protobuf:"bytes,10,opt,name=Time,json=time,proto3" json:"Time,omitempty"` RFChain uint32 `protobuf:"varint,11,opt,name=RFChain,json=rFChain,proto3" json:"RFChain,omitempty"` CRCStatus int32 `protobuf:"varint,12,opt,name=CRCStatus,json=cRCStatus,proto3" json:"CRCStatus,omitempty"` Modulation string `protobuf:"bytes,13,opt,name=Modulation,json=modulation,proto3" json:"Modulation,omitempty"` InvPolarity bool `protobuf:"varint,14,opt,name=InvPolarity,json=invPolarity,proto3" json:"InvPolarity,omitempty"` Power uint32 `protobuf:"varint,15,opt,name=Power,json=power,proto3" json:"Power,omitempty"` Channel uint32 `protobuf:"varint,16,opt,name=Channel,json=channel,proto3" json:"Channel,omitempty"` GatewayEUI string `protobuf:"bytes,20,opt,name=GatewayEUI,json=gatewayEUI,proto3" json:"GatewayEUI,omitempty"` Altitude int32 `protobuf:"varint,21,opt,name=Altitude,json=altitude,proto3" json:"Altitude,omitempty"` Longitude float32 `protobuf:"fixed32,22,opt,name=Longitude,json=longitude,proto3" json:"Longitude,omitempty"` Latitude float32 `protobuf:"fixed32,23,opt,name=Latitude,json=latitude,proto3" json:"Latitude,omitempty"` ServerTime string `protobuf:"bytes,31,opt,name=ServerTime,json=serverTime,proto3" json:"ServerTime,omitempty"` }
func (*Metadata) Descriptor ¶
func (*Metadata) ProtoMessage ¶
func (*Metadata) ProtoMessage()
type OTAAAppReq ¶
type OTAAAppReq struct {
Metadata []AppMetadata `json:"metadata"`
}
OTAAAppReq are used to notify application of an accepted OTAA
type RemoveApplicationCollectorReq ¶
type RemoveApplicationCollectorReq struct {
AppEUI []byte `protobuf:"bytes,1,opt,name=AppEUI,json=appEUI,proto3" json:"AppEUI,omitempty"`
}
func (*RemoveApplicationCollectorReq) Descriptor ¶
func (*RemoveApplicationCollectorReq) Descriptor() ([]byte, []int)
func (*RemoveApplicationCollectorReq) Marshal ¶
func (m *RemoveApplicationCollectorReq) Marshal() (data []byte, err error)
func (*RemoveApplicationCollectorReq) MarshalTo ¶
func (m *RemoveApplicationCollectorReq) MarshalTo(data []byte) (int, error)
func (*RemoveApplicationCollectorReq) ProtoMessage ¶
func (*RemoveApplicationCollectorReq) ProtoMessage()
func (*RemoveApplicationCollectorReq) Reset ¶
func (m *RemoveApplicationCollectorReq) Reset()
func (*RemoveApplicationCollectorReq) Size ¶
func (m *RemoveApplicationCollectorReq) Size() (n int)
func (*RemoveApplicationCollectorReq) String ¶
func (m *RemoveApplicationCollectorReq) String() string
func (*RemoveApplicationCollectorReq) Unmarshal ¶
func (m *RemoveApplicationCollectorReq) Unmarshal(data []byte) error
type RemoveApplicationCollectorRes ¶
type RemoveApplicationCollectorRes struct { }
func (*RemoveApplicationCollectorRes) Descriptor ¶
func (*RemoveApplicationCollectorRes) Descriptor() ([]byte, []int)
func (*RemoveApplicationCollectorRes) Marshal ¶
func (m *RemoveApplicationCollectorRes) Marshal() (data []byte, err error)
func (*RemoveApplicationCollectorRes) MarshalTo ¶
func (m *RemoveApplicationCollectorRes) MarshalTo(data []byte) (int, error)
func (*RemoveApplicationCollectorRes) ProtoMessage ¶
func (*RemoveApplicationCollectorRes) ProtoMessage()
func (*RemoveApplicationCollectorRes) Reset ¶
func (m *RemoveApplicationCollectorRes) Reset()
func (*RemoveApplicationCollectorRes) Size ¶
func (m *RemoveApplicationCollectorRes) Size() (n int)
func (*RemoveApplicationCollectorRes) String ¶
func (m *RemoveApplicationCollectorRes) String() string
func (*RemoveApplicationCollectorRes) Unmarshal ¶
func (m *RemoveApplicationCollectorRes) Unmarshal(data []byte) error
type RouterClient ¶
type RouterClient interface { HandleData(ctx context.Context, in *DataRouterReq, opts ...grpc.CallOption) (*DataRouterRes, error) HandleStats(ctx context.Context, in *StatsReq, opts ...grpc.CallOption) (*StatsRes, error) HandleJoin(ctx context.Context, in *JoinRouterReq, opts ...grpc.CallOption) (*JoinRouterRes, error) }
func NewRouterClient ¶
func NewRouterClient(cc *grpc.ClientConn) RouterClient
type RouterServer ¶
type RouterServer interface { HandleData(context.Context, *DataRouterReq) (*DataRouterRes, error) HandleStats(context.Context, *StatsReq) (*StatsRes, error) HandleJoin(context.Context, *JoinRouterReq) (*JoinRouterRes, error) }
type SetDefaultDeviceReq ¶
type SetDefaultDeviceReq struct { Token string `protobuf:"bytes,1,opt,name=Token,json=token,proto3" json:"Token,omitempty"` AppEUI []byte `protobuf:"bytes,2,opt,name=AppEUI,json=appEUI,proto3" json:"AppEUI,omitempty"` AppKey []byte `protobuf:"bytes,3,opt,name=AppKey,json=appKey,proto3" json:"AppKey,omitempty"` }
func (*SetDefaultDeviceReq) Descriptor ¶
func (*SetDefaultDeviceReq) Descriptor() ([]byte, []int)
func (*SetDefaultDeviceReq) Marshal ¶
func (m *SetDefaultDeviceReq) Marshal() (data []byte, err error)
func (*SetDefaultDeviceReq) MarshalTo ¶
func (m *SetDefaultDeviceReq) MarshalTo(data []byte) (int, error)
func (*SetDefaultDeviceReq) ProtoMessage ¶
func (*SetDefaultDeviceReq) ProtoMessage()
func (*SetDefaultDeviceReq) Reset ¶
func (m *SetDefaultDeviceReq) Reset()
func (*SetDefaultDeviceReq) Size ¶
func (m *SetDefaultDeviceReq) Size() (n int)
func (*SetDefaultDeviceReq) String ¶
func (m *SetDefaultDeviceReq) String() string
func (*SetDefaultDeviceReq) Unmarshal ¶
func (m *SetDefaultDeviceReq) Unmarshal(data []byte) error
type SetDefaultDeviceRes ¶
type SetDefaultDeviceRes struct { }
func (*SetDefaultDeviceRes) Descriptor ¶
func (*SetDefaultDeviceRes) Descriptor() ([]byte, []int)
func (*SetDefaultDeviceRes) Marshal ¶
func (m *SetDefaultDeviceRes) Marshal() (data []byte, err error)
func (*SetDefaultDeviceRes) MarshalTo ¶
func (m *SetDefaultDeviceRes) MarshalTo(data []byte) (int, error)
func (*SetDefaultDeviceRes) ProtoMessage ¶
func (*SetDefaultDeviceRes) ProtoMessage()
func (*SetDefaultDeviceRes) Reset ¶
func (m *SetDefaultDeviceRes) Reset()
func (*SetDefaultDeviceRes) Size ¶
func (m *SetDefaultDeviceRes) Size() (n int)
func (*SetDefaultDeviceRes) String ¶
func (m *SetDefaultDeviceRes) String() string
func (*SetDefaultDeviceRes) Unmarshal ¶
func (m *SetDefaultDeviceRes) Unmarshal(data []byte) error
type SetPayloadFunctionsReq ¶
type SetPayloadFunctionsReq struct { Token string `protobuf:"bytes,1,opt,name=Token,json=token,proto3" json:"Token,omitempty"` AppEUI []byte `protobuf:"bytes,2,opt,name=AppEUI,json=appEUI,proto3" json:"AppEUI,omitempty"` Decoder string `protobuf:"bytes,11,opt,name=Decoder,json=decoder,proto3" json:"Decoder,omitempty"` Converter string `protobuf:"bytes,12,opt,name=Converter,json=converter,proto3" json:"Converter,omitempty"` Validator string `protobuf:"bytes,13,opt,name=Validator,json=validator,proto3" json:"Validator,omitempty"` }
func (*SetPayloadFunctionsReq) Descriptor ¶
func (*SetPayloadFunctionsReq) Descriptor() ([]byte, []int)
func (*SetPayloadFunctionsReq) Marshal ¶
func (m *SetPayloadFunctionsReq) Marshal() (data []byte, err error)
func (*SetPayloadFunctionsReq) MarshalTo ¶
func (m *SetPayloadFunctionsReq) MarshalTo(data []byte) (int, error)
func (*SetPayloadFunctionsReq) ProtoMessage ¶
func (*SetPayloadFunctionsReq) ProtoMessage()
func (*SetPayloadFunctionsReq) Reset ¶
func (m *SetPayloadFunctionsReq) Reset()
func (*SetPayloadFunctionsReq) Size ¶
func (m *SetPayloadFunctionsReq) Size() (n int)
func (*SetPayloadFunctionsReq) String ¶
func (m *SetPayloadFunctionsReq) String() string
func (*SetPayloadFunctionsReq) Unmarshal ¶
func (m *SetPayloadFunctionsReq) Unmarshal(data []byte) error
type SetPayloadFunctionsRes ¶
type SetPayloadFunctionsRes struct { }
func (*SetPayloadFunctionsRes) Descriptor ¶
func (*SetPayloadFunctionsRes) Descriptor() ([]byte, []int)
func (*SetPayloadFunctionsRes) Marshal ¶
func (m *SetPayloadFunctionsRes) Marshal() (data []byte, err error)
func (*SetPayloadFunctionsRes) MarshalTo ¶
func (m *SetPayloadFunctionsRes) MarshalTo(data []byte) (int, error)
func (*SetPayloadFunctionsRes) ProtoMessage ¶
func (*SetPayloadFunctionsRes) ProtoMessage()
func (*SetPayloadFunctionsRes) Reset ¶
func (m *SetPayloadFunctionsRes) Reset()
func (*SetPayloadFunctionsRes) Size ¶
func (m *SetPayloadFunctionsRes) Size() (n int)
func (*SetPayloadFunctionsRes) String ¶
func (m *SetPayloadFunctionsRes) String() string
func (*SetPayloadFunctionsRes) Unmarshal ¶
func (m *SetPayloadFunctionsRes) Unmarshal(data []byte) error
type StatsMetadata ¶
type StatsMetadata struct { Altitude int32 `protobuf:"varint,1,opt,name=Altitude,json=altitude,proto3" json:"Altitude,omitempty"` Longitude float32 `protobuf:"fixed32,2,opt,name=Longitude,json=longitude,proto3" json:"Longitude,omitempty"` Latitude float32 `protobuf:"fixed32,3,opt,name=Latitude,json=latitude,proto3" json:"Latitude,omitempty"` }
func (*StatsMetadata) Descriptor ¶
func (*StatsMetadata) Descriptor() ([]byte, []int)
func (*StatsMetadata) Marshal ¶
func (m *StatsMetadata) Marshal() (data []byte, err error)
func (StatsMetadata) MarshalBinary ¶
func (m StatsMetadata) MarshalBinary() ([]byte, error)
MarshalBinary implements the encoding.BinaryMarshaler interface
func (*StatsMetadata) ProtoMessage ¶
func (*StatsMetadata) ProtoMessage()
func (*StatsMetadata) Reset ¶
func (m *StatsMetadata) Reset()
func (*StatsMetadata) Size ¶
func (m *StatsMetadata) Size() (n int)
func (*StatsMetadata) String ¶
func (m *StatsMetadata) String() string
func (*StatsMetadata) Unmarshal ¶
func (m *StatsMetadata) Unmarshal(data []byte) error
func (*StatsMetadata) UnmarshalBinary ¶
func (m *StatsMetadata) UnmarshalBinary(data []byte) error
UnmarshalBinary implements the encoding.BinaryUnmarshaler interface
type StatsReq ¶
type StatsReq struct { GatewayID []byte `protobuf:"bytes,1,opt,name=GatewayID,json=gatewayID,proto3" json:"GatewayID,omitempty"` Metadata *StatsMetadata `protobuf:"bytes,2,opt,name=Metadata,json=metadata" json:"Metadata,omitempty"` }
func (*StatsReq) Descriptor ¶
func (*StatsReq) GetMetadata ¶
func (m *StatsReq) GetMetadata() *StatsMetadata
func (*StatsReq) ProtoMessage ¶
func (*StatsReq) ProtoMessage()
type StatsRes ¶
type StatsRes struct { }
func (*StatsRes) Descriptor ¶
func (*StatsRes) ProtoMessage ¶
func (*StatsRes) ProtoMessage()
type TestPayloadFunctionsReq ¶
type TestPayloadFunctionsReq struct { Token string `protobuf:"bytes,1,opt,name=Token,json=token,proto3" json:"Token,omitempty"` AppEUI []byte `protobuf:"bytes,2,opt,name=AppEUI,json=appEUI,proto3" json:"AppEUI,omitempty"` Payload []byte `protobuf:"bytes,11,opt,name=Payload,json=payload,proto3" json:"Payload,omitempty"` Decoder string `protobuf:"bytes,21,opt,name=Decoder,json=decoder,proto3" json:"Decoder,omitempty"` Converter string `protobuf:"bytes,22,opt,name=Converter,json=converter,proto3" json:"Converter,omitempty"` Validator string `protobuf:"bytes,23,opt,name=Validator,json=validator,proto3" json:"Validator,omitempty"` }
func (*TestPayloadFunctionsReq) Descriptor ¶
func (*TestPayloadFunctionsReq) Descriptor() ([]byte, []int)
func (*TestPayloadFunctionsReq) Marshal ¶
func (m *TestPayloadFunctionsReq) Marshal() (data []byte, err error)
func (*TestPayloadFunctionsReq) MarshalTo ¶
func (m *TestPayloadFunctionsReq) MarshalTo(data []byte) (int, error)
func (*TestPayloadFunctionsReq) ProtoMessage ¶
func (*TestPayloadFunctionsReq) ProtoMessage()
func (*TestPayloadFunctionsReq) Reset ¶
func (m *TestPayloadFunctionsReq) Reset()
func (*TestPayloadFunctionsReq) Size ¶
func (m *TestPayloadFunctionsReq) Size() (n int)
func (*TestPayloadFunctionsReq) String ¶
func (m *TestPayloadFunctionsReq) String() string
func (*TestPayloadFunctionsReq) Unmarshal ¶
func (m *TestPayloadFunctionsReq) Unmarshal(data []byte) error
type TestPayloadFunctionsRes ¶
type TestPayloadFunctionsRes struct { Fields string `protobuf:"bytes,1,opt,name=Fields,json=fields,proto3" json:"Fields,omitempty"` Valid bool `protobuf:"varint,2,opt,name=Valid,json=valid,proto3" json:"Valid,omitempty"` }
func (*TestPayloadFunctionsRes) Descriptor ¶
func (*TestPayloadFunctionsRes) Descriptor() ([]byte, []int)
func (*TestPayloadFunctionsRes) Marshal ¶
func (m *TestPayloadFunctionsRes) Marshal() (data []byte, err error)
func (*TestPayloadFunctionsRes) MarshalTo ¶
func (m *TestPayloadFunctionsRes) MarshalTo(data []byte) (int, error)
func (*TestPayloadFunctionsRes) ProtoMessage ¶
func (*TestPayloadFunctionsRes) ProtoMessage()
func (*TestPayloadFunctionsRes) Reset ¶
func (m *TestPayloadFunctionsRes) Reset()
func (*TestPayloadFunctionsRes) Size ¶
func (m *TestPayloadFunctionsRes) Size() (n int)
func (*TestPayloadFunctionsRes) String ¶
func (m *TestPayloadFunctionsRes) String() string
func (*TestPayloadFunctionsRes) Unmarshal ¶
func (m *TestPayloadFunctionsRes) Unmarshal(data []byte) error
type UpsertABPBrokerReq ¶
type UpsertABPBrokerReq struct { Token string `protobuf:"bytes,1,opt,name=Token,json=token,proto3" json:"Token,omitempty"` AppEUI []byte `protobuf:"bytes,2,opt,name=AppEUI,json=appEUI,proto3" json:"AppEUI,omitempty"` NetAddress string `protobuf:"bytes,3,opt,name=NetAddress,json=netAddress,proto3" json:"NetAddress,omitempty"` DevAddr []byte `protobuf:"bytes,4,opt,name=DevAddr,json=devAddr,proto3" json:"DevAddr,omitempty"` NwkSKey []byte `protobuf:"bytes,5,opt,name=NwkSKey,json=nwkSKey,proto3" json:"NwkSKey,omitempty"` Flags uint32 `protobuf:"varint,6,opt,name=Flags,json=flags,proto3" json:"Flags,omitempty"` }
func (*UpsertABPBrokerReq) Descriptor ¶
func (*UpsertABPBrokerReq) Descriptor() ([]byte, []int)
func (*UpsertABPBrokerReq) Marshal ¶
func (m *UpsertABPBrokerReq) Marshal() (data []byte, err error)
func (*UpsertABPBrokerReq) MarshalTo ¶
func (m *UpsertABPBrokerReq) MarshalTo(data []byte) (int, error)
func (*UpsertABPBrokerReq) ProtoMessage ¶
func (*UpsertABPBrokerReq) ProtoMessage()
func (*UpsertABPBrokerReq) Reset ¶
func (m *UpsertABPBrokerReq) Reset()
func (*UpsertABPBrokerReq) Size ¶
func (m *UpsertABPBrokerReq) Size() (n int)
func (*UpsertABPBrokerReq) String ¶
func (m *UpsertABPBrokerReq) String() string
func (*UpsertABPBrokerReq) Unmarshal ¶
func (m *UpsertABPBrokerReq) Unmarshal(data []byte) error
type UpsertABPBrokerRes ¶
type UpsertABPBrokerRes struct { }
func (*UpsertABPBrokerRes) Descriptor ¶
func (*UpsertABPBrokerRes) Descriptor() ([]byte, []int)
func (*UpsertABPBrokerRes) Marshal ¶
func (m *UpsertABPBrokerRes) Marshal() (data []byte, err error)
func (*UpsertABPBrokerRes) MarshalTo ¶
func (m *UpsertABPBrokerRes) MarshalTo(data []byte) (int, error)
func (*UpsertABPBrokerRes) ProtoMessage ¶
func (*UpsertABPBrokerRes) ProtoMessage()
func (*UpsertABPBrokerRes) Reset ¶
func (m *UpsertABPBrokerRes) Reset()
func (*UpsertABPBrokerRes) Size ¶
func (m *UpsertABPBrokerRes) Size() (n int)
func (*UpsertABPBrokerRes) String ¶
func (m *UpsertABPBrokerRes) String() string
func (*UpsertABPBrokerRes) Unmarshal ¶
func (m *UpsertABPBrokerRes) Unmarshal(data []byte) error
type UpsertABPHandlerReq ¶
type UpsertABPHandlerReq struct { Token string `protobuf:"bytes,1,opt,name=Token,json=token,proto3" json:"Token,omitempty"` AppEUI []byte `protobuf:"bytes,2,opt,name=AppEUI,json=appEUI,proto3" json:"AppEUI,omitempty"` DevAddr []byte `protobuf:"bytes,3,opt,name=DevAddr,json=devAddr,proto3" json:"DevAddr,omitempty"` NwkSKey []byte `protobuf:"bytes,4,opt,name=NwkSKey,json=nwkSKey,proto3" json:"NwkSKey,omitempty"` AppSKey []byte `protobuf:"bytes,5,opt,name=AppSKey,json=appSKey,proto3" json:"AppSKey,omitempty"` Flags uint32 `protobuf:"varint,6,opt,name=Flags,json=flags,proto3" json:"Flags,omitempty"` }
func (*UpsertABPHandlerReq) Descriptor ¶
func (*UpsertABPHandlerReq) Descriptor() ([]byte, []int)
func (*UpsertABPHandlerReq) Marshal ¶
func (m *UpsertABPHandlerReq) Marshal() (data []byte, err error)
func (*UpsertABPHandlerReq) MarshalTo ¶
func (m *UpsertABPHandlerReq) MarshalTo(data []byte) (int, error)
func (*UpsertABPHandlerReq) ProtoMessage ¶
func (*UpsertABPHandlerReq) ProtoMessage()
func (*UpsertABPHandlerReq) Reset ¶
func (m *UpsertABPHandlerReq) Reset()
func (*UpsertABPHandlerReq) Size ¶
func (m *UpsertABPHandlerReq) Size() (n int)
func (*UpsertABPHandlerReq) String ¶
func (m *UpsertABPHandlerReq) String() string
func (*UpsertABPHandlerReq) Unmarshal ¶
func (m *UpsertABPHandlerReq) Unmarshal(data []byte) error
type UpsertABPHandlerRes ¶
type UpsertABPHandlerRes struct { }
func (*UpsertABPHandlerRes) Descriptor ¶
func (*UpsertABPHandlerRes) Descriptor() ([]byte, []int)
func (*UpsertABPHandlerRes) Marshal ¶
func (m *UpsertABPHandlerRes) Marshal() (data []byte, err error)
func (*UpsertABPHandlerRes) MarshalTo ¶
func (m *UpsertABPHandlerRes) MarshalTo(data []byte) (int, error)
func (*UpsertABPHandlerRes) ProtoMessage ¶
func (*UpsertABPHandlerRes) ProtoMessage()
func (*UpsertABPHandlerRes) Reset ¶
func (m *UpsertABPHandlerRes) Reset()
func (*UpsertABPHandlerRes) Size ¶
func (m *UpsertABPHandlerRes) Size() (n int)
func (*UpsertABPHandlerRes) String ¶
func (m *UpsertABPHandlerRes) String() string
func (*UpsertABPHandlerRes) Unmarshal ¶
func (m *UpsertABPHandlerRes) Unmarshal(data []byte) error
type UpsertOTAAHandlerReq ¶
type UpsertOTAAHandlerReq struct { Token string `protobuf:"bytes,1,opt,name=Token,json=token,proto3" json:"Token,omitempty"` AppEUI []byte `protobuf:"bytes,2,opt,name=AppEUI,json=appEUI,proto3" json:"AppEUI,omitempty"` DevEUI []byte `protobuf:"bytes,3,opt,name=DevEUI,json=devEUI,proto3" json:"DevEUI,omitempty"` AppKey []byte `protobuf:"bytes,4,opt,name=AppKey,json=appKey,proto3" json:"AppKey,omitempty"` }
func (*UpsertOTAAHandlerReq) Descriptor ¶
func (*UpsertOTAAHandlerReq) Descriptor() ([]byte, []int)
func (*UpsertOTAAHandlerReq) Marshal ¶
func (m *UpsertOTAAHandlerReq) Marshal() (data []byte, err error)
func (*UpsertOTAAHandlerReq) MarshalTo ¶
func (m *UpsertOTAAHandlerReq) MarshalTo(data []byte) (int, error)
func (*UpsertOTAAHandlerReq) ProtoMessage ¶
func (*UpsertOTAAHandlerReq) ProtoMessage()
func (*UpsertOTAAHandlerReq) Reset ¶
func (m *UpsertOTAAHandlerReq) Reset()
func (*UpsertOTAAHandlerReq) Size ¶
func (m *UpsertOTAAHandlerReq) Size() (n int)
func (*UpsertOTAAHandlerReq) String ¶
func (m *UpsertOTAAHandlerReq) String() string
func (*UpsertOTAAHandlerReq) Unmarshal ¶
func (m *UpsertOTAAHandlerReq) Unmarshal(data []byte) error
type UpsertOTAAHandlerRes ¶
type UpsertOTAAHandlerRes struct { }
func (*UpsertOTAAHandlerRes) Descriptor ¶
func (*UpsertOTAAHandlerRes) Descriptor() ([]byte, []int)
func (*UpsertOTAAHandlerRes) Marshal ¶
func (m *UpsertOTAAHandlerRes) Marshal() (data []byte, err error)
func (*UpsertOTAAHandlerRes) MarshalTo ¶
func (m *UpsertOTAAHandlerRes) MarshalTo(data []byte) (int, error)
func (*UpsertOTAAHandlerRes) ProtoMessage ¶
func (*UpsertOTAAHandlerRes) ProtoMessage()
func (*UpsertOTAAHandlerRes) Reset ¶
func (m *UpsertOTAAHandlerRes) Reset()
func (*UpsertOTAAHandlerRes) Size ¶
func (m *UpsertOTAAHandlerRes) Size() (n int)
func (*UpsertOTAAHandlerRes) String ¶
func (m *UpsertOTAAHandlerRes) String() string
func (*UpsertOTAAHandlerRes) Unmarshal ¶
func (m *UpsertOTAAHandlerRes) Unmarshal(data []byte) error
type ValidateOTAABrokerReq ¶
type ValidateOTAABrokerReq struct { Token string `protobuf:"bytes,1,opt,name=Token,json=token,proto3" json:"Token,omitempty"` AppEUI []byte `protobuf:"bytes,2,opt,name=AppEUI,json=appEUI,proto3" json:"AppEUI,omitempty"` NetAddress string `protobuf:"bytes,3,opt,name=NetAddress,json=netAddress,proto3" json:"NetAddress,omitempty"` }
func (*ValidateOTAABrokerReq) Descriptor ¶
func (*ValidateOTAABrokerReq) Descriptor() ([]byte, []int)
func (*ValidateOTAABrokerReq) Marshal ¶
func (m *ValidateOTAABrokerReq) Marshal() (data []byte, err error)
func (*ValidateOTAABrokerReq) MarshalTo ¶
func (m *ValidateOTAABrokerReq) MarshalTo(data []byte) (int, error)
func (*ValidateOTAABrokerReq) ProtoMessage ¶
func (*ValidateOTAABrokerReq) ProtoMessage()
func (*ValidateOTAABrokerReq) Reset ¶
func (m *ValidateOTAABrokerReq) Reset()
func (*ValidateOTAABrokerReq) Size ¶
func (m *ValidateOTAABrokerReq) Size() (n int)
func (*ValidateOTAABrokerReq) String ¶
func (m *ValidateOTAABrokerReq) String() string
func (*ValidateOTAABrokerReq) Unmarshal ¶
func (m *ValidateOTAABrokerReq) Unmarshal(data []byte) error
type ValidateOTAABrokerRes ¶
type ValidateOTAABrokerRes struct { }
func (*ValidateOTAABrokerRes) Descriptor ¶
func (*ValidateOTAABrokerRes) Descriptor() ([]byte, []int)
func (*ValidateOTAABrokerRes) Marshal ¶
func (m *ValidateOTAABrokerRes) Marshal() (data []byte, err error)
func (*ValidateOTAABrokerRes) MarshalTo ¶
func (m *ValidateOTAABrokerRes) MarshalTo(data []byte) (int, error)
func (*ValidateOTAABrokerRes) ProtoMessage ¶
func (*ValidateOTAABrokerRes) ProtoMessage()
func (*ValidateOTAABrokerRes) Reset ¶
func (m *ValidateOTAABrokerRes) Reset()
func (*ValidateOTAABrokerRes) Size ¶
func (m *ValidateOTAABrokerRes) Size() (n int)
func (*ValidateOTAABrokerRes) String ¶
func (m *ValidateOTAABrokerRes) String() string
func (*ValidateOTAABrokerRes) Unmarshal ¶
func (m *ValidateOTAABrokerRes) Unmarshal(data []byte) error
type ValidateTokenBrokerReq ¶
type ValidateTokenBrokerReq struct { Token string `protobuf:"bytes,1,opt,name=Token,json=token,proto3" json:"Token,omitempty"` AppEUI []byte `protobuf:"bytes,2,opt,name=AppEUI,json=appEUI,proto3" json:"AppEUI,omitempty"` }
func (*ValidateTokenBrokerReq) Descriptor ¶
func (*ValidateTokenBrokerReq) Descriptor() ([]byte, []int)
func (*ValidateTokenBrokerReq) Marshal ¶
func (m *ValidateTokenBrokerReq) Marshal() (data []byte, err error)
func (*ValidateTokenBrokerReq) MarshalTo ¶
func (m *ValidateTokenBrokerReq) MarshalTo(data []byte) (int, error)
func (*ValidateTokenBrokerReq) ProtoMessage ¶
func (*ValidateTokenBrokerReq) ProtoMessage()
func (*ValidateTokenBrokerReq) Reset ¶
func (m *ValidateTokenBrokerReq) Reset()
func (*ValidateTokenBrokerReq) Size ¶
func (m *ValidateTokenBrokerReq) Size() (n int)
func (*ValidateTokenBrokerReq) String ¶
func (m *ValidateTokenBrokerReq) String() string
func (*ValidateTokenBrokerReq) Unmarshal ¶
func (m *ValidateTokenBrokerReq) Unmarshal(data []byte) error
type ValidateTokenBrokerRes ¶
type ValidateTokenBrokerRes struct { }
func (*ValidateTokenBrokerRes) Descriptor ¶
func (*ValidateTokenBrokerRes) Descriptor() ([]byte, []int)
func (*ValidateTokenBrokerRes) Marshal ¶
func (m *ValidateTokenBrokerRes) Marshal() (data []byte, err error)
func (*ValidateTokenBrokerRes) MarshalTo ¶
func (m *ValidateTokenBrokerRes) MarshalTo(data []byte) (int, error)
func (*ValidateTokenBrokerRes) ProtoMessage ¶
func (*ValidateTokenBrokerRes) ProtoMessage()
func (*ValidateTokenBrokerRes) Reset ¶
func (m *ValidateTokenBrokerRes) Reset()
func (*ValidateTokenBrokerRes) Size ¶
func (m *ValidateTokenBrokerRes) Size() (n int)
func (*ValidateTokenBrokerRes) String ¶
func (m *ValidateTokenBrokerRes) String() string
func (*ValidateTokenBrokerRes) Unmarshal ¶
func (m *ValidateTokenBrokerRes) Unmarshal(data []byte) error
Source Files ¶
Directories ¶
Path | Synopsis |
---|---|
adapters
|
|
http
Package http provides adapter implementations which run on top of http.
|
Package http provides adapter implementations which run on top of http. |
components
|
|
Package mocks offers dedicated mocking interface / structures for testing
|
Package mocks offers dedicated mocking interface / structures for testing |