proto

package
v0.9.3 Latest Latest
Warning

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

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

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 (m *AllocatedTaskResources) GetCpu() *AllocatedCpuResources

func (*AllocatedTaskResources) GetMemory 

func (m *AllocatedTaskResources) GetMemory() *AllocatedMemoryResources

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 (m *DriverCapabilities) GetFsIsolation() DriverCapabilities_FSIsolation

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 

func (x DriverCapabilities_FSIsolation) String() 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 (m *ExecTaskStreamingIOOperation) String() string

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 (m *ExecTaskStreamingRequest) GetSetup() *ExecTaskStreamingRequest_Setup

func (*ExecTaskStreamingRequest) GetStdin added in v0.9.2 

func (m *ExecTaskStreamingRequest) GetStdin() *ExecTaskStreamingIOOperation

func (*ExecTaskStreamingRequest) GetTtySize added in v0.9.2 

func (m *ExecTaskStreamingRequest) GetTtySize() *ExecTaskStreamingRequest_TerminalSize

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 (m *ExecTaskStreamingRequest_Setup) GetTty() bool

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 (m *ExecTaskStreamingRequest_Setup) String() string

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 (m *ExecTaskStreamingRequest_TerminalSize) GetHeight() int32

func (*ExecTaskStreamingRequest_TerminalSize) GetWidth added in v0.9.2 

func (m *ExecTaskStreamingRequest_TerminalSize) GetWidth() int32

func (*ExecTaskStreamingRequest_TerminalSize) ProtoMessage added in v0.9.2 

func (*ExecTaskStreamingRequest_TerminalSize) ProtoMessage()

func (*ExecTaskStreamingRequest_TerminalSize) Reset added in v0.9.2 

func (m *ExecTaskStreamingRequest_TerminalSize) Reset()

func (*ExecTaskStreamingRequest_TerminalSize) String added in v0.9.2 

func (m *ExecTaskStreamingRequest_TerminalSize) String() string

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 (dst *ExecTaskStreamingRequest_TerminalSize) XXX_Merge(src proto.Message)

func (*ExecTaskStreamingRequest_TerminalSize) XXX_Size added in v0.9.2 

func (m *ExecTaskStreamingRequest_TerminalSize) XXX_Size() int

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 (m *ExecTaskStreamingResponse) GetStderr() *ExecTaskStreamingIOOperation

func (*ExecTaskStreamingResponse) GetStdout added in v0.9.2 

func (m *ExecTaskStreamingResponse) GetStdout() *ExecTaskStreamingIOOperation

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 (m *FingerprintResponse) GetHealth() FingerprintResponse_HealthState

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 

func (x FingerprintResponse_HealthState) String() 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 (m *StartTaskResponse) GetResult() StartTaskResponse_Result

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.