taskv1

package
v0.0.0-...-3511abf Latest Latest
Warning

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

 Go to latest Published: Nov 2, 2023 License: Apache-2.0 Imports: 8 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		3: "STATE_PULLING",
		4: "STATE_STARTING",
		5: "STATE_RUNNING",
		6: "STATE_TERMINATED",
		7: "STATE_TERMINATING",
		9: "STATE_WAITING",
		8: "STATE_QUEUED",
	}
	State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"STATE_PULLING":     3,
		"STATE_STARTING":    4,
		"STATE_RUNNING":     5,
		"STATE_TERMINATED":  6,
		"STATE_TERMINATING": 7,
		"STATE_WAITING":     9,
		"STATE_QUEUED":      8,
	}
)

Enum value maps for State.

View Source 
var (
	TaskType_name = map[int32]string{
		0: "TASK_TYPE_UNSPECIFIED",
		1: "TASK_TYPE_TRIAL",
		2: "TASK_TYPE_NOTEBOOK",
		3: "TASK_TYPE_SHELL",
		4: "TASK_TYPE_COMMAND",
		5: "TASK_TYPE_TENSORBOARD",
		6: "TASK_TYPE_CHECKPOINT_GC",
	}
	TaskType_value = map[string]int32{
		"TASK_TYPE_UNSPECIFIED":   0,
		"TASK_TYPE_TRIAL":         1,
		"TASK_TYPE_NOTEBOOK":      2,
		"TASK_TYPE_SHELL":         3,
		"TASK_TYPE_COMMAND":       4,
		"TASK_TYPE_TENSORBOARD":   5,
		"TASK_TYPE_CHECKPOINT_GC": 6,
	}
)

Enum value maps for TaskType.

View Source 
var (
	FailureType_name = map[int32]string{
		0: "FAILURE_TYPE_UNSPECIFIED",
		1: "FAILURE_TYPE_RESOURCES_FAILED",
		2: "FAILURE_TYPE_RESOURCES_ABORTED",
		3: "FAILURE_TYPE_RESOURCES_MISSING",
		4: "FAILURE_TYPE_TASK_ABORTED",
		5: "FAILURE_TYPE_TASK_ERROR",
		6: "FAILURE_TYPE_AGENT_FAILED",
		7: "FAILURE_TYPE_AGENT_ERROR",
		8: "FAILURE_TYPE_RESTORE_ERROR",
		9: "FAILURE_TYPE_UNKNOWN_ERROR",
	}
	FailureType_value = map[string]int32{
		"FAILURE_TYPE_UNSPECIFIED":       0,
		"FAILURE_TYPE_RESOURCES_FAILED":  1,
		"FAILURE_TYPE_RESOURCES_ABORTED": 2,
		"FAILURE_TYPE_RESOURCES_MISSING": 3,
		"FAILURE_TYPE_TASK_ABORTED":      4,
		"FAILURE_TYPE_TASK_ERROR":        5,
		"FAILURE_TYPE_AGENT_FAILED":      6,
		"FAILURE_TYPE_AGENT_ERROR":       7,
		"FAILURE_TYPE_RESTORE_ERROR":     8,
		"FAILURE_TYPE_UNKNOWN_ERROR":     9,
	}
)

Enum value maps for FailureType.

View Source 
var File_determined_task_v1_task_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Address 

type Address struct {

	// ContainerIP is the IP address from inside the container.
	ContainerIp string `protobuf:"bytes,1,opt,name=container_ip,json=containerIp,proto3" json:"container_ip,omitempty"`
	// ContainerPort is the port from inside the container.
	ContainerPort int32 `protobuf:"varint,2,opt,name=container_port,json=containerPort,proto3" json:"container_port,omitempty"`
	// HostIP is the IP address from outside the container. This can be
	// different than the ContainerIP because of network forwarding on the host
	// machine.
	HostIp string `protobuf:"bytes,3,opt,name=host_ip,json=hostIp,proto3" json:"host_ip,omitempty"`
	// HostPort is the IP port from outside the container. This can be different
	// than the ContainerPort because of network forwarding on the host machine.
	HostPort int32 `protobuf:"varint,4,opt,name=host_port,json=hostPort,proto3" json:"host_port,omitempty"`
	// contains filtered or unexported fields
}

Address represents an exposed port on a container.

func (*Address) Descriptor deprecated 

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

Deprecated: Use Address.ProtoReflect.Descriptor instead.

