tasks

package
v1.3.9 Latest Latest
Warning

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

Go to latest
Published: Nov 30, 2020 License: Apache-2.0 Imports: 13 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")
)

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) 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 added in v1.3.0

func (m *CheckpointTaskRequest) XXX_DiscardUnknown()

func (*CheckpointTaskRequest) XXX_Marshal added in v1.3.0

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

func (*CheckpointTaskRequest) XXX_Merge added in v1.3.0

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

func (*CheckpointTaskRequest) XXX_Size added in v1.3.0

func (m *CheckpointTaskRequest) XXX_Size() int

func (*CheckpointTaskRequest) XXX_Unmarshal added in v1.3.0

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) 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 added in v1.3.0

func (m *CheckpointTaskResponse) XXX_DiscardUnknown()

func (*CheckpointTaskResponse) XXX_Marshal added in v1.3.0

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

func (*CheckpointTaskResponse) XXX_Merge added in v1.3.0

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

func (*CheckpointTaskResponse) XXX_Size added in v1.3.0

func (m *CheckpointTaskResponse) XXX_Size() int

func (*CheckpointTaskResponse) XXX_Unmarshal added in v1.3.0

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) 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 added in v1.3.0

func (m *CloseIORequest) XXX_DiscardUnknown()

func (*CloseIORequest) XXX_Marshal added in v1.3.0

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

func (*CloseIORequest) XXX_Merge added in v1.3.0

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

func (*CloseIORequest) XXX_Size added in v1.3.0

func (m *CloseIORequest) XXX_Size() int

func (*CloseIORequest) XXX_Unmarshal added in v1.3.0

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"`
	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) 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 added in v1.3.0

func (m *CreateTaskRequest) XXX_DiscardUnknown()

func (*CreateTaskRequest) XXX_Marshal added in v1.3.0

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

func (*CreateTaskRequest) XXX_Merge added in v1.3.0

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

func (*CreateTaskRequest) XXX_Size added in v1.3.0

func (m *CreateTaskRequest) XXX_Size() int

func (*CreateTaskRequest) XXX_Unmarshal added in v1.3.0

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) 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 added in v1.3.0

func (m *CreateTaskResponse) XXX_DiscardUnknown()

func (*CreateTaskResponse) XXX_Marshal added in v1.3.0

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

func (*CreateTaskResponse) XXX_Merge added in v1.3.0

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

func (*CreateTaskResponse) XXX_Size added in v1.3.0

func (m *CreateTaskResponse) XXX_Size() int

func (*CreateTaskResponse) XXX_Unmarshal added in v1.3.0

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) 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 added in v1.3.0

func (m *DeleteProcessRequest) XXX_DiscardUnknown()

func (*DeleteProcessRequest) XXX_Marshal added in v1.3.0

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

func (*DeleteProcessRequest) XXX_Merge added in v1.3.0

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

func (*DeleteProcessRequest) XXX_Size added in v1.3.0

func (m *DeleteProcessRequest) XXX_Size() int

func (*DeleteProcessRequest) XXX_Unmarshal added in v1.3.0

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) 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 added in v1.3.0

func (m *DeleteResponse) XXX_DiscardUnknown()

func (*DeleteResponse) XXX_Marshal added in v1.3.0

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

func (*DeleteResponse) XXX_Merge added in v1.3.0

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

func (*DeleteResponse) XXX_Size added in v1.3.0

func (m *DeleteResponse) XXX_Size() int

func (*DeleteResponse) XXX_Unmarshal added in v1.3.0

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) 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 added in v1.3.0

func (m *DeleteTaskRequest) XXX_DiscardUnknown()

func (*DeleteTaskRequest) XXX_Marshal added in v1.3.0

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

func (*DeleteTaskRequest) XXX_Merge added in v1.3.0

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

func (*DeleteTaskRequest) XXX_Size added in v1.3.0

func (m *DeleteTaskRequest) XXX_Size() int

func (*DeleteTaskRequest) XXX_Unmarshal added in v1.3.0

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) 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 added in v1.3.0

func (m *ExecProcessRequest) XXX_DiscardUnknown()

func (*ExecProcessRequest) XXX_Marshal added in v1.3.0

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

