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

proto

package
v0.9.2 Latest Latest
Warning

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

Go to latest
Published: Jun 5, 2019 License: MPL-2.0 Imports: 9 Imported by: 77

Documentation

Index

Constants

This section is empty.

Variables

View Source
var CPUUsage_Fields_name = map[int32]string{
	0: "SYSTEM_MODE",
	1: "USER_MODE",
	2: "TOTAL_TICKS",
	3: "THROTTLED_PERIODS",
	4: "THROTTLED_TIME",
	5: "PERCENT",
}
View Source
var CPUUsage_Fields_value = map[string]int32{
	"SYSTEM_MODE":       0,
	"USER_MODE":         1,
	"TOTAL_TICKS":       2,
	"THROTTLED_PERIODS": 3,
	"THROTTLED_TIME":    4,
	"PERCENT":           5,
}
View Source
var DriverCapabilities_FSIsolation_name = map[int32]string{
	0: "NONE",
	1: "CHROOT",
	2: "IMAGE",
}
View Source
var DriverCapabilities_FSIsolation_value = map[string]int32{
	"NONE":   0,
	"CHROOT": 1,
	"IMAGE":  2,
}
View Source
var FingerprintResponse_HealthState_name = map[int32]string{
	0: "UNDETECTED",
	1: "UNHEALTHY",
	2: "HEALTHY",
}
View Source
var FingerprintResponse_HealthState_value = map[string]int32{
	"UNDETECTED": 0,
	"UNHEALTHY":  1,
	"HEALTHY":    2,
}
View Source
var MemoryUsage_Fields_name = map[int32]string{
	0: "RSS",
	1: "CACHE",
	2: "MAX_USAGE",
	3: "KERNEL_USAGE",
	4: "KERNEL_MAX_USAGE",
	5: "USAGE",
	6: "SWAP",
}
View Source
var MemoryUsage_Fields_value = map[string]int32{
	"RSS":              0,
	"CACHE":            1,
	"MAX_USAGE":        2,
	"KERNEL_USAGE":     3,
	"KERNEL_MAX_USAGE": 4,
	"USAGE":            5,
	"SWAP":             6,
}
View Source
var StartTaskResponse_Result_name = map[int32]string{
	0: "SUCCESS",
	1: "RETRY",
	2: "FATAL",
}
View Source
var StartTaskResponse_Result_value = map[string]int32{
	"SUCCESS": 0,
	"RETRY":   1,
	"FATAL":   2,
}
View Source
var TaskState_name = map[int32]string{
	0: "UNKNOWN",
	1: "RUNNING",
	2: "EXITED",
}
View Source
var TaskState_value = map[string]int32{
	"UNKNOWN": 0,
	"RUNNING": 1,
	"EXITED":  2,
}

Functions

func RegisterDriverServer

func RegisterDriverServer(s *grpc.Server, srv DriverServer)

Types

type AllocatedCpuResources

