router

package
v0.0.0-...-49646fe Latest Latest
Warning

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

 Go to latest Published: Oct 31, 2022 License: Apache-2.0 Imports: 9 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_router_router_proto protoreflect.FileDescriptor
View Source 
var RouterV1_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "router.RouterV1",
	HandlerType: (*RouterV1Server)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "NetIds",
			Handler:    _RouterV1_NetIds_Handler,
		},
		{
			MethodName: "JoinFilter",
			Handler:    _RouterV1_JoinFilter_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Events",
			Handler:       _RouterV1_Events_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "router/router.proto",
}

RouterV1_ServiceDesc is the grpc.ServiceDesc for RouterV1 service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterRouterV1Server 

func RegisterRouterV1Server(s grpc.ServiceRegistrar, srv RouterV1Server)

Types

type AirtimePaymentEvent 

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

func (*AirtimePaymentEvent) Descriptor deprecated 

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

Deprecated: Use AirtimePaymentEvent.ProtoReflect.Descriptor instead.

func (*AirtimePaymentEvent) ProtoMessage 

func (*AirtimePaymentEvent) ProtoMessage()

func (*AirtimePaymentEvent) ProtoReflect 

func (x *AirtimePaymentEvent) ProtoReflect() protoreflect.Message

func (*AirtimePaymentEvent) Reset 

func (x *AirtimePaymentEvent) Reset()

func (*AirtimePaymentEvent) String 

func (x *AirtimePaymentEvent) String() string

type AirtimeReceipt 

