proto

package
v0.0.0-...-ae3a0a2 Latest Latest
Warning

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

 Go to latest Published: Dec 14, 2022 License: MPL-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterExecutorServer 

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

Types

type ExecRequest 

type ExecRequest struct {
	Deadline             *timestamp.Timestamp `protobuf:"bytes,1,opt,name=deadline,proto3" json:"deadline,omitempty"`
	Cmd                  string               `protobuf:"bytes,2,opt,name=cmd,proto3" json:"cmd,omitempty"`
	Args                 []string             `protobuf:"bytes,3,rep,name=args,proto3" json:"args,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ExecRequest) Descriptor 

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

func (*ExecRequest) GetArgs 

func (m *ExecRequest) GetArgs() []string

func (*ExecRequest) GetCmd 

func (m *ExecRequest) GetCmd() string

func (*ExecRequest) GetDeadline 

func (m *ExecRequest) GetDeadline() *timestamp.Timestamp

func (*ExecRequest) ProtoMessage 

func (*ExecRequest) ProtoMessage()

func (*ExecRequest) Reset 

func (m *ExecRequest) Reset()

func (*ExecRequest) String 

func (m *ExecRequest) String() string

func (*ExecRequest) XXX_DiscardUnknown 

func (m *ExecRequest) XXX_DiscardUnknown()

func (*ExecRequest) XXX_Marshal 

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

func (*ExecRequest) XXX_Merge 

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

func (*ExecRequest) XXX_Size 

func (m *ExecRequest) XXX_Size() int

func (*ExecRequest) XXX_Unmarshal 

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

type ExecResponse 

type ExecResponse struct {
	Output               []byte   `protobuf:"bytes,1,opt,name=output,proto3" json:"output,omitempty"`
	ExitCode             int32    `protobuf:"varint,2,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ExecResponse) Descriptor 

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

func (*ExecResponse) GetExitCode 

func (m *ExecResponse) GetExitCode() int32

func (*ExecResponse) GetOutput 

func (m *ExecResponse) GetOutput() []byte

func (*ExecResponse) ProtoMessage 

func (*ExecResponse) ProtoMessage()

func (*ExecResponse) Reset 

func (m *ExecResponse) Reset()

func (*ExecResponse) String 

func (m *ExecResponse) String() string

func (*ExecResponse) XXX_DiscardUnknown 

func (m *ExecResponse) XXX_DiscardUnknown()

func (*ExecResponse) XXX_Marshal 

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

func (*ExecResponse) XXX_Merge 

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

func (*ExecResponse) XXX_Size 

func (m *ExecResponse) XXX_Size() int

func (*ExecResponse) XXX_Unmarshal 

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

type ExecutorClient 

type ExecutorClient interface {
	Launch(ctx context.Context, in *LaunchRequest, opts ...grpc.CallOption) (*LaunchResponse, error)
	Wait(ctx context.Context, in *WaitRequest, opts ...grpc.CallOption) (*WaitResponse, error)
	Shutdown(ctx context.Context, in *ShutdownRequest, opts ...grpc.CallOption) (*ShutdownResponse, error)
	UpdateResources(ctx context.Context, in *UpdateResourcesRequest, opts ...grpc.CallOption) (*UpdateResourcesResponse, error)
	Version(ctx context.Context, in *VersionRequest, opts ...grpc.CallOption) (*VersionResponse, error)
	Stats(ctx context.Context, in *StatsRequest, opts ...grpc.CallOption) (Executor_StatsClient, error)
	Signal(ctx context.Context, in *SignalRequest, opts ...grpc.CallOption) (*SignalResponse, error)
	Exec(ctx context.Context, in *ExecRequest, opts ...grpc.CallOption) (*ExecResponse, error)
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	ExecStreaming(ctx context.Context, opts ...grpc.CallOption) (Executor_ExecStreamingClient, 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.ClientConnInterface) ExecutorClient

type ExecutorServer 

type ExecutorServer interface {
	Launch(context.Context, *LaunchRequest) (*LaunchResponse, error)
	Wait(context.Context, *WaitRequest) (*WaitResponse, error)
	Shutdown(context.Context, *ShutdownRequest) (*ShutdownResponse, error)
	UpdateResources(context.Context, *UpdateResourcesRequest) (*UpdateResourcesResponse, error)
	Version(context.Context, *VersionRequest) (*VersionResponse, error)
	Stats(*StatsRequest, Executor_StatsServer) error
	Signal(context.Context, *SignalRequest) (*SignalResponse, error)
	Exec(context.Context, *ExecRequest) (*ExecResponse, error)
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	ExecStreaming(Executor_ExecStreamingServer) error
}

ExecutorServer is the server API for Executor service.

type Executor_ExecStreamingClient 

type Executor_ExecStreamingClient interface {
	Send(*proto1.ExecTaskStreamingRequest) error
	Recv() (*proto1.ExecTaskStreamingResponse, error)
	grpc.ClientStream
}

type Executor_ExecStreamingServer 

type Executor_ExecStreamingServer interface {
	Send(*proto1.ExecTaskStreamingResponse) error
	Recv() (*proto1.ExecTaskStreamingRequest, error)
	grpc.ServerStream
}

type Executor_StatsClient 

type Executor_StatsClient interface {
	Recv() (*StatsResponse, error)
	grpc.ClientStream
}

type Executor_StatsServer 

type Executor_StatsServer interface {
	Send(*StatsResponse) error
	grpc.ServerStream
}

type LaunchRequest 

type LaunchRequest struct {
	Cmd                  string                       `protobuf:"bytes,1,opt,name=cmd,proto3" json:"cmd,omitempty"`
	Args                 []string                     `protobuf:"bytes,2,rep,name=args,proto3" json:"args,omitempty"`
	Resources            *proto1.Resources            `protobuf:"bytes,3,opt,name=resources,proto3" json:"resources,omitempty"`
	StdoutPath           string                       `protobuf:"bytes,4,opt,name=stdout_path,json=stdoutPath,proto3" json:"stdout_path,omitempty"`
	StderrPath           string                       `protobuf:"bytes,5,opt,name=stderr_path,json=stderrPath,proto3" json:"stderr_path,omitempty"`
	Env                  []string                     `protobuf:"bytes,6,rep,name=env,proto3" json:"env,omitempty"`
	User                 string                       `protobuf:"bytes,7,opt,name=user,proto3" json:"user,omitempty"`
	TaskDir              string                       `protobuf:"bytes,8,opt,name=task_dir,json=taskDir,proto3" json:"task_dir,omitempty"`
	ResourceLimits       bool                         `protobuf:"varint,9,opt,name=resource_limits,json=resourceLimits,proto3" json:"resource_limits,omitempty"`
	BasicProcessCgroup   bool                         `protobuf:"varint,10,opt,name=basic_process_cgroup,json=basicProcessCgroup,proto3" json:"basic_process_cgroup,omitempty"`
	Mounts               []*proto1.Mount              `protobuf:"bytes,11,rep,name=mounts,proto3" json:"mounts,omitempty"`
	Devices              []*proto1.Device             `protobuf:"bytes,12,rep,name=devices,proto3" json:"devices,omitempty"`
	NetworkIsolation     *proto1.NetworkIsolationSpec `protobuf:"bytes,13,opt,name=network_isolation,json=networkIsolation,proto3" json:"network_isolation,omitempty"`
	NoPivotRoot          bool                         `protobuf:"varint,14,opt,name=no_pivot_root,json=noPivotRoot,proto3" json:"no_pivot_root,omitempty"`
	DefaultPidMode       string                       `protobuf:"bytes,15,opt,name=default_pid_mode,json=defaultPidMode,proto3" json:"default_pid_mode,omitempty"`
	DefaultIpcMode       string                       `protobuf:"bytes,16,opt,name=default_ipc_mode,json=defaultIpcMode,proto3" json:"default_ipc_mode,omitempty"`
	CpusetCgroup         string                       `protobuf:"bytes,17,opt,name=cpuset_cgroup,json=cpusetCgroup,proto3" json:"cpuset_cgroup,omitempty"`
	AllowCaps            []string                     `protobuf:"bytes,18,rep,name=allow_caps,json=allowCaps,proto3" json:"allow_caps,omitempty"`
	Capabilities         []string                     `protobuf:"bytes,19,rep,name=capabilities,proto3" json:"capabilities,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*LaunchRequest) Descriptor 

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

func (*LaunchRequest) GetAllowCaps 

func (m *LaunchRequest) GetAllowCaps() []string

func (*LaunchRequest) GetArgs 

func (m *LaunchRequest) GetArgs() []string

func (*LaunchRequest) GetBasicProcessCgroup 

func (m *LaunchRequest) GetBasicProcessCgroup() bool

func (*LaunchRequest) GetCapabilities 

func (m *LaunchRequest) GetCapabilities() []string

func (*LaunchRequest) GetCmd 

func (m *LaunchRequest) GetCmd() string

func (*LaunchRequest) GetCpusetCgroup 

func (m *LaunchRequest) GetCpusetCgroup() string

func (*LaunchRequest) GetDefaultIpcMode 

func (m *LaunchRequest) GetDefaultIpcMode() string

func (*LaunchRequest) GetDefaultPidMode 

func (m *LaunchRequest) GetDefaultPidMode() string

func (*LaunchRequest) GetDevices 

func (m *LaunchRequest) GetDevices() []*proto1.Device

func (*LaunchRequest) GetEnv 

func (m *LaunchRequest) GetEnv() []string

func (*LaunchRequest) GetMounts 

func (m *LaunchRequest) GetMounts() []*proto1.Mount

func (*LaunchRequest) GetNetworkIsolation 

func (m *LaunchRequest) GetNetworkIsolation() *proto1.NetworkIsolationSpec

func (*LaunchRequest) GetNoPivotRoot 

func (m *LaunchRequest) GetNoPivotRoot() bool

func (*LaunchRequest) GetResourceLimits 

func (m *LaunchRequest) GetResourceLimits() bool

func (*LaunchRequest) GetResources 

func (m *LaunchRequest) GetResources() *proto1.Resources

func (*LaunchRequest) GetStderrPath 

func (m *LaunchRequest) GetStderrPath() string

func (*LaunchRequest) GetStdoutPath 

func (m *LaunchRequest) GetStdoutPath() string

func (*LaunchRequest) GetTaskDir 

func (m *LaunchRequest) GetTaskDir() string

func (*LaunchRequest) GetUser 

func (m *LaunchRequest) GetUser() string

func (*LaunchRequest) ProtoMessage 

func (*LaunchRequest) ProtoMessage()

func (*LaunchRequest) Reset 

func (m *LaunchRequest) Reset()

func (*LaunchRequest) String 

func (m *LaunchRequest) String() string

func (*LaunchRequest) XXX_DiscardUnknown 

func (m *LaunchRequest) XXX_DiscardUnknown()

func (*LaunchRequest) XXX_Marshal 

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

func (*LaunchRequest) XXX_Merge 

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

func (*LaunchRequest) XXX_Size 

func (m *LaunchRequest) XXX_Size() int

func (*LaunchRequest) XXX_Unmarshal 

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

type LaunchResponse 

type LaunchResponse struct {
	Process              *ProcessState `protobuf:"bytes,1,opt,name=process,proto3" json:"process,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*LaunchResponse) Descriptor 

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

func (*LaunchResponse) GetProcess 

func (m *LaunchResponse) GetProcess() *ProcessState

func (*LaunchResponse) ProtoMessage 

func (*LaunchResponse) ProtoMessage()

func (*LaunchResponse) Reset 

func (m *LaunchResponse) Reset()

func (*LaunchResponse) String 

func (m *LaunchResponse) String() string

func (*LaunchResponse) XXX_DiscardUnknown 

func (m *LaunchResponse) XXX_DiscardUnknown()

func (*LaunchResponse) XXX_Marshal 

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

func (*LaunchResponse) XXX_Merge 

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

func (*LaunchResponse) XXX_Size 

func (m *LaunchResponse) XXX_Size() int

func (*LaunchResponse) XXX_Unmarshal 

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

type ProcessState 

type ProcessState struct {
	Pid                  int32                `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
	ExitCode             int32                `protobuf:"varint,2,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	Signal               int32                `protobuf:"varint,3,opt,name=signal,proto3" json:"signal,omitempty"`
	Time                 *timestamp.Timestamp `protobuf:"bytes,4,opt,name=time,proto3" json:"time,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ProcessState) Descriptor 

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

func (*ProcessState) GetExitCode 

func (m *ProcessState) GetExitCode() int32

func (*ProcessState) GetPid 

func (m *ProcessState) GetPid() int32

func (*ProcessState) GetSignal 

func (m *ProcessState) GetSignal() int32

func (*ProcessState) GetTime 

func (m *ProcessState) GetTime() *timestamp.Timestamp

func (*ProcessState) ProtoMessage 

func (*ProcessState) ProtoMessage()

func (*ProcessState) Reset 

func (m *ProcessState) Reset()

func (*ProcessState) String 

func (m *ProcessState) String() string

func (*ProcessState) XXX_DiscardUnknown 

func (m *ProcessState) XXX_DiscardUnknown()

func (*ProcessState) XXX_Marshal 

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

func (*ProcessState) XXX_Merge 

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

func (*ProcessState) XXX_Size 

func (m *ProcessState) XXX_Size() int

func (*ProcessState) XXX_Unmarshal 

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

type ShutdownRequest 

type ShutdownRequest struct {
	Signal               string   `protobuf:"bytes,1,opt,name=signal,proto3" json:"signal,omitempty"`
	GracePeriod          int64    `protobuf:"varint,2,opt,name=grace_period,json=gracePeriod,proto3" json:"grace_period,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ShutdownRequest) Descriptor 

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

func (*ShutdownRequest) GetGracePeriod 

func (m *ShutdownRequest) GetGracePeriod() int64

func (*ShutdownRequest) GetSignal 

func (m *ShutdownRequest) GetSignal() string

func (*ShutdownRequest) ProtoMessage 

func (*ShutdownRequest) ProtoMessage()

func (*ShutdownRequest) Reset 

func (m *ShutdownRequest) Reset()

func (*ShutdownRequest) String 

func (m *ShutdownRequest) String() string

func (*ShutdownRequest) XXX_DiscardUnknown 

func (m *ShutdownRequest) XXX_DiscardUnknown()

func (*ShutdownRequest) XXX_Marshal 

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

func (*ShutdownRequest) XXX_Merge 

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

func (*ShutdownRequest) XXX_Size 

func (m *ShutdownRequest) XXX_Size() int

func (*ShutdownRequest) XXX_Unmarshal 

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

type ShutdownResponse 

type ShutdownResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ShutdownResponse) Descriptor 

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

func (*ShutdownResponse) ProtoMessage 

func (*ShutdownResponse) ProtoMessage()

func (*ShutdownResponse) Reset 

func (m *ShutdownResponse) Reset()

func (*ShutdownResponse) String 

func (m *ShutdownResponse) String() string

func (*ShutdownResponse) XXX_DiscardUnknown 

func (m *ShutdownResponse) XXX_DiscardUnknown()

func (*ShutdownResponse) XXX_Marshal 

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

func (*ShutdownResponse) XXX_Merge 

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

func (*ShutdownResponse) XXX_Size 

func (m *ShutdownResponse) XXX_Size() int

func (*ShutdownResponse) XXX_Unmarshal 

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

type SignalRequest 

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

func (*SignalRequest) Descriptor 

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

func (*SignalRequest) GetSignal 

func (m *SignalRequest) GetSignal() int32

func (*SignalRequest) ProtoMessage 

func (*SignalRequest) ProtoMessage()

func (*SignalRequest) Reset 

func (m *SignalRequest) Reset()

func (*SignalRequest) String 

func (m *SignalRequest) String() string

func (*SignalRequest) XXX_DiscardUnknown 

func (m *SignalRequest) XXX_DiscardUnknown()

func (*SignalRequest) XXX_Marshal 

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

func (*SignalRequest) XXX_Merge 

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

func (*SignalRequest) XXX_Size 

func (m *SignalRequest) XXX_Size() int

func (*SignalRequest) XXX_Unmarshal 

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

type SignalResponse 

type SignalResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SignalResponse) Descriptor 

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

func (*SignalResponse) ProtoMessage 

func (*SignalResponse) ProtoMessage()

func (*SignalResponse) Reset 

func (m *SignalResponse) Reset()

func (*SignalResponse) String 

func (m *SignalResponse) String() string

func (*SignalResponse) XXX_DiscardUnknown 

func (m *SignalResponse) XXX_DiscardUnknown()

func (*SignalResponse) XXX_Marshal 

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

func (*SignalResponse) XXX_Merge 

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

func (*SignalResponse) XXX_Size 

func (m *SignalResponse) XXX_Size() int

func (*SignalResponse) XXX_Unmarshal 

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

type StatsRequest 

type StatsRequest struct {
	Interval             int64    `protobuf:"varint,1,opt,name=interval,proto3" json:"interval,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StatsRequest) Descriptor 

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

func (*StatsRequest) GetInterval 

func (m *StatsRequest) GetInterval() int64

func (*StatsRequest) ProtoMessage 

func (*StatsRequest) ProtoMessage()

func (*StatsRequest) Reset 

func (m *StatsRequest) Reset()

func (*StatsRequest) String 

func (m *StatsRequest) String() string

func (*StatsRequest) XXX_DiscardUnknown 

func (m *StatsRequest) XXX_DiscardUnknown()

func (*StatsRequest) XXX_Marshal 

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

func (*StatsRequest) XXX_Merge 

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

func (*StatsRequest) XXX_Size 

func (m *StatsRequest) XXX_Size() int

func (*StatsRequest) XXX_Unmarshal 

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

type StatsResponse 

type StatsResponse struct {
	Stats                *proto1.TaskStats `protobuf:"bytes,1,opt,name=stats,proto3" json:"stats,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*StatsResponse) Descriptor 

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

func (*StatsResponse) GetStats 

func (m *StatsResponse) GetStats() *proto1.TaskStats

func (*StatsResponse) ProtoMessage 

func (*StatsResponse) ProtoMessage()

func (*StatsResponse) Reset 

func (m *StatsResponse) Reset()

func (*StatsResponse) String 

func (m *StatsResponse) String() string

func (*StatsResponse) XXX_DiscardUnknown 

func (m *StatsResponse) XXX_DiscardUnknown()

func (*StatsResponse) XXX_Marshal 

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

func (*StatsResponse) XXX_Merge 

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

func (*StatsResponse) XXX_Size 

func (m *StatsResponse) XXX_Size() int

func (*StatsResponse) XXX_Unmarshal 

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

type UnimplementedExecutorServer 

type UnimplementedExecutorServer struct {
}

UnimplementedExecutorServer can be embedded to have forward compatible implementations.

func (*UnimplementedExecutorServer) Exec 

func (*UnimplementedExecutorServer) Exec(ctx context.Context, req *ExecRequest) (*ExecResponse, error)

func (*UnimplementedExecutorServer) ExecStreaming 

func (*UnimplementedExecutorServer) ExecStreaming(srv Executor_ExecStreamingServer) error

func (*UnimplementedExecutorServer) Launch 

func (*UnimplementedExecutorServer) Launch(ctx context.Context, req *LaunchRequest) (*LaunchResponse, error)

func (*UnimplementedExecutorServer) Shutdown 

func (*UnimplementedExecutorServer) Shutdown(ctx context.Context, req *ShutdownRequest) (*ShutdownResponse, error)

func (*UnimplementedExecutorServer) Signal 

func (*UnimplementedExecutorServer) Signal(ctx context.Context, req *SignalRequest) (*SignalResponse, error)

func (*UnimplementedExecutorServer) Stats 

func (*UnimplementedExecutorServer) Stats(req *StatsRequest, srv Executor_StatsServer) error

func (*UnimplementedExecutorServer) UpdateResources 

func (*UnimplementedExecutorServer) UpdateResources(ctx context.Context, req *UpdateResourcesRequest) (*UpdateResourcesResponse, error)

func (*UnimplementedExecutorServer) Version 

func (*UnimplementedExecutorServer) Version(ctx context.Context, req *VersionRequest) (*VersionResponse, error)

func (*UnimplementedExecutorServer) Wait 

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

type UpdateResourcesRequest 

type UpdateResourcesRequest struct {
	Resources            *proto1.Resources `protobuf:"bytes,1,opt,name=resources,proto3" json:"resources,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*UpdateResourcesRequest) Descriptor 

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

func (*UpdateResourcesRequest) GetResources 

func (m *UpdateResourcesRequest) GetResources() *proto1.Resources

func (*UpdateResourcesRequest) ProtoMessage 

func (*UpdateResourcesRequest) ProtoMessage()

func (*UpdateResourcesRequest) Reset 

func (m *UpdateResourcesRequest) Reset()

func (*UpdateResourcesRequest) String 

func (m *UpdateResourcesRequest) String() string

func (*UpdateResourcesRequest) XXX_DiscardUnknown 

func (m *UpdateResourcesRequest) XXX_DiscardUnknown()

func (*UpdateResourcesRequest) XXX_Marshal 

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

func (*UpdateResourcesRequest) XXX_Merge 

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

func (*UpdateResourcesRequest) XXX_Size 

func (m *UpdateResourcesRequest) XXX_Size() int

func (*UpdateResourcesRequest) XXX_Unmarshal 

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

type UpdateResourcesResponse 

type UpdateResourcesResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateResourcesResponse) Descriptor 

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

func (*UpdateResourcesResponse) ProtoMessage 

func (*UpdateResourcesResponse) ProtoMessage()

func (*UpdateResourcesResponse) Reset 

func (m *UpdateResourcesResponse) Reset()

func (*UpdateResourcesResponse) String 

func (m *UpdateResourcesResponse) String() string

func (*UpdateResourcesResponse) XXX_DiscardUnknown 

func (m *UpdateResourcesResponse) XXX_DiscardUnknown()

func (*UpdateResourcesResponse) XXX_Marshal 

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

func (*UpdateResourcesResponse) XXX_Merge 

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

func (*UpdateResourcesResponse) XXX_Size 

func (m *UpdateResourcesResponse) XXX_Size() int

func (*UpdateResourcesResponse) XXX_Unmarshal 

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

type VersionRequest 

type VersionRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VersionRequest) Descriptor 

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

func (*VersionRequest) ProtoMessage 

func (*VersionRequest) ProtoMessage()

func (*VersionRequest) Reset 

func (m *VersionRequest) Reset()

func (*VersionRequest) String 

func (m *VersionRequest) String() string

func (*VersionRequest) XXX_DiscardUnknown 

func (m *VersionRequest) XXX_DiscardUnknown()

func (*VersionRequest) XXX_Marshal 

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

func (*VersionRequest) XXX_Merge 

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

func (*VersionRequest) XXX_Size 

func (m *VersionRequest) XXX_Size() int

func (*VersionRequest) XXX_Unmarshal 

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

type VersionResponse 

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

func (*VersionResponse) Descriptor 

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

func (*VersionResponse) GetVersion 

func (m *VersionResponse) GetVersion() string

func (*VersionResponse) ProtoMessage 

func (*VersionResponse) ProtoMessage()

func (*VersionResponse) Reset 

func (m *VersionResponse) Reset()

func (*VersionResponse) String 

func (m *VersionResponse) String() string

func (*VersionResponse) XXX_DiscardUnknown 

func (m *VersionResponse) XXX_DiscardUnknown()

func (*VersionResponse) XXX_Marshal 

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

func (*VersionResponse) XXX_Merge 

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

func (*VersionResponse) XXX_Size 

func (m *VersionResponse) XXX_Size() int

func (*VersionResponse) XXX_Unmarshal 

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

type WaitRequest 

type WaitRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WaitRequest) Descriptor 

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

func (*WaitRequest) ProtoMessage 

func (*WaitRequest) ProtoMessage()

func (*WaitRequest) Reset 

func (m *WaitRequest) Reset()

func (*WaitRequest) String 

func (m *WaitRequest) String() string

func (*WaitRequest) XXX_DiscardUnknown 

func (m *WaitRequest) XXX_DiscardUnknown()

func (*WaitRequest) XXX_Marshal 

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

func (*WaitRequest) XXX_Merge 

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

func (*WaitRequest) XXX_Size 

func (m *WaitRequest) XXX_Size() int

func (*WaitRequest) XXX_Unmarshal 

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

type WaitResponse 

type WaitResponse struct {
	Process              *ProcessState `protobuf:"bytes,1,opt,name=process,proto3" json:"process,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*WaitResponse) Descriptor 

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

func (*WaitResponse) GetProcess 

func (m *WaitResponse) GetProcess() *ProcessState

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.