core

package
v0.0.0-...-9a529fd Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 26, 2017 License: MIT Imports: 10 Imported by: 18

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
DeleteDeviceBrokerReq
DeleteDeviceBrokerRes
BrokerDevice
ValidateTokenBrokerReq
ValidateTokenBrokerRes
GetApplicationsCollectorReq
GetApplicationsCollectorRes
CollectorApplication
AddApplicationCollectorReq
AddApplicationCollectorRes
RemoveApplicationCollectorReq
RemoveApplicationCollectorRes
Metadata
StatsMetadata
DataUpHandlerReq
DataUpHandlerRes
DataDownHandlerReq
DataDownHandlerRes
JoinHandlerReq
JoinHandlerRes
UpsertOTAAHandlerReq
UpsertOTAAHandlerRes
DeleteOTAAHandlerReq
DeleteOTAAHandlerRes
UpsertABPHandlerReq
UpsertABPHandlerRes
DeleteABPHandlerReq
DeleteABPHandlerRes
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

View Source 
const (
	RelaxFcntCheck uint32 = 1 << iota
)

Variables

View Source 
var (
	ErrInvalidLengthApplication = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowApplication   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthBroker = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowBroker   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthBrokerManager = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowBrokerManager   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthCollector = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCollector   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthCore = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCore   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthHandler = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowHandler   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthHandlerManager = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowHandlerManager   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthLorawan = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowLorawan   = fmt.Errorf("proto: integer overflow")
)
View Source 
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 RegisterAppServer(s *grpc.Server, srv AppServer)

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,proto3" json:"AppEUI,omitempty"`
	AppAccessKey string `protobuf:"bytes,2,opt,name=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,proto3" json:"DevEUI,omitempty"`
	DevAddr []byte `protobuf:"bytes,2,opt,name=DevAddr,proto3" json:"DevAddr,omitempty"`
	NwkSKey []byte `protobuf:"bytes,3,opt,name=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) MarshalTo 

func (m *BrokerDevice) MarshalTo(data []byte) (int, 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)
	DeleteDevice(ctx context.Context, in *DeleteDeviceBrokerReq, opts ...grpc.CallOption) (*DeleteDeviceBrokerRes, 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)
	DeleteDevice(context.Context, *DeleteDeviceBrokerReq) (*DeleteDeviceBrokerRes, 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,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,proto3" json:"AppEUI,omitempty"`
	DevEUI   []byte      `protobuf:"bytes,2,opt,name=DevEUI,proto3" json:"DevEUI,omitempty"`
	FPort    uint32      `protobuf:"varint,10,opt,name=FPort,proto3" json:"FPort,omitempty"`
	FCnt     uint32      `protobuf:"varint,11,opt,name=FCnt,proto3" json:"FCnt,omitempty"`
	Payload  []byte      `protobuf:"bytes,20,opt,name=Payload,proto3" json:"Payload,omitempty"`
	Metadata []*Metadata `protobuf:"bytes,30,rep,name=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) MarshalTo 

func (m *DataAppReq) MarshalTo(data []byte) (int, 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) MarshalTo 

func (m *DataAppRes) MarshalTo(data []byte) (int, 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,omitempty"`
	Metadata *Metadata    `protobuf:"bytes,2,opt,name=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) MarshalTo 

func (m *DataBrokerReq) MarshalTo(data []byte) (int, 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,omitempty"`
	Metadata *Metadata    `protobuf:"bytes,2,opt,name=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) MarshalTo 

func (m *DataBrokerRes) MarshalTo(data []byte) (int, 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,proto3" json:"AppEUI,omitempty"`
	DevEUI  []byte `protobuf:"bytes,2,opt,name=DevEUI,proto3" json:"DevEUI,omitempty"`
	Payload []byte `protobuf:"bytes,20,opt,name=Payload,proto3" json:"Payload,omitempty"`
	TTL     string `protobuf:"bytes,30,opt,name=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,proto3" json:"GatewayID,omitempty"`
	Payload   *LoRaWANData `protobuf:"bytes,2,opt,name=Payload" json:"Payload,omitempty"`
	Metadata  *Metadata    `protobuf:"bytes,3,opt,name=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) MarshalTo 

func (m *DataRouterReq) MarshalTo(data []byte) (int, 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,omitempty"`
	Metadata *Metadata    `protobuf:"bytes,2,opt,name=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) MarshalTo 

func (m *DataRouterRes) MarshalTo(data []byte) (int, 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,proto3" json:"AppEUI,omitempty"`
	DevEUI      []byte    `protobuf:"bytes,2,opt,name=DevEUI,proto3" json:"DevEUI,omitempty"`
	FCnt        uint32    `protobuf:"varint,10,opt,name=FCnt,proto3" json:"FCnt,omitempty"`
	FPort       uint32    `protobuf:"varint,11,opt,name=FPort,proto3" json:"FPort,omitempty"`
	MType       uint32    `protobuf:"varint,12,opt,name=MType,proto3" json:"MType,omitempty"`
	FCntUpReset bool      `protobuf:"varint,13,opt,name=FCntUpReset,proto3" json:"FCntUpReset,omitempty"`
	Payload     []byte    `protobuf:"bytes,20,opt,name=Payload,proto3" json:"Payload,omitempty"`
	Metadata    *Metadata `protobuf:"bytes,30,opt,name=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) MarshalTo 

func (m *DataUpHandlerReq) MarshalTo(data []byte) (int, 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,omitempty"`
	Metadata *Metadata    `protobuf:"bytes,30,opt,name=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) MarshalTo 

func (m *DataUpHandlerRes) MarshalTo(data []byte) (int, 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 DeleteABPHandlerReq 

type DeleteABPHandlerReq struct {
	Token   string `protobuf:"bytes,1,opt,name=Token,proto3" json:"Token,omitempty"`
	AppEUI  []byte `protobuf:"bytes,2,opt,name=AppEUI,proto3" json:"AppEUI,omitempty"`
	DevAddr []byte `protobuf:"bytes,3,opt,name=DevAddr,proto3" json:"DevAddr,omitempty"`
}

func (*DeleteABPHandlerReq) Descriptor 

func (*DeleteABPHandlerReq) Descriptor() ([]byte, []int)

func (*DeleteABPHandlerReq) Marshal 

func (m *DeleteABPHandlerReq) Marshal() (data []byte, err error)

func (*DeleteABPHandlerReq) MarshalTo 

func (m *DeleteABPHandlerReq) MarshalTo(data []byte) (int, error)

func (*DeleteABPHandlerReq) ProtoMessage 

func (*DeleteABPHandlerReq) ProtoMessage()

func (*DeleteABPHandlerReq) Reset 

func (m *DeleteABPHandlerReq) Reset()

func (*DeleteABPHandlerReq) Size 

func (m *DeleteABPHandlerReq) Size() (n int)

func (*DeleteABPHandlerReq) String 

func (m *DeleteABPHandlerReq) String() string

func (*DeleteABPHandlerReq) Unmarshal 

func (m *DeleteABPHandlerReq) Unmarshal(data []byte) error

type DeleteABPHandlerRes 

type DeleteABPHandlerRes struct {
}

func (*DeleteABPHandlerRes) Descriptor 

func (*DeleteABPHandlerRes) Descriptor() ([]byte, []int)

func (*DeleteABPHandlerRes) Marshal 

func (m *DeleteABPHandlerRes) Marshal() (data []byte, err error)

func (*DeleteABPHandlerRes) MarshalTo 

func (m *DeleteABPHandlerRes) MarshalTo(data []byte) (int, error)

func (*DeleteABPHandlerRes) ProtoMessage 

func (*DeleteABPHandlerRes) ProtoMessage()

func (*DeleteABPHandlerRes) Reset 

func (m *DeleteABPHandlerRes) Reset()

func (*DeleteABPHandlerRes) Size 

func (m *DeleteABPHandlerRes) Size() (n int)

func (*DeleteABPHandlerRes) String 

func (m *DeleteABPHandlerRes) String() string

func (*DeleteABPHandlerRes) Unmarshal 

func (m *DeleteABPHandlerRes) Unmarshal(data []byte) error

type DeleteDeviceBrokerReq 

type DeleteDeviceBrokerReq struct {
	Token   string `protobuf:"bytes,1,opt,name=Token,proto3" json:"Token,omitempty"`
	AppEUI  []byte `protobuf:"bytes,2,opt,name=AppEUI,proto3" json:"AppEUI,omitempty"`
	DevEUI  []byte `protobuf:"bytes,3,opt,name=DevEUI,proto3" json:"DevEUI,omitempty"`
	DevAddr []byte `protobuf:"bytes,4,opt,name=DevAddr,proto3" json:"DevAddr,omitempty"`
}

func (*DeleteDeviceBrokerReq) Descriptor 

func (*DeleteDeviceBrokerReq) Descriptor() ([]byte, []int)

func (*DeleteDeviceBrokerReq) Marshal 

func (m *DeleteDeviceBrokerReq) Marshal() (data []byte, err error)

func (*DeleteDeviceBrokerReq) MarshalTo 

func (m *DeleteDeviceBrokerReq) MarshalTo(data []byte) (int, error)

func (*DeleteDeviceBrokerReq) ProtoMessage 

func (*DeleteDeviceBrokerReq) ProtoMessage()

func (*DeleteDeviceBrokerReq) Reset 

func (m *DeleteDeviceBrokerReq) Reset()

func (*DeleteDeviceBrokerReq) Size 

func (m *DeleteDeviceBrokerReq) Size() (n int)

func (*DeleteDeviceBrokerReq) String 

func (m *DeleteDeviceBrokerReq) String() string

func (*DeleteDeviceBrokerReq) Unmarshal 

func (m *DeleteDeviceBrokerReq) Unmarshal(data []byte) error

type DeleteDeviceBrokerRes 

type DeleteDeviceBrokerRes struct {
}

func (*DeleteDeviceBrokerRes) Descriptor 

func (*DeleteDeviceBrokerRes) Descriptor() ([]byte, []int)

func (*DeleteDeviceBrokerRes) Marshal 

func (m *DeleteDeviceBrokerRes) Marshal() (data []byte, err error)

func (*DeleteDeviceBrokerRes) MarshalTo 

func (m *DeleteDeviceBrokerRes) MarshalTo(data []byte) (int, error)

func (*DeleteDeviceBrokerRes) ProtoMessage 

func (*DeleteDeviceBrokerRes) ProtoMessage()

func (*DeleteDeviceBrokerRes) Reset 

func (m *DeleteDeviceBrokerRes) Reset()

func (*DeleteDeviceBrokerRes) Size 

func (m *DeleteDeviceBrokerRes) Size() (n int)

func (*DeleteDeviceBrokerRes) String 

func (m *DeleteDeviceBrokerRes) String() string

func (*DeleteDeviceBrokerRes) Unmarshal 

func (m *DeleteDeviceBrokerRes) Unmarshal(data []byte) error

type DeleteOTAAHandlerReq 

type DeleteOTAAHandlerReq struct {
	Token  string `protobuf:"bytes,1,opt,name=Token,proto3" json:"Token,omitempty"`
	AppEUI []byte `protobuf:"bytes,2,opt,name=AppEUI,proto3" json:"AppEUI,omitempty"`
	DevEUI []byte `protobuf:"bytes,3,opt,name=DevEUI,proto3" json:"DevEUI,omitempty"`
}

func (*DeleteOTAAHandlerReq) Descriptor 

func (*DeleteOTAAHandlerReq) Descriptor() ([]byte, []int)

func (*DeleteOTAAHandlerReq) Marshal 

func (m *DeleteOTAAHandlerReq) Marshal() (data []byte, err error)

func (*DeleteOTAAHandlerReq) MarshalTo 

func (m *DeleteOTAAHandlerReq) MarshalTo(data []byte) (int, error)

func (*DeleteOTAAHandlerReq) ProtoMessage 

func (*DeleteOTAAHandlerReq) ProtoMessage()

func (*DeleteOTAAHandlerReq) Reset 

func (m *DeleteOTAAHandlerReq) Reset()

func (*DeleteOTAAHandlerReq) Size 

func (m *DeleteOTAAHandlerReq) Size() (n int)

func (*DeleteOTAAHandlerReq) String 

func (m *DeleteOTAAHandlerReq) String() string

func (*DeleteOTAAHandlerReq) Unmarshal 

func (m *DeleteOTAAHandlerReq) Unmarshal(data []byte) error

type DeleteOTAAHandlerRes 

type DeleteOTAAHandlerRes struct {
}

func (*DeleteOTAAHandlerRes) Descriptor 

func (*DeleteOTAAHandlerRes) Descriptor() ([]byte, []int)

func (*DeleteOTAAHandlerRes) Marshal 

func (m *DeleteOTAAHandlerRes) Marshal() (data []byte, err error)

func (*DeleteOTAAHandlerRes) MarshalTo 

func (m *DeleteOTAAHandlerRes) MarshalTo(data []byte) (int, error)

func (*DeleteOTAAHandlerRes) ProtoMessage 

func (*DeleteOTAAHandlerRes) ProtoMessage()

func (*DeleteOTAAHandlerRes) Reset 

func (m *DeleteOTAAHandlerRes) Reset()

func (*DeleteOTAAHandlerRes) Size 

func (m *DeleteOTAAHandlerRes) Size() (n int)

func (*DeleteOTAAHandlerRes) String 

func (m *DeleteOTAAHandlerRes) String() string

func (*DeleteOTAAHandlerRes) Unmarshal 

func (m *DeleteOTAAHandlerRes) 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,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,proto3" json:"Token,omitempty"`
	AppEUI []byte `protobuf:"bytes,2,opt,name=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,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,proto3" json:"Token,omitempty"`
	AppEUI []byte `protobuf:"bytes,2,opt,name=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,proto3" json:"Decoder,omitempty"`
	Converter string `protobuf:"bytes,2,opt,name=Converter,proto3" json:"Converter,omitempty"`
	Validator string `protobuf:"bytes,3,opt,name=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,proto3" json:"DevAddr,omitempty"`
	NwkSKey  []byte `protobuf:"bytes,3,opt,name=NwkSKey,proto3" json:"NwkSKey,omitempty"`
	AppSKey  []byte `protobuf:"bytes,4,opt,name=AppSKey,proto3" json:"AppSKey,omitempty"`
	FCntUp   uint32 `protobuf:"varint,5,opt,name=FCntUp,proto3" json:"FCntUp,omitempty"`
	FCntDown uint32 `protobuf:"varint,6,opt,name=FCntDown,proto3" json:"FCntDown,omitempty"`
	Flags    uint32 `protobuf:"varint,7,opt,name=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) MarshalTo 

func (m *HandlerABPDevice) MarshalTo(data []byte) (int, 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)
	DeleteOTAA(ctx context.Context, in *DeleteOTAAHandlerReq, opts ...grpc.CallOption) (*DeleteOTAAHandlerRes, error)
	DeleteABP(ctx context.Context, in *DeleteABPHandlerReq, opts ...grpc.CallOption) (*DeleteABPHandlerRes, 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)
	DeleteOTAA(context.Context, *DeleteOTAAHandlerReq) (*DeleteOTAAHandlerRes, error)
	DeleteABP(context.Context, *DeleteABPHandlerReq) (*DeleteABPHandlerRes, 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,proto3" json:"DevEUI,omitempty"`
	DevAddr  []byte `protobuf:"bytes,2,opt,name=DevAddr,proto3" json:"DevAddr,omitempty"`
	NwkSKey  []byte `protobuf:"bytes,3,opt,name=NwkSKey,proto3" json:"NwkSKey,omitempty"`
	AppSKey  []byte `protobuf:"bytes,4,opt,name=AppSKey,proto3" json:"AppSKey,omitempty"`
	AppKey   []byte `protobuf:"bytes,5,opt,name=AppKey,proto3" json:"AppKey,omitempty"`
	FCntUp   uint32 `protobuf:"varint,7,opt,name=FCntUp,proto3" json:"FCntUp,omitempty"`
	FCntDown uint32 `protobuf:"varint,8,opt,name=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,proto3" json:"AppEUI,omitempty"`
	DevEUI   []byte      `protobuf:"bytes,2,opt,name=DevEUI,proto3" json:"DevEUI,omitempty"`
	Metadata []*Metadata `protobuf:"bytes,30,rep,name=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) MarshalTo 

func (m *JoinAppReq) MarshalTo(data []byte) (int, 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) MarshalTo 

func (m *JoinAppRes) MarshalTo(data []byte) (int, 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,proto3" json:"AppEUI,omitempty"`
	DevEUI   []byte    `protobuf:"bytes,2,opt,name=DevEUI,proto3" json:"DevEUI,omitempty"`
	DevNonce []byte    `protobuf:"bytes,3,opt,name=DevNonce,proto3" json:"DevNonce,omitempty"`
	MIC      []byte    `protobuf:"bytes,4,opt,name=MIC,proto3" json:"MIC,omitempty"`
	Metadata *Metadata `protobuf:"bytes,5,opt,name=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) MarshalTo 

func (m *JoinBrokerReq) MarshalTo(data []byte) (int, 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,omitempty"`
	DevAddr  []byte             `protobuf:"bytes,2,opt,name=DevAddr,proto3" json:"DevAddr,omitempty"`
	Metadata *Metadata          `protobuf:"bytes,3,opt,name=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) MarshalTo 

func (m *JoinBrokerRes) MarshalTo(data []byte) (int, 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,proto3" json:"AppEUI,omitempty"`
	DevEUI   []byte    `protobuf:"bytes,2,opt,name=DevEUI,proto3" json:"DevEUI,omitempty"`
	DevNonce []byte    `protobuf:"bytes,10,opt,name=DevNonce,proto3" json:"DevNonce,omitempty"`
	MIC      []byte    `protobuf:"bytes,11,opt,name=MIC,proto3" json:"MIC,omitempty"`
	Metadata *Metadata `protobuf:"bytes,30,opt,name=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) MarshalTo 

func (m *JoinHandlerReq) MarshalTo(data []byte) (int, 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,proto3" json:"DevAddr,omitempty"`
	Payload  *LoRaWANJoinAccept `protobuf:"bytes,20,opt,name=Payload" json:"Payload,omitempty"`
	NwkSKey  []byte             `protobuf:"bytes,21,opt,name=NwkSKey,proto3" json:"NwkSKey,omitempty"`
	Metadata *Metadata          `protobuf:"bytes,30,opt,name=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) MarshalTo 

func (m *JoinHandlerRes) MarshalTo(data []byte) (int, 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,proto3" json:"GatewayID,omitempty"`
	AppEUI    []byte    `protobuf:"bytes,2,opt,name=AppEUI,proto3" json:"AppEUI,omitempty"`
	DevEUI    []byte    `protobuf:"bytes,3,opt,name=DevEUI,proto3" json:"DevEUI,omitempty"`
	DevNonce  []byte    `protobuf:"bytes,4,opt,name=DevNonce,proto3" json:"DevNonce,omitempty"`
	MIC       []byte    `protobuf:"bytes,5,opt,name=MIC,proto3" json:"MIC,omitempty"`
	Metadata  *Metadata `protobuf:"bytes,6,opt,name=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) MarshalTo 

func (m *JoinRouterReq) MarshalTo(data []byte) (int, 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,omitempty"`
	Metadata *Metadata          `protobuf:"bytes,2,opt,name=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) MarshalTo 

func (m *JoinRouterRes) MarshalTo(data []byte) (int, 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,proto3" json:"Token,omitempty"`
	AppEUI []byte `protobuf:"bytes,2,opt,name=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,omitempty"`
	ABP  []*HandlerABPDevice  `protobuf:"bytes,2,rep,name=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,proto3" json:"RX1DRoffset,omitempty"`
	RX2DataRate uint32 `protobuf:"varint,2,opt,name=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,omitempty"`
	MACPayload *LoRaWANMACPayload `protobuf:"bytes,2,opt,name=MACPayload" json:"MACPayload,omitempty"`
	MIC        []byte             `protobuf:"bytes,3,opt,name=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) MarshalTo 

func (m *LoRaWANData) MarshalTo(data []byte) (int, 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,proto3" json:"ADR,omitempty"`
	ADRAckReq bool   `protobuf:"varint,2,opt,name=ADRAckReq,proto3" json:"ADRAckReq,omitempty"`
	Ack       bool   `protobuf:"varint,3,opt,name=Ack,proto3" json:"Ack,omitempty"`
	FPending  bool   `protobuf:"varint,4,opt,name=FPending,proto3" json:"FPending,omitempty"`
	FOptsLen  []byte `protobuf:"bytes,5,opt,name=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) MarshalTo 

func (m *LoRaWANFCtrl) MarshalTo(data []byte) (int, 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,proto3" json:"DevAddr,omitempty"`
	FCtrl   *LoRaWANFCtrl `protobuf:"bytes,2,opt,name=FCtrl" json:"FCtrl,omitempty"`
	FCnt    uint32        `protobuf:"varint,3,opt,name=FCnt,proto3" json:"FCnt,omitempty"`
	FOpts   [][]byte      `protobuf:"bytes,4,rep,name=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) MarshalTo 

func (m *LoRaWANFHDR) MarshalTo(data []byte) (int, 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,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,proto3" json:"DevEUI,omitempty"`
	AppEUI   []byte `protobuf:"bytes,2,opt,name=AppEUI,proto3" json:"AppEUI,omitempty"`
	DevNonce []byte `protobuf:"bytes,3,opt,name=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,omitempty"`
	FPort      uint32       `protobuf:"varint,2,opt,name=FPort,proto3" json:"FPort,omitempty"`
	FRMPayload []byte       `protobuf:"bytes,3,opt,name=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,proto3" json:"MType,omitempty"`
	Major uint32 `protobuf:"varint,2,opt,name=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) MarshalTo 

func (m *LoRaWANMHDR) MarshalTo(data []byte) (int, 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 {
	Region      string  `protobuf:"bytes,99,opt,name=Region,proto3" json:"Region,omitempty"`
	DutyRX1     uint32  `protobuf:"varint,1,opt,name=DutyRX1,proto3" json:"DutyRX1,omitempty"`
	DutyRX2     uint32  `protobuf:"varint,2,opt,name=DutyRX2,proto3" json:"DutyRX2,omitempty"`
	Frequency   float32 `protobuf:"fixed32,3,opt,name=Frequency,proto3" json:"Frequency,omitempty"`
	DataRate    string  `protobuf:"bytes,4,opt,name=DataRate,proto3" json:"DataRate,omitempty"`
	CodingRate  string  `protobuf:"bytes,5,opt,name=CodingRate,proto3" json:"CodingRate,omitempty"`
	Timestamp   uint32  `protobuf:"varint,6,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	Rssi        int32   `protobuf:"varint,7,opt,name=Rssi,proto3" json:"Rssi,omitempty"`
	Lsnr        float32 `protobuf:"fixed32,8,opt,name=Lsnr,proto3" json:"Lsnr,omitempty"`
	PayloadSize uint32  `protobuf:"varint,9,opt,name=PayloadSize,proto3" json:"PayloadSize,omitempty"`
	Time        string  `protobuf:"bytes,10,opt,name=Time,proto3" json:"Time,omitempty"`
	RFChain     uint32  `protobuf:"varint,11,opt,name=RFChain,proto3" json:"RFChain,omitempty"`
	CRCStatus   int32   `protobuf:"varint,12,opt,name=CRCStatus,proto3" json:"CRCStatus,omitempty"`
	Modulation  string  `protobuf:"bytes,13,opt,name=Modulation,proto3" json:"Modulation,omitempty"`
	InvPolarity bool    `protobuf:"varint,14,opt,name=InvPolarity,proto3" json:"InvPolarity,omitempty"`
	Power       uint32  `protobuf:"varint,15,opt,name=Power,proto3" json:"Power,omitempty"`
	Channel     uint32  `protobuf:"varint,16,opt,name=Channel,proto3" json:"Channel,omitempty"`
	GatewayEUI  string  `protobuf:"bytes,20,opt,name=GatewayEUI,proto3" json:"GatewayEUI,omitempty"`
	Altitude    int32   `protobuf:"varint,21,opt,name=Altitude,proto3" json:"Altitude,omitempty"`
	Longitude   float32 `protobuf:"fixed32,22,opt,name=Longitude,proto3" json:"Longitude,omitempty"`
	Latitude    float32 `protobuf:"fixed32,23,opt,name=Latitude,proto3" json:"Latitude,omitempty"`
	ServerTime  string  `protobuf:"bytes,31,opt,name=ServerTime,proto3" json:"ServerTime,omitempty"`
}

