Versions in this module Expand all Collapse all v0 v0.1.1 Apr 19, 2026 v0.1.0 Apr 19, 2026 Changes in this version + const Tunnel_DevsyConfig_FullMethodName + const Tunnel_DockerCredentials_FullMethodName + const Tunnel_ForwardPort_FullMethodName + const Tunnel_GPGPublicKeys_FullMethodName + const Tunnel_GitCredentials_FullMethodName + const Tunnel_GitSSHSignature_FullMethodName + const Tunnel_GitUser_FullMethodName + const Tunnel_KubeConfig_FullMethodName + const Tunnel_Log_FullMethodName + const Tunnel_Ping_FullMethodName + const Tunnel_SendResult_FullMethodName + const Tunnel_StopForwardPort_FullMethodName + const Tunnel_StreamMount_FullMethodName + const Tunnel_StreamWorkspace_FullMethodName + var File_tunnel_proto protoreflect.FileDescriptor + var LogLevel_name = map[int32]string + var LogLevel_value = map[string]int32 + var Tunnel_ServiceDesc = grpc.ServiceDesc + func RegisterTunnelServer(s grpc.ServiceRegistrar, srv TunnelServer) + type Chunk struct + Content []byte + func (*Chunk) Descriptor() ([]byte, []int) + func (*Chunk) ProtoMessage() + func (x *Chunk) GetContent() []byte + func (x *Chunk) ProtoReflect() protoreflect.Message + func (x *Chunk) Reset() + func (x *Chunk) String() string + type Empty struct + func (*Empty) Descriptor() ([]byte, []int) + func (*Empty) ProtoMessage() + func (x *Empty) ProtoReflect() protoreflect.Message + func (x *Empty) Reset() + func (x *Empty) String() string + type ForwardPortRequest struct + Port string + func (*ForwardPortRequest) Descriptor() ([]byte, []int) + func (*ForwardPortRequest) ProtoMessage() + func (x *ForwardPortRequest) GetPort() string + func (x *ForwardPortRequest) ProtoReflect() protoreflect.Message + func (x *ForwardPortRequest) Reset() + func (x *ForwardPortRequest) String() string + type ForwardPortResponse struct + func (*ForwardPortResponse) Descriptor() ([]byte, []int) + func (*ForwardPortResponse) ProtoMessage() + func (x *ForwardPortResponse) ProtoReflect() protoreflect.Message + func (x *ForwardPortResponse) Reset() + func (x *ForwardPortResponse) String() string + type LogLevel int32 + const LogLevel_DEBUG + const LogLevel_DONE + const LogLevel_ERROR + const LogLevel_INFO + const LogLevel_WARNING + func (LogLevel) Descriptor() protoreflect.EnumDescriptor + func (LogLevel) EnumDescriptor() ([]byte, []int) + func (LogLevel) Type() protoreflect.EnumType + func (x LogLevel) Enum() *LogLevel + func (x LogLevel) Number() protoreflect.EnumNumber + func (x LogLevel) String() string + type LogMessage struct + LogLevel LogLevel + Message string + func (*LogMessage) Descriptor() ([]byte, []int) + func (*LogMessage) ProtoMessage() + func (x *LogMessage) GetLogLevel() LogLevel + func (x *LogMessage) GetMessage() string + func (x *LogMessage) ProtoReflect() protoreflect.Message + func (x *LogMessage) Reset() + func (x *LogMessage) String() string + type Message struct + Message string + func (*Message) Descriptor() ([]byte, []int) + func (*Message) ProtoMessage() + func (x *Message) GetMessage() string + func (x *Message) ProtoReflect() protoreflect.Message + func (x *Message) Reset() + func (x *Message) String() string + type StopForwardPortRequest struct + Port string + func (*StopForwardPortRequest) Descriptor() ([]byte, []int) + func (*StopForwardPortRequest) ProtoMessage() + func (x *StopForwardPortRequest) GetPort() string + func (x *StopForwardPortRequest) ProtoReflect() protoreflect.Message + func (x *StopForwardPortRequest) Reset() + func (x *StopForwardPortRequest) String() string + type StopForwardPortResponse struct + func (*StopForwardPortResponse) Descriptor() ([]byte, []int) + func (*StopForwardPortResponse) ProtoMessage() + func (x *StopForwardPortResponse) ProtoReflect() protoreflect.Message + func (x *StopForwardPortResponse) Reset() + func (x *StopForwardPortResponse) String() string + type StreamMountRequest struct + Mount string + func (*StreamMountRequest) Descriptor() ([]byte, []int) + func (*StreamMountRequest) ProtoMessage() + func (x *StreamMountRequest) GetMount() string + func (x *StreamMountRequest) ProtoReflect() protoreflect.Message + func (x *StreamMountRequest) Reset() + func (x *StreamMountRequest) String() string + type TunnelClient interface + DevsyConfig func(ctx context.Context, in *Message, opts ...grpc.CallOption) (*Message, error) + DockerCredentials func(ctx context.Context, in *Message, opts ...grpc.CallOption) (*Message, error) + ForwardPort func(ctx context.Context, in *ForwardPortRequest, opts ...grpc.CallOption) (*ForwardPortResponse, error) + GPGPublicKeys func(ctx context.Context, in *Message, opts ...grpc.CallOption) (*Message, error) + GitCredentials func(ctx context.Context, in *Message, opts ...grpc.CallOption) (*Message, error) + GitSSHSignature func(ctx context.Context, in *Message, opts ...grpc.CallOption) (*Message, error) + GitUser func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Message, error) + KubeConfig func(ctx context.Context, in *Message, opts ...grpc.CallOption) (*Message, error) + Log func(ctx context.Context, in *LogMessage, opts ...grpc.CallOption) (*Empty, error) + Ping func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error) + SendResult func(ctx context.Context, in *Message, opts ...grpc.CallOption) (*Empty, error) + StopForwardPort func(ctx context.Context, in *StopForwardPortRequest, opts ...grpc.CallOption) (*StopForwardPortResponse, error) + StreamMount func(ctx context.Context, in *StreamMountRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[Chunk], error) + StreamWorkspace func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (grpc.ServerStreamingClient[Chunk], error) + func NewTunnelClient(cc grpc.ClientConnInterface) TunnelClient + type TunnelServer interface + DevsyConfig func(context.Context, *Message) (*Message, error) + DockerCredentials func(context.Context, *Message) (*Message, error) + ForwardPort func(context.Context, *ForwardPortRequest) (*ForwardPortResponse, error) + GPGPublicKeys func(context.Context, *Message) (*Message, error) + GitCredentials func(context.Context, *Message) (*Message, error) + GitSSHSignature func(context.Context, *Message) (*Message, error) + GitUser func(context.Context, *Empty) (*Message, error) + KubeConfig func(context.Context, *Message) (*Message, error) + Log func(context.Context, *LogMessage) (*Empty, error) + Ping func(context.Context, *Empty) (*Empty, error) + SendResult func(context.Context, *Message) (*Empty, error) + StopForwardPort func(context.Context, *StopForwardPortRequest) (*StopForwardPortResponse, error) + StreamMount func(*StreamMountRequest, grpc.ServerStreamingServer[Chunk]) error + StreamWorkspace func(*Empty, grpc.ServerStreamingServer[Chunk]) error + type Tunnel_StreamMountClient = grpc.ServerStreamingClient[Chunk] + type Tunnel_StreamMountServer = grpc.ServerStreamingServer[Chunk] + type Tunnel_StreamWorkspaceClient = grpc.ServerStreamingClient[Chunk] + type Tunnel_StreamWorkspaceServer = grpc.ServerStreamingServer[Chunk] + type UnimplementedTunnelServer struct + func (UnimplementedTunnelServer) DevsyConfig(context.Context, *Message) (*Message, error) + func (UnimplementedTunnelServer) DockerCredentials(context.Context, *Message) (*Message, error) + func (UnimplementedTunnelServer) ForwardPort(context.Context, *ForwardPortRequest) (*ForwardPortResponse, error) + func (UnimplementedTunnelServer) GPGPublicKeys(context.Context, *Message) (*Message, error) + func (UnimplementedTunnelServer) GitCredentials(context.Context, *Message) (*Message, error) + func (UnimplementedTunnelServer) GitSSHSignature(context.Context, *Message) (*Message, error) + func (UnimplementedTunnelServer) GitUser(context.Context, *Empty) (*Message, error) + func (UnimplementedTunnelServer) KubeConfig(context.Context, *Message) (*Message, error) + func (UnimplementedTunnelServer) Log(context.Context, *LogMessage) (*Empty, error) + func (UnimplementedTunnelServer) Ping(context.Context, *Empty) (*Empty, error) + func (UnimplementedTunnelServer) SendResult(context.Context, *Message) (*Empty, error) + func (UnimplementedTunnelServer) StopForwardPort(context.Context, *StopForwardPortRequest) (*StopForwardPortResponse, error) + func (UnimplementedTunnelServer) StreamMount(*StreamMountRequest, grpc.ServerStreamingServer[Chunk]) error + func (UnimplementedTunnelServer) StreamWorkspace(*Empty, grpc.ServerStreamingServer[Chunk]) error + type UnsafeTunnelServer interface