rpc

package
v0.0.0-...-78c2119 Latest Latest
Warning

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

 Go to latest Published: Aug 21, 2023 License: BSD-3-Clause Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_tunnel_proto protoreflect.FileDescriptor
View Source 
var TunnelService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "TunnelService",
	HandlerType: (*TunnelServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Connect",
			Handler:       _TunnelService_Connect_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "ReverseConnect",
			Handler:       _TunnelService_ReverseConnect_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "tunnel.proto",
}

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

Functions

func RegisterTunnelServiceServer 

func RegisterTunnelServiceServer(s grpc.ServiceRegistrar, srv TunnelServiceServer)

Types

type CloseStream 

type CloseStream struct {
	ReponseTrailers *Metadata      `protobuf:"bytes,1,opt,name=reponse_trailers,json=reponseTrailers,proto3" json:"reponse_trailers,omitempty"`
	Status          *status.Status `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*CloseStream) Descriptor deprecated 

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

Deprecated: Use CloseStream.ProtoReflect.Descriptor instead.

func (*CloseStream) GetReponseTrailers 

func (x *CloseStream) GetReponseTrailers() *Metadata

func (*CloseStream) GetStatus 

func (x *CloseStream) GetStatus() *status.Status

func (*CloseStream) ProtoMessage 

func (*CloseStream) ProtoMessage()

func (*CloseStream) ProtoReflect 

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

func (*CloseStream) Reset 

func (x *CloseStream) Reset()

func (*CloseStream) String 

func (x *CloseStream) String() string

type ConnectRequest 

type ConnectRequest struct {
	StreamId int64 `protobuf:"varint,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	// Types that are assignable to Frame:
	//
	//	*ConnectRequest_NewStream
	//	*ConnectRequest_RequestMessage
	//	*ConnectRequest_MoreRequestData
	//	*ConnectRequest_HalfClose
	//	*ConnectRequest_Cancel
	Frame isConnectRequest_Frame `protobuf_oneof:"frame"`
	// contains filtered or unexported fields
}

func (*ConnectRequest) Descriptor deprecated 

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

Deprecated: Use ConnectRequest.ProtoReflect.Descriptor instead.

func (*ConnectRequest) GetCancel 

func (x *ConnectRequest) GetCancel() *emptypb.Empty

func (*ConnectRequest) GetFrame 

func (m *ConnectRequest) GetFrame() isConnectRequest_Frame

func (*ConnectRequest) GetHalfClose 

func (x *ConnectRequest) GetHalfClose() *emptypb.Empty

func (*ConnectRequest) GetMoreRequestData 

func (x *ConnectRequest) GetMoreRequestData() []byte

func (*ConnectRequest) GetNewStream 

func (x *ConnectRequest) GetNewStream() *NewStream

func (*ConnectRequest) GetRequestMessage 

func (x *ConnectRequest) GetRequestMessage() *MessageData

func (*ConnectRequest) GetStreamId 

func (x *ConnectRequest) GetStreamId() int64

func (*ConnectRequest) ProtoMessage 

func (*ConnectRequest) ProtoMessage()

func (*ConnectRequest) ProtoReflect 

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

func (*ConnectRequest) Reset 

func (x *ConnectRequest) Reset()

func (*ConnectRequest) String 

func (x *ConnectRequest) String() string

type ConnectRequestFrame 

type ConnectRequestFrame = isConnectRequest_Frame

type ConnectRequest_Cancel 

type ConnectRequest_Cancel struct {
	Cancel *emptypb.Empty `protobuf:"bytes,6,opt,name=cancel,proto3,oneof"`
}

type ConnectRequest_HalfClose 

type ConnectRequest_HalfClose struct {
	HalfClose *emptypb.Empty `protobuf:"bytes,5,opt,name=half_close,json=halfClose,proto3,oneof"`
}

type ConnectRequest_MoreRequestData 

type ConnectRequest_MoreRequestData struct {
	MoreRequestData []byte `protobuf:"bytes,4,opt,name=more_request_data,json=moreRequestData,proto3,oneof"`
}

type ConnectRequest_NewStream 

