rpc

package
v17.4.1 Latest Latest
Warning

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

 Go to latest Published: Sep 24, 2024 License: MIT Imports: 15 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ReverseTunnel_Connect_FullMethodName = "/gitlab.agent.reverse_tunnel.rpc.ReverseTunnel/Connect"
)

Variables

View Source 
var (
	GatewayResponseVisitor = grpctool.NewLazyStreamVisitor(&GatewayResponse{})
	ConnectRequestVisitor  = grpctool.NewLazyStreamVisitor(&ConnectRequest{})
	ConnectResponseVisitor = grpctool.NewLazyStreamVisitor(&ConnectResponse{})
)
View Source 
var File_internal_tunnel_rpc_rpc_proto protoreflect.FileDescriptor
View Source 
var ReverseTunnel_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "gitlab.agent.reverse_tunnel.rpc.ReverseTunnel",
	HandlerType: (*ReverseTunnelServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Connect",
			Handler:       _ReverseTunnel_Connect_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "internal/tunnel/rpc/rpc.proto",
}

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

Functions

func RegisterReverseTunnelServer 

func RegisterReverseTunnelServer(s grpc.ServiceRegistrar, srv ReverseTunnelServer)

Types

type CloseSend 

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

func (*CloseSend) Descriptor deprecated 

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

Deprecated: Use CloseSend.ProtoReflect.Descriptor instead.

func (*CloseSend) ProtoMessage 

func (*CloseSend) ProtoMessage()

func (*CloseSend) ProtoReflect 

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

func (*CloseSend) Reset 

func (x *CloseSend) Reset()

func (*CloseSend) String 

func (x *CloseSend) String() string

type ConnectRequest 

type ConnectRequest struct {

	// Types that are assignable to Msg:
	//
	//	*ConnectRequest_Descriptor_
	//	*ConnectRequest_Header
	//	*ConnectRequest_Message
	//	*ConnectRequest_Trailer
	//	*ConnectRequest_Error
	Msg isConnectRequest_Msg `protobuf_oneof:"msg"`
	// contains filtered or unexported fields
}

func (*ConnectRequest) Descriptor deprecated 

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

Deprecated: Use ConnectRequest.ProtoReflect.Descriptor instead.

func (*ConnectRequest) GetDescriptor_ 

func (x *ConnectRequest) GetDescriptor_() *Descriptor

func (*ConnectRequest) GetError 

func (x *ConnectRequest) GetError() *Error

func (*ConnectRequest) GetHeader 

func (x *ConnectRequest) GetHeader() *Header

func (*ConnectRequest) GetMessage 

func (x *ConnectRequest) GetMessage() *Message

func (*ConnectRequest) GetMsg 

func (m *ConnectRequest) GetMsg() isConnectRequest_Msg

func (*ConnectRequest) GetTrailer 

func (x *ConnectRequest) GetTrailer() *Trailer

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 ConnectRequest_Descriptor_ 

type ConnectRequest_Descriptor_ struct {
	Descriptor_ *Descriptor `protobuf:"bytes,1,opt,name=descriptor,proto3,oneof"`
}

type ConnectRequest_Error 

type ConnectRequest_Error struct {
	Error *Error `protobuf:"bytes,5,opt,name=error,proto3,oneof"`
}

type ConnectRequest_Header 

type ConnectRequest_Header struct {
	Header *Header `protobuf:"bytes,2,opt,name=header,proto3,oneof"`
}

type ConnectRequest_Message 

type ConnectRequest_Message struct {
	Message *Message `protobuf:"bytes,3,opt,name=message,proto3,oneof"`
}

type ConnectRequest_Trailer 

type ConnectRequest_Trailer struct {
	Trailer *Trailer `protobuf:"bytes,4,opt,name=trailer,proto3,oneof"`
}

type ConnectResponse 

type ConnectResponse struct {

	// Types that are assignable to Msg:
	//
	//	*ConnectResponse_RequestInfo
	//	*ConnectResponse_Message
	//	*ConnectResponse_CloseSend
	Msg isConnectResponse_Msg `protobuf_oneof:"msg"`
	// contains filtered or unexported fields
}

func (*ConnectResponse) Descriptor deprecated 

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

Deprecated: Use ConnectResponse.ProtoReflect.Descriptor instead.

func (*ConnectResponse) GetCloseSend 

func (x *ConnectResponse) GetCloseSend() *CloseSend

func (*ConnectResponse) GetMessage 

func (x *ConnectResponse) GetMessage() *Message

func (*ConnectResponse) GetMsg 

func (m *ConnectResponse) GetMsg() isConnectResponse_Msg