func (*Metadata) Descriptor 

func (*Metadata) Descriptor() ([]byte, []int)

func (*Metadata) Marshal 

func (m *Metadata) Marshal() (data []byte, err error)

func (*Metadata) MarshalTo 

func (m *Metadata) MarshalTo(data []byte) (int, error)

func (*Metadata) ProtoMessage 

func (*Metadata) ProtoMessage()

func (*Metadata) Reset 

func (m *Metadata) Reset()

func (*Metadata) Size 

func (m *Metadata) Size() (n int)

func (*Metadata) String 

func (m *Metadata) String() string

func (*Metadata) Unmarshal 

func (m *Metadata) Unmarshal(data []byte) error

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,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,proto3" json:"Token,omitempty"`
	AppEUI []byte `protobuf:"bytes,2,opt,name=AppEUI,proto3" json:"AppEUI,omitempty"`
	AppKey []byte `protobuf:"bytes,3,opt,name=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,proto3" json:"Token,omitempty"`
	AppEUI    []byte `protobuf:"bytes,2,opt,name=AppEUI,proto3" json:"AppEUI,omitempty"`
	Decoder   string `protobuf:"bytes,11,opt,name=Decoder,proto3" json:"Decoder,omitempty"`
	Converter string `protobuf:"bytes,12,opt,name=Converter,proto3" json:"Converter,omitempty"`
	Validator string `protobuf:"bytes,13,opt,name=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,proto3" json:"Altitude,omitempty"`
	Longitude float32 `protobuf:"fixed32,2,opt,name=Longitude,proto3" json:"Longitude,omitempty"`
	Latitude  float32 `protobuf:"fixed32,3,opt,name=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) MarshalTo 

func (m *StatsMetadata) MarshalTo(data []byte) (int, error)

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,proto3" json:"GatewayID,omitempty"`
	Metadata  *StatsMetadata `protobuf:"bytes,2,opt,name=Metadata" json:"Metadata,omitempty"`
}