type ConnectRequest_NewStream struct {
	NewStream *NewStream `protobuf:"bytes,2,opt,name=new_stream,json=newStream,proto3,oneof"`
}

type ConnectRequest_RequestMessage 

type ConnectRequest_RequestMessage struct {
	RequestMessage *MessageData `protobuf:"bytes,3,opt,name=request_message,json=requestMessage,proto3,oneof"`
}

type ConnectResponse 

type ConnectResponse struct {
	StreamId int64 `protobuf:"varint,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	// Types that are assignable to Frame:
	//
	//	*ConnectResponse_ResponseHeaders
	//	*ConnectResponse_ResponseMessage
	//	*ConnectResponse_MoreResponseData
	//	*ConnectResponse_CloseStream
	Frame isConnectResponse_Frame `protobuf_oneof:"frame"`
	// contains filtered or unexported fields
}

func (*ConnectResponse) Descriptor deprecated 

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

Deprecated: Use ConnectResponse.ProtoReflect.Descriptor instead.

func (*ConnectResponse) GetCloseStream 

func (x *ConnectResponse) GetCloseStream() *CloseStream

func (*ConnectResponse) GetFrame 

func (m *ConnectResponse) GetFrame() isConnectResponse_Frame

func (*ConnectResponse) GetMoreResponseData 

func (x *ConnectResponse) GetMoreResponseData() []byte

func (*ConnectResponse) GetResponseHeaders 

func (x *ConnectResponse) GetResponseHeaders() *Metadata

func (*ConnectResponse) GetResponseMessage 

func (x *ConnectResponse) GetResponseMessage() *MessageData

func (*ConnectResponse) GetStreamId 

func (x *ConnectResponse) GetStreamId() int64

func (*ConnectResponse) ProtoMessage 

func (*ConnectResponse) ProtoMessage()

func (*ConnectResponse) ProtoReflect 

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

func (*ConnectResponse) Reset 

func (x *ConnectResponse) Reset()

func (*ConnectResponse) String 

func (x *ConnectResponse) String() string

type ConnectResponseFrame 

type ConnectResponseFrame = isConnectResponse_Frame

type ConnectResponse_CloseStream 

type ConnectResponse_CloseStream struct {
	CloseStream *CloseStream `protobuf:"bytes,5,opt,name=close_stream,json=closeStream,proto3,oneof"`
}

type ConnectResponse_MoreResponseData 

type ConnectResponse_MoreResponseData struct {
	MoreResponseData []byte `protobuf:"bytes,4,opt,name=more_response_data,json=moreResponseData,proto3,oneof"`
}

type ConnectResponse_ResponseHeaders 

type ConnectResponse_ResponseHeaders struct {
	ResponseHeaders *Metadata `protobuf:"bytes,2,opt,name=response_headers,json=responseHeaders,proto3,oneof"`
}

type ConnectResponse_ResponseMessage 

type ConnectResponse_ResponseMessage struct {
	ResponseMessage *MessageData `protobuf:"bytes,3,opt,name=response_message,json=responseMessage,proto3,oneof"`
}

type MessageData 

type MessageData struct {
	Size int32  `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*MessageData) Descriptor deprecated 

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

Deprecated: Use MessageData.ProtoReflect.Descriptor instead.

func (*MessageData) GetData 

func (x *MessageData) GetData() []byte

func (*MessageData) GetSize 

func (x *MessageData) GetSize() int32

func (*MessageData) ProtoMessage 

func (*MessageData) ProtoMessage()

func (*MessageData) ProtoReflect 

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

func (*MessageData) Reset 

func (x *MessageData) Reset()

func (*MessageData) String 

func (x *MessageData) String() string

type Metadata 