func (*ConnectResponse) GetRequestInfo 

func (x *ConnectResponse) GetRequestInfo() *RequestInfo

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 ConnectResponse_CloseSend 

type ConnectResponse_CloseSend struct {
	CloseSend *CloseSend `protobuf:"bytes,3,opt,name=close_send,json=closeSend,proto3,oneof"`
}

type ConnectResponse_Message 

type ConnectResponse_Message struct {
	Message *Message `protobuf:"bytes,2,opt,name=message,proto3,oneof"`
}

type ConnectResponse_RequestInfo 

type ConnectResponse_RequestInfo struct {
	RequestInfo *RequestInfo `protobuf:"bytes,1,opt,name=request_info,json=requestInfo,proto3,oneof"`
}

type Descriptor 

type Descriptor struct {
	ApiDescriptor *info.APIDescriptor `protobuf:"bytes,1,opt,name=api_descriptor,json=apiDescriptor,proto3" json:"api_descriptor,omitempty"`
	// contains filtered or unexported fields
}

func (*Descriptor) Descriptor deprecated 

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

Deprecated: Use Descriptor.ProtoReflect.Descriptor instead.

func (*Descriptor) GetApiDescriptor 

func (x *Descriptor) GetApiDescriptor() *info.APIDescriptor

func (*Descriptor) ProtoMessage 

func (*Descriptor) ProtoMessage()

func (*Descriptor) ProtoReflect 

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

func (*Descriptor) Reset 

func (x *Descriptor) Reset()

func (*Descriptor) String 

func (x *Descriptor) String() string

type Error 

type Error struct {
	Status *status.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*Error) Descriptor deprecated 

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

Deprecated: Use Error.ProtoReflect.Descriptor instead.

func (*Error) GetStatus 

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

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) ProtoReflect 

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

func (*Error) Reset 

func (x *Error) Reset()

func (*Error) String 

func (x *Error) String() string

type GatewayResponse 

type GatewayResponse struct {

	// Types that are assignable to Msg:
	//
	//	*GatewayResponse_TunnelReady_
	//	*GatewayResponse_Header_
	//	*GatewayResponse_Message_
	//	*GatewayResponse_Trailer_
	//	*GatewayResponse_Error_
	//	*GatewayResponse_NoTunnel_
	Msg isGatewayResponse_Msg `protobuf_oneof:"msg"`
	// contains filtered or unexported fields
}

func (*GatewayResponse) Descriptor deprecated 

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

Deprecated: Use GatewayResponse.ProtoReflect.Descriptor instead.

func (*GatewayResponse) GetError 

func (x *GatewayResponse) GetError() *GatewayResponse_Error

func (*GatewayResponse) GetHeader 

func (x *GatewayResponse) GetHeader() *GatewayResponse_Header

func (*GatewayResponse) GetMessage 

func (x *GatewayResponse) GetMessage() *GatewayResponse_Message

func (*GatewayResponse) GetMsg 

func (m *GatewayResponse) GetMsg() isGatewayResponse_Msg

func (*GatewayResponse) GetNoTunnel 

func (x *GatewayResponse) GetNoTunnel() *GatewayResponse_NoTunnel

func (*GatewayResponse) GetTrailer 

func (x *GatewayResponse) GetTrailer() *GatewayResponse_Trailer

func (*GatewayResponse) GetTunnelReady 

func (x *GatewayResponse) GetTunnelReady() *GatewayResponse_TunnelReady

func (*GatewayResponse) ProtoMessage 

func (*GatewayResponse) ProtoMessage()

func (*GatewayResponse) ProtoReflect 

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

func (*GatewayResponse) Reset 

func (x *GatewayResponse) Reset()

func (*GatewayResponse) String 

func (x *GatewayResponse) String() string

type GatewayResponse_Error 

type GatewayResponse_Error struct {
	Status *status.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*GatewayResponse_Error) Descriptor deprecated 

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

Deprecated: Use GatewayResponse_Error.ProtoReflect.Descriptor instead.

func (*GatewayResponse_Error) GetStatus 

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

func (*GatewayResponse_Error) ProtoMessage 

func (*GatewayResponse_Error) ProtoMessage()

func (*GatewayResponse_Error) ProtoReflect 

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

func (*GatewayResponse_Error) Reset 

func (x *GatewayResponse_Error) Reset()

func (*GatewayResponse_Error) String 

func (x *GatewayResponse_Error) String() string

type GatewayResponse_Error_ 

type GatewayResponse_Error_ struct {
	Error *GatewayResponse_Error `protobuf:"bytes,5,opt,name=error,proto3,oneof"`
}

type GatewayResponse_Header 