type AirtimeReceipt struct {
	Owner   []byte `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	Airtime uint32 `protobuf:"varint,2,opt,name=airtime,proto3" json:"airtime,omitempty"`
	// contains filtered or unexported fields
}

func (*AirtimeReceipt) Descriptor deprecated 

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

Deprecated: Use AirtimeReceipt.ProtoReflect.Descriptor instead.

func (*AirtimeReceipt) GetAirtime 

func (x *AirtimeReceipt) GetAirtime() uint32

func (*AirtimeReceipt) GetOwner 

func (x *AirtimeReceipt) GetOwner() []byte

func (*AirtimeReceipt) ProtoMessage 

func (*AirtimeReceipt) ProtoMessage()

func (*AirtimeReceipt) ProtoReflect 

func (x *AirtimeReceipt) ProtoReflect() protoreflect.Message

func (*AirtimeReceipt) Reset 

func (x *AirtimeReceipt) Reset()

func (*AirtimeReceipt) String 

func (x *AirtimeReceipt) String() string

type DownlinkFrameEvent 

type DownlinkFrameEvent struct {
	DownlinkFrame *gw.DownlinkFrame `protobuf:"bytes,2,opt,name=downlinkFrame,proto3" json:"downlinkFrame,omitempty"`
	// contains filtered or unexported fields
}

func (*DownlinkFrameEvent) Descriptor deprecated 

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

Deprecated: Use DownlinkFrameEvent.ProtoReflect.Descriptor instead.

func (*DownlinkFrameEvent) GetDownlinkFrame 

func (x *DownlinkFrameEvent) GetDownlinkFrame() *gw.DownlinkFrame

func (*DownlinkFrameEvent) ProtoMessage 

func (*DownlinkFrameEvent) ProtoMessage()

func (*DownlinkFrameEvent) ProtoReflect 

func (x *DownlinkFrameEvent) ProtoReflect() protoreflect.Message

func (*DownlinkFrameEvent) Reset 

func (x *DownlinkFrameEvent) Reset()

func (*DownlinkFrameEvent) String 

func (x *DownlinkFrameEvent) String() string

type DownlinkTXAckEvent 

type DownlinkTXAckEvent struct {
	DownlinkTXAck  *gw.DownlinkTXAck `protobuf:"bytes,1,opt,name=downlinkTXAck,proto3" json:"downlinkTXAck,omitempty"`
	AirtimeReceipt *AirtimeReceipt   `protobuf:"bytes,2,opt,name=airtimeReceipt,proto3" json:"airtimeReceipt,omitempty"`
	// contains filtered or unexported fields
}

func (*DownlinkTXAckEvent) Descriptor deprecated 

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

Deprecated: Use DownlinkTXAckEvent.ProtoReflect.Descriptor instead.

func (*DownlinkTXAckEvent) GetAirtimeReceipt 

func (x *DownlinkTXAckEvent) GetAirtimeReceipt() *AirtimeReceipt

func (*DownlinkTXAckEvent) GetDownlinkTXAck 

func (x *DownlinkTXAckEvent) GetDownlinkTXAck() *gw.DownlinkTXAck

func (*DownlinkTXAckEvent) ProtoMessage 

func (*DownlinkTXAckEvent) ProtoMessage()

func (*DownlinkTXAckEvent) ProtoReflect 

func (x *DownlinkTXAckEvent) ProtoReflect() protoreflect.Message

func (*DownlinkTXAckEvent) Reset 

func (x *DownlinkTXAckEvent) Reset()

func (*DownlinkTXAckEvent) String 

func (x *DownlinkTXAckEvent) String() string

type GatewayInformation 

type GatewayInformation struct {
	PublicKey []byte `protobuf:"bytes,1,opt,name=publicKey,proto3" json:"publicKey,omitempty"`
	Owner     []byte `protobuf:"bytes,2,opt,name=owner,proto3" json:"owner,omitempty"`
	// contains filtered or unexported fields
}

func (*GatewayInformation) Descriptor deprecated 

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

Deprecated: Use GatewayInformation.ProtoReflect.Descriptor instead.

func (*GatewayInformation) GetOwner 

func (x *GatewayInformation) GetOwner() []byte

func (*GatewayInformation) GetPublicKey 

func (x *GatewayInformation) GetPublicKey() []byte

func (*GatewayInformation) ProtoMessage 

func (*GatewayInformation) ProtoMessage()

func (*GatewayInformation) ProtoReflect 

func (x *GatewayInformation) ProtoReflect() protoreflect.Message

func (*GatewayInformation) Reset 

func (x *GatewayInformation) Reset()

func (*GatewayInformation) String 

func (x *GatewayInformation) String() string

type GatewayToRouterEvent 

type GatewayToRouterEvent struct {
	GatewayInformation *GatewayInformation `protobuf:"bytes,1,opt,name=gatewayInformation,proto3" json:"gatewayInformation,omitempty"`
	// Types that are assignable to Event:
	//
	//	*GatewayToRouterEvent_UplinkFrameEvent
	//	*GatewayToRouterEvent_DownlinkTXAckEvent
	//	*GatewayToRouterEvent_StatusEvent
	Event isGatewayToRouterEvent_Event `protobuf_oneof:"event"`
	// contains filtered or unexported fields
}

func (*GatewayToRouterEvent) Descriptor deprecated 

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

Deprecated: Use GatewayToRouterEvent.ProtoReflect.Descriptor instead.

func (*GatewayToRouterEvent) GetDownlinkTXAckEvent 

func (x *GatewayToRouterEvent) GetDownlinkTXAckEvent() *DownlinkTXAckEvent

func (*GatewayToRouterEvent) GetEvent 

func (m *GatewayToRouterEvent) GetEvent() isGatewayToRouterEvent_Event

func (*GatewayToRouterEvent) GetGatewayInformation 

func (x *GatewayToRouterEvent) GetGatewayInformation() *GatewayInformation

func (*GatewayToRouterEvent) GetStatusEvent 

func (x *GatewayToRouterEvent) GetStatusEvent() *StatusEvent

func (*GatewayToRouterEvent) GetUplinkFrameEvent 

func (x *GatewayToRouterEvent) GetUplinkFrameEvent() *UplinkFrameEvent

func (*GatewayToRouterEvent) ProtoMessage 

func (*GatewayToRouterEvent) ProtoMessage()

func (*GatewayToRouterEvent) ProtoReflect 

func (x *GatewayToRouterEvent) ProtoReflect() protoreflect.Message

func (*GatewayToRouterEvent) Reset 

func (x *GatewayToRouterEvent) Reset()

func (*GatewayToRouterEvent) String 

func (x *GatewayToRouterEvent) String() string

type GatewayToRouterEvent_DownlinkTXAckEvent 

type GatewayToRouterEvent_DownlinkTXAckEvent struct {
	DownlinkTXAckEvent *DownlinkTXAckEvent `protobuf:"bytes,3,opt,name=downlinkTXAckEvent,proto3,oneof"`
}

type GatewayToRouterEvent_StatusEvent 

type GatewayToRouterEvent_StatusEvent struct {
	StatusEvent *StatusEvent `protobuf:"bytes,4,opt,name=statusEvent,proto3,oneof"`
}

type GatewayToRouterEvent_UplinkFrameEvent 

type GatewayToRouterEvent_UplinkFrameEvent struct {
	UplinkFrameEvent *UplinkFrameEvent `protobuf:"bytes,2,opt,name=uplinkFrameEvent,proto3,oneof"`
}

type JoinFilter 

type JoinFilter struct {

	// Types that are assignable to Filter:
	//
	//	*JoinFilter_Xor8
	Filter isJoinFilter_Filter `protobuf_oneof:"filter"`
	// contains filtered or unexported fields
}

func (*JoinFilter) Descriptor deprecated 

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

Deprecated: Use JoinFilter.ProtoReflect.Descriptor instead.

func (*JoinFilter) GetFilter 

func (m *JoinFilter) GetFilter() isJoinFilter_Filter

func (*JoinFilter) GetXor8 

func (x *JoinFilter) GetXor8() *Xor8Filter

func (*JoinFilter) ProtoMessage 

func (*JoinFilter) ProtoMessage()

func (*JoinFilter) ProtoReflect 

func (x *JoinFilter) ProtoReflect() protoreflect.Message

func (*JoinFilter) Reset 

func (x *JoinFilter) Reset()

func (*JoinFilter) String 

func (x *JoinFilter) String() string

type JoinFilterRequest 

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

func (*JoinFilterRequest) Descriptor deprecated 

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

Deprecated: Use JoinFilterRequest.ProtoReflect.Descriptor instead.

func (*JoinFilterRequest) ProtoMessage 

func (*JoinFilterRequest) ProtoMessage()

func (*JoinFilterRequest) ProtoReflect 

func (x *JoinFilterRequest) ProtoReflect() protoreflect.Message

func (*JoinFilterRequest) Reset 

func (x *JoinFilterRequest) Reset()

func (*JoinFilterRequest) String 

func (x *JoinFilterRequest) String() string

type JoinFilterResponse 

type JoinFilterResponse struct {
	JoinFilter *JoinFilter `protobuf:"bytes,1,opt,name=joinFilter,proto3" json:"joinFilter,omitempty"`
	// contains filtered or unexported fields
}

func (*JoinFilterResponse) Descriptor deprecated 

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

Deprecated: Use JoinFilterResponse.ProtoReflect.Descriptor instead.

func (*JoinFilterResponse) GetJoinFilter 

func (x *JoinFilterResponse) GetJoinFilter() *JoinFilter

func (*JoinFilterResponse) ProtoMessage 

func (*JoinFilterResponse) ProtoMessage()

func (*JoinFilterResponse) ProtoReflect 

func (x *JoinFilterResponse) ProtoReflect() protoreflect.Message

func (*JoinFilterResponse) Reset 

func (x *JoinFilterResponse) Reset()

func (*JoinFilterResponse) String 

func (x *JoinFilterResponse) String() string

type JoinFilter_Xor8 

type JoinFilter_Xor8 struct {
	Xor8 *Xor8Filter `protobuf:"bytes,1,opt,name=xor8,proto3,oneof"`
}

type NetIdsRequest 

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

func (*NetIdsRequest) Descriptor deprecated 

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

Deprecated: Use NetIdsRequest.ProtoReflect.Descriptor instead.

func (*NetIdsRequest) ProtoMessage 

func (*NetIdsRequest) ProtoMessage()

func (*NetIdsRequest) ProtoReflect 

func (x *NetIdsRequest) ProtoReflect() protoreflect.Message

func (*NetIdsRequest) Reset 

func (x *NetIdsRequest) Reset()

func (*NetIdsRequest) String 

func (x *NetIdsRequest) String() string

type NetIdsResponse 

type NetIdsResponse struct {
	NetId [][]byte `protobuf:"bytes,1,rep,name=netId,proto3" json:"netId,omitempty"`
	// contains filtered or unexported fields
}

func (*NetIdsResponse) Descriptor deprecated 

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

Deprecated: Use NetIdsResponse.ProtoReflect.Descriptor instead.

func (*NetIdsResponse) GetNetId 

func (x *NetIdsResponse) GetNetId() [][]byte

func (*NetIdsResponse) ProtoMessage 

func (*NetIdsResponse) ProtoMessage()

func (*NetIdsResponse) ProtoReflect 

func (x *NetIdsResponse) ProtoReflect() protoreflect.Message

func (*NetIdsResponse) Reset 

func (x *NetIdsResponse) Reset()

func (*NetIdsResponse) String 

func (x *NetIdsResponse) String() string

type RouterToGatewayEvent 

type RouterToGatewayEvent struct {

	// Types that are assignable to Event:
	//
	//	*RouterToGatewayEvent_DownlinkFrameEvent
	//	*RouterToGatewayEvent_AirtimePaymentEvent
	Event isRouterToGatewayEvent_Event `protobuf_oneof:"event"`
	// contains filtered or unexported fields
}

func (*RouterToGatewayEvent) Descriptor deprecated 

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

Deprecated: Use RouterToGatewayEvent.ProtoReflect.Descriptor instead.

func (*RouterToGatewayEvent) GetAirtimePaymentEvent 

func (x *RouterToGatewayEvent) GetAirtimePaymentEvent() *AirtimePaymentEvent

func (*RouterToGatewayEvent) GetDownlinkFrameEvent 

func (x *RouterToGatewayEvent) GetDownlinkFrameEvent() *DownlinkFrameEvent

func (*RouterToGatewayEvent) GetEvent 

func (m *RouterToGatewayEvent) GetEvent() isRouterToGatewayEvent_Event

func (*RouterToGatewayEvent) ProtoMessage 

func (*RouterToGatewayEvent) ProtoMessage()

func (*RouterToGatewayEvent) ProtoReflect 

func (x *RouterToGatewayEvent) ProtoReflect() protoreflect.Message

func (*RouterToGatewayEvent) Reset 

func (x *RouterToGatewayEvent) Reset()

func (*RouterToGatewayEvent) String 

func (x *RouterToGatewayEvent) String() string

type RouterToGatewayEvent_AirtimePaymentEvent 

type RouterToGatewayEvent_AirtimePaymentEvent struct {
	AirtimePaymentEvent *AirtimePaymentEvent `protobuf:"bytes,2,opt,name=airtimePaymentEvent,proto3,oneof"`
}

type RouterToGatewayEvent_DownlinkFrameEvent 

type RouterToGatewayEvent_DownlinkFrameEvent struct {
	DownlinkFrameEvent *DownlinkFrameEvent `protobuf:"bytes,1,opt,name=downlinkFrameEvent,proto3,oneof"`
}

type RouterV1Client 

type RouterV1Client interface {
	NetIds(ctx context.Context, in *NetIdsRequest, opts ...grpc.CallOption) (*NetIdsResponse, error)
	JoinFilter(ctx context.Context, in *JoinFilterRequest, opts ...grpc.CallOption) (*JoinFilterResponse, error)
	Events(ctx context.Context, opts ...grpc.CallOption) (RouterV1_EventsClient, error)
}

RouterV1Client is the client API for RouterV1 service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewRouterV1Client 

func NewRouterV1Client(cc grpc.ClientConnInterface) RouterV1Client

type RouterV1Server 

type RouterV1Server interface {
	NetIds(context.Context, *NetIdsRequest) (*NetIdsResponse, error)
	JoinFilter(context.Context, *JoinFilterRequest) (*JoinFilterResponse, error)
	Events(RouterV1_EventsServer) error
	// contains filtered or unexported methods
}

RouterV1Server is the server API for RouterV1 service. All implementations must embed UnimplementedRouterV1Server for forward compatibility

type RouterV1_EventsClient 

type RouterV1_EventsClient interface {
	Send(*GatewayToRouterEvent) error
	Recv() (*RouterToGatewayEvent, error)
	grpc.ClientStream
}

type RouterV1_EventsServer 

type RouterV1_EventsServer interface {
	Send(*RouterToGatewayEvent) error
	Recv() (*GatewayToRouterEvent, error)
	grpc.ServerStream
}

type StatusEvent 

type StatusEvent struct {
	Online bool `protobuf:"varint,1,opt,name=online,proto3" json:"online,omitempty"`
	// contains filtered or unexported fields
}

func (*StatusEvent) Descriptor deprecated 

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

Deprecated: Use StatusEvent.ProtoReflect.Descriptor instead.

func (*StatusEvent) GetOnline 

func (x *StatusEvent) GetOnline() bool

func (*StatusEvent) ProtoMessage 

func (*StatusEvent) ProtoMessage()

func (*StatusEvent) ProtoReflect 

func (x *StatusEvent) ProtoReflect() protoreflect.Message

func (*StatusEvent) Reset 

func (x *StatusEvent) Reset()

func (*StatusEvent) String 

func (x *StatusEvent) String() string

type UnimplementedRouterV1Server 

type UnimplementedRouterV1Server struct {
}

UnimplementedRouterV1Server must be embedded to have forward compatible implementations.

func (UnimplementedRouterV1Server) Events 

func (UnimplementedRouterV1Server) Events(RouterV1_EventsServer) error

func (UnimplementedRouterV1Server) JoinFilter 

func (UnimplementedRouterV1Server) JoinFilter(context.Context, *JoinFilterRequest) (*JoinFilterResponse, error)

func (UnimplementedRouterV1Server) NetIds 

func (UnimplementedRouterV1Server) NetIds(context.Context, *NetIdsRequest) (*NetIdsResponse, error)

type UnsafeRouterV1Server 

type UnsafeRouterV1Server interface {
	// contains filtered or unexported methods
}

UnsafeRouterV1Server may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RouterV1Server will result in compilation errors.

type UplinkFrameEvent 

type UplinkFrameEvent struct {
	UplinkFrame    *gw.UplinkFrame `protobuf:"bytes,1,opt,name=uplinkFrame,proto3" json:"uplinkFrame,omitempty"`
	AirtimeReceipt *AirtimeReceipt `protobuf:"bytes,2,opt,name=airtimeReceipt,proto3" json:"airtimeReceipt,omitempty"`
	// contains filtered or unexported fields
}

func (*UplinkFrameEvent) Descriptor deprecated 

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

Deprecated: Use UplinkFrameEvent.ProtoReflect.Descriptor instead.

func (*UplinkFrameEvent) GetAirtimeReceipt 

func (x *UplinkFrameEvent) GetAirtimeReceipt() *AirtimeReceipt

func (*UplinkFrameEvent) GetUplinkFrame 

func (x *UplinkFrameEvent) GetUplinkFrame() *gw.UplinkFrame

func (*UplinkFrameEvent) ProtoMessage 

func (*UplinkFrameEvent) ProtoMessage()

func (*UplinkFrameEvent) ProtoReflect 

func (x *UplinkFrameEvent) ProtoReflect() protoreflect.Message

func (*UplinkFrameEvent) Reset 

func (x *UplinkFrameEvent) Reset()

func (*UplinkFrameEvent) String 

func (x *UplinkFrameEvent) String() string

type Xor8Filter 

type Xor8Filter struct {
	Seed         uint64 `protobuf:"varint,1,opt,name=seed,proto3" json:"seed,omitempty"`
	Blocklength  uint32 `protobuf:"varint,2,opt,name=blocklength,proto3" json:"blocklength,omitempty"`
	Fingerprints []byte `protobuf:"bytes,3,opt,name=fingerprints,proto3" json:"fingerprints,omitempty"`
	// contains filtered or unexported fields
}

func (*Xor8Filter) Descriptor deprecated 

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

Deprecated: Use Xor8Filter.ProtoReflect.Descriptor instead.

func (*Xor8Filter) GetBlocklength 

func (x *Xor8Filter) GetBlocklength() uint32

func (*Xor8Filter) GetFingerprints 

func (x *Xor8Filter) GetFingerprints() []byte

func (*Xor8Filter) GetSeed 

func (x *Xor8Filter) GetSeed() uint64

func (*Xor8Filter) ProtoMessage 

func (*Xor8Filter) ProtoMessage()

func (*Xor8Filter) ProtoReflect 

func (x *Xor8Filter) ProtoReflect() protoreflect.Message

func (*Xor8Filter) Reset 

func (x *Xor8Filter) Reset()

func (*Xor8Filter) String 

func (x *Xor8Filter) String() string

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.