rpc

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
}

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
}

type ConnectRequestFrame = isConnectRequest_Frame

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

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

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

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

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

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
}

type ConnectResponseFrame = isConnectResponse_Frame

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

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

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

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

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
}

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

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

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
}

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

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

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

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

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

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

type UnimplementedTunnelServiceServer struct {
}

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