type GatewayResponse_Header struct {
	Meta map[string]*prototool.HeaderValues `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GatewayResponse_Header) Descriptor deprecated 

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

Deprecated: Use GatewayResponse_Header.ProtoReflect.Descriptor instead.

func (*GatewayResponse_Header) GetMeta 

func (x *GatewayResponse_Header) GetMeta() map[string]*prototool.HeaderValues

func (*GatewayResponse_Header) Metadata 

func (x *GatewayResponse_Header) Metadata() metadata.MD

func (*GatewayResponse_Header) ProtoMessage 

func (*GatewayResponse_Header) ProtoMessage()

func (*GatewayResponse_Header) ProtoReflect 

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

func (*GatewayResponse_Header) Reset 

func (x *GatewayResponse_Header) Reset()

func (*GatewayResponse_Header) String 

func (x *GatewayResponse_Header) String() string

type GatewayResponse_Header_ 

type GatewayResponse_Header_ struct {
	Header *GatewayResponse_Header `protobuf:"bytes,2,opt,name=header,proto3,oneof"`
}

type GatewayResponse_Message 

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

func (*GatewayResponse_Message) Descriptor deprecated 

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

Deprecated: Use GatewayResponse_Message.ProtoReflect.Descriptor instead.

func (*GatewayResponse_Message) GetData 

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

func (*GatewayResponse_Message) ProtoMessage 

func (*GatewayResponse_Message) ProtoMessage()

func (*GatewayResponse_Message) ProtoReflect 

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

func (*GatewayResponse_Message) Reset 

func (x *GatewayResponse_Message) Reset()

func (*GatewayResponse_Message) String 

func (x *GatewayResponse_Message) String() string

type GatewayResponse_Message_ 

type GatewayResponse_Message_ struct {
	Message *GatewayResponse_Message `protobuf:"bytes,3,opt,name=message,proto3,oneof"`
}

type GatewayResponse_NoTunnel 

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

func (*GatewayResponse_NoTunnel) Descriptor deprecated 

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

Deprecated: Use GatewayResponse_NoTunnel.ProtoReflect.Descriptor instead.

func (*GatewayResponse_NoTunnel) ProtoMessage 

func (*GatewayResponse_NoTunnel) ProtoMessage()

func (*GatewayResponse_NoTunnel) ProtoReflect 

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

func (*GatewayResponse_NoTunnel) Reset 

func (x *GatewayResponse_NoTunnel) Reset()

func (*GatewayResponse_NoTunnel) String 

func (x *GatewayResponse_NoTunnel) String() string

type GatewayResponse_NoTunnel_ 

type GatewayResponse_NoTunnel_ struct {
	NoTunnel *GatewayResponse_NoTunnel `protobuf:"bytes,6,opt,name=no_tunnel,json=noTunnel,proto3,oneof"`
}

type GatewayResponse_Trailer 

type GatewayResponse_Trailer struct {
	Meta map[string]*prototool.HeaderValues `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GatewayResponse_Trailer) Descriptor deprecated 

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

Deprecated: Use GatewayResponse_Trailer.ProtoReflect.Descriptor instead.

func (*GatewayResponse_Trailer) GetMeta 

func (x *GatewayResponse_Trailer) GetMeta() map[string]*prototool.HeaderValues

func (*GatewayResponse_Trailer) Metadata 

func (x *GatewayResponse_Trailer) Metadata() metadata.MD

func (*GatewayResponse_Trailer) ProtoMessage 

func (*GatewayResponse_Trailer) ProtoMessage()

func (*GatewayResponse_Trailer) ProtoReflect 

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

func (*GatewayResponse_Trailer) Reset 

func (x *GatewayResponse_Trailer) Reset()

func (*GatewayResponse_Trailer) String 

func (x *GatewayResponse_Trailer) String() string

type GatewayResponse_Trailer_ 

type GatewayResponse_Trailer_ struct {
	Trailer *GatewayResponse_Trailer `protobuf:"bytes,4,opt,name=trailer,proto3,oneof"`
}

type GatewayResponse_TunnelReady 

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

func (*GatewayResponse_TunnelReady) Descriptor deprecated 

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

Deprecated: Use GatewayResponse_TunnelReady.ProtoReflect.Descriptor instead.

func (*GatewayResponse_TunnelReady) ProtoMessage 

func (*GatewayResponse_TunnelReady) ProtoMessage()

func (*GatewayResponse_TunnelReady) ProtoReflect 

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

func (*GatewayResponse_TunnelReady) Reset 

func (x *GatewayResponse_TunnelReady) Reset()

func (*GatewayResponse_TunnelReady) String 

