networkserver

package
v2.0.2+incompatible Latest Latest
Warning

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

Go to latest
Published: Dec 19, 2016 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 {
	DevAddr *github_com_TheThingsNetwork_ttn_core_types.DevAddr `` /* 144-byte string literal not displayed */
	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) 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 (*MockNetworkServerClient) EXPECT

func (_m *MockNetworkServerClient) EXPECT() *_MockNetworkServerClientRecorder

func (*MockNetworkServerClient) GetDevices

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

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 (*MockNetworkServerServer) EXPECT

func (_m *MockNetworkServerServer) EXPECT() *_MockNetworkServerServerRecorder

func (*MockNetworkServerServer) GetDevices

func (_m *MockNetworkServerServer) GetDevices(_param0 context.Context, _param1 *DevicesRequest) (*DevicesResponse, error)

type NetworkServerClient

type NetworkServerClient interface {
	// Broker requests devices with DevAddr for MIC 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
	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 should sign, add 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 for MIC 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
	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 should sign, add 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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL