proto

package
v0.1.0-beta13 Latest Latest
Warning

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

 Go to latest Published: Jul 26, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_proto_orion_holepunch_proto protoreflect.FileDescriptor
View Source 
var File_proto_orion_registry_proto protoreflect.FileDescriptor
View Source 
var HolePunchingService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "HolePunchingService",
	HandlerType: (*HolePunchingServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Session",
			Handler:       _HolePunchingService_Session_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "proto/orion_holepunch.proto",
}

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

View Source 
var Registry_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "Registry",
	HandlerType: (*RegistryServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "SubscribeToStream",
			Handler:       _Registry_SubscribeToStream_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "proto/orion_registry.proto",
}

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

Functions

func RegisterHolePunchingServiceServer 

func RegisterHolePunchingServiceServer(s grpc.ServiceRegistrar, srv HolePunchingServiceServer)

func RegisterRegistryServer 

func RegisterRegistryServer(s grpc.ServiceRegistrar, srv RegistryServer)

Types

type ClientDisconnectedTeardownEvent 

type ClientDisconnectedTeardownEvent struct {
	FriendlyName string `protobuf:"bytes,1,opt,name=friendly_name,json=friendlyName,proto3" json:"friendly_name,omitempty"`
	PeerId       uint32 `protobuf:"varint,2,opt,name=peer_id,json=peerId,proto3" json:"peer_id,omitempty"`
	// contains filtered or unexported fields
}

Sent when a clients lost connection and needs to be completely kicked from the network.

func (*ClientDisconnectedTeardownEvent) Descriptor deprecated 

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

Deprecated: Use ClientDisconnectedTeardownEvent.ProtoReflect.Descriptor instead.

func (*ClientDisconnectedTeardownEvent) GetFriendlyName 

func (x *ClientDisconnectedTeardownEvent) GetFriendlyName() string

func (*ClientDisconnectedTeardownEvent) GetPeerId 

func (x *ClientDisconnectedTeardownEvent) GetPeerId() uint32

func (*ClientDisconnectedTeardownEvent) ProtoMessage 

func (*ClientDisconnectedTeardownEvent) ProtoMessage()

func (*ClientDisconnectedTeardownEvent) ProtoReflect 

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

func (*ClientDisconnectedTeardownEvent) Reset 

func (x *ClientDisconnectedTeardownEvent) Reset()

func (*ClientDisconnectedTeardownEvent) String 

func (x *ClientDisconnectedTeardownEvent) String() string

type ClientNewOnNetworkEvent 

type ClientNewOnNetworkEvent struct {
	FriendlyName string `protobuf:"bytes,1,opt,name=friendly_name,json=friendlyName,proto3" json:"friendly_name,omitempty"`
	PeerId       uint32 `protobuf:"varint,2,opt,name=peer_id,json=peerId,proto3" json:"peer_id,omitempty"`
	// contains filtered or unexported fields
}

Event sent to all clients when a new orion client joined the network

func (*ClientNewOnNetworkEvent) Descriptor deprecated 

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

Deprecated: Use ClientNewOnNetworkEvent.ProtoReflect.Descriptor instead.

func (*ClientNewOnNetworkEvent) GetFriendlyName 

func (x *ClientNewOnNetworkEvent) GetFriendlyName() string

func (*ClientNewOnNetworkEvent) GetPeerId 

func (x *ClientNewOnNetworkEvent) GetPeerId() uint32

func (*ClientNewOnNetworkEvent) ProtoMessage 

func (*ClientNewOnNetworkEvent) ProtoMessage()

func (*ClientNewOnNetworkEvent) ProtoReflect 

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

func (*ClientNewOnNetworkEvent) Reset 

func (x *ClientNewOnNetworkEvent) Reset()

func (*ClientNewOnNetworkEvent) String 

func (x *ClientNewOnNetworkEvent) String() string

type ClientWantToConnectToClient 

type ClientWantToConnectToClient struct {
	EndpointAddr      string `protobuf:"bytes,1,opt,name=endpoint_addr,json=endpointAddr,proto3" json:"endpoint_addr,omitempty"`
	EndpointPort      uint32 `protobuf:"varint,2,opt,name=endpoint_port,json=endpointPort,proto3" json:"endpoint_port,omitempty"`
	PublicKey         []byte `protobuf:"bytes,3,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`
	FriendlyName      string `protobuf:"bytes,5,opt,name=friendly_name,json=friendlyName,proto3" json:"friendly_name,omitempty"`
	DestinationPeerId uint32 `protobuf:"varint,6,opt,name=destination_peer_id,json=destinationPeerId,proto3" json:"destination_peer_id,omitempty"`
	SourcePeerId      uint32 `protobuf:"varint,7,opt,name=source_peer_id,json=sourcePeerId,proto3" json:"source_peer_id,omitempty"`
	// contains filtered or unexported fields
}

Sent by the clients when wanting to initialize a new peer to peer request

func (*ClientWantToConnectToClient) Descriptor deprecated 

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

Deprecated: Use ClientWantToConnectToClient.ProtoReflect.Descriptor instead.

func (*ClientWantToConnectToClient) GetDestinationPeerId 

func (x *ClientWantToConnectToClient) GetDestinationPeerId() uint32

func (*ClientWantToConnectToClient) GetEndpointAddr 

func (x *ClientWantToConnectToClient) GetEndpointAddr() string

func (*ClientWantToConnectToClient) GetEndpointPort 

func (x *ClientWantToConnectToClient) GetEndpointPort() uint32

func (*ClientWantToConnectToClient) GetFriendlyName 

func (x *ClientWantToConnectToClient) GetFriendlyName() string

func (*ClientWantToConnectToClient) GetPublicKey 

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

func (*ClientWantToConnectToClient) GetSourcePeerId 

func (x *ClientWantToConnectToClient) GetSourcePeerId() uint32

func (*ClientWantToConnectToClient) ProtoMessage 

func (*ClientWantToConnectToClient) ProtoMessage()

func (*ClientWantToConnectToClient) ProtoReflect 

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

func (*ClientWantToConnectToClient) Reset 

func (x *ClientWantToConnectToClient) Reset()

func (*ClientWantToConnectToClient) String 

func (x *ClientWantToConnectToClient) String() string

type ClientWantToConnectToClientResponse 

type ClientWantToConnectToClientResponse struct {
	EndpointAddr      string `protobuf:"bytes,1,opt,name=endpoint_addr,json=endpointAddr,proto3" json:"endpoint_addr,omitempty"`
	EndpointPort      uint32 `protobuf:"varint,2,opt,name=endpoint_port,json=endpointPort,proto3" json:"endpoint_port,omitempty"`
	PublicKey         []byte `protobuf:"bytes,3,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`
	FriendlyName      string `protobuf:"bytes,4,opt,name=friendly_name,json=friendlyName,proto3" json:"friendly_name,omitempty"`
	DestinationPeerId uint32 `protobuf:"varint,5,opt,name=destination_peer_id,json=destinationPeerId,proto3" json:"destination_peer_id,omitempty"`
	PresharedKey      []byte `protobuf:"bytes,7,opt,name=preshared_key,json=presharedKey,proto3" json:"preshared_key,omitempty"`
	SourcePeerId      uint32 `protobuf:"varint,6,opt,name=source_peer_id,json=sourcePeerId,proto3" json:"source_peer_id,omitempty"`
	// contains filtered or unexported fields
}

Response to a ClientWantToConnectToClient

func (*ClientWantToConnectToClientResponse) Descriptor deprecated 

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

Deprecated: Use ClientWantToConnectToClientResponse.ProtoReflect.Descriptor instead.

func (*ClientWantToConnectToClientResponse) GetDestinationPeerId 

func (x *ClientWantToConnectToClientResponse) GetDestinationPeerId() uint32

func (*ClientWantToConnectToClientResponse) GetEndpointAddr 

func (x *ClientWantToConnectToClientResponse) GetEndpointAddr() string

func (*ClientWantToConnectToClientResponse) GetEndpointPort 

func (x *ClientWantToConnectToClientResponse) GetEndpointPort() uint32

func (*ClientWantToConnectToClientResponse) GetFriendlyName 

func (x *ClientWantToConnectToClientResponse) GetFriendlyName() string

func (*ClientWantToConnectToClientResponse) GetPresharedKey 

func (x *ClientWantToConnectToClientResponse) GetPresharedKey() []byte

func (*ClientWantToConnectToClientResponse) GetPublicKey 

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

func (*ClientWantToConnectToClientResponse) GetSourcePeerId 

func (x *ClientWantToConnectToClientResponse) GetSourcePeerId() uint32

func (*ClientWantToConnectToClientResponse) ProtoMessage 

func (*ClientWantToConnectToClientResponse) ProtoMessage()

func (*ClientWantToConnectToClientResponse) ProtoReflect 

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

func (*ClientWantToConnectToClientResponse) Reset 

func (x *ClientWantToConnectToClientResponse) Reset()

func (*ClientWantToConnectToClientResponse) String 

func (x *ClientWantToConnectToClientResponse) String() string

type HolePunchingCompleteResponse 

type HolePunchingCompleteResponse struct {
	ClientEndpointAddr string `protobuf:"bytes,1,opt,name=client_endpoint_addr,json=clientEndpointAddr,proto3" json:"client_endpoint_addr,omitempty"`
	ClientEndpointPort uint32 `protobuf:"varint,2,opt,name=client_endpoint_port,json=clientEndpointPort,proto3" json:"client_endpoint_port,omitempty"`
	// contains filtered or unexported fields
}

Message send to inform that the information was gathered by the registry server

func (*HolePunchingCompleteResponse) Descriptor deprecated 

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

Deprecated: Use HolePunchingCompleteResponse.ProtoReflect.Descriptor instead.

func (*HolePunchingCompleteResponse) GetClientEndpointAddr 

func (x *HolePunchingCompleteResponse) GetClientEndpointAddr() string

func (*HolePunchingCompleteResponse) GetClientEndpointPort 

func (x *HolePunchingCompleteResponse) GetClientEndpointPort() uint32

func (*HolePunchingCompleteResponse) ProtoMessage 

func (*HolePunchingCompleteResponse) ProtoMessage()

func (*HolePunchingCompleteResponse) ProtoReflect 

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

func (*HolePunchingCompleteResponse) Reset 

func (x *HolePunchingCompleteResponse) Reset()

func (*HolePunchingCompleteResponse) String 

func (x *HolePunchingCompleteResponse) String() string

type HolePunchingEvent 

type HolePunchingEvent struct {

	// Types that are assignable to Event:
	//
	//	*HolePunchingEvent_InitializationResponse
	//	*HolePunchingEvent_Complete
	Event isHolePunchingEvent_Event `protobuf_oneof:"event"`
	// contains filtered or unexported fields
}

Message after the connection of the client to the holepunching-dedicated server endpoint.

func (*HolePunchingEvent) Descriptor deprecated 

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

Deprecated: Use HolePunchingEvent.ProtoReflect.Descriptor instead.

func (*HolePunchingEvent) GetComplete 

func (x *HolePunchingEvent) GetComplete() *HolePunchingCompleteResponse

func (*HolePunchingEvent) GetEvent 

func (m *HolePunchingEvent) GetEvent() isHolePunchingEvent_Event

func (*HolePunchingEvent) GetInitializationResponse 

func (x *HolePunchingEvent) GetInitializationResponse() *HolePunchingInitializationResponse

func (*HolePunchingEvent) ProtoMessage 

func (*HolePunchingEvent) ProtoMessage()

func (*HolePunchingEvent) ProtoReflect 

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

func (*HolePunchingEvent) Reset 

func (x *HolePunchingEvent) Reset()

func (*HolePunchingEvent) String 

func (x *HolePunchingEvent) String() string

type HolePunchingEvent_Complete 

type HolePunchingEvent_Complete struct {
	Complete *HolePunchingCompleteResponse `protobuf:"bytes,2,opt,name=complete,proto3,oneof"`
}

type HolePunchingEvent_InitializationResponse 

type HolePunchingEvent_InitializationResponse struct {
	InitializationResponse *HolePunchingInitializationResponse `protobuf:"bytes,1,opt,name=initialization_response,json=initializationResponse,proto3,oneof"`
}

