nc

package
v0.0.0-...-d91e8b8 Latest Latest
Warning

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

 Go to latest Published: Nov 14, 2024 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var MType_name = map[int32]string{
	0: "UNKNOWN",
	1: "JOIN_REQUEST",
	2: "JOIN_ACCEPT",
	3: "UNCONFIRMED_DATA_UP",
	4: "UNCONFIRMED_DATA_DOWN",
	5: "CONFIRMED_DATA_UP",
	6: "CONFIRMED_DATA_DOWN",
	7: "REJOIN_REQUEST",
}
View Source 
var MType_value = map[string]int32{
	"UNKNOWN":               0,
	"JOIN_REQUEST":          1,
	"JOIN_ACCEPT":           2,
	"UNCONFIRMED_DATA_UP":   3,
	"UNCONFIRMED_DATA_DOWN": 4,
	"CONFIRMED_DATA_UP":     5,
	"CONFIRMED_DATA_DOWN":   6,
	"REJOIN_REQUEST":        7,
}

Functions

func RegisterNetworkControllerServiceServer 

func RegisterNetworkControllerServiceServer(s *grpc.Server, srv NetworkControllerServiceServer)

Types

type HandleDownlinkMetaDataRequest 

type HandleDownlinkMetaDataRequest struct {
	// Device EUI (8 bytes).
	DevEui []byte `protobuf:"bytes,1,opt,name=dev_eui,json=devEui,proto3" json:"dev_eui,omitempty"`
	// Multicast Group ID (UUID).
	MulticastGroupId []byte `protobuf:"bytes,2,opt,name=multicast_group_id,json=multicastGroupId,proto3" json:"multicast_group_id,omitempty"`
	// TX meta-data.
	TxInfo *gw.DownlinkTXInfo `protobuf:"bytes,3,opt,name=tx_info,json=txInfo,proto3" json:"tx_info,omitempty"`
	// PHYPayload byte count.
	PhyPayloadByteCount uint32 `protobuf:"varint,4,opt,name=phy_payload_byte_count,json=phyPayloadByteCount,proto3" json:"phy_payload_byte_count,omitempty"`
	// MAC-Command byte count.
	MacCommandByteCount uint32 `protobuf:"varint,5,opt,name=mac_command_byte_count,json=macCommandByteCount,proto3" json:"mac_command_byte_count,omitempty"`
	// Application payload byte count.
	ApplicationPayloadByteCount uint32 `` /* 147-byte string literal not displayed */
	// Message type.
	MessageType MType `protobuf:"varint,7,opt,name=message_type,json=messageType,proto3,enum=nc.MType" json:"message_type,omitempty"`
	// Gateway ID.
	GatewayId            []byte   `protobuf:"bytes,8,opt,name=gateway_id,json=gatewayId,proto3" json:"gateway_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HandleDownlinkMetaDataRequest) Descriptor 

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

func (*HandleDownlinkMetaDataRequest) GetApplicationPayloadByteCount 

func (m *HandleDownlinkMetaDataRequest) GetApplicationPayloadByteCount() uint32

func (*HandleDownlinkMetaDataRequest) GetDevEui 

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

func (*HandleDownlinkMetaDataRequest) GetGatewayId 

func (m *HandleDownlinkMetaDataRequest) GetGatewayId() []byte

func (*HandleDownlinkMetaDataRequest) GetMacCommandByteCount 

func (m *HandleDownlinkMetaDataRequest) GetMacCommandByteCount() uint32

func (*HandleDownlinkMetaDataRequest) GetMessageType 

func (m *HandleDownlinkMetaDataRequest) GetMessageType() MType

func (*HandleDownlinkMetaDataRequest) GetMulticastGroupId 

func (m *HandleDownlinkMetaDataRequest) GetMulticastGroupId() []byte

func (*HandleDownlinkMetaDataRequest) GetPhyPayloadByteCount 

func (m *HandleDownlinkMetaDataRequest) GetPhyPayloadByteCount() uint32

func (*HandleDownlinkMetaDataRequest) GetTxInfo 

func (m *HandleDownlinkMetaDataRequest) GetTxInfo() *gw.DownlinkTXInfo

func (*HandleDownlinkMetaDataRequest) ProtoMessage 

func (*HandleDownlinkMetaDataRequest) ProtoMessage()

func (*HandleDownlinkMetaDataRequest) Reset 

func (m *HandleDownlinkMetaDataRequest) Reset()

func (*HandleDownlinkMetaDataRequest) String 

func (m *HandleDownlinkMetaDataRequest) String() string

func (*HandleDownlinkMetaDataRequest) XXX_DiscardUnknown 

func (m *HandleDownlinkMetaDataRequest) XXX_DiscardUnknown()

func (*HandleDownlinkMetaDataRequest) XXX_Marshal 

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

func (*HandleDownlinkMetaDataRequest) XXX_Merge 

func (m *HandleDownlinkMetaDataRequest) XXX_Merge(src proto.Message)

func (*HandleDownlinkMetaDataRequest) XXX_Size 

func (m *HandleDownlinkMetaDataRequest) XXX_Size() int

func (*HandleDownlinkMetaDataRequest) XXX_Unmarshal 

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

type HandleRejectedUplinkFrameSetRequest 

type HandleRejectedUplinkFrameSetRequest struct {
	FrameSet             *gw.UplinkFrameSet `protobuf:"bytes,1,opt,name=frame_set,json=frameSet,proto3" json:"frame_set,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*HandleRejectedUplinkFrameSetRequest) Descriptor 

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

func (*HandleRejectedUplinkFrameSetRequest) GetFrameSet 

func (m *HandleRejectedUplinkFrameSetRequest) GetFrameSet() *gw.UplinkFrameSet

func (*HandleRejectedUplinkFrameSetRequest) ProtoMessage 

func (*HandleRejectedUplinkFrameSetRequest) ProtoMessage()

func (*HandleRejectedUplinkFrameSetRequest) Reset 

func (m *HandleRejectedUplinkFrameSetRequest) Reset()

func (*HandleRejectedUplinkFrameSetRequest) String 

func (m *HandleRejectedUplinkFrameSetRequest) String() string

func (*HandleRejectedUplinkFrameSetRequest) XXX_DiscardUnknown 

func (m *HandleRejectedUplinkFrameSetRequest) XXX_DiscardUnknown()

func (*HandleRejectedUplinkFrameSetRequest) XXX_Marshal 

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

func (*HandleRejectedUplinkFrameSetRequest) XXX_Merge 

func (m *HandleRejectedUplinkFrameSetRequest) XXX_Merge(src proto.Message)

func (*HandleRejectedUplinkFrameSetRequest) XXX_Size 

func (m *HandleRejectedUplinkFrameSetRequest) XXX_Size() int

func (*HandleRejectedUplinkFrameSetRequest) XXX_Unmarshal 

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

type HandleUplinkMACCommandRequest 

type HandleUplinkMACCommandRequest struct {
	// Device EUI (8 bytes).
	DevEui []byte `protobuf:"bytes,1,opt,name=dev_eui,json=devEui,proto3" json:"dev_eui,omitempty"`
	// Command identifier (specified by the LoRaWAN specs).
	Cid uint32 `protobuf:"varint,2,opt,name=cid,proto3" json:"cid,omitempty"`
	// MAC-command payload(s).
	Commands             [][]byte `protobuf:"bytes,6,rep,name=commands,proto3" json:"commands,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HandleUplinkMACCommandRequest) Descriptor 

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

func (*HandleUplinkMACCommandRequest) GetCid 

func (m *HandleUplinkMACCommandRequest) GetCid() uint32

func (*HandleUplinkMACCommandRequest) GetCommands 

func (m *HandleUplinkMACCommandRequest) GetCommands() [][]byte

func (*HandleUplinkMACCommandRequest) GetDevEui 

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

func (*HandleUplinkMACCommandRequest) ProtoMessage 

func (*HandleUplinkMACCommandRequest) ProtoMessage()

func (*HandleUplinkMACCommandRequest) Reset 

func (m *HandleUplinkMACCommandRequest) Reset()

func (*HandleUplinkMACCommandRequest) String 

func (m *HandleUplinkMACCommandRequest) String() string

func (*HandleUplinkMACCommandRequest) XXX_DiscardUnknown 

func (m *HandleUplinkMACCommandRequest) XXX_DiscardUnknown()

func (*HandleUplinkMACCommandRequest) XXX_Marshal 

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

func (*HandleUplinkMACCommandRequest) XXX_Merge 

func (m *HandleUplinkMACCommandRequest) XXX_Merge(src proto.Message)

func (*HandleUplinkMACCommandRequest) XXX_Size 

func (m *HandleUplinkMACCommandRequest) XXX_Size() int

func (*HandleUplinkMACCommandRequest) XXX_Unmarshal 

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

type HandleUplinkMetaDataRequest 

type HandleUplinkMetaDataRequest struct {
	// Device EUI (8 bytes).
	DevEui []byte `protobuf:"bytes,1,opt,name=dev_eui,json=devEui,proto3" json:"dev_eui,omitempty"`
	// TX meta-data.
	TxInfo *gw.UplinkTXInfo `protobuf:"bytes,2,opt,name=tx_info,json=txInfo,proto3" json:"tx_info,omitempty"`
	// RX meta-data.
	RxInfo []*gw.UplinkRXInfo `protobuf:"bytes,3,rep,name=rx_info,json=rxInfo,proto3" json:"rx_info,omitempty"`
	// PHYPayload byte count.
	PhyPayloadByteCount uint32 `protobuf:"varint,4,opt,name=phy_payload_byte_count,json=phyPayloadByteCount,proto3" json:"phy_payload_byte_count,omitempty"`
	// MAC-Command byte count.
	MacCommandByteCount uint32 `protobuf:"varint,5,opt,name=mac_command_byte_count,json=macCommandByteCount,proto3" json:"mac_command_byte_count,omitempty"`
	// Application payload byte count.
	ApplicationPayloadByteCount uint32 `` /* 147-byte string literal not displayed */
	// Message type.
	MessageType          MType    `protobuf:"varint,7,opt,name=message_type,json=messageType,proto3,enum=nc.MType" json:"message_type,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HandleUplinkMetaDataRequest) Descriptor 

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

func (*HandleUplinkMetaDataRequest) GetApplicationPayloadByteCount 

func (m *HandleUplinkMetaDataRequest) GetApplicationPayloadByteCount() uint32

func (*HandleUplinkMetaDataRequest) GetDevEui 

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

func (*HandleUplinkMetaDataRequest) GetMacCommandByteCount 

func (m *HandleUplinkMetaDataRequest) GetMacCommandByteCount() uint32

func (*HandleUplinkMetaDataRequest) GetMessageType 

func (m *HandleUplinkMetaDataRequest) GetMessageType() MType

func (*HandleUplinkMetaDataRequest) GetPhyPayloadByteCount 

func (m *HandleUplinkMetaDataRequest) GetPhyPayloadByteCount() uint32

func (*HandleUplinkMetaDataRequest) GetRxInfo 

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

func (*HandleUplinkMetaDataRequest) GetTxInfo 

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

func (*HandleUplinkMetaDataRequest) ProtoMessage 

func (*HandleUplinkMetaDataRequest) ProtoMessage()

func (*HandleUplinkMetaDataRequest) Reset 

func (m *HandleUplinkMetaDataRequest) Reset()

func (*HandleUplinkMetaDataRequest) String 

func (m *HandleUplinkMetaDataRequest) String() string

func (*HandleUplinkMetaDataRequest) XXX_DiscardUnknown 

func (m *HandleUplinkMetaDataRequest) XXX_DiscardUnknown()

func (*HandleUplinkMetaDataRequest) XXX_Marshal 

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

func (*HandleUplinkMetaDataRequest) XXX_Merge 

func (m *HandleUplinkMetaDataRequest) XXX_Merge(src proto.Message)

func (*HandleUplinkMetaDataRequest) XXX_Size 

func (m *HandleUplinkMetaDataRequest) XXX_Size() int

func (*HandleUplinkMetaDataRequest) XXX_Unmarshal 

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

type MType 

type MType int32
const (
	MType_UNKNOWN               MType = 0
	MType_JOIN_REQUEST          MType = 1
	MType_JOIN_ACCEPT           MType = 2
	MType_UNCONFIRMED_DATA_UP   MType = 3
	MType_UNCONFIRMED_DATA_DOWN MType = 4
	MType_CONFIRMED_DATA_UP     MType = 5
	MType_CONFIRMED_DATA_DOWN   MType = 6
	MType_REJOIN_REQUEST        MType = 7
)

func (MType) EnumDescriptor 

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

func (MType) String 

func (x MType) String() string

type NetworkControllerServiceClient 

type NetworkControllerServiceClient interface {
	// HandleUplinkMetaData handles uplink meta-rata.
	HandleUplinkMetaData(ctx context.Context, in *HandleUplinkMetaDataRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// HandleDownlinkMetaData handles downlink meta-data.
	HandleDownlinkMetaData(ctx context.Context, in *HandleDownlinkMetaDataRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// HandleUplinkMACCommand handles an uplink mac-command.
	// This method will only be called in case the mac-command request was
	// enqueued throught the API or when the CID is >= 0x80 (proprietary
	// mac-command range).
	HandleUplinkMACCommand(ctx context.Context, in *HandleUplinkMACCommandRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// HandleRejectedUplinkFrameSet handles a rejected uplink.
	// And uplink can be rejected in the case the device has not (yet) been
	// provisioned, because of invalid frame-counter, MIC, ...
	HandleRejectedUplinkFrameSet(ctx context.Context, in *HandleRejectedUplinkFrameSetRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

NetworkControllerServiceClient is the client API for NetworkControllerService service.

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

func NewNetworkControllerServiceClient 

func NewNetworkControllerServiceClient(cc grpc.ClientConnInterface) NetworkControllerServiceClient

type NetworkControllerServiceServer 

type NetworkControllerServiceServer interface {
	// HandleUplinkMetaData handles uplink meta-rata.
	HandleUplinkMetaData(context.Context, *HandleUplinkMetaDataRequest) (*emptypb.Empty, error)
	// HandleDownlinkMetaData handles downlink meta-data.
	HandleDownlinkMetaData(context.Context, *HandleDownlinkMetaDataRequest) (*emptypb.Empty, error)
	// HandleUplinkMACCommand handles an uplink mac-command.
	// This method will only be called in case the mac-command request was
	// enqueued throught the API or when the CID is >= 0x80 (proprietary
	// mac-command range).
	HandleUplinkMACCommand(context.Context, *HandleUplinkMACCommandRequest) (*emptypb.Empty, error)
	// HandleRejectedUplinkFrameSet handles a rejected uplink.
	// And uplink can be rejected in the case the device has not (yet) been
	// provisioned, because of invalid frame-counter, MIC, ...
	HandleRejectedUplinkFrameSet(context.Context, *HandleRejectedUplinkFrameSetRequest) (*emptypb.Empty, error)
}

NetworkControllerServiceServer is the server API for NetworkControllerService service.

type UnimplementedNetworkControllerServiceServer 

type UnimplementedNetworkControllerServiceServer struct {
}

UnimplementedNetworkControllerServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedNetworkControllerServiceServer) HandleDownlinkMetaData 

func (*UnimplementedNetworkControllerServiceServer) HandleDownlinkMetaData(ctx context.Context, req *HandleDownlinkMetaDataRequest) (*emptypb.Empty, error)

func (*UnimplementedNetworkControllerServiceServer) HandleRejectedUplinkFrameSet 

func (*UnimplementedNetworkControllerServiceServer) HandleRejectedUplinkFrameSet(ctx context.Context, req *HandleRejectedUplinkFrameSetRequest) (*emptypb.Empty, error)

func (*UnimplementedNetworkControllerServiceServer) HandleUplinkMACCommand 

func (*UnimplementedNetworkControllerServiceServer) HandleUplinkMACCommand(ctx context.Context, req *HandleUplinkMACCommandRequest) (*emptypb.Empty, error)

func (*UnimplementedNetworkControllerServiceServer) HandleUplinkMetaData 

func (*UnimplementedNetworkControllerServiceServer) HandleUplinkMetaData(ctx context.Context, req *HandleUplinkMetaDataRequest) (*emptypb.Empty, 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.