func (*Address) GetContainerIp 

func (x *Address) GetContainerIp() string

func (*Address) GetContainerPort 

func (x *Address) GetContainerPort() int32

func (*Address) GetHostIp 

func (x *Address) GetHostIp() string

func (*Address) GetHostPort 

func (x *Address) GetHostPort() int32

func (*Address) ProtoMessage 

func (*Address) ProtoMessage()

func (*Address) ProtoReflect 

func (x *Address) ProtoReflect() protoreflect.Message

func (*Address) Reset 

func (x *Address) Reset()

func (*Address) String 

func (x *Address) String() string

type Allocation 

type Allocation struct {

	// Unique ID of task associated with the allocation.
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// The current state of the allocation.
	State State `protobuf:"varint,2,opt,name=state,proto3,enum=determined.task.v1.State" json:"state,omitempty"`
	// Whether the allocation is ready to access.
	IsReady *bool `protobuf:"varint,3,opt,name=is_ready,json=isReady,proto3,oneof" json:"is_ready,omitempty"`
	// Start timestamp.
	StartTime *string `protobuf:"bytes,4,opt,name=start_time,json=startTime,proto3,oneof" json:"start_time,omitempty"`
	// End timestamp if completed.
	EndTime *string `protobuf:"bytes,5,opt,name=end_time,json=endTime,proto3,oneof" json:"end_time,omitempty"`
	// Unique ID of the allocation.
	AllocationId string `protobuf:"bytes,6,opt,name=allocation_id,json=allocationId,proto3" json:"allocation_id,omitempty"`
	// The number of slots associated with the allocation.
	Slots int32 `protobuf:"varint,7,opt,name=slots,proto3" json:"slots,omitempty"`
	// The exit reason for the allocation.
	ExitReason *string `protobuf:"bytes,8,opt,name=exit_reason,json=exitReason,proto3,oneof" json:"exit_reason,omitempty"`
	// The status code the allocation exits with.
	StatusCode *int32 `protobuf:"varint,9,opt,name=status_code,json=statusCode,proto3,oneof" json:"status_code,omitempty"`
	// contains filtered or unexported fields
}

Allocation tracks a specific instance of a Task.

func (*Allocation) Descriptor deprecated 

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

Deprecated: Use Allocation.ProtoReflect.Descriptor instead.

func (*Allocation) GetAllocationId 

func (x *Allocation) GetAllocationId() string

func (*Allocation) GetEndTime 

func (x *Allocation) GetEndTime() string

func (*Allocation) GetExitReason 

func (x *Allocation) GetExitReason() string

func (*Allocation) GetIsReady 

func (x *Allocation) GetIsReady() bool

func (*Allocation) GetSlots 

func (x *Allocation) GetSlots() int32

func (*Allocation) GetStartTime 

func (x *Allocation) GetStartTime() string

func (*Allocation) GetState 

func (x *Allocation) GetState() State

func (*Allocation) GetStatusCode 

func (x *Allocation) GetStatusCode() int32

func (*Allocation) GetTaskId 

func (x *Allocation) GetTaskId() string

func (*Allocation) ProtoMessage 

func (*Allocation) ProtoMessage()

func (*Allocation) ProtoReflect 

func (x *Allocation) ProtoReflect() protoreflect.Message

func (*Allocation) Reset 

func (x *Allocation) Reset()

func (*Allocation) String 

func (x *Allocation) String() string

type AllocationSummary 

type AllocationSummary struct {

	// TaskID is the unique ID of a task among all tasks.
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// AllocationID is the ID of an allocation of a task. It is usually of the
	// form TaskID.allocation_number, maybe with some other metadata if different
	// types of allocations run.
	AllocationId string `protobuf:"bytes,2,opt,name=allocation_id,json=allocationId,proto3" json:"allocation_id,omitempty"`
	// The name of the task.
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// The registered time of the task.
	RegisteredTime *timestamp.Timestamp `protobuf:"bytes,4,opt,name=registered_time,json=registeredTime,proto3" json:"registered_time,omitempty"`
	// The name of the resource pool.
	ResourcePool string `protobuf:"bytes,5,opt,name=resource_pool,json=resourcePool,proto3" json:"resource_pool,omitempty"`
	// The number of slots that are needed.
	SlotsNeeded int32 `protobuf:"varint,6,opt,name=slots_needed,json=slotsNeeded,proto3" json:"slots_needed,omitempty"`
	// ResourcesSummary provides a summary of the resources comprising what we
	// know at the time the allocation is granted.
	Resources []*ResourcesSummary `protobuf:"bytes,7,rep,name=resources,proto3" json:"resources,omitempty"`
	// The type of the scheduler. Either 'FAIR_SHARE', 'PRIORITY', or
	// 'ROUND_ROBIN'.
	SchedulerType string `protobuf:"bytes,8,opt,name=scheduler_type,json=schedulerType,proto3" json:"scheduler_type,omitempty"`
	// THe priority of the task.
	Priority *int32 `protobuf:"varint,9,opt,name=priority,proto3,oneof" json:"priority,omitempty"`
	// ProxyPortConfig configures a proxy the allocation should start.
	ProxyPorts []*ProxyPortConfig `protobuf:"bytes,10,rep,name=proxy_ports,json=proxyPorts,proto3" json:"proxy_ports,omitempty"`
	// contains filtered or unexported fields
}