func (*StatsReq) Descriptor 

func (*StatsReq) Descriptor() ([]byte, []int)

func (*StatsReq) GetMetadata 

func (m *StatsReq) GetMetadata() *StatsMetadata

func (*StatsReq) Marshal 

func (m *StatsReq) Marshal() (data []byte, err error)

func (*StatsReq) MarshalTo 

func (m *StatsReq) MarshalTo(data []byte) (int, error)

func (*StatsReq) ProtoMessage 

func (*StatsReq) ProtoMessage()

func (*StatsReq) Reset 

func (m *StatsReq) Reset()

func (*StatsReq) Size 

func (m *StatsReq) Size() (n int)

func (*StatsReq) String 

func (m *StatsReq) String() string

func (*StatsReq) Unmarshal 

func (m *StatsReq) Unmarshal(data []byte) error

type StatsRes 

type StatsRes struct {
}

func (*StatsRes) Descriptor 

func (*StatsRes) Descriptor() ([]byte, []int)

func (*StatsRes) Marshal 

func (m *StatsRes) Marshal() (data []byte, err error)

func (*StatsRes) MarshalTo 

func (m *StatsRes) MarshalTo(data []byte) (int, error)

func (*StatsRes) ProtoMessage 

func (*StatsRes) ProtoMessage()

