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 DriverCapabilities_MountConfigs_name = map[int32]string{
	0: "UNKNOWN_MOUNTS",

	1: "NO_MOUNTS",
}
View Source
var DriverCapabilities_MountConfigs_value = map[string]int32{
	"UNKNOWN_MOUNTS": 0,
	"ANY_MOUNTS":     0,
	"NO_MOUNTS":      1,
}
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 NetworkIsolationSpec_NetworkIsolationMode_name = map[int32]string{
	0: "HOST",
	1: "GROUP",
	2: "TASK",
	3: "NONE",
}
View Source
var NetworkIsolationSpec_NetworkIsolationMode_value = map[string]int32{
	"HOST":  0,
	"GROUP": 1,
	"TASK":  2,
	"NONE":  3,
}
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 (m *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 (m *AllocatedMemoryResources) XXX_Merge(src proto.Message)

func (*AllocatedMemoryResources) XXX_Size

func (m *AllocatedMemoryResources) XXX_Size() int

func (*AllocatedMemoryResources) XXX_Unmarshal

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

type AllocatedTaskResources

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

func (*AllocatedTaskResources) Descriptor

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

func (*AllocatedTaskResources) GetCpu

func (*AllocatedTaskResources) GetMemory

func (*AllocatedTaskResources) GetNetworks

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

func (*AllocatedTaskResources) ProtoMessage

func (*AllocatedTaskResources) ProtoMessage()

func (*AllocatedTaskResources) Reset

func (m *AllocatedTaskResources) Reset()

func (*AllocatedTaskResources) String

func (m *AllocatedTaskResources) String() string

func (*AllocatedTaskResources) XXX_DiscardUnknown

func (m *AllocatedTaskResources) XXX_DiscardUnknown()

func (*AllocatedTaskResources) XXX_Marshal

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

func (*AllocatedTaskResources) XXX_Merge

func (m *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 (m *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 (m *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 (m *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 CreateNetworkRequest

type CreateNetworkRequest struct {
	// AllocID of the allocation the network is associated with
	AllocId              string   `protobuf:"bytes,1,opt,name=alloc_id,json=allocId,proto3" json:"alloc_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateNetworkRequest) Descriptor

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

func (*CreateNetworkRequest) GetAllocId

func (m *CreateNetworkRequest) GetAllocId() string

func (*CreateNetworkRequest) ProtoMessage

func (*CreateNetworkRequest) ProtoMessage()

func (*CreateNetworkRequest) Reset

func (m *CreateNetworkRequest) Reset()

func (*CreateNetworkRequest) String

func (m *CreateNetworkRequest) String() string

func (*CreateNetworkRequest) XXX_DiscardUnknown

func (m *CreateNetworkRequest) XXX_DiscardUnknown()

func (*CreateNetworkRequest) XXX_Marshal

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

func (*CreateNetworkRequest) XXX_Merge

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

func (*CreateNetworkRequest) XXX_Size

func (m *CreateNetworkRequest) XXX_Size() int

func (*CreateNetworkRequest) XXX_Unmarshal

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

type CreateNetworkResponse

type CreateNetworkResponse struct {
	IsolationSpec *NetworkIsolationSpec `protobuf:"bytes,1,opt,name=isolation_spec,json=isolationSpec,proto3" json:"isolation_spec,omitempty"`
	// created indicates that the network namespace is newly created
	// as a result of this request. if false, the NetworkIsolationSpec
	// value returned is an existing spec.
	Created              bool     `protobuf:"varint,2,opt,name=created,proto3" json:"created,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateNetworkResponse) Descriptor

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

func (*CreateNetworkResponse) GetCreated

func (m *CreateNetworkResponse) GetCreated() bool

func (*CreateNetworkResponse) GetIsolationSpec

func (m *CreateNetworkResponse) GetIsolationSpec() *NetworkIsolationSpec

func (*CreateNetworkResponse) ProtoMessage

func (*CreateNetworkResponse) ProtoMessage()

func (*CreateNetworkResponse) Reset

func (m *CreateNetworkResponse) Reset()

func (*CreateNetworkResponse) String

func (m *CreateNetworkResponse) String() string

func (*CreateNetworkResponse) XXX_DiscardUnknown

func (m *CreateNetworkResponse) XXX_DiscardUnknown()

func (*CreateNetworkResponse) XXX_Marshal

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

func (*CreateNetworkResponse) XXX_Merge

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

func (*CreateNetworkResponse) XXX_Size

func (m *CreateNetworkResponse) XXX_Size() int

func (*CreateNetworkResponse) XXX_Unmarshal

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

type DNSConfig

type DNSConfig struct {
	Servers              []string `protobuf:"bytes,1,rep,name=servers,proto3" json:"servers,omitempty"`
	Searches             []string `protobuf:"bytes,2,rep,name=searches,proto3" json:"searches,omitempty"`
	Options              []string `protobuf:"bytes,3,rep,name=options,proto3" json:"options,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DNSConfig) Descriptor

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

func (*DNSConfig) GetOptions

func (m *DNSConfig) GetOptions() []string

func (*DNSConfig) GetSearches

func (m *DNSConfig) GetSearches() []string

func (*DNSConfig) GetServers

func (m *DNSConfig) GetServers() []string

func (*DNSConfig) ProtoMessage

func (*DNSConfig) ProtoMessage()

func (*DNSConfig) Reset

func (m *DNSConfig) Reset()

func (*DNSConfig) String

func (m *DNSConfig) String() string

func (*DNSConfig) XXX_DiscardUnknown

func (m *DNSConfig) XXX_DiscardUnknown()

func (*DNSConfig) XXX_Marshal

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

func (*DNSConfig) XXX_Merge

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

func (*DNSConfig) XXX_Size

func (m *DNSConfig) XXX_Size() int

func (*DNSConfig) XXX_Unmarshal

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

type DestroyNetworkRequest

type DestroyNetworkRequest struct {
	// AllocID of the allocation the network is associated with
	AllocId              string                `protobuf:"bytes,1,opt,name=alloc_id,json=allocId,proto3" json:"alloc_id,omitempty"`
	IsolationSpec        *NetworkIsolationSpec `protobuf:"bytes,2,opt,name=isolation_spec,json=isolationSpec,proto3" json:"isolation_spec,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*DestroyNetworkRequest) Descriptor

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

func (*DestroyNetworkRequest) GetAllocId

func (m *DestroyNetworkRequest) GetAllocId() string

func (*DestroyNetworkRequest) GetIsolationSpec

func (m *DestroyNetworkRequest) GetIsolationSpec() *NetworkIsolationSpec

func (*DestroyNetworkRequest) ProtoMessage

func (*DestroyNetworkRequest) ProtoMessage()

func (*DestroyNetworkRequest) Reset

func (m *DestroyNetworkRequest) Reset()

func (*DestroyNetworkRequest) String

func (m *DestroyNetworkRequest) String() string

func (*DestroyNetworkRequest) XXX_DiscardUnknown

func (m *DestroyNetworkRequest) XXX_DiscardUnknown()

func (*DestroyNetworkRequest) XXX_Marshal

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

func (*DestroyNetworkRequest) XXX_Merge

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

func (*DestroyNetworkRequest) XXX_Size

func (m *DestroyNetworkRequest) XXX_Size() int

func (*DestroyNetworkRequest) XXX_Unmarshal

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

type DestroyNetworkResponse

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

func (*DestroyNetworkResponse) Descriptor

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

func (*DestroyNetworkResponse) ProtoMessage

func (*DestroyNetworkResponse) ProtoMessage()

func (*DestroyNetworkResponse) Reset

func (m *DestroyNetworkResponse) Reset()

func (*DestroyNetworkResponse) String

func (m *DestroyNetworkResponse) String() string

func (*DestroyNetworkResponse) XXX_DiscardUnknown

func (m *DestroyNetworkResponse) XXX_DiscardUnknown()

func (*DestroyNetworkResponse) XXX_Marshal

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

func (*DestroyNetworkResponse) XXX_Merge

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

func (*DestroyNetworkResponse) XXX_Size

func (m *DestroyNetworkResponse) XXX_Size() int

func (*DestroyNetworkResponse) XXX_Unmarshal

func (m *DestroyNetworkResponse) 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 (m *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 (m *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 (m *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 */
	NetworkIsolationModes []NetworkIsolationSpec_NetworkIsolationMode `` /* 219-byte string literal not displayed */
	MustCreateNetwork     bool                                        `protobuf:"varint,5,opt,name=must_create_network,json=mustCreateNetwork,proto3" json:"must_create_network,omitempty"`
	// MountConfigs indicates whether the driver supports mount configurations.
	MountConfigs         DriverCapabilities_MountConfigs `` /* 173-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func (*DriverCapabilities) Descriptor

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

func (*DriverCapabilities) GetExec

func (m *DriverCapabilities) GetExec() bool

func (*DriverCapabilities) GetFsIsolation

func (*DriverCapabilities) GetMountConfigs

func (*DriverCapabilities) GetMustCreateNetwork

func (m *DriverCapabilities) GetMustCreateNetwork() bool

func (*DriverCapabilities) GetNetworkIsolationModes

func (m *DriverCapabilities) GetNetworkIsolationModes() []NetworkIsolationSpec_NetworkIsolationMode

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

func (*DriverCapabilities) XXX_Size

func (m *DriverCapabilities) XXX_Size() int

func (*DriverCapabilities) XXX_Unmarshal

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

type DriverCapabilities_FSIsolation

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

func (DriverCapabilities_FSIsolation) EnumDescriptor

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

func (DriverCapabilities_FSIsolation) String

type DriverCapabilities_MountConfigs

type DriverCapabilities_MountConfigs int32
const (
	DriverCapabilities_UNKNOWN_MOUNTS DriverCapabilities_MountConfigs = 0
	DriverCapabilities_ANY_MOUNTS     DriverCapabilities_MountConfigs = 0
	DriverCapabilities_NO_MOUNTS      DriverCapabilities_MountConfigs = 1
)

func (DriverCapabilities_MountConfigs) EnumDescriptor

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

func (DriverCapabilities_MountConfigs) 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
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	ExecTaskStreaming(ctx context.Context, opts ...grpc.CallOption) (Driver_ExecTaskStreamingClient, error)
	// CreateNetwork is implemented when the driver needs to create the network
	// namespace instead of allowing the Nomad client to do.
	CreateNetwork(ctx context.Context, in *CreateNetworkRequest, opts ...grpc.CallOption) (*CreateNetworkResponse, error)
	// DestroyNetwork destroys a previously created network. This rpc is only
	// implemented if the driver needs to manage network namespace creation.
	DestroyNetwork(ctx context.Context, in *DestroyNetworkRequest, opts ...grpc.CallOption) (*DestroyNetworkResponse, 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.ClientConnInterface) 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
    	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
    	ExecTaskStreaming(Driver_ExecTaskStreamingServer) error
    	// CreateNetwork is implemented when the driver needs to create the network
    	// namespace instead of allowing the Nomad client to do.
    	CreateNetwork(context.Context, *CreateNetworkRequest) (*CreateNetworkResponse, error)
    	// DestroyNetwork destroys a previously created network. This rpc is only
    	// implemented if the driver needs to manage network namespace creation.
    	DestroyNetwork(context.Context, *DestroyNetworkRequest) (*DestroyNetworkResponse, 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 (m *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

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

      type Driver_ExecTaskStreamingServer

      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 (m *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 (m *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

      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

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

      func (*ExecTaskStreamingIOOperation) GetClose

      func (m *ExecTaskStreamingIOOperation) GetClose() bool

      func (*ExecTaskStreamingIOOperation) GetData

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

      func (*ExecTaskStreamingIOOperation) ProtoMessage

      func (*ExecTaskStreamingIOOperation) ProtoMessage()

      func (*ExecTaskStreamingIOOperation) Reset

      func (m *ExecTaskStreamingIOOperation) Reset()

      func (*ExecTaskStreamingIOOperation) String

      func (*ExecTaskStreamingIOOperation) XXX_DiscardUnknown

      func (m *ExecTaskStreamingIOOperation) XXX_DiscardUnknown()

      func (*ExecTaskStreamingIOOperation) XXX_Marshal

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

      func (*ExecTaskStreamingIOOperation) XXX_Merge

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

      func (*ExecTaskStreamingIOOperation) XXX_Size

      func (m *ExecTaskStreamingIOOperation) XXX_Size() int

      func (*ExecTaskStreamingIOOperation) XXX_Unmarshal

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

      type ExecTaskStreamingRequest

      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

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

      func (*ExecTaskStreamingRequest) GetSetup

      func (*ExecTaskStreamingRequest) GetStdin

      func (*ExecTaskStreamingRequest) GetTtySize

      func (*ExecTaskStreamingRequest) ProtoMessage

      func (*ExecTaskStreamingRequest) ProtoMessage()

      func (*ExecTaskStreamingRequest) Reset

      func (m *ExecTaskStreamingRequest) Reset()

      func (*ExecTaskStreamingRequest) String

      func (m *ExecTaskStreamingRequest) String() string

      func (*ExecTaskStreamingRequest) XXX_DiscardUnknown

      func (m *ExecTaskStreamingRequest) XXX_DiscardUnknown()

      func (*ExecTaskStreamingRequest) XXX_Marshal

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

      func (*ExecTaskStreamingRequest) XXX_Merge

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

      func (*ExecTaskStreamingRequest) XXX_Size

      func (m *ExecTaskStreamingRequest) XXX_Size() int

      func (*ExecTaskStreamingRequest) XXX_Unmarshal

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

      type ExecTaskStreamingRequest_Setup

      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

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

      func (*ExecTaskStreamingRequest_Setup) GetCommand

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

      func (*ExecTaskStreamingRequest_Setup) GetTaskId

      func (m *ExecTaskStreamingRequest_Setup) GetTaskId() string

      func (*ExecTaskStreamingRequest_Setup) GetTty

      func (*ExecTaskStreamingRequest_Setup) ProtoMessage

      func (*ExecTaskStreamingRequest_Setup) ProtoMessage()

      func (*ExecTaskStreamingRequest_Setup) Reset

      func (m *ExecTaskStreamingRequest_Setup) Reset()

      func (*ExecTaskStreamingRequest_Setup) String

      func (*ExecTaskStreamingRequest_Setup) XXX_DiscardUnknown

      func (m *ExecTaskStreamingRequest_Setup) XXX_DiscardUnknown()

      func (*ExecTaskStreamingRequest_Setup) XXX_Marshal

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

      func (*ExecTaskStreamingRequest_Setup) XXX_Merge

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

      func (*ExecTaskStreamingRequest_Setup) XXX_Size

      func (m *ExecTaskStreamingRequest_Setup) XXX_Size() int

      func (*ExecTaskStreamingRequest_Setup) XXX_Unmarshal

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

      type ExecTaskStreamingRequest_TerminalSize

      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

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

      func (*ExecTaskStreamingRequest_TerminalSize) GetHeight

      func (*ExecTaskStreamingRequest_TerminalSize) GetWidth

      func (*ExecTaskStreamingRequest_TerminalSize) ProtoMessage

      func (*ExecTaskStreamingRequest_TerminalSize) ProtoMessage()

      func (*ExecTaskStreamingRequest_TerminalSize) Reset

      func (*ExecTaskStreamingRequest_TerminalSize) String

      func (*ExecTaskStreamingRequest_TerminalSize) XXX_DiscardUnknown

      func (m *ExecTaskStreamingRequest_TerminalSize) XXX_DiscardUnknown()

      func (*ExecTaskStreamingRequest_TerminalSize) XXX_Marshal

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

      func (*ExecTaskStreamingRequest_TerminalSize) XXX_Merge

      func (*ExecTaskStreamingRequest_TerminalSize) XXX_Size

      func (*ExecTaskStreamingRequest_TerminalSize) XXX_Unmarshal

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

      type ExecTaskStreamingResponse

      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

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

      func (*ExecTaskStreamingResponse) GetExited

      func (m *ExecTaskStreamingResponse) GetExited() bool

      func (*ExecTaskStreamingResponse) GetResult

      func (m *ExecTaskStreamingResponse) GetResult() *ExitResult

      func (*ExecTaskStreamingResponse) GetStderr

      func (*ExecTaskStreamingResponse) GetStdout

      func (*ExecTaskStreamingResponse) ProtoMessage

      func (*ExecTaskStreamingResponse) ProtoMessage()

      func (*ExecTaskStreamingResponse) Reset

      func (m *ExecTaskStreamingResponse) Reset()

      func (*ExecTaskStreamingResponse) String

      func (m *ExecTaskStreamingResponse) String() string

      func (*ExecTaskStreamingResponse) XXX_DiscardUnknown

      func (m *ExecTaskStreamingResponse) XXX_DiscardUnknown()

      func (*ExecTaskStreamingResponse) XXX_Marshal

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

      func (*ExecTaskStreamingResponse) XXX_Merge

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

      func (*ExecTaskStreamingResponse) XXX_Size

      func (m *ExecTaskStreamingResponse) XXX_Size() int

      func (*ExecTaskStreamingResponse) XXX_Unmarshal

      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 (m *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 (m *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 constraints and affinities.
        	Attributes map[string]*proto1.Attribute `` /* 161-byte string literal not displayed */
        	// Health is used to determine the state of the health the driver is in.
        	// Health can be one of the following states:
        	//  * UNDETECTED: driver dependencies are not met and the driver can not start
        	//  * UNHEALTHY: driver dependencies are met but the driver is unable to
        	//      perform operations due to some other problem
        	//  * HEALTHY: driver is able to perform all operations
        	Health FingerprintResponse_HealthState `` /* 141-byte string literal not displayed */
        	// HealthDescription is a human readable message describing the current
        	// state of driver health
        	HealthDescription    string   `protobuf:"bytes,3,opt,name=health_description,json=healthDescription,proto3" json:"health_description,omitempty"`
        	XXX_NoUnkeyedLiteral struct{} `json:"-"`
        	XXX_unrecognized     []byte   `json:"-"`
        	XXX_sizecache        int32    `json:"-"`
        }

        func (*FingerprintResponse) Descriptor

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

        func (*FingerprintResponse) GetAttributes

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

        func (*FingerprintResponse) GetHealth

        func (*FingerprintResponse) GetHealthDescription

        func (m *FingerprintResponse) GetHealthDescription() string

        func (*FingerprintResponse) ProtoMessage

        func (*FingerprintResponse) ProtoMessage()

        func (*FingerprintResponse) Reset

        func (m *FingerprintResponse) Reset()

        func (*FingerprintResponse) String

        func (m *FingerprintResponse) String() string

        func (*FingerprintResponse) XXX_DiscardUnknown

        func (m *FingerprintResponse) XXX_DiscardUnknown()

        func (*FingerprintResponse) XXX_Marshal

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

        func (*FingerprintResponse) XXX_Merge

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

        func (*FingerprintResponse) XXX_Size

        func (m *FingerprintResponse) XXX_Size() int

        func (*FingerprintResponse) XXX_Unmarshal

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

        type FingerprintResponse_HealthState

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

        func (FingerprintResponse_HealthState) EnumDescriptor

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

        func (FingerprintResponse_HealthState) String

        type InspectTaskRequest

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

        func (*InspectTaskRequest) Descriptor

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

        func (*InspectTaskRequest) GetTaskId

        func (m *InspectTaskRequest) GetTaskId() string

        func (*InspectTaskRequest) ProtoMessage

        func (*InspectTaskRequest) ProtoMessage()

        func (*InspectTaskRequest) Reset

        func (m *InspectTaskRequest) Reset()

        func (*InspectTaskRequest) String

        func (m *InspectTaskRequest) String() string

        func (*InspectTaskRequest) XXX_DiscardUnknown

        func (m *InspectTaskRequest) XXX_DiscardUnknown()

        func (*InspectTaskRequest) XXX_Marshal

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

        func (*InspectTaskRequest) XXX_Merge

        func (m *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 (m *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
        	// buf:lint:ignore FIELD_LOWER_SNAKE_CASE
        	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 (m *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 (m *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 (m *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 NetworkIsolationSpec

        type NetworkIsolationSpec struct {
        	Mode                 NetworkIsolationSpec_NetworkIsolationMode `` /* 147-byte string literal not displayed */
        	Path                 string                                    `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
        	Labels               map[string]string                         `` /* 153-byte string literal not displayed */
        	XXX_NoUnkeyedLiteral struct{}                                  `json:"-"`
        	XXX_unrecognized     []byte                                    `json:"-"`
        	XXX_sizecache        int32                                     `json:"-"`
        }

        func (*NetworkIsolationSpec) Descriptor

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

        func (*NetworkIsolationSpec) GetLabels

        func (m *NetworkIsolationSpec) GetLabels() map[string]string

        func (*NetworkIsolationSpec) GetMode

        func (*NetworkIsolationSpec) GetPath

        func (m *NetworkIsolationSpec) GetPath() string

        func (*NetworkIsolationSpec) ProtoMessage

        func (*NetworkIsolationSpec) ProtoMessage()

        func (*NetworkIsolationSpec) Reset

        func (m *NetworkIsolationSpec) Reset()

        func (*NetworkIsolationSpec) String

        func (m *NetworkIsolationSpec) String() string

        func (*NetworkIsolationSpec) XXX_DiscardUnknown

        func (m *NetworkIsolationSpec) XXX_DiscardUnknown()

        func (*NetworkIsolationSpec) XXX_Marshal

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

        func (*NetworkIsolationSpec) XXX_Merge

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

        func (*NetworkIsolationSpec) XXX_Size

        func (m *NetworkIsolationSpec) XXX_Size() int

        func (*NetworkIsolationSpec) XXX_Unmarshal

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

        type NetworkIsolationSpec_NetworkIsolationMode

        type NetworkIsolationSpec_NetworkIsolationMode int32
        const (
        	NetworkIsolationSpec_HOST  NetworkIsolationSpec_NetworkIsolationMode = 0
        	NetworkIsolationSpec_GROUP NetworkIsolationSpec_NetworkIsolationMode = 1
        	NetworkIsolationSpec_TASK  NetworkIsolationSpec_NetworkIsolationMode = 2
        	NetworkIsolationSpec_NONE  NetworkIsolationSpec_NetworkIsolationMode = 3
        )

        func (NetworkIsolationSpec_NetworkIsolationMode) EnumDescriptor

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

        func (NetworkIsolationSpec_NetworkIsolationMode) String

        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 (m *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 (m *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 (m *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 PortMapping

          type PortMapping 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"`
          	To                   int32    `protobuf:"varint,3,opt,name=to,proto3" json:"to,omitempty"`
          	HostIp               string   `protobuf:"bytes,4,opt,name=host_ip,json=hostIp,proto3" json:"host_ip,omitempty"`
          	XXX_NoUnkeyedLiteral struct{} `json:"-"`
          	XXX_unrecognized     []byte   `json:"-"`
          	XXX_sizecache        int32    `json:"-"`
          }

          func (*PortMapping) Descriptor

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

          func (*PortMapping) GetHostIp

          func (m *PortMapping) GetHostIp() string

          func (*PortMapping) GetLabel

          func (m *PortMapping) GetLabel() string

          func (*PortMapping) GetTo

          func (m *PortMapping) GetTo() int32

          func (*PortMapping) GetValue

          func (m *PortMapping) GetValue() int32

          func (*PortMapping) ProtoMessage

          func (*PortMapping) ProtoMessage()

          func (*PortMapping) Reset

          func (m *PortMapping) Reset()

          func (*PortMapping) String

          func (m *PortMapping) String() string

          func (*PortMapping) XXX_DiscardUnknown

          func (m *PortMapping) XXX_DiscardUnknown()

          func (*PortMapping) XXX_Marshal

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

          func (*PortMapping) XXX_Merge

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

          func (*PortMapping) XXX_Size

          func (m *PortMapping) XXX_Size() int

          func (*PortMapping) XXX_Unmarshal

          func (m *PortMapping) 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 (m *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 (m *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"`
          	// Ports are the allocated port mappings for the allocation.
          	// A task may use these to manually configure port mapping if shared network namespaces aren't being used.
          	Ports                []*PortMapping `protobuf:"bytes,3,rep,name=ports,proto3" json:"ports,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) GetPorts

          func (m *Resources) GetPorts() []*PortMapping

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

          func (*StartTaskRequest) XXX_Size

          func (m *StartTaskRequest) XXX_Size() int

          func (*StartTaskRequest) XXX_Unmarshal

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

          type StartTaskResponse

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

          func (*StartTaskResponse) Descriptor

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

          func (*StartTaskResponse) GetDriverErrorMsg

          func (m *StartTaskResponse) GetDriverErrorMsg() string

          func (*StartTaskResponse) GetHandle

          func (m *StartTaskResponse) GetHandle() *TaskHandle

          func (*StartTaskResponse) GetNetworkOverride

          func (m *StartTaskResponse) GetNetworkOverride() *NetworkOverride

          func (*StartTaskResponse) GetResult

          func (*StartTaskResponse) ProtoMessage

          func (*StartTaskResponse) ProtoMessage()

          func (*StartTaskResponse) Reset

          func (m *StartTaskResponse) Reset()

          func (*StartTaskResponse) String

          func (m *StartTaskResponse) String() string

          func (*StartTaskResponse) XXX_DiscardUnknown

          func (m *StartTaskResponse) XXX_DiscardUnknown()

          func (*StartTaskResponse) XXX_Marshal

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

          func (*StartTaskResponse) XXX_Merge

          func (m *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 (m *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 (m *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"`
          	// NetworkIsolationSpec specifies the configuration for the network namespace
          	// to use for the task. *Only supported on Linux
          	NetworkIsolationSpec *NetworkIsolationSpec `protobuf:"bytes,16,opt,name=network_isolation_spec,json=networkIsolationSpec,proto3" json:"network_isolation_spec,omitempty"`
          	// DNSConfig is the configuration for task DNS resolvers and other options
          	Dns                  *DNSConfig `protobuf:"bytes,17,opt,name=dns,proto3" json:"dns,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) GetDns

          func (m *TaskConfig) GetDns() *DNSConfig

          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) GetNetworkIsolationSpec

          func (m *TaskConfig) GetNetworkIsolationSpec() *NetworkIsolationSpec

          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 (m *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 (m *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 (m *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 (m *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 (m *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 (m *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 (m *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 (m *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 (m *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 (m *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 (m *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 UnimplementedDriverServer

              type UnimplementedDriverServer struct {
              }

                UnimplementedDriverServer can be embedded to have forward compatible implementations.

                func (*UnimplementedDriverServer) Capabilities

                func (*UnimplementedDriverServer) CreateNetwork

                func (*UnimplementedDriverServer) DestroyNetwork

                func (*UnimplementedDriverServer) DestroyTask

                func (*UnimplementedDriverServer) ExecTask

                func (*UnimplementedDriverServer) ExecTaskStreaming

                func (*UnimplementedDriverServer) Fingerprint

                func (*UnimplementedDriverServer) InspectTask

                func (*UnimplementedDriverServer) RecoverTask

                func (*UnimplementedDriverServer) SignalTask

                func (*UnimplementedDriverServer) StartTask

                func (*UnimplementedDriverServer) StopTask

                func (*UnimplementedDriverServer) TaskConfigSchema

                func (*UnimplementedDriverServer) TaskEvents

                func (*UnimplementedDriverServer) TaskStats

                func (*UnimplementedDriverServer) WaitTask

                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 (m *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 (m *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