func (*ExecProcessRequest) XXX_Merge added in v1.3.0

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

func (*ExecProcessRequest) XXX_Size added in v1.3.0

func (m *ExecProcessRequest) XXX_Size() int

func (*ExecProcessRequest) XXX_Unmarshal added in v1.3.0

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) 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 added in v1.3.0

func (m *ExecProcessResponse) XXX_DiscardUnknown()

func (*ExecProcessResponse) XXX_Marshal added in v1.3.0

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

func (*ExecProcessResponse) XXX_Merge added in v1.3.0

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

func (*ExecProcessResponse) XXX_Size added in v1.3.0

func (m *ExecProcessResponse) XXX_Size() int

func (*ExecProcessResponse) XXX_Unmarshal added in v1.3.0

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) 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 added in v1.3.0

func (m *GetRequest) XXX_DiscardUnknown()

func (*GetRequest) XXX_Marshal added in v1.3.0

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

func (*GetRequest) XXX_Merge added in v1.3.0

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

func (*GetRequest) XXX_Size added in v1.3.0

func (m *GetRequest) XXX_Size() int

func (*GetRequest) XXX_Unmarshal added in v1.3.0

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) 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 added in v1.3.0

func (m *GetResponse) XXX_DiscardUnknown()

func (*GetResponse) XXX_Marshal added in v1.3.0

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

func (*GetResponse) XXX_Merge added in v1.3.0

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

func (*GetResponse) XXX_Size added in v1.3.0

func (m *GetResponse) XXX_Size() int

func (*GetResponse) XXX_Unmarshal added in v1.3.0

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) 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 added in v1.3.0

func (m *KillRequest) XXX_DiscardUnknown()

func (*KillRequest) XXX_Marshal added in v1.3.0

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

func (*KillRequest) XXX_Merge added in v1.3.0

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

func (*KillRequest) XXX_Size added in v1.3.0

func (m *KillRequest) XXX_Size() int

func (*KillRequest) XXX_Unmarshal added in v1.3.0

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) 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 added in v1.3.0

func (m *ListPidsRequest) XXX_DiscardUnknown()

func (*ListPidsRequest) XXX_Marshal added in v1.3.0

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

func (*ListPidsRequest) XXX_Merge added in v1.3.0

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

func (*ListPidsRequest) XXX_Size added in v1.3.0

func (m *ListPidsRequest) XXX_Size() int

func (*ListPidsRequest) XXX_Unmarshal added in v1.3.0

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) 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 added in v1.3.0

func (m *ListPidsResponse) XXX_DiscardUnknown()

func (*ListPidsResponse) XXX_Marshal added in v1.3.0

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

func (*ListPidsResponse) XXX_Merge added in v1.3.0

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

func (*ListPidsResponse) XXX_Size added in v1.3.0

func (m *ListPidsResponse) XXX_Size() int

func (*ListPidsResponse) XXX_Unmarshal added in v1.3.0

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) 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 added in v1.3.0

func (m *ListTasksRequest) XXX_DiscardUnknown()

func (*ListTasksRequest) XXX_Marshal added in v1.3.0

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

func (*ListTasksRequest) XXX_Merge added in v1.3.0

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

func (*ListTasksRequest) XXX_Size added in v1.3.0

func (m *ListTasksRequest) XXX_Size() int

func (*ListTasksRequest) XXX_Unmarshal added in v1.3.0

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) 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 added in v1.3.0

func (m *ListTasksResponse) XXX_DiscardUnknown()

func (*ListTasksResponse) XXX_Marshal added in v1.3.0

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

func (*ListTasksResponse) XXX_Merge added in v1.3.0

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

func (*ListTasksResponse) XXX_Size added in v1.3.0

func (m *ListTasksResponse) XXX_Size() int

func (*ListTasksResponse) XXX_Unmarshal added in v1.3.0

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) 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 added in v1.3.0

func (m *MetricsRequest) XXX_DiscardUnknown()

func (*MetricsRequest) XXX_Marshal added in v1.3.0

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

func (*MetricsRequest) XXX_Merge added in v1.3.0

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

func (*MetricsRequest) XXX_Size added in v1.3.0

