Help us shape the future of Go! Take the 2026 Go Developer Survey

tasks

package
v0.49.2 Latest Latest
Warning

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

Go to latest
Published: Dec 9, 2024 License: Apache-2.0, Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthTasks        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTasks          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTasks = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterTasksServer

func RegisterTasksServer(s *grpc.Server, srv TasksServer)

Types

type CheckpointTaskRequest

type CheckpointTaskRequest struct {
	ContainerID          string                                     `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	ParentCheckpoint     github_com_opencontainers_go_digest.Digest `` /* 153-byte string literal not displayed */
	Options              *types1.Any                                `protobuf:"bytes,3,opt,name=options,proto3" json:"options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                   `json:"-"`
	XXX_unrecognized     []byte                                     `json:"-"`
	XXX_sizecache        int32                                      `json:"-"`
}

func (*CheckpointTaskRequest) Descriptor

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

func (*CheckpointTaskRequest) Marshal

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

func (*CheckpointTaskRequest) MarshalTo

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

func (*CheckpointTaskRequest) MarshalToSizedBuffer

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

func (*CheckpointTaskRequest) ProtoMessage

func (*CheckpointTaskRequest) ProtoMessage()

func (*CheckpointTaskRequest) Reset

func (m *CheckpointTaskRequest) Reset()

func (*CheckpointTaskRequest) Size

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

func (*CheckpointTaskRequest) String

func (this *CheckpointTaskRequest) String() string

func (*CheckpointTaskRequest) Unmarshal

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

func (*CheckpointTaskRequest) XXX_DiscardUnknown

func (m *CheckpointTaskRequest) XXX_DiscardUnknown()

func (*CheckpointTaskRequest) XXX_Marshal

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

func (*CheckpointTaskRequest) XXX_Merge

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

func (*CheckpointTaskRequest) XXX_Size

func (m *CheckpointTaskRequest) XXX_Size() int

func (*CheckpointTaskRequest) XXX_Unmarshal

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

type CheckpointTaskResponse

