Versions in this module Expand all Collapse all v18 v18.0.0 May 14, 2025 Changes in this version + const ReverseTunnel_Connect_FullMethodName + var ConnectRequestVisitor = grpctool.NewLazyStreamVisitor(&ConnectRequest{}) + var ConnectResponseVisitor = grpctool.NewLazyStreamVisitor(&ConnectResponse{}) + var File_internal_tunnel_rpc_rpc_proto protoreflect.FileDescriptor + var GatewayResponseVisitor = grpctool.NewLazyStreamVisitor(&GatewayResponse{}) + var ReverseTunnel_ServiceDesc = grpc.ServiceDesc + func MetadataKVToMeta(from []*MetadataKV) metadata.MD + func RegisterReverseTunnelServer(s grpc.ServiceRegistrar, srv ReverseTunnelServer) + type CloseSend struct + func (*CloseSend) Descriptor() ([]byte, []int) + func (*CloseSend) ProtoMessage() + func (x *CloseSend) ProtoReflect() protoreflect.Message + func (x *CloseSend) Reset() + func (x *CloseSend) String() string + type ConnectRequest struct + Msg isConnectRequest_Msg + func (*ConnectRequest) Descriptor() ([]byte, []int) + func (*ConnectRequest) ProtoMessage() + func (x *ConnectRequest) GetDescriptor_() *Descriptor + func (x *ConnectRequest) GetError() *Error + func (x *ConnectRequest) GetHeader() *Header + func (x *ConnectRequest) GetMessage() *Message + func (x *ConnectRequest) GetMsg() isConnectRequest_Msg + func (x *ConnectRequest) GetTrailer() *Trailer + func (x *ConnectRequest) ProtoReflect() protoreflect.Message + func (x *ConnectRequest) Reset() + func (x *ConnectRequest) String() string + type ConnectRequest_Descriptor_ struct + Descriptor_ *Descriptor + type ConnectRequest_Error struct + Error *Error + type ConnectRequest_Header struct + Header *Header + type ConnectRequest_Message struct + Message *Message + type ConnectRequest_Trailer struct + Trailer *Trailer + type ConnectResponse struct + Msg isConnectResponse_Msg + func (*ConnectResponse) Descriptor() ([]byte, []int) + func (*ConnectResponse) ProtoMessage() + func (x *ConnectResponse) GetCloseSend() *CloseSend + func (x *ConnectResponse) GetMessage() *Message + func (x *ConnectResponse) GetMsg() isConnectResponse_Msg + func (x *ConnectResponse) GetRequestInfo() *RequestInfo + func (x *ConnectResponse) ProtoReflect() protoreflect.Message + func (x *ConnectResponse) Reset() + func (x *ConnectResponse) String() string + type ConnectResponse_CloseSend struct + CloseSend *CloseSend + type ConnectResponse_Message struct + Message *Message + type ConnectResponse_RequestInfo struct + RequestInfo *RequestInfo + type Descriptor struct + ApiDescriptor *info.APIDescriptor + func (*Descriptor) Descriptor() ([]byte, []int) + func (*Descriptor) ProtoMessage() + func (x *Descriptor) GetApiDescriptor() *info.APIDescriptor + func (x *Descriptor) ProtoReflect() protoreflect.Message + func (x *Descriptor) Reset() + func (x *Descriptor) String() string + type Error struct + Status *status.Status + func (*Error) Descriptor() ([]byte, []int) + func (*Error) ProtoMessage() + func (x *Error) GetStatus() *status.Status + func (x *Error) ProtoReflect() protoreflect.Message + func (x *Error) Reset() + func (x *Error) String() string + type GatewayResponse struct + Msg isGatewayResponse_Msg + func (*GatewayResponse) Descriptor() ([]byte, []int) + func (*GatewayResponse) ProtoMessage() + func (x *GatewayResponse) GetError() *GatewayResponse_Error + func (x *GatewayResponse) GetHeader() *GatewayResponse_Header + func (x *GatewayResponse) GetMessage() *GatewayResponse_Message + func (x *GatewayResponse) GetMsg() isGatewayResponse_Msg + func (x *GatewayResponse) GetNoTunnel() *GatewayResponse_NoTunnel + func (x *GatewayResponse) GetTrailer() *GatewayResponse_Trailer + func (x *GatewayResponse) GetTunnelReady() *GatewayResponse_TunnelReady + func (x *GatewayResponse) ProtoReflect() protoreflect.Message + func (x *GatewayResponse) Reset() + func (x *GatewayResponse) String() string + type GatewayResponse_Error struct + Status *status.Status + func (*GatewayResponse_Error) Descriptor() ([]byte, []int) + func (*GatewayResponse_Error) ProtoMessage() + func (x *GatewayResponse_Error) GetStatus() *status.Status + func (x *GatewayResponse_Error) ProtoReflect() protoreflect.Message + func (x *GatewayResponse_Error) Reset() + func (x *GatewayResponse_Error) String() string + type GatewayResponse_Error_ struct + Error *GatewayResponse_Error + type GatewayResponse_Header struct + Meta []*MetadataKV + func (*GatewayResponse_Header) Descriptor() ([]byte, []int) + func (*GatewayResponse_Header) ProtoMessage() + func (x *GatewayResponse_Header) GetMeta() []*MetadataKV + func (x *GatewayResponse_Header) Metadata() metadata.MD + func (x *GatewayResponse_Header) ProtoReflect() protoreflect.Message + func (x *GatewayResponse_Header) Reset() + func (x *GatewayResponse_Header) String() string + type GatewayResponse_Header_ struct + Header *GatewayResponse_Header + type GatewayResponse_Message struct + Data []byte + func (*GatewayResponse_Message) Descriptor() ([]byte, []int) + func (*GatewayResponse_Message) ProtoMessage() + func (x *GatewayResponse_Message) GetData() []byte + func (x *GatewayResponse_Message) ProtoReflect() protoreflect.Message + func (x *GatewayResponse_Message) Reset() + func (x *GatewayResponse_Message) String() string + type GatewayResponse_Message_ struct + Message *GatewayResponse_Message + type GatewayResponse_NoTunnel struct + func (*GatewayResponse_NoTunnel) Descriptor() ([]byte, []int) + func (*GatewayResponse_NoTunnel) ProtoMessage() + func (x *GatewayResponse_NoTunnel) ProtoReflect() protoreflect.Message + func (x *GatewayResponse_NoTunnel) Reset() + func (x *GatewayResponse_NoTunnel) String() string + type GatewayResponse_NoTunnel_ struct + NoTunnel *GatewayResponse_NoTunnel + type GatewayResponse_Trailer struct + Meta []*MetadataKV + func (*GatewayResponse_Trailer) Descriptor() ([]byte, []int) + func (*GatewayResponse_Trailer) ProtoMessage() + func (x *GatewayResponse_Trailer) GetMeta() []*MetadataKV + func (x *GatewayResponse_Trailer) Metadata() metadata.MD + func (x *GatewayResponse_Trailer) ProtoReflect() protoreflect.Message + func (x *GatewayResponse_Trailer) Reset() + func (x *GatewayResponse_Trailer) String() string + type GatewayResponse_Trailer_ struct + Trailer *GatewayResponse_Trailer + type GatewayResponse_TunnelReady struct + func (*GatewayResponse_TunnelReady) Descriptor() ([]byte, []int) + func (*GatewayResponse_TunnelReady) ProtoMessage() + func (x *GatewayResponse_TunnelReady) ProtoReflect() protoreflect.Message + func (x *GatewayResponse_TunnelReady) Reset() + func (x *GatewayResponse_TunnelReady) String() string + type GatewayResponse_TunnelReady_ struct + TunnelReady *GatewayResponse_TunnelReady + type Header struct + Meta []*MetadataKV + func (*Header) Descriptor() ([]byte, []int) + func (*Header) ProtoMessage() + func (x *Header) GetMeta() []*MetadataKV + func (x *Header) Metadata() metadata.MD + func (x *Header) ProtoReflect() protoreflect.Message + func (x *Header) Reset() + func (x *Header) String() string + type Message struct + Data []byte + func (*Message) Descriptor() ([]byte, []int) + func (*Message) ProtoMessage() + func (x *Message) GetData() []byte + func (x *Message) ProtoReflect() protoreflect.Message + func (x *Message) Reset() + func (x *Message) String() string + type MetadataKV struct + Key []byte + Value *MetadataValues + func MetaToMetadataKV(from metadata.MD) []*MetadataKV + func (*MetadataKV) Descriptor() ([]byte, []int) + func (*MetadataKV) ProtoMessage() + func (x *MetadataKV) GetKey() []byte + func (x *MetadataKV) GetValue() *MetadataValues + func (x *MetadataKV) ProtoReflect() protoreflect.Message + func (x *MetadataKV) Reset() + func (x *MetadataKV) String() string + type MetadataValues struct + Value [][]byte + func (*MetadataValues) Descriptor() ([]byte, []int) + func (*MetadataValues) ProtoMessage() + func (x *MetadataValues) GetValue() [][]byte + func (x *MetadataValues) ProtoReflect() protoreflect.Message + func (x *MetadataValues) Reset() + func (x *MetadataValues) String() string + type RequestInfo struct + Meta []*MetadataKV + MethodName string + func (*RequestInfo) Descriptor() ([]byte, []int) + func (*RequestInfo) ProtoMessage() + func (x *RequestInfo) GetMeta() []*MetadataKV + func (x *RequestInfo) GetMethodName() string + func (x *RequestInfo) Metadata() metadata.MD + func (x *RequestInfo) ProtoReflect() protoreflect.Message + func (x *RequestInfo) Reset() + func (x *RequestInfo) String() string + type ReverseTunnelClient interface + Connect func(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[ConnectRequest, ConnectResponse], error) + func NewReverseTunnelClient(cc grpc.ClientConnInterface) ReverseTunnelClient + type ReverseTunnelServer interface + Connect func(grpc.BidiStreamingServer[ConnectRequest, ConnectResponse]) error + type ReverseTunnel_ConnectClient = grpc.BidiStreamingClient[ConnectRequest, ConnectResponse] + type ReverseTunnel_ConnectServer = grpc.BidiStreamingServer[ConnectRequest, ConnectResponse] + type StartStreaming struct + func (*StartStreaming) Descriptor() ([]byte, []int) + func (*StartStreaming) ProtoMessage() + func (x *StartStreaming) ProtoReflect() protoreflect.Message + func (x *StartStreaming) Reset() + func (x *StartStreaming) String() string + type Trailer struct + Meta []*MetadataKV + func (*Trailer) Descriptor() ([]byte, []int) + func (*Trailer) ProtoMessage() + func (x *Trailer) GetMeta() []*MetadataKV + func (x *Trailer) Metadata() metadata.MD + func (x *Trailer) ProtoReflect() protoreflect.Message + func (x *Trailer) Reset() + func (x *Trailer) String() string + type UnimplementedReverseTunnelServer struct + func (UnimplementedReverseTunnelServer) Connect(grpc.BidiStreamingServer[ConnectRequest, ConnectResponse]) error + type UnsafeReverseTunnelServer interface v18.0.0-rc42 May 13, 2025 Other modules containing this package gitlab.com/gitlab-org/cluster-integration/gitlab-agent/v16 gitlab.com/gitlab-org/cluster-integration/gitlab-agent/v17