func (m *MetricsRequest) XXX_Size() int

func (*MetricsRequest) XXX_Unmarshal added in v1.3.0

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) 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 added in v1.3.0

func (m *MetricsResponse) XXX_DiscardUnknown()

func (*MetricsResponse) XXX_Marshal added in v1.3.0

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

func (*MetricsResponse) XXX_Merge added in v1.3.0

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

func (*MetricsResponse) XXX_Size added in v1.3.0

func (m *MetricsResponse) XXX_Size() int

func (*MetricsResponse) XXX_Unmarshal added in v1.3.0

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) 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 added in v1.3.0

func (m *PauseTaskRequest) XXX_DiscardUnknown()

func (*PauseTaskRequest) XXX_Marshal added in v1.3.0

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

func (*PauseTaskRequest) XXX_Merge added in v1.3.0

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

func (*PauseTaskRequest) XXX_Size added in v1.3.0

func (m *PauseTaskRequest) XXX_Size() int

func (*PauseTaskRequest) XXX_Unmarshal added in v1.3.0

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) 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 added in v1.3.0

func (m *ResizePtyRequest) XXX_DiscardUnknown()

func (*ResizePtyRequest) XXX_Marshal added in v1.3.0

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

func (*ResizePtyRequest) XXX_Merge added in v1.3.0

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

func (*ResizePtyRequest) XXX_Size added in v1.3.0

func (m *ResizePtyRequest) XXX_Size() int

func (*ResizePtyRequest) XXX_Unmarshal added in v1.3.0

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) 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 added in v1.3.0

func (m *ResumeTaskRequest) XXX_DiscardUnknown()

func (*ResumeTaskRequest) XXX_Marshal added in v1.3.0

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

func (*ResumeTaskRequest) XXX_Merge added in v1.3.0

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

func (*ResumeTaskRequest) XXX_Size added in v1.3.0

func (m *ResumeTaskRequest) XXX_Size() int

func (*ResumeTaskRequest) XXX_Unmarshal added in v1.3.0

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) 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 added in v1.3.0

func (m *StartRequest) XXX_DiscardUnknown()

func (*StartRequest) XXX_Marshal added in v1.3.0

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

func (*StartRequest) XXX_Merge added in v1.3.0

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

func (*StartRequest) XXX_Size added in v1.3.0

func (m *StartRequest) XXX_Size() int

func (*StartRequest) XXX_Unmarshal added in v1.3.0

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) 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 added in v1.3.0

func (m *StartResponse) XXX_DiscardUnknown()

func (*StartResponse) XXX_Marshal added in v1.3.0

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

func (*StartResponse) XXX_Merge added in v1.3.0

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

func (*StartResponse) XXX_Size added in v1.3.0

func (m *StartResponse) XXX_Size() int

func (*StartResponse) XXX_Unmarshal added in v1.3.0

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 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"`
	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) 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 added in v1.3.0

func (m *UpdateTaskRequest) XXX_DiscardUnknown()

func (*UpdateTaskRequest) XXX_Marshal added in v1.3.0

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

func (*UpdateTaskRequest) XXX_Merge added in v1.3.0

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

func (*UpdateTaskRequest) XXX_Size added in v1.3.0

func (m *UpdateTaskRequest) XXX_Size() int

func (*UpdateTaskRequest) XXX_Unmarshal added in v1.3.0

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) 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 added in v1.3.0

func (m *WaitRequest) XXX_DiscardUnknown()

func (*WaitRequest) XXX_Marshal added in v1.3.0

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

func (*WaitRequest) XXX_Merge added in v1.3.0

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

func (*WaitRequest) XXX_Size added in v1.3.0

func (m *WaitRequest) XXX_Size() int

func (*WaitRequest) XXX_Unmarshal added in v1.3.0

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) 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 added in v1.3.0

func (m *WaitResponse) XXX_DiscardUnknown()

func (*WaitResponse) XXX_Marshal added in v1.3.0

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

func (*WaitResponse) XXX_Merge added in v1.3.0

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

func (*WaitResponse) XXX_Size added in v1.3.0

func (m *WaitResponse) XXX_Size() int

func (*WaitResponse) XXX_Unmarshal added in v1.3.0

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