networkserver

package
v0.0.0-...-228f33a Latest Latest
Warning

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

Go to latest
Published: Aug 18, 2021 License: MIT Imports: 20 Imported by: 24

Documentation

Overview

Package networkserver is a generated GoMock package.

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")
	ErrUnexpectedEndOfGroupNetworkserver = fmt.Errorf("proto: unexpected end of group")
)

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 `` /* 134-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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedDevicesRequest

func NewPopulatedDevicesRequest(r randyNetworkserver, easy bool) *DevicesRequest

func (*DevicesRequest) Descriptor

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

func (*DevicesRequest) Equal

func (this *DevicesRequest) Equal(that interface{}) bool

func (*DevicesRequest) GetDevAddr

func (m *DevicesRequest) GetDevAddr() (addr 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) MarshalToSizedBuffer

func (m *DevicesRequest) MarshalToSizedBuffer(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 (this *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

func (*DevicesRequest) XXX_DiscardUnknown

func (m *DevicesRequest) XXX_DiscardUnknown()

func (*DevicesRequest) XXX_Marshal

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

func (*DevicesRequest) XXX_Merge

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

func (*DevicesRequest) XXX_Size

func (m *DevicesRequest) XXX_Size() int

func (*DevicesRequest) XXX_Unmarshal

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

type DevicesResponse

type DevicesResponse struct {
	Results              []*lorawan.Device `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func NewPopulatedDevicesResponse

func NewPopulatedDevicesResponse(r randyNetworkserver, easy bool) *DevicesResponse

func (*DevicesResponse) Descriptor

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

func (*DevicesResponse) Equal

func (this *DevicesResponse) Equal(that interface{}) bool

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

func (m *DevicesResponse) MarshalToSizedBuffer(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 (this *DevicesResponse) String() string

func (*DevicesResponse) Unmarshal

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

func (*DevicesResponse) XXX_DiscardUnknown

func (m *DevicesResponse) XXX_DiscardUnknown()

func (*DevicesResponse) XXX_Marshal

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

func (*DevicesResponse) XXX_Merge

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

func (*DevicesResponse) XXX_Size

func (m *DevicesResponse) XXX_Size() int

func (*DevicesResponse) XXX_Unmarshal

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

type MockNetworkServerClient

type MockNetworkServerClient struct {
	// contains filtered or unexported fields
}

MockNetworkServerClient is a mock of NetworkServerClient interface

func NewMockNetworkServerClient

func NewMockNetworkServerClient(ctrl *gomock.Controller) *MockNetworkServerClient

NewMockNetworkServerClient creates a new mock instance

func (*MockNetworkServerClient) Activate

Activate mocks base method

Downlink mocks base method

func (*MockNetworkServerClient) EXPECT

EXPECT returns an object that allows the caller to indicate expected use

func (*MockNetworkServerClient) GetDevices

GetDevices mocks base method

func (*MockNetworkServerClient) PrepareActivation

PrepareActivation mocks base method

Uplink mocks base method

type MockNetworkServerClientMockRecorder

type MockNetworkServerClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockNetworkServerClientMockRecorder is the mock recorder for MockNetworkServerClient

func (*MockNetworkServerClientMockRecorder) Activate

func (mr *MockNetworkServerClientMockRecorder) Activate(ctx, in interface{}, opts ...interface{}) *gomock.Call

Activate indicates an expected call of Activate

func (mr *MockNetworkServerClientMockRecorder) Downlink(ctx, in interface{}, opts ...interface{}) *gomock.Call

Downlink indicates an expected call of Downlink

func (*MockNetworkServerClientMockRecorder) GetDevices

func (mr *MockNetworkServerClientMockRecorder) GetDevices(ctx, in interface{}, opts ...interface{}) *gomock.Call

GetDevices indicates an expected call of GetDevices

func (*MockNetworkServerClientMockRecorder) PrepareActivation

func (mr *MockNetworkServerClientMockRecorder) PrepareActivation(ctx, in interface{}, opts ...interface{}) *gomock.Call

PrepareActivation indicates an expected call of PrepareActivation

func (mr *MockNetworkServerClientMockRecorder) Uplink(ctx, in interface{}, opts ...interface{}) *gomock.Call

Uplink indicates an expected call of Uplink

type MockNetworkServerManagerClient

type MockNetworkServerManagerClient struct {
	// contains filtered or unexported fields
}

MockNetworkServerManagerClient is a mock of NetworkServerManagerClient interface

func NewMockNetworkServerManagerClient

func NewMockNetworkServerManagerClient(ctrl *gomock.Controller) *MockNetworkServerManagerClient

NewMockNetworkServerManagerClient creates a new mock instance

func (*MockNetworkServerManagerClient) EXPECT

EXPECT returns an object that allows the caller to indicate expected use

func (*MockNetworkServerManagerClient) GetStatus

GetStatus mocks base method

type MockNetworkServerManagerClientMockRecorder

type MockNetworkServerManagerClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockNetworkServerManagerClientMockRecorder is the mock recorder for MockNetworkServerManagerClient

func (*MockNetworkServerManagerClientMockRecorder) GetStatus

func (mr *MockNetworkServerManagerClientMockRecorder) GetStatus(ctx, in interface{}, opts ...interface{}) *gomock.Call

GetStatus indicates an expected call of GetStatus

type MockNetworkServerManagerServer

type MockNetworkServerManagerServer struct {
	// contains filtered or unexported fields
}

MockNetworkServerManagerServer is a mock of NetworkServerManagerServer interface

func NewMockNetworkServerManagerServer

func NewMockNetworkServerManagerServer(ctrl *gomock.Controller) *MockNetworkServerManagerServer

NewMockNetworkServerManagerServer creates a new mock instance

func (*MockNetworkServerManagerServer) EXPECT

EXPECT returns an object that allows the caller to indicate expected use

func (*MockNetworkServerManagerServer) GetStatus

GetStatus mocks base method

type MockNetworkServerManagerServerMockRecorder

type MockNetworkServerManagerServerMockRecorder struct {
	// contains filtered or unexported fields
}

MockNetworkServerManagerServerMockRecorder is the mock recorder for MockNetworkServerManagerServer

func (*MockNetworkServerManagerServerMockRecorder) GetStatus

func (mr *MockNetworkServerManagerServerMockRecorder) GetStatus(arg0, arg1 interface{}) *gomock.Call

GetStatus indicates an expected call of GetStatus

type MockNetworkServerServer

type MockNetworkServerServer struct {
	// contains filtered or unexported fields
}

MockNetworkServerServer is a mock of NetworkServerServer interface

func NewMockNetworkServerServer

func NewMockNetworkServerServer(ctrl *gomock.Controller) *MockNetworkServerServer

NewMockNetworkServerServer creates a new mock instance

func (*MockNetworkServerServer) Activate

Activate mocks base method

Downlink mocks base method

func (*MockNetworkServerServer) EXPECT

EXPECT returns an object that allows the caller to indicate expected use

func (*MockNetworkServerServer) GetDevices

GetDevices mocks base method

func (*MockNetworkServerServer) PrepareActivation

PrepareActivation mocks base method

Uplink mocks base method

type MockNetworkServerServerMockRecorder

type MockNetworkServerServerMockRecorder struct {
	// contains filtered or unexported fields
}

MockNetworkServerServerMockRecorder is the mock recorder for MockNetworkServerServer

func (*MockNetworkServerServerMockRecorder) Activate

func (mr *MockNetworkServerServerMockRecorder) Activate(arg0, arg1 interface{}) *gomock.Call

Activate indicates an expected call of Activate

func (mr *MockNetworkServerServerMockRecorder) Downlink(arg0, arg1 interface{}) *gomock.Call

Downlink indicates an expected call of Downlink

func (*MockNetworkServerServerMockRecorder) GetDevices

func (mr *MockNetworkServerServerMockRecorder) GetDevices(arg0, arg1 interface{}) *gomock.Call

GetDevices indicates an expected call of GetDevices

func (*MockNetworkServerServerMockRecorder) PrepareActivation

func (mr *MockNetworkServerServerMockRecorder) PrepareActivation(arg0, arg1 interface{}) *gomock.Call

PrepareActivation indicates an expected call of PrepareActivation

func (mr *MockNetworkServerServerMockRecorder) Uplink(arg0, arg1 interface{}) *gomock.Call

Uplink indicates an expected call of Uplink

type MockrandyNetworkserver

type MockrandyNetworkserver struct {
	// contains filtered or unexported fields
}

MockrandyNetworkserver is a mock of randyNetworkserver interface

func NewMockrandyNetworkserver

func NewMockrandyNetworkserver(ctrl *gomock.Controller) *MockrandyNetworkserver

NewMockrandyNetworkserver creates a new mock instance

func (*MockrandyNetworkserver) EXPECT

EXPECT returns an object that allows the caller to indicate expected use

func (*MockrandyNetworkserver) Float32

func (m *MockrandyNetworkserver) Float32() float32

Float32 mocks base method

func (*MockrandyNetworkserver) Float64

func (m *MockrandyNetworkserver) Float64() float64

Float64 mocks base method

func (*MockrandyNetworkserver) Int31

func (m *MockrandyNetworkserver) Int31() int32

Int31 mocks base method

func (*MockrandyNetworkserver) Int63

func (m *MockrandyNetworkserver) Int63() int64

Int63 mocks base method

func (*MockrandyNetworkserver) Intn

func (m *MockrandyNetworkserver) Intn(n int) int

Intn mocks base method

func (*MockrandyNetworkserver) Uint32

func (m *MockrandyNetworkserver) Uint32() uint32

Uint32 mocks base method

type MockrandyNetworkserverMockRecorder

type MockrandyNetworkserverMockRecorder struct {
	// contains filtered or unexported fields
}

MockrandyNetworkserverMockRecorder is the mock recorder for MockrandyNetworkserver

func (*MockrandyNetworkserverMockRecorder) Float32

Float32 indicates an expected call of Float32

func (*MockrandyNetworkserverMockRecorder) Float64

Float64 indicates an expected call of Float64

func (*MockrandyNetworkserverMockRecorder) Int31

Int31 indicates an expected call of Int31

func (*MockrandyNetworkserverMockRecorder) Int63

Int63 indicates an expected call of Int63

func (*MockrandyNetworkserverMockRecorder) Intn

func (mr *MockrandyNetworkserverMockRecorder) Intn(n interface{}) *gomock.Call

Intn indicates an expected call of Intn

func (*MockrandyNetworkserverMockRecorder) Uint32

Uint32 indicates an expected call of Uint32

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

NetworkServerClient is the client API for NetworkServer service.

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

func NewNetworkServerClient

func NewNetworkServerClient(cc *grpc.ClientConn) NetworkServerClient

type NetworkServerManagerClient

type NetworkServerManagerClient interface {
	GetStatus(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*Status, error)
}

NetworkServerManagerClient is the client API for NetworkServerManager service.

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

func NewNetworkServerManagerClient

func NewNetworkServerManagerClient(cc *grpc.ClientConn) NetworkServerManagerClient

type NetworkServerManagerServer

type NetworkServerManagerServer interface {
	GetStatus(context.Context, *StatusRequest) (*Status, error)
}

NetworkServerManagerServer is the server API for NetworkServerManager service.

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

NetworkServerServer is the server API for NetworkServer service.

type Status

type Status struct {
	System               api.SystemStats    `protobuf:"bytes,1,opt,name=system,proto3" json:"system"`
	Component            api.ComponentStats `protobuf:"bytes,2,opt,name=component,proto3" json:"component"`
	Uplink               *api.Rates         `protobuf:"bytes,11,opt,name=uplink,proto3" json:"uplink,omitempty"`
	Downlink             *api.Rates         `protobuf:"bytes,12,opt,name=downlink,proto3" json:"downlink,omitempty"`
	Activations          *api.Rates         `protobuf:"bytes,13,opt,name=activations,proto3" json:"activations,omitempty"`
	DevicesPerAddress    *api.Percentiles   `protobuf:"bytes,21,opt,name=devices_per_address,json=devicesPerAddress,proto3" json:"devices_per_address,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

message Status is the response to the StatusRequest

func NewPopulatedStatus

func NewPopulatedStatus(r randyNetworkserver, easy bool) *Status

func (*Status) Descriptor

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

func (*Status) Equal

func (this *Status) Equal(that interface{}) bool

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

func (m *Status) MarshalToSizedBuffer(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 (this *Status) String() string

func (*Status) Unmarshal

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

func (*Status) XXX_DiscardUnknown

func (m *Status) XXX_DiscardUnknown()

func (*Status) XXX_Marshal

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

func (*Status) XXX_Merge

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

func (*Status) XXX_Size

func (m *Status) XXX_Size() int

func (*Status) XXX_Unmarshal

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

type StatusRequest

type StatusRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

message StatusRequest is used to request the status of this NetworkServer

func NewPopulatedStatusRequest

func NewPopulatedStatusRequest(r randyNetworkserver, easy bool) *StatusRequest

func (*StatusRequest) Descriptor

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

func (*StatusRequest) Equal

func (this *StatusRequest) Equal(that interface{}) bool

func (*StatusRequest) Marshal

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

func (*StatusRequest) MarshalTo

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

func (*StatusRequest) MarshalToSizedBuffer

func (m *StatusRequest) MarshalToSizedBuffer(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 (this *StatusRequest) String() string

func (*StatusRequest) Unmarshal

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

func (*StatusRequest) XXX_DiscardUnknown

func (m *StatusRequest) XXX_DiscardUnknown()

func (*StatusRequest) XXX_Marshal

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

func (*StatusRequest) XXX_Merge

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

func (*StatusRequest) XXX_Size

func (m *StatusRequest) XXX_Size() int

func (*StatusRequest) XXX_Unmarshal

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

type UnimplementedNetworkServerManagerServer

type UnimplementedNetworkServerManagerServer struct {
}

UnimplementedNetworkServerManagerServer can be embedded to have forward compatible implementations.

func (*UnimplementedNetworkServerManagerServer) GetStatus

type UnimplementedNetworkServerServer

type UnimplementedNetworkServerServer struct {
}

UnimplementedNetworkServerServer can be embedded to have forward compatible implementations.

func (*UnimplementedNetworkServerServer) Activate

func (*UnimplementedNetworkServerServer) GetDevices

Jump to

Keyboard shortcuts

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