type HolePunchingInitializationResponse 

type HolePunchingInitializationResponse struct {

	// The public endpoint and port of the registry server.
	EndpointAddr string `protobuf:"bytes,1,opt,name=endpoint_addr,json=endpointAddr,proto3" json:"endpoint_addr,omitempty"`
	EndpointPort uint32 `protobuf:"varint,2,opt,name=endpoint_port,json=endpointPort,proto3" json:"endpoint_port,omitempty"`
	// The public key of the registry server.
	PublicKey []byte `protobuf:"bytes,3,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`
	// The preshared key assigned by the server for this session.
	PresharedKey []byte `protobuf:"bytes,4,opt,name=preshared_key,json=presharedKey,proto3" json:"preshared_key,omitempty"`
	// contains filtered or unexported fields
}

Message send to inform the client of the Wireguard credentials and ip adresses

func (*HolePunchingInitializationResponse) Descriptor deprecated 

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

Deprecated: Use HolePunchingInitializationResponse.ProtoReflect.Descriptor instead.

func (*HolePunchingInitializationResponse) GetEndpointAddr 

func (x *HolePunchingInitializationResponse) GetEndpointAddr() string

func (*HolePunchingInitializationResponse) GetEndpointPort 

func (x *HolePunchingInitializationResponse) GetEndpointPort() uint32

func (*HolePunchingInitializationResponse) GetPresharedKey 

func (x *HolePunchingInitializationResponse) GetPresharedKey() []byte

func (*HolePunchingInitializationResponse) GetPublicKey 

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

func (*HolePunchingInitializationResponse) ProtoMessage 

func (*HolePunchingInitializationResponse) ProtoMessage()

func (*HolePunchingInitializationResponse) ProtoReflect 

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

func (*HolePunchingInitializationResponse) Reset 

func (x *HolePunchingInitializationResponse) Reset()

func (*HolePunchingInitializationResponse) String 

func (x *HolePunchingInitializationResponse) String() string

type HolePunchingInitialize 

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

Message sent to initialize a hole-punching session for a given Wireguard Tunnel.

func (*HolePunchingInitialize) Descriptor deprecated 

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

Deprecated: Use HolePunchingInitialize.ProtoReflect.Descriptor instead.

func (*HolePunchingInitialize) GetPublicKey 

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

func (*HolePunchingInitialize) ProtoMessage 

func (*HolePunchingInitialize) ProtoMessage()

func (*HolePunchingInitialize) ProtoReflect 

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

func (*HolePunchingInitialize) Reset 

func (x *HolePunchingInitialize) Reset()

func (*HolePunchingInitialize) String 

func (x *HolePunchingInitialize) String() string

type HolePunchingServiceClient 

type HolePunchingServiceClient interface {
	Session(ctx context.Context, in *HolePunchingInitialize, opts ...grpc.CallOption) (HolePunchingService_SessionClient, error)
}

HolePunchingServiceClient is the client API for HolePunchingService 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 NewHolePunchingServiceClient 

func NewHolePunchingServiceClient(cc grpc.ClientConnInterface) HolePunchingServiceClient

type HolePunchingServiceServer 

type HolePunchingServiceServer interface {
	Session(*HolePunchingInitialize, HolePunchingService_SessionServer) error
	// contains filtered or unexported methods
}

HolePunchingServiceServer is the server API for HolePunchingService service. All implementations must embed UnimplementedHolePunchingServiceServer for forward compatibility

type HolePunchingService_SessionClient 

type HolePunchingService_SessionClient interface {
	Recv() (*HolePunchingEvent, error)
	grpc.ClientStream
}

type HolePunchingService_SessionServer 

type HolePunchingService_SessionServer interface {
	Send(*HolePunchingEvent) error
	grpc.ServerStream
}

type InitializeRequest 

type InitializeRequest struct {
	FriendlyName    string `protobuf:"bytes,1,opt,name=friendly_name,json=friendlyName,proto3" json:"friendly_name,omitempty"`
	TimestampSigned int64  `protobuf:"varint,2,opt,name=timestamp_signed,json=timestampSigned,proto3" json:"timestamp_signed,omitempty"`
	Signed          []byte `protobuf:"bytes,3,opt,name=signed,proto3" json:"signed,omitempty"`
	MemberId        uint32 `protobuf:"varint,4,opt,name=member_id,json=memberId,proto3" json:"member_id,omitempty"`
	Certificate     []byte `protobuf:"bytes,5,opt,name=certificate,proto3" json:"certificate,omitempty"`
	// contains filtered or unexported fields
}

Data sent by a client to initialize an orion membership session

func (*InitializeRequest) Descriptor deprecated 

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

Deprecated: Use InitializeRequest.ProtoReflect.Descriptor instead.

func (*InitializeRequest) GetCertificate 

func (x *InitializeRequest) GetCertificate() []byte

func (*InitializeRequest) GetFriendlyName 

func (x *InitializeRequest) GetFriendlyName() string

func (*InitializeRequest) GetMemberId 

func (x *InitializeRequest) GetMemberId() uint32

func (*InitializeRequest) GetSigned 

func (x *InitializeRequest) GetSigned() []byte

func (*InitializeRequest) GetTimestampSigned 

func (x *InitializeRequest) GetTimestampSigned() int64

func (*InitializeRequest) ProtoMessage 

func (*InitializeRequest) ProtoMessage()

func (*InitializeRequest) ProtoReflect 

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

func (*InitializeRequest) Reset 

func (x *InitializeRequest) Reset()

func (*InitializeRequest) String 

func (x *InitializeRequest) String() string

type RPCClientEvent 

type RPCClientEvent struct {

	// Types that are assignable to Event:
	//
	//	*RPCClientEvent_Initialize
	//	*RPCClientEvent_Connect
	//	*RPCClientEvent_ConnectResponse
	Event isRPCClientEvent_Event `protobuf_oneof:"event"`
	// contains filtered or unexported fields
}

func (*RPCClientEvent) Descriptor deprecated 

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

Deprecated: Use RPCClientEvent.ProtoReflect.Descriptor instead.

func (*RPCClientEvent) GetConnect 

func (x *RPCClientEvent) GetConnect() *ClientWantToConnectToClient

func (*RPCClientEvent) GetConnectResponse 

func (x *RPCClientEvent) GetConnectResponse() *ClientWantToConnectToClientResponse

func (*RPCClientEvent) GetEvent 

func (m *RPCClientEvent) GetEvent() isRPCClientEvent_Event

func (*RPCClientEvent) GetInitialize 

func (x *RPCClientEvent) GetInitialize() *InitializeRequest

func (*RPCClientEvent) ProtoMessage 

func (*RPCClientEvent) ProtoMessage()

func (*RPCClientEvent) ProtoReflect 

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

func (*RPCClientEvent) Reset 

func (x *RPCClientEvent) Reset()

func (*RPCClientEvent) String 

func (x *RPCClientEvent) String() string

type RPCClientEvent_Connect 

type RPCClientEvent_Connect struct {
	// Sent when the clients wants to connect to a new client
	Connect *ClientWantToConnectToClient `protobuf:"bytes,2,opt,name=connect,proto3,oneof"`
}

type RPCClientEvent_ConnectResponse 

type RPCClientEvent_ConnectResponse struct {
	ConnectResponse *ClientWantToConnectToClientResponse `protobuf:"bytes,3,opt,name=connect_response,json=connectResponse,proto3,oneof"`
}

type RPCClientEvent_Initialize 

type RPCClientEvent_Initialize struct {
	// First message sent to the server in order to initialize the stream status.
	Initialize *InitializeRequest `protobuf:"bytes,1,opt,name=initialize,proto3,oneof"`
}

type RPCServerEvent 

type RPCServerEvent struct {

	// Types that are assignable to Event:
	//
	//	*RPCServerEvent_NewClient
	//	*RPCServerEvent_RemovedClient
	//	*RPCServerEvent_WantsToConnect
	//	*RPCServerEvent_WantsToConnectResponse
	Event isRPCServerEvent_Event `protobuf_oneof:"event"`
	// contains filtered or unexported fields
}

func (*RPCServerEvent) Descriptor deprecated 

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

