proto

package
v0.1.36 Latest Latest
Warning

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

 Go to latest Published: Nov 27, 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 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"`
	SessionId       string `protobuf:"bytes,6,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	Reconnect       bool   `protobuf:"varint,7,opt,name=reconnect,proto3" json:"reconnect,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *InitializeRequest) GetReconnect() bool

func (*InitializeRequest) GetSessionId 

func (x *InitializeRequest) GetSessionId() string

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 MemberConnectEvent 

type MemberConnectEvent 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
}

func (*MemberConnectEvent) Descriptor deprecated 

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

Deprecated: Use MemberConnectEvent.ProtoReflect.Descriptor instead.

func (*MemberConnectEvent) GetDestinationPeerId 

func (x *MemberConnectEvent) GetDestinationPeerId() uint32

func (*MemberConnectEvent) GetEndpointAddr 

func (x *MemberConnectEvent) GetEndpointAddr() string

func (*MemberConnectEvent) GetEndpointPort 

func (x *MemberConnectEvent) GetEndpointPort() uint32

func (*MemberConnectEvent) GetFriendlyName 

func (x *MemberConnectEvent) GetFriendlyName() string

func (*MemberConnectEvent) GetPublicKey 

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

func (*MemberConnectEvent) GetSourcePeerId 

func (x *MemberConnectEvent) GetSourcePeerId() uint32

func (*MemberConnectEvent) ProtoMessage 

func (*MemberConnectEvent) ProtoMessage()

func (*MemberConnectEvent) ProtoReflect 

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

func (*MemberConnectEvent) Reset 

func (x *MemberConnectEvent) Reset()

func (*MemberConnectEvent) String 

func (x *MemberConnectEvent) String() string

type MemberConnectResponseEvent 

type MemberConnectResponseEvent 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
}

func (*MemberConnectResponseEvent) Descriptor deprecated 

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

Deprecated: Use MemberConnectResponseEvent.ProtoReflect.Descriptor instead.

func (*MemberConnectResponseEvent) GetDestinationPeerId 

func (x *MemberConnectResponseEvent) GetDestinationPeerId() uint32

func (*MemberConnectResponseEvent) GetEndpointAddr 

func (x *MemberConnectResponseEvent) GetEndpointAddr() string

func (*MemberConnectResponseEvent) GetEndpointPort 

func (x *MemberConnectResponseEvent) GetEndpointPort() uint32

func (*MemberConnectResponseEvent) GetFriendlyName 

func (x *MemberConnectResponseEvent) GetFriendlyName() string

func (*MemberConnectResponseEvent) GetPresharedKey 

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

func (*MemberConnectResponseEvent) GetPublicKey 

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

func (*MemberConnectResponseEvent) GetSourcePeerId 

func (x *MemberConnectResponseEvent) GetSourcePeerId() uint32

func (*MemberConnectResponseEvent) ProtoMessage 

func (*MemberConnectResponseEvent) ProtoMessage()

func (*MemberConnectResponseEvent) ProtoReflect 

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

func (*MemberConnectResponseEvent) Reset 

func (x *MemberConnectResponseEvent) Reset()

func (*MemberConnectResponseEvent) String 

func (x *MemberConnectResponseEvent) String() string

type MemberDisconnectedEvent 

type MemberDisconnectedEvent 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
}

func (*MemberDisconnectedEvent) Descriptor deprecated 

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

Deprecated: Use MemberDisconnectedEvent.ProtoReflect.Descriptor instead.

func (*MemberDisconnectedEvent) GetFriendlyName 

func (x *MemberDisconnectedEvent) GetFriendlyName() string

func (*MemberDisconnectedEvent) GetPeerId 

func (x *MemberDisconnectedEvent) GetPeerId() uint32

func (*MemberDisconnectedEvent) ProtoMessage 

func (*MemberDisconnectedEvent) ProtoMessage()

func (*MemberDisconnectedEvent) ProtoReflect 

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