type Metadata struct {
	Md map[string]*Metadata_Values `` /* 145-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Metadata) Descriptor deprecated 

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

Deprecated: Use Metadata.ProtoReflect.Descriptor instead.

func (*Metadata) GetMd 

func (x *Metadata) GetMd() map[string]*Metadata_Values

func (*Metadata) ProtoMessage 

func (*Metadata) ProtoMessage()

func (*Metadata) ProtoReflect 

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

func (*Metadata) Reset 

func (x *Metadata) Reset()

func (*Metadata) String 

func (x *Metadata) String() string

type Metadata_Values 

type Metadata_Values struct {
	Val []string `protobuf:"bytes,1,rep,name=val,proto3" json:"val,omitempty"`
	// contains filtered or unexported fields
}

func (*Metadata_Values) Descriptor deprecated 

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

Deprecated: Use Metadata_Values.ProtoReflect.Descriptor instead.

func (*Metadata_Values) GetVal 

func (x *Metadata_Values) GetVal() []string

func (*Metadata_Values) ProtoMessage 

func (*Metadata_Values) ProtoMessage()

func (*Metadata_Values) ProtoReflect 

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

func (*Metadata_Values) Reset 

func (x *Metadata_Values) Reset()

func (*Metadata_Values) String 

func (x *Metadata_Values) String() string

type NewStream 

type NewStream struct {
	MethodName     string    `protobuf:"bytes,1,opt,name=method_name,json=methodName,proto3" json:"method_name,omitempty"`
	RequestHeaders *Metadata `protobuf:"bytes,2,opt,name=request_headers,json=requestHeaders,proto3" json:"request_headers,omitempty"`
	// contains filtered or unexported fields
}

func (*NewStream) Descriptor deprecated 

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

Deprecated: Use NewStream.ProtoReflect.Descriptor instead.

func (*NewStream) GetMethodName 

func (x *NewStream) GetMethodName() string

func (*NewStream) GetRequestHeaders 

func (x *NewStream) GetRequestHeaders() *Metadata

func (*NewStream) ProtoMessage 

func (*NewStream) ProtoMessage()

func (*NewStream) ProtoReflect 

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

func (*NewStream) Reset 

func (x *NewStream) Reset()

func (*NewStream) String 

func (x *NewStream) String() string

type TunnelServiceClient 

type TunnelServiceClient interface {
	Connect(ctx context.Context, opts ...grpc.CallOption) (TunnelService_ConnectClient, error)
	ReverseConnect(ctx context.Context, opts ...grpc.CallOption) (TunnelService_ReverseConnectClient, error)
}

TunnelServiceClient is the client API for TunnelService 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 NewTunnelServiceClient 

func NewTunnelServiceClient(cc grpc.ClientConnInterface) TunnelServiceClient

type TunnelServiceServer 

type TunnelServiceServer interface {
	Connect(TunnelService_ConnectServer) error
	ReverseConnect(TunnelService_ReverseConnectServer) error
	// contains filtered or unexported methods
}

TunnelServiceServer is the server API for TunnelService service. All implementations must embed UnimplementedTunnelServiceServer for forward compatibility

type TunnelService_ConnectClient 

type TunnelService_ConnectClient interface {
	Send(*ConnectRequest) error
	Recv() (*ConnectResponse, error)
	grpc.ClientStream
}

type TunnelService_ConnectServer 

type TunnelService_ConnectServer interface {
	Send(*ConnectResponse) error
	Recv() (*ConnectRequest, error)
	grpc.ServerStream
}

type TunnelService_ReverseConnectClient 

type TunnelService_ReverseConnectClient interface {
	Send(*ConnectResponse) error
	Recv() (*ConnectRequest, error)
	grpc.ClientStream
}

type TunnelService_ReverseConnectServer 

type TunnelService_ReverseConnectServer interface {
	Send(*ConnectRequest) error
	Recv() (*ConnectResponse, error)
	grpc.ServerStream
}

type UnimplementedTunnelServiceServer 

type UnimplementedTunnelServiceServer struct {
}

UnimplementedTunnelServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTunnelServiceServer) Connect 

func (UnimplementedTunnelServiceServer) Connect(TunnelService_ConnectServer) error

func (UnimplementedTunnelServiceServer) ReverseConnect 

func (UnimplementedTunnelServiceServer) ReverseConnect(TunnelService_ReverseConnectServer) error

type UnsafeTunnelServiceServer 

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

UnsafeTunnelServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TunnelServiceServer 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.