AllocationSummary contains information about a task for external display.

func (*AllocationSummary) Descriptor deprecated 

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

Deprecated: Use AllocationSummary.ProtoReflect.Descriptor instead.

func (*AllocationSummary) GetAllocationId 

func (x *AllocationSummary) GetAllocationId() string

func (*AllocationSummary) GetName 

func (x *AllocationSummary) GetName() string

func (*AllocationSummary) GetPriority 

func (x *AllocationSummary) GetPriority() int32

func (*AllocationSummary) GetProxyPorts 

func (x *AllocationSummary) GetProxyPorts() []*ProxyPortConfig

func (*AllocationSummary) GetRegisteredTime 

func (x *AllocationSummary) GetRegisteredTime() *timestamp.Timestamp

func (*AllocationSummary) GetResourcePool 

func (x *AllocationSummary) GetResourcePool() string

func (*AllocationSummary) GetResources 

func (x *AllocationSummary) GetResources() []*ResourcesSummary

func (*AllocationSummary) GetSchedulerType 

func (x *AllocationSummary) GetSchedulerType() string

func (*AllocationSummary) GetSlotsNeeded 

func (x *AllocationSummary) GetSlotsNeeded() int32

func (*AllocationSummary) GetTaskId 

func (x *AllocationSummary) GetTaskId() string

func (*AllocationSummary) ProtoMessage 

func (*AllocationSummary) ProtoMessage()

func (*AllocationSummary) ProtoReflect 

func (x *AllocationSummary) ProtoReflect() protoreflect.Message

func (*AllocationSummary) Reset 

func (x *AllocationSummary) Reset()

func (*AllocationSummary) String 

func (x *AllocationSummary) String() string

type FailureType 

type FailureType int32

The failure type of a resource. 

const (
	// UNSPECIFIED denotes an error that is not defined below.
	FailureType_FAILURE_TYPE_UNSPECIFIED FailureType = 0
	// ResourcesFailed denotes that the container ran but failed with a non-zero
	// exit code.
	FailureType_FAILURE_TYPE_RESOURCES_FAILED FailureType = 1
	// ResourcesAborted denotes the container was canceled before it was started.
	FailureType_FAILURE_TYPE_RESOURCES_ABORTED FailureType = 2
	// ResourcesMissing denotes the resources were missing when the master asked
	// about it.
	FailureType_FAILURE_TYPE_RESOURCES_MISSING FailureType = 3
	// TaskAborted denotes that the task was canceled before it was started.
	FailureType_FAILURE_TYPE_TASK_ABORTED FailureType = 4
	// TaskError denotes that the task failed without an associated exit code.
	FailureType_FAILURE_TYPE_TASK_ERROR FailureType = 5
	// AgentFailed denotes that the agent failed while the container was running.
	FailureType_FAILURE_TYPE_AGENT_FAILED FailureType = 6
	// AgentError denotes that the agent failed to launch the container.
	FailureType_FAILURE_TYPE_AGENT_ERROR FailureType = 7
	// RestoreError denotes a failure to restore a running allocation on master
	// blip.
	FailureType_FAILURE_TYPE_RESTORE_ERROR FailureType = 8
	// UnknownError denotes an internal error that did not map to a know failure
	// type.
	FailureType_FAILURE_TYPE_UNKNOWN_ERROR FailureType = 9
)

func (FailureType) Descriptor 

func (FailureType) Descriptor() protoreflect.EnumDescriptor

func (FailureType) Enum 