func (*MemberDisconnectedEvent) Reset 

func (x *MemberDisconnectedEvent) Reset()

func (*MemberDisconnectedEvent) String 

func (x *MemberDisconnectedEvent) String() string

type NewMemberEvent 

type NewMemberEvent 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
}

func (*NewMemberEvent) Descriptor deprecated 

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

Deprecated: Use NewMemberEvent.ProtoReflect.Descriptor instead.

func (*NewMemberEvent) GetFriendlyName 

func (x *NewMemberEvent) GetFriendlyName() string

func (*NewMemberEvent) GetPeerId 

func (x *NewMemberEvent) GetPeerId() uint32

func (*NewMemberEvent) ProtoMessage 

func (*NewMemberEvent) ProtoMessage()

func (*NewMemberEvent) ProtoReflect 

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

func (*NewMemberEvent) Reset 

func (x *NewMemberEvent) Reset()

func (*NewMemberEvent) String 

func (x *NewMemberEvent) 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() *MemberConnectEvent

func (*RPCClientEvent) GetConnectResponse 

func (x *RPCClientEvent) GetConnectResponse() *MemberConnectResponseEvent

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 {
	Connect *MemberConnectEvent `protobuf:"bytes,2,opt,name=connect,proto3,oneof"`
}

type RPCClientEvent_ConnectResponse 

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

type RPCClientEvent_Initialize 

type RPCClientEvent_Initialize struct {
	Initialize *InitializeRequest `protobuf:"bytes,1,opt,name=initialize,proto3,oneof"`
}

type RPCServerEvent 

type RPCServerEvent struct {

	// Types that are assignable to Event:
	//
	//	*RPCServerEvent_NewMember
	//	*RPCServerEvent_DisconnectedMember
	//	*RPCServerEvent_MemberConnect
	//	*RPCServerEvent_MemberConnectResponse
	//	*RPCServerEvent_SessionId
	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) GetDisconnectedMember 

func (x *RPCServerEvent) GetDisconnectedMember() *MemberDisconnectedEvent

func (*RPCServerEvent) GetEvent 

func (m *RPCServerEvent) GetEvent() isRPCServerEvent_Event

func (*RPCServerEvent) GetMemberConnect 

func (x *RPCServerEvent) GetMemberConnect() *MemberConnectEvent

func (*RPCServerEvent) GetMemberConnectResponse 

func (x *RPCServerEvent) GetMemberConnectResponse() *MemberConnectResponseEvent

func (*RPCServerEvent) GetNewMember 

func (x *RPCServerEvent) GetNewMember() *NewMemberEvent

func (*RPCServerEvent) GetSessionId 

func (x *RPCServerEvent) GetSessionId() string

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_DisconnectedMember 

type RPCServerEvent_DisconnectedMember struct {
	DisconnectedMember *MemberDisconnectedEvent `protobuf:"bytes,2,opt,name=disconnected_member,json=disconnectedMember,proto3,oneof"`
}

type RPCServerEvent_MemberConnect 

type RPCServerEvent_MemberConnect struct {
	MemberConnect *MemberConnectEvent `protobuf:"bytes,3,opt,name=member_connect,json=memberConnect,proto3,oneof"`
}

type RPCServerEvent_MemberConnectResponse 

type RPCServerEvent_MemberConnectResponse struct {
	MemberConnectResponse *MemberConnectResponseEvent `protobuf:"bytes,4,opt,name=member_connect_response,json=memberConnectResponse,proto3,oneof"`
}

type RPCServerEvent_NewMember 

type RPCServerEvent_NewMember struct {
	NewMember *NewMemberEvent `protobuf:"bytes,1,opt,name=new_member,json=newMember,proto3,oneof"`
}

type RPCServerEvent_SessionId 

type RPCServerEvent_SessionId struct {
	SessionId string `protobuf:"bytes,5,opt,name=session_id,json=sessionId,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.