func (*StatsRes) Reset 

func (m *StatsRes) Reset()

func (*StatsRes) Size 

func (m *StatsRes) Size() (n int)

func (*StatsRes) String 

func (m *StatsRes) String() string

func (*StatsRes) Unmarshal 

func (m *StatsRes) Unmarshal(data []byte) error

type TestPayloadFunctionsReq 

type TestPayloadFunctionsReq struct {
	Token     string `protobuf:"bytes,1,opt,name=Token,proto3" json:"Token,omitempty"`
	AppEUI    []byte `protobuf:"bytes,2,opt,name=AppEUI,proto3" json:"AppEUI,omitempty"`
	Payload   []byte `protobuf:"bytes,11,opt,name=Payload,proto3" json:"Payload,omitempty"`
	Decoder   string `protobuf:"bytes,21,opt,name=Decoder,proto3" json:"Decoder,omitempty"`
	Converter string `protobuf:"bytes,22,opt,name=Converter,proto3" json:"Converter,omitempty"`
	Validator string `protobuf:"bytes,23,opt,name=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,proto3" json:"Fields,omitempty"`
	Valid  bool   `protobuf:"varint,2,opt,name=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,proto3" json:"Token,omitempty"`
	AppEUI     []byte `protobuf:"bytes,2,opt,name=AppEUI,proto3" json:"AppEUI,omitempty"`
	NetAddress string `protobuf:"bytes,3,opt,name=NetAddress,proto3" json:"NetAddress,omitempty"`
	DevAddr    []byte `protobuf:"bytes,4,opt,name=DevAddr,proto3" json:"DevAddr,omitempty"`
	NwkSKey    []byte `protobuf:"bytes,5,opt,name=NwkSKey,proto3" json:"NwkSKey,omitempty"`
	Flags      uint32 `protobuf:"varint,6,opt,name=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,proto3" json:"Token,omitempty"`
	AppEUI  []byte `protobuf:"bytes,2,opt,name=AppEUI,proto3" json:"AppEUI,omitempty"`
	DevAddr []byte `protobuf:"bytes,3,opt,name=DevAddr,proto3" json:"DevAddr,omitempty"`
	NwkSKey []byte `protobuf:"bytes,4,opt,name=NwkSKey,proto3" json:"NwkSKey,omitempty"`
	AppSKey []byte `protobuf:"bytes,5,opt,name=AppSKey,proto3" json:"AppSKey,omitempty"`
	Flags   uint32 `protobuf:"varint,6,opt,name=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,proto3" json:"Token,omitempty"`
	AppEUI []byte `protobuf:"bytes,2,opt,name=AppEUI,proto3" json:"AppEUI,omitempty"`
	DevEUI []byte `protobuf:"bytes,3,opt,name=DevEUI,proto3" json:"DevEUI,omitempty"`
	AppKey []byte `protobuf:"bytes,4,opt,name=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,proto3" json:"Token,omitempty"`
	AppEUI     []byte `protobuf:"bytes,2,opt,name=AppEUI,proto3" json:"AppEUI,omitempty"`
	NetAddress string `protobuf:"bytes,3,opt,name=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,proto3" json:"Token,omitempty"`
	AppEUI []byte `protobuf:"bytes,2,opt,name=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

View all Source files

Directories

Path Synopsis
adapters
fields
http
Package http provides adapter implementations which run on top of http.
 Package http provides adapter implementations which run on top of http.
mqtt
udp
Package band provides band specific defaults and configuration.
 Package band provides band specific defaults and configuration.
au915_928
eu863_870
us902_928
components
broker
handler
router
Package mocks offers dedicated mocking interface / structures for testing
 Package mocks offers dedicated mocking interface / structures for testing

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.