terminal

package
v0.19.3 Latest Latest
Warning

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

 Go to latest Published: Oct 23, 2025 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthTerminal        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTerminal          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTerminal = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterTerminalServer 

func RegisterTerminalServer(s *grpc.Server, srv TerminalServer)

Types

type Ready 

type Ready struct {
}

func (*Ready) Descriptor 

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

func (*Ready) Equal 

func (this *Ready) Equal(that interface{}) bool

func (*Ready) GoString 

func (this *Ready) GoString() string

func (*Ready) Marshal 

func (m *Ready) Marshal() (dAtA []byte, err error)

func (*Ready) MarshalTo 

func (m *Ready) MarshalTo(dAtA []byte) (int, error)

func (*Ready) MarshalToSizedBuffer 

func (m *Ready) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Ready) ProtoMessage 

func (*Ready) ProtoMessage()

func (*Ready) Reset 

func (m *Ready) Reset()

func (*Ready) Size 

func (m *Ready) Size() (n int)

func (*Ready) String 

func (this *Ready) String() string

func (*Ready) Unmarshal 

func (m *Ready) Unmarshal(dAtA []byte) error

func (*Ready) XXX_DiscardUnknown 

func (m *Ready) XXX_DiscardUnknown()

func (*Ready) XXX_Marshal 

func (m *Ready) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Ready) XXX_Merge 

func (m *Ready) XXX_Merge(src proto.Message)

func (*Ready) XXX_Size 

func (m *Ready) XXX_Size() int

func (*Ready) XXX_Unmarshal 

func (m *Ready) XXX_Unmarshal(b []byte) error

type Resize 

type Resize struct {
	Width  int32 `protobuf:"varint,1,opt,name=Width,proto3" json:"Width,omitempty"`
	Height int32 `protobuf:"varint,2,opt,name=Height,proto3" json:"Height,omitempty"`
}

func (*Resize) Descriptor 

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

func (*Resize) Equal 

func (this *Resize) Equal(that interface{}) bool

func (*Resize) GetHeight 

func (m *Resize) GetHeight() int32

func (*Resize) GetWidth 

func (m *Resize) GetWidth() int32

func (*Resize) GoString 

func (this *Resize) GoString() string

func (*Resize) Marshal 

func (m *Resize) Marshal() (dAtA []byte, err error)

func (*Resize) MarshalTo 

func (m *Resize) MarshalTo(dAtA []byte) (int, error)

func (*Resize) MarshalToSizedBuffer 

func (m *Resize) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Resize) ProtoMessage 

func (*Resize) ProtoMessage()

func (*Resize) Reset 

func (m *Resize) Reset()

func (*Resize) Size 

func (m *Resize) Size() (n int)

func (*Resize) String 

func (this *Resize) String() string

func (*Resize) Unmarshal 

func (m *Resize) Unmarshal(dAtA []byte) error

func (*Resize) XXX_DiscardUnknown 

func (m *Resize) XXX_DiscardUnknown()

func (*Resize) XXX_Marshal 

func (m *Resize) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Resize) XXX_Merge 

func (m *Resize) XXX_Merge(src proto.Message)

func (*Resize) XXX_Size 

func (m *Resize) XXX_Size() int

func (*Resize) XXX_Unmarshal 

func (m *Resize) XXX_Unmarshal(b []byte) error

type SessionRequest 

type SessionRequest struct {
	// Types that are valid to be assigned to Msg:
	//
	//	*SessionRequest_Stdout
	//	*SessionRequest_Stderr
	//	*SessionRequest_Exit
	Msg isSessionRequest_Msg `protobuf_oneof:"msg"`
}

func (*SessionRequest) Descriptor 

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

func (*SessionRequest) Equal 

func (this *SessionRequest) Equal(that interface{}) bool

func (*SessionRequest) GetExit 

func (m *SessionRequest) GetExit() int32

func (*SessionRequest) GetMsg 

func (m *SessionRequest) GetMsg() isSessionRequest_Msg

func (*SessionRequest) GetStderr 

func (m *SessionRequest) GetStderr() []byte

func (*SessionRequest) GetStdout 

func (m *SessionRequest) GetStdout() []byte

func (*SessionRequest) GoString 

func (this *SessionRequest) GoString() string

func (*SessionRequest) Marshal 

func (m *SessionRequest) Marshal() (dAtA []byte, err error)

func (*SessionRequest) MarshalTo 

func (m *SessionRequest) MarshalTo(dAtA []byte) (int, error)

func (*SessionRequest) MarshalToSizedBuffer 

func (m *SessionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SessionRequest) ProtoMessage 

func (*SessionRequest) ProtoMessage()

func (*SessionRequest) Reset 

func (m *SessionRequest) Reset()

func (*SessionRequest) Size 

func (m *SessionRequest) Size() (n int)

func (*SessionRequest) String 

func (this *SessionRequest) String() string

func (*SessionRequest) Unmarshal 

func (m *SessionRequest) Unmarshal(dAtA []byte) error