func (x FailureType) Enum() *FailureType

func (FailureType) EnumDescriptor deprecated 

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

Deprecated: Use FailureType.Descriptor instead.

func (FailureType) Number 

func (x FailureType) Number() protoreflect.EnumNumber

func (FailureType) String 

func (x FailureType) String() string

func (FailureType) Type 

func (FailureType) Type() protoreflect.EnumType

type ProxyPortConfig 

type ProxyPortConfig struct {

	// The service ID of the proxy port config.
	ServiceId string `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	// The port of the proxy port config.
	Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// True if proxy uses TCP.
	ProxyTcp bool `protobuf:"varint,3,opt,name=proxy_tcp,json=proxyTcp,proto3" json:"proxy_tcp,omitempty"`
	// True if the proxy is unauthenticated.
	Unauthenticated bool `protobuf:"varint,4,opt,name=unauthenticated,proto3" json:"unauthenticated,omitempty"`
	// contains filtered or unexported fields
}

ProxyPortConfig configures a proxy the allocation should start.

func (*ProxyPortConfig) Descriptor deprecated 

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

Deprecated: Use ProxyPortConfig.ProtoReflect.Descriptor instead.

func (*ProxyPortConfig) GetPort 

func (x *ProxyPortConfig) GetPort() int32

func (*ProxyPortConfig) GetProxyTcp 

func (x *ProxyPortConfig) GetProxyTcp() bool

func (*ProxyPortConfig) GetServiceId 

func (x *ProxyPortConfig) GetServiceId() string

func (*ProxyPortConfig) GetUnauthenticated 

func (x *ProxyPortConfig) GetUnauthenticated() bool

func (*ProxyPortConfig) ProtoMessage 

func (*ProxyPortConfig) ProtoMessage()

func (*ProxyPortConfig) ProtoReflect 

func (x *ProxyPortConfig) ProtoReflect() protoreflect.Message

func (*ProxyPortConfig) Reset 

func (x *ProxyPortConfig) Reset()

func (*ProxyPortConfig) String 

func (x *ProxyPortConfig) String() string

type ResourcesFailure 

type ResourcesFailure struct {

	// FailureType denotes the type of failure that resulted in the container
	// stopping.
	FailureType FailureType `` /* 131-byte string literal not displayed */
	// The error message of the failure.
	ErrMsg string `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	// The exit code of the failure.
	ExitCode *int32 `protobuf:"varint,3,opt,name=exit_code,json=exitCode,proto3,oneof" json:"exit_code,omitempty"`
	// contains filtered or unexported fields
}

ResourcesFailure contains information about restored resources' failure.

func (*ResourcesFailure) Descriptor deprecated 

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

Deprecated: Use ResourcesFailure.ProtoReflect.Descriptor instead.

func (*ResourcesFailure) GetErrMsg 

func (x *ResourcesFailure) GetErrMsg() string

func (*ResourcesFailure) GetExitCode 

func (x *ResourcesFailure) GetExitCode() int32

func (*ResourcesFailure) GetFailureType 

func (x *ResourcesFailure) GetFailureType() FailureType

func (*ResourcesFailure) ProtoMessage 

func (*ResourcesFailure) ProtoMessage()

func (*ResourcesFailure) ProtoReflect 

func (x *ResourcesFailure) ProtoReflect() protoreflect.Message

func (*ResourcesFailure) Reset 

func (x *ResourcesFailure) Reset()

func (*ResourcesFailure) String 

func (x *ResourcesFailure) String() string

type ResourcesStarted 

type ResourcesStarted struct {

	// Addresses represents the exposed ports on a container.
	Addresses []*Address `protobuf:"bytes,1,rep,name=addresses,proto3" json:"addresses,omitempty"`
	// NativeResourcesID is the native Docker hex container ID of the Determined
	// container.
	NativeResourcesId string `protobuf:"bytes,2,opt,name=native_resources_id,json=nativeResourcesId,proto3" json:"native_resources_id,omitempty"`
	// contains filtered or unexported fields
}

ResourcesStarted contains the information needed by tasks from container started.

func (*ResourcesStarted) Descriptor deprecated 

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

Deprecated: Use ResourcesStarted.ProtoReflect.Descriptor instead.

func (*ResourcesStarted) GetAddresses 

func (x *ResourcesStarted) GetAddresses() []*Address

func (*ResourcesStarted) GetNativeResourcesId 