type CheckpointTaskResponse struct {
	Descriptors          []*types.Descriptor `protobuf:"bytes,1,rep,name=descriptors,proto3" json:"descriptors,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*CheckpointTaskResponse) Descriptor

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

func (*CheckpointTaskResponse) Marshal

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

func (*CheckpointTaskResponse) MarshalTo

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

func (*CheckpointTaskResponse) MarshalToSizedBuffer

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

func (*CheckpointTaskResponse) ProtoMessage

func (*CheckpointTaskResponse) ProtoMessage()

func (*CheckpointTaskResponse) Reset

func (m *CheckpointTaskResponse) Reset()

func (*CheckpointTaskResponse) Size

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

func (*CheckpointTaskResponse) String

func (this *CheckpointTaskResponse) String() string

func (*CheckpointTaskResponse) Unmarshal

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

func (*CheckpointTaskResponse) XXX_DiscardUnknown

func (m *CheckpointTaskResponse) XXX_DiscardUnknown()

func (*CheckpointTaskResponse) XXX_Marshal

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

func (*CheckpointTaskResponse) XXX_Merge

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

func (*CheckpointTaskResponse) XXX_Size

func (m *CheckpointTaskResponse) XXX_Size() int

func (*CheckpointTaskResponse) XXX_Unmarshal

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

type CloseIORequest

type CloseIORequest struct {
	ContainerID          string   `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	ExecID               string   `protobuf:"bytes,2,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"`
	Stdin                bool     `protobuf:"varint,3,opt,name=stdin,proto3" json:"stdin,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CloseIORequest) Descriptor

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

func (*CloseIORequest) Marshal

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

func (*CloseIORequest) MarshalTo

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

func (*CloseIORequest) MarshalToSizedBuffer

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

func (*CloseIORequest) ProtoMessage

func (*CloseIORequest) ProtoMessage()

func (*CloseIORequest) Reset

func (m *CloseIORequest) Reset()

func (*CloseIORequest) Size

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

func (*CloseIORequest) String

func (this *CloseIORequest) String() string

func (*CloseIORequest) Unmarshal

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

func (*CloseIORequest) XXX_DiscardUnknown

func (m *CloseIORequest) XXX_DiscardUnknown()

func (*CloseIORequest) XXX_Marshal

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

func (*CloseIORequest) XXX_Merge

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

func (*CloseIORequest) XXX_Size

func (m *CloseIORequest) XXX_Size() int

func (*CloseIORequest) XXX_Unmarshal

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

type CreateTaskRequest

type CreateTaskRequest struct {
	ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	// RootFS provides the pre-chroot mounts to perform in the shim before
	// executing the container task.
	//
	// These are for mounts that cannot be performed in the user namespace.
	// Typically, these mounts should be resolved from snapshots specified on
	// the container object.
	Rootfs               []*types.Mount    `protobuf:"bytes,3,rep,name=rootfs,proto3" json:"rootfs,omitempty"`
	Stdin                string            `protobuf:"bytes,4,opt,name=stdin,proto3" json:"stdin,omitempty"`
	Stdout               string            `protobuf:"bytes,5,opt,name=stdout,proto3" json:"stdout,omitempty"`
	Stderr               string            `protobuf:"bytes,6,opt,name=stderr,proto3" json:"stderr,omitempty"`
	Terminal             bool              `protobuf:"varint,7,opt,name=terminal,proto3" json:"terminal,omitempty"`
	Checkpoint           *types.Descriptor `protobuf:"bytes,8,opt,name=checkpoint,proto3" json:"checkpoint,omitempty"`
	Options              *types1.Any       `protobuf:"bytes,9,opt,name=options,proto3" json:"options,omitempty"`
	RuntimePath          string            `protobuf:"bytes,10,opt,name=runtime_path,json=runtimePath,proto3" json:"runtime_path,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*CreateTaskRequest) Descriptor

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

func (*CreateTaskRequest) Marshal

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

func (*CreateTaskRequest) MarshalTo

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

func (*CreateTaskRequest) MarshalToSizedBuffer

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

func (*CreateTaskRequest) ProtoMessage

func (*CreateTaskRequest) ProtoMessage()

func (*CreateTaskRequest) Reset

func (m *CreateTaskRequest) Reset()

func (*CreateTaskRequest) Size

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

func (*CreateTaskRequest) String

func (this *CreateTaskRequest) String() string

func (*CreateTaskRequest) Unmarshal

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

func (*CreateTaskRequest) XXX_DiscardUnknown

func (m *CreateTaskRequest) XXX_DiscardUnknown()

func (*CreateTaskRequest) XXX_Marshal

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

func (*CreateTaskRequest) XXX_Merge

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

func (*CreateTaskRequest) XXX_Size

func (m *CreateTaskRequest) XXX_Size() int

func (*CreateTaskRequest) XXX_Unmarshal

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

type CreateTaskResponse

type CreateTaskResponse struct {
	ContainerID          string   `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	Pid                  uint32   `protobuf:"varint,2,opt,name=pid,proto3" json:"pid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateTaskResponse) Descriptor

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

func (*CreateTaskResponse) Marshal

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

func (*CreateTaskResponse) MarshalTo

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

func (*CreateTaskResponse) MarshalToSizedBuffer

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

func (*CreateTaskResponse) ProtoMessage

func (*CreateTaskResponse) ProtoMessage()

func (*CreateTaskResponse) Reset

func (m *CreateTaskResponse) Reset()

func (*CreateTaskResponse) Size

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

func (*CreateTaskResponse) String

func (this *CreateTaskResponse) String() string

func (*CreateTaskResponse) Unmarshal

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

func (*CreateTaskResponse) XXX_DiscardUnknown

func (m *CreateTaskResponse) XXX_DiscardUnknown()

func (*CreateTaskResponse) XXX_Marshal

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

func (*CreateTaskResponse) XXX_Merge

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

func (*CreateTaskResponse) XXX_Size

func (m *CreateTaskResponse) XXX_Size() int

func (*CreateTaskResponse) XXX_Unmarshal

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

type DeleteProcessRequest

type DeleteProcessRequest struct {
	ContainerID          string   `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	ExecID               string   `protobuf:"bytes,2,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteProcessRequest) Descriptor

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

func (*DeleteProcessRequest) Marshal

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

func (*DeleteProcessRequest) MarshalTo

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

func (*DeleteProcessRequest) MarshalToSizedBuffer

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

func (*DeleteProcessRequest) ProtoMessage

func (*DeleteProcessRequest) ProtoMessage()

func (*DeleteProcessRequest) Reset

func (m *DeleteProcessRequest) Reset()

func (*DeleteProcessRequest) Size

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

func (*DeleteProcessRequest) String

func (this *DeleteProcessRequest) String() string

func (*DeleteProcessRequest) Unmarshal

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

func (*DeleteProcessRequest) XXX_DiscardUnknown

func (m *DeleteProcessRequest) XXX_DiscardUnknown()

func (*DeleteProcessRequest) XXX_Marshal

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

func (*DeleteProcessRequest) XXX_Merge

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

func (*DeleteProcessRequest) XXX_Size

func (m *DeleteProcessRequest) XXX_Size() int

func (*DeleteProcessRequest) XXX_Unmarshal

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

type DeleteResponse

type DeleteResponse struct {
	ID                   string    `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Pid                  uint32    `protobuf:"varint,2,opt,name=pid,proto3" json:"pid,omitempty"`
	ExitStatus           uint32    `protobuf:"varint,3,opt,name=exit_status,json=exitStatus,proto3" json:"exit_status,omitempty"`
	ExitedAt             time.Time `protobuf:"bytes,4,opt,name=exited_at,json=exitedAt,proto3,stdtime" json:"exited_at"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*DeleteResponse) Descriptor

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

func (*DeleteResponse) Marshal

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

func (*DeleteResponse) MarshalTo

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

func (*DeleteResponse) MarshalToSizedBuffer

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

func (*DeleteResponse) ProtoMessage

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) Reset

func (m *DeleteResponse) Reset()

func (*DeleteResponse) Size

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

func (*DeleteResponse) String

func (this *DeleteResponse) String() string

func (*DeleteResponse) Unmarshal

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

func (*DeleteResponse) XXX_DiscardUnknown

func (m *DeleteResponse) XXX_DiscardUnknown()

func (*DeleteResponse) XXX_Marshal

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

func (*DeleteResponse) XXX_Merge

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

func (*DeleteResponse) XXX_Size

func (m *DeleteResponse) XXX_Size() int

func (*DeleteResponse) XXX_Unmarshal

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

type DeleteTaskRequest

type DeleteTaskRequest struct {
	ContainerID          string   `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteTaskRequest) Descriptor

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

func (*DeleteTaskRequest) Marshal

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

func (*DeleteTaskRequest) MarshalTo

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

func (*DeleteTaskRequest) MarshalToSizedBuffer

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

func (*DeleteTaskRequest) ProtoMessage

func (*DeleteTaskRequest) ProtoMessage()

func (*DeleteTaskRequest) Reset

func (m *DeleteTaskRequest) Reset()

func (*DeleteTaskRequest) Size

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

func (*DeleteTaskRequest) String

func (this *DeleteTaskRequest) String() string

func (*DeleteTaskRequest) Unmarshal

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

func (*DeleteTaskRequest) XXX_DiscardUnknown

func (m *DeleteTaskRequest) XXX_DiscardUnknown()

func (*DeleteTaskRequest) XXX_Marshal

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

func (*DeleteTaskRequest) XXX_Merge

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

func (*DeleteTaskRequest) XXX_Size

func (m *DeleteTaskRequest) XXX_Size() int

func (*DeleteTaskRequest) XXX_Unmarshal

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

type ExecProcessRequest

type ExecProcessRequest struct {
	ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	Stdin       string `protobuf:"bytes,2,opt,name=stdin,proto3" json:"stdin,omitempty"`
	Stdout      string `protobuf:"bytes,3,opt,name=stdout,proto3" json:"stdout,omitempty"`
	Stderr      string `protobuf:"bytes,4,opt,name=stderr,proto3" json:"stderr,omitempty"`
	Terminal    bool   `protobuf:"varint,5,opt,name=terminal,proto3" json:"terminal,omitempty"`
	// Spec for starting a process in the target container.
	//
	// For runc, this is a process spec, for example.
	Spec *types1.Any `protobuf:"bytes,6,opt,name=spec,proto3" json:"spec,omitempty"`
	// id of the exec process
	ExecID               string   `protobuf:"bytes,7,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ExecProcessRequest) Descriptor

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

func (*ExecProcessRequest) Marshal

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

func (*ExecProcessRequest) MarshalTo

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

func (*ExecProcessRequest) MarshalToSizedBuffer

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

func (*ExecProcessRequest) ProtoMessage

func (*ExecProcessRequest) ProtoMessage()

func (*ExecProcessRequest) Reset

func (m *ExecProcessRequest) Reset()

func (*ExecProcessRequest) Size

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

func (*ExecProcessRequest) String

func (this *ExecProcessRequest) String() string

func (*ExecProcessRequest) Unmarshal

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

func (*ExecProcessRequest) XXX_DiscardUnknown

func (m *ExecProcessRequest) XXX_DiscardUnknown()

func (*ExecProcessRequest) XXX_Marshal

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

func (*ExecProcessRequest) XXX_Merge

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

func (*ExecProcessRequest) XXX_Size

func (m *ExecProcessRequest) XXX_Size() int

func (*ExecProcessRequest) XXX_Unmarshal

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

type ExecProcessResponse

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

func (*ExecProcessResponse) Descriptor

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

func (*ExecProcessResponse) Marshal

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

func (*ExecProcessResponse) MarshalTo

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

func (*ExecProcessResponse) MarshalToSizedBuffer

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

func (*ExecProcessResponse) ProtoMessage

func (*ExecProcessResponse) ProtoMessage()

func (*ExecProcessResponse) Reset

func (m *ExecProcessResponse) Reset()

func (*ExecProcessResponse) Size

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

func (*ExecProcessResponse) String

func (this *ExecProcessResponse) String() string

func (*ExecProcessResponse) Unmarshal

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

func (*ExecProcessResponse) XXX_DiscardUnknown

func (m *ExecProcessResponse) XXX_DiscardUnknown()

func (*ExecProcessResponse) XXX_Marshal

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

func (*ExecProcessResponse) XXX_Merge

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

func (*ExecProcessResponse) XXX_Size

func (m *ExecProcessResponse) XXX_Size() int

func (*ExecProcessResponse) XXX_Unmarshal

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

type GetRequest

type GetRequest struct {
	ContainerID          string   `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	ExecID               string   `protobuf:"bytes,2,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetRequest) Descriptor

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

func (*GetRequest) Marshal

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

func (*GetRequest) MarshalTo

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

func (*GetRequest) MarshalToSizedBuffer

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

func (*GetRequest) ProtoMessage

func (*GetRequest) ProtoMessage()

func (*GetRequest) Reset

func (m *GetRequest) Reset()

func (*GetRequest) Size

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

func (*GetRequest) String

func (this *GetRequest) String() string

func (*GetRequest) Unmarshal

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

func (*GetRequest) XXX_DiscardUnknown

func (m *GetRequest) XXX_DiscardUnknown()

func (*GetRequest) XXX_Marshal

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

func (*GetRequest) XXX_Merge

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

func (*GetRequest) XXX_Size

func (m *GetRequest) XXX_Size() int

func (*GetRequest) XXX_Unmarshal

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

type GetResponse

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

func (*GetResponse) Descriptor

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

func (*GetResponse) Marshal

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

func (*GetResponse) MarshalTo

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

func (*GetResponse) MarshalToSizedBuffer

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

func (*GetResponse) ProtoMessage

func (*GetResponse) ProtoMessage()

func (*GetResponse) Reset

func (m *GetResponse) Reset()

func (*GetResponse) Size

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

func (*GetResponse) String

func (this *GetResponse) String() string

func (*GetResponse) Unmarshal

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

func (*GetResponse) XXX_DiscardUnknown

func (m *GetResponse) XXX_DiscardUnknown()

func (*GetResponse) XXX_Marshal

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

func (*GetResponse) XXX_Merge

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

func (*GetResponse) XXX_Size

func (m *GetResponse) XXX_Size() int

func (*GetResponse) XXX_Unmarshal

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

type KillRequest

type KillRequest struct {
	ContainerID          string   `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	ExecID               string   `protobuf:"bytes,2,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"`
	Signal               uint32   `protobuf:"varint,3,opt,name=signal,proto3" json:"signal,omitempty"`
	All                  bool     `protobuf:"varint,4,opt,name=all,proto3" json:"all,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KillRequest) Descriptor

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

func (*KillRequest) Marshal

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

func (*KillRequest) MarshalTo

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

func (*KillRequest) MarshalToSizedBuffer

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

func (*KillRequest) ProtoMessage

func (*KillRequest) ProtoMessage()

func (*KillRequest) Reset

func (m *KillRequest) Reset()

func (*KillRequest) Size

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

func (*KillRequest) String

func (this *KillRequest) String() string

func (*KillRequest) Unmarshal

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

func (*KillRequest) XXX_DiscardUnknown

func (m *KillRequest) XXX_DiscardUnknown()

func (*KillRequest) XXX_Marshal

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

func (*KillRequest) XXX_Merge

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

func (*KillRequest) XXX_Size

func (m *KillRequest) XXX_Size() int

func (*KillRequest) XXX_Unmarshal

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

type ListPidsRequest

type ListPidsRequest struct {
	ContainerID          string   `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListPidsRequest) Descriptor

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

func (*ListPidsRequest) Marshal

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

func (*ListPidsRequest) MarshalTo

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

func (*ListPidsRequest) MarshalToSizedBuffer

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

func (*ListPidsRequest) ProtoMessage

func (*ListPidsRequest) ProtoMessage()

func (*ListPidsRequest) Reset

func (m *ListPidsRequest) Reset()

func (*ListPidsRequest) Size

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

func (*ListPidsRequest) String

func (this *ListPidsRequest) String() string

func (*ListPidsRequest) Unmarshal

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

func (*ListPidsRequest) XXX_DiscardUnknown

func (m *ListPidsRequest) XXX_DiscardUnknown()

func (*ListPidsRequest) XXX_Marshal

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

func (*ListPidsRequest) XXX_Merge

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

func (*ListPidsRequest) XXX_Size

func (m *ListPidsRequest) XXX_Size() int

func (*ListPidsRequest) XXX_Unmarshal

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

type ListPidsResponse

type ListPidsResponse struct {
	// Processes includes the process ID and additional process information
	Processes            []*task.ProcessInfo `protobuf:"bytes,1,rep,name=processes,proto3" json:"processes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*ListPidsResponse) Descriptor

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

func (*ListPidsResponse) Marshal

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

func (*ListPidsResponse) MarshalTo

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

func (*ListPidsResponse) MarshalToSizedBuffer

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

func (*ListPidsResponse) ProtoMessage

func (*ListPidsResponse) ProtoMessage()

func (*ListPidsResponse) Reset

func (m *ListPidsResponse) Reset()

func (*ListPidsResponse) Size

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

func (*ListPidsResponse) String

func (this *ListPidsResponse) String() string

func (*ListPidsResponse) Unmarshal

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

func (*ListPidsResponse) XXX_DiscardUnknown

func (m *ListPidsResponse) XXX_DiscardUnknown()

func (*ListPidsResponse) XXX_Marshal

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

func (*ListPidsResponse) XXX_Merge

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

func (*ListPidsResponse) XXX_Size

func (m *ListPidsResponse) XXX_Size() int

func (*ListPidsResponse) XXX_Unmarshal

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

type ListTasksRequest

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

func (*ListTasksRequest) Descriptor

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

func (*ListTasksRequest) Marshal

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

func (*ListTasksRequest) MarshalTo

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

func (*ListTasksRequest) MarshalToSizedBuffer

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

func (*ListTasksRequest) ProtoMessage

func (*ListTasksRequest) ProtoMessage()

func (*ListTasksRequest) Reset

func (m *ListTasksRequest) Reset()

func (*ListTasksRequest) Size

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

func (*ListTasksRequest) String

func (this *ListTasksRequest) String() string

func (*ListTasksRequest) Unmarshal

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

func (*ListTasksRequest) XXX_DiscardUnknown

func (m *ListTasksRequest) XXX_DiscardUnknown()

func (*ListTasksRequest) XXX_Marshal

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

func (*ListTasksRequest) XXX_Merge

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

func (*ListTasksRequest) XXX_Size

func (m *ListTasksRequest) XXX_Size() int

func (*ListTasksRequest) XXX_Unmarshal

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

type ListTasksResponse

type ListTasksResponse struct {
	Tasks                []*task.Process `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*ListTasksResponse) Descriptor

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

func (*ListTasksResponse) Marshal

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

func (*ListTasksResponse) MarshalTo

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

func (*ListTasksResponse) MarshalToSizedBuffer

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

func (*ListTasksResponse) ProtoMessage

func (*ListTasksResponse) ProtoMessage()

func (*ListTasksResponse) Reset

func (m *ListTasksResponse) Reset()

func (*ListTasksResponse) Size

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

func (*ListTasksResponse) String

func (this *ListTasksResponse) String() string

func (*ListTasksResponse) Unmarshal

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

func (*ListTasksResponse) XXX_DiscardUnknown

func (m *ListTasksResponse) XXX_DiscardUnknown()

func (*ListTasksResponse) XXX_Marshal

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

func (*ListTasksResponse) XXX_Merge

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

func (*ListTasksResponse) XXX_Size

func (m *ListTasksResponse) XXX_Size() int

func (*ListTasksResponse) XXX_Unmarshal

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

type MetricsRequest

type MetricsRequest struct {
	Filters              []string `protobuf:"bytes,1,rep,name=filters,proto3" json:"filters,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MetricsRequest) Descriptor

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

func (*MetricsRequest) Marshal

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

func (*MetricsRequest) MarshalTo

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

func (*MetricsRequest) MarshalToSizedBuffer

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

func (*MetricsRequest) ProtoMessage

func (*MetricsRequest) ProtoMessage()

func (*MetricsRequest) Reset

func (m *MetricsRequest) Reset()

func (*MetricsRequest) Size

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

func (*MetricsRequest) String

func (this *MetricsRequest) String() string

func (*MetricsRequest) Unmarshal

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

func (*MetricsRequest) XXX_DiscardUnknown

func (m *MetricsRequest) XXX_DiscardUnknown()

func (*MetricsRequest) XXX_Marshal

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

func (*MetricsRequest) XXX_Merge

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

func (*MetricsRequest) XXX_Size

func (m *MetricsRequest) XXX_Size() int

func (*MetricsRequest) XXX_Unmarshal

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

type MetricsResponse

type MetricsResponse struct {
	Metrics              []*types.Metric `protobuf:"bytes,1,rep,name=metrics,proto3" json:"metrics,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*MetricsResponse) Descriptor

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

func (*MetricsResponse) Marshal

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

func (*MetricsResponse) MarshalTo

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

func (*MetricsResponse) MarshalToSizedBuffer

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

func (*MetricsResponse) ProtoMessage

func (*MetricsResponse) ProtoMessage()

func (*MetricsResponse) Reset

func (m *MetricsResponse) Reset()

func (*MetricsResponse) Size

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

func (*MetricsResponse) String

func (this *MetricsResponse) String() string

func (*MetricsResponse) Unmarshal

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

func (*MetricsResponse) XXX_DiscardUnknown

func (m *MetricsResponse) XXX_DiscardUnknown()

func (*MetricsResponse) XXX_Marshal

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

func (*MetricsResponse) XXX_Merge

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

func (*MetricsResponse) XXX_Size

func (m *MetricsResponse) XXX_Size() int

func (*MetricsResponse) XXX_Unmarshal

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

type PauseTaskRequest

type PauseTaskRequest struct {
	ContainerID          string   `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PauseTaskRequest) Descriptor

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

func (*PauseTaskRequest) Marshal

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

func (*PauseTaskRequest) MarshalTo

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

func (*PauseTaskRequest) MarshalToSizedBuffer

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

func (*PauseTaskRequest) ProtoMessage

func (*PauseTaskRequest) ProtoMessage()

func (*PauseTaskRequest) Reset

func (m *PauseTaskRequest) Reset()

func (*PauseTaskRequest) Size

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

func (*PauseTaskRequest) String

func (this *PauseTaskRequest) String() string

func (*PauseTaskRequest) Unmarshal

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

func (*PauseTaskRequest) XXX_DiscardUnknown

func (m *PauseTaskRequest) XXX_DiscardUnknown()

func (*PauseTaskRequest) XXX_Marshal

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

func (*PauseTaskRequest) XXX_Merge

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

func (*PauseTaskRequest) XXX_Size

func (m *PauseTaskRequest) XXX_Size() int

func (*PauseTaskRequest) XXX_Unmarshal

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

type ResizePtyRequest

type ResizePtyRequest struct {
	ContainerID          string   `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	ExecID               string   `protobuf:"bytes,2,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"`
	Width                uint32   `protobuf:"varint,3,opt,name=width,proto3" json:"width,omitempty"`
	Height               uint32   `protobuf:"varint,4,opt,name=height,proto3" json:"height,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResizePtyRequest) Descriptor

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

func (*ResizePtyRequest) Marshal

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

func (*ResizePtyRequest) MarshalTo

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

func (*ResizePtyRequest) MarshalToSizedBuffer

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

func (*ResizePtyRequest) ProtoMessage

func (*ResizePtyRequest) ProtoMessage()

func (*ResizePtyRequest) Reset

func (m *ResizePtyRequest) Reset()

func (*ResizePtyRequest) Size

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

func (*ResizePtyRequest) String

func (this *ResizePtyRequest) String() string

func (*ResizePtyRequest) Unmarshal

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

func (*ResizePtyRequest) XXX_DiscardUnknown

func (m *ResizePtyRequest) XXX_DiscardUnknown()

func (*ResizePtyRequest) XXX_Marshal

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

func (*ResizePtyRequest) XXX_Merge

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

func (*ResizePtyRequest) XXX_Size

func (m *ResizePtyRequest) XXX_Size() int

func (*ResizePtyRequest) XXX_Unmarshal

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

type ResumeTaskRequest

type ResumeTaskRequest struct {
	ContainerID          string   `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResumeTaskRequest) Descriptor

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

func (*ResumeTaskRequest) Marshal

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

func (*ResumeTaskRequest) MarshalTo

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

func (*ResumeTaskRequest) MarshalToSizedBuffer

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

func (*ResumeTaskRequest) ProtoMessage

func (*ResumeTaskRequest) ProtoMessage()

func (*ResumeTaskRequest) Reset

func (m *ResumeTaskRequest) Reset()

func (*ResumeTaskRequest) Size

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

func (*ResumeTaskRequest) String

func (this *ResumeTaskRequest) String() string

func (*ResumeTaskRequest) Unmarshal

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

func (*ResumeTaskRequest) XXX_DiscardUnknown

func (m *ResumeTaskRequest) XXX_DiscardUnknown()

func (*ResumeTaskRequest) XXX_Marshal

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

func (*ResumeTaskRequest) XXX_Merge

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

func (*ResumeTaskRequest) XXX_Size

func (m *ResumeTaskRequest) XXX_Size() int

func (*ResumeTaskRequest) XXX_Unmarshal

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

type StartRequest

type StartRequest struct {
	ContainerID          string   `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	ExecID               string   `protobuf:"bytes,2,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StartRequest) Descriptor

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

func (*StartRequest) Marshal

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

func (*StartRequest) MarshalTo

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

func (*StartRequest) MarshalToSizedBuffer

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

func (*StartRequest) ProtoMessage

func (*StartRequest) ProtoMessage()

func (*StartRequest) Reset

func (m *StartRequest) Reset()

func (*StartRequest) Size

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

func (*StartRequest) String

func (this *StartRequest) String() string

func (*StartRequest) Unmarshal

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

func (*StartRequest) XXX_DiscardUnknown

func (m *StartRequest) XXX_DiscardUnknown()

func (*StartRequest) XXX_Marshal

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

func (*StartRequest) XXX_Merge

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

func (*StartRequest) XXX_Size

func (m *StartRequest) XXX_Size() int

func (*StartRequest) XXX_Unmarshal

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

type StartResponse

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

func (*StartResponse) Descriptor

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

func (*StartResponse) Marshal

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

func (*StartResponse) MarshalTo

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

func (*StartResponse) MarshalToSizedBuffer

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

func (*StartResponse) ProtoMessage

func (*StartResponse) ProtoMessage()

func (*StartResponse) Reset

func (m *StartResponse) Reset()

func (*StartResponse) Size

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

func (*StartResponse) String

func (this *StartResponse) String() string

func (*StartResponse) Unmarshal

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

func (*StartResponse) XXX_DiscardUnknown

func (m *StartResponse) XXX_DiscardUnknown()

func (*StartResponse) XXX_Marshal

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

func (*StartResponse) XXX_Merge

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

func (*StartResponse) XXX_Size

func (m *StartResponse) XXX_Size() int

func (*StartResponse) XXX_Unmarshal

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

type TasksClient

type TasksClient interface {
	// Create a task.
	Create(ctx context.Context, in *CreateTaskRequest, opts ...grpc.CallOption) (*CreateTaskResponse, error)
	// Start a process.
	Start(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartResponse, error)
	// Delete a task and on disk state.
	Delete(ctx context.Context, in *DeleteTaskRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	DeleteProcess(ctx context.Context, in *DeleteProcessRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	List(ctx context.Context, in *ListTasksRequest, opts ...grpc.CallOption) (*ListTasksResponse, error)
	// Kill a task or process.
	Kill(ctx context.Context, in *KillRequest, opts ...grpc.CallOption) (*types1.Empty, error)
	Exec(ctx context.Context, in *ExecProcessRequest, opts ...grpc.CallOption) (*types1.Empty, error)
	ResizePty(ctx context.Context, in *ResizePtyRequest, opts ...grpc.CallOption) (*types1.Empty, error)
	CloseIO(ctx context.Context, in *CloseIORequest, opts ...grpc.CallOption) (*types1.Empty, error)
	Pause(ctx context.Context, in *PauseTaskRequest, opts ...grpc.CallOption) (*types1.Empty, error)
	Resume(ctx context.Context, in *ResumeTaskRequest, opts ...grpc.CallOption) (*types1.Empty, error)
	ListPids(ctx context.Context, in *ListPidsRequest, opts ...grpc.CallOption) (*ListPidsResponse, error)
	Checkpoint(ctx context.Context, in *CheckpointTaskRequest, opts ...grpc.CallOption) (*CheckpointTaskResponse, error)
	Update(ctx context.Context, in *UpdateTaskRequest, opts ...grpc.CallOption) (*types1.Empty, error)
	Metrics(ctx context.Context, in *MetricsRequest, opts ...grpc.CallOption) (*MetricsResponse, error)
	Wait(ctx context.Context, in *WaitRequest, opts ...grpc.CallOption) (*WaitResponse, error)
}

TasksClient is the client API for Tasks service.

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

func NewTasksClient

func NewTasksClient(cc *grpc.ClientConn) TasksClient

type UnimplementedTasksServer

type UnimplementedTasksServer struct {
}

UnimplementedTasksServer can be embedded to have forward compatible implementations.

func (*UnimplementedTasksServer) Checkpoint

func (*UnimplementedTasksServer) CloseIO

func (*UnimplementedTasksServer) Create

func (*UnimplementedTasksServer) Delete

func (*UnimplementedTasksServer) DeleteProcess

func (*UnimplementedTasksServer) Exec

func (*UnimplementedTasksServer) Get

func (*UnimplementedTasksServer) Kill

func (*UnimplementedTasksServer) List

func (*UnimplementedTasksServer) ListPids

func (*UnimplementedTasksServer) Metrics

func (*UnimplementedTasksServer) Pause

func (*UnimplementedTasksServer) ResizePty

func (*UnimplementedTasksServer) Resume

func (*UnimplementedTasksServer) Start

func (*UnimplementedTasksServer) Update

func (*UnimplementedTasksServer) Wait

type UpdateTaskRequest

type UpdateTaskRequest struct {
	ContainerID          string            `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	Resources            *types1.Any       `protobuf:"bytes,2,opt,name=resources,proto3" json:"resources,omitempty"`
	Annotations          map[string]string `` /* 163-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*UpdateTaskRequest) Descriptor

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

func (*UpdateTaskRequest) Marshal

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

func (*UpdateTaskRequest) MarshalTo

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

func (*UpdateTaskRequest) MarshalToSizedBuffer

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

func (*UpdateTaskRequest) ProtoMessage

func (*UpdateTaskRequest) ProtoMessage()

func (*UpdateTaskRequest) Reset

func (m *UpdateTaskRequest) Reset()

func (*UpdateTaskRequest) Size

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

func (*UpdateTaskRequest) String

func (this *UpdateTaskRequest) String() string

func (*UpdateTaskRequest) Unmarshal

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

func (*UpdateTaskRequest) XXX_DiscardUnknown

func (m *UpdateTaskRequest) XXX_DiscardUnknown()

func (*UpdateTaskRequest) XXX_Marshal

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

func (*UpdateTaskRequest) XXX_Merge

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

func (*UpdateTaskRequest) XXX_Size

func (m *UpdateTaskRequest) XXX_Size() int

func (*UpdateTaskRequest) XXX_Unmarshal

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

type WaitRequest

type WaitRequest struct {
	ContainerID          string   `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	ExecID               string   `protobuf:"bytes,2,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WaitRequest) Descriptor

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

func (*WaitRequest) Marshal

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

func (*WaitRequest) MarshalTo

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

func (*WaitRequest) MarshalToSizedBuffer

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

func (*WaitRequest) ProtoMessage

func (*WaitRequest) ProtoMessage()

func (*WaitRequest) Reset

func (m *WaitRequest) Reset()

func (*WaitRequest) Size

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

func (*WaitRequest) String

func (this *WaitRequest) String() string

func (*WaitRequest) Unmarshal

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

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 {
	ExitStatus           uint32    `protobuf:"varint,1,opt,name=exit_status,json=exitStatus,proto3" json:"exit_status,omitempty"`
	ExitedAt             time.Time `protobuf:"bytes,2,opt,name=exited_at,json=exitedAt,proto3,stdtime" json:"exited_at"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*WaitResponse) Descriptor

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

func (*WaitResponse) Marshal

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

func (*WaitResponse) MarshalTo

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

func (*WaitResponse) MarshalToSizedBuffer

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

func (*WaitResponse) ProtoMessage

func (*WaitResponse) ProtoMessage()

func (*WaitResponse) Reset

func (m *WaitResponse) Reset()

func (*WaitResponse) Size

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

func (*WaitResponse) String

func (this *WaitResponse) String() string

func (*WaitResponse) Unmarshal

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL