Versions in this module Expand all Collapse all v1 v1.3.4 Apr 16, 2020 v1.0.0 May 17, 2020 Changes in this version + var ErrIntOverflowTasks = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthTasks = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupTasks = fmt.Errorf("proto: unexpected end of group") + func RegisterTasksServer(s *grpc.Server, srv TasksServer) + type CheckpointTaskRequest struct + ContainerID string + Options *types1.Any + ParentCheckpoint github_com_opencontainers_go_digest.Digest + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CheckpointTaskRequest) Descriptor() ([]byte, []int) + func (*CheckpointTaskRequest) ProtoMessage() + func (m *CheckpointTaskRequest) Marshal() (dAtA []byte, err error) + func (m *CheckpointTaskRequest) MarshalTo(dAtA []byte) (int, error) + func (m *CheckpointTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CheckpointTaskRequest) Reset() + func (m *CheckpointTaskRequest) Size() (n int) + func (m *CheckpointTaskRequest) Unmarshal(dAtA []byte) error + func (m *CheckpointTaskRequest) XXX_DiscardUnknown() + func (m *CheckpointTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CheckpointTaskRequest) XXX_Merge(src proto.Message) + func (m *CheckpointTaskRequest) XXX_Size() int + func (m *CheckpointTaskRequest) XXX_Unmarshal(b []byte) error + func (this *CheckpointTaskRequest) String() string + type CheckpointTaskResponse struct + Descriptors []*types.Descriptor + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CheckpointTaskResponse) Descriptor() ([]byte, []int) + func (*CheckpointTaskResponse) ProtoMessage() + func (m *CheckpointTaskResponse) Marshal() (dAtA []byte, err error) + func (m *CheckpointTaskResponse) MarshalTo(dAtA []byte) (int, error) + func (m *CheckpointTaskResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CheckpointTaskResponse) Reset() + func (m *CheckpointTaskResponse) Size() (n int) + func (m *CheckpointTaskResponse) Unmarshal(dAtA []byte) error + func (m *CheckpointTaskResponse) XXX_DiscardUnknown() + func (m *CheckpointTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CheckpointTaskResponse) XXX_Merge(src proto.Message) + func (m *CheckpointTaskResponse) XXX_Size() int + func (m *CheckpointTaskResponse) XXX_Unmarshal(b []byte) error + func (this *CheckpointTaskResponse) String() string + type CloseIORequest struct + ContainerID string + ExecID string + Stdin bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CloseIORequest) Descriptor() ([]byte, []int) + func (*CloseIORequest) ProtoMessage() + func (m *CloseIORequest) Marshal() (dAtA []byte, err error) + func (m *CloseIORequest) MarshalTo(dAtA []byte) (int, error) + func (m *CloseIORequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CloseIORequest) Reset() + func (m *CloseIORequest) Size() (n int) + func (m *CloseIORequest) Unmarshal(dAtA []byte) error + func (m *CloseIORequest) XXX_DiscardUnknown() + func (m *CloseIORequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CloseIORequest) XXX_Merge(src proto.Message) + func (m *CloseIORequest) XXX_Size() int + func (m *CloseIORequest) XXX_Unmarshal(b []byte) error + func (this *CloseIORequest) String() string + type CreateTaskRequest struct + Checkpoint *types.Descriptor + ContainerID string + Options *types1.Any + Rootfs []*types.Mount + Stderr string + Stdin string + Stdout string + Terminal bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreateTaskRequest) Descriptor() ([]byte, []int) + func (*CreateTaskRequest) ProtoMessage() + func (m *CreateTaskRequest) Marshal() (dAtA []byte, err error) + func (m *CreateTaskRequest) MarshalTo(dAtA []byte) (int, error) + func (m *CreateTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CreateTaskRequest) Reset() + func (m *CreateTaskRequest) Size() (n int) + func (m *CreateTaskRequest) Unmarshal(dAtA []byte) error + func (m *CreateTaskRequest) XXX_DiscardUnknown() + func (m *CreateTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateTaskRequest) XXX_Merge(src proto.Message) + func (m *CreateTaskRequest) XXX_Size() int + func (m *CreateTaskRequest) XXX_Unmarshal(b []byte) error + func (this *CreateTaskRequest) String() string + type CreateTaskResponse struct + ContainerID string + Pid uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreateTaskResponse) Descriptor() ([]byte, []int) + func (*CreateTaskResponse) ProtoMessage() + func (m *CreateTaskResponse) Marshal() (dAtA []byte, err error) + func (m *CreateTaskResponse) MarshalTo(dAtA []byte) (int, error) + func (m *CreateTaskResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CreateTaskResponse) Reset() + func (m *CreateTaskResponse) Size() (n int) + func (m *CreateTaskResponse) Unmarshal(dAtA []byte) error + func (m *CreateTaskResponse) XXX_DiscardUnknown() + func (m *CreateTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateTaskResponse) XXX_Merge(src proto.Message) + func (m *CreateTaskResponse) XXX_Size() int + func (m *CreateTaskResponse) XXX_Unmarshal(b []byte) error + func (this *CreateTaskResponse) String() string + type DeleteProcessRequest struct + ContainerID string + ExecID string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteProcessRequest) Descriptor() ([]byte, []int) + func (*DeleteProcessRequest) ProtoMessage() + func (m *DeleteProcessRequest) Marshal() (dAtA []byte, err error) + func (m *DeleteProcessRequest) MarshalTo(dAtA []byte) (int, error) + func (m *DeleteProcessRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DeleteProcessRequest) Reset() + func (m *DeleteProcessRequest) Size() (n int) + func (m *DeleteProcessRequest) Unmarshal(dAtA []byte) error + func (m *DeleteProcessRequest) XXX_DiscardUnknown() + func (m *DeleteProcessRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteProcessRequest) XXX_Merge(src proto.Message) + func (m *DeleteProcessRequest) XXX_Size() int + func (m *DeleteProcessRequest) XXX_Unmarshal(b []byte) error + func (this *DeleteProcessRequest) String() string + type DeleteResponse struct + ExitStatus uint32 + ExitedAt time.Time + ID string + Pid uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteResponse) Descriptor() ([]byte, []int) + func (*DeleteResponse) ProtoMessage() + func (m *DeleteResponse) Marshal() (dAtA []byte, err error) + func (m *DeleteResponse) MarshalTo(dAtA []byte) (int, error) + func (m *DeleteResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DeleteResponse) Reset() + func (m *DeleteResponse) Size() (n int) + func (m *DeleteResponse) Unmarshal(dAtA []byte) error + func (m *DeleteResponse) XXX_DiscardUnknown() + func (m *DeleteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteResponse) XXX_Merge(src proto.Message) + func (m *DeleteResponse) XXX_Size() int + func (m *DeleteResponse) XXX_Unmarshal(b []byte) error + func (this *DeleteResponse) String() string + type DeleteTaskRequest struct + ContainerID string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteTaskRequest) Descriptor() ([]byte, []int) + func (*DeleteTaskRequest) ProtoMessage() + func (m *DeleteTaskRequest) Marshal() (dAtA []byte, err error) + func (m *DeleteTaskRequest) MarshalTo(dAtA []byte) (int, error) + func (m *DeleteTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DeleteTaskRequest) Reset() + func (m *DeleteTaskRequest) Size() (n int) + func (m *DeleteTaskRequest) Unmarshal(dAtA []byte) error + func (m *DeleteTaskRequest) XXX_DiscardUnknown() + func (m *DeleteTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteTaskRequest) XXX_Merge(src proto.Message) + func (m *DeleteTaskRequest) XXX_Size() int + func (m *DeleteTaskRequest) XXX_Unmarshal(b []byte) error + func (this *DeleteTaskRequest) String() string + type ExecProcessRequest struct + ContainerID string + ExecID string + Spec *types1.Any + Stderr string + Stdin string + Stdout string + Terminal bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ExecProcessRequest) Descriptor() ([]byte, []int) + func (*ExecProcessRequest) ProtoMessage() + func (m *ExecProcessRequest) Marshal() (dAtA []byte, err error) + func (m *ExecProcessRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ExecProcessRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ExecProcessRequest) Reset() + func (m *ExecProcessRequest) Size() (n int) + func (m *ExecProcessRequest) Unmarshal(dAtA []byte) error + func (m *ExecProcessRequest) XXX_DiscardUnknown() + func (m *ExecProcessRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ExecProcessRequest) XXX_Merge(src proto.Message) + func (m *ExecProcessRequest) XXX_Size() int + func (m *ExecProcessRequest) XXX_Unmarshal(b []byte) error + func (this *ExecProcessRequest) String() string + type ExecProcessResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ExecProcessResponse) Descriptor() ([]byte, []int) + func (*ExecProcessResponse) ProtoMessage() + func (m *ExecProcessResponse) Marshal() (dAtA []byte, err error) + func (m *ExecProcessResponse) MarshalTo(dAtA []byte) (int, error) + func (m *ExecProcessResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ExecProcessResponse) Reset() + func (m *ExecProcessResponse) Size() (n int) + func (m *ExecProcessResponse) Unmarshal(dAtA []byte) error + func (m *ExecProcessResponse) XXX_DiscardUnknown() + func (m *ExecProcessResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ExecProcessResponse) XXX_Merge(src proto.Message) + func (m *ExecProcessResponse) XXX_Size() int + func (m *ExecProcessResponse) XXX_Unmarshal(b []byte) error + func (this *ExecProcessResponse) String() string + type GetRequest struct + ContainerID string + ExecID string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetRequest) Descriptor() ([]byte, []int) + func (*GetRequest) ProtoMessage() + func (m *GetRequest) Marshal() (dAtA []byte, err error) + func (m *GetRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetRequest) Reset() + func (m *GetRequest) Size() (n int) + func (m *GetRequest) Unmarshal(dAtA []byte) error + func (m *GetRequest) XXX_DiscardUnknown() + func (m *GetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetRequest) XXX_Merge(src proto.Message) + func (m *GetRequest) XXX_Size() int + func (m *GetRequest) XXX_Unmarshal(b []byte) error + func (this *GetRequest) String() string + type GetResponse struct + Process *task.Process + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetResponse) Descriptor() ([]byte, []int) + func (*GetResponse) ProtoMessage() + func (m *GetResponse) Marshal() (dAtA []byte, err error) + func (m *GetResponse) MarshalTo(dAtA []byte) (int, error) + func (m *GetResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetResponse) Reset() + func (m *GetResponse) Size() (n int) + func (m *GetResponse) Unmarshal(dAtA []byte) error + func (m *GetResponse) XXX_DiscardUnknown() + func (m *GetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetResponse) XXX_Merge(src proto.Message) + func (m *GetResponse) XXX_Size() int + func (m *GetResponse) XXX_Unmarshal(b []byte) error + func (this *GetResponse) String() string + type KillRequest struct + All bool + ContainerID string + ExecID string + Signal uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*KillRequest) Descriptor() ([]byte, []int) + func (*KillRequest) ProtoMessage() + func (m *KillRequest) Marshal() (dAtA []byte, err error) + func (m *KillRequest) MarshalTo(dAtA []byte) (int, error) + func (m *KillRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *KillRequest) Reset() + func (m *KillRequest) Size() (n int) + func (m *KillRequest) Unmarshal(dAtA []byte) error + func (m *KillRequest) XXX_DiscardUnknown() + func (m *KillRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *KillRequest) XXX_Merge(src proto.Message) + func (m *KillRequest) XXX_Size() int + func (m *KillRequest) XXX_Unmarshal(b []byte) error + func (this *KillRequest) String() string + type ListPidsRequest struct + ContainerID string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListPidsRequest) Descriptor() ([]byte, []int) + func (*ListPidsRequest) ProtoMessage() + func (m *ListPidsRequest) Marshal() (dAtA []byte, err error) + func (m *ListPidsRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ListPidsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ListPidsRequest) Reset() + func (m *ListPidsRequest) Size() (n int) + func (m *ListPidsRequest) Unmarshal(dAtA []byte) error + func (m *ListPidsRequest) XXX_DiscardUnknown() + func (m *ListPidsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListPidsRequest) XXX_Merge(src proto.Message) + func (m *ListPidsRequest) XXX_Size() int + func (m *ListPidsRequest) XXX_Unmarshal(b []byte) error + func (this *ListPidsRequest) String() string + type ListPidsResponse struct + Processes []*task.ProcessInfo + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListPidsResponse) Descriptor() ([]byte, []int) + func (*ListPidsResponse) ProtoMessage() + func (m *ListPidsResponse) Marshal() (dAtA []byte, err error) + func (m *ListPidsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *ListPidsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ListPidsResponse) Reset() + func (m *ListPidsResponse) Size() (n int) + func (m *ListPidsResponse) Unmarshal(dAtA []byte) error + func (m *ListPidsResponse) XXX_DiscardUnknown() + func (m *ListPidsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListPidsResponse) XXX_Merge(src proto.Message) + func (m *ListPidsResponse) XXX_Size() int + func (m *ListPidsResponse) XXX_Unmarshal(b []byte) error + func (this *ListPidsResponse) String() string + type ListTasksRequest struct + Filter string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListTasksRequest) Descriptor() ([]byte, []int) + func (*ListTasksRequest) ProtoMessage() + func (m *ListTasksRequest) Marshal() (dAtA []byte, err error) + func (m *ListTasksRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ListTasksRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ListTasksRequest) Reset() + func (m *ListTasksRequest) Size() (n int) + func (m *ListTasksRequest) Unmarshal(dAtA []byte) error + func (m *ListTasksRequest) XXX_DiscardUnknown() + func (m *ListTasksRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListTasksRequest) XXX_Merge(src proto.Message) + func (m *ListTasksRequest) XXX_Size() int + func (m *ListTasksRequest) XXX_Unmarshal(b []byte) error + func (this *ListTasksRequest) String() string + type ListTasksResponse struct + Tasks []*task.Process + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListTasksResponse) Descriptor() ([]byte, []int) + func (*ListTasksResponse) ProtoMessage() + func (m *ListTasksResponse) Marshal() (dAtA []byte, err error) + func (m *ListTasksResponse) MarshalTo(dAtA []byte) (int, error) + func (m *ListTasksResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ListTasksResponse) Reset() + func (m *ListTasksResponse) Size() (n int) + func (m *ListTasksResponse) Unmarshal(dAtA []byte) error + func (m *ListTasksResponse) XXX_DiscardUnknown() + func (m *ListTasksResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListTasksResponse) XXX_Merge(src proto.Message) + func (m *ListTasksResponse) XXX_Size() int + func (m *ListTasksResponse) XXX_Unmarshal(b []byte) error + func (this *ListTasksResponse) String() string + type MetricsRequest struct + Filters []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*MetricsRequest) Descriptor() ([]byte, []int) + func (*MetricsRequest) ProtoMessage() + func (m *MetricsRequest) Marshal() (dAtA []byte, err error) + func (m *MetricsRequest) MarshalTo(dAtA []byte) (int, error) + func (m *MetricsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MetricsRequest) Reset() + func (m *MetricsRequest) Size() (n int) + func (m *MetricsRequest) Unmarshal(dAtA []byte) error + func (m *MetricsRequest) XXX_DiscardUnknown() + func (m *MetricsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MetricsRequest) XXX_Merge(src proto.Message) + func (m *MetricsRequest) XXX_Size() int + func (m *MetricsRequest) XXX_Unmarshal(b []byte) error + func (this *MetricsRequest) String() string + type MetricsResponse struct + Metrics []*types.Metric + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*MetricsResponse) Descriptor() ([]byte, []int) + func (*MetricsResponse) ProtoMessage() + func (m *MetricsResponse) Marshal() (dAtA []byte, err error) + func (m *MetricsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *MetricsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MetricsResponse) Reset() + func (m *MetricsResponse) Size() (n int) + func (m *MetricsResponse) Unmarshal(dAtA []byte) error + func (m *MetricsResponse) XXX_DiscardUnknown() + func (m *MetricsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MetricsResponse) XXX_Merge(src proto.Message) + func (m *MetricsResponse) XXX_Size() int + func (m *MetricsResponse) XXX_Unmarshal(b []byte) error + func (this *MetricsResponse) String() string + type PauseTaskRequest struct + ContainerID string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PauseTaskRequest) Descriptor() ([]byte, []int) + func (*PauseTaskRequest) ProtoMessage() + func (m *PauseTaskRequest) Marshal() (dAtA []byte, err error) + func (m *PauseTaskRequest) MarshalTo(dAtA []byte) (int, error) + func (m *PauseTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PauseTaskRequest) Reset() + func (m *PauseTaskRequest) Size() (n int) + func (m *PauseTaskRequest) Unmarshal(dAtA []byte) error + func (m *PauseTaskRequest) XXX_DiscardUnknown() + func (m *PauseTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PauseTaskRequest) XXX_Merge(src proto.Message) + func (m *PauseTaskRequest) XXX_Size() int + func (m *PauseTaskRequest) XXX_Unmarshal(b []byte) error + func (this *PauseTaskRequest) String() string + type ResizePtyRequest struct + ContainerID string + ExecID string + Height uint32 + Width uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ResizePtyRequest) Descriptor() ([]byte, []int) + func (*ResizePtyRequest) ProtoMessage() + func (m *ResizePtyRequest) Marshal() (dAtA []byte, err error) + func (m *ResizePtyRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ResizePtyRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ResizePtyRequest) Reset() + func (m *ResizePtyRequest) Size() (n int) + func (m *ResizePtyRequest) Unmarshal(dAtA []byte) error + func (m *ResizePtyRequest) XXX_DiscardUnknown() + func (m *ResizePtyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ResizePtyRequest) XXX_Merge(src proto.Message) + func (m *ResizePtyRequest) XXX_Size() int + func (m *ResizePtyRequest) XXX_Unmarshal(b []byte) error + func (this *ResizePtyRequest) String() string + type ResumeTaskRequest struct + ContainerID string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ResumeTaskRequest) Descriptor() ([]byte, []int) + func (*ResumeTaskRequest) ProtoMessage() + func (m *ResumeTaskRequest) Marshal() (dAtA []byte, err error) + func (m *ResumeTaskRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ResumeTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ResumeTaskRequest) Reset() + func (m *ResumeTaskRequest) Size() (n int) + func (m *ResumeTaskRequest) Unmarshal(dAtA []byte) error + func (m *ResumeTaskRequest) XXX_DiscardUnknown() + func (m *ResumeTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ResumeTaskRequest) XXX_Merge(src proto.Message) + func (m *ResumeTaskRequest) XXX_Size() int + func (m *ResumeTaskRequest) XXX_Unmarshal(b []byte) error + func (this *ResumeTaskRequest) String() string + type StartRequest struct + ContainerID string + ExecID string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StartRequest) Descriptor() ([]byte, []int) + func (*StartRequest) ProtoMessage() + func (m *StartRequest) Marshal() (dAtA []byte, err error) + func (m *StartRequest) MarshalTo(dAtA []byte) (int, error) + func (m *StartRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *StartRequest) Reset() + func (m *StartRequest) Size() (n int) + func (m *StartRequest) Unmarshal(dAtA []byte) error + func (m *StartRequest) XXX_DiscardUnknown() + func (m *StartRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StartRequest) XXX_Merge(src proto.Message) + func (m *StartRequest) XXX_Size() int + func (m *StartRequest) XXX_Unmarshal(b []byte) error + func (this *StartRequest) String() string + type StartResponse struct + Pid uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StartResponse) Descriptor() ([]byte, []int) + func (*StartResponse) ProtoMessage() + func (m *StartResponse) Marshal() (dAtA []byte, err error) + func (m *StartResponse) MarshalTo(dAtA []byte) (int, error) + func (m *StartResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *StartResponse) Reset() + func (m *StartResponse) Size() (n int) + func (m *StartResponse) Unmarshal(dAtA []byte) error + func (m *StartResponse) XXX_DiscardUnknown() + func (m *StartResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StartResponse) XXX_Merge(src proto.Message) + func (m *StartResponse) XXX_Size() int + func (m *StartResponse) XXX_Unmarshal(b []byte) error + func (this *StartResponse) String() string + type TasksClient interface + Checkpoint func(ctx context.Context, in *CheckpointTaskRequest, opts ...grpc.CallOption) (*CheckpointTaskResponse, error) + CloseIO func(ctx context.Context, in *CloseIORequest, opts ...grpc.CallOption) (*types1.Empty, error) + Create func(ctx context.Context, in *CreateTaskRequest, opts ...grpc.CallOption) (*CreateTaskResponse, error) + Delete func(ctx context.Context, in *DeleteTaskRequest, opts ...grpc.CallOption) (*DeleteResponse, error) + DeleteProcess func(ctx context.Context, in *DeleteProcessRequest, opts ...grpc.CallOption) (*DeleteResponse, error) + Exec func(ctx context.Context, in *ExecProcessRequest, opts ...grpc.CallOption) (*types1.Empty, error) + Get func(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error) + Kill func(ctx context.Context, in *KillRequest, opts ...grpc.CallOption) (*types1.Empty, error) + List func(ctx context.Context, in *ListTasksRequest, opts ...grpc.CallOption) (*ListTasksResponse, error) + ListPids func(ctx context.Context, in *ListPidsRequest, opts ...grpc.CallOption) (*ListPidsResponse, error) + Metrics func(ctx context.Context, in *MetricsRequest, opts ...grpc.CallOption) (*MetricsResponse, error) + Pause func(ctx context.Context, in *PauseTaskRequest, opts ...grpc.CallOption) (*types1.Empty, error) + ResizePty func(ctx context.Context, in *ResizePtyRequest, opts ...grpc.CallOption) (*types1.Empty, error) + Resume func(ctx context.Context, in *ResumeTaskRequest, opts ...grpc.CallOption) (*types1.Empty, error) + Start func(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartResponse, error) + Update func(ctx context.Context, in *UpdateTaskRequest, opts ...grpc.CallOption) (*types1.Empty, error) + Wait func(ctx context.Context, in *WaitRequest, opts ...grpc.CallOption) (*WaitResponse, error) + func NewTasksClient(cc *grpc.ClientConn) TasksClient + type TasksServer interface + Checkpoint func(context.Context, *CheckpointTaskRequest) (*CheckpointTaskResponse, error) + CloseIO func(context.Context, *CloseIORequest) (*types1.Empty, error) + Create func(context.Context, *CreateTaskRequest) (*CreateTaskResponse, error) + Delete func(context.Context, *DeleteTaskRequest) (*DeleteResponse, error) + DeleteProcess func(context.Context, *DeleteProcessRequest) (*DeleteResponse, error) + Exec func(context.Context, *ExecProcessRequest) (*types1.Empty, error) + Get func(context.Context, *GetRequest) (*GetResponse, error) + Kill func(context.Context, *KillRequest) (*types1.Empty, error) + List func(context.Context, *ListTasksRequest) (*ListTasksResponse, error) + ListPids func(context.Context, *ListPidsRequest) (*ListPidsResponse, error) + Metrics func(context.Context, *MetricsRequest) (*MetricsResponse, error) + Pause func(context.Context, *PauseTaskRequest) (*types1.Empty, error) + ResizePty func(context.Context, *ResizePtyRequest) (*types1.Empty, error) + Resume func(context.Context, *ResumeTaskRequest) (*types1.Empty, error) + Start func(context.Context, *StartRequest) (*StartResponse, error) + Update func(context.Context, *UpdateTaskRequest) (*types1.Empty, error) + Wait func(context.Context, *WaitRequest) (*WaitResponse, error) + type UnimplementedTasksServer struct + func (*UnimplementedTasksServer) Checkpoint(ctx context.Context, req *CheckpointTaskRequest) (*CheckpointTaskResponse, error) + func (*UnimplementedTasksServer) CloseIO(ctx context.Context, req *CloseIORequest) (*types1.Empty, error) + func (*UnimplementedTasksServer) Create(ctx context.Context, req *CreateTaskRequest) (*CreateTaskResponse, error) + func (*UnimplementedTasksServer) Delete(ctx context.Context, req *DeleteTaskRequest) (*DeleteResponse, error) + func (*UnimplementedTasksServer) DeleteProcess(ctx context.Context, req *DeleteProcessRequest) (*DeleteResponse, error) + func (*UnimplementedTasksServer) Exec(ctx context.Context, req *ExecProcessRequest) (*types1.Empty, error) + func (*UnimplementedTasksServer) Get(ctx context.Context, req *GetRequest) (*GetResponse, error) + func (*UnimplementedTasksServer) Kill(ctx context.Context, req *KillRequest) (*types1.Empty, error) + func (*UnimplementedTasksServer) List(ctx context.Context, req *ListTasksRequest) (*ListTasksResponse, error) + func (*UnimplementedTasksServer) ListPids(ctx context.Context, req *ListPidsRequest) (*ListPidsResponse, error) + func (*UnimplementedTasksServer) Metrics(ctx context.Context, req *MetricsRequest) (*MetricsResponse, error) + func (*UnimplementedTasksServer) Pause(ctx context.Context, req *PauseTaskRequest) (*types1.Empty, error) + func (*UnimplementedTasksServer) ResizePty(ctx context.Context, req *ResizePtyRequest) (*types1.Empty, error) + func (*UnimplementedTasksServer) Resume(ctx context.Context, req *ResumeTaskRequest) (*types1.Empty, error) + func (*UnimplementedTasksServer) Start(ctx context.Context, req *StartRequest) (*StartResponse, error) + func (*UnimplementedTasksServer) Update(ctx context.Context, req *UpdateTaskRequest) (*types1.Empty, error) + func (*UnimplementedTasksServer) Wait(ctx context.Context, req *WaitRequest) (*WaitResponse, error) + type UpdateTaskRequest struct + ContainerID string + Resources *types1.Any + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdateTaskRequest) Descriptor() ([]byte, []int) + func (*UpdateTaskRequest) ProtoMessage() + func (m *UpdateTaskRequest) Marshal() (dAtA []byte, err error) + func (m *UpdateTaskRequest) MarshalTo(dAtA []byte) (int, error) + func (m *UpdateTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *UpdateTaskRequest) Reset() + func (m *UpdateTaskRequest) Size() (n int) + func (m *UpdateTaskRequest) Unmarshal(dAtA []byte) error + func (m *UpdateTaskRequest) XXX_DiscardUnknown() + func (m *UpdateTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdateTaskRequest) XXX_Merge(src proto.Message) + func (m *UpdateTaskRequest) XXX_Size() int + func (m *UpdateTaskRequest) XXX_Unmarshal(b []byte) error + func (this *UpdateTaskRequest) String() string + type WaitRequest struct + ContainerID string + ExecID string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WaitRequest) Descriptor() ([]byte, []int) + func (*WaitRequest) ProtoMessage() + func (m *WaitRequest) Marshal() (dAtA []byte, err error) + func (m *WaitRequest) MarshalTo(dAtA []byte) (int, error) + func (m *WaitRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *WaitRequest) Reset() + func (m *WaitRequest) Size() (n int) + func (m *WaitRequest) Unmarshal(dAtA []byte) error + func (m *WaitRequest) XXX_DiscardUnknown() + func (m *WaitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WaitRequest) XXX_Merge(src proto.Message) + func (m *WaitRequest) XXX_Size() int + func (m *WaitRequest) XXX_Unmarshal(b []byte) error + func (this *WaitRequest) String() string + type WaitResponse struct + ExitStatus uint32 + ExitedAt time.Time + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WaitResponse) Descriptor() ([]byte, []int) + func (*WaitResponse) ProtoMessage() + func (m *WaitResponse) Marshal() (dAtA []byte, err error) + func (m *WaitResponse) MarshalTo(dAtA []byte) (int, error) + func (m *WaitResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *WaitResponse) Reset() + func (m *WaitResponse) Size() (n int) + func (m *WaitResponse) Unmarshal(dAtA []byte) error + func (m *WaitResponse) XXX_DiscardUnknown() + func (m *WaitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WaitResponse) XXX_Merge(src proto.Message) + func (m *WaitResponse) XXX_Size() int + func (m *WaitResponse) XXX_Unmarshal(b []byte) error + func (this *WaitResponse) String() string
Go to main page