func (x *ResourcesStarted) GetNativeResourcesId() string

func (*ResourcesStarted) ProtoMessage 

func (*ResourcesStarted) ProtoMessage()

func (*ResourcesStarted) ProtoReflect 

func (x *ResourcesStarted) ProtoReflect() protoreflect.Message

func (*ResourcesStarted) Reset 

func (x *ResourcesStarted) Reset()

func (*ResourcesStarted) String 

func (x *ResourcesStarted) String() string

type ResourcesStopped 

type ResourcesStopped struct {

	// ResourcesFailure contains information about restored resources' failure.
	Failure *ResourcesFailure `protobuf:"bytes,1,opt,name=failure,proto3" json:"failure,omitempty"`
	// contains filtered or unexported fields
}

ResourcesStopped contains the information needed by tasks from container stopped.

func (*ResourcesStopped) Descriptor deprecated 

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

Deprecated: Use ResourcesStopped.ProtoReflect.Descriptor instead.

func (*ResourcesStopped) GetFailure 

func (x *ResourcesStopped) GetFailure() *ResourcesFailure

func (*ResourcesStopped) ProtoMessage 

func (*ResourcesStopped) ProtoMessage()

func (*ResourcesStopped) ProtoReflect 

func (x *ResourcesStopped) ProtoReflect() protoreflect.Message

func (*ResourcesStopped) Reset 

func (x *ResourcesStopped) Reset()

func (*ResourcesStopped) String 

func (x *ResourcesStopped) String() string

type ResourcesSummary 

type ResourcesSummary struct {

	// ResourcesID is the ID of some set of resources.
	ResourcesId string `protobuf:"bytes,1,opt,name=resources_id,json=resourcesId,proto3" json:"resources_id,omitempty"`
	// ResourcesType is the type of some set of resources. This should be purely
	// informational.
	ResourcesType string `protobuf:"bytes,2,opt,name=resources_type,json=resourcesType,proto3" json:"resources_type,omitempty"`
	// AllocationID is the ID of an allocation of a task.
	AllocationId string `protobuf:"bytes,3,opt,name=allocation_id,json=allocationId,proto3" json:"allocation_id,omitempty"`
	// ID, an identifier for an agent, maps to the associated devices.
	AgentDevices map[string]*ResourcesSummary_Devices `` /* 185-byte string literal not displayed */
	// Available if the RM can give information on the container level.
	ContainerId *string `protobuf:"bytes,5,opt,name=container_id,json=containerId,proto3,oneof" json:"container_id,omitempty"`
	// Available if the RM knows the resource is already started / exited.
	Started *ResourcesStarted `protobuf:"bytes,6,opt,name=started,proto3,oneof" json:"started,omitempty"`
	// ResourcesStopped contains the information needed by tasks from container
	// stopped.
	Exited *ResourcesStopped `protobuf:"bytes,7,opt,name=exited,proto3,oneof" json:"exited,omitempty"`
	// contains filtered or unexported fields
}

ResourcesSummary provides a summary of the resources comprising what we know at the time the allocation is granted, but for k8s it is granted before being scheduled so it isn't really much and `agent_devices` are missing for k8s.

func (*ResourcesSummary) Descriptor deprecated 

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

Deprecated: Use ResourcesSummary.ProtoReflect.Descriptor instead.

func (*ResourcesSummary) GetAgentDevices 

func (x *ResourcesSummary) GetAgentDevices() map[string]*ResourcesSummary_Devices

func (*ResourcesSummary) GetAllocationId 

func (x *ResourcesSummary) GetAllocationId() string

func (*ResourcesSummary) GetContainerId 

func (x *ResourcesSummary) GetContainerId() string

func (*ResourcesSummary) GetExited 

func (x *ResourcesSummary) GetExited() *ResourcesStopped

func (*ResourcesSummary) GetResourcesId 

func (x *ResourcesSummary) GetResourcesId() string

func (*ResourcesSummary) GetResourcesType 

func (x *ResourcesSummary) GetResourcesType() string

func (*ResourcesSummary) GetStarted 

func (x *ResourcesSummary) GetStarted() *ResourcesStarted

func (*ResourcesSummary) ProtoMessage 

func (*ResourcesSummary) ProtoMessage()

func (*ResourcesSummary) ProtoReflect 

func (x *ResourcesSummary) ProtoReflect() protoreflect.Message

func (*ResourcesSummary) Reset 

func (x *ResourcesSummary) Reset()