func (*SessionRequest) XXX_DiscardUnknown 

func (m *SessionRequest) XXX_DiscardUnknown()

func (*SessionRequest) XXX_Marshal 

func (m *SessionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SessionRequest) XXX_Merge 

func (m *SessionRequest) XXX_Merge(src proto.Message)

func (*SessionRequest) XXX_OneofWrappers 

func (*SessionRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*SessionRequest) XXX_Size 

func (m *SessionRequest) XXX_Size() int

func (*SessionRequest) XXX_Unmarshal 

func (m *SessionRequest) XXX_Unmarshal(b []byte) error

type SessionRequest_Exit 

type SessionRequest_Exit struct {
	Exit int32 `protobuf:"varint,3,opt,name=exit,proto3,oneof" json:"exit,omitempty"`
}

func (*SessionRequest_Exit) Equal 

func (this *SessionRequest_Exit) Equal(that interface{}) bool

func (*SessionRequest_Exit) GoString 

func (this *SessionRequest_Exit) GoString() string

func (*SessionRequest_Exit) MarshalTo 

func (m *SessionRequest_Exit) MarshalTo(dAtA []byte) (int, error)

func (*SessionRequest_Exit) MarshalToSizedBuffer 

func (m *SessionRequest_Exit) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SessionRequest_Exit) Size 

func (m *SessionRequest_Exit) Size() (n int)

func (*SessionRequest_Exit) String 

func (this *SessionRequest_Exit) String() string

type SessionRequest_Stderr 

type SessionRequest_Stderr struct {
	Stderr []byte `protobuf:"bytes,2,opt,name=stderr,proto3,oneof" json:"stderr,omitempty"`
}

func (*SessionRequest_Stderr) Equal 

func (this *SessionRequest_Stderr) Equal(that interface{}) bool

func (*SessionRequest_Stderr) GoString 

func (this *SessionRequest_Stderr) GoString() string

func (*SessionRequest_Stderr) MarshalTo 

func (m *SessionRequest_Stderr) MarshalTo(dAtA []byte) (int, error)

func (*SessionRequest_Stderr) MarshalToSizedBuffer 

func (m *SessionRequest_Stderr) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SessionRequest_Stderr) Size 

func (m *SessionRequest_Stderr) Size() (n int)

func (*SessionRequest_Stderr) String 

func (this *SessionRequest_Stderr) String() string

type SessionRequest_Stdout 

type SessionRequest_Stdout struct {
	Stdout []byte `protobuf:"bytes,1,opt,name=stdout,proto3,oneof" json:"stdout,omitempty"`
}

func (*SessionRequest_Stdout) Equal 

func (this *SessionRequest_Stdout) Equal(that interface{}) bool

func (*SessionRequest_Stdout) GoString 

func (this *SessionRequest_Stdout) GoString() string

func (*SessionRequest_Stdout) MarshalTo 

func (m *SessionRequest_Stdout) MarshalTo(dAtA []byte) (int, error)

func (*SessionRequest_Stdout) MarshalToSizedBuffer 

func (m *SessionRequest_Stdout) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SessionRequest_Stdout) Size 

func (m *SessionRequest_Stdout) Size() (n int)

func (*SessionRequest_Stdout) String 

func (this *SessionRequest_Stdout) String() string

type SessionResponse 

type SessionResponse struct {
	// Types that are valid to be assigned to Msg:
	//
	//	*SessionResponse_Stdin
	//	*SessionResponse_Resize
	//	*SessionResponse_Ready
	Msg isSessionResponse_Msg `protobuf_oneof:"msg"`
}

func (*SessionResponse) Descriptor 

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

func (*SessionResponse) Equal 

func (this *SessionResponse) Equal(that interface{}) bool

func (*SessionResponse) GetMsg 

func (m *SessionResponse) GetMsg() isSessionResponse_Msg

func (*SessionResponse) GetReady 

func (m *SessionResponse) GetReady() *Ready

func (*SessionResponse) GetResize 

func (m *SessionResponse) GetResize() *Resize

func (*SessionResponse) GetStdin 

func (m *SessionResponse) GetStdin() []byte

func (*SessionResponse) GoString 

func (this *SessionResponse) GoString() string

func (*SessionResponse) Marshal 

func (m *SessionResponse) Marshal() (dAtA []byte, err error)

func (*SessionResponse) MarshalTo 

func (m *SessionResponse) MarshalTo(dAtA []byte) (int, error)

func (*SessionResponse) MarshalToSizedBuffer 

func (m *SessionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SessionResponse) ProtoMessage 

func (*SessionResponse) ProtoMessage()

func (*SessionResponse) Reset 

func (m *SessionResponse) Reset()

func (*SessionResponse) Size 

func (m *SessionResponse) Size() (n int)

func (*SessionResponse) String 

func (this *SessionResponse) String() string

func (*SessionResponse) Unmarshal 

func (m *SessionResponse) Unmarshal(dAtA []byte) error

