router

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: 24 Imported by: 68

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthRouter        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRouter          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupRouter = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterRouterManagerServer 

func RegisterRouterManagerServer(s *grpc.Server, srv RouterManagerServer)

func RegisterRouterServer 

func RegisterRouterServer(s *grpc.Server, srv RouterServer)

Types

type DeviceActivationRequest 

type DeviceActivationRequest struct {
	Payload              []byte                                            `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	Message              *protocol.Message                                 `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	DevEUI               github_com_TheThingsNetwork_ttn_core_types.DevEUI `` /* 131-byte string literal not displayed */
	AppEUI               github_com_TheThingsNetwork_ttn_core_types.AppEUI `` /* 131-byte string literal not displayed */
	ProtocolMetadata     protocol.RxMetadata                               `protobuf:"bytes,21,opt,name=protocol_metadata,json=protocolMetadata,proto3" json:"protocol_metadata"`
	GatewayMetadata      gateway.RxMetadata                                `protobuf:"bytes,22,opt,name=gateway_metadata,json=gatewayMetadata,proto3" json:"gateway_metadata"`
	ActivationMetadata   *protocol.ActivationMetadata                      `protobuf:"bytes,23,opt,name=activation_metadata,json=activationMetadata,proto3" json:"activation_metadata,omitempty"`
	Trace                *trace.Trace                                      `protobuf:"bytes,31,opt,name=trace,proto3" json:"trace,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                          `json:"-"`
	XXX_sizecache        int32                                             `json:"-"`
}

func NewPopulatedDeviceActivationRequest 

func NewPopulatedDeviceActivationRequest(r randyRouter, easy bool) *DeviceActivationRequest

func (*DeviceActivationRequest) Descriptor 

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

func (*DeviceActivationRequest) Equal 

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

func (*DeviceActivationRequest) GetActivationMetadata 

func (m *DeviceActivationRequest) GetActivationMetadata() *protocol.ActivationMetadata

func (*DeviceActivationRequest) GetAppEUI 

func (m *DeviceActivationRequest) GetAppEUI() (eui types.AppEUI)

func (*DeviceActivationRequest) GetDevEUI 

func (m *DeviceActivationRequest) GetDevEUI() (eui types.DevEUI)

func (*DeviceActivationRequest) GetGatewayMetadata 

func (m *DeviceActivationRequest) GetGatewayMetadata() gateway.RxMetadata

func (*DeviceActivationRequest) GetMessage 

func (m *DeviceActivationRequest) GetMessage() *protocol.Message

func (*DeviceActivationRequest) GetPayload 

func (m *DeviceActivationRequest) GetPayload() []byte

func (*DeviceActivationRequest) GetProtocolMetadata 

func (m *DeviceActivationRequest) GetProtocolMetadata() protocol.RxMetadata

func (*DeviceActivationRequest) GetTrace 

func (m *DeviceActivationRequest) GetTrace() *trace.Trace

func (*DeviceActivationRequest) Marshal 

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

func (*DeviceActivationRequest) MarshalPayload 

func (m *DeviceActivationRequest) MarshalPayload() error

MarshalPayload marshals the Message into Payload if Payload is nil

func (*DeviceActivationRequest) MarshalTo 

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

func (*DeviceActivationRequest) MarshalToSizedBuffer 

func (m *DeviceActivationRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeviceActivationRequest) ProtoMessage 

func (*DeviceActivationRequest) ProtoMessage()

func (*DeviceActivationRequest) Reset 

func (m *DeviceActivationRequest) Reset()

func (*DeviceActivationRequest) Size 

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

func (*DeviceActivationRequest) String 

func (this *DeviceActivationRequest) String() string

func (*DeviceActivationRequest) Unmarshal 

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

func (*DeviceActivationRequest) UnmarshalPayload 

func (m *DeviceActivationRequest) UnmarshalPayload() error

UnmarshalPayload unmarshals the Payload into Message if Message is nil

func (*DeviceActivationRequest) Validate 

func (m *DeviceActivationRequest) Validate() error

Validate implements the api.Validator interface

func (*DeviceActivationRequest) XXX_DiscardUnknown 

func (m *DeviceActivationRequest) XXX_DiscardUnknown()

func (*DeviceActivationRequest) XXX_Marshal 

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

func (*DeviceActivationRequest) XXX_Merge 

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

func (*DeviceActivationRequest) XXX_Size 

func (m *DeviceActivationRequest) XXX_Size() int

func (*DeviceActivationRequest) XXX_Unmarshal 

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

type DeviceActivationResponse 

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

func NewPopulatedDeviceActivationResponse 

func NewPopulatedDeviceActivationResponse(r randyRouter, easy bool) *DeviceActivationResponse

func (*DeviceActivationResponse) Descriptor 

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

func (*DeviceActivationResponse) Equal 

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

func (*DeviceActivationResponse) Marshal 

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

func (*DeviceActivationResponse) MarshalTo 

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

func (*DeviceActivationResponse) MarshalToSizedBuffer 

func (m *DeviceActivationResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeviceActivationResponse) ProtoMessage 

func (*DeviceActivationResponse) ProtoMessage()

func (*DeviceActivationResponse) Reset 

func (m *DeviceActivationResponse) Reset()

func (*DeviceActivationResponse) Size 

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

func (*DeviceActivationResponse) String 

func (this *DeviceActivationResponse) String() string

func (*DeviceActivationResponse) Unmarshal 

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

func (*DeviceActivationResponse) XXX_DiscardUnknown 

func (m *DeviceActivationResponse) XXX_DiscardUnknown()

func (*DeviceActivationResponse) XXX_Marshal 

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

func (*DeviceActivationResponse) XXX_Merge 

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

func (*DeviceActivationResponse) XXX_Size 

func (m *DeviceActivationResponse) XXX_Size() int

func (*DeviceActivationResponse) XXX_Unmarshal 

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

type DownlinkMessage 

type DownlinkMessage struct {
	Payload               []byte                   `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	Message               *protocol.Message        `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	ProtocolConfiguration protocol.TxConfiguration `protobuf:"bytes,11,opt,name=protocol_configuration,json=protocolConfiguration,proto3" json:"protocol_configuration"`
	GatewayConfiguration  gateway.TxConfiguration  `protobuf:"bytes,12,opt,name=gateway_configuration,json=gatewayConfiguration,proto3" json:"gateway_configuration"`
	Trace                 *trace.Trace             `protobuf:"bytes,21,opt,name=trace,proto3" json:"trace,omitempty"`
	XXX_NoUnkeyedLiteral  struct{}                 `json:"-"`
	XXX_sizecache         int32                    `json:"-"`
}

func NewPopulatedDownlinkMessage 

func NewPopulatedDownlinkMessage(r randyRouter, easy bool) *DownlinkMessage

func (*DownlinkMessage) Descriptor 

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

func (*DownlinkMessage) Equal 

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

func (*DownlinkMessage) GetGatewayConfiguration 

func (m *DownlinkMessage) GetGatewayConfiguration() gateway.TxConfiguration

func (*DownlinkMessage) GetMessage 

func (m *DownlinkMessage) GetMessage() *protocol.Message

func (*DownlinkMessage) GetPayload 

func (m *DownlinkMessage) GetPayload() []byte

func (*DownlinkMessage) GetProtocolConfiguration 

func (m *DownlinkMessage) GetProtocolConfiguration() protocol.TxConfiguration

func (*DownlinkMessage) GetTrace 

func (m *DownlinkMessage) GetTrace() *trace.Trace

func (*DownlinkMessage) Marshal 

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

func (*DownlinkMessage) MarshalPayload 

func (m *DownlinkMessage) MarshalPayload() error

MarshalPayload marshals the Message into Payload if Payload is nil

func (*DownlinkMessage) MarshalTo 

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

func (*DownlinkMessage) MarshalToSizedBuffer 

func (m *DownlinkMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DownlinkMessage) ProtoMessage 

func (*DownlinkMessage) ProtoMessage()

func (*DownlinkMessage) Reset 

func (m *DownlinkMessage) Reset()

func (*DownlinkMessage) Size 

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

func (*DownlinkMessage) String 

func (this *DownlinkMessage) String() string

func (*DownlinkMessage) Unmarshal 

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

func (*DownlinkMessage) UnmarshalPayload 

func (m *DownlinkMessage) UnmarshalPayload() error

UnmarshalPayload unmarshals the Payload into Message if Message is nil

func (*DownlinkMessage) Validate 

func (m *DownlinkMessage) Validate() error

Validate implements the api.Validator interface

func (*DownlinkMessage) XXX_DiscardUnknown 

func (m *DownlinkMessage) XXX_DiscardUnknown()

func (*DownlinkMessage) XXX_Marshal 

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

func (*DownlinkMessage) XXX_Merge 

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

func (*DownlinkMessage) XXX_Size 

func (m *DownlinkMessage) XXX_Size() int

func (*DownlinkMessage) XXX_Unmarshal 

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

type GatewayStatusRequest 

type GatewayStatusRequest struct {
	GatewayID            string   `protobuf:"bytes,1,opt,name=gateway_id,json=gatewayId,proto3" json:"gateway_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

message GatewayStatusRequest is used to request the status of a gateway from this Router

func NewPopulatedGatewayStatusRequest 

func NewPopulatedGatewayStatusRequest(r randyRouter, easy bool) *GatewayStatusRequest

func (*GatewayStatusRequest) Descriptor 

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

func (*GatewayStatusRequest) Equal 

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

func (*GatewayStatusRequest) GetGatewayID 

func (m *GatewayStatusRequest) GetGatewayID() string

func (*GatewayStatusRequest) Marshal 

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

func (*GatewayStatusRequest) MarshalTo 

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

func (*GatewayStatusRequest) MarshalToSizedBuffer 

func (m *GatewayStatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GatewayStatusRequest) ProtoMessage 

func (*GatewayStatusRequest) ProtoMessage()

func (*GatewayStatusRequest) Reset 

func (m *GatewayStatusRequest) Reset()

func (*GatewayStatusRequest) Size 

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

func (*GatewayStatusRequest) String 

func (this *GatewayStatusRequest) String() string

func (*GatewayStatusRequest) Unmarshal 

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

func (*GatewayStatusRequest) XXX_DiscardUnknown 

func (m *GatewayStatusRequest) XXX_DiscardUnknown()

func (*GatewayStatusRequest) XXX_Marshal 

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

func (*GatewayStatusRequest) XXX_Merge 

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

func (*GatewayStatusRequest) XXX_Size 

func (m *GatewayStatusRequest) XXX_Size() int

func (*GatewayStatusRequest) XXX_Unmarshal 

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

type GatewayStatusResponse 

type GatewayStatusResponse struct {
	LastSeen             int64          `protobuf:"varint,1,opt,name=last_seen,json=lastSeen,proto3" json:"last_seen,omitempty"`
	Status               gateway.Status `protobuf:"bytes,2,opt,name=status,proto3" json:"status"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func NewPopulatedGatewayStatusResponse 

func NewPopulatedGatewayStatusResponse(r randyRouter, easy bool) *GatewayStatusResponse

func (*GatewayStatusResponse) Descriptor 

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

func (*GatewayStatusResponse) Equal 

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

func (*GatewayStatusResponse) GetLastSeen 

func (m *GatewayStatusResponse) GetLastSeen() int64

func (*GatewayStatusResponse) GetStatus 

func (m *GatewayStatusResponse) GetStatus() gateway.Status

func (*GatewayStatusResponse) Marshal 

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

func (*GatewayStatusResponse) MarshalTo 

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

func (*GatewayStatusResponse) MarshalToSizedBuffer 

func (m *GatewayStatusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GatewayStatusResponse) ProtoMessage 

func (*GatewayStatusResponse) ProtoMessage()

func (*GatewayStatusResponse) Reset 

func (m *GatewayStatusResponse) Reset()

func (*GatewayStatusResponse) Size 

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

func (*GatewayStatusResponse) String 

func (this *GatewayStatusResponse) String() string

func (*GatewayStatusResponse) Unmarshal 

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

func (*GatewayStatusResponse) XXX_DiscardUnknown 

func (m *GatewayStatusResponse) XXX_DiscardUnknown()

func (*GatewayStatusResponse) XXX_Marshal 

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

func (*GatewayStatusResponse) XXX_Merge 

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

func (*GatewayStatusResponse) XXX_Size 

func (m *GatewayStatusResponse) XXX_Size() int

func (*GatewayStatusResponse) XXX_Unmarshal 

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

type RouterClient 

type RouterClient interface {
	// Gateway streams status messages to Router
	GatewayStatus(ctx context.Context, opts ...grpc.CallOption) (Router_GatewayStatusClient, error)
	// Gateway streams uplink messages to Router
	Uplink(ctx context.Context, opts ...grpc.CallOption) (Router_UplinkClient, error)
	// Gateway subscribes to downlink messages from Router
	// It is possible to open multiple subscriptions (but not recommended).
	// If you do this, you are responsible for de-duplication of downlink messages.
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (Router_SubscribeClient, error)
	// Gateway requests device activation
	Activate(ctx context.Context, in *DeviceActivationRequest, opts ...grpc.CallOption) (*DeviceActivationResponse, error)
}

RouterClient is the client API for Router service.

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

func NewRouterClient 

func NewRouterClient(cc *grpc.ClientConn) RouterClient

type RouterManagerClient 

type RouterManagerClient interface {
	// Gateway owner or network operator requests Gateway status from Router Manager
	// Deprecated: Use monitor API (NOC) instead of this
	GatewayStatus(ctx context.Context, in *GatewayStatusRequest, opts ...grpc.CallOption) (*GatewayStatusResponse, error)
	// Network operator requests Router status
	GetStatus(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*Status, error)
}

RouterManagerClient is the client API for RouterManager service.

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

func NewRouterManagerClient 

func NewRouterManagerClient(cc *grpc.ClientConn) RouterManagerClient

type RouterManagerServer 

type RouterManagerServer interface {
	// Gateway owner or network operator requests Gateway status from Router Manager
	// Deprecated: Use monitor API (NOC) instead of this
	GatewayStatus(context.Context, *GatewayStatusRequest) (*GatewayStatusResponse, error)
	// Network operator requests Router status
	GetStatus(context.Context, *StatusRequest) (*Status, error)
}

RouterManagerServer is the server API for RouterManager service.

type RouterServer 

type RouterServer interface {
	// Gateway streams status messages to Router
	GatewayStatus(Router_GatewayStatusServer) error
	// Gateway streams uplink messages to Router
	Uplink(Router_UplinkServer) error
	// Gateway subscribes to downlink messages from Router
	// It is possible to open multiple subscriptions (but not recommended).
	// If you do this, you are responsible for de-duplication of downlink messages.
	Subscribe(*SubscribeRequest, Router_SubscribeServer) error
	// Gateway requests device activation
	Activate(context.Context, *DeviceActivationRequest) (*DeviceActivationResponse, error)
}

RouterServer is the server API for Router service.

type Router_GatewayStatusClient 

type Router_GatewayStatusClient interface {
	Send(*gateway.Status) error
	CloseAndRecv() (*types.Empty, error)
	grpc.ClientStream
}

type Router_GatewayStatusServer 

type Router_GatewayStatusServer interface {
	SendAndClose(*types.Empty) error
	Recv() (*gateway.Status, error)
	grpc.ServerStream
}

type Router_SubscribeClient 

type Router_SubscribeClient interface {
	Recv() (*DownlinkMessage, error)
	grpc.ClientStream
}

type Router_SubscribeServer 

type Router_SubscribeServer interface {
	Send(*DownlinkMessage) error
	grpc.ServerStream
}

type Router_UplinkClient 

type Router_UplinkClient interface {
	Send(*UplinkMessage) error
	CloseAndRecv() (*types.Empty, error)
	grpc.ClientStream
}

type Router_UplinkServer 

type Router_UplinkServer interface {
	SendAndClose(*types.Empty) error
	Recv() (*UplinkMessage, error)
	grpc.ServerStream
}

type Status 

type Status struct {
	System        *api.SystemStats    `protobuf:"bytes,1,opt,name=system,proto3" json:"system,omitempty"`
	Component     *api.ComponentStats `protobuf:"bytes,2,opt,name=component,proto3" json:"component,omitempty"`
	GatewayStatus *api.Rates          `protobuf:"bytes,11,opt,name=gateway_status,json=gatewayStatus,proto3" json:"gateway_status,omitempty"`
	Uplink        *api.Rates          `protobuf:"bytes,12,opt,name=uplink,proto3" json:"uplink,omitempty"`
	Downlink      *api.Rates          `protobuf:"bytes,13,opt,name=downlink,proto3" json:"downlink,omitempty"`
	Activations   *api.Rates          `protobuf:"bytes,14,opt,name=activations,proto3" json:"activations,omitempty"`
	// Connections
	ConnectedGateways    uint32   `protobuf:"varint,21,opt,name=connected_gateways,json=connectedGateways,proto3" json:"connected_gateways,omitempty"`
	ConnectedBrokers     uint32   `protobuf:"varint,22,opt,name=connected_brokers,json=connectedBrokers,proto3" json:"connected_brokers,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

message Status is the response to the StatusRequest

func NewPopulatedStatus 

func NewPopulatedStatus(r randyRouter, 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) GetConnectedBrokers 

func (m *Status) GetConnectedBrokers() uint32

func (*Status) GetConnectedGateways 

func (m *Status) GetConnectedGateways() uint32
func (m *Status) GetDownlink() *api.Rates

func (*Status) GetGatewayStatus 

func (m *Status) GetGatewayStatus() *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 Router

func NewPopulatedStatusRequest 

func NewPopulatedStatusRequest(r randyRouter, 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 SubscribeRequest 

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

func NewPopulatedSubscribeRequest 

func NewPopulatedSubscribeRequest(r randyRouter, easy bool) *SubscribeRequest

func (*SubscribeRequest) Descriptor 

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

func (*SubscribeRequest) Equal 

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

func (*SubscribeRequest) Marshal 

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

func (*SubscribeRequest) MarshalTo 

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

func (*SubscribeRequest) MarshalToSizedBuffer 

func (m *SubscribeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SubscribeRequest) ProtoMessage 

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) Reset 

func (m *SubscribeRequest) Reset()

func (*SubscribeRequest) Size 

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

func (*SubscribeRequest) String 

func (this *SubscribeRequest) String() string

func (*SubscribeRequest) Unmarshal 

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

func (*SubscribeRequest) XXX_DiscardUnknown 

func (m *SubscribeRequest) XXX_DiscardUnknown()

func (*SubscribeRequest) XXX_Marshal 

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

func (*SubscribeRequest) XXX_Merge 

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

func (*SubscribeRequest) XXX_Size 

func (m *SubscribeRequest) XXX_Size() int

func (*SubscribeRequest) XXX_Unmarshal 

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

type UnimplementedRouterManagerServer 

type UnimplementedRouterManagerServer struct {
}

UnimplementedRouterManagerServer can be embedded to have forward compatible implementations.

func (*UnimplementedRouterManagerServer) GatewayStatus 

func (*UnimplementedRouterManagerServer) GatewayStatus(ctx context.Context, req *GatewayStatusRequest) (*GatewayStatusResponse, error)

func (*UnimplementedRouterManagerServer) GetStatus 

func (*UnimplementedRouterManagerServer) GetStatus(ctx context.Context, req *StatusRequest) (*Status, error)

type UnimplementedRouterServer 

type UnimplementedRouterServer struct {
}

UnimplementedRouterServer can be embedded to have forward compatible implementations.

func (*UnimplementedRouterServer) Activate 

func (*UnimplementedRouterServer) Activate(ctx context.Context, req *DeviceActivationRequest) (*DeviceActivationResponse, error)

func (*UnimplementedRouterServer) GatewayStatus 

func (*UnimplementedRouterServer) GatewayStatus(srv Router_GatewayStatusServer) error

func (*UnimplementedRouterServer) Subscribe 

func (*UnimplementedRouterServer) Subscribe(req *SubscribeRequest, srv Router_SubscribeServer) error
func (*UnimplementedRouterServer) Uplink(srv Router_UplinkServer) error

type UplinkMessage 

type UplinkMessage struct {
	Payload              []byte              `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	Message              *protocol.Message   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	ProtocolMetadata     protocol.RxMetadata `protobuf:"bytes,11,opt,name=protocol_metadata,json=protocolMetadata,proto3" json:"protocol_metadata"`
	GatewayMetadata      gateway.RxMetadata  `protobuf:"bytes,12,opt,name=gateway_metadata,json=gatewayMetadata,proto3" json:"gateway_metadata"`
	Trace                *trace.Trace        `protobuf:"bytes,21,opt,name=trace,proto3" json:"trace,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func NewPopulatedUplinkMessage 

func NewPopulatedUplinkMessage(r randyRouter, easy bool) *UplinkMessage

func (*UplinkMessage) Descriptor 

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

func (*UplinkMessage) Equal 

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

func (*UplinkMessage) GetGatewayMetadata 

func (m *UplinkMessage) GetGatewayMetadata() gateway.RxMetadata

func (*UplinkMessage) GetMessage 

func (m *UplinkMessage) GetMessage() *protocol.Message

func (*UplinkMessage) GetPayload 

func (m *UplinkMessage) GetPayload() []byte

func (*UplinkMessage) GetProtocolMetadata 

func (m *UplinkMessage) GetProtocolMetadata() protocol.RxMetadata

func (*UplinkMessage) GetTrace 

func (m *UplinkMessage) GetTrace() *trace.Trace

func (*UplinkMessage) Marshal 

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

func (*UplinkMessage) MarshalPayload 

func (m *UplinkMessage) MarshalPayload() error

MarshalPayload marshals the Message into Payload if Payload is nil

func (*UplinkMessage) MarshalTo 

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

func (*UplinkMessage) MarshalToSizedBuffer 

func (m *UplinkMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UplinkMessage) ProtoMessage 

func (*UplinkMessage) ProtoMessage()

func (*UplinkMessage) Reset 

func (m *UplinkMessage) Reset()

func (*UplinkMessage) Size 

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

func (*UplinkMessage) String 

func (this *UplinkMessage) String() string

func (*UplinkMessage) Unmarshal 

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

func (*UplinkMessage) UnmarshalPayload 

func (m *UplinkMessage) UnmarshalPayload() error

UnmarshalPayload unmarshals the Payload into Message if Message is nil

func (*UplinkMessage) Validate 

func (m *UplinkMessage) Validate() error

Validate implements the api.Validator interface

func (*UplinkMessage) XXX_DiscardUnknown 

func (m *UplinkMessage) XXX_DiscardUnknown()

func (*UplinkMessage) XXX_Marshal 

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

func (*UplinkMessage) XXX_Merge 

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

func (*UplinkMessage) XXX_Size 

func (m *UplinkMessage) XXX_Size() int

func (*UplinkMessage) XXX_Unmarshal 

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

Source Files

View all Source files

Directories

Path Synopsis

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.