Deprecated: Use RPCServerEvent.ProtoReflect.Descriptor instead.

func (*RPCServerEvent) GetEvent 

func (m *RPCServerEvent) GetEvent() isRPCServerEvent_Event

func (*RPCServerEvent) GetNewClient 

func (x *RPCServerEvent) GetNewClient() *ClientNewOnNetworkEvent

func (*RPCServerEvent) GetRemovedClient 

func (x *RPCServerEvent) GetRemovedClient() *ClientDisconnectedTeardownEvent

func (*RPCServerEvent) GetWantsToConnect 

func (x *RPCServerEvent) GetWantsToConnect() *ClientWantToConnectToClient

func (*RPCServerEvent) GetWantsToConnectResponse 

func (x *RPCServerEvent) GetWantsToConnectResponse() *ClientWantToConnectToClientResponse

func (*RPCServerEvent) ProtoMessage 

func (*RPCServerEvent) ProtoMessage()

func (*RPCServerEvent) ProtoReflect 

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

func (*RPCServerEvent) Reset 

func (x *RPCServerEvent) Reset()

func (*RPCServerEvent) String 

func (x *RPCServerEvent) String() string

type RPCServerEvent_NewClient 

type RPCServerEvent_NewClient struct {
	NewClient *ClientNewOnNetworkEvent `protobuf:"bytes,1,opt,name=new_client,json=newClient,proto3,oneof"`
}

type RPCServerEvent_RemovedClient 

type RPCServerEvent_RemovedClient struct {
	RemovedClient *ClientDisconnectedTeardownEvent `protobuf:"bytes,2,opt,name=removed_client,json=removedClient,proto3,oneof"`
}

type RPCServerEvent_WantsToConnect 

type RPCServerEvent_WantsToConnect struct {
	WantsToConnect *ClientWantToConnectToClient `protobuf:"bytes,3,opt,name=wants_to_connect,json=wantsToConnect,proto3,oneof"`
}

type RPCServerEvent_WantsToConnectResponse 

type RPCServerEvent_WantsToConnectResponse struct {
	WantsToConnectResponse *ClientWantToConnectToClientResponse `protobuf:"bytes,4,opt,name=wants_to_connect_response,json=wantsToConnectResponse,proto3,oneof"`
}

type RegistryClient 

type RegistryClient interface {
	// Subscribe to the event stream
	SubscribeToStream(ctx context.Context, opts ...grpc.CallOption) (Registry_SubscribeToStreamClient, error)
}

RegistryClient is the client API for Registry 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 NewRegistryClient 

func NewRegistryClient(cc grpc.ClientConnInterface) RegistryClient

type RegistryServer 

type RegistryServer interface {
	// Subscribe to the event stream
	SubscribeToStream(Registry_SubscribeToStreamServer) error
	// contains filtered or unexported methods
}

RegistryServer is the server API for Registry service. All implementations must embed UnimplementedRegistryServer for forward compatibility

type Registry_SubscribeToStreamClient 

type Registry_SubscribeToStreamClient interface {
	Send(*RPCClientEvent) error
	Recv() (*RPCServerEvent, error)
	grpc.ClientStream
}

type Registry_SubscribeToStreamServer 

type Registry_SubscribeToStreamServer interface {
	Send(*RPCServerEvent) error
	Recv() (*RPCClientEvent, error)
	grpc.ServerStream
}

type UnimplementedHolePunchingServiceServer 

type UnimplementedHolePunchingServiceServer struct {
}

UnimplementedHolePunchingServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedHolePunchingServiceServer) Session 

func (UnimplementedHolePunchingServiceServer) Session(*HolePunchingInitialize, HolePunchingService_SessionServer) error

type UnimplementedRegistryServer 

type UnimplementedRegistryServer struct {
}

UnimplementedRegistryServer must be embedded to have forward compatible implementations.

func (UnimplementedRegistryServer) SubscribeToStream 

func (UnimplementedRegistryServer) SubscribeToStream(Registry_SubscribeToStreamServer) error

type UnsafeHolePunchingServiceServer 

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

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

type UnsafeRegistryServer 

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

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

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.