Documentation ¶
Index ¶
- Variables
- func RegisterDriverServer(s *grpc.Server, srv DriverServer)
- type AllocatedCpuResources
- func (*AllocatedCpuResources) Descriptor() ([]byte, []int)
- func (m *AllocatedCpuResources) GetCpuShares() int64
- func (*AllocatedCpuResources) ProtoMessage()
- func (m *AllocatedCpuResources) Reset()
- func (m *AllocatedCpuResources) String() string
- func (m *AllocatedCpuResources) XXX_DiscardUnknown()
- func (m *AllocatedCpuResources) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AllocatedCpuResources) XXX_Merge(src proto.Message)
- func (m *AllocatedCpuResources) XXX_Size() int
- func (m *AllocatedCpuResources) XXX_Unmarshal(b []byte) error
- type AllocatedMemoryResources
- func (*AllocatedMemoryResources) Descriptor() ([]byte, []int)
- func (m *AllocatedMemoryResources) GetMemoryMaxMb() int64
- func (m *AllocatedMemoryResources) GetMemoryMb() int64
- func (*AllocatedMemoryResources) ProtoMessage()
- func (m *AllocatedMemoryResources) Reset()
- func (m *AllocatedMemoryResources) String() string
- func (m *AllocatedMemoryResources) XXX_DiscardUnknown()
- func (m *AllocatedMemoryResources) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AllocatedMemoryResources) XXX_Merge(src proto.Message)
- func (m *AllocatedMemoryResources) XXX_Size() int
- func (m *AllocatedMemoryResources) XXX_Unmarshal(b []byte) error
- type AllocatedTaskResources
- func (*AllocatedTaskResources) Descriptor() ([]byte, []int)
- func (m *AllocatedTaskResources) GetCpu() *AllocatedCpuResources
- func (m *AllocatedTaskResources) GetMemory() *AllocatedMemoryResources
- func (m *AllocatedTaskResources) GetNetworks() []*NetworkResource
- func (*AllocatedTaskResources) ProtoMessage()
- func (m *AllocatedTaskResources) Reset()
- func (m *AllocatedTaskResources) String() string
- func (m *AllocatedTaskResources) XXX_DiscardUnknown()
- func (m *AllocatedTaskResources) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AllocatedTaskResources) XXX_Merge(src proto.Message)
- func (m *AllocatedTaskResources) XXX_Size() int
- func (m *AllocatedTaskResources) XXX_Unmarshal(b []byte) error
- type CPUUsage
- func (*CPUUsage) Descriptor() ([]byte, []int)
- func (m *CPUUsage) GetMeasuredFields() []CPUUsage_Fields
- func (m *CPUUsage) GetPercent() float64
- func (m *CPUUsage) GetSystemMode() float64
- func (m *CPUUsage) GetThrottledPeriods() uint64
- func (m *CPUUsage) GetThrottledTime() uint64
- func (m *CPUUsage) GetTotalTicks() float64
- func (m *CPUUsage) GetUserMode() float64
- func (*CPUUsage) ProtoMessage()
- func (m *CPUUsage) Reset()
- func (m *CPUUsage) String() string
- func (m *CPUUsage) XXX_DiscardUnknown()
- func (m *CPUUsage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CPUUsage) XXX_Merge(src proto.Message)
- func (m *CPUUsage) XXX_Size() int
- func (m *CPUUsage) XXX_Unmarshal(b []byte) error
- type CPUUsage_Fields
- type CapabilitiesRequest
- func (*CapabilitiesRequest) Descriptor() ([]byte, []int)
- func (*CapabilitiesRequest) ProtoMessage()
- func (m *CapabilitiesRequest) Reset()
- func (m *CapabilitiesRequest) String() string
- func (m *CapabilitiesRequest) XXX_DiscardUnknown()
- func (m *CapabilitiesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CapabilitiesRequest) XXX_Merge(src proto.Message)
- func (m *CapabilitiesRequest) XXX_Size() int
- func (m *CapabilitiesRequest) XXX_Unmarshal(b []byte) error
- type CapabilitiesResponse
- func (*CapabilitiesResponse) Descriptor() ([]byte, []int)
- func (m *CapabilitiesResponse) GetCapabilities() *DriverCapabilities
- func (*CapabilitiesResponse) ProtoMessage()
- func (m *CapabilitiesResponse) Reset()
- func (m *CapabilitiesResponse) String() string
- func (m *CapabilitiesResponse) XXX_DiscardUnknown()
- func (m *CapabilitiesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CapabilitiesResponse) XXX_Merge(src proto.Message)
- func (m *CapabilitiesResponse) XXX_Size() int
- func (m *CapabilitiesResponse) XXX_Unmarshal(b []byte) error
- type CreateNetworkRequest
- func (*CreateNetworkRequest) Descriptor() ([]byte, []int)
- func (m *CreateNetworkRequest) GetAllocId() string
- func (m *CreateNetworkRequest) GetHostname() string
- func (*CreateNetworkRequest) ProtoMessage()
- func (m *CreateNetworkRequest) Reset()
- func (m *CreateNetworkRequest) String() string
- func (m *CreateNetworkRequest) XXX_DiscardUnknown()
- func (m *CreateNetworkRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateNetworkRequest) XXX_Merge(src proto.Message)
- func (m *CreateNetworkRequest) XXX_Size() int
- func (m *CreateNetworkRequest) XXX_Unmarshal(b []byte) error
- type CreateNetworkResponse
- func (*CreateNetworkResponse) Descriptor() ([]byte, []int)
- func (m *CreateNetworkResponse) GetCreated() bool
- func (m *CreateNetworkResponse) GetIsolationSpec() *NetworkIsolationSpec
- func (*CreateNetworkResponse) ProtoMessage()
- func (m *CreateNetworkResponse) Reset()
- func (m *CreateNetworkResponse) String() string
- func (m *CreateNetworkResponse) XXX_DiscardUnknown()
- func (m *CreateNetworkResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateNetworkResponse) XXX_Merge(src proto.Message)
- func (m *CreateNetworkResponse) XXX_Size() int
- func (m *CreateNetworkResponse) XXX_Unmarshal(b []byte) error
- type DNSConfig
- func (*DNSConfig) Descriptor() ([]byte, []int)
- func (m *DNSConfig) GetOptions() []string
- func (m *DNSConfig) GetSearches() []string
- func (m *DNSConfig) GetServers() []string
- func (*DNSConfig) ProtoMessage()
- func (m *DNSConfig) Reset()
- func (m *DNSConfig) String() string
- func (m *DNSConfig) XXX_DiscardUnknown()
- func (m *DNSConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DNSConfig) XXX_Merge(src proto.Message)
- func (m *DNSConfig) XXX_Size() int
- func (m *DNSConfig) XXX_Unmarshal(b []byte) error
- type DestroyNetworkRequest
- func (*DestroyNetworkRequest) Descriptor() ([]byte, []int)
- func (m *DestroyNetworkRequest) GetAllocId() string
- func (m *DestroyNetworkRequest) GetIsolationSpec() *NetworkIsolationSpec
- func (*DestroyNetworkRequest) ProtoMessage()
- func (m *DestroyNetworkRequest) Reset()
- func (m *DestroyNetworkRequest) String() string
- func (m *DestroyNetworkRequest) XXX_DiscardUnknown()
- func (m *DestroyNetworkRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DestroyNetworkRequest) XXX_Merge(src proto.Message)
- func (m *DestroyNetworkRequest) XXX_Size() int
- func (m *DestroyNetworkRequest) XXX_Unmarshal(b []byte) error
- type DestroyNetworkResponse
- func (*DestroyNetworkResponse) Descriptor() ([]byte, []int)
- func (*DestroyNetworkResponse) ProtoMessage()
- func (m *DestroyNetworkResponse) Reset()
- func (m *DestroyNetworkResponse) String() string
- func (m *DestroyNetworkResponse) XXX_DiscardUnknown()
- func (m *DestroyNetworkResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DestroyNetworkResponse) XXX_Merge(src proto.Message)
- func (m *DestroyNetworkResponse) XXX_Size() int
- func (m *DestroyNetworkResponse) XXX_Unmarshal(b []byte) error
- type DestroyTaskRequest
- func (*DestroyTaskRequest) Descriptor() ([]byte, []int)
- func (m *DestroyTaskRequest) GetForce() bool
- func (m *DestroyTaskRequest) GetTaskId() string
- func (*DestroyTaskRequest) ProtoMessage()
- func (m *DestroyTaskRequest) Reset()
- func (m *DestroyTaskRequest) String() string
- func (m *DestroyTaskRequest) XXX_DiscardUnknown()
- func (m *DestroyTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DestroyTaskRequest) XXX_Merge(src proto.Message)
- func (m *DestroyTaskRequest) XXX_Size() int
- func (m *DestroyTaskRequest) XXX_Unmarshal(b []byte) error
- type DestroyTaskResponse
- func (*DestroyTaskResponse) Descriptor() ([]byte, []int)
- func (*DestroyTaskResponse) ProtoMessage()
- func (m *DestroyTaskResponse) Reset()
- func (m *DestroyTaskResponse) String() string
- func (m *DestroyTaskResponse) XXX_DiscardUnknown()
- func (m *DestroyTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DestroyTaskResponse) XXX_Merge(src proto.Message)
- func (m *DestroyTaskResponse) XXX_Size() int
- func (m *DestroyTaskResponse) XXX_Unmarshal(b []byte) error
- type Device
- func (*Device) Descriptor() ([]byte, []int)
- func (m *Device) GetCgroupPermissions() string
- func (m *Device) GetHostPath() string
- func (m *Device) GetTaskPath() string
- func (*Device) ProtoMessage()
- func (m *Device) Reset()
- func (m *Device) String() string
- func (m *Device) XXX_DiscardUnknown()
- func (m *Device) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Device) XXX_Merge(src proto.Message)
- func (m *Device) XXX_Size() int
- func (m *Device) XXX_Unmarshal(b []byte) error
- type DriverCapabilities
- func (*DriverCapabilities) Descriptor() ([]byte, []int)
- func (m *DriverCapabilities) GetExec() bool
- func (m *DriverCapabilities) GetFsIsolation() DriverCapabilities_FSIsolation
- func (m *DriverCapabilities) GetMountConfigs() DriverCapabilities_MountConfigs
- func (m *DriverCapabilities) GetMustCreateNetwork() bool
- func (m *DriverCapabilities) GetNetworkIsolationModes() []NetworkIsolationSpec_NetworkIsolationMode
- func (m *DriverCapabilities) GetRemoteTasks() bool
- func (m *DriverCapabilities) GetSendSignals() bool
- func (*DriverCapabilities) ProtoMessage()
- func (m *DriverCapabilities) Reset()
- func (m *DriverCapabilities) String() string
- func (m *DriverCapabilities) XXX_DiscardUnknown()
- func (m *DriverCapabilities) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DriverCapabilities) XXX_Merge(src proto.Message)
- func (m *DriverCapabilities) XXX_Size() int
- func (m *DriverCapabilities) XXX_Unmarshal(b []byte) error
- type DriverCapabilities_FSIsolation
- type DriverCapabilities_MountConfigs
- type DriverClient
- type DriverServer
- type DriverTaskEvent
- func (*DriverTaskEvent) Descriptor() ([]byte, []int)
- func (m *DriverTaskEvent) GetAllocId() string
- func (m *DriverTaskEvent) GetAnnotations() map[string]string
- func (m *DriverTaskEvent) GetMessage() string
- func (m *DriverTaskEvent) GetTaskId() string
- func (m *DriverTaskEvent) GetTaskName() string
- func (m *DriverTaskEvent) GetTimestamp() *timestamp.Timestamp
- func (*DriverTaskEvent) ProtoMessage()
- func (m *DriverTaskEvent) Reset()
- func (m *DriverTaskEvent) String() string
- func (m *DriverTaskEvent) XXX_DiscardUnknown()
- func (m *DriverTaskEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DriverTaskEvent) XXX_Merge(src proto.Message)
- func (m *DriverTaskEvent) XXX_Size() int
- func (m *DriverTaskEvent) XXX_Unmarshal(b []byte) error
- type Driver_ExecTaskStreamingClient
- type Driver_ExecTaskStreamingServer
- type Driver_FingerprintClient
- type Driver_FingerprintServer
- type Driver_TaskEventsClient
- type Driver_TaskEventsServer
- type Driver_TaskStatsClient
- type Driver_TaskStatsServer
- type ExecTaskRequest
- func (*ExecTaskRequest) Descriptor() ([]byte, []int)
- func (m *ExecTaskRequest) GetCommand() []string
- func (m *ExecTaskRequest) GetTaskId() string
- func (m *ExecTaskRequest) GetTimeout() *duration.Duration
- func (*ExecTaskRequest) ProtoMessage()
- func (m *ExecTaskRequest) Reset()
- func (m *ExecTaskRequest) String() string
- func (m *ExecTaskRequest) XXX_DiscardUnknown()
- func (m *ExecTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExecTaskRequest) XXX_Merge(src proto.Message)
- func (m *ExecTaskRequest) XXX_Size() int
- func (m *ExecTaskRequest) XXX_Unmarshal(b []byte) error
- type ExecTaskResponse
- func (*ExecTaskResponse) Descriptor() ([]byte, []int)
- func (m *ExecTaskResponse) GetResult() *ExitResult
- func (m *ExecTaskResponse) GetStderr() []byte
- func (m *ExecTaskResponse) GetStdout() []byte
- func (*ExecTaskResponse) ProtoMessage()
- func (m *ExecTaskResponse) Reset()
- func (m *ExecTaskResponse) String() string
- func (m *ExecTaskResponse) XXX_DiscardUnknown()
- func (m *ExecTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExecTaskResponse) XXX_Merge(src proto.Message)
- func (m *ExecTaskResponse) XXX_Size() int
- func (m *ExecTaskResponse) XXX_Unmarshal(b []byte) error
- type ExecTaskStreamingIOOperation
- func (*ExecTaskStreamingIOOperation) Descriptor() ([]byte, []int)
- func (m *ExecTaskStreamingIOOperation) GetClose() bool
- func (m *ExecTaskStreamingIOOperation) GetData() []byte
- func (*ExecTaskStreamingIOOperation) ProtoMessage()
- func (m *ExecTaskStreamingIOOperation) Reset()
- func (m *ExecTaskStreamingIOOperation) String() string
- func (m *ExecTaskStreamingIOOperation) XXX_DiscardUnknown()
- func (m *ExecTaskStreamingIOOperation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExecTaskStreamingIOOperation) XXX_Merge(src proto.Message)
- func (m *ExecTaskStreamingIOOperation) XXX_Size() int
- func (m *ExecTaskStreamingIOOperation) XXX_Unmarshal(b []byte) error
- type ExecTaskStreamingRequest
- func (*ExecTaskStreamingRequest) Descriptor() ([]byte, []int)
- func (m *ExecTaskStreamingRequest) GetSetup() *ExecTaskStreamingRequest_Setup
- func (m *ExecTaskStreamingRequest) GetStdin() *ExecTaskStreamingIOOperation
- func (m *ExecTaskStreamingRequest) GetTtySize() *ExecTaskStreamingRequest_TerminalSize
- func (*ExecTaskStreamingRequest) ProtoMessage()
- func (m *ExecTaskStreamingRequest) Reset()
- func (m *ExecTaskStreamingRequest) String() string
- func (m *ExecTaskStreamingRequest) XXX_DiscardUnknown()
- func (m *ExecTaskStreamingRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExecTaskStreamingRequest) XXX_Merge(src proto.Message)
- func (m *ExecTaskStreamingRequest) XXX_Size() int
- func (m *ExecTaskStreamingRequest) XXX_Unmarshal(b []byte) error
- type ExecTaskStreamingRequest_Setup
- func (*ExecTaskStreamingRequest_Setup) Descriptor() ([]byte, []int)
- func (m *ExecTaskStreamingRequest_Setup) GetCommand() []string
- func (m *ExecTaskStreamingRequest_Setup) GetTaskId() string
- func (m *ExecTaskStreamingRequest_Setup) GetTty() bool
- func (*ExecTaskStreamingRequest_Setup) ProtoMessage()
- func (m *ExecTaskStreamingRequest_Setup) Reset()
- func (m *ExecTaskStreamingRequest_Setup) String() string
- func (m *ExecTaskStreamingRequest_Setup) XXX_DiscardUnknown()
- func (m *ExecTaskStreamingRequest_Setup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExecTaskStreamingRequest_Setup) XXX_Merge(src proto.Message)
- func (m *ExecTaskStreamingRequest_Setup) XXX_Size() int
- func (m *ExecTaskStreamingRequest_Setup) XXX_Unmarshal(b []byte) error
- type ExecTaskStreamingRequest_TerminalSize
- func (*ExecTaskStreamingRequest_TerminalSize) Descriptor() ([]byte, []int)
- func (m *ExecTaskStreamingRequest_TerminalSize) GetHeight() int32
- func (m *ExecTaskStreamingRequest_TerminalSize) GetWidth() int32
- func (*ExecTaskStreamingRequest_TerminalSize) ProtoMessage()
- func (m *ExecTaskStreamingRequest_TerminalSize) Reset()
- func (m *ExecTaskStreamingRequest_TerminalSize) String() string
- func (m *ExecTaskStreamingRequest_TerminalSize) XXX_DiscardUnknown()
- func (m *ExecTaskStreamingRequest_TerminalSize) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExecTaskStreamingRequest_TerminalSize) XXX_Merge(src proto.Message)
- func (m *ExecTaskStreamingRequest_TerminalSize) XXX_Size() int
- func (m *ExecTaskStreamingRequest_TerminalSize) XXX_Unmarshal(b []byte) error
- type ExecTaskStreamingResponse
- func (*ExecTaskStreamingResponse) Descriptor() ([]byte, []int)
- func (m *ExecTaskStreamingResponse) GetExited() bool
- func (m *ExecTaskStreamingResponse) GetResult() *ExitResult
- func (m *ExecTaskStreamingResponse) GetStderr() *ExecTaskStreamingIOOperation
- func (m *ExecTaskStreamingResponse) GetStdout() *ExecTaskStreamingIOOperation
- func (*ExecTaskStreamingResponse) ProtoMessage()
- func (m *ExecTaskStreamingResponse) Reset()
- func (m *ExecTaskStreamingResponse) String() string
- func (m *ExecTaskStreamingResponse) XXX_DiscardUnknown()
- func (m *ExecTaskStreamingResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExecTaskStreamingResponse) XXX_Merge(src proto.Message)
- func (m *ExecTaskStreamingResponse) XXX_Size() int
- func (m *ExecTaskStreamingResponse) XXX_Unmarshal(b []byte) error
- type ExitResult
- func (*ExitResult) Descriptor() ([]byte, []int)
- func (m *ExitResult) GetExitCode() int32
- func (m *ExitResult) GetOomKilled() bool
- func (m *ExitResult) GetSignal() int32
- func (*ExitResult) ProtoMessage()
- func (m *ExitResult) Reset()
- func (m *ExitResult) String() string
- func (m *ExitResult) XXX_DiscardUnknown()
- func (m *ExitResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExitResult) XXX_Merge(src proto.Message)
- func (m *ExitResult) XXX_Size() int
- func (m *ExitResult) XXX_Unmarshal(b []byte) error
- type FingerprintRequest
- func (*FingerprintRequest) Descriptor() ([]byte, []int)
- func (*FingerprintRequest) ProtoMessage()
- func (m *FingerprintRequest) Reset()
- func (m *FingerprintRequest) String() string
- func (m *FingerprintRequest) XXX_DiscardUnknown()
- func (m *FingerprintRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FingerprintRequest) XXX_Merge(src proto.Message)
- func (m *FingerprintRequest) XXX_Size() int
- func (m *FingerprintRequest) XXX_Unmarshal(b []byte) error
- type FingerprintResponse
- func (*FingerprintResponse) Descriptor() ([]byte, []int)
- func (m *FingerprintResponse) GetAttributes() map[string]*proto1.Attribute
- func (m *FingerprintResponse) GetHealth() FingerprintResponse_HealthState
- func (m *FingerprintResponse) GetHealthDescription() string
- func (*FingerprintResponse) ProtoMessage()
- func (m *FingerprintResponse) Reset()
- func (m *FingerprintResponse) String() string
- func (m *FingerprintResponse) XXX_DiscardUnknown()
- func (m *FingerprintResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FingerprintResponse) XXX_Merge(src proto.Message)
- func (m *FingerprintResponse) XXX_Size() int
- func (m *FingerprintResponse) XXX_Unmarshal(b []byte) error
- type FingerprintResponse_HealthState
- type HostsConfig
- func (*HostsConfig) Descriptor() ([]byte, []int)
- func (m *HostsConfig) GetAddress() string
- func (m *HostsConfig) GetHostname() string
- func (*HostsConfig) ProtoMessage()
- func (m *HostsConfig) Reset()
- func (m *HostsConfig) String() string
- func (m *HostsConfig) XXX_DiscardUnknown()
- func (m *HostsConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HostsConfig) XXX_Merge(src proto.Message)
- func (m *HostsConfig) XXX_Size() int
- func (m *HostsConfig) XXX_Unmarshal(b []byte) error
- type InspectTaskRequest
- func (*InspectTaskRequest) Descriptor() ([]byte, []int)
- func (m *InspectTaskRequest) GetTaskId() string
- func (*InspectTaskRequest) ProtoMessage()
- func (m *InspectTaskRequest) Reset()
- func (m *InspectTaskRequest) String() string
- func (m *InspectTaskRequest) XXX_DiscardUnknown()
- func (m *InspectTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InspectTaskRequest) XXX_Merge(src proto.Message)
- func (m *InspectTaskRequest) XXX_Size() int
- func (m *InspectTaskRequest) XXX_Unmarshal(b []byte) error
- type InspectTaskResponse
- func (*InspectTaskResponse) Descriptor() ([]byte, []int)
- func (m *InspectTaskResponse) GetDriver() *TaskDriverStatus
- func (m *InspectTaskResponse) GetNetworkOverride() *NetworkOverride
- func (m *InspectTaskResponse) GetTask() *TaskStatus
- func (*InspectTaskResponse) ProtoMessage()
- func (m *InspectTaskResponse) Reset()
- func (m *InspectTaskResponse) String() string
- func (m *InspectTaskResponse) XXX_DiscardUnknown()
- func (m *InspectTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InspectTaskResponse) XXX_Merge(src proto.Message)
- func (m *InspectTaskResponse) XXX_Size() int
- func (m *InspectTaskResponse) XXX_Unmarshal(b []byte) error
- type LinuxResources
- func (*LinuxResources) Descriptor() ([]byte, []int)
- func (m *LinuxResources) GetCpuPeriod() int64
- func (m *LinuxResources) GetCpuQuota() int64
- func (m *LinuxResources) GetCpuShares() int64
- func (m *LinuxResources) GetCpusetCgroup() string
- func (m *LinuxResources) GetCpusetCpus() string
- func (m *LinuxResources) GetMemoryLimitBytes() int64
- func (m *LinuxResources) GetOomScoreAdj() int64
- func (m *LinuxResources) GetPercentTicks() float64
- func (*LinuxResources) ProtoMessage()
- func (m *LinuxResources) Reset()
- func (m *LinuxResources) String() string
- func (m *LinuxResources) XXX_DiscardUnknown()
- func (m *LinuxResources) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LinuxResources) XXX_Merge(src proto.Message)
- func (m *LinuxResources) XXX_Size() int
- func (m *LinuxResources) XXX_Unmarshal(b []byte) error
- type MemoryUsage
- func (*MemoryUsage) Descriptor() ([]byte, []int)
- func (m *MemoryUsage) GetCache() uint64
- func (m *MemoryUsage) GetKernelMaxUsage() uint64
- func (m *MemoryUsage) GetKernelUsage() uint64
- func (m *MemoryUsage) GetMaxUsage() uint64
- func (m *MemoryUsage) GetMeasuredFields() []MemoryUsage_Fields
- func (m *MemoryUsage) GetRss() uint64
- func (m *MemoryUsage) GetSwap() uint64
- func (m *MemoryUsage) GetUsage() uint64
- func (*MemoryUsage) ProtoMessage()
- func (m *MemoryUsage) Reset()
- func (m *MemoryUsage) String() string
- func (m *MemoryUsage) XXX_DiscardUnknown()
- func (m *MemoryUsage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MemoryUsage) XXX_Merge(src proto.Message)
- func (m *MemoryUsage) XXX_Size() int
- func (m *MemoryUsage) XXX_Unmarshal(b []byte) error
- type MemoryUsage_Fields
- type Mount
- func (*Mount) Descriptor() ([]byte, []int)
- func (m *Mount) GetHostPath() string
- func (m *Mount) GetPropagationMode() string
- func (m *Mount) GetReadonly() bool
- func (m *Mount) GetTaskPath() string
- func (*Mount) ProtoMessage()
- func (m *Mount) Reset()
- func (m *Mount) String() string
- func (m *Mount) XXX_DiscardUnknown()
- func (m *Mount) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Mount) XXX_Merge(src proto.Message)
- func (m *Mount) XXX_Size() int
- func (m *Mount) XXX_Unmarshal(b []byte) error
- type NetworkIsolationSpec
- func (*NetworkIsolationSpec) Descriptor() ([]byte, []int)
- func (m *NetworkIsolationSpec) GetHostsConfig() *HostsConfig
- func (m *NetworkIsolationSpec) GetLabels() map[string]string
- func (m *NetworkIsolationSpec) GetMode() NetworkIsolationSpec_NetworkIsolationMode
- func (m *NetworkIsolationSpec) GetPath() string
- func (*NetworkIsolationSpec) ProtoMessage()
- func (m *NetworkIsolationSpec) Reset()
- func (m *NetworkIsolationSpec) String() string
- func (m *NetworkIsolationSpec) XXX_DiscardUnknown()
- func (m *NetworkIsolationSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NetworkIsolationSpec) XXX_Merge(src proto.Message)
- func (m *NetworkIsolationSpec) XXX_Size() int
- func (m *NetworkIsolationSpec) XXX_Unmarshal(b []byte) error
- type NetworkIsolationSpec_NetworkIsolationMode
- type NetworkOverride
- func (*NetworkOverride) Descriptor() ([]byte, []int)
- func (m *NetworkOverride) GetAddr() string
- func (m *NetworkOverride) GetAutoAdvertise() bool
- func (m *NetworkOverride) GetPortMap() map[string]int32
- func (*NetworkOverride) ProtoMessage()
- func (m *NetworkOverride) Reset()
- func (m *NetworkOverride) String() string
- func (m *NetworkOverride) XXX_DiscardUnknown()
- func (m *NetworkOverride) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NetworkOverride) XXX_Merge(src proto.Message)
- func (m *NetworkOverride) XXX_Size() int
- func (m *NetworkOverride) XXX_Unmarshal(b []byte) error
- type NetworkPort
- func (*NetworkPort) Descriptor() ([]byte, []int)
- func (m *NetworkPort) GetLabel() string
- func (m *NetworkPort) GetValue() int32
- func (*NetworkPort) ProtoMessage()
- func (m *NetworkPort) Reset()
- func (m *NetworkPort) String() string
- func (m *NetworkPort) XXX_DiscardUnknown()
- func (m *NetworkPort) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NetworkPort) XXX_Merge(src proto.Message)
- func (m *NetworkPort) XXX_Size() int
- func (m *NetworkPort) XXX_Unmarshal(b []byte) error
- type NetworkResource
- func (*NetworkResource) Descriptor() ([]byte, []int)
- func (m *NetworkResource) GetCidr() string
- func (m *NetworkResource) GetDevice() string
- func (m *NetworkResource) GetDynamicPorts() []*NetworkPort
- func (m *NetworkResource) GetIp() string
- func (m *NetworkResource) GetMbits() int32
- func (m *NetworkResource) GetReservedPorts() []*NetworkPort
- func (*NetworkResource) ProtoMessage()
- func (m *NetworkResource) Reset()
- func (m *NetworkResource) String() string
- func (m *NetworkResource) XXX_DiscardUnknown()
- func (m *NetworkResource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NetworkResource) XXX_Merge(src proto.Message)
- func (m *NetworkResource) XXX_Size() int
- func (m *NetworkResource) XXX_Unmarshal(b []byte) error
- type PortMapping
- func (*PortMapping) Descriptor() ([]byte, []int)
- func (m *PortMapping) GetHostIp() string
- func (m *PortMapping) GetLabel() string
- func (m *PortMapping) GetTo() int32
- func (m *PortMapping) GetValue() int32
- func (*PortMapping) ProtoMessage()
- func (m *PortMapping) Reset()
- func (m *PortMapping) String() string
- func (m *PortMapping) XXX_DiscardUnknown()
- func (m *PortMapping) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PortMapping) XXX_Merge(src proto.Message)
- func (m *PortMapping) XXX_Size() int
- func (m *PortMapping) XXX_Unmarshal(b []byte) error
- type RecoverTaskRequest
- func (*RecoverTaskRequest) Descriptor() ([]byte, []int)
- func (m *RecoverTaskRequest) GetHandle() *TaskHandle
- func (m *RecoverTaskRequest) GetTaskId() string
- func (*RecoverTaskRequest) ProtoMessage()
- func (m *RecoverTaskRequest) Reset()
- func (m *RecoverTaskRequest) String() string
- func (m *RecoverTaskRequest) XXX_DiscardUnknown()
- func (m *RecoverTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RecoverTaskRequest) XXX_Merge(src proto.Message)
- func (m *RecoverTaskRequest) XXX_Size() int
- func (m *RecoverTaskRequest) XXX_Unmarshal(b []byte) error
- type RecoverTaskResponse
- func (*RecoverTaskResponse) Descriptor() ([]byte, []int)
- func (*RecoverTaskResponse) ProtoMessage()
- func (m *RecoverTaskResponse) Reset()
- func (m *RecoverTaskResponse) String() string
- func (m *RecoverTaskResponse) XXX_DiscardUnknown()
- func (m *RecoverTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RecoverTaskResponse) XXX_Merge(src proto.Message)
- func (m *RecoverTaskResponse) XXX_Size() int
- func (m *RecoverTaskResponse) XXX_Unmarshal(b []byte) error
- type Resources
- func (*Resources) Descriptor() ([]byte, []int)
- func (m *Resources) GetAllocatedResources() *AllocatedTaskResources
- func (m *Resources) GetLinuxResources() *LinuxResources
- func (m *Resources) GetPorts() []*PortMapping
- func (*Resources) ProtoMessage()
- func (m *Resources) Reset()
- func (m *Resources) String() string
- func (m *Resources) XXX_DiscardUnknown()
- func (m *Resources) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Resources) XXX_Merge(src proto.Message)
- func (m *Resources) XXX_Size() int
- func (m *Resources) XXX_Unmarshal(b []byte) error
- type SignalTaskRequest
- func (*SignalTaskRequest) Descriptor() ([]byte, []int)
- func (m *SignalTaskRequest) GetSignal() string
- func (m *SignalTaskRequest) GetTaskId() string
- func (*SignalTaskRequest) ProtoMessage()
- func (m *SignalTaskRequest) Reset()
- func (m *SignalTaskRequest) String() string
- func (m *SignalTaskRequest) XXX_DiscardUnknown()
- func (m *SignalTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SignalTaskRequest) XXX_Merge(src proto.Message)
- func (m *SignalTaskRequest) XXX_Size() int
- func (m *SignalTaskRequest) XXX_Unmarshal(b []byte) error
- type SignalTaskResponse
- func (*SignalTaskResponse) Descriptor() ([]byte, []int)
- func (*SignalTaskResponse) ProtoMessage()
- func (m *SignalTaskResponse) Reset()
- func (m *SignalTaskResponse) String() string
- func (m *SignalTaskResponse) XXX_DiscardUnknown()
- func (m *SignalTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SignalTaskResponse) XXX_Merge(src proto.Message)
- func (m *SignalTaskResponse) XXX_Size() int
- func (m *SignalTaskResponse) XXX_Unmarshal(b []byte) error
- type StartTaskRequest
- func (*StartTaskRequest) Descriptor() ([]byte, []int)
- func (m *StartTaskRequest) GetTask() *TaskConfig
- func (*StartTaskRequest) ProtoMessage()
- func (m *StartTaskRequest) Reset()
- func (m *StartTaskRequest) String() string
- func (m *StartTaskRequest) XXX_DiscardUnknown()
- func (m *StartTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StartTaskRequest) XXX_Merge(src proto.Message)
- func (m *StartTaskRequest) XXX_Size() int
- func (m *StartTaskRequest) XXX_Unmarshal(b []byte) error
- type StartTaskResponse
- func (*StartTaskResponse) Descriptor() ([]byte, []int)
- func (m *StartTaskResponse) GetDriverErrorMsg() string
- func (m *StartTaskResponse) GetHandle() *TaskHandle
- func (m *StartTaskResponse) GetNetworkOverride() *NetworkOverride
- func (m *StartTaskResponse) GetResult() StartTaskResponse_Result
- func (*StartTaskResponse) ProtoMessage()
- func (m *StartTaskResponse) Reset()
- func (m *StartTaskResponse) String() string
- func (m *StartTaskResponse) XXX_DiscardUnknown()
- func (m *StartTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StartTaskResponse) XXX_Merge(src proto.Message)
- func (m *StartTaskResponse) XXX_Size() int
- func (m *StartTaskResponse) XXX_Unmarshal(b []byte) error
- type StartTaskResponse_Result
- type StopTaskRequest
- func (*StopTaskRequest) Descriptor() ([]byte, []int)
- func (m *StopTaskRequest) GetSignal() string
- func (m *StopTaskRequest) GetTaskId() string
- func (m *StopTaskRequest) GetTimeout() *duration.Duration
- func (*StopTaskRequest) ProtoMessage()
- func (m *StopTaskRequest) Reset()
- func (m *StopTaskRequest) String() string
- func (m *StopTaskRequest) XXX_DiscardUnknown()
- func (m *StopTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StopTaskRequest) XXX_Merge(src proto.Message)
- func (m *StopTaskRequest) XXX_Size() int
- func (m *StopTaskRequest) XXX_Unmarshal(b []byte) error
- type StopTaskResponse
- func (*StopTaskResponse) Descriptor() ([]byte, []int)
- func (*StopTaskResponse) ProtoMessage()
- func (m *StopTaskResponse) Reset()
- func (m *StopTaskResponse) String() string
- func (m *StopTaskResponse) XXX_DiscardUnknown()
- func (m *StopTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StopTaskResponse) XXX_Merge(src proto.Message)
- func (m *StopTaskResponse) XXX_Size() int
- func (m *StopTaskResponse) XXX_Unmarshal(b []byte) error
- type TaskConfig
- func (*TaskConfig) Descriptor() ([]byte, []int)
- func (m *TaskConfig) GetAllocDir() string
- func (m *TaskConfig) GetAllocId() string
- func (m *TaskConfig) GetDeviceEnv() map[string]string
- func (m *TaskConfig) GetDevices() []*Device
- func (m *TaskConfig) GetDns() *DNSConfig
- func (m *TaskConfig) GetEnv() map[string]string
- func (m *TaskConfig) GetId() string
- func (m *TaskConfig) GetJobName() string
- func (m *TaskConfig) GetMounts() []*Mount
- func (m *TaskConfig) GetMsgpackDriverConfig() []byte
- func (m *TaskConfig) GetName() string
- func (m *TaskConfig) GetNetworkIsolationSpec() *NetworkIsolationSpec
- func (m *TaskConfig) GetResources() *Resources
- func (m *TaskConfig) GetStderrPath() string
- func (m *TaskConfig) GetStdoutPath() string
- func (m *TaskConfig) GetTaskGroupName() string
- func (m *TaskConfig) GetUser() string
- func (*TaskConfig) ProtoMessage()
- func (m *TaskConfig) Reset()
- func (m *TaskConfig) String() string
- func (m *TaskConfig) XXX_DiscardUnknown()
- func (m *TaskConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TaskConfig) XXX_Merge(src proto.Message)
- func (m *TaskConfig) XXX_Size() int
- func (m *TaskConfig) XXX_Unmarshal(b []byte) error
- type TaskConfigSchemaRequest
- func (*TaskConfigSchemaRequest) Descriptor() ([]byte, []int)
- func (*TaskConfigSchemaRequest) ProtoMessage()
- func (m *TaskConfigSchemaRequest) Reset()
- func (m *TaskConfigSchemaRequest) String() string
- func (m *TaskConfigSchemaRequest) XXX_DiscardUnknown()
- func (m *TaskConfigSchemaRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TaskConfigSchemaRequest) XXX_Merge(src proto.Message)
- func (m *TaskConfigSchemaRequest) XXX_Size() int
- func (m *TaskConfigSchemaRequest) XXX_Unmarshal(b []byte) error
- type TaskConfigSchemaResponse
- func (*TaskConfigSchemaResponse) Descriptor() ([]byte, []int)
- func (m *TaskConfigSchemaResponse) GetSpec() *hclspec.Spec
- func (*TaskConfigSchemaResponse) ProtoMessage()
- func (m *TaskConfigSchemaResponse) Reset()
- func (m *TaskConfigSchemaResponse) String() string
- func (m *TaskConfigSchemaResponse) XXX_DiscardUnknown()
- func (m *TaskConfigSchemaResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TaskConfigSchemaResponse) XXX_Merge(src proto.Message)
- func (m *TaskConfigSchemaResponse) XXX_Size() int
- func (m *TaskConfigSchemaResponse) XXX_Unmarshal(b []byte) error
- type TaskDriverStatus
- func (*TaskDriverStatus) Descriptor() ([]byte, []int)
- func (m *TaskDriverStatus) GetAttributes() map[string]string
- func (*TaskDriverStatus) ProtoMessage()
- func (m *TaskDriverStatus) Reset()
- func (m *TaskDriverStatus) String() string
- func (m *TaskDriverStatus) XXX_DiscardUnknown()
- func (m *TaskDriverStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TaskDriverStatus) XXX_Merge(src proto.Message)
- func (m *TaskDriverStatus) XXX_Size() int
- func (m *TaskDriverStatus) XXX_Unmarshal(b []byte) error
- type TaskEventsRequest
- func (*TaskEventsRequest) Descriptor() ([]byte, []int)
- func (*TaskEventsRequest) ProtoMessage()
- func (m *TaskEventsRequest) Reset()
- func (m *TaskEventsRequest) String() string
- func (m *TaskEventsRequest) XXX_DiscardUnknown()
- func (m *TaskEventsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TaskEventsRequest) XXX_Merge(src proto.Message)
- func (m *TaskEventsRequest) XXX_Size() int
- func (m *TaskEventsRequest) XXX_Unmarshal(b []byte) error
- type TaskHandle
- func (*TaskHandle) Descriptor() ([]byte, []int)
- func (m *TaskHandle) GetConfig() *TaskConfig
- func (m *TaskHandle) GetDriverState() []byte
- func (m *TaskHandle) GetState() TaskState
- func (m *TaskHandle) GetVersion() int32
- func (*TaskHandle) ProtoMessage()
- func (m *TaskHandle) Reset()
- func (m *TaskHandle) String() string
- func (m *TaskHandle) XXX_DiscardUnknown()
- func (m *TaskHandle) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TaskHandle) XXX_Merge(src proto.Message)
- func (m *TaskHandle) XXX_Size() int
- func (m *TaskHandle) XXX_Unmarshal(b []byte) error
- type TaskResourceUsage
- func (*TaskResourceUsage) Descriptor() ([]byte, []int)
- func (m *TaskResourceUsage) GetCpu() *CPUUsage
- func (m *TaskResourceUsage) GetMemory() *MemoryUsage
- func (*TaskResourceUsage) ProtoMessage()
- func (m *TaskResourceUsage) Reset()
- func (m *TaskResourceUsage) String() string
- func (m *TaskResourceUsage) XXX_DiscardUnknown()
- func (m *TaskResourceUsage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TaskResourceUsage) XXX_Merge(src proto.Message)
- func (m *TaskResourceUsage) XXX_Size() int
- func (m *TaskResourceUsage) XXX_Unmarshal(b []byte) error
- type TaskState
- type TaskStats
- func (*TaskStats) Descriptor() ([]byte, []int)
- func (m *TaskStats) GetAggResourceUsage() *TaskResourceUsage
- func (m *TaskStats) GetId() string
- func (m *TaskStats) GetResourceUsageByPid() map[string]*TaskResourceUsage
- func (m *TaskStats) GetTimestamp() *timestamp.Timestamp
- func (*TaskStats) ProtoMessage()
- func (m *TaskStats) Reset()
- func (m *TaskStats) String() string
- func (m *TaskStats) XXX_DiscardUnknown()
- func (m *TaskStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TaskStats) XXX_Merge(src proto.Message)
- func (m *TaskStats) XXX_Size() int
- func (m *TaskStats) XXX_Unmarshal(b []byte) error
- type TaskStatsRequest
- func (*TaskStatsRequest) Descriptor() ([]byte, []int)
- func (m *TaskStatsRequest) GetCollectionInterval() *duration.Duration
- func (m *TaskStatsRequest) GetTaskId() string
- func (*TaskStatsRequest) ProtoMessage()
- func (m *TaskStatsRequest) Reset()
- func (m *TaskStatsRequest) String() string
- func (m *TaskStatsRequest) XXX_DiscardUnknown()
- func (m *TaskStatsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TaskStatsRequest) XXX_Merge(src proto.Message)
- func (m *TaskStatsRequest) XXX_Size() int
- func (m *TaskStatsRequest) XXX_Unmarshal(b []byte) error
- type TaskStatsResponse
- func (*TaskStatsResponse) Descriptor() ([]byte, []int)
- func (m *TaskStatsResponse) GetStats() *TaskStats
- func (*TaskStatsResponse) ProtoMessage()
- func (m *TaskStatsResponse) Reset()
- func (m *TaskStatsResponse) String() string
- func (m *TaskStatsResponse) XXX_DiscardUnknown()
- func (m *TaskStatsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TaskStatsResponse) XXX_Merge(src proto.Message)
- func (m *TaskStatsResponse) XXX_Size() int
- func (m *TaskStatsResponse) XXX_Unmarshal(b []byte) error
- type TaskStatus
- func (*TaskStatus) Descriptor() ([]byte, []int)
- func (m *TaskStatus) GetCompletedAt() *timestamp.Timestamp
- func (m *TaskStatus) GetId() string
- func (m *TaskStatus) GetName() string
- func (m *TaskStatus) GetResult() *ExitResult
- func (m *TaskStatus) GetStartedAt() *timestamp.Timestamp
- func (m *TaskStatus) GetState() TaskState
- func (*TaskStatus) ProtoMessage()
- func (m *TaskStatus) Reset()
- func (m *TaskStatus) String() string
- func (m *TaskStatus) XXX_DiscardUnknown()
- func (m *TaskStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TaskStatus) XXX_Merge(src proto.Message)
- func (m *TaskStatus) XXX_Size() int
- func (m *TaskStatus) XXX_Unmarshal(b []byte) error
- type UnimplementedDriverServer
- func (*UnimplementedDriverServer) Capabilities(ctx context.Context, req *CapabilitiesRequest) (*CapabilitiesResponse, error)
- func (*UnimplementedDriverServer) CreateNetwork(ctx context.Context, req *CreateNetworkRequest) (*CreateNetworkResponse, error)
- func (*UnimplementedDriverServer) DestroyNetwork(ctx context.Context, req *DestroyNetworkRequest) (*DestroyNetworkResponse, error)
- func (*UnimplementedDriverServer) DestroyTask(ctx context.Context, req *DestroyTaskRequest) (*DestroyTaskResponse, error)
- func (*UnimplementedDriverServer) ExecTask(ctx context.Context, req *ExecTaskRequest) (*ExecTaskResponse, error)
- func (*UnimplementedDriverServer) ExecTaskStreaming(srv Driver_ExecTaskStreamingServer) error
- func (*UnimplementedDriverServer) Fingerprint(req *FingerprintRequest, srv Driver_FingerprintServer) error
- func (*UnimplementedDriverServer) InspectTask(ctx context.Context, req *InspectTaskRequest) (*InspectTaskResponse, error)
- func (*UnimplementedDriverServer) RecoverTask(ctx context.Context, req *RecoverTaskRequest) (*RecoverTaskResponse, error)
- func (*UnimplementedDriverServer) SignalTask(ctx context.Context, req *SignalTaskRequest) (*SignalTaskResponse, error)
- func (*UnimplementedDriverServer) StartTask(ctx context.Context, req *StartTaskRequest) (*StartTaskResponse, error)
- func (*UnimplementedDriverServer) StopTask(ctx context.Context, req *StopTaskRequest) (*StopTaskResponse, error)
- func (*UnimplementedDriverServer) TaskConfigSchema(ctx context.Context, req *TaskConfigSchemaRequest) (*TaskConfigSchemaResponse, error)
- func (*UnimplementedDriverServer) TaskEvents(req *TaskEventsRequest, srv Driver_TaskEventsServer) error
- func (*UnimplementedDriverServer) TaskStats(req *TaskStatsRequest, srv Driver_TaskStatsServer) error
- func (*UnimplementedDriverServer) WaitTask(ctx context.Context, req *WaitTaskRequest) (*WaitTaskResponse, error)
- type WaitTaskRequest
- func (*WaitTaskRequest) Descriptor() ([]byte, []int)
- func (m *WaitTaskRequest) GetTaskId() string
- func (*WaitTaskRequest) ProtoMessage()
- func (m *WaitTaskRequest) Reset()
- func (m *WaitTaskRequest) String() string
- func (m *WaitTaskRequest) XXX_DiscardUnknown()
- func (m *WaitTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WaitTaskRequest) XXX_Merge(src proto.Message)
- func (m *WaitTaskRequest) XXX_Size() int
- func (m *WaitTaskRequest) XXX_Unmarshal(b []byte) error
- type WaitTaskResponse
- func (*WaitTaskResponse) Descriptor() ([]byte, []int)
- func (m *WaitTaskResponse) GetErr() string
- func (m *WaitTaskResponse) GetResult() *ExitResult
- func (*WaitTaskResponse) ProtoMessage()
- func (m *WaitTaskResponse) Reset()
- func (m *WaitTaskResponse) String() string
- func (m *WaitTaskResponse) XXX_DiscardUnknown()
- func (m *WaitTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WaitTaskResponse) XXX_Merge(src proto.Message)
- func (m *WaitTaskResponse) XXX_Size() int
- func (m *WaitTaskResponse) XXX_Unmarshal(b []byte) error
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 { 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"` MemoryMaxMb int64 `protobuf:"varint,3,opt,name=memory_max_mb,json=memoryMaxMb,proto3" json:"memory_max_mb,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*AllocatedMemoryResources) Descriptor ¶
func (*AllocatedMemoryResources) Descriptor() ([]byte, []int)
func (*AllocatedMemoryResources) GetMemoryMaxMb ¶
func (m *AllocatedMemoryResources) GetMemoryMaxMb() int64
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 (m *AllocatedTaskResources) GetCpu() *AllocatedCpuResources
func (*AllocatedTaskResources) GetMemory ¶
func (m *AllocatedTaskResources) GetMemory() *AllocatedMemoryResources
func (*AllocatedTaskResources) GetNetworks ¶
func (m *AllocatedTaskResources) GetNetworks() []*NetworkResource
func (*AllocatedTaskResources) ProtoMessage ¶
func (*AllocatedTaskResources) ProtoMessage()
func (*AllocatedTaskResources) Reset ¶
func (m *AllocatedTaskResources) Reset()
func (*AllocatedTaskResources) String ¶
func (m *AllocatedTaskResources) String() string
func (*AllocatedTaskResources) XXX_DiscardUnknown ¶
func (m *AllocatedTaskResources) XXX_DiscardUnknown()
func (*AllocatedTaskResources) XXX_Marshal ¶
func (m *AllocatedTaskResources) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AllocatedTaskResources) XXX_Merge ¶
func (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) GetMeasuredFields ¶
func (m *CPUUsage) GetMeasuredFields() []CPUUsage_Fields
func (*CPUUsage) GetPercent ¶
func (*CPUUsage) GetSystemMode ¶
func (*CPUUsage) GetThrottledPeriods ¶
func (*CPUUsage) GetThrottledTime ¶
func (*CPUUsage) GetTotalTicks ¶
func (*CPUUsage) GetUserMode ¶
func (*CPUUsage) ProtoMessage ¶
func (*CPUUsage) ProtoMessage()
func (*CPUUsage) XXX_DiscardUnknown ¶
func (m *CPUUsage) XXX_DiscardUnknown()
func (*CPUUsage) XXX_Marshal ¶
func (*CPUUsage) XXX_Unmarshal ¶
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"` // Hostname of the network namespace Hostname string `protobuf:"bytes,2,opt,name=hostname,proto3" json:"hostname,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) GetHostname ¶
func (m *CreateNetworkRequest) GetHostname() 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) GetOptions ¶
func (*DNSConfig) GetSearches ¶
func (*DNSConfig) GetServers ¶
func (*DNSConfig) ProtoMessage ¶
func (*DNSConfig) ProtoMessage()
func (*DNSConfig) XXX_DiscardUnknown ¶
func (m *DNSConfig) XXX_DiscardUnknown()
func (*DNSConfig) XXX_Marshal ¶
func (*DNSConfig) XXX_Unmarshal ¶
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) GetCgroupPermissions ¶
func (*Device) GetHostPath ¶
func (*Device) GetTaskPath ¶
func (*Device) ProtoMessage ¶
func (*Device) ProtoMessage()
func (*Device) XXX_DiscardUnknown ¶
func (m *Device) XXX_DiscardUnknown()
func (*Device) XXX_Marshal ¶
func (*Device) XXX_Unmarshal ¶
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 */ // remote_tasks indicates whether the driver executes tasks remotely such // on cloud runtimes like AWS ECS. RemoteTasks bool `protobuf:"varint,7,opt,name=remote_tasks,json=remoteTasks,proto3" json:"remote_tasks,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DriverCapabilities) Descriptor ¶
func (*DriverCapabilities) Descriptor() ([]byte, []int)
func (*DriverCapabilities) GetExec ¶
func (m *DriverCapabilities) GetExec() bool
func (*DriverCapabilities) GetFsIsolation ¶
func (m *DriverCapabilities) GetFsIsolation() DriverCapabilities_FSIsolation
func (*DriverCapabilities) GetMountConfigs ¶
func (m *DriverCapabilities) GetMountConfigs() DriverCapabilities_MountConfigs
func (*DriverCapabilities) GetMustCreateNetwork ¶
func (m *DriverCapabilities) GetMustCreateNetwork() bool
func (*DriverCapabilities) GetNetworkIsolationModes ¶
func (m *DriverCapabilities) GetNetworkIsolationModes() []NetworkIsolationSpec_NetworkIsolationMode
func (*DriverCapabilities) GetRemoteTasks ¶
func (m *DriverCapabilities) GetRemoteTasks() bool
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 ¶
func (x DriverCapabilities_FSIsolation) String() 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 ¶
func (x DriverCapabilities_MountConfigs) String() string
type DriverClient ¶
type DriverClient interface { // TaskConfigSchema returns the schema for parsing the driver // configuration of a task. TaskConfigSchema(ctx context.Context, in *TaskConfigSchemaRequest, opts ...grpc.CallOption) (*TaskConfigSchemaResponse, error) // Capabilities returns a set of features which the driver implements. Some // RPCs are not possible to implement on some runtimes, this allows the // driver to indicate if it doesn't support these RPCs and features. Capabilities(ctx context.Context, in *CapabilitiesRequest, opts ...grpc.CallOption) (*CapabilitiesResponse, error) // Fingerprint starts a stream which emits information about the driver // including whether the driver healthy and able to function in the // existing environment. // // The driver should immediately stream a FingerprintResponse when the RPC // is initially called, then send any additional responses if there is a // change in the driver's state. Fingerprint(ctx context.Context, in *FingerprintRequest, opts ...grpc.CallOption) (Driver_FingerprintClient, error) // RecoverTask is used when a task has been started but the driver may not // know about it. Such is the case if the driver restarts or is upgraded. RecoverTask(ctx context.Context, in *RecoverTaskRequest, opts ...grpc.CallOption) (*RecoverTaskResponse, error) // StartTask starts and tracks the task on the implemented runtime StartTask(ctx context.Context, in *StartTaskRequest, opts ...grpc.CallOption) (*StartTaskResponse, error) // WaitTask blocks until the given task exits, returning the result of the // task. It may be called after the task has exited, but before the task is // destroyed. WaitTask(ctx context.Context, in *WaitTaskRequest, opts ...grpc.CallOption) (*WaitTaskResponse, error) // StopTask stops a given task by sending the desired signal to the process. // If the task does not exit on its own within the given timeout, it will be // forcefully killed. StopTask(ctx context.Context, in *StopTaskRequest, opts ...grpc.CallOption) (*StopTaskResponse, error) // DestroyTask removes the task from the driver's internal state and cleans // up any additional resources created by the driver. It cannot be called // on a running task, unless force is set to true. DestroyTask(ctx context.Context, in *DestroyTaskRequest, opts ...grpc.CallOption) (*DestroyTaskResponse, error) // InspectTask returns detailed information for the given task InspectTask(ctx context.Context, in *InspectTaskRequest, opts ...grpc.CallOption) (*InspectTaskResponse, error) // TaskStats collects and returns runtime metrics for the given task TaskStats(ctx context.Context, in *TaskStatsRequest, opts ...grpc.CallOption) (Driver_TaskStatsClient, error) // TaskEvents starts a streaming RPC where all task events emitted by the // driver are streamed to the caller. TaskEvents(ctx context.Context, in *TaskEventsRequest, opts ...grpc.CallOption) (Driver_TaskEventsClient, error) // SignalTask sends a signal to the task SignalTask(ctx context.Context, in *SignalTaskRequest, opts ...grpc.CallOption) (*SignalTaskResponse, error) // ExecTask executes a command inside the tasks execution context ExecTask(ctx context.Context, in *ExecTaskRequest, opts ...grpc.CallOption) (*ExecTaskResponse, error) // ExecTaskStreaming executes a command inside the tasks execution context // and streams back results // 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 (m *ExecTaskStreamingIOOperation) String() 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 (m *ExecTaskStreamingRequest) GetSetup() *ExecTaskStreamingRequest_Setup
func (*ExecTaskStreamingRequest) GetStdin ¶
func (m *ExecTaskStreamingRequest) GetStdin() *ExecTaskStreamingIOOperation
func (*ExecTaskStreamingRequest) GetTtySize ¶
func (m *ExecTaskStreamingRequest) GetTtySize() *ExecTaskStreamingRequest_TerminalSize
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 (m *ExecTaskStreamingRequest_Setup) GetTty() bool
func (*ExecTaskStreamingRequest_Setup) ProtoMessage ¶
func (*ExecTaskStreamingRequest_Setup) ProtoMessage()
func (*ExecTaskStreamingRequest_Setup) Reset ¶
func (m *ExecTaskStreamingRequest_Setup) Reset()
func (*ExecTaskStreamingRequest_Setup) String ¶
func (m *ExecTaskStreamingRequest_Setup) String() 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 (m *ExecTaskStreamingRequest_TerminalSize) GetHeight() int32
func (*ExecTaskStreamingRequest_TerminalSize) GetWidth ¶
func (m *ExecTaskStreamingRequest_TerminalSize) GetWidth() int32
func (*ExecTaskStreamingRequest_TerminalSize) ProtoMessage ¶
func (*ExecTaskStreamingRequest_TerminalSize) ProtoMessage()
func (*ExecTaskStreamingRequest_TerminalSize) Reset ¶
func (m *ExecTaskStreamingRequest_TerminalSize) Reset()
func (*ExecTaskStreamingRequest_TerminalSize) String ¶
func (m *ExecTaskStreamingRequest_TerminalSize) String() 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 (m *ExecTaskStreamingRequest_TerminalSize) XXX_Merge(src proto.Message)
func (*ExecTaskStreamingRequest_TerminalSize) XXX_Size ¶
func (m *ExecTaskStreamingRequest_TerminalSize) XXX_Size() int
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 (m *ExecTaskStreamingResponse) GetStderr() *ExecTaskStreamingIOOperation
func (*ExecTaskStreamingResponse) GetStdout ¶
func (m *ExecTaskStreamingResponse) GetStdout() *ExecTaskStreamingIOOperation
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 (m *FingerprintResponse) GetHealth() FingerprintResponse_HealthState
func (*FingerprintResponse) GetHealthDescription ¶
func (m *FingerprintResponse) GetHealthDescription() string
func (*FingerprintResponse) ProtoMessage ¶
func (*FingerprintResponse) ProtoMessage()
func (*FingerprintResponse) Reset ¶
func (m *FingerprintResponse) Reset()
func (*FingerprintResponse) String ¶
func (m *FingerprintResponse) String() string
func (*FingerprintResponse) XXX_DiscardUnknown ¶
func (m *FingerprintResponse) XXX_DiscardUnknown()
func (*FingerprintResponse) XXX_Marshal ¶
func (m *FingerprintResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FingerprintResponse) XXX_Merge ¶
func (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 ¶
func (x FingerprintResponse_HealthState) String() string
type HostsConfig ¶
type HostsConfig struct { Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"` Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*HostsConfig) Descriptor ¶
func (*HostsConfig) Descriptor() ([]byte, []int)
func (*HostsConfig) GetAddress ¶
func (m *HostsConfig) GetAddress() string
func (*HostsConfig) GetHostname ¶
func (m *HostsConfig) GetHostname() string
func (*HostsConfig) ProtoMessage ¶
func (*HostsConfig) ProtoMessage()
func (*HostsConfig) Reset ¶
func (m *HostsConfig) Reset()
func (*HostsConfig) String ¶
func (m *HostsConfig) String() string
func (*HostsConfig) XXX_DiscardUnknown ¶
func (m *HostsConfig) XXX_DiscardUnknown()
func (*HostsConfig) XXX_Marshal ¶
func (m *HostsConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HostsConfig) XXX_Merge ¶
func (m *HostsConfig) XXX_Merge(src proto.Message)
func (*HostsConfig) XXX_Size ¶
func (m *HostsConfig) XXX_Size() int
func (*HostsConfig) XXX_Unmarshal ¶
func (m *HostsConfig) XXX_Unmarshal(b []byte) error
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"` 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) // This field exists to support drivers which can't set a cgroup path. CpusetCpus string `protobuf:"bytes,6,opt,name=cpuset_cpus,json=cpusetCpus,proto3" json:"cpuset_cpus,omitempty"` // CpusetCgroup is the path to the cpuset cgroup managed by the client CpusetCgroup string `protobuf:"bytes,9,opt,name=cpuset_cgroup,json=cpusetCgroup,proto3" json:"cpuset_cgroup,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) GetCpusetCgroup ¶
func (m *LinuxResources) GetCpusetCgroup() string
func (*LinuxResources) GetCpusetCpus ¶
func (m *LinuxResources) GetCpusetCpus() 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"` // Propagation mode for the mount. Not exactly the same as the unix mount // propagation flags. See callsite usage for details. PropagationMode string `protobuf:"bytes,4,opt,name=propagation_mode,json=propagationMode,proto3" json:"propagation_mode,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Mount) Descriptor ¶
func (*Mount) GetHostPath ¶
func (*Mount) GetPropagationMode ¶
func (*Mount) GetReadonly ¶
func (*Mount) GetTaskPath ¶
func (*Mount) ProtoMessage ¶
func (*Mount) ProtoMessage()
func (*Mount) XXX_DiscardUnknown ¶
func (m *Mount) XXX_DiscardUnknown()
func (*Mount) XXX_Marshal ¶
func (*Mount) XXX_Unmarshal ¶
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 */ HostsConfig *HostsConfig `protobuf:"bytes,4,opt,name=hostsConfig,proto3" json:"hostsConfig,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NetworkIsolationSpec) Descriptor ¶
func (*NetworkIsolationSpec) Descriptor() ([]byte, []int)
func (*NetworkIsolationSpec) GetHostsConfig ¶
func (m *NetworkIsolationSpec) GetHostsConfig() *HostsConfig
func (*NetworkIsolationSpec) GetLabels ¶
func (m *NetworkIsolationSpec) GetLabels() map[string]string
func (*NetworkIsolationSpec) GetMode ¶
func (m *NetworkIsolationSpec) GetMode() NetworkIsolationSpec_NetworkIsolationMode
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 ¶
func (x NetworkIsolationSpec_NetworkIsolationMode) String() 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) 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) XXX_DiscardUnknown ¶
func (m *Resources) XXX_DiscardUnknown()
func (*Resources) XXX_Marshal ¶
func (*Resources) XXX_Unmarshal ¶
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 (m *StartTaskResponse) GetResult() StartTaskResponse_Result
func (*StartTaskResponse) ProtoMessage ¶
func (*StartTaskResponse) ProtoMessage()
func (*StartTaskResponse) Reset ¶
func (m *StartTaskResponse) Reset()
func (*StartTaskResponse) String ¶
func (m *StartTaskResponse) String() string
func (*StartTaskResponse) XXX_DiscardUnknown ¶
func (m *StartTaskResponse) XXX_DiscardUnknown()
func (*StartTaskResponse) XXX_Marshal ¶
func (m *StartTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StartTaskResponse) XXX_Merge ¶
func (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 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) GetAggResourceUsage ¶
func (m *TaskStats) GetAggResourceUsage() *TaskResourceUsage
func (*TaskStats) GetResourceUsageByPid ¶
func (m *TaskStats) GetResourceUsageByPid() map[string]*TaskResourceUsage
func (*TaskStats) GetTimestamp ¶
func (*TaskStats) ProtoMessage ¶
func (*TaskStats) ProtoMessage()
func (*TaskStats) XXX_DiscardUnknown ¶
func (m *TaskStats) XXX_DiscardUnknown()
func (*TaskStats) XXX_Marshal ¶
func (*TaskStats) XXX_Unmarshal ¶
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) Capabilities(ctx context.Context, req *CapabilitiesRequest) (*CapabilitiesResponse, error)
func (*UnimplementedDriverServer) CreateNetwork ¶
func (*UnimplementedDriverServer) CreateNetwork(ctx context.Context, req *CreateNetworkRequest) (*CreateNetworkResponse, error)
func (*UnimplementedDriverServer) DestroyNetwork ¶
func (*UnimplementedDriverServer) DestroyNetwork(ctx context.Context, req *DestroyNetworkRequest) (*DestroyNetworkResponse, error)
func (*UnimplementedDriverServer) DestroyTask ¶
func (*UnimplementedDriverServer) DestroyTask(ctx context.Context, req *DestroyTaskRequest) (*DestroyTaskResponse, error)
func (*UnimplementedDriverServer) ExecTask ¶
func (*UnimplementedDriverServer) ExecTask(ctx context.Context, req *ExecTaskRequest) (*ExecTaskResponse, error)
func (*UnimplementedDriverServer) ExecTaskStreaming ¶
func (*UnimplementedDriverServer) ExecTaskStreaming(srv Driver_ExecTaskStreamingServer) error
func (*UnimplementedDriverServer) Fingerprint ¶
func (*UnimplementedDriverServer) Fingerprint(req *FingerprintRequest, srv Driver_FingerprintServer) error
func (*UnimplementedDriverServer) InspectTask ¶
func (*UnimplementedDriverServer) InspectTask(ctx context.Context, req *InspectTaskRequest) (*InspectTaskResponse, error)
func (*UnimplementedDriverServer) RecoverTask ¶
func (*UnimplementedDriverServer) RecoverTask(ctx context.Context, req *RecoverTaskRequest) (*RecoverTaskResponse, error)
func (*UnimplementedDriverServer) SignalTask ¶
func (*UnimplementedDriverServer) SignalTask(ctx context.Context, req *SignalTaskRequest) (*SignalTaskResponse, error)
func (*UnimplementedDriverServer) StartTask ¶
func (*UnimplementedDriverServer) StartTask(ctx context.Context, req *StartTaskRequest) (*StartTaskResponse, error)
func (*UnimplementedDriverServer) StopTask ¶
func (*UnimplementedDriverServer) StopTask(ctx context.Context, req *StopTaskRequest) (*StopTaskResponse, error)
func (*UnimplementedDriverServer) TaskConfigSchema ¶
func (*UnimplementedDriverServer) TaskConfigSchema(ctx context.Context, req *TaskConfigSchemaRequest) (*TaskConfigSchemaResponse, error)
func (*UnimplementedDriverServer) TaskEvents ¶
func (*UnimplementedDriverServer) TaskEvents(req *TaskEventsRequest, srv Driver_TaskEventsServer) error
func (*UnimplementedDriverServer) TaskStats ¶
func (*UnimplementedDriverServer) TaskStats(req *TaskStatsRequest, srv Driver_TaskStatsServer) error
func (*UnimplementedDriverServer) WaitTask ¶
func (*UnimplementedDriverServer) WaitTask(ctx context.Context, req *WaitTaskRequest) (*WaitTaskResponse, error)
type WaitTaskRequest ¶
type WaitTaskRequest struct { // TaskId is the ID of the target task TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*WaitTaskRequest) Descriptor ¶
func (*WaitTaskRequest) Descriptor() ([]byte, []int)
func (*WaitTaskRequest) GetTaskId ¶
func (m *WaitTaskRequest) GetTaskId() string
func (*WaitTaskRequest) ProtoMessage ¶
func (*WaitTaskRequest) ProtoMessage()
func (*WaitTaskRequest) Reset ¶
func (m *WaitTaskRequest) Reset()
func (*WaitTaskRequest) String ¶
func (m *WaitTaskRequest) String() string
func (*WaitTaskRequest) XXX_DiscardUnknown ¶
func (m *WaitTaskRequest) XXX_DiscardUnknown()
func (*WaitTaskRequest) XXX_Marshal ¶
func (m *WaitTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*WaitTaskRequest) XXX_Merge ¶
func (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
Click to show internal directories.
Click to hide internal directories.