Documentation ¶
Index ¶
- func RegisterExecutorServer(s *grpc.Server, srv ExecutorServer)
- type ExecRequest
- func (*ExecRequest) Descriptor() ([]byte, []int)
- func (m *ExecRequest) GetArgs() []string
- func (m *ExecRequest) GetCmd() string
- func (m *ExecRequest) GetDeadline() *timestamp.Timestamp
- func (*ExecRequest) ProtoMessage()
- func (m *ExecRequest) Reset()
- func (m *ExecRequest) String() string
- func (m *ExecRequest) XXX_DiscardUnknown()
- func (m *ExecRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ExecRequest) XXX_Merge(src proto.Message)
- func (m *ExecRequest) XXX_Size() int
- func (m *ExecRequest) XXX_Unmarshal(b []byte) error
- type ExecResponse
- func (*ExecResponse) Descriptor() ([]byte, []int)
- func (m *ExecResponse) GetExitCode() int32
- func (m *ExecResponse) GetOutput() []byte
- func (*ExecResponse) ProtoMessage()
- func (m *ExecResponse) Reset()
- func (m *ExecResponse) String() string
- func (m *ExecResponse) XXX_DiscardUnknown()
- func (m *ExecResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ExecResponse) XXX_Merge(src proto.Message)
- func (m *ExecResponse) XXX_Size() int
- func (m *ExecResponse) XXX_Unmarshal(b []byte) error
- type ExecutorClient
- type ExecutorServer
- type Executor_ExecStreamingClient
- type Executor_ExecStreamingServer
- type Executor_StatsClient
- type Executor_StatsServer
- type LaunchRequest
- func (*LaunchRequest) Descriptor() ([]byte, []int)
- func (m *LaunchRequest) GetArgs() []string
- func (m *LaunchRequest) GetBasicProcessCgroup() bool
- func (m *LaunchRequest) GetCmd() string
- func (m *LaunchRequest) GetDevices() []*proto1.Device
- func (m *LaunchRequest) GetEnv() []string
- func (m *LaunchRequest) GetMounts() []*proto1.Mount
- func (m *LaunchRequest) GetResourceLimits() bool
- func (m *LaunchRequest) GetResources() *proto1.Resources
- func (m *LaunchRequest) GetStderrPath() string
- func (m *LaunchRequest) GetStdoutPath() string
- func (m *LaunchRequest) GetTaskDir() string
- func (m *LaunchRequest) GetUser() string
- func (*LaunchRequest) ProtoMessage()
- func (m *LaunchRequest) Reset()
- func (m *LaunchRequest) String() string
- func (m *LaunchRequest) XXX_DiscardUnknown()
- func (m *LaunchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *LaunchRequest) XXX_Merge(src proto.Message)
- func (m *LaunchRequest) XXX_Size() int
- func (m *LaunchRequest) XXX_Unmarshal(b []byte) error
- type LaunchResponse
- func (*LaunchResponse) Descriptor() ([]byte, []int)
- func (m *LaunchResponse) GetProcess() *ProcessState
- func (*LaunchResponse) ProtoMessage()
- func (m *LaunchResponse) Reset()
- func (m *LaunchResponse) String() string
- func (m *LaunchResponse) XXX_DiscardUnknown()
- func (m *LaunchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *LaunchResponse) XXX_Merge(src proto.Message)
- func (m *LaunchResponse) XXX_Size() int
- func (m *LaunchResponse) XXX_Unmarshal(b []byte) error
- type ProcessState
- func (*ProcessState) Descriptor() ([]byte, []int)
- func (m *ProcessState) GetExitCode() int32
- func (m *ProcessState) GetPid() int32
- func (m *ProcessState) GetSignal() int32
- func (m *ProcessState) GetTime() *timestamp.Timestamp
- func (*ProcessState) ProtoMessage()
- func (m *ProcessState) Reset()
- func (m *ProcessState) String() string
- func (m *ProcessState) XXX_DiscardUnknown()
- func (m *ProcessState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ProcessState) XXX_Merge(src proto.Message)
- func (m *ProcessState) XXX_Size() int
- func (m *ProcessState) XXX_Unmarshal(b []byte) error
- type ShutdownRequest
- func (*ShutdownRequest) Descriptor() ([]byte, []int)
- func (m *ShutdownRequest) GetGracePeriod() int64
- func (m *ShutdownRequest) GetSignal() string
- func (*ShutdownRequest) ProtoMessage()
- func (m *ShutdownRequest) Reset()
- func (m *ShutdownRequest) String() string
- func (m *ShutdownRequest) XXX_DiscardUnknown()
- func (m *ShutdownRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ShutdownRequest) XXX_Merge(src proto.Message)
- func (m *ShutdownRequest) XXX_Size() int
- func (m *ShutdownRequest) XXX_Unmarshal(b []byte) error
- type ShutdownResponse
- func (*ShutdownResponse) Descriptor() ([]byte, []int)
- func (*ShutdownResponse) ProtoMessage()
- func (m *ShutdownResponse) Reset()
- func (m *ShutdownResponse) String() string
- func (m *ShutdownResponse) XXX_DiscardUnknown()
- func (m *ShutdownResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ShutdownResponse) XXX_Merge(src proto.Message)
- func (m *ShutdownResponse) XXX_Size() int
- func (m *ShutdownResponse) XXX_Unmarshal(b []byte) error
- type SignalRequest
- func (*SignalRequest) Descriptor() ([]byte, []int)
- func (m *SignalRequest) GetSignal() int32
- func (*SignalRequest) ProtoMessage()
- func (m *SignalRequest) Reset()
- func (m *SignalRequest) String() string
- func (m *SignalRequest) XXX_DiscardUnknown()
- func (m *SignalRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *SignalRequest) XXX_Merge(src proto.Message)
- func (m *SignalRequest) XXX_Size() int
- func (m *SignalRequest) XXX_Unmarshal(b []byte) error
- type SignalResponse
- func (*SignalResponse) Descriptor() ([]byte, []int)
- func (*SignalResponse) ProtoMessage()
- func (m *SignalResponse) Reset()
- func (m *SignalResponse) String() string
- func (m *SignalResponse) XXX_DiscardUnknown()
- func (m *SignalResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *SignalResponse) XXX_Merge(src proto.Message)
- func (m *SignalResponse) XXX_Size() int
- func (m *SignalResponse) XXX_Unmarshal(b []byte) error
- type StatsRequest
- func (*StatsRequest) Descriptor() ([]byte, []int)
- func (m *StatsRequest) GetInterval() int64
- func (*StatsRequest) ProtoMessage()
- func (m *StatsRequest) Reset()
- func (m *StatsRequest) String() string
- func (m *StatsRequest) XXX_DiscardUnknown()
- func (m *StatsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *StatsRequest) XXX_Merge(src proto.Message)
- func (m *StatsRequest) XXX_Size() int
- func (m *StatsRequest) XXX_Unmarshal(b []byte) error
- type StatsResponse
- func (*StatsResponse) Descriptor() ([]byte, []int)
- func (m *StatsResponse) GetStats() *proto1.TaskStats
- func (*StatsResponse) ProtoMessage()
- func (m *StatsResponse) Reset()
- func (m *StatsResponse) String() string
- func (m *StatsResponse) XXX_DiscardUnknown()
- func (m *StatsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *StatsResponse) XXX_Merge(src proto.Message)
- func (m *StatsResponse) XXX_Size() int
- func (m *StatsResponse) XXX_Unmarshal(b []byte) error
- type UpdateResourcesRequest
- func (*UpdateResourcesRequest) Descriptor() ([]byte, []int)
- func (m *UpdateResourcesRequest) GetResources() *proto1.Resources
- func (*UpdateResourcesRequest) ProtoMessage()
- func (m *UpdateResourcesRequest) Reset()
- func (m *UpdateResourcesRequest) String() string
- func (m *UpdateResourcesRequest) XXX_DiscardUnknown()
- func (m *UpdateResourcesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *UpdateResourcesRequest) XXX_Merge(src proto.Message)
- func (m *UpdateResourcesRequest) XXX_Size() int
- func (m *UpdateResourcesRequest) XXX_Unmarshal(b []byte) error
- type UpdateResourcesResponse
- func (*UpdateResourcesResponse) Descriptor() ([]byte, []int)
- func (*UpdateResourcesResponse) ProtoMessage()
- func (m *UpdateResourcesResponse) Reset()
- func (m *UpdateResourcesResponse) String() string
- func (m *UpdateResourcesResponse) XXX_DiscardUnknown()
- func (m *UpdateResourcesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *UpdateResourcesResponse) XXX_Merge(src proto.Message)
- func (m *UpdateResourcesResponse) XXX_Size() int
- func (m *UpdateResourcesResponse) XXX_Unmarshal(b []byte) error
- type VersionRequest
- func (*VersionRequest) Descriptor() ([]byte, []int)
- func (*VersionRequest) ProtoMessage()
- func (m *VersionRequest) Reset()
- func (m *VersionRequest) String() string
- func (m *VersionRequest) XXX_DiscardUnknown()
- func (m *VersionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *VersionRequest) XXX_Merge(src proto.Message)
- func (m *VersionRequest) XXX_Size() int
- func (m *VersionRequest) XXX_Unmarshal(b []byte) error
- type VersionResponse
- func (*VersionResponse) Descriptor() ([]byte, []int)
- func (m *VersionResponse) GetVersion() string
- func (*VersionResponse) ProtoMessage()
- func (m *VersionResponse) Reset()
- func (m *VersionResponse) String() string
- func (m *VersionResponse) XXX_DiscardUnknown()
- func (m *VersionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *VersionResponse) XXX_Merge(src proto.Message)
- func (m *VersionResponse) XXX_Size() int
- func (m *VersionResponse) XXX_Unmarshal(b []byte) error
- type WaitRequest
- func (*WaitRequest) Descriptor() ([]byte, []int)
- func (*WaitRequest) ProtoMessage()
- func (m *WaitRequest) Reset()
- func (m *WaitRequest) String() string
- func (m *WaitRequest) XXX_DiscardUnknown()
- func (m *WaitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *WaitRequest) XXX_Merge(src proto.Message)
- func (m *WaitRequest) XXX_Size() int
- func (m *WaitRequest) XXX_Unmarshal(b []byte) error
- type WaitResponse
- func (*WaitResponse) Descriptor() ([]byte, []int)
- func (m *WaitResponse) GetProcess() *ProcessState
- func (*WaitResponse) ProtoMessage()
- func (m *WaitResponse) Reset()
- func (m *WaitResponse) String() string
- func (m *WaitResponse) XXX_DiscardUnknown()
- func (m *WaitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *WaitResponse) XXX_Merge(src proto.Message)
- func (m *WaitResponse) XXX_Size() int
- func (m *WaitResponse) XXX_Unmarshal(b []byte) error
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 (dst *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 (dst *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) 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.ClientConn) 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) 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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*LaunchRequest) Descriptor ¶
func (*LaunchRequest) Descriptor() ([]byte, []int)
func (*LaunchRequest) GetArgs ¶
func (m *LaunchRequest) GetArgs() []string
func (*LaunchRequest) GetBasicProcessCgroup ¶
func (m *LaunchRequest) GetBasicProcessCgroup() bool
func (*LaunchRequest) GetCmd ¶
func (m *LaunchRequest) GetCmd() 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) 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 (dst *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 (dst *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 (dst *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 (dst *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 (dst *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 (dst *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 (dst *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 (dst *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 (dst *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 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 (dst *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 (dst *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 (dst *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 (dst *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 (dst *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 (dst *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
Click to show internal directories.
Click to hide internal directories.