Documentation
¶
Overview ¶
Package networkserver is a generated protocol buffer package.
It is generated from these files:
github.com/TheThingsNetwork/ttn/api/networkserver/networkserver.proto
It has these top-level messages:
DevicesRequest DevicesResponse StatusRequest Status
Index ¶
- Variables
- func RegisterNetworkServerManagerServer(s *grpc.Server, srv NetworkServerManagerServer)
- func RegisterNetworkServerServer(s *grpc.Server, srv NetworkServerServer)
- type DevicesRequest
- func (*DevicesRequest) Descriptor() ([]byte, []int)
- func (m *DevicesRequest) Marshal() (dAtA []byte, err error)
- func (m *DevicesRequest) MarshalTo(dAtA []byte) (int, error)
- func (*DevicesRequest) ProtoMessage()
- func (m *DevicesRequest) Reset()
- func (m *DevicesRequest) Size() (n int)
- func (m *DevicesRequest) String() string
- func (m *DevicesRequest) Unmarshal(dAtA []byte) error
- func (m *DevicesRequest) Validate() error
- type DevicesResponse
- func (*DevicesResponse) Descriptor() ([]byte, []int)
- func (m *DevicesResponse) GetResults() []*lorawan.Device
- func (m *DevicesResponse) Marshal() (dAtA []byte, err error)
- func (m *DevicesResponse) MarshalTo(dAtA []byte) (int, error)
- func (*DevicesResponse) ProtoMessage()
- func (m *DevicesResponse) Reset()
- func (m *DevicesResponse) Size() (n int)
- func (m *DevicesResponse) String() string
- func (m *DevicesResponse) Unmarshal(dAtA []byte) error
- type MockNetworkServerClient
- func (_m *MockNetworkServerClient) Activate(ctx context.Context, in *handler.DeviceActivationResponse, ...) (*handler.DeviceActivationResponse, error)
- func (_m *MockNetworkServerClient) Downlink(ctx context.Context, in *broker.DownlinkMessage, opts ...grpc.CallOption) (*broker.DownlinkMessage, error)
- func (_m *MockNetworkServerClient) EXPECT() *_MockNetworkServerClientRecorder
- func (_m *MockNetworkServerClient) GetDevices(ctx context.Context, in *DevicesRequest, opts ...grpc.CallOption) (*DevicesResponse, error)
- func (_m *MockNetworkServerClient) PrepareActivation(ctx context.Context, in *broker.DeduplicatedDeviceActivationRequest, ...) (*broker.DeduplicatedDeviceActivationRequest, error)
- func (_m *MockNetworkServerClient) Uplink(ctx context.Context, in *broker.DeduplicatedUplinkMessage, ...) (*broker.DeduplicatedUplinkMessage, error)
- type MockNetworkServerManagerClient
- type MockNetworkServerManagerServer
- type MockNetworkServerServer
- func (_m *MockNetworkServerServer) Activate(_param0 context.Context, _param1 *handler.DeviceActivationResponse) (*handler.DeviceActivationResponse, error)
- func (_m *MockNetworkServerServer) Downlink(_param0 context.Context, _param1 *broker.DownlinkMessage) (*broker.DownlinkMessage, error)
- func (_m *MockNetworkServerServer) EXPECT() *_MockNetworkServerServerRecorder
- func (_m *MockNetworkServerServer) GetDevices(_param0 context.Context, _param1 *DevicesRequest) (*DevicesResponse, error)
- func (_m *MockNetworkServerServer) PrepareActivation(_param0 context.Context, _param1 *broker.DeduplicatedDeviceActivationRequest) (*broker.DeduplicatedDeviceActivationRequest, error)
- func (_m *MockNetworkServerServer) Uplink(_param0 context.Context, _param1 *broker.DeduplicatedUplinkMessage) (*broker.DeduplicatedUplinkMessage, error)
- type NetworkServerClient
- type NetworkServerManagerClient
- type NetworkServerManagerServer
- type NetworkServerServer
- type Status
- func (*Status) Descriptor() ([]byte, []int)
- func (m *Status) GetActivations() *api.Rates
- func (m *Status) GetComponent() *api.ComponentStats
- func (m *Status) GetDevicesPerAddress() *api.Percentiles
- func (m *Status) GetDownlink() *api.Rates
- func (m *Status) GetSystem() *api.SystemStats
- func (m *Status) GetUplink() *api.Rates
- func (m *Status) Marshal() (dAtA []byte, err error)
- func (m *Status) MarshalTo(dAtA []byte) (int, error)
- func (*Status) ProtoMessage()
- func (m *Status) Reset()
- func (m *Status) Size() (n int)
- func (m *Status) String() string
- func (m *Status) Unmarshal(dAtA []byte) error
- type StatusRequest
- func (*StatusRequest) Descriptor() ([]byte, []int)
- func (m *StatusRequest) Marshal() (dAtA []byte, err error)
- func (m *StatusRequest) MarshalTo(dAtA []byte) (int, error)
- func (*StatusRequest) ProtoMessage()
- func (m *StatusRequest) Reset()
- func (m *StatusRequest) Size() (n int)
- func (m *StatusRequest) String() string
- func (m *StatusRequest) Unmarshal(dAtA []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthNetworkserver = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowNetworkserver = fmt.Errorf("proto: integer overflow") )
Functions ¶
func RegisterNetworkServerManagerServer ¶
func RegisterNetworkServerManagerServer(s *grpc.Server, srv NetworkServerManagerServer)
func RegisterNetworkServerServer ¶
func RegisterNetworkServerServer(s *grpc.Server, srv NetworkServerServer)
Types ¶
type DevicesRequest ¶
type DevicesRequest struct { // Device address from the uplink message DevAddr *github_com_TheThingsNetwork_ttn_core_types.DevAddr `` /* 144-byte string literal not displayed */ // Frame counter from the uplink message FCnt uint32 `protobuf:"varint,2,opt,name=f_cnt,json=fCnt,proto3" json:"f_cnt,omitempty"` }
func (*DevicesRequest) Descriptor ¶
func (*DevicesRequest) Descriptor() ([]byte, []int)
func (*DevicesRequest) Marshal ¶
func (m *DevicesRequest) Marshal() (dAtA []byte, err error)
func (*DevicesRequest) ProtoMessage ¶
func (*DevicesRequest) ProtoMessage()
func (*DevicesRequest) Reset ¶
func (m *DevicesRequest) Reset()
func (*DevicesRequest) Size ¶
func (m *DevicesRequest) Size() (n int)
func (*DevicesRequest) String ¶
func (m *DevicesRequest) String() string
func (*DevicesRequest) Unmarshal ¶
func (m *DevicesRequest) Unmarshal(dAtA []byte) error
func (*DevicesRequest) Validate ¶
func (m *DevicesRequest) Validate() error
Validate implements the api.Validator interface
type DevicesResponse ¶
type DevicesResponse struct {
Results []*lorawan.Device `protobuf:"bytes,1,rep,name=results" json:"results,omitempty"`
}
func (*DevicesResponse) Descriptor ¶
func (*DevicesResponse) Descriptor() ([]byte, []int)
func (*DevicesResponse) GetResults ¶
func (m *DevicesResponse) GetResults() []*lorawan.Device
func (*DevicesResponse) Marshal ¶
func (m *DevicesResponse) Marshal() (dAtA []byte, err error)
func (*DevicesResponse) ProtoMessage ¶
func (*DevicesResponse) ProtoMessage()
func (*DevicesResponse) Reset ¶
func (m *DevicesResponse) Reset()
func (*DevicesResponse) Size ¶
func (m *DevicesResponse) Size() (n int)
func (*DevicesResponse) String ¶
func (m *DevicesResponse) String() string
func (*DevicesResponse) Unmarshal ¶
func (m *DevicesResponse) Unmarshal(dAtA []byte) error
type MockNetworkServerClient ¶
type MockNetworkServerClient struct {
// contains filtered or unexported fields
}
Mock of NetworkServerClient interface
func NewMockNetworkServerClient ¶
func NewMockNetworkServerClient(ctrl *gomock.Controller) *MockNetworkServerClient
func (*MockNetworkServerClient) Activate ¶
func (_m *MockNetworkServerClient) Activate(ctx context.Context, in *handler.DeviceActivationResponse, opts ...grpc.CallOption) (*handler.DeviceActivationResponse, error)
func (*MockNetworkServerClient) Downlink ¶
func (_m *MockNetworkServerClient) Downlink(ctx context.Context, in *broker.DownlinkMessage, opts ...grpc.CallOption) (*broker.DownlinkMessage, error)
func (*MockNetworkServerClient) EXPECT ¶
func (_m *MockNetworkServerClient) EXPECT() *_MockNetworkServerClientRecorder
func (*MockNetworkServerClient) GetDevices ¶
func (_m *MockNetworkServerClient) GetDevices(ctx context.Context, in *DevicesRequest, opts ...grpc.CallOption) (*DevicesResponse, error)
func (*MockNetworkServerClient) PrepareActivation ¶
func (_m *MockNetworkServerClient) PrepareActivation(ctx context.Context, in *broker.DeduplicatedDeviceActivationRequest, opts ...grpc.CallOption) (*broker.DeduplicatedDeviceActivationRequest, error)
func (*MockNetworkServerClient) Uplink ¶
func (_m *MockNetworkServerClient) Uplink(ctx context.Context, in *broker.DeduplicatedUplinkMessage, opts ...grpc.CallOption) (*broker.DeduplicatedUplinkMessage, error)
type MockNetworkServerManagerClient ¶
type MockNetworkServerManagerClient struct {
// contains filtered or unexported fields
}
Mock of NetworkServerManagerClient interface
func NewMockNetworkServerManagerClient ¶
func NewMockNetworkServerManagerClient(ctrl *gomock.Controller) *MockNetworkServerManagerClient
func (*MockNetworkServerManagerClient) EXPECT ¶
func (_m *MockNetworkServerManagerClient) EXPECT() *_MockNetworkServerManagerClientRecorder
func (*MockNetworkServerManagerClient) GetStatus ¶
func (_m *MockNetworkServerManagerClient) GetStatus(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*Status, error)
type MockNetworkServerManagerServer ¶
type MockNetworkServerManagerServer struct {
// contains filtered or unexported fields
}
Mock of NetworkServerManagerServer interface
func NewMockNetworkServerManagerServer ¶
func NewMockNetworkServerManagerServer(ctrl *gomock.Controller) *MockNetworkServerManagerServer
func (*MockNetworkServerManagerServer) EXPECT ¶
func (_m *MockNetworkServerManagerServer) EXPECT() *_MockNetworkServerManagerServerRecorder
func (*MockNetworkServerManagerServer) GetStatus ¶
func (_m *MockNetworkServerManagerServer) GetStatus(_param0 context.Context, _param1 *StatusRequest) (*Status, error)
type MockNetworkServerServer ¶
type MockNetworkServerServer struct {
// contains filtered or unexported fields
}
Mock of NetworkServerServer interface
func NewMockNetworkServerServer ¶
func NewMockNetworkServerServer(ctrl *gomock.Controller) *MockNetworkServerServer
func (*MockNetworkServerServer) Activate ¶
func (_m *MockNetworkServerServer) Activate(_param0 context.Context, _param1 *handler.DeviceActivationResponse) (*handler.DeviceActivationResponse, error)
func (*MockNetworkServerServer) Downlink ¶
func (_m *MockNetworkServerServer) Downlink(_param0 context.Context, _param1 *broker.DownlinkMessage) (*broker.DownlinkMessage, error)
func (*MockNetworkServerServer) EXPECT ¶
func (_m *MockNetworkServerServer) EXPECT() *_MockNetworkServerServerRecorder
func (*MockNetworkServerServer) GetDevices ¶
func (_m *MockNetworkServerServer) GetDevices(_param0 context.Context, _param1 *DevicesRequest) (*DevicesResponse, error)
func (*MockNetworkServerServer) PrepareActivation ¶
func (_m *MockNetworkServerServer) PrepareActivation(_param0 context.Context, _param1 *broker.DeduplicatedDeviceActivationRequest) (*broker.DeduplicatedDeviceActivationRequest, error)
func (*MockNetworkServerServer) Uplink ¶
func (_m *MockNetworkServerServer) Uplink(_param0 context.Context, _param1 *broker.DeduplicatedUplinkMessage) (*broker.DeduplicatedUplinkMessage, error)
type NetworkServerClient ¶
type NetworkServerClient interface { // Broker requests devices with DevAddr and matching FCnt (or disabled FCnt check) GetDevices(ctx context.Context, in *DevicesRequest, opts ...grpc.CallOption) (*DevicesResponse, error) // Broker requests device activation "template" from Network Server PrepareActivation(ctx context.Context, in *broker.DeduplicatedDeviceActivationRequest, opts ...grpc.CallOption) (*broker.DeduplicatedDeviceActivationRequest, error) // Broker confirms device activation (after response from Handler) Activate(ctx context.Context, in *handler.DeviceActivationResponse, opts ...grpc.CallOption) (*handler.DeviceActivationResponse, error) // Broker informs Network Server about Uplink Uplink(ctx context.Context, in *broker.DeduplicatedUplinkMessage, opts ...grpc.CallOption) (*broker.DeduplicatedUplinkMessage, error) // Broker informs Network Server about Downlink, NetworkServer may add MAC commands and re-set MIC Downlink(ctx context.Context, in *broker.DownlinkMessage, opts ...grpc.CallOption) (*broker.DownlinkMessage, error) }
func NewNetworkServerClient ¶
func NewNetworkServerClient(cc *grpc.ClientConn) NetworkServerClient
type NetworkServerManagerClient ¶
type NetworkServerManagerClient interface {
GetStatus(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*Status, error)
}
func NewNetworkServerManagerClient ¶
func NewNetworkServerManagerClient(cc *grpc.ClientConn) NetworkServerManagerClient
type NetworkServerManagerServer ¶
type NetworkServerManagerServer interface {
GetStatus(context.Context, *StatusRequest) (*Status, error)
}
type NetworkServerServer ¶
type NetworkServerServer interface { // Broker requests devices with DevAddr and matching FCnt (or disabled FCnt check) GetDevices(context.Context, *DevicesRequest) (*DevicesResponse, error) // Broker requests device activation "template" from Network Server PrepareActivation(context.Context, *broker.DeduplicatedDeviceActivationRequest) (*broker.DeduplicatedDeviceActivationRequest, error) // Broker confirms device activation (after response from Handler) Activate(context.Context, *handler.DeviceActivationResponse) (*handler.DeviceActivationResponse, error) // Broker informs Network Server about Uplink Uplink(context.Context, *broker.DeduplicatedUplinkMessage) (*broker.DeduplicatedUplinkMessage, error) // Broker informs Network Server about Downlink, NetworkServer may add MAC commands and re-set MIC Downlink(context.Context, *broker.DownlinkMessage) (*broker.DownlinkMessage, error) }
type Status ¶
type Status struct { System *api.SystemStats `protobuf:"bytes,1,opt,name=system" json:"system,omitempty"` Component *api.ComponentStats `protobuf:"bytes,2,opt,name=component" json:"component,omitempty"` Uplink *api.Rates `protobuf:"bytes,11,opt,name=uplink" json:"uplink,omitempty"` Downlink *api.Rates `protobuf:"bytes,12,opt,name=downlink" json:"downlink,omitempty"` Activations *api.Rates `protobuf:"bytes,13,opt,name=activations" json:"activations,omitempty"` DevicesPerAddress *api.Percentiles `protobuf:"bytes,21,opt,name=devices_per_address,json=devicesPerAddress" json:"devices_per_address,omitempty"` }
message Status is the response to the StatusRequest
func (*Status) Descriptor ¶
func (*Status) GetActivations ¶
func (*Status) GetComponent ¶
func (m *Status) GetComponent() *api.ComponentStats
func (*Status) GetDevicesPerAddress ¶
func (m *Status) GetDevicesPerAddress() *api.Percentiles
func (*Status) GetDownlink ¶
func (*Status) GetSystem ¶
func (m *Status) GetSystem() *api.SystemStats
func (*Status) ProtoMessage ¶
func (*Status) ProtoMessage()
type StatusRequest ¶
type StatusRequest struct { }
message StatusRequest is used to request the status of this NetworkServer
func (*StatusRequest) Descriptor ¶
func (*StatusRequest) Descriptor() ([]byte, []int)
func (*StatusRequest) Marshal ¶
func (m *StatusRequest) Marshal() (dAtA []byte, err error)
func (*StatusRequest) ProtoMessage ¶
func (*StatusRequest) ProtoMessage()
func (*StatusRequest) Reset ¶
func (m *StatusRequest) Reset()
func (*StatusRequest) Size ¶
func (m *StatusRequest) Size() (n int)
func (*StatusRequest) String ¶
func (m *StatusRequest) String() string
func (*StatusRequest) Unmarshal ¶
func (m *StatusRequest) Unmarshal(dAtA []byte) error
Click to show internal directories.
Click to hide internal directories.