func (*SessionResponse) XXX_DiscardUnknown 

func (m *SessionResponse) XXX_DiscardUnknown()

func (*SessionResponse) XXX_Marshal 

func (m *SessionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SessionResponse) XXX_Merge 

func (m *SessionResponse) XXX_Merge(src proto.Message)

func (*SessionResponse) XXX_OneofWrappers 

func (*SessionResponse) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*SessionResponse) XXX_Size 

func (m *SessionResponse) XXX_Size() int

func (*SessionResponse) XXX_Unmarshal 

func (m *SessionResponse) XXX_Unmarshal(b []byte) error

type SessionResponse_Ready 

type SessionResponse_Ready struct {
	Ready *Ready `protobuf:"bytes,3,opt,name=ready,proto3,oneof" json:"ready,omitempty"`
}

func (*SessionResponse_Ready) Equal 

func (this *SessionResponse_Ready) Equal(that interface{}) bool

func (*SessionResponse_Ready) GoString 

func (this *SessionResponse_Ready) GoString() string

func (*SessionResponse_Ready) MarshalTo 

func (m *SessionResponse_Ready) MarshalTo(dAtA []byte) (int, error)

func (*SessionResponse_Ready) MarshalToSizedBuffer 

func (m *SessionResponse_Ready) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SessionResponse_Ready) Size 

func (m *SessionResponse_Ready) Size() (n int)

func (*SessionResponse_Ready) String 

func (this *SessionResponse_Ready) String() string

type SessionResponse_Resize 

type SessionResponse_Resize struct {
	Resize *Resize `protobuf:"bytes,2,opt,name=resize,proto3,oneof" json:"resize,omitempty"`
}

func (*SessionResponse_Resize) Equal 

func (this *SessionResponse_Resize) Equal(that interface{}) bool

func (*SessionResponse_Resize) GoString 

func (this *SessionResponse_Resize) GoString() string

func (*SessionResponse_Resize) MarshalTo 

func (m *SessionResponse_Resize) MarshalTo(dAtA []byte) (int, error)

func (*SessionResponse_Resize) MarshalToSizedBuffer 

func (m *SessionResponse_Resize) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SessionResponse_Resize) Size 

func (m *SessionResponse_Resize) Size() (n int)

func (*SessionResponse_Resize) String 

func (this *SessionResponse_Resize) String() string

type SessionResponse_Stdin 

type SessionResponse_Stdin struct {
	Stdin []byte `protobuf:"bytes,1,opt,name=stdin,proto3,oneof" json:"stdin,omitempty"`
}

func (*SessionResponse_Stdin) Equal 

func (this *SessionResponse_Stdin) Equal(that interface{}) bool

func (*SessionResponse_Stdin) GoString 

func (this *SessionResponse_Stdin) GoString() string

func (*SessionResponse_Stdin) MarshalTo 

func (m *SessionResponse_Stdin) MarshalTo(dAtA []byte) (int, error)

func (*SessionResponse_Stdin) MarshalToSizedBuffer 

func (m *SessionResponse_Stdin) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SessionResponse_Stdin) Size 

func (m *SessionResponse_Stdin) Size() (n int)

func (*SessionResponse_Stdin) String 

func (this *SessionResponse_Stdin) String() string

type TerminalAttachable 

type TerminalAttachable struct {
	UnimplementedTerminalServer
	// contains filtered or unexported fields
}

func NewTerminalAttachable 

func NewTerminalAttachable(
	rootCtx context.Context,
	withTerminal WithTerminalFunc,
) TerminalAttachable

func (TerminalAttachable) Register 

func (s TerminalAttachable) Register(srv *grpc.Server)

func (TerminalAttachable) Session 

func (s TerminalAttachable) Session(srv Terminal_SessionServer) error

type TerminalClient 

type TerminalClient interface {
	Session(ctx context.Context, opts ...grpc.CallOption) (Terminal_SessionClient, error)
}

TerminalClient is the client API for Terminal service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewTerminalClient 

func NewTerminalClient(cc *grpc.ClientConn) TerminalClient

type TerminalServer 

type TerminalServer interface {
	Session(Terminal_SessionServer) error
}

TerminalServer is the server API for Terminal service.

type Terminal_SessionClient 

type Terminal_SessionClient interface {
	Send(*SessionRequest) error
	Recv() (*SessionResponse, error)
	grpc.ClientStream
}

type Terminal_SessionServer 

type Terminal_SessionServer interface {
	Send(*SessionResponse) error
	Recv() (*SessionRequest, error)
	grpc.ServerStream
}

type UnimplementedTerminalServer 

type UnimplementedTerminalServer struct {
}

UnimplementedTerminalServer can be embedded to have forward compatible implementations.

func (*UnimplementedTerminalServer) Session 

func (*UnimplementedTerminalServer) Session(srv Terminal_SessionServer) error

type WithTerminalFunc 

type WithTerminalFunc func(func(stdin io.Reader, stdout, stderr io.Writer) error) error

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.