networkserver

package
v2.5.0+incompatible Latest Latest
Warning

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

 Go to latest Published: Feb 7, 2017 License: MIT Imports: 14 Imported by: 0

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

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) GetDevAddr 

func (m *DevicesRequest) GetDevAddr() *types.DevAddr

func (*DevicesRequest) GetFCnt 

func (m *DevicesRequest) GetFCnt() uint32

func (*DevicesRequest) Marshal 

func (m *DevicesRequest) Marshal() (dAtA []byte, err error)

func (*DevicesRequest) MarshalTo 

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

func (m *DevicesResponse) MarshalTo(dAtA []byte) (int, 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 (_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 (_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 (_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 (_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) Descriptor() ([]byte, []int)

func (*Status) GetActivations 

func (m *Status) GetActivations() *api.Rates

func (*Status) GetComponent 

func (m *Status) GetComponent() *api.ComponentStats

func (*Status) GetDevicesPerAddress 

func (m *Status) GetDevicesPerAddress() *api.Percentiles
func (m *Status) GetDownlink() *api.Rates

func (*Status) GetSystem 

func (m *Status) GetSystem() *api.SystemStats
func (m *Status) GetUplink() *api.Rates

func (*Status) Marshal 

func (m *Status) Marshal() (dAtA []byte, err error)

func (*Status) MarshalTo 

func (m *Status) MarshalTo(dAtA []byte) (int, error)

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) Reset 

func (m *Status) Reset()

func (*Status) Size 

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

func (*Status) String 

func (m *Status) String() string

func (*Status) Unmarshal 

func (m *Status) Unmarshal(dAtA []byte) error

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) MarshalTo 

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

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.