Documentation ¶
Overview ¶
Package networkserver is a generated GoMock package.
Index ¶
- Variables
- func RegisterNetworkServerManagerServer(s *grpc.Server, srv NetworkServerManagerServer)
- func RegisterNetworkServerServer(s *grpc.Server, srv NetworkServerServer)
- type DevicesRequest
- func (*DevicesRequest) Descriptor() ([]byte, []int)
- func (this *DevicesRequest) Equal(that interface{}) bool
- func (m *DevicesRequest) GetDevAddr() (addr types.DevAddr)
- func (m *DevicesRequest) GetFCnt() uint32
- func (m *DevicesRequest) Marshal() (dAtA []byte, err error)
- func (m *DevicesRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *DevicesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DevicesRequest) ProtoMessage()
- func (m *DevicesRequest) Reset()
- func (m *DevicesRequest) Size() (n int)
- func (this *DevicesRequest) String() string
- func (m *DevicesRequest) Unmarshal(dAtA []byte) error
- func (m *DevicesRequest) Validate() error
- func (m *DevicesRequest) XXX_DiscardUnknown()
- func (m *DevicesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DevicesRequest) XXX_Merge(src proto.Message)
- func (m *DevicesRequest) XXX_Size() int
- func (m *DevicesRequest) XXX_Unmarshal(b []byte) error
- type DevicesResponse
- func (*DevicesResponse) Descriptor() ([]byte, []int)
- func (this *DevicesResponse) Equal(that interface{}) bool
- func (m *DevicesResponse) GetResults() []*lorawan.Device
- func (m *DevicesResponse) Marshal() (dAtA []byte, err error)
- func (m *DevicesResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *DevicesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DevicesResponse) ProtoMessage()
- func (m *DevicesResponse) Reset()
- func (m *DevicesResponse) Size() (n int)
- func (this *DevicesResponse) String() string
- func (m *DevicesResponse) Unmarshal(dAtA []byte) error
- func (m *DevicesResponse) XXX_DiscardUnknown()
- func (m *DevicesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DevicesResponse) XXX_Merge(src proto.Message)
- func (m *DevicesResponse) XXX_Size() int
- func (m *DevicesResponse) XXX_Unmarshal(b []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() *MockNetworkServerClientMockRecorder
- 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 MockNetworkServerClientMockRecorder
- func (mr *MockNetworkServerClientMockRecorder) Activate(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockNetworkServerClientMockRecorder) Downlink(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockNetworkServerClientMockRecorder) GetDevices(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockNetworkServerClientMockRecorder) PrepareActivation(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockNetworkServerClientMockRecorder) Uplink(ctx, in interface{}, opts ...interface{}) *gomock.Call
- type MockNetworkServerManagerClient
- type MockNetworkServerManagerClientMockRecorder
- type MockNetworkServerManagerServer
- type MockNetworkServerManagerServerMockRecorder
- type MockNetworkServerServer
- func (m *MockNetworkServerServer) Activate(arg0 context.Context, arg1 *handler.DeviceActivationResponse) (*handler.DeviceActivationResponse, error)
- func (m *MockNetworkServerServer) Downlink(arg0 context.Context, arg1 *broker.DownlinkMessage) (*broker.DownlinkMessage, error)
- func (m *MockNetworkServerServer) EXPECT() *MockNetworkServerServerMockRecorder
- func (m *MockNetworkServerServer) GetDevices(arg0 context.Context, arg1 *DevicesRequest) (*DevicesResponse, error)
- func (m *MockNetworkServerServer) PrepareActivation(arg0 context.Context, arg1 *broker.DeduplicatedDeviceActivationRequest) (*broker.DeduplicatedDeviceActivationRequest, error)
- func (m *MockNetworkServerServer) Uplink(arg0 context.Context, arg1 *broker.DeduplicatedUplinkMessage) (*broker.DeduplicatedUplinkMessage, error)
- type MockNetworkServerServerMockRecorder
- func (mr *MockNetworkServerServerMockRecorder) Activate(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockNetworkServerServerMockRecorder) Downlink(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockNetworkServerServerMockRecorder) GetDevices(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockNetworkServerServerMockRecorder) PrepareActivation(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockNetworkServerServerMockRecorder) Uplink(arg0, arg1 interface{}) *gomock.Call
- type MockrandyNetworkserver
- func (m *MockrandyNetworkserver) EXPECT() *MockrandyNetworkserverMockRecorder
- func (m *MockrandyNetworkserver) Float32() float32
- func (m *MockrandyNetworkserver) Float64() float64
- func (m *MockrandyNetworkserver) Int31() int32
- func (m *MockrandyNetworkserver) Int63() int64
- func (m *MockrandyNetworkserver) Intn(n int) int
- func (m *MockrandyNetworkserver) Uint32() uint32
- type MockrandyNetworkserverMockRecorder
- func (mr *MockrandyNetworkserverMockRecorder) Float32() *gomock.Call
- func (mr *MockrandyNetworkserverMockRecorder) Float64() *gomock.Call
- func (mr *MockrandyNetworkserverMockRecorder) Int31() *gomock.Call
- func (mr *MockrandyNetworkserverMockRecorder) Int63() *gomock.Call
- func (mr *MockrandyNetworkserverMockRecorder) Intn(n interface{}) *gomock.Call
- func (mr *MockrandyNetworkserverMockRecorder) Uint32() *gomock.Call
- type NetworkServerClient
- type NetworkServerManagerClient
- type NetworkServerManagerServer
- type NetworkServerServer
- type Status
- func (*Status) Descriptor() ([]byte, []int)
- func (this *Status) Equal(that interface{}) bool
- 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 (m *Status) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Status) ProtoMessage()
- func (m *Status) Reset()
- func (m *Status) Size() (n int)
- func (this *Status) String() string
- func (m *Status) Unmarshal(dAtA []byte) error
- func (m *Status) XXX_DiscardUnknown()
- func (m *Status) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Status) XXX_Merge(src proto.Message)
- func (m *Status) XXX_Size() int
- func (m *Status) XXX_Unmarshal(b []byte) error
- type StatusRequest
- func (*StatusRequest) Descriptor() ([]byte, []int)
- func (this *StatusRequest) Equal(that interface{}) bool
- func (m *StatusRequest) Marshal() (dAtA []byte, err error)
- func (m *StatusRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *StatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StatusRequest) ProtoMessage()
- func (m *StatusRequest) Reset()
- func (m *StatusRequest) Size() (n int)
- func (this *StatusRequest) String() string
- func (m *StatusRequest) Unmarshal(dAtA []byte) error
- func (m *StatusRequest) XXX_DiscardUnknown()
- func (m *StatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StatusRequest) XXX_Merge(src proto.Message)
- func (m *StatusRequest) XXX_Size() int
- func (m *StatusRequest) XXX_Unmarshal(b []byte) error
- type UnimplementedNetworkServerManagerServer
- type UnimplementedNetworkServerServer
- func (*UnimplementedNetworkServerServer) Activate(ctx context.Context, req *handler.DeviceActivationResponse) (*handler.DeviceActivationResponse, error)
- func (*UnimplementedNetworkServerServer) Downlink(ctx context.Context, req *broker.DownlinkMessage) (*broker.DownlinkMessage, error)
- func (*UnimplementedNetworkServerServer) GetDevices(ctx context.Context, req *DevicesRequest) (*DevicesResponse, error)
- func (*UnimplementedNetworkServerServer) PrepareActivation(ctx context.Context, req *broker.DeduplicatedDeviceActivationRequest) (*broker.DeduplicatedDeviceActivationRequest, error)
- func (*UnimplementedNetworkServerServer) Uplink(ctx context.Context, req *broker.DeduplicatedUplinkMessage) (*broker.DeduplicatedUplinkMessage, error)
Constants ¶
This section is empty.
Variables ¶
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) 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) 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 ¶
func (m *MockNetworkServerClient) Activate(ctx context.Context, in *handler.DeviceActivationResponse, opts ...grpc.CallOption) (*handler.DeviceActivationResponse, error)
Activate mocks base method
func (*MockNetworkServerClient) Downlink ¶
func (m *MockNetworkServerClient) Downlink(ctx context.Context, in *broker.DownlinkMessage, opts ...grpc.CallOption) (*broker.DownlinkMessage, error)
Downlink mocks base method
func (*MockNetworkServerClient) EXPECT ¶
func (m *MockNetworkServerClient) EXPECT() *MockNetworkServerClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockNetworkServerClient) GetDevices ¶
func (m *MockNetworkServerClient) GetDevices(ctx context.Context, in *DevicesRequest, opts ...grpc.CallOption) (*DevicesResponse, error)
GetDevices mocks base method
func (*MockNetworkServerClient) PrepareActivation ¶
func (m *MockNetworkServerClient) PrepareActivation(ctx context.Context, in *broker.DeduplicatedDeviceActivationRequest, opts ...grpc.CallOption) (*broker.DeduplicatedDeviceActivationRequest, error)
PrepareActivation mocks base method
func (*MockNetworkServerClient) Uplink ¶
func (m *MockNetworkServerClient) Uplink(ctx context.Context, in *broker.DeduplicatedUplinkMessage, opts ...grpc.CallOption) (*broker.DeduplicatedUplinkMessage, error)
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 (*MockNetworkServerClientMockRecorder) Downlink ¶
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 (*MockNetworkServerClientMockRecorder) Uplink ¶
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 ¶
func (m *MockNetworkServerManagerClient) EXPECT() *MockNetworkServerManagerClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockNetworkServerManagerClient) GetStatus ¶
func (m *MockNetworkServerManagerClient) GetStatus(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*Status, error)
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 ¶
func (m *MockNetworkServerManagerServer) EXPECT() *MockNetworkServerManagerServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockNetworkServerManagerServer) GetStatus ¶
func (m *MockNetworkServerManagerServer) GetStatus(arg0 context.Context, arg1 *StatusRequest) (*Status, error)
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 ¶
func (m *MockNetworkServerServer) Activate(arg0 context.Context, arg1 *handler.DeviceActivationResponse) (*handler.DeviceActivationResponse, error)
Activate mocks base method
func (*MockNetworkServerServer) Downlink ¶
func (m *MockNetworkServerServer) Downlink(arg0 context.Context, arg1 *broker.DownlinkMessage) (*broker.DownlinkMessage, error)
Downlink mocks base method
func (*MockNetworkServerServer) EXPECT ¶
func (m *MockNetworkServerServer) EXPECT() *MockNetworkServerServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockNetworkServerServer) GetDevices ¶
func (m *MockNetworkServerServer) GetDevices(arg0 context.Context, arg1 *DevicesRequest) (*DevicesResponse, error)
GetDevices mocks base method
func (*MockNetworkServerServer) PrepareActivation ¶
func (m *MockNetworkServerServer) PrepareActivation(arg0 context.Context, arg1 *broker.DeduplicatedDeviceActivationRequest) (*broker.DeduplicatedDeviceActivationRequest, error)
PrepareActivation mocks base method
func (*MockNetworkServerServer) Uplink ¶
func (m *MockNetworkServerServer) Uplink(arg0 context.Context, arg1 *broker.DeduplicatedUplinkMessage) (*broker.DeduplicatedUplinkMessage, error)
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 (*MockNetworkServerServerMockRecorder) Downlink ¶
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 (*MockNetworkServerServerMockRecorder) Uplink ¶
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 ¶
func (m *MockrandyNetworkserver) EXPECT() *MockrandyNetworkserverMockRecorder
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 ¶
func (mr *MockrandyNetworkserverMockRecorder) Float32() *gomock.Call
Float32 indicates an expected call of Float32
func (*MockrandyNetworkserverMockRecorder) Float64 ¶
func (mr *MockrandyNetworkserverMockRecorder) Float64() *gomock.Call
Float64 indicates an expected call of Float64
func (*MockrandyNetworkserverMockRecorder) Int31 ¶
func (mr *MockrandyNetworkserverMockRecorder) Int31() *gomock.Call
Int31 indicates an expected call of Int31
func (*MockrandyNetworkserverMockRecorder) Int63 ¶
func (mr *MockrandyNetworkserverMockRecorder) Int63() *gomock.Call
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 ¶
func (mr *MockrandyNetworkserverMockRecorder) Uint32() *gomock.Call
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 (*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) MarshalToSizedBuffer ¶
func (*Status) ProtoMessage ¶
func (*Status) ProtoMessage()
func (*Status) XXX_DiscardUnknown ¶
func (m *Status) XXX_DiscardUnknown()
func (*Status) XXX_Marshal ¶
func (*Status) XXX_Unmarshal ¶
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) 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 ¶
func (*UnimplementedNetworkServerManagerServer) GetStatus(ctx context.Context, req *StatusRequest) (*Status, error)
type UnimplementedNetworkServerServer ¶
type UnimplementedNetworkServerServer struct { }
UnimplementedNetworkServerServer can be embedded to have forward compatible implementations.
func (*UnimplementedNetworkServerServer) Activate ¶
func (*UnimplementedNetworkServerServer) Activate(ctx context.Context, req *handler.DeviceActivationResponse) (*handler.DeviceActivationResponse, error)
func (*UnimplementedNetworkServerServer) Downlink ¶
func (*UnimplementedNetworkServerServer) Downlink(ctx context.Context, req *broker.DownlinkMessage) (*broker.DownlinkMessage, error)
func (*UnimplementedNetworkServerServer) GetDevices ¶
func (*UnimplementedNetworkServerServer) GetDevices(ctx context.Context, req *DevicesRequest) (*DevicesResponse, error)
func (*UnimplementedNetworkServerServer) PrepareActivation ¶
func (*UnimplementedNetworkServerServer) PrepareActivation(ctx context.Context, req *broker.DeduplicatedDeviceActivationRequest) (*broker.DeduplicatedDeviceActivationRequest, error)
func (*UnimplementedNetworkServerServer) Uplink ¶
func (*UnimplementedNetworkServerServer) Uplink(ctx context.Context, req *broker.DeduplicatedUplinkMessage) (*broker.DeduplicatedUplinkMessage, error)