func (x *GatewayResponse_TunnelReady) String() string

type GatewayResponse_TunnelReady_ 

type GatewayResponse_TunnelReady_ struct {
	TunnelReady *GatewayResponse_TunnelReady `protobuf:"bytes,1,opt,name=tunnel_ready,json=tunnelReady,proto3,oneof"`
}
type Header struct {
	Meta map[string]*prototool.HeaderValues `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Header) Descriptor deprecated 

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

Deprecated: Use Header.ProtoReflect.Descriptor instead.

func (*Header) GetMeta 

func (x *Header) GetMeta() map[string]*prototool.HeaderValues

func (*Header) Metadata 

func (x *Header) Metadata() metadata.MD

func (*Header) ProtoMessage 

func (*Header) ProtoMessage()

func (*Header) ProtoReflect 

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

func (*Header) Reset 

func (x *Header) Reset()

func (*Header) String 

func (x *Header) String() string

type Message 

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

func (*Message) Descriptor deprecated 

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

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetData 

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

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) ProtoReflect 

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

func (*Message) Reset 

func (x *Message) Reset()

func (*Message) String 

func (x *Message) String() string

type RequestInfo 

type RequestInfo struct {
	MethodName string                             `protobuf:"bytes,1,opt,name=method_name,json=methodName,proto3" json:"method_name,omitempty"`
	Meta       map[string]*prototool.HeaderValues `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RequestInfo) Descriptor deprecated 

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

Deprecated: Use RequestInfo.ProtoReflect.Descriptor instead.

func (*RequestInfo) GetMeta 

func (x *RequestInfo) GetMeta() map[string]*prototool.HeaderValues

func (*RequestInfo) GetMethodName 

func (x *RequestInfo) GetMethodName() string

func (*RequestInfo) Metadata 

func (x *RequestInfo) Metadata() metadata.MD

func (*RequestInfo) ProtoMessage 

func (*RequestInfo) ProtoMessage()

func (*RequestInfo) ProtoReflect 

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

func (*RequestInfo) Reset 

func (x *RequestInfo) Reset()

func (*RequestInfo) String 

func (x *RequestInfo) String() string

type ReverseTunnelClient 

type ReverseTunnelClient interface {
	Connect(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[ConnectRequest, ConnectResponse], error)
}

ReverseTunnelClient is the client API for ReverseTunnel 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 NewReverseTunnelClient 

func NewReverseTunnelClient(cc grpc.ClientConnInterface) ReverseTunnelClient

type ReverseTunnelServer 

type ReverseTunnelServer interface {
	Connect(grpc.BidiStreamingServer[ConnectRequest, ConnectResponse]) error
	// contains filtered or unexported methods
}

ReverseTunnelServer is the server API for ReverseTunnel service. All implementations must embed UnimplementedReverseTunnelServer for forward compatibility.

type ReverseTunnel_ConnectClient 

type ReverseTunnel_ConnectClient = grpc.BidiStreamingClient[ConnectRequest, ConnectResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type ReverseTunnel_ConnectServer 

type ReverseTunnel_ConnectServer = grpc.BidiStreamingServer[ConnectRequest, ConnectResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type StartStreaming 

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

func (*StartStreaming) Descriptor deprecated 

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

Deprecated: Use StartStreaming.ProtoReflect.Descriptor instead.

func (*StartStreaming) ProtoMessage 

func (*StartStreaming) ProtoMessage()

func (*StartStreaming) ProtoReflect 

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

func (*StartStreaming) Reset 

func (x *StartStreaming) Reset()

func (*StartStreaming) String 

func (x *StartStreaming) String() string

type Trailer 

type Trailer struct {
	Meta map[string]*prototool.HeaderValues `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Trailer) Descriptor deprecated 

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

Deprecated: Use Trailer.ProtoReflect.Descriptor instead.

func (*Trailer) GetMeta 

func (x *Trailer) GetMeta() map[string]*prototool.HeaderValues

func (*Trailer) Metadata 

func (x *Trailer) Metadata() metadata.MD

func (*Trailer) ProtoMessage 

func (*Trailer) ProtoMessage()

func (*Trailer) ProtoReflect 

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

func (*Trailer) Reset 

func (x *Trailer) Reset()

func (*Trailer) String 

func (x *Trailer) String() string

type UnimplementedReverseTunnelServer 

type UnimplementedReverseTunnelServer struct{}

UnimplementedReverseTunnelServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedReverseTunnelServer) Connect 

func (UnimplementedReverseTunnelServer) Connect(grpc.BidiStreamingServer[ConnectRequest, ConnectResponse]) error

type UnsafeReverseTunnelServer 

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

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