func (*ResourcesSummary) String 

func (x *ResourcesSummary) String() string

type ResourcesSummary_Devices 

type ResourcesSummary_Devices struct {

	// The devices on an agent.
	Devices []*devicev1.Device `protobuf:"bytes,1,rep,name=devices,proto3" json:"devices,omitempty"`
	// contains filtered or unexported fields
}

A wrapper message of a list of devices.

func (*ResourcesSummary_Devices) Descriptor deprecated 

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

Deprecated: Use ResourcesSummary_Devices.ProtoReflect.Descriptor instead.

func (*ResourcesSummary_Devices) GetDevices 

func (x *ResourcesSummary_Devices) GetDevices() []*devicev1.Device

func (*ResourcesSummary_Devices) ProtoMessage 

func (*ResourcesSummary_Devices) ProtoMessage()

func (*ResourcesSummary_Devices) ProtoReflect 

func (x *ResourcesSummary_Devices) ProtoReflect() protoreflect.Message

func (*ResourcesSummary_Devices) Reset 

func (x *ResourcesSummary_Devices) Reset()

func (*ResourcesSummary_Devices) String 

func (x *ResourcesSummary_Devices) String() string

type State 

type State int32

The current state of the task. 

const (
	// The task state is unknown.
	State_STATE_UNSPECIFIED State = 0
	// The task's base image is being pulled from the Docker registry.
	State_STATE_PULLING State = 3
	// The image has been pulled and the task is being started, but the task is
	// not ready yet.
	State_STATE_STARTING State = 4
	// The service in the task is running.
	State_STATE_RUNNING State = 5
	// The task has exited or has been aborted.
	State_STATE_TERMINATED State = 6
	// The task has begun to exit.
	State_STATE_TERMINATING State = 7
	// The task is waiting on something to complete.
	State_STATE_WAITING State = 9
	// Additional state to cover queueing operations.
	State_STATE_QUEUED State = 8
)

func (State) Descriptor 

func (State) Descriptor() protoreflect.EnumDescriptor

func (State) Enum 

func (x State) Enum() *State

func (State) EnumDescriptor deprecated 

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

Deprecated: Use State.Descriptor instead.

func (State) Number 

func (x State) Number() protoreflect.EnumNumber

func (State) String 

func (x State) String() string

func (State) Type 

func (State) Type() protoreflect.EnumType

type Task 

type Task struct {

	// Unique ID of task.
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Type of Task.
	TaskType TaskType `protobuf:"varint,2,opt,name=task_type,json=taskType,proto3,enum=determined.task.v1.TaskType" json:"task_type,omitempty"`
	// List of Allocations.
	Allocations []*Allocation `protobuf:"bytes,4,rep,name=allocations,proto3" json:"allocations,omitempty"`
	// Start timestamp.
	StartTime *timestamp.Timestamp `protobuf:"bytes,5,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// End timestamp if completed.
	EndTime *timestamp.Timestamp `protobuf:"bytes,6,opt,name=end_time,json=endTime,proto3,oneof" json:"end_time,omitempty"`
	// contains filtered or unexported fields
}

Task is the model for a task in the database.

func (*Task) Descriptor deprecated 

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetAllocations 

func (x *Task) GetAllocations() []*Allocation

func (*Task) GetEndTime 

func (x *Task) GetEndTime() *timestamp.Timestamp

func (*Task) GetStartTime 

func (x *Task) GetStartTime() *timestamp.Timestamp

func (*Task) GetTaskId 

func (x *Task) GetTaskId() string

func (*Task) GetTaskType 

func (x *Task) GetTaskType() TaskType

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) ProtoReflect 

func (x *Task) ProtoReflect() protoreflect.Message

func (*Task) Reset 

func (x *Task) Reset()

func (*Task) String 

func (x *Task) String() string

type TaskLog 

type TaskLog struct {

	// The ID of the log.
	Id *int32 `protobuf:"varint,1,opt,name=id,proto3,oneof" json:"id,omitempty"`
	// The ID of the task.
	TaskId string `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// The ID of the allocation.
	AllocationId *string `protobuf:"bytes,3,opt,name=allocation_id,json=allocationId,proto3,oneof" json:"allocation_id,omitempty"`
	// The agent the logs came from.
	AgentId *string `protobuf:"bytes,4,opt,name=agent_id,json=agentId,proto3,oneof" json:"agent_id,omitempty"`
	// The ID of the container or, in the case of k8s, the pod name.
	ContainerId *string `protobuf:"bytes,5,opt,name=container_id,json=containerId,proto3,oneof" json:"container_id,omitempty"`
	// The rank ID.
	RankId *int32 `protobuf:"varint,6,opt,name=rank_id,json=rankId,proto3,oneof" json:"rank_id,omitempty"`
	// The timestamp of the log.
	Timestamp *timestamp.Timestamp `protobuf:"bytes,7,opt,name=timestamp,proto3,oneof" json:"timestamp,omitempty"`
	// The level of this log.
	Level *logv1.LogLevel `protobuf:"varint,8,opt,name=level,proto3,enum=determined.log.v1.LogLevel,oneof" json:"level,omitempty"`
	// The text of the log entry.
	Log string `protobuf:"bytes,9,opt,name=log,proto3" json:"log,omitempty"`
	// The source of the log entry.
	Source *string `protobuf:"bytes,10,opt,name=source,proto3,oneof" json:"source,omitempty"`
	// The output stream (e.g. stdout, stderr).
	Stdtype *string `protobuf:"bytes,11,opt,name=stdtype,proto3,oneof" json:"stdtype,omitempty"`
	// contains filtered or unexported fields
}

