apis

package
v0.0.0-...-f538abd Latest Latest
Warning

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

 Go to latest Published: Mar 12, 2026 License: Apache-2.0 Imports: 7 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterExecutorServer 

func RegisterExecutorServer(s *grpc.Server, srv ExecutorServer)

Types

type Command 

type Command struct {
	Path                 []byte   `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Args                 [][]byte `protobuf:"bytes,2,rep,name=args,proto3" json:"args,omitempty"`
	Env                  [][]byte `protobuf:"bytes,3,rep,name=env,proto3" json:"env,omitempty"`
	Dir                  []byte   `protobuf:"bytes,4,opt,name=dir,proto3" json:"dir,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Command) Descriptor 

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

func (*Command) GetArgs 

func (m *Command) GetArgs() [][]byte

func (*Command) GetDir 

func (m *Command) GetDir() []byte

func (*Command) GetEnv 

func (m *Command) GetEnv() [][]byte

func (*Command) GetPath 

func (m *Command) GetPath() []byte

func (*Command) ProtoMessage 

func (*Command) ProtoMessage()

func (*Command) Reset 

func (m *Command) Reset()

func (*Command) String 

func (m *Command) String() string

func (*Command) XXX_DiscardUnknown 

func (m *Command) XXX_DiscardUnknown()

func (*Command) XXX_Marshal 

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

func (*Command) XXX_Merge 

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

func (*Command) XXX_Size 

func (m *Command) XXX_Size() int

func (*Command) XXX_Unmarshal 

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

type Error 

type Error struct {
	Error                []byte   `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Error) Descriptor 

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

func (*Error) GetError 

func (m *Error) GetError() []byte

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) Reset 

func (m *Error) Reset()

func (*Error) String 

func (m *Error) String() string

func (*Error) XXX_DiscardUnknown 

func (m *Error) XXX_DiscardUnknown()

func (*Error) XXX_Marshal 

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

func (*Error) XXX_Merge 

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

func (*Error) XXX_Size 

func (m *Error) XXX_Size() int

func (*Error) XXX_Unmarshal 

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

type ExecutorClient 

type ExecutorClient interface {
	SendInput(ctx context.Context, opts ...grpc.CallOption) (Executor_SendInputClient, error)
	FetchStdout(ctx context.Context, in *Sn, opts ...grpc.CallOption) (Executor_FetchStdoutClient, error)
	FetchStderr(ctx context.Context, in *Sn, opts ...grpc.CallOption) (Executor_FetchStderrClient, error)
	Start(ctx context.Context, in *StartInput, opts ...grpc.CallOption) (*StartResponse, error)
	Wait(ctx context.Context, in *Sn, opts ...grpc.CallOption) (*WaitResponse, error)
	ExecCommand(ctx context.Context, in *Command, opts ...grpc.CallOption) (*Sn, error)
	Kill(ctx context.Context, in *Sn, opts ...grpc.CallOption) (*Error, error)
}

ExecutorClient is the client API for Executor service.

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

func NewExecutorClient 

func NewExecutorClient(cc *grpc.ClientConn) ExecutorClient

type ExecutorServer 

type ExecutorServer interface {
	SendInput(Executor_SendInputServer) error
	FetchStdout(*Sn, Executor_FetchStdoutServer) error
	FetchStderr(*Sn, Executor_FetchStderrServer) error
	Start(context.Context, *StartInput) (*StartResponse, error)
	Wait(context.Context, *Sn) (*WaitResponse, error)
	ExecCommand(context.Context, *Command) (*Sn, error)
	Kill(context.Context, *Sn) (*Error, error)
}

ExecutorServer is the server API for Executor service.

type Executor_FetchStderrClient 

type Executor_FetchStderrClient interface {
	Recv() (*Stderr, error)
	grpc.ClientStream
}

type Executor_FetchStderrServer 

type Executor_FetchStderrServer interface {
	Send(*Stderr) error
	grpc.ServerStream
}

type Executor_FetchStdoutClient 

type Executor_FetchStdoutClient interface {
	Recv() (*Stdout, error)
	grpc.ClientStream
}

type Executor_FetchStdoutServer 

type Executor_FetchStdoutServer interface {
	Send(*Stdout) error
	grpc.ServerStream
}

type Executor_SendInputClient 

type Executor_SendInputClient interface {
	Send(*Input) error
	CloseAndRecv() (*Error, error)
	grpc.ClientStream
}

type Executor_SendInputServer 

type Executor_SendInputServer interface {
	SendAndClose(*Error) error
	Recv() (*Input, error)
	grpc.ServerStream
}

type Input 

type Input struct {
	Sn                   uint32   `protobuf:"varint,1,opt,name=sn,proto3" json:"sn,omitempty"`
	Input                []byte   `protobuf:"bytes,2,opt,name=input,proto3" json:"input,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Input) Descriptor 

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

func (*Input) GetInput 

func (m *Input) GetInput() []byte

func (*Input) GetSn 

func (m *Input) GetSn() uint32

func (*Input) ProtoMessage 

func (*Input) ProtoMessage()

func (*Input) Reset 

func (m *Input) Reset()

func (*Input) String 

func (m *Input) String() string

func (*Input) XXX_DiscardUnknown 

func (m *Input) XXX_DiscardUnknown()

func (*Input) XXX_Marshal 

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

func (*Input) XXX_Merge 

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

func (*Input) XXX_Size 

func (m *Input) XXX_Size() int

func (*Input) XXX_Unmarshal 

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

type Sn 

type Sn struct {
	Sn                   uint32   `protobuf:"varint,1,opt,name=sn,proto3" json:"sn,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Sn) Descriptor 

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

func (*Sn) GetSn 

func (m *Sn) GetSn() uint32

func (*Sn) ProtoMessage 

func (*Sn) ProtoMessage()

func (*Sn) Reset 

func (m *Sn) Reset()

func (*Sn) String 

func (m *Sn) String() string

func (*Sn) XXX_DiscardUnknown 

func (m *Sn) XXX_DiscardUnknown()

func (*Sn) XXX_Marshal 

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

func (*Sn) XXX_Merge 

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

func (*Sn) XXX_Size 

func (m *Sn) XXX_Size() int

func (*Sn) XXX_Unmarshal 

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

type StartInput 

type StartInput struct {
	Sn                   uint32   `protobuf:"varint,1,opt,name=sn,proto3" json:"sn,omitempty"`
	HasStdin             bool     `protobuf:"varint,2,opt,name=has_stdin,json=hasStdin,proto3" json:"has_stdin,omitempty"`
	HasStdout            bool     `protobuf:"varint,3,opt,name=has_stdout,json=hasStdout,proto3" json:"has_stdout,omitempty"`
	HasStderr            bool     `protobuf:"varint,4,opt,name=has_stderr,json=hasStderr,proto3" json:"has_stderr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StartInput) Descriptor 

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

func (*StartInput) GetHasStderr 

func (m *StartInput) GetHasStderr() bool

func (*StartInput) GetHasStdin 

func (m *StartInput) GetHasStdin() bool

func (*StartInput) GetHasStdout 

func (m *StartInput) GetHasStdout() bool

func (*StartInput) GetSn 

func (m *StartInput) GetSn() uint32

func (*StartInput) ProtoMessage 

func (*StartInput) ProtoMessage()

func (*StartInput) Reset 

func (m *StartInput) Reset()

func (*StartInput) String 

func (m *StartInput) String() string

func (*StartInput) XXX_DiscardUnknown 

func (m *StartInput) XXX_DiscardUnknown()

func (*StartInput) XXX_Marshal 

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

func (*StartInput) XXX_Merge 

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

func (*StartInput) XXX_Size 

func (m *StartInput) XXX_Size() int

func (*StartInput) XXX_Unmarshal 

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

type StartResponse 

type StartResponse struct {
	Success              bool     `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Error                []byte   `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StartResponse) Descriptor 

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

func (*StartResponse) GetError 

func (m *StartResponse) GetError() []byte

func (*StartResponse) GetSuccess 

func (m *StartResponse) GetSuccess() bool

func (*StartResponse) ProtoMessage 

func (*StartResponse) ProtoMessage()

func (*StartResponse) Reset 

func (m *StartResponse) Reset()

func (*StartResponse) String 

func (m *StartResponse) String() string

func (*StartResponse) XXX_DiscardUnknown 

func (m *StartResponse) XXX_DiscardUnknown()

func (*StartResponse) XXX_Marshal 

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

func (*StartResponse) XXX_Merge 

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

func (*StartResponse) XXX_Size 

func (m *StartResponse) XXX_Size() int

func (*StartResponse) XXX_Unmarshal 

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

type Stderr 

type Stderr struct {
	Stderr               []byte   `protobuf:"bytes,1,opt,name=stderr,proto3" json:"stderr,omitempty"`
	Closed               bool     `protobuf:"varint,2,opt,name=closed,proto3" json:"closed,omitempty"`
	RuntimeError         []byte   `protobuf:"bytes,3,opt,name=runtime_error,json=runtimeError,proto3" json:"runtime_error,omitempty"`
	Start                bool     `protobuf:"varint,4,opt,name=start,proto3" json:"start,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Stderr) Descriptor 

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

func (*Stderr) GetClosed 

func (m *Stderr) GetClosed() bool

func (*Stderr) GetRuntimeError 

func (m *Stderr) GetRuntimeError() []byte

func (*Stderr) GetStart 

func (m *Stderr) GetStart() bool

func (*Stderr) GetStderr 

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

func (*Stderr) ProtoMessage 

func (*Stderr) ProtoMessage()

func (*Stderr) Reset 

func (m *Stderr) Reset()

func (*Stderr) String 

func (m *Stderr) String() string

func (*Stderr) XXX_DiscardUnknown 

func (m *Stderr) XXX_DiscardUnknown()

func (*Stderr) XXX_Marshal 

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

func (*Stderr) XXX_Merge 

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

func (*Stderr) XXX_Size 

func (m *Stderr) XXX_Size() int

func (*Stderr) XXX_Unmarshal 

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

type Stdout 

type Stdout struct {
	Stdout               []byte   `protobuf:"bytes,1,opt,name=stdout,proto3" json:"stdout,omitempty"`
	Closed               bool     `protobuf:"varint,2,opt,name=closed,proto3" json:"closed,omitempty"`
	RuntimeError         []byte   `protobuf:"bytes,3,opt,name=runtime_error,json=runtimeError,proto3" json:"runtime_error,omitempty"`
	Start                bool     `protobuf:"varint,4,opt,name=start,proto3" json:"start,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Stdout) Descriptor 

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

func (*Stdout) GetClosed 

func (m *Stdout) GetClosed() bool

func (*Stdout) GetRuntimeError 

func (m *Stdout) GetRuntimeError() []byte

func (*Stdout) GetStart 

func (m *Stdout) GetStart() bool

func (*Stdout) GetStdout 

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

func (*Stdout) ProtoMessage 

func (*Stdout) ProtoMessage()

func (*Stdout) Reset 

func (m *Stdout) Reset()

func (*Stdout) String 

func (m *Stdout) String() string

func (*Stdout) XXX_DiscardUnknown 

func (m *Stdout) XXX_DiscardUnknown()

func (*Stdout) XXX_Marshal 

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

func (*Stdout) XXX_Merge 

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

func (*Stdout) XXX_Size 

func (m *Stdout) XXX_Size() int

func (*Stdout) XXX_Unmarshal 

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

type UnimplementedExecutorServer 

type UnimplementedExecutorServer struct {
}

UnimplementedExecutorServer can be embedded to have forward compatible implementations.

func (*UnimplementedExecutorServer) ExecCommand 

func (*UnimplementedExecutorServer) ExecCommand(ctx context.Context, req *Command) (*Sn, error)

func (*UnimplementedExecutorServer) FetchStderr 

func (*UnimplementedExecutorServer) FetchStderr(req *Sn, srv Executor_FetchStderrServer) error

func (*UnimplementedExecutorServer) FetchStdout 

func (*UnimplementedExecutorServer) FetchStdout(req *Sn, srv Executor_FetchStdoutServer) error

func (*UnimplementedExecutorServer) Kill 

func (*UnimplementedExecutorServer) Kill(ctx context.Context, req *Sn) (*Error, error)

func (*UnimplementedExecutorServer) SendInput 

func (*UnimplementedExecutorServer) SendInput(srv Executor_SendInputServer) error

func (*UnimplementedExecutorServer) Start 

func (*UnimplementedExecutorServer) Start(ctx context.Context, req *StartInput) (*StartResponse, error)

func (*UnimplementedExecutorServer) Wait 

func (*UnimplementedExecutorServer) Wait(ctx context.Context, req *Sn) (*WaitResponse, error)

type WaitCommand 

type WaitCommand struct {
	Sn                   uint32   `protobuf:"varint,1,opt,name=sn,proto3" json:"sn,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WaitCommand) Descriptor 

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

func (*WaitCommand) GetSn 

func (m *WaitCommand) GetSn() uint32

func (*WaitCommand) ProtoMessage 

func (*WaitCommand) ProtoMessage()

func (*WaitCommand) Reset 

func (m *WaitCommand) Reset()

func (*WaitCommand) String 

func (m *WaitCommand) String() string

func (*WaitCommand) XXX_DiscardUnknown 

func (m *WaitCommand) XXX_DiscardUnknown()

func (*WaitCommand) XXX_Marshal 

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

func (*WaitCommand) XXX_Merge 

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

func (*WaitCommand) XXX_Size 

func (m *WaitCommand) XXX_Size() int

func (*WaitCommand) XXX_Unmarshal 

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

type WaitResponse 

type WaitResponse struct {
	ExitStatus           uint32   `protobuf:"varint,1,opt,name=exit_status,json=exitStatus,proto3" json:"exit_status,omitempty"`
	ErrContent           []byte   `protobuf:"bytes,2,opt,name=err_content,json=errContent,proto3" json:"err_content,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WaitResponse) Descriptor 

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

func (*WaitResponse) GetErrContent 

func (m *WaitResponse) GetErrContent() []byte

func (*WaitResponse) GetExitStatus 

func (m *WaitResponse) GetExitStatus() uint32

func (*WaitResponse) ProtoMessage 

func (*WaitResponse) ProtoMessage()

func (*WaitResponse) Reset 

func (m *WaitResponse) Reset()

func (*WaitResponse) String 

func (m *WaitResponse) String() string

func (*WaitResponse) XXX_DiscardUnknown 

func (m *WaitResponse) XXX_DiscardUnknown()

func (*WaitResponse) XXX_Marshal 

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

func (*WaitResponse) XXX_Merge 

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

func (*WaitResponse) XXX_Size 

func (m *WaitResponse) XXX_Size() int

func (*WaitResponse) XXX_Unmarshal 

func (m *WaitResponse) XXX_Unmarshal(b []byte) 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.