as

package
v2.0.2+incompatible Latest Latest
Warning

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

 Go to latest Published: Aug 15, 2018 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ErrorType_name = map[int32]string{
	0: "GENERIC",
	1: "OTAA",
	2: "DATA_UP_FCNT",
	3: "DATA_UP_MIC",
	4: "DEVICE_QUEUE_ITEM_SIZE",
	5: "DEVICE_QUEUE_ITEM_FCNT",
}
View Source 
var ErrorType_value = map[string]int32{
	"GENERIC":                0,
	"OTAA":                   1,
	"DATA_UP_FCNT":           2,
	"DATA_UP_MIC":            3,
	"DEVICE_QUEUE_ITEM_SIZE": 4,
	"DEVICE_QUEUE_ITEM_FCNT": 5,
}
View Source 
var RXWindow_name = map[int32]string{
	0: "RX1",
	1: "RX2",
}
View Source 
var RXWindow_value = map[string]int32{
	"RX1": 0,
	"RX2": 1,
}

Functions

func RegisterApplicationServerServiceServer 

func RegisterApplicationServerServiceServer(s *grpc.Server, srv ApplicationServerServiceServer)

Types

type ApplicationServerServiceClient 

type ApplicationServerServiceClient interface {
	// HandleUplinkData handles uplink data received from an end-device.
	HandleUplinkData(ctx context.Context, in *HandleUplinkDataRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// HandleProprietaryUplink handles proprietary uplink payloads.
	HandleProprietaryUplink(ctx context.Context, in *HandleProprietaryUplinkRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// HandleError handles an error message.
	HandleError(ctx context.Context, in *HandleErrorRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// HandleDownlinkACK handles a downlink ACK or nACK response.
	HandleDownlinkACK(ctx context.Context, in *HandleDownlinkACKRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// SetDeviceStatus updates the device-status for a device.
	SetDeviceStatus(ctx context.Context, in *SetDeviceStatusRequest, opts ...grpc.CallOption) (*empty.Empty, error)
}

ApplicationServerServiceClient is the client API for ApplicationServerService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewApplicationServerServiceClient 

func NewApplicationServerServiceClient(cc *grpc.ClientConn) ApplicationServerServiceClient

type ApplicationServerServiceServer 

type ApplicationServerServiceServer interface {
	// HandleUplinkData handles uplink data received from an end-device.
	HandleUplinkData(context.Context, *HandleUplinkDataRequest) (*empty.Empty, error)
	// HandleProprietaryUplink handles proprietary uplink payloads.
	HandleProprietaryUplink(context.Context, *HandleProprietaryUplinkRequest) (*empty.Empty, error)
	// HandleError handles an error message.
	HandleError(context.Context, *HandleErrorRequest) (*empty.Empty, error)
	// HandleDownlinkACK handles a downlink ACK or nACK response.
	HandleDownlinkACK(context.Context, *HandleDownlinkACKRequest) (*empty.Empty, error)
	// SetDeviceStatus updates the device-status for a device.
	SetDeviceStatus(context.Context, *SetDeviceStatusRequest) (*empty.Empty, error)
}

ApplicationServerServiceServer is the server API for ApplicationServerService service.

type DeviceActivationContext 

type DeviceActivationContext struct {
	// Assigned Device Address.
	DevAddr []byte `protobuf:"bytes,1,opt,name=dev_addr,json=devAddr,proto3" json:"dev_addr,omitempty"`
	// Application session key (envelope).
	AppSKey              *common.KeyEnvelope `protobuf:"bytes,2,opt,name=app_s_key,json=appSKey,proto3" json:"app_s_key,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*DeviceActivationContext) Descriptor 

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

func (*DeviceActivationContext) GetAppSKey 

func (m *DeviceActivationContext) GetAppSKey() *common.KeyEnvelope

func (*DeviceActivationContext) GetDevAddr 

func (m *DeviceActivationContext) GetDevAddr() []byte

func (*DeviceActivationContext) ProtoMessage 

func (*DeviceActivationContext) ProtoMessage()

func (*DeviceActivationContext) Reset 

func (m *DeviceActivationContext) Reset()

func (*DeviceActivationContext) String 

func (m *DeviceActivationContext) String() string

func (*DeviceActivationContext) XXX_DiscardUnknown 

func (m *DeviceActivationContext) XXX_DiscardUnknown()

func (*DeviceActivationContext) XXX_Marshal 

func (m *DeviceActivationContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeviceActivationContext) XXX_Merge 

func (dst *DeviceActivationContext) XXX_Merge(src proto.Message)

func (*DeviceActivationContext) XXX_Size 

func (m *DeviceActivationContext) XXX_Size() int

func (*DeviceActivationContext) XXX_Unmarshal 

func (m *DeviceActivationContext) XXX_Unmarshal(b []byte) error

type ErrorType 

type ErrorType int32
const (
	ErrorType_GENERIC                ErrorType = 0
	ErrorType_OTAA                   ErrorType = 1
	ErrorType_DATA_UP_FCNT           ErrorType = 2
	ErrorType_DATA_UP_MIC            ErrorType = 3
	ErrorType_DEVICE_QUEUE_ITEM_SIZE ErrorType = 4
	ErrorType_DEVICE_QUEUE_ITEM_FCNT ErrorType = 5
)

func (ErrorType) EnumDescriptor 

func (ErrorType) EnumDescriptor() ([]byte, []int)

func (ErrorType) String 

func (x ErrorType) String() string

type HandleDownlinkACKRequest 

type HandleDownlinkACKRequest struct {
	// Device EUI (8 bytes).
	DevEui []byte `protobuf:"bytes,1,opt,name=dev_eui,json=devEui,proto3" json:"dev_eui,omitempty"`
	// Downlink frame-counter.
	FCnt uint32 `protobuf:"varint,2,opt,name=f_cnt,json=fCnt,proto3" json:"f_cnt,omitempty"`
	// Frame was acknowledged?
	Acknowledged         bool     `protobuf:"varint,3,opt,name=acknowledged,proto3" json:"acknowledged,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HandleDownlinkACKRequest) Descriptor 

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

func (*HandleDownlinkACKRequest) GetAcknowledged 

func (m *HandleDownlinkACKRequest) GetAcknowledged() bool

func (*HandleDownlinkACKRequest) GetDevEui 

func (m *HandleDownlinkACKRequest) GetDevEui() []byte

func (*HandleDownlinkACKRequest) GetFCnt 

func (m *HandleDownlinkACKRequest) GetFCnt() uint32

func (*HandleDownlinkACKRequest) ProtoMessage 

func (*HandleDownlinkACKRequest) ProtoMessage()

func (*HandleDownlinkACKRequest) Reset 

func (m *HandleDownlinkACKRequest) Reset()

func (*HandleDownlinkACKRequest) String 

func (m *HandleDownlinkACKRequest) String() string

func (*HandleDownlinkACKRequest) XXX_DiscardUnknown 

func (m *HandleDownlinkACKRequest) XXX_DiscardUnknown()

func (*HandleDownlinkACKRequest) XXX_Marshal 

func (m *HandleDownlinkACKRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HandleDownlinkACKRequest) XXX_Merge 

func (dst *HandleDownlinkACKRequest) XXX_Merge(src proto.Message)

func (*HandleDownlinkACKRequest) XXX_Size 

func (m *HandleDownlinkACKRequest) XXX_Size() int

func (*HandleDownlinkACKRequest) XXX_Unmarshal 

func (m *HandleDownlinkACKRequest) XXX_Unmarshal(b []byte) error

type HandleErrorRequest 

type HandleErrorRequest struct {
	// Device EUI (8 bytes).
	DevEui []byte `protobuf:"bytes,1,opt,name=dev_eui,json=devEui,proto3" json:"dev_eui,omitempty"`
	// Type of the error.
	Type ErrorType `protobuf:"varint,3,opt,name=type,proto3,enum=as.ErrorType" json:"type,omitempty"`
	// Error string describing the error.
	Error string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	// Frame-counter (if applicable) related to the error.
	FCnt                 uint32   `protobuf:"varint,5,opt,name=f_cnt,json=fCnt,proto3" json:"f_cnt,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HandleErrorRequest) Descriptor 

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

func (*HandleErrorRequest) GetDevEui 

func (m *HandleErrorRequest) GetDevEui() []byte

func (*HandleErrorRequest) GetError 

func (m *HandleErrorRequest) GetError() string

func (*HandleErrorRequest) GetFCnt 

func (m *HandleErrorRequest) GetFCnt() uint32

func (*HandleErrorRequest) GetType 

func (m *HandleErrorRequest) GetType() ErrorType

func (*HandleErrorRequest) ProtoMessage 

func (*HandleErrorRequest) ProtoMessage()

func (*HandleErrorRequest) Reset 

func (m *HandleErrorRequest) Reset()

func (*HandleErrorRequest) String 

func (m *HandleErrorRequest) String() string

func (*HandleErrorRequest) XXX_DiscardUnknown 

func (m *HandleErrorRequest) XXX_DiscardUnknown()

func (*HandleErrorRequest) XXX_Marshal 

func (m *HandleErrorRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HandleErrorRequest) XXX_Merge 

func (dst *HandleErrorRequest) XXX_Merge(src proto.Message)

func (*HandleErrorRequest) XXX_Size 

func (m *HandleErrorRequest) XXX_Size() int

func (*HandleErrorRequest) XXX_Unmarshal 

func (m *HandleErrorRequest) XXX_Unmarshal(b []byte) error

type HandleProprietaryUplinkRequest 

type HandleProprietaryUplinkRequest struct {
	// MACPayload of the proprietary LoRaWAN frame.
	MacPayload []byte `protobuf:"bytes,1,opt,name=mac_payload,json=macPayload,proto3" json:"mac_payload,omitempty"`
	// MIC of the proprietary LoRaWAN frame.
	Mic []byte `protobuf:"bytes,2,opt,name=mic,proto3" json:"mic,omitempty"`
	// TXInfo contains the TX related meta-data.
	TxInfo *gw.UplinkTXInfo `protobuf:"bytes,3,opt,name=tx_info,json=txInfo,proto3" json:"tx_info,omitempty"`
	// RXInfo contains the RX related meta-data.
	RxInfo               []*gw.UplinkRXInfo `protobuf:"bytes,4,rep,name=rx_info,json=rxInfo,proto3" json:"rx_info,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*HandleProprietaryUplinkRequest) Descriptor 

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

func (*HandleProprietaryUplinkRequest) GetMacPayload 

func (m *HandleProprietaryUplinkRequest) GetMacPayload() []byte

func (*HandleProprietaryUplinkRequest) GetMic 

func (m *HandleProprietaryUplinkRequest) GetMic() []byte

func (*HandleProprietaryUplinkRequest) GetRxInfo 

func (m *HandleProprietaryUplinkRequest) GetRxInfo() []*gw.UplinkRXInfo

func (*HandleProprietaryUplinkRequest) GetTxInfo 

func (m *HandleProprietaryUplinkRequest) GetTxInfo() *gw.UplinkTXInfo

func (*HandleProprietaryUplinkRequest) ProtoMessage 

func (*HandleProprietaryUplinkRequest) ProtoMessage()

func (*HandleProprietaryUplinkRequest) Reset 

func (m *HandleProprietaryUplinkRequest) Reset()

func (*HandleProprietaryUplinkRequest) String 

func (m *HandleProprietaryUplinkRequest) String() string

func (*HandleProprietaryUplinkRequest) XXX_DiscardUnknown 

func (m *HandleProprietaryUplinkRequest) XXX_DiscardUnknown()

func (*HandleProprietaryUplinkRequest) XXX_Marshal 

func (m *HandleProprietaryUplinkRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HandleProprietaryUplinkRequest) XXX_Merge 

func (dst *HandleProprietaryUplinkRequest) XXX_Merge(src proto.Message)

func (*HandleProprietaryUplinkRequest) XXX_Size 

func (m *HandleProprietaryUplinkRequest) XXX_Size() int

func (*HandleProprietaryUplinkRequest) XXX_Unmarshal 

func (m *HandleProprietaryUplinkRequest) XXX_Unmarshal(b []byte) error

type HandleUplinkDataRequest 

type HandleUplinkDataRequest struct {
	// DevEUI EUI (8 bytes).
	DevEui []byte `protobuf:"bytes,1,opt,name=dev_eui,json=devEui,proto3" json:"dev_eui,omitempty"`
	// Join EUI used for OTAA activation (8 bytes).
	JoinEui []byte `protobuf:"bytes,2,opt,name=join_eui,json=joinEui,proto3" json:"join_eui,omitempty"`
	// Frame-counter.
	FCnt uint32 `protobuf:"varint,3,opt,name=f_cnt,json=fCnt,proto3" json:"f_cnt,omitempty"`
	// Frame port.
	FPort uint32 `protobuf:"varint,4,opt,name=f_port,json=fPort,proto3" json:"f_port,omitempty"`
	// ADR enabled.
	Adr bool `protobuf:"varint,5,opt,name=adr,proto3" json:"adr,omitempty"`
	// Data-rate.
	Dr uint32 `protobuf:"varint,6,opt,name=dr,proto3" json:"dr,omitempty"`
	// TX meta-data.
	TxInfo *gw.UplinkTXInfo `protobuf:"bytes,7,opt,name=tx_info,json=txInfo,proto3" json:"tx_info,omitempty"`
	// RX meta-data.
	RxInfo []*gw.UplinkRXInfo `protobuf:"bytes,8,rep,name=rx_info,json=rxInfo,proto3" json:"rx_info,omitempty"`
	// Received data (encrypted).
	Data []byte `protobuf:"bytes,9,opt,name=data,proto3" json:"data,omitempty"`
	// Device activation context.
	//
	// This field is only set on the first uplink frame when the security
	// context has changed (e.g. a new OTAA (re)activation).
	DeviceActivationContext *DeviceActivationContext `` /* 133-byte string literal not displayed */
	XXX_NoUnkeyedLiteral    struct{}                 `json:"-"`
	XXX_unrecognized        []byte                   `json:"-"`
	XXX_sizecache           int32                    `json:"-"`
}

func (*HandleUplinkDataRequest) Descriptor 

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

func (*HandleUplinkDataRequest) GetAdr 

func (m *HandleUplinkDataRequest) GetAdr() bool

func (*HandleUplinkDataRequest) GetData 

func (m *HandleUplinkDataRequest) GetData() []byte

func (*HandleUplinkDataRequest) GetDevEui 

func (m *HandleUplinkDataRequest) GetDevEui() []byte

func (*HandleUplinkDataRequest) GetDeviceActivationContext 

func (m *HandleUplinkDataRequest) GetDeviceActivationContext() *DeviceActivationContext

func (*HandleUplinkDataRequest) GetDr 

func (m *HandleUplinkDataRequest) GetDr() uint32

func (*HandleUplinkDataRequest) GetFCnt 

func (m *HandleUplinkDataRequest) GetFCnt() uint32

func (*HandleUplinkDataRequest) GetFPort 

func (m *HandleUplinkDataRequest) GetFPort() uint32

func (*HandleUplinkDataRequest) GetJoinEui 

func (m *HandleUplinkDataRequest) GetJoinEui() []byte

func (*HandleUplinkDataRequest) GetRxInfo 

func (m *HandleUplinkDataRequest) GetRxInfo() []*gw.UplinkRXInfo

func (*HandleUplinkDataRequest) GetTxInfo 

func (m *HandleUplinkDataRequest) GetTxInfo() *gw.UplinkTXInfo

func (*HandleUplinkDataRequest) ProtoMessage 

func (*HandleUplinkDataRequest) ProtoMessage()

func (*HandleUplinkDataRequest) Reset 

func (m *HandleUplinkDataRequest) Reset()

func (*HandleUplinkDataRequest) String 

func (m *HandleUplinkDataRequest) String() string

func (*HandleUplinkDataRequest) XXX_DiscardUnknown 

func (m *HandleUplinkDataRequest) XXX_DiscardUnknown()

func (*HandleUplinkDataRequest) XXX_Marshal 

func (m *HandleUplinkDataRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HandleUplinkDataRequest) XXX_Merge 

func (dst *HandleUplinkDataRequest) XXX_Merge(src proto.Message)

func (*HandleUplinkDataRequest) XXX_Size 

func (m *HandleUplinkDataRequest) XXX_Size() int

func (*HandleUplinkDataRequest) XXX_Unmarshal 

func (m *HandleUplinkDataRequest) XXX_Unmarshal(b []byte) error

type RXWindow 

type RXWindow int32
const (
	RXWindow_RX1 RXWindow = 0
	RXWindow_RX2 RXWindow = 1
)

func (RXWindow) EnumDescriptor 

func (RXWindow) EnumDescriptor() ([]byte, []int)

func (RXWindow) String 

func (x RXWindow) String() string

type SetDeviceStatusRequest 

type SetDeviceStatusRequest struct {
	// Device EUI (8 bytes).
	DevEui []byte `protobuf:"bytes,1,opt,name=dev_eui,json=devEui,proto3" json:"dev_eui,omitempty"`
	// Battery level.
	// 0:      The end-device is connected to an external power source
	// 1..254: The battery level, 1 being at minimum and 254 being at maximum
	// 255:    The end-device was not able to measure the battery level
	// 256:    The device-status is not available.
	Battery uint32 `protobuf:"varint,2,opt,name=battery,proto3" json:"battery,omitempty"`
	// The device margin status
	// -32..32: The demodulation SNR ration in dB
	// 256:     The device-status is not available.
	Margin               int32    `protobuf:"varint,3,opt,name=margin,proto3" json:"margin,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SetDeviceStatusRequest) Descriptor 

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

func (*SetDeviceStatusRequest) GetBattery 

func (m *SetDeviceStatusRequest) GetBattery() uint32

func (*SetDeviceStatusRequest) GetDevEui 

func (m *SetDeviceStatusRequest) GetDevEui() []byte

func (*SetDeviceStatusRequest) GetMargin 

func (m *SetDeviceStatusRequest) GetMargin() int32

func (*SetDeviceStatusRequest) ProtoMessage 

func (*SetDeviceStatusRequest) ProtoMessage()

func (*SetDeviceStatusRequest) Reset 

func (m *SetDeviceStatusRequest) Reset()

func (*SetDeviceStatusRequest) String 

func (m *SetDeviceStatusRequest) String() string

func (*SetDeviceStatusRequest) XXX_DiscardUnknown 

func (m *SetDeviceStatusRequest) XXX_DiscardUnknown()

func (*SetDeviceStatusRequest) XXX_Marshal 

func (m *SetDeviceStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetDeviceStatusRequest) XXX_Merge 

func (dst *SetDeviceStatusRequest) XXX_Merge(src proto.Message)

func (*SetDeviceStatusRequest) XXX_Size 

func (m *SetDeviceStatusRequest) XXX_Size() int

func (*SetDeviceStatusRequest) XXX_Unmarshal 

func (m *SetDeviceStatusRequest) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

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.