TaskLog is the model for a task log in the database

func (*TaskLog) Descriptor deprecated 

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

Deprecated: Use TaskLog.ProtoReflect.Descriptor instead.

func (*TaskLog) GetAgentId 

func (x *TaskLog) GetAgentId() string

func (*TaskLog) GetAllocationId 

func (x *TaskLog) GetAllocationId() string

func (*TaskLog) GetContainerId 

func (x *TaskLog) GetContainerId() string

func (*TaskLog) GetId 

func (x *TaskLog) GetId() int32

func (*TaskLog) GetLevel 

func (x *TaskLog) GetLevel() logv1.LogLevel

func (*TaskLog) GetLog 

func (x *TaskLog) GetLog() string

func (*TaskLog) GetRankId 

func (x *TaskLog) GetRankId() int32

func (*TaskLog) GetSource 

func (x *TaskLog) GetSource() string

func (*TaskLog) GetStdtype 

func (x *TaskLog) GetStdtype() string

func (*TaskLog) GetTaskId 

func (x *TaskLog) GetTaskId() string

func (*TaskLog) GetTimestamp 

func (x *TaskLog) GetTimestamp() *timestamp.Timestamp

func (*TaskLog) ProtoMessage 

func (*TaskLog) ProtoMessage()

func (*TaskLog) ProtoReflect 

func (x *TaskLog) ProtoReflect() protoreflect.Message

func (*TaskLog) Reset 

func (x *TaskLog) Reset()

func (*TaskLog) String 

func (x *TaskLog) String() string

type TaskType 

type TaskType int32

Type of the task 

const (
	// The task type is unknown
	TaskType_TASK_TYPE_UNSPECIFIED TaskType = 0
	// "TRIAL" task type for the enum public.task_type in Postgres.
	TaskType_TASK_TYPE_TRIAL TaskType = 1
	// "NOTEBOOK" task type for the enum public.task_type in Postgres.
	TaskType_TASK_TYPE_NOTEBOOK TaskType = 2
	// "SHELL" task type for the enum public.task_type in Postgres.
	TaskType_TASK_TYPE_SHELL TaskType = 3
	// "COMMAND" task type for the enum public.task_type in Postgres.
	TaskType_TASK_TYPE_COMMAND TaskType = 4
	// "TENSORBOARD" task type for the enum public.task_type in Postgres.
	TaskType_TASK_TYPE_TENSORBOARD TaskType = 5
	// "CHECKPOINT_GC" task type for the enum public.task_type in Postgres.
	TaskType_TASK_TYPE_CHECKPOINT_GC TaskType = 6
)

func (TaskType) Descriptor 

func (TaskType) Descriptor() protoreflect.EnumDescriptor

func (TaskType) Enum 

func (x TaskType) Enum() *TaskType

func (TaskType) EnumDescriptor deprecated 

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

Deprecated: Use TaskType.Descriptor instead.

func (TaskType) Number 

func (x TaskType) Number() protoreflect.EnumNumber

func (TaskType) String 

func (x TaskType) String() string

func (TaskType) Type 

func (TaskType) Type() protoreflect.EnumType

Source Files

View all Source files

Jump to

Keyboard shortcuts

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