type AllocatedCpuResources struct {
	CpuShares            int64    `protobuf:"varint,1,opt,name=cpu_shares,json=cpuShares,proto3" json:"cpu_shares,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AllocatedCpuResources) Descriptor

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

func (*AllocatedCpuResources) GetCpuShares

func (m *AllocatedCpuResources) GetCpuShares() int64

func (*AllocatedCpuResources) ProtoMessage

func (*AllocatedCpuResources) ProtoMessage()

func (*AllocatedCpuResources) Reset

func (m *AllocatedCpuResources) Reset()

func (*AllocatedCpuResources) String

func (m *AllocatedCpuResources) String() string

func (*AllocatedCpuResources) XXX_DiscardUnknown

func (m *AllocatedCpuResources) XXX_DiscardUnknown()

func (*AllocatedCpuResources) XXX_Marshal

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

func (*AllocatedCpuResources) XXX_Merge

func (dst *AllocatedCpuResources) XXX_Merge(src proto.Message)

func (*AllocatedCpuResources) XXX_Size

func (m *AllocatedCpuResources) XXX_Size() int

func (*AllocatedCpuResources) XXX_Unmarshal

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

type AllocatedMemoryResources

type AllocatedMemoryResources struct {
	MemoryMb             int64    `protobuf:"varint,2,opt,name=memory_mb,json=memoryMb,proto3" json:"memory_mb,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AllocatedMemoryResources) Descriptor

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

func (*AllocatedMemoryResources) GetMemoryMb

func (m *AllocatedMemoryResources) GetMemoryMb() int64

func (*AllocatedMemoryResources) ProtoMessage

func (*AllocatedMemoryResources) ProtoMessage()

func (*AllocatedMemoryResources) Reset

func (m *AllocatedMemoryResources) Reset()

func (*AllocatedMemoryResources) String

func (m *AllocatedMemoryResources) String() string

func (*AllocatedMemoryResources) XXX_DiscardUnknown

func (m *AllocatedMemoryResources) XXX_DiscardUnknown()

func (*AllocatedMemoryResources) XXX_Marshal

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

func (*AllocatedMemoryResources) XXX_Merge

func (dst *AllocatedMemoryResources) XXX_Merge(src proto.Message)

func (*AllocatedMemoryResources) XXX_Size

func (m *AllocatedMemoryResources) XXX_Size() int

func (*AllocatedMemoryResources) XXX_Unmarshal

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

type AllocatedTaskResources

type AllocatedTaskResources struct {
	Cpu                  *AllocatedCpuResources    `protobuf:"bytes,1,opt,name=cpu,proto3" json:"cpu,omitempty"`
	Memory               *AllocatedMemoryResources `protobuf:"bytes,2,opt,name=memory,proto3" json:"memory,omitempty"`
	Networks             []*NetworkResource        `protobuf:"bytes,5,rep,name=networks,proto3" json:"networks,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*AllocatedTaskResources) Descriptor

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

func (*AllocatedTaskResources) GetCpu

func (*AllocatedTaskResources) GetMemory

func (*AllocatedTaskResources) GetNetworks

func (m *AllocatedTaskResources) GetNetworks() []*NetworkResource

func (*AllocatedTaskResources) ProtoMessage

func (*AllocatedTaskResources) ProtoMessage()

func (*AllocatedTaskResources) Reset

func (m *AllocatedTaskResources) Reset()

func (*AllocatedTaskResources) String

func (m *AllocatedTaskResources) String() string

func (*AllocatedTaskResources) XXX_DiscardUnknown

func (m *AllocatedTaskResources) XXX_DiscardUnknown()

func (*AllocatedTaskResources) XXX_Marshal

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

func (*AllocatedTaskResources) XXX_Merge

func (dst *AllocatedTaskResources) XXX_Merge(src proto.Message)

func (*AllocatedTaskResources) XXX_Size

func (m *AllocatedTaskResources) XXX_Size() int

func (*AllocatedTaskResources) XXX_Unmarshal

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

type CPUUsage

type CPUUsage struct {
	SystemMode       float64 `protobuf:"fixed64,1,opt,name=system_mode,json=systemMode,proto3" json:"system_mode,omitempty"`
	UserMode         float64 `protobuf:"fixed64,2,opt,name=user_mode,json=userMode,proto3" json:"user_mode,omitempty"`
	TotalTicks       float64 `protobuf:"fixed64,3,opt,name=total_ticks,json=totalTicks,proto3" json:"total_ticks,omitempty"`
	ThrottledPeriods uint64  `protobuf:"varint,4,opt,name=throttled_periods,json=throttledPeriods,proto3" json:"throttled_periods,omitempty"`
	ThrottledTime    uint64  `protobuf:"varint,5,opt,name=throttled_time,json=throttledTime,proto3" json:"throttled_time,omitempty"`
	Percent          float64 `protobuf:"fixed64,6,opt,name=percent,proto3" json:"percent,omitempty"`
	// MeasuredFields indicates which fields were actually sampled
	MeasuredFields       []CPUUsage_Fields `` /* 170-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*CPUUsage) Descriptor

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

func (*CPUUsage) GetMeasuredFields

func (m *CPUUsage) GetMeasuredFields() []CPUUsage_Fields

func (*CPUUsage) GetPercent

func (m *CPUUsage) GetPercent() float64

func (*CPUUsage) GetSystemMode

func (m *CPUUsage) GetSystemMode() float64

func (*CPUUsage) GetThrottledPeriods

func (m *CPUUsage) GetThrottledPeriods() uint64

func (*CPUUsage) GetThrottledTime

func (m *CPUUsage) GetThrottledTime() uint64

func (*CPUUsage) GetTotalTicks

func (m *CPUUsage) GetTotalTicks() float64

func (*CPUUsage) GetUserMode

func (m *CPUUsage) GetUserMode() float64

func (*CPUUsage) ProtoMessage

func (*CPUUsage) ProtoMessage()

func (*CPUUsage) Reset

func (m *CPUUsage) Reset()

func (*CPUUsage) String

func (m *CPUUsage) String() string

func (*CPUUsage) XXX_DiscardUnknown

func (m *CPUUsage) XXX_DiscardUnknown()

func (*CPUUsage) XXX_Marshal

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

func (*CPUUsage) XXX_Merge

func (dst *CPUUsage) XXX_Merge(src proto.Message)

func (*CPUUsage) XXX_Size

func (m *CPUUsage) XXX_Size() int

func (*CPUUsage) XXX_Unmarshal

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

type CPUUsage_Fields

type CPUUsage_Fields int32
const (
	CPUUsage_SYSTEM_MODE       CPUUsage_Fields = 0
	CPUUsage_USER_MODE         CPUUsage_Fields = 1
	CPUUsage_TOTAL_TICKS       CPUUsage_Fields = 2
	CPUUsage_THROTTLED_PERIODS CPUUsage_Fields = 3
	CPUUsage_THROTTLED_TIME    CPUUsage_Fields = 4
	CPUUsage_PERCENT           CPUUsage_Fields = 5
)

func (CPUUsage_Fields) EnumDescriptor

func (CPUUsage_Fields) EnumDescriptor() ([]byte, []int)

func (CPUUsage_Fields) String

func (x CPUUsage_Fields) String() string

type CapabilitiesRequest

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

func (*CapabilitiesRequest) Descriptor

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

func (*CapabilitiesRequest) ProtoMessage

func (*CapabilitiesRequest) ProtoMessage()

func (*CapabilitiesRequest) Reset

func (m *CapabilitiesRequest) Reset()

func (*CapabilitiesRequest) String

func (m *CapabilitiesRequest) String() string

func (*CapabilitiesRequest) XXX_DiscardUnknown

func (m *CapabilitiesRequest) XXX_DiscardUnknown()

func (*CapabilitiesRequest) XXX_Marshal

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

func (*CapabilitiesRequest) XXX_Merge

func (dst *CapabilitiesRequest) XXX_Merge(src proto.Message)

func (*CapabilitiesRequest) XXX_Size

func (m *CapabilitiesRequest) XXX_Size() int

func (*CapabilitiesRequest) XXX_Unmarshal

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

type CapabilitiesResponse

type CapabilitiesResponse struct {
	// Capabilities provides a way for the driver to denote if it implements
	// non-core RPCs. Some Driver service RPCs expose additional information
	// or functionality outside of the core task management functions. These
	// RPCs are only implemented if the driver sets the corresponding capability.
	Capabilities         *DriverCapabilities `protobuf:"bytes,1,opt,name=capabilities,proto3" json:"capabilities,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*CapabilitiesResponse) Descriptor

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

func (*CapabilitiesResponse) GetCapabilities

func (m *CapabilitiesResponse) GetCapabilities() *DriverCapabilities

func (*CapabilitiesResponse) ProtoMessage

func (*CapabilitiesResponse) ProtoMessage()

func (*CapabilitiesResponse) Reset

func (m *CapabilitiesResponse) Reset()

func (*CapabilitiesResponse) String

func (m *CapabilitiesResponse) String() string

func (*CapabilitiesResponse) XXX_DiscardUnknown

func (m *CapabilitiesResponse) XXX_DiscardUnknown()

func (*CapabilitiesResponse) XXX_Marshal

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

func (*CapabilitiesResponse) XXX_Merge

func (dst *CapabilitiesResponse) XXX_Merge(src proto.Message)

func (*CapabilitiesResponse) XXX_Size

func (m *CapabilitiesResponse) XXX_Size() int

func (*CapabilitiesResponse) XXX_Unmarshal

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

type DestroyTaskRequest

type DestroyTaskRequest struct {
	// TaskId is the ID of the target task
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Force destroys the task even if it is still in a running state
	Force                bool     `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DestroyTaskRequest) Descriptor

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

func (*DestroyTaskRequest) GetForce

func (m *DestroyTaskRequest) GetForce() bool

func (*DestroyTaskRequest) GetTaskId

func (m *DestroyTaskRequest) GetTaskId() string

func (*DestroyTaskRequest) ProtoMessage

func (*DestroyTaskRequest) ProtoMessage()

func (*DestroyTaskRequest) Reset

func (m *DestroyTaskRequest) Reset()

func (*DestroyTaskRequest) String

func (m *DestroyTaskRequest) String() string

func (*DestroyTaskRequest) XXX_DiscardUnknown

func (m *DestroyTaskRequest) XXX_DiscardUnknown()

func (*DestroyTaskRequest) XXX_Marshal

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

func (*DestroyTaskRequest) XXX_Merge

func (dst *DestroyTaskRequest) XXX_Merge(src proto.Message)

func (*DestroyTaskRequest) XXX_Size

func (m *DestroyTaskRequest) XXX_Size() int

func (*DestroyTaskRequest) XXX_Unmarshal

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

type DestroyTaskResponse

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

func (*DestroyTaskResponse) Descriptor

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

func (*DestroyTaskResponse) ProtoMessage

func (*DestroyTaskResponse) ProtoMessage()

func (*DestroyTaskResponse) Reset

func (m *DestroyTaskResponse) Reset()

func (*DestroyTaskResponse) String

func (m *DestroyTaskResponse) String() string

func (*DestroyTaskResponse) XXX_DiscardUnknown

func (m *DestroyTaskResponse) XXX_DiscardUnknown()

func (*DestroyTaskResponse) XXX_Marshal

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

func (*DestroyTaskResponse) XXX_Merge

func (dst *DestroyTaskResponse) XXX_Merge(src proto.Message)

func (*DestroyTaskResponse) XXX_Size

func (m *DestroyTaskResponse) XXX_Size() int

func (*DestroyTaskResponse) XXX_Unmarshal

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

type Device

type Device struct {
	// TaskPath is the file path within the task to mount the device to
	TaskPath string `protobuf:"bytes,1,opt,name=task_path,json=taskPath,proto3" json:"task_path,omitempty"`
	// HostPath is the path on the host to the source device
	HostPath string `protobuf:"bytes,2,opt,name=host_path,json=hostPath,proto3" json:"host_path,omitempty"`
	// CgroupPermissions defines the Cgroup permissions of the device.
	// One or more of the following options can be set:
	//  * r - allows the task to read from the specified device.
	//  * w - allows the task to write to the specified device.
	//  * m - allows the task to create device files that do not yet exist.
	//
	// Example: "rw"
	CgroupPermissions    string   `protobuf:"bytes,3,opt,name=cgroup_permissions,json=cgroupPermissions,proto3" json:"cgroup_permissions,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Device) Descriptor

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

func (*Device) GetCgroupPermissions

func (m *Device) GetCgroupPermissions() string

func (*Device) GetHostPath

func (m *Device) GetHostPath() string

func (*Device) GetTaskPath

func (m *Device) GetTaskPath() string

func (*Device) ProtoMessage

func (*Device) ProtoMessage()

func (*Device) Reset

func (m *Device) Reset()

func (*Device) String

func (m *Device) String() string

func (*Device) XXX_DiscardUnknown

func (m *Device) XXX_DiscardUnknown()

func (*Device) XXX_Marshal

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

func (*Device) XXX_Merge

func (dst *Device) XXX_Merge(src proto.Message)

func (*Device) XXX_Size

func (m *Device) XXX_Size() int

func (*Device) XXX_Unmarshal

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

type DriverCapabilities

type DriverCapabilities struct {
	// SendSignals indicates that the driver can send process signals (ex. SIGUSR1)
	// to the task.
	SendSignals bool `protobuf:"varint,1,opt,name=send_signals,json=sendSignals,proto3" json:"send_signals,omitempty"`
	// Exec indicates that the driver supports executing arbitrary commands
	// in the task's execution environment.
	Exec bool `protobuf:"varint,2,opt,name=exec,proto3" json:"exec,omitempty"`
	// FsIsolation indicates what kind of filesystem isolation a driver supports.
	FsIsolation          DriverCapabilities_FSIsolation `` /* 169-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

func (*DriverCapabilities) Descriptor

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

func (*DriverCapabilities) GetExec

func (m *DriverCapabilities) GetExec() bool

func (*DriverCapabilities) GetFsIsolation

func (*DriverCapabilities) GetSendSignals

func (m *DriverCapabilities) GetSendSignals() bool

func (*DriverCapabilities) ProtoMessage

func (*DriverCapabilities) ProtoMessage()

func (*DriverCapabilities) Reset

func (m *DriverCapabilities) Reset()

func (*DriverCapabilities) String

func (m *DriverCapabilities) String() string

func (*DriverCapabilities) XXX_DiscardUnknown

func (m *DriverCapabilities) XXX_DiscardUnknown()

func (*DriverCapabilities) XXX_Marshal

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

func (*DriverCapabilities) XXX_Merge

func (dst *DriverCapabilities) XXX_Merge(src proto.Message)

func (*DriverCapabilities) XXX_Size

func (m *DriverCapabilities) XXX_Size() int

func (*DriverCapabilities) XXX_Unmarshal

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

type DriverCapabilities_FSIsolation

type DriverCapabilities_FSIsolation int32
const (
	DriverCapabilities_NONE   DriverCapabilities_FSIsolation = 0
	DriverCapabilities_CHROOT DriverCapabilities_FSIsolation = 1
	DriverCapabilities_IMAGE  DriverCapabilities_FSIsolation = 2
)

func (DriverCapabilities_FSIsolation) EnumDescriptor

func (DriverCapabilities_FSIsolation) EnumDescriptor() ([]byte, []int)

func (DriverCapabilities_FSIsolation) String

type DriverClient

type DriverClient interface {
	// TaskConfigSchema returns the schema for parsing the driver
	// configuration of a task.
	TaskConfigSchema(ctx context.Context, in *TaskConfigSchemaRequest, opts ...grpc.CallOption) (*TaskConfigSchemaResponse, error)
	// Capabilities returns a set of features which the driver implements. Some
	// RPCs are not possible to implement on some runtimes, this allows the
	// driver to indicate if it doesn't support these RPCs and features.
	Capabilities(ctx context.Context, in *CapabilitiesRequest, opts ...grpc.CallOption) (*CapabilitiesResponse, error)
	// Fingerprint starts a stream which emits information about the driver
	// including whether the driver healthy and able to function in the
	// existing environment.
	//
	// The driver should immediately stream a FingerprintResponse when the RPC
	// is initially called, then send any additional responses if there is a
	// change in the driver's state.
	Fingerprint(ctx context.Context, in *FingerprintRequest, opts ...grpc.CallOption) (Driver_FingerprintClient, error)
	// RecoverTask is used when a task has been started but the driver may not
	// know about it. Such is the case if the driver restarts or is upgraded.
	RecoverTask(ctx context.Context, in *RecoverTaskRequest, opts ...grpc.CallOption) (*RecoverTaskResponse, error)
	// StartTask starts and tracks the task on the implemented runtime
	StartTask(ctx context.Context, in *StartTaskRequest, opts ...grpc.CallOption) (*StartTaskResponse, error)
	// WaitTask blocks until the given task exits, returning the result of the
	// task. It may be called after the task has exited, but before the task is
	// destroyed.
	WaitTask(ctx context.Context, in *WaitTaskRequest, opts ...grpc.CallOption) (*WaitTaskResponse, error)
	// StopTask stops a given task by sending the desired signal to the process.
	// If the task does not exit on its own within the given timeout, it will be
	// forcefully killed.
	StopTask(ctx context.Context, in *StopTaskRequest, opts ...grpc.CallOption) (*StopTaskResponse, error)
	// DestroyTask removes the task from the driver's internal state and cleans
	// up any additional resources created by the driver. It cannot be called
	// on a running task, unless force is set to true.
	DestroyTask(ctx context.Context, in *DestroyTaskRequest, opts ...grpc.CallOption) (*DestroyTaskResponse, error)
	// InspectTask returns detailed information for the given task
	InspectTask(ctx context.Context, in *InspectTaskRequest, opts ...grpc.CallOption) (*InspectTaskResponse, error)
	// TaskStats collects and returns runtime metrics for the given task
	TaskStats(ctx context.Context, in *TaskStatsRequest, opts ...grpc.CallOption) (Driver_TaskStatsClient, error)
	// TaskEvents starts a streaming RPC where all task events emitted by the
	// driver are streamed to the caller.
	TaskEvents(ctx context.Context, in *TaskEventsRequest, opts ...grpc.CallOption) (Driver_TaskEventsClient, error)
	// SignalTask sends a signal to the task
	SignalTask(ctx context.Context, in *SignalTaskRequest, opts ...grpc.CallOption) (*SignalTaskResponse, error)
	// ExecTask executes a command inside the tasks execution context
	ExecTask(ctx context.Context, in *ExecTaskRequest, opts ...grpc.CallOption) (*ExecTaskResponse, error)
	// ExecTaskStreaming executes a command inside the tasks execution context
	// and streams back results
	ExecTaskStreaming(ctx context.Context, opts ...grpc.CallOption) (Driver_ExecTaskStreamingClient, error)
}

DriverClient is the client API for Driver service.

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

func NewDriverClient

func NewDriverClient(cc *grpc.ClientConn) DriverClient

type DriverServer

type DriverServer interface {
	// TaskConfigSchema returns the schema for parsing the driver
	// configuration of a task.
	TaskConfigSchema(context.Context, *TaskConfigSchemaRequest) (*TaskConfigSchemaResponse, error)
	// Capabilities returns a set of features which the driver implements. Some
	// RPCs are not possible to implement on some runtimes, this allows the
	// driver to indicate if it doesn't support these RPCs and features.
	Capabilities(context.Context, *CapabilitiesRequest) (*CapabilitiesResponse, error)
	// Fingerprint starts a stream which emits information about the driver
	// including whether the driver healthy and able to function in the
	// existing environment.
	//
	// The driver should immediately stream a FingerprintResponse when the RPC
	// is initially called, then send any additional responses if there is a
	// change in the driver's state.
	Fingerprint(*FingerprintRequest, Driver_FingerprintServer) error
	// RecoverTask is used when a task has been started but the driver may not
	// know about it. Such is the case if the driver restarts or is upgraded.
	RecoverTask(context.Context, *RecoverTaskRequest) (*RecoverTaskResponse, error)
	// StartTask starts and tracks the task on the implemented runtime
	StartTask(context.Context, *StartTaskRequest) (*StartTaskResponse, error)
	// WaitTask blocks until the given task exits, returning the result of the
	// task. It may be called after the task has exited, but before the task is
	// destroyed.
	WaitTask(context.Context, *WaitTaskRequest) (*WaitTaskResponse, error)
	// StopTask stops a given task by sending the desired signal to the process.
	// If the task does not exit on its own within the given timeout, it will be
	// forcefully killed.
	StopTask(context.Context, *StopTaskRequest) (*StopTaskResponse, error)
	// DestroyTask removes the task from the driver's internal state and cleans
	// up any additional resources created by the driver. It cannot be called
	// on a running task, unless force is set to true.
	DestroyTask(context.Context, *DestroyTaskRequest) (*DestroyTaskResponse, error)
	// InspectTask returns detailed information for the given task
	InspectTask(context.Context, *InspectTaskRequest) (*InspectTaskResponse, error)
	// TaskStats collects and returns runtime metrics for the given task
	TaskStats(*TaskStatsRequest, Driver_TaskStatsServer) error
	// TaskEvents starts a streaming RPC where all task events emitted by the
	// driver are streamed to the caller.
	TaskEvents(*TaskEventsRequest, Driver_TaskEventsServer) error
	// SignalTask sends a signal to the task
	SignalTask(context.Context, *SignalTaskRequest) (*SignalTaskResponse, error)
	// ExecTask executes a command inside the tasks execution context
	ExecTask(context.Context, *ExecTaskRequest) (*ExecTaskResponse, error)
	// ExecTaskStreaming executes a command inside the tasks execution context
	// and streams back results
	ExecTaskStreaming(Driver_ExecTaskStreamingServer) error
}

DriverServer is the server API for Driver service.

type DriverTaskEvent

type DriverTaskEvent struct {
	// TaskId is the id of the task for the event
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// AllocId of the task for the event
	AllocId string `protobuf:"bytes,2,opt,name=alloc_id,json=allocId,proto3" json:"alloc_id,omitempty"`
	// TaskName is the name of the task for the event
	TaskName string `protobuf:"bytes,3,opt,name=task_name,json=taskName,proto3" json:"task_name,omitempty"`
	// Timestamp when the event occurred
	Timestamp *timestamp.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Message is the body of the event
	Message string `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"`
	// Annotations allows for additional key/value data to be sent along with the event
	Annotations          map[string]string `` /* 163-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*DriverTaskEvent) Descriptor

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

func (*DriverTaskEvent) GetAllocId

func (m *DriverTaskEvent) GetAllocId() string

func (*DriverTaskEvent) GetAnnotations

func (m *DriverTaskEvent) GetAnnotations() map[string]string

func (*DriverTaskEvent) GetMessage

func (m *DriverTaskEvent) GetMessage() string

func (*DriverTaskEvent) GetTaskId

func (m *DriverTaskEvent) GetTaskId() string

func (*DriverTaskEvent) GetTaskName

func (m *DriverTaskEvent) GetTaskName() string

func (*DriverTaskEvent) GetTimestamp

func (m *DriverTaskEvent) GetTimestamp() *timestamp.Timestamp

func (*DriverTaskEvent) ProtoMessage

func (*DriverTaskEvent) ProtoMessage()

func (*DriverTaskEvent) Reset

func (m *DriverTaskEvent) Reset()

func (*DriverTaskEvent) String

func (m *DriverTaskEvent) String() string

func (*DriverTaskEvent) XXX_DiscardUnknown

func (m *DriverTaskEvent) XXX_DiscardUnknown()

func (*DriverTaskEvent) XXX_Marshal

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

func (*DriverTaskEvent) XXX_Merge

func (dst *DriverTaskEvent) XXX_Merge(src proto.Message)

func (*DriverTaskEvent) XXX_Size

func (m *DriverTaskEvent) XXX_Size() int

func (*DriverTaskEvent) XXX_Unmarshal

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

type Driver_ExecTaskStreamingClient added in v0.9.2

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

type Driver_ExecTaskStreamingServer added in v0.9.2

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

type Driver_FingerprintClient

type Driver_FingerprintClient interface {
	Recv() (*FingerprintResponse, error)
	grpc.ClientStream
}

type Driver_FingerprintServer

type Driver_FingerprintServer interface {
	Send(*FingerprintResponse) error
	grpc.ServerStream
}

type Driver_TaskEventsClient

type Driver_TaskEventsClient interface {
	Recv() (*DriverTaskEvent, error)
	grpc.ClientStream
}

type Driver_TaskEventsServer

type Driver_TaskEventsServer interface {
	Send(*DriverTaskEvent) error
	grpc.ServerStream
}

type Driver_TaskStatsClient

type Driver_TaskStatsClient interface {
	Recv() (*TaskStatsResponse, error)
	grpc.ClientStream
}

type Driver_TaskStatsServer

type Driver_TaskStatsServer interface {
	Send(*TaskStatsResponse) error
	grpc.ServerStream
}

type ExecTaskRequest

type ExecTaskRequest struct {
	// TaskId is the ID of the target task
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Command is the command to execute in the task environment
	Command []string `protobuf:"bytes,2,rep,name=command,proto3" json:"command,omitempty"`
	// Timeout is the amount of time to wait for the command to stop.
	// Defaults to 0 (run forever)
	Timeout              *duration.Duration `protobuf:"bytes,3,opt,name=timeout,proto3" json:"timeout,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*ExecTaskRequest) Descriptor

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

func (*ExecTaskRequest) GetCommand

func (m *ExecTaskRequest) GetCommand() []string

func (*ExecTaskRequest) GetTaskId

func (m *ExecTaskRequest) GetTaskId() string

func (*ExecTaskRequest) GetTimeout

func (m *ExecTaskRequest) GetTimeout() *duration.Duration

func (*ExecTaskRequest) ProtoMessage

func (*ExecTaskRequest) ProtoMessage()

func (*ExecTaskRequest) Reset

func (m *ExecTaskRequest) Reset()

func (*ExecTaskRequest) String

func (m *ExecTaskRequest) String() string

func (*ExecTaskRequest) XXX_DiscardUnknown

func (m *ExecTaskRequest) XXX_DiscardUnknown()

func (*ExecTaskRequest) XXX_Marshal

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

func (*ExecTaskRequest) XXX_Merge

func (dst *ExecTaskRequest) XXX_Merge(src proto.Message)

func (*ExecTaskRequest) XXX_Size

func (m *ExecTaskRequest) XXX_Size() int

func (*ExecTaskRequest) XXX_Unmarshal

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

type ExecTaskResponse

type ExecTaskResponse struct {
	// Stdout from the exec
	Stdout []byte `protobuf:"bytes,1,opt,name=stdout,proto3" json:"stdout,omitempty"`
	// Stderr from the exec
	Stderr []byte `protobuf:"bytes,2,opt,name=stderr,proto3" json:"stderr,omitempty"`
	// Result from the exec
	Result               *ExitResult `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*ExecTaskResponse) Descriptor

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

func (*ExecTaskResponse) GetResult

func (m *ExecTaskResponse) GetResult() *ExitResult

func (*ExecTaskResponse) GetStderr

func (m *ExecTaskResponse) GetStderr() []byte

func (*ExecTaskResponse) GetStdout

func (m *ExecTaskResponse) GetStdout() []byte

func (*ExecTaskResponse) ProtoMessage

func (*ExecTaskResponse) ProtoMessage()

func (*ExecTaskResponse) Reset

func (m *ExecTaskResponse) Reset()

func (*ExecTaskResponse) String

func (m *ExecTaskResponse) String() string

func (*ExecTaskResponse) XXX_DiscardUnknown

func (m *ExecTaskResponse) XXX_DiscardUnknown()

func (*ExecTaskResponse) XXX_Marshal

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

func (*ExecTaskResponse) XXX_Merge

func (dst *ExecTaskResponse) XXX_Merge(src proto.Message)

func (*ExecTaskResponse) XXX_Size

func (m *ExecTaskResponse) XXX_Size() int

func (*ExecTaskResponse) XXX_Unmarshal

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

type ExecTaskStreamingIOOperation added in v0.9.2

type ExecTaskStreamingIOOperation struct {
	Data                 []byte   `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Close                bool     `protobuf:"varint,2,opt,name=close,proto3" json:"close,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ExecTaskStreamingIOOperation) Descriptor added in v0.9.2

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

func (*ExecTaskStreamingIOOperation) GetClose added in v0.9.2

func (m *ExecTaskStreamingIOOperation) GetClose() bool

func (*ExecTaskStreamingIOOperation) GetData added in v0.9.2

func (m *ExecTaskStreamingIOOperation) GetData() []byte

func (*ExecTaskStreamingIOOperation) ProtoMessage added in v0.9.2

func (*ExecTaskStreamingIOOperation) ProtoMessage()

func (*ExecTaskStreamingIOOperation) Reset added in v0.9.2

func (m *ExecTaskStreamingIOOperation) Reset()

func (*ExecTaskStreamingIOOperation) String added in v0.9.2

func (*ExecTaskStreamingIOOperation) XXX_DiscardUnknown added in v0.9.2

func (m *ExecTaskStreamingIOOperation) XXX_DiscardUnknown()

func (*ExecTaskStreamingIOOperation) XXX_Marshal added in v0.9.2

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

func (*ExecTaskStreamingIOOperation) XXX_Merge added in v0.9.2

func (dst *ExecTaskStreamingIOOperation) XXX_Merge(src proto.Message)

func (*ExecTaskStreamingIOOperation) XXX_Size added in v0.9.2

func (m *ExecTaskStreamingIOOperation) XXX_Size() int

func (*ExecTaskStreamingIOOperation) XXX_Unmarshal added in v0.9.2

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

type ExecTaskStreamingRequest added in v0.9.2

type ExecTaskStreamingRequest struct {
	Setup                *ExecTaskStreamingRequest_Setup        `protobuf:"bytes,1,opt,name=setup,proto3" json:"setup,omitempty"`
	TtySize              *ExecTaskStreamingRequest_TerminalSize `protobuf:"bytes,2,opt,name=tty_size,json=ttySize,proto3" json:"tty_size,omitempty"`
	Stdin                *ExecTaskStreamingIOOperation          `protobuf:"bytes,3,opt,name=stdin,proto3" json:"stdin,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                               `json:"-"`
	XXX_unrecognized     []byte                                 `json:"-"`
	XXX_sizecache        int32                                  `json:"-"`
}

func (*ExecTaskStreamingRequest) Descriptor added in v0.9.2

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

func (*ExecTaskStreamingRequest) GetSetup added in v0.9.2

func (*ExecTaskStreamingRequest) GetStdin added in v0.9.2

func (*ExecTaskStreamingRequest) GetTtySize added in v0.9.2

func (*ExecTaskStreamingRequest) ProtoMessage added in v0.9.2

func (*ExecTaskStreamingRequest) ProtoMessage()

func (*ExecTaskStreamingRequest) Reset added in v0.9.2

func (m *ExecTaskStreamingRequest) Reset()

func (*ExecTaskStreamingRequest) String added in v0.9.2

func (m *ExecTaskStreamingRequest) String() string

func (*ExecTaskStreamingRequest) XXX_DiscardUnknown added in v0.9.2

func (m *ExecTaskStreamingRequest) XXX_DiscardUnknown()

func (*ExecTaskStreamingRequest) XXX_Marshal added in v0.9.2

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

func (*ExecTaskStreamingRequest) XXX_Merge added in v0.9.2

func (dst *ExecTaskStreamingRequest) XXX_Merge(src proto.Message)

func (*ExecTaskStreamingRequest) XXX_Size added in v0.9.2

func (m *ExecTaskStreamingRequest) XXX_Size() int

func (*ExecTaskStreamingRequest) XXX_Unmarshal added in v0.9.2

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

type ExecTaskStreamingRequest_Setup added in v0.9.2

type ExecTaskStreamingRequest_Setup struct {
	TaskId               string   `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Command              []string `protobuf:"bytes,2,rep,name=command,proto3" json:"command,omitempty"`
	Tty                  bool     `protobuf:"varint,3,opt,name=tty,proto3" json:"tty,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ExecTaskStreamingRequest_Setup) Descriptor added in v0.9.2

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

func (*ExecTaskStreamingRequest_Setup) GetCommand added in v0.9.2

func (m *ExecTaskStreamingRequest_Setup) GetCommand() []string

func (*ExecTaskStreamingRequest_Setup) GetTaskId added in v0.9.2

func (m *ExecTaskStreamingRequest_Setup) GetTaskId() string

func (*ExecTaskStreamingRequest_Setup) GetTty added in v0.9.2

func (*ExecTaskStreamingRequest_Setup) ProtoMessage added in v0.9.2

func (*ExecTaskStreamingRequest_Setup) ProtoMessage()

func (*ExecTaskStreamingRequest_Setup) Reset added in v0.9.2

func (m *ExecTaskStreamingRequest_Setup) Reset()

func (*ExecTaskStreamingRequest_Setup) String added in v0.9.2

func (*ExecTaskStreamingRequest_Setup) XXX_DiscardUnknown added in v0.9.2

func (m *ExecTaskStreamingRequest_Setup) XXX_DiscardUnknown()

func (*ExecTaskStreamingRequest_Setup) XXX_Marshal added in v0.9.2

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

func (*ExecTaskStreamingRequest_Setup) XXX_Merge added in v0.9.2

func (dst *ExecTaskStreamingRequest_Setup) XXX_Merge(src proto.Message)

func (*ExecTaskStreamingRequest_Setup) XXX_Size added in v0.9.2

func (m *ExecTaskStreamingRequest_Setup) XXX_Size() int

func (*ExecTaskStreamingRequest_Setup) XXX_Unmarshal added in v0.9.2

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

type ExecTaskStreamingRequest_TerminalSize added in v0.9.2

type ExecTaskStreamingRequest_TerminalSize struct {
	Height               int32    `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"`
	Width                int32    `protobuf:"varint,2,opt,name=width,proto3" json:"width,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ExecTaskStreamingRequest_TerminalSize) Descriptor added in v0.9.2

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

func (*ExecTaskStreamingRequest_TerminalSize) GetHeight added in v0.9.2

func (*ExecTaskStreamingRequest_TerminalSize) GetWidth added in v0.9.2

func (*ExecTaskStreamingRequest_TerminalSize) ProtoMessage added in v0.9.2

func (*ExecTaskStreamingRequest_TerminalSize) ProtoMessage()

func (*ExecTaskStreamingRequest_TerminalSize) Reset added in v0.9.2

func (*ExecTaskStreamingRequest_TerminalSize) String added in v0.9.2

func (*ExecTaskStreamingRequest_TerminalSize) XXX_DiscardUnknown added in v0.9.2

func (m *ExecTaskStreamingRequest_TerminalSize) XXX_DiscardUnknown()

func (*ExecTaskStreamingRequest_TerminalSize) XXX_Marshal added in v0.9.2

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

func (*ExecTaskStreamingRequest_TerminalSize) XXX_Merge added in v0.9.2

func (*ExecTaskStreamingRequest_TerminalSize) XXX_Size added in v0.9.2

func (*ExecTaskStreamingRequest_TerminalSize) XXX_Unmarshal added in v0.9.2

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

type ExecTaskStreamingResponse added in v0.9.2

type ExecTaskStreamingResponse struct {
	Stdout               *ExecTaskStreamingIOOperation `protobuf:"bytes,1,opt,name=stdout,proto3" json:"stdout,omitempty"`
	Stderr               *ExecTaskStreamingIOOperation `protobuf:"bytes,2,opt,name=stderr,proto3" json:"stderr,omitempty"`
	Exited               bool                          `protobuf:"varint,3,opt,name=exited,proto3" json:"exited,omitempty"`
	Result               *ExitResult                   `protobuf:"bytes,4,opt,name=result,proto3" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

func (*ExecTaskStreamingResponse) Descriptor added in v0.9.2

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

func (*ExecTaskStreamingResponse) GetExited added in v0.9.2

func (m *ExecTaskStreamingResponse) GetExited() bool

func (*ExecTaskStreamingResponse) GetResult added in v0.9.2

func (m *ExecTaskStreamingResponse) GetResult() *ExitResult

func (*ExecTaskStreamingResponse) GetStderr added in v0.9.2

func (*ExecTaskStreamingResponse) GetStdout added in v0.9.2

func (*ExecTaskStreamingResponse) ProtoMessage added in v0.9.2

func (*ExecTaskStreamingResponse) ProtoMessage()

func (*ExecTaskStreamingResponse) Reset added in v0.9.2

func (m *ExecTaskStreamingResponse) Reset()

func (*ExecTaskStreamingResponse) String added in v0.9.2

func (m *ExecTaskStreamingResponse) String() string

func (*ExecTaskStreamingResponse) XXX_DiscardUnknown added in v0.9.2

func (m *ExecTaskStreamingResponse) XXX_DiscardUnknown()

func (*ExecTaskStreamingResponse) XXX_Marshal added in v0.9.2

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

func (*ExecTaskStreamingResponse) XXX_Merge added in v0.9.2

func (dst *ExecTaskStreamingResponse) XXX_Merge(src proto.Message)

func (*ExecTaskStreamingResponse) XXX_Size added in v0.9.2

func (m *ExecTaskStreamingResponse) XXX_Size() int

func (*ExecTaskStreamingResponse) XXX_Unmarshal added in v0.9.2

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

type ExitResult

type ExitResult struct {
	// ExitCode returned from the task on exit
	ExitCode int32 `protobuf:"varint,1,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	// Signal is set if a signal was sent to the task
	Signal int32 `protobuf:"varint,2,opt,name=signal,proto3" json:"signal,omitempty"`
	// OomKilled is true if the task exited as a result of the OOM Killer
	OomKilled            bool     `protobuf:"varint,3,opt,name=oom_killed,json=oomKilled,proto3" json:"oom_killed,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ExitResult contains information about the exit status of a task

func (*ExitResult) Descriptor

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

func (*ExitResult) GetExitCode

func (m *ExitResult) GetExitCode() int32

func (*ExitResult) GetOomKilled

func (m *ExitResult) GetOomKilled() bool

func (*ExitResult) GetSignal

func (m *ExitResult) GetSignal() int32

func (*ExitResult) ProtoMessage

func (*ExitResult) ProtoMessage()

func (*ExitResult) Reset

func (m *ExitResult) Reset()

func (*ExitResult) String

func (m *ExitResult) String() string

func (*ExitResult) XXX_DiscardUnknown

func (m *ExitResult) XXX_DiscardUnknown()

func (*ExitResult) XXX_Marshal

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

func (*ExitResult) XXX_Merge

func (dst *ExitResult) XXX_Merge(src proto.Message)

func (*ExitResult) XXX_Size

func (m *ExitResult) XXX_Size() int

func (*ExitResult) XXX_Unmarshal

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

type FingerprintRequest

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

func (*FingerprintRequest) Descriptor

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

func (*FingerprintRequest) ProtoMessage

func (*FingerprintRequest) ProtoMessage()

func (*FingerprintRequest) Reset

func (m *FingerprintRequest) Reset()

func (*FingerprintRequest) String

func (m *FingerprintRequest) String() string

func (*FingerprintRequest) XXX_DiscardUnknown

func (m *FingerprintRequest) XXX_DiscardUnknown()

func (*FingerprintRequest) XXX_Marshal

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

func (*FingerprintRequest) XXX_Merge

func (dst *FingerprintRequest) XXX_Merge(src proto.Message)

func (*FingerprintRequest) XXX_Size

func (m *FingerprintRequest) XXX_Size() int

func (*FingerprintRequest) XXX_Unmarshal

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

type FingerprintResponse

type FingerprintResponse struct {
	// Attributes are key/value pairs that annotate the nomad client and can be
	// used in scheduling contraints and affinities.
	Attributes map[string]*proto1.Attribute `` /* 161-byte string literal not displayed */
	// Health is used to determine the state of the health the driver is in.
	// Health can be one of the following states:
	//  * UNDETECTED: driver dependencies are not met and the driver can not start
	//  * UNHEALTHY: driver dependencies are met but the driver is unable to
	//      perform operations due to some other problem
	//  * HEALTHY: driver is able to perform all operations
	Health FingerprintResponse_HealthState `` /* 141-byte string literal not displayed */
	// HealthDescription is a human readable message describing the current
	// state of driver health
	HealthDescription    string   `protobuf:"bytes,3,opt,name=health_description,json=healthDescription,proto3" json:"health_description,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FingerprintResponse) Descriptor

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

func (*FingerprintResponse) GetAttributes

func (m *FingerprintResponse) GetAttributes() map[string]*proto1.Attribute

func (*FingerprintResponse) GetHealth

func (*FingerprintResponse) GetHealthDescription

func (m *FingerprintResponse) GetHealthDescription() string

func (*FingerprintResponse) ProtoMessage

func (*FingerprintResponse) ProtoMessage()

func (*FingerprintResponse) Reset

func (m *FingerprintResponse) Reset()

func (*FingerprintResponse) String

func (m *FingerprintResponse) String() string

func (*FingerprintResponse) XXX_DiscardUnknown

func (m *FingerprintResponse) XXX_DiscardUnknown()

func (*FingerprintResponse) XXX_Marshal

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

func (*FingerprintResponse) XXX_Merge

func (dst *FingerprintResponse) XXX_Merge(src proto.Message)

func (*FingerprintResponse) XXX_Size

func (m *FingerprintResponse) XXX_Size() int

func (*FingerprintResponse) XXX_Unmarshal

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

type FingerprintResponse_HealthState

type FingerprintResponse_HealthState int32
const (
	FingerprintResponse_UNDETECTED FingerprintResponse_HealthState = 0
	FingerprintResponse_UNHEALTHY  FingerprintResponse_HealthState = 1
	FingerprintResponse_HEALTHY    FingerprintResponse_HealthState = 2
)

func (FingerprintResponse_HealthState) EnumDescriptor

func (FingerprintResponse_HealthState) EnumDescriptor() ([]byte, []int)

func (FingerprintResponse_HealthState) String

type InspectTaskRequest

type InspectTaskRequest struct {
	// TaskId is the ID of the target task
	TaskId               string   `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*InspectTaskRequest) Descriptor

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

func (*InspectTaskRequest) GetTaskId

func (m *InspectTaskRequest) GetTaskId() string

func (*InspectTaskRequest) ProtoMessage

func (*InspectTaskRequest) ProtoMessage()

func (*InspectTaskRequest) Reset

func (m *InspectTaskRequest) Reset()

func (*InspectTaskRequest) String

func (m *InspectTaskRequest) String() string

func (*InspectTaskRequest) XXX_DiscardUnknown

func (m *InspectTaskRequest) XXX_DiscardUnknown()

func (*InspectTaskRequest) XXX_Marshal

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

func (*InspectTaskRequest) XXX_Merge

func (dst *InspectTaskRequest) XXX_Merge(src proto.Message)

func (*InspectTaskRequest) XXX_Size

func (m *InspectTaskRequest) XXX_Size() int

func (*InspectTaskRequest) XXX_Unmarshal

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

type InspectTaskResponse

type InspectTaskResponse struct {
	// Task details
	Task *TaskStatus `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	// Driver details for task
	Driver *TaskDriverStatus `protobuf:"bytes,2,opt,name=driver,proto3" json:"driver,omitempty"`
	// NetworkOverride info if set
	NetworkOverride      *NetworkOverride `protobuf:"bytes,3,opt,name=network_override,json=networkOverride,proto3" json:"network_override,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*InspectTaskResponse) Descriptor

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

func (*InspectTaskResponse) GetDriver

func (m *InspectTaskResponse) GetDriver() *TaskDriverStatus

func (*InspectTaskResponse) GetNetworkOverride

func (m *InspectTaskResponse) GetNetworkOverride() *NetworkOverride

func (*InspectTaskResponse) GetTask

func (m *InspectTaskResponse) GetTask() *TaskStatus

func (*InspectTaskResponse) ProtoMessage

func (*InspectTaskResponse) ProtoMessage()

func (*InspectTaskResponse) Reset

func (m *InspectTaskResponse) Reset()

func (*InspectTaskResponse) String

func (m *InspectTaskResponse) String() string

func (*InspectTaskResponse) XXX_DiscardUnknown

func (m *InspectTaskResponse) XXX_DiscardUnknown()

func (*InspectTaskResponse) XXX_Marshal

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

func (*InspectTaskResponse) XXX_Merge

func (dst *InspectTaskResponse) XXX_Merge(src proto.Message)

func (*InspectTaskResponse) XXX_Size

func (m *InspectTaskResponse) XXX_Size() int

func (*InspectTaskResponse) XXX_Unmarshal

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

type LinuxResources

type LinuxResources struct {
	// CPU CFS (Completely Fair Scheduler) period. Default: 0 (not specified)
	CpuPeriod int64 `protobuf:"varint,1,opt,name=cpu_period,json=cpuPeriod,proto3" json:"cpu_period,omitempty"`
	// CPU CFS (Completely Fair Scheduler) quota. Default: 0 (not specified)
	CpuQuota int64 `protobuf:"varint,2,opt,name=cpu_quota,json=cpuQuota,proto3" json:"cpu_quota,omitempty"`
	// CPU shares (relative weight vs. other containers). Default: 0 (not specified)
	CpuShares int64 `protobuf:"varint,3,opt,name=cpu_shares,json=cpuShares,proto3" json:"cpu_shares,omitempty"`
	// Memory limit in bytes. Default: 0 (not specified)
	MemoryLimitBytes int64 `protobuf:"varint,4,opt,name=memory_limit_bytes,json=memoryLimitBytes,proto3" json:"memory_limit_bytes,omitempty"`
	// OOMScoreAdj adjusts the oom-killer score. Default: 0 (not specified)
	OomScoreAdj int64 `protobuf:"varint,5,opt,name=oom_score_adj,json=oomScoreAdj,proto3" json:"oom_score_adj,omitempty"`
	// CpusetCpus constrains the allowed set of logical CPUs. Default: "" (not specified)
	CpusetCpus string `protobuf:"bytes,6,opt,name=cpuset_cpus,json=cpusetCpus,proto3" json:"cpuset_cpus,omitempty"`
	// CpusetMems constrains the allowed set of memory nodes. Default: "" (not specified)
	CpusetMems string `protobuf:"bytes,7,opt,name=cpuset_mems,json=cpusetMems,proto3" json:"cpuset_mems,omitempty"`
	// PercentTicks is a compatibility option for docker and should not be used
	PercentTicks         float64  `protobuf:"fixed64,8,opt,name=PercentTicks,proto3" json:"PercentTicks,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LinuxResources) Descriptor

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

func (*LinuxResources) GetCpuPeriod

func (m *LinuxResources) GetCpuPeriod() int64

func (*LinuxResources) GetCpuQuota

func (m *LinuxResources) GetCpuQuota() int64

func (*LinuxResources) GetCpuShares

func (m *LinuxResources) GetCpuShares() int64

func (*LinuxResources) GetCpusetCpus

func (m *LinuxResources) GetCpusetCpus() string

func (*LinuxResources) GetCpusetMems

func (m *LinuxResources) GetCpusetMems() string

func (*LinuxResources) GetMemoryLimitBytes

func (m *LinuxResources) GetMemoryLimitBytes() int64

func (*LinuxResources) GetOomScoreAdj

func (m *LinuxResources) GetOomScoreAdj() int64

func (*LinuxResources) GetPercentTicks

func (m *LinuxResources) GetPercentTicks() float64

func (*LinuxResources) ProtoMessage

func (*LinuxResources) ProtoMessage()

func (*LinuxResources) Reset

func (m *LinuxResources) Reset()

func (*LinuxResources) String

func (m *LinuxResources) String() string

func (*LinuxResources) XXX_DiscardUnknown

func (m *LinuxResources) XXX_DiscardUnknown()

func (*LinuxResources) XXX_Marshal

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

func (*LinuxResources) XXX_Merge

func (dst *LinuxResources) XXX_Merge(src proto.Message)

func (*LinuxResources) XXX_Size

func (m *LinuxResources) XXX_Size() int

func (*LinuxResources) XXX_Unmarshal

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

type MemoryUsage

type MemoryUsage struct {
	Rss            uint64 `protobuf:"varint,1,opt,name=rss,proto3" json:"rss,omitempty"`
	Cache          uint64 `protobuf:"varint,2,opt,name=cache,proto3" json:"cache,omitempty"`
	MaxUsage       uint64 `protobuf:"varint,3,opt,name=max_usage,json=maxUsage,proto3" json:"max_usage,omitempty"`
	KernelUsage    uint64 `protobuf:"varint,4,opt,name=kernel_usage,json=kernelUsage,proto3" json:"kernel_usage,omitempty"`
	KernelMaxUsage uint64 `protobuf:"varint,5,opt,name=kernel_max_usage,json=kernelMaxUsage,proto3" json:"kernel_max_usage,omitempty"`
	Usage          uint64 `protobuf:"varint,7,opt,name=usage,proto3" json:"usage,omitempty"`
	Swap           uint64 `protobuf:"varint,8,opt,name=swap,proto3" json:"swap,omitempty"`
	// MeasuredFields indicates which fields were actually sampled
	MeasuredFields       []MemoryUsage_Fields `` /* 173-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*MemoryUsage) Descriptor

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

func (*MemoryUsage) GetCache

func (m *MemoryUsage) GetCache() uint64

func (*MemoryUsage) GetKernelMaxUsage

func (m *MemoryUsage) GetKernelMaxUsage() uint64

func (*MemoryUsage) GetKernelUsage

func (m *MemoryUsage) GetKernelUsage() uint64

func (*MemoryUsage) GetMaxUsage

func (m *MemoryUsage) GetMaxUsage() uint64

func (*MemoryUsage) GetMeasuredFields

func (m *MemoryUsage) GetMeasuredFields() []MemoryUsage_Fields

func (*MemoryUsage) GetRss

func (m *MemoryUsage) GetRss() uint64

func (*MemoryUsage) GetSwap

func (m *MemoryUsage) GetSwap() uint64

func (*MemoryUsage) GetUsage

func (m *MemoryUsage) GetUsage() uint64

func (*MemoryUsage) ProtoMessage

func (*MemoryUsage) ProtoMessage()

func (*MemoryUsage) Reset

func (m *MemoryUsage) Reset()

func (*MemoryUsage) String

func (m *MemoryUsage) String() string

func (*MemoryUsage) XXX_DiscardUnknown

func (m *MemoryUsage) XXX_DiscardUnknown()

func (*MemoryUsage) XXX_Marshal

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

func (*MemoryUsage) XXX_Merge

func (dst *MemoryUsage) XXX_Merge(src proto.Message)

func (*MemoryUsage) XXX_Size

func (m *MemoryUsage) XXX_Size() int

func (*MemoryUsage) XXX_Unmarshal

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

type MemoryUsage_Fields

type MemoryUsage_Fields int32
const (
	MemoryUsage_RSS              MemoryUsage_Fields = 0
	MemoryUsage_CACHE            MemoryUsage_Fields = 1
	MemoryUsage_MAX_USAGE        MemoryUsage_Fields = 2
	MemoryUsage_KERNEL_USAGE     MemoryUsage_Fields = 3
	MemoryUsage_KERNEL_MAX_USAGE MemoryUsage_Fields = 4
	MemoryUsage_USAGE            MemoryUsage_Fields = 5
	MemoryUsage_SWAP             MemoryUsage_Fields = 6
)

func (MemoryUsage_Fields) EnumDescriptor

func (MemoryUsage_Fields) EnumDescriptor() ([]byte, []int)

func (MemoryUsage_Fields) String

func (x MemoryUsage_Fields) String() string

type Mount

type Mount struct {
	// TaskPath is the file path within the task directory to mount to
	TaskPath string `protobuf:"bytes,1,opt,name=task_path,json=taskPath,proto3" json:"task_path,omitempty"`
	// HostPath is the file path on the host to mount from
	HostPath string `protobuf:"bytes,2,opt,name=host_path,json=hostPath,proto3" json:"host_path,omitempty"`
	// Readonly if set true, mounts the path in readonly mode
	Readonly             bool     `protobuf:"varint,3,opt,name=readonly,proto3" json:"readonly,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Mount) Descriptor

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

func (*Mount) GetHostPath

func (m *Mount) GetHostPath() string

func (*Mount) GetReadonly

func (m *Mount) GetReadonly() bool

func (*Mount) GetTaskPath

func (m *Mount) GetTaskPath() string

func (*Mount) ProtoMessage

func (*Mount) ProtoMessage()

func (*Mount) Reset

func (m *Mount) Reset()

func (*Mount) String

func (m *Mount) String() string

func (*Mount) XXX_DiscardUnknown

func (m *Mount) XXX_DiscardUnknown()

func (*Mount) XXX_Marshal

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

func (*Mount) XXX_Merge

func (dst *Mount) XXX_Merge(src proto.Message)

func (*Mount) XXX_Size

func (m *Mount) XXX_Size() int

func (*Mount) XXX_Unmarshal

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

type NetworkOverride

type NetworkOverride struct {
	// PortMap can be set to replace ports with driver-specific mappings
	PortMap map[string]int32 `` /* 171-byte string literal not displayed */
	// Addr is the IP address for the task created by the driver
	Addr string `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	// AutoAdvertise indicates whether the driver thinks services that choose
	// to auto_advertise_addresses should use this IP instead of the host's.
	AutoAdvertise        bool     `protobuf:"varint,3,opt,name=auto_advertise,json=autoAdvertise,proto3" json:"auto_advertise,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

NetworkOverride contains network settings which the driver may override for the task, such as when the driver is setting up the task's network.

func (*NetworkOverride) Descriptor

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

func (*NetworkOverride) GetAddr

func (m *NetworkOverride) GetAddr() string

func (*NetworkOverride) GetAutoAdvertise

func (m *NetworkOverride) GetAutoAdvertise() bool

func (*NetworkOverride) GetPortMap

func (m *NetworkOverride) GetPortMap() map[string]int32

func (*NetworkOverride) ProtoMessage

func (*NetworkOverride) ProtoMessage()

func (*NetworkOverride) Reset

func (m *NetworkOverride) Reset()

func (*NetworkOverride) String

func (m *NetworkOverride) String() string

func (*NetworkOverride) XXX_DiscardUnknown

func (m *NetworkOverride) XXX_DiscardUnknown()

func (*NetworkOverride) XXX_Marshal

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

func (*NetworkOverride) XXX_Merge

func (dst *NetworkOverride) XXX_Merge(src proto.Message)

func (*NetworkOverride) XXX_Size

func (m *NetworkOverride) XXX_Size() int

func (*NetworkOverride) XXX_Unmarshal

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

type NetworkPort

type NetworkPort struct {
	Label                string   `protobuf:"bytes,1,opt,name=label,proto3" json:"label,omitempty"`
	Value                int32    `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NetworkPort) Descriptor

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

func (*NetworkPort) GetLabel

func (m *NetworkPort) GetLabel() string

func (*NetworkPort) GetValue

func (m *NetworkPort) GetValue() int32

func (*NetworkPort) ProtoMessage

func (*NetworkPort) ProtoMessage()

func (*NetworkPort) Reset

func (m *NetworkPort) Reset()

func (*NetworkPort) String

func (m *NetworkPort) String() string

func (*NetworkPort) XXX_DiscardUnknown

func (m *NetworkPort) XXX_DiscardUnknown()

func (*NetworkPort) XXX_Marshal

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

func (*NetworkPort) XXX_Merge

func (dst *NetworkPort) XXX_Merge(src proto.Message)

func (*NetworkPort) XXX_Size

func (m *NetworkPort) XXX_Size() int

func (*NetworkPort) XXX_Unmarshal

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

type NetworkResource

type NetworkResource struct {
	Device               string         `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	Cidr                 string         `protobuf:"bytes,2,opt,name=cidr,proto3" json:"cidr,omitempty"`
	Ip                   string         `protobuf:"bytes,3,opt,name=ip,proto3" json:"ip,omitempty"`
	Mbits                int32          `protobuf:"varint,4,opt,name=mbits,proto3" json:"mbits,omitempty"`
	ReservedPorts        []*NetworkPort `protobuf:"bytes,5,rep,name=reserved_ports,json=reservedPorts,proto3" json:"reserved_ports,omitempty"`
	DynamicPorts         []*NetworkPort `protobuf:"bytes,6,rep,name=dynamic_ports,json=dynamicPorts,proto3" json:"dynamic_ports,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*NetworkResource) Descriptor

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

func (*NetworkResource) GetCidr

func (m *NetworkResource) GetCidr() string

func (*NetworkResource) GetDevice

func (m *NetworkResource) GetDevice() string

func (*NetworkResource) GetDynamicPorts

func (m *NetworkResource) GetDynamicPorts() []*NetworkPort

func (*NetworkResource) GetIp

func (m *NetworkResource) GetIp() string

func (*NetworkResource) GetMbits

func (m *NetworkResource) GetMbits() int32

func (*NetworkResource) GetReservedPorts

func (m *NetworkResource) GetReservedPorts() []*NetworkPort

func (*NetworkResource) ProtoMessage

func (*NetworkResource) ProtoMessage()

func (*NetworkResource) Reset

func (m *NetworkResource) Reset()

func (*NetworkResource) String

func (m *NetworkResource) String() string

func (*NetworkResource) XXX_DiscardUnknown

func (m *NetworkResource) XXX_DiscardUnknown()

func (*NetworkResource) XXX_Marshal

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

func (*NetworkResource) XXX_Merge

func (dst *NetworkResource) XXX_Merge(src proto.Message)

func (*NetworkResource) XXX_Size

func (m *NetworkResource) XXX_Size() int

func (*NetworkResource) XXX_Unmarshal

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

type RecoverTaskRequest

type RecoverTaskRequest struct {
	// TaskId is the ID of the target task
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Handle is the TaskHandle returned from StartTask
	Handle               *TaskHandle `protobuf:"bytes,2,opt,name=handle,proto3" json:"handle,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*RecoverTaskRequest) Descriptor

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

func (*RecoverTaskRequest) GetHandle

func (m *RecoverTaskRequest) GetHandle() *TaskHandle

func (*RecoverTaskRequest) GetTaskId

func (m *RecoverTaskRequest) GetTaskId() string

func (*RecoverTaskRequest) ProtoMessage

func (*RecoverTaskRequest) ProtoMessage()

func (*RecoverTaskRequest) Reset

func (m *RecoverTaskRequest) Reset()

func (*RecoverTaskRequest) String

func (m *RecoverTaskRequest) String() string

func (*RecoverTaskRequest) XXX_DiscardUnknown

func (m *RecoverTaskRequest) XXX_DiscardUnknown()

func (*RecoverTaskRequest) XXX_Marshal

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

func (*RecoverTaskRequest) XXX_Merge

func (dst *RecoverTaskRequest) XXX_Merge(src proto.Message)

func (*RecoverTaskRequest) XXX_Size

func (m *RecoverTaskRequest) XXX_Size() int

func (*RecoverTaskRequest) XXX_Unmarshal

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

type RecoverTaskResponse

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

func (*RecoverTaskResponse) Descriptor

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

func (*RecoverTaskResponse) ProtoMessage

func (*RecoverTaskResponse) ProtoMessage()

func (*RecoverTaskResponse) Reset

func (m *RecoverTaskResponse) Reset()

func (*RecoverTaskResponse) String

func (m *RecoverTaskResponse) String() string

func (*RecoverTaskResponse) XXX_DiscardUnknown

func (m *RecoverTaskResponse) XXX_DiscardUnknown()

func (*RecoverTaskResponse) XXX_Marshal

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

func (*RecoverTaskResponse) XXX_Merge

func (dst *RecoverTaskResponse) XXX_Merge(src proto.Message)

func (*RecoverTaskResponse) XXX_Size

func (m *RecoverTaskResponse) XXX_Size() int

func (*RecoverTaskResponse) XXX_Unmarshal

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

type Resources

type Resources struct {
	// AllocatedResources are the resources set for the task
	AllocatedResources *AllocatedTaskResources `protobuf:"bytes,1,opt,name=allocated_resources,json=allocatedResources,proto3" json:"allocated_resources,omitempty"`
	// LinuxResources are the computed values to set for specific Linux features
	LinuxResources       *LinuxResources `protobuf:"bytes,2,opt,name=linux_resources,json=linuxResources,proto3" json:"linux_resources,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*Resources) Descriptor

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

func (*Resources) GetAllocatedResources

func (m *Resources) GetAllocatedResources() *AllocatedTaskResources

func (*Resources) GetLinuxResources

func (m *Resources) GetLinuxResources() *LinuxResources

func (*Resources) ProtoMessage

func (*Resources) ProtoMessage()

func (*Resources) Reset

func (m *Resources) Reset()

func (*Resources) String

func (m *Resources) String() string

func (*Resources) XXX_DiscardUnknown

func (m *Resources) XXX_DiscardUnknown()

func (*Resources) XXX_Marshal

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

func (*Resources) XXX_Merge

func (dst *Resources) XXX_Merge(src proto.Message)

func (*Resources) XXX_Size

func (m *Resources) XXX_Size() int

func (*Resources) XXX_Unmarshal

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

type SignalTaskRequest

type SignalTaskRequest struct {
	// TaskId is the ID of the target task
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Signal is the operating system signal to send to the task. Ex: SIGHUP
	Signal               string   `protobuf:"bytes,2,opt,name=signal,proto3" json:"signal,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SignalTaskRequest) Descriptor

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

func (*SignalTaskRequest) GetSignal

func (m *SignalTaskRequest) GetSignal() string

func (*SignalTaskRequest) GetTaskId

func (m *SignalTaskRequest) GetTaskId() string

func (*SignalTaskRequest) ProtoMessage

func (*SignalTaskRequest) ProtoMessage()

func (*SignalTaskRequest) Reset

func (m *SignalTaskRequest) Reset()

func (*SignalTaskRequest) String

func (m *SignalTaskRequest) String() string

func (*SignalTaskRequest) XXX_DiscardUnknown

func (m *SignalTaskRequest) XXX_DiscardUnknown()

func (*SignalTaskRequest) XXX_Marshal

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

func (*SignalTaskRequest) XXX_Merge

func (dst *SignalTaskRequest) XXX_Merge(src proto.Message)

func (*SignalTaskRequest) XXX_Size

func (m *SignalTaskRequest) XXX_Size() int

func (*SignalTaskRequest) XXX_Unmarshal

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

type SignalTaskResponse

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

func (*SignalTaskResponse) Descriptor

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

func (*SignalTaskResponse) ProtoMessage

func (*SignalTaskResponse) ProtoMessage()

func (*SignalTaskResponse) Reset

func (m *SignalTaskResponse) Reset()

func (*SignalTaskResponse) String

func (m *SignalTaskResponse) String() string

func (*SignalTaskResponse) XXX_DiscardUnknown

func (m *SignalTaskResponse) XXX_DiscardUnknown()

func (*SignalTaskResponse) XXX_Marshal

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

func (*SignalTaskResponse) XXX_Merge

func (dst *SignalTaskResponse) XXX_Merge(src proto.Message)

func (*SignalTaskResponse) XXX_Size

func (m *SignalTaskResponse) XXX_Size() int

func (*SignalTaskResponse) XXX_Unmarshal

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

type StartTaskRequest

type StartTaskRequest struct {
	// Task configuration to launch
	Task                 *TaskConfig `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*StartTaskRequest) Descriptor

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

func (*StartTaskRequest) GetTask

func (m *StartTaskRequest) GetTask() *TaskConfig

func (*StartTaskRequest) ProtoMessage

func (*StartTaskRequest) ProtoMessage()

func (*StartTaskRequest) Reset

func (m *StartTaskRequest) Reset()

func (*StartTaskRequest) String

func (m *StartTaskRequest) String() string

func (*StartTaskRequest) XXX_DiscardUnknown

func (m *StartTaskRequest) XXX_DiscardUnknown()

func (*StartTaskRequest) XXX_Marshal

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

func (*StartTaskRequest) XXX_Merge

func (dst *StartTaskRequest) XXX_Merge(src proto.Message)

func (*StartTaskRequest) XXX_Size

func (m *StartTaskRequest) XXX_Size() int

func (*StartTaskRequest) XXX_Unmarshal

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

type StartTaskResponse

type StartTaskResponse struct {
	// Result is set depending on the type of error that occurred while starting
	// a task:
	//
	//   * SUCCESS: No error occurred, handle is set
	//   * RETRY: An error occurred, but is recoverable and the RPC should be retried
	//   * FATAL: A fatal error occurred and is not likely to succeed if retried
	//
	// If Result is not successful, the DriverErrorMsg will be set.
	Result StartTaskResponse_Result `` /* 134-byte string literal not displayed */
	// DriverErrorMsg is set if an error occurred
	DriverErrorMsg string `protobuf:"bytes,2,opt,name=driver_error_msg,json=driverErrorMsg,proto3" json:"driver_error_msg,omitempty"`
	// Handle is opaque to the client, but must be stored in order to recover
	// the task.
	Handle *TaskHandle `protobuf:"bytes,3,opt,name=handle,proto3" json:"handle,omitempty"`
	// NetworkOverride is set if the driver sets network settings and the service ip/port
	// needs to be set differently.
	NetworkOverride      *NetworkOverride `protobuf:"bytes,4,opt,name=network_override,json=networkOverride,proto3" json:"network_override,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*StartTaskResponse) Descriptor

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

func (*StartTaskResponse) GetDriverErrorMsg

func (m *StartTaskResponse) GetDriverErrorMsg() string

func (*StartTaskResponse) GetHandle

func (m *StartTaskResponse) GetHandle() *TaskHandle

func (*StartTaskResponse) GetNetworkOverride

func (m *StartTaskResponse) GetNetworkOverride() *NetworkOverride

func (*StartTaskResponse) GetResult

func (*StartTaskResponse) ProtoMessage

func (*StartTaskResponse) ProtoMessage()

func (*StartTaskResponse) Reset

func (m *StartTaskResponse) Reset()

func (*StartTaskResponse) String

func (m *StartTaskResponse) String() string

func (*StartTaskResponse) XXX_DiscardUnknown

func (m *StartTaskResponse) XXX_DiscardUnknown()

func (*StartTaskResponse) XXX_Marshal

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

func (*StartTaskResponse) XXX_Merge

func (dst *StartTaskResponse) XXX_Merge(src proto.Message)

func (*StartTaskResponse) XXX_Size

func (m *StartTaskResponse) XXX_Size() int

func (*StartTaskResponse) XXX_Unmarshal

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

type StartTaskResponse_Result

type StartTaskResponse_Result int32
const (
	StartTaskResponse_SUCCESS StartTaskResponse_Result = 0
	StartTaskResponse_RETRY   StartTaskResponse_Result = 1
	StartTaskResponse_FATAL   StartTaskResponse_Result = 2
)

func (StartTaskResponse_Result) EnumDescriptor

func (StartTaskResponse_Result) EnumDescriptor() ([]byte, []int)

func (StartTaskResponse_Result) String

func (x StartTaskResponse_Result) String() string

type StopTaskRequest

type StopTaskRequest struct {
	// TaskId is the ID of the target task
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Timeout defines the amount of time to wait before forcefully killing
	// the task. For example, on Unix clients, this means sending a SIGKILL to
	// the process.
	Timeout *duration.Duration `protobuf:"bytes,2,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// Signal can be set to override the Task's configured shutdown signal
	Signal               string   `protobuf:"bytes,3,opt,name=signal,proto3" json:"signal,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StopTaskRequest) Descriptor

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

func (*StopTaskRequest) GetSignal

func (m *StopTaskRequest) GetSignal() string

func (*StopTaskRequest) GetTaskId

func (m *StopTaskRequest) GetTaskId() string

func (*StopTaskRequest) GetTimeout

func (m *StopTaskRequest) GetTimeout() *duration.Duration

func (*StopTaskRequest) ProtoMessage

func (*StopTaskRequest) ProtoMessage()

func (*StopTaskRequest) Reset

func (m *StopTaskRequest) Reset()

func (*StopTaskRequest) String

func (m *StopTaskRequest) String() string

func (*StopTaskRequest) XXX_DiscardUnknown

func (m *StopTaskRequest) XXX_DiscardUnknown()

func (*StopTaskRequest) XXX_Marshal

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

func (*StopTaskRequest) XXX_Merge

func (dst *StopTaskRequest) XXX_Merge(src proto.Message)

func (*StopTaskRequest) XXX_Size

func (m *StopTaskRequest) XXX_Size() int

func (*StopTaskRequest) XXX_Unmarshal

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

type StopTaskResponse

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

func (*StopTaskResponse) Descriptor

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

func (*StopTaskResponse) ProtoMessage

func (*StopTaskResponse) ProtoMessage()

func (*StopTaskResponse) Reset

func (m *StopTaskResponse) Reset()

func (*StopTaskResponse) String

func (m *StopTaskResponse) String() string

func (*StopTaskResponse) XXX_DiscardUnknown

func (m *StopTaskResponse) XXX_DiscardUnknown()

func (*StopTaskResponse) XXX_Marshal

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

func (*StopTaskResponse) XXX_Merge

func (dst *StopTaskResponse) XXX_Merge(src proto.Message)

func (*StopTaskResponse) XXX_Size

func (m *StopTaskResponse) XXX_Size() int

func (*StopTaskResponse) XXX_Unmarshal

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

type TaskConfig

type TaskConfig struct {
	// Id of the task, recommended to the globally unique, must be unique to the driver.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Name of the task
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// MsgpackDriverConfig is the encoded driver configuation of the task
	MsgpackDriverConfig []byte `protobuf:"bytes,3,opt,name=msgpack_driver_config,json=msgpackDriverConfig,proto3" json:"msgpack_driver_config,omitempty"`
	// Env is the a set of key/value pairs to be set as environment variables
	Env map[string]string `` /* 147-byte string literal not displayed */
	// DeviceEnv is the set of environment variables that are defined by device
	// plugins. This allows the driver to differentiate environment variables
	// set by the device plugins and those by the user. When populating the
	// task's environment env should be used.
	DeviceEnv map[string]string `` /* 176-byte string literal not displayed */
	// Resources defines the resources to isolate
	Resources *Resources `protobuf:"bytes,6,opt,name=resources,proto3" json:"resources,omitempty"`
	// Mounts is a list of targets to bind mount into the task directory
	Mounts []*Mount `protobuf:"bytes,7,rep,name=mounts,proto3" json:"mounts,omitempty"`
	// Devices is a list of system devices to mount into the task's execution
	// environment.
	Devices []*Device `protobuf:"bytes,8,rep,name=devices,proto3" json:"devices,omitempty"`
	// User defines the operating system user the tasks should run as
	User string `protobuf:"bytes,9,opt,name=user,proto3" json:"user,omitempty"`
	// AllocDir is the directory on the host where the allocation directory
	// exists.
	AllocDir string `protobuf:"bytes,10,opt,name=alloc_dir,json=allocDir,proto3" json:"alloc_dir,omitempty"`
	// StdoutPath is the path to the file to open and write task stdout to
	StdoutPath string `protobuf:"bytes,11,opt,name=stdout_path,json=stdoutPath,proto3" json:"stdout_path,omitempty"`
	// StderrPath is the path to the file to open and write task stderr to
	StderrPath string `protobuf:"bytes,12,opt,name=stderr_path,json=stderrPath,proto3" json:"stderr_path,omitempty"`
	// TaskGroupName is the name of the task group which this task is a member of
	TaskGroupName string `protobuf:"bytes,13,opt,name=task_group_name,json=taskGroupName,proto3" json:"task_group_name,omitempty"`
	// JobName is the name of the job of which this task is part of
	JobName string `protobuf:"bytes,14,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	// AllocId is the ID of the associated allocation
	AllocId              string   `protobuf:"bytes,15,opt,name=alloc_id,json=allocId,proto3" json:"alloc_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TaskConfig) Descriptor

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

func (*TaskConfig) GetAllocDir

func (m *TaskConfig) GetAllocDir() string

func (*TaskConfig) GetAllocId

func (m *TaskConfig) GetAllocId() string

func (*TaskConfig) GetDeviceEnv

func (m *TaskConfig) GetDeviceEnv() map[string]string

func (*TaskConfig) GetDevices

func (m *TaskConfig) GetDevices() []*Device

func (*TaskConfig) GetEnv

func (m *TaskConfig) GetEnv() map[string]string

func (*TaskConfig) GetId

func (m *TaskConfig) GetId() string

func (*TaskConfig) GetJobName

func (m *TaskConfig) GetJobName() string

func (*TaskConfig) GetMounts

func (m *TaskConfig) GetMounts() []*Mount

func (*TaskConfig) GetMsgpackDriverConfig

func (m *TaskConfig) GetMsgpackDriverConfig() []byte

func (*TaskConfig) GetName

func (m *TaskConfig) GetName() string

func (*TaskConfig) GetResources

func (m *TaskConfig) GetResources() *Resources

func (*TaskConfig) GetStderrPath

func (m *TaskConfig) GetStderrPath() string

func (*TaskConfig) GetStdoutPath

func (m *TaskConfig) GetStdoutPath() string

func (*TaskConfig) GetTaskGroupName

func (m *TaskConfig) GetTaskGroupName() string

func (*TaskConfig) GetUser

func (m *TaskConfig) GetUser() string

func (*TaskConfig) ProtoMessage

func (*TaskConfig) ProtoMessage()

func (*TaskConfig) Reset

func (m *TaskConfig) Reset()

func (*TaskConfig) String

func (m *TaskConfig) String() string

func (*TaskConfig) XXX_DiscardUnknown

func (m *TaskConfig) XXX_DiscardUnknown()

func (*TaskConfig) XXX_Marshal

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

func (*TaskConfig) XXX_Merge

func (dst *TaskConfig) XXX_Merge(src proto.Message)

func (*TaskConfig) XXX_Size

func (m *TaskConfig) XXX_Size() int

func (*TaskConfig) XXX_Unmarshal

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

type TaskConfigSchemaRequest

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

func (*TaskConfigSchemaRequest) Descriptor

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

func (*TaskConfigSchemaRequest) ProtoMessage

func (*TaskConfigSchemaRequest) ProtoMessage()

func (*TaskConfigSchemaRequest) Reset

func (m *TaskConfigSchemaRequest) Reset()

func (*TaskConfigSchemaRequest) String

func (m *TaskConfigSchemaRequest) String() string

func (*TaskConfigSchemaRequest) XXX_DiscardUnknown

func (m *TaskConfigSchemaRequest) XXX_DiscardUnknown()

func (*TaskConfigSchemaRequest) XXX_Marshal

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

func (*TaskConfigSchemaRequest) XXX_Merge

func (dst *TaskConfigSchemaRequest) XXX_Merge(src proto.Message)

func (*TaskConfigSchemaRequest) XXX_Size

func (m *TaskConfigSchemaRequest) XXX_Size() int

func (*TaskConfigSchemaRequest) XXX_Unmarshal

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

type TaskConfigSchemaResponse

type TaskConfigSchemaResponse struct {
	// Spec is the configuration schema for the job driver config stanza
	Spec                 *hclspec.Spec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*TaskConfigSchemaResponse) Descriptor

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

func (*TaskConfigSchemaResponse) GetSpec

func (m *TaskConfigSchemaResponse) GetSpec() *hclspec.Spec

func (*TaskConfigSchemaResponse) ProtoMessage

func (*TaskConfigSchemaResponse) ProtoMessage()

func (*TaskConfigSchemaResponse) Reset

func (m *TaskConfigSchemaResponse) Reset()

func (*TaskConfigSchemaResponse) String

func (m *TaskConfigSchemaResponse) String() string

func (*TaskConfigSchemaResponse) XXX_DiscardUnknown

func (m *TaskConfigSchemaResponse) XXX_DiscardUnknown()

func (*TaskConfigSchemaResponse) XXX_Marshal

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

func (*TaskConfigSchemaResponse) XXX_Merge

func (dst *TaskConfigSchemaResponse) XXX_Merge(src proto.Message)

func (*TaskConfigSchemaResponse) XXX_Size

func (m *TaskConfigSchemaResponse) XXX_Size() int

func (*TaskConfigSchemaResponse) XXX_Unmarshal

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

type TaskDriverStatus

type TaskDriverStatus struct {
	// Attributes is a set of string/string key value pairs specific to the
	// implementing driver
	Attributes           map[string]string `` /* 161-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*TaskDriverStatus) Descriptor

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

func (*TaskDriverStatus) GetAttributes

func (m *TaskDriverStatus) GetAttributes() map[string]string

func (*TaskDriverStatus) ProtoMessage

func (*TaskDriverStatus) ProtoMessage()

func (*TaskDriverStatus) Reset

func (m *TaskDriverStatus) Reset()

func (*TaskDriverStatus) String

func (m *TaskDriverStatus) String() string

func (*TaskDriverStatus) XXX_DiscardUnknown

func (m *TaskDriverStatus) XXX_DiscardUnknown()

func (*TaskDriverStatus) XXX_Marshal

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

func (*TaskDriverStatus) XXX_Merge

func (dst *TaskDriverStatus) XXX_Merge(src proto.Message)

func (*TaskDriverStatus) XXX_Size

func (m *TaskDriverStatus) XXX_Size() int

func (*TaskDriverStatus) XXX_Unmarshal

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

type TaskEventsRequest

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

func (*TaskEventsRequest) Descriptor

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

func (*TaskEventsRequest) ProtoMessage

func (*TaskEventsRequest) ProtoMessage()

func (*TaskEventsRequest) Reset

func (m *TaskEventsRequest) Reset()

func (*TaskEventsRequest) String

func (m *TaskEventsRequest) String() string

func (*TaskEventsRequest) XXX_DiscardUnknown

func (m *TaskEventsRequest) XXX_DiscardUnknown()

func (*TaskEventsRequest) XXX_Marshal

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

func (*TaskEventsRequest) XXX_Merge

func (dst *TaskEventsRequest) XXX_Merge(src proto.Message)

func (*TaskEventsRequest) XXX_Size

func (m *TaskEventsRequest) XXX_Size() int

func (*TaskEventsRequest) XXX_Unmarshal

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

type TaskHandle

type TaskHandle struct {
	// Version is used by the driver to version the DriverState schema.
	// Version 0 is reserved by Nomad and should not be used.
	Version int32 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	// Config is the TaskConfig for the task
	Config *TaskConfig `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	// State is the state of the task's execution
	State TaskState `protobuf:"varint,3,opt,name=state,proto3,enum=hashicorp.nomad.plugins.drivers.proto.TaskState" json:"state,omitempty"`
	// DriverState is the encoded state for the specific driver
	DriverState          []byte   `protobuf:"bytes,4,opt,name=driver_state,json=driverState,proto3" json:"driver_state,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TaskHandle is created when starting a task and is used to recover task

func (*TaskHandle) Descriptor

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

func (*TaskHandle) GetConfig

func (m *TaskHandle) GetConfig() *TaskConfig

func (*TaskHandle) GetDriverState

func (m *TaskHandle) GetDriverState() []byte

func (*TaskHandle) GetState

func (m *TaskHandle) GetState() TaskState

func (*TaskHandle) GetVersion

func (m *TaskHandle) GetVersion() int32

func (*TaskHandle) ProtoMessage

func (*TaskHandle) ProtoMessage()

func (*TaskHandle) Reset

func (m *TaskHandle) Reset()

func (*TaskHandle) String

func (m *TaskHandle) String() string

func (*TaskHandle) XXX_DiscardUnknown

func (m *TaskHandle) XXX_DiscardUnknown()

func (*TaskHandle) XXX_Marshal

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

func (*TaskHandle) XXX_Merge

func (dst *TaskHandle) XXX_Merge(src proto.Message)

func (*TaskHandle) XXX_Size

func (m *TaskHandle) XXX_Size() int

func (*TaskHandle) XXX_Unmarshal

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

type TaskResourceUsage

type TaskResourceUsage struct {
	// CPU usage stats
	Cpu *CPUUsage `protobuf:"bytes,1,opt,name=cpu,proto3" json:"cpu,omitempty"`
	// Memory usage stats
	Memory               *MemoryUsage `protobuf:"bytes,2,opt,name=memory,proto3" json:"memory,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*TaskResourceUsage) Descriptor

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

func (*TaskResourceUsage) GetCpu

func (m *TaskResourceUsage) GetCpu() *CPUUsage

func (*TaskResourceUsage) GetMemory

func (m *TaskResourceUsage) GetMemory() *MemoryUsage

func (*TaskResourceUsage) ProtoMessage

func (*TaskResourceUsage) ProtoMessage()

func (*TaskResourceUsage) Reset

func (m *TaskResourceUsage) Reset()

func (*TaskResourceUsage) String

func (m *TaskResourceUsage) String() string

func (*TaskResourceUsage) XXX_DiscardUnknown

func (m *TaskResourceUsage) XXX_DiscardUnknown()

func (*TaskResourceUsage) XXX_Marshal

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

func (*TaskResourceUsage) XXX_Merge

func (dst *TaskResourceUsage) XXX_Merge(src proto.Message)

func (*TaskResourceUsage) XXX_Size

func (m *TaskResourceUsage) XXX_Size() int

func (*TaskResourceUsage) XXX_Unmarshal

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

type TaskState

type TaskState int32
const (
	TaskState_UNKNOWN TaskState = 0
	TaskState_RUNNING TaskState = 1
	TaskState_EXITED  TaskState = 2
)

func (TaskState) EnumDescriptor

func (TaskState) EnumDescriptor() ([]byte, []int)

func (TaskState) String

func (x TaskState) String() string

type TaskStats

type TaskStats struct {
	// Id of the task
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Timestamp for which the stats were collected
	Timestamp *timestamp.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// AggResourceUsage is the aggreate usage of all processes
	AggResourceUsage *TaskResourceUsage `protobuf:"bytes,3,opt,name=agg_resource_usage,json=aggResourceUsage,proto3" json:"agg_resource_usage,omitempty"`
	// ResourceUsageByPid breaks the usage stats by process
	ResourceUsageByPid   map[string]*TaskResourceUsage `` /* 207-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

func (*TaskStats) Descriptor

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

func (*TaskStats) GetAggResourceUsage

func (m *TaskStats) GetAggResourceUsage() *TaskResourceUsage

func (*TaskStats) GetId

func (m *TaskStats) GetId() string

func (*TaskStats) GetResourceUsageByPid

func (m *TaskStats) GetResourceUsageByPid() map[string]*TaskResourceUsage

func (*TaskStats) GetTimestamp

func (m *TaskStats) GetTimestamp() *timestamp.Timestamp

func (*TaskStats) ProtoMessage

func (*TaskStats) ProtoMessage()

func (*TaskStats) Reset

func (m *TaskStats) Reset()

func (*TaskStats) String

func (m *TaskStats) String() string

func (*TaskStats) XXX_DiscardUnknown

func (m *TaskStats) XXX_DiscardUnknown()

func (*TaskStats) XXX_Marshal

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

func (*TaskStats) XXX_Merge

func (dst *TaskStats) XXX_Merge(src proto.Message)

func (*TaskStats) XXX_Size

func (m *TaskStats) XXX_Size() int

func (*TaskStats) XXX_Unmarshal

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

type TaskStatsRequest

type TaskStatsRequest struct {
	// TaskId is the ID of the target task
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// CollectionInterval is the interval at which to stream stats to the caller
	CollectionInterval   *duration.Duration `protobuf:"bytes,2,opt,name=collection_interval,json=collectionInterval,proto3" json:"collection_interval,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*TaskStatsRequest) Descriptor

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

func (*TaskStatsRequest) GetCollectionInterval

func (m *TaskStatsRequest) GetCollectionInterval() *duration.Duration

func (*TaskStatsRequest) GetTaskId

func (m *TaskStatsRequest) GetTaskId() string

func (*TaskStatsRequest) ProtoMessage

func (*TaskStatsRequest) ProtoMessage()

func (*TaskStatsRequest) Reset

func (m *TaskStatsRequest) Reset()

func (*TaskStatsRequest) String

func (m *TaskStatsRequest) String() string

func (*TaskStatsRequest) XXX_DiscardUnknown

func (m *TaskStatsRequest) XXX_DiscardUnknown()

func (*TaskStatsRequest) XXX_Marshal

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

func (*TaskStatsRequest) XXX_Merge

func (dst *TaskStatsRequest) XXX_Merge(src proto.Message)

func (*TaskStatsRequest) XXX_Size

func (m *TaskStatsRequest) XXX_Size() int

func (*TaskStatsRequest) XXX_Unmarshal

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

type TaskStatsResponse

type TaskStatsResponse struct {
	// Stats for the task
	Stats                *TaskStats `protobuf:"bytes,1,opt,name=stats,proto3" json:"stats,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*TaskStatsResponse) Descriptor

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

func (*TaskStatsResponse) GetStats

func (m *TaskStatsResponse) GetStats() *TaskStats

func (*TaskStatsResponse) ProtoMessage

func (*TaskStatsResponse) ProtoMessage()

func (*TaskStatsResponse) Reset

func (m *TaskStatsResponse) Reset()

func (*TaskStatsResponse) String

func (m *TaskStatsResponse) String() string

func (*TaskStatsResponse) XXX_DiscardUnknown

func (m *TaskStatsResponse) XXX_DiscardUnknown()

func (*TaskStatsResponse) XXX_Marshal

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

func (*TaskStatsResponse) XXX_Merge

func (dst *TaskStatsResponse) XXX_Merge(src proto.Message)

func (*TaskStatsResponse) XXX_Size

func (m *TaskStatsResponse) XXX_Size() int

func (*TaskStatsResponse) XXX_Unmarshal

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

type TaskStatus

type TaskStatus struct {
	Id   string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// State is the state of the task's execution
	State TaskState `protobuf:"varint,3,opt,name=state,proto3,enum=hashicorp.nomad.plugins.drivers.proto.TaskState" json:"state,omitempty"`
	// StartedAt is the timestamp when the task was started
	StartedAt *timestamp.Timestamp `protobuf:"bytes,4,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	// CompletedAt is the timestamp when the task exited.
	// If the task is still running, CompletedAt will not be set
	CompletedAt *timestamp.Timestamp `protobuf:"bytes,5,opt,name=completed_at,json=completedAt,proto3" json:"completed_at,omitempty"`
	// Result is set when CompletedAt is set.
	Result               *ExitResult `protobuf:"bytes,6,opt,name=result,proto3" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

TaskStatus includes information of a specific task

func (*TaskStatus) Descriptor

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

func (*TaskStatus) GetCompletedAt

func (m *TaskStatus) GetCompletedAt() *timestamp.Timestamp

func (*TaskStatus) GetId

func (m *TaskStatus) GetId() string

func (*TaskStatus) GetName

func (m *TaskStatus) GetName() string

func (*TaskStatus) GetResult

func (m *TaskStatus) GetResult() *ExitResult

func (*TaskStatus) GetStartedAt

func (m *TaskStatus) GetStartedAt() *timestamp.Timestamp

func (*TaskStatus) GetState

func (m *TaskStatus) GetState() TaskState

func (*TaskStatus) ProtoMessage

func (*TaskStatus) ProtoMessage()

func (*TaskStatus) Reset

func (m *TaskStatus) Reset()

func (*TaskStatus) String

func (m *TaskStatus) String() string

func (*TaskStatus) XXX_DiscardUnknown

func (m *TaskStatus) XXX_DiscardUnknown()

func (*TaskStatus) XXX_Marshal

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

func (*TaskStatus) XXX_Merge

func (dst *TaskStatus) XXX_Merge(src proto.Message)

func (*TaskStatus) XXX_Size

func (m *TaskStatus) XXX_Size() int

func (*TaskStatus) XXX_Unmarshal

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

type WaitTaskRequest

type WaitTaskRequest struct {
	// TaskId is the ID of the target task
	TaskId               string   `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WaitTaskRequest) Descriptor

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

func (*WaitTaskRequest) GetTaskId

func (m *WaitTaskRequest) GetTaskId() string

func (*WaitTaskRequest) ProtoMessage

func (*WaitTaskRequest) ProtoMessage()

func (*WaitTaskRequest) Reset

func (m *WaitTaskRequest) Reset()

func (*WaitTaskRequest) String

func (m *WaitTaskRequest) String() string

func (*WaitTaskRequest) XXX_DiscardUnknown

func (m *WaitTaskRequest) XXX_DiscardUnknown()

func (*WaitTaskRequest) XXX_Marshal

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

func (*WaitTaskRequest) XXX_Merge

func (dst *WaitTaskRequest) XXX_Merge(src proto.Message)

func (*WaitTaskRequest) XXX_Size

func (m *WaitTaskRequest) XXX_Size() int

func (*WaitTaskRequest) XXX_Unmarshal

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

type WaitTaskResponse

type WaitTaskResponse struct {
	// Result is the exit status of the task
	Result *ExitResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// Err is set if any driver error occurred while waiting for the task
	Err                  string   `protobuf:"bytes,2,opt,name=err,proto3" json:"err,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WaitTaskResponse) Descriptor

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

func (*WaitTaskResponse) GetErr

func (m *WaitTaskResponse) GetErr() string

func (*WaitTaskResponse) GetResult

func (m *WaitTaskResponse) GetResult() *ExitResult

func (*WaitTaskResponse) ProtoMessage

func (*WaitTaskResponse) ProtoMessage()

func (*WaitTaskResponse) Reset

func (m *WaitTaskResponse) Reset()

func (*WaitTaskResponse) String

func (m *WaitTaskResponse) String() string

func (*WaitTaskResponse) XXX_DiscardUnknown

func (m *WaitTaskResponse) XXX_DiscardUnknown()

func (*WaitTaskResponse) XXX_Marshal

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

func (*WaitTaskResponse) XXX_Merge

func (dst *WaitTaskResponse) XXX_Merge(src proto.Message)

func (*WaitTaskResponse) XXX_Size

func (m *WaitTaskResponse) XXX_Size() int

func (*WaitTaskResponse) XXX_Unmarshal

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

Jump to

Keyboard shortcuts

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