Documentation
¶
Index ¶
- Variables
- func RegisterTunnelServer(s grpc.ServiceRegistrar, srv TunnelServer)
- type Chunk
- type Empty
- type LogLevel
- type LogMessage
- type Message
- type TunnelClient
- type TunnelServer
- type Tunnel_ReadWorkspaceClient
- type Tunnel_ReadWorkspaceServer
- type UnimplementedTunnelServer
- func (UnimplementedTunnelServer) DockerCredentials(context.Context, *Message) (*Message, error)
- func (UnimplementedTunnelServer) GitCredentials(context.Context, *Message) (*Message, error)
- func (UnimplementedTunnelServer) GitUser(context.Context, *Empty) (*Message, error)
- func (UnimplementedTunnelServer) Log(context.Context, *LogMessage) (*Empty, error)
- func (UnimplementedTunnelServer) Ping(context.Context, *Empty) (*Empty, error)
- func (UnimplementedTunnelServer) ReadWorkspace(*Empty, Tunnel_ReadWorkspaceServer) error
- func (UnimplementedTunnelServer) SendResult(context.Context, *Message) (*Empty, error)
- type UnsafeTunnelServer
Constants ¶
This section is empty.
Variables ¶
var ( LogLevel_name = map[int32]string{ 0: "DEBUG", 1: "INFO", 2: "DONE", 3: "WARNING", 4: "ERROR", } LogLevel_value = map[string]int32{ "DEBUG": 0, "INFO": 1, "DONE": 2, "WARNING": 3, "ERROR": 4, } )
Enum value maps for LogLevel.
var File_tunnel_proto protoreflect.FileDescriptor
var Tunnel_ServiceDesc = grpc.ServiceDesc{ ServiceName: "tunnel.Tunnel", HandlerType: (*TunnelServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Ping", Handler: _Tunnel_Ping_Handler, }, { MethodName: "Log", Handler: _Tunnel_Log_Handler, }, { MethodName: "SendResult", Handler: _Tunnel_SendResult_Handler, }, { MethodName: "DockerCredentials", Handler: _Tunnel_DockerCredentials_Handler, }, { MethodName: "GitCredentials", Handler: _Tunnel_GitCredentials_Handler, }, { MethodName: "GitUser", Handler: _Tunnel_GitUser_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "ReadWorkspace", Handler: _Tunnel_ReadWorkspace_Handler, ServerStreams: true, }, }, Metadata: "tunnel.proto", }
Tunnel_ServiceDesc is the grpc.ServiceDesc for Tunnel service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterTunnelServer ¶
func RegisterTunnelServer(s grpc.ServiceRegistrar, srv TunnelServer)
Types ¶
type Chunk ¶
type Chunk struct { Content []byte `protobuf:"bytes,1,opt,name=Content,proto3" json:"Content,omitempty"` // contains filtered or unexported fields }
func (*Chunk) Descriptor
deprecated
func (*Chunk) GetContent ¶
func (*Chunk) ProtoMessage ¶
func (*Chunk) ProtoMessage()
func (*Chunk) ProtoReflect ¶
func (x *Chunk) ProtoReflect() protoreflect.Message
type Empty ¶
type Empty struct {
// contains filtered or unexported fields
}
func (*Empty) Descriptor
deprecated
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
func (*Empty) ProtoReflect ¶
func (x *Empty) ProtoReflect() protoreflect.Message
type LogLevel ¶
type LogLevel int32
func (LogLevel) Descriptor ¶
func (LogLevel) Descriptor() protoreflect.EnumDescriptor
func (LogLevel) EnumDescriptor
deprecated
func (LogLevel) Number ¶
func (x LogLevel) Number() protoreflect.EnumNumber
func (LogLevel) Type ¶
func (LogLevel) Type() protoreflect.EnumType
type LogMessage ¶
type LogMessage struct { LogLevel LogLevel `protobuf:"varint,1,opt,name=logLevel,proto3,enum=tunnel.LogLevel" json:"logLevel,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*LogMessage) Descriptor
deprecated
func (*LogMessage) Descriptor() ([]byte, []int)
Deprecated: Use LogMessage.ProtoReflect.Descriptor instead.
func (*LogMessage) GetLogLevel ¶
func (x *LogMessage) GetLogLevel() LogLevel
func (*LogMessage) GetMessage ¶
func (x *LogMessage) GetMessage() string
func (*LogMessage) ProtoMessage ¶
func (*LogMessage) ProtoMessage()
func (*LogMessage) ProtoReflect ¶
func (x *LogMessage) ProtoReflect() protoreflect.Message
func (*LogMessage) Reset ¶
func (x *LogMessage) Reset()
func (*LogMessage) String ¶
func (x *LogMessage) String() string
type Message ¶
type Message struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*Message) Descriptor
deprecated
func (*Message) GetMessage ¶
func (*Message) ProtoMessage ¶
func (*Message) ProtoMessage()
func (*Message) ProtoReflect ¶
func (x *Message) ProtoReflect() protoreflect.Message
type TunnelClient ¶
type TunnelClient interface { Ping(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error) Log(ctx context.Context, in *LogMessage, opts ...grpc.CallOption) (*Empty, error) ReadWorkspace(ctx context.Context, in *Empty, opts ...grpc.CallOption) (Tunnel_ReadWorkspaceClient, error) SendResult(ctx context.Context, in *Message, opts ...grpc.CallOption) (*Empty, error) DockerCredentials(ctx context.Context, in *Message, opts ...grpc.CallOption) (*Message, error) GitCredentials(ctx context.Context, in *Message, opts ...grpc.CallOption) (*Message, error) GitUser(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Message, error) }
TunnelClient is the client API for Tunnel 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 NewTunnelClient ¶
func NewTunnelClient(cc grpc.ClientConnInterface) TunnelClient
type TunnelServer ¶
type TunnelServer interface { Ping(context.Context, *Empty) (*Empty, error) Log(context.Context, *LogMessage) (*Empty, error) ReadWorkspace(*Empty, Tunnel_ReadWorkspaceServer) error SendResult(context.Context, *Message) (*Empty, error) DockerCredentials(context.Context, *Message) (*Message, error) GitCredentials(context.Context, *Message) (*Message, error) GitUser(context.Context, *Empty) (*Message, error) // contains filtered or unexported methods }
TunnelServer is the server API for Tunnel service. All implementations must embed UnimplementedTunnelServer for forward compatibility
type Tunnel_ReadWorkspaceClient ¶
type Tunnel_ReadWorkspaceClient interface { Recv() (*Chunk, error) grpc.ClientStream }
type Tunnel_ReadWorkspaceServer ¶
type Tunnel_ReadWorkspaceServer interface { Send(*Chunk) error grpc.ServerStream }
type UnimplementedTunnelServer ¶
type UnimplementedTunnelServer struct { }
UnimplementedTunnelServer must be embedded to have forward compatible implementations.
func (UnimplementedTunnelServer) DockerCredentials ¶
func (UnimplementedTunnelServer) GitCredentials ¶
func (UnimplementedTunnelServer) Log ¶
func (UnimplementedTunnelServer) Log(context.Context, *LogMessage) (*Empty, error)
func (UnimplementedTunnelServer) ReadWorkspace ¶
func (UnimplementedTunnelServer) ReadWorkspace(*Empty, Tunnel_ReadWorkspaceServer) error
func (UnimplementedTunnelServer) SendResult ¶
type UnsafeTunnelServer ¶
type UnsafeTunnelServer interface {
// contains filtered or unexported methods
}
UnsafeTunnelServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TunnelServer will result in compilation errors.