executorapi

package
v0.12.0 Latest Latest
Warning

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

 Go to latest Published: Sep 12, 2024 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthExecutorapi        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowExecutorapi          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupExecutorapi = fmt.Errorf("proto: unexpected end of group")
)

Functions

func NewNodeFromNodeInfo added in v0.4.20 

func NewNodeFromNodeInfo(nodeInfo *NodeInfo, executor string, allowedPriorities []int32, lastSeen time.Time) (*schedulerobjects.Node, error)

func RegisterExecutorApiServer 

func RegisterExecutorApiServer(s *grpc.Server, srv ExecutorApiServer)

func ResourceListFromProtoResources added in v0.8.7 

func ResourceListFromProtoResources(r map[string]*resource.Quantity) schedulerobjects.ResourceList

Types

type CancelRuns 

type CancelRuns struct {
	JobRunIdsToCancel    []*armadaevents.Uuid `protobuf:"bytes,1,rep,name=job_run_ids_to_cancel,json=jobRunIdsToCancel,proto3" json:"jobRunIdsToCancel,omitempty"`
	JobRunIdsToCancelStr []string             `protobuf:"bytes,2,rep,name=job_run_ids_to_cancel_str,json=jobRunIdsToCancelStr,proto3" json:"jobRunIdsToCancelStr,omitempty"`
}

Indicates that the job runs with the given ids should be cancelled.

func (*CancelRuns) Descriptor 

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

func (*CancelRuns) GetJobRunIdsToCancel 

func (m *CancelRuns) GetJobRunIdsToCancel() []*armadaevents.Uuid

func (*CancelRuns) GetJobRunIdsToCancelStr added in v0.12.0 

func (m *CancelRuns) GetJobRunIdsToCancelStr() []string

func (*CancelRuns) Marshal 

func (m *CancelRuns) Marshal() (dAtA []byte, err error)

func (*CancelRuns) MarshalTo 

func (m *CancelRuns) MarshalTo(dAtA []byte) (int, error)

func (*CancelRuns) MarshalToSizedBuffer 

func (m *CancelRuns) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CancelRuns) ProtoMessage 

func (*CancelRuns) ProtoMessage()

func (*CancelRuns) Reset 

func (m *CancelRuns) Reset()

func (*CancelRuns) Size 

func (m *CancelRuns) Size() (n int)

func (*CancelRuns) String 

func (m *CancelRuns) String() string

func (*CancelRuns) Unmarshal 

func (m *CancelRuns) Unmarshal(dAtA []byte) error

func (*CancelRuns) XXX_DiscardUnknown 

func (m *CancelRuns) XXX_DiscardUnknown()

func (*CancelRuns) XXX_Marshal 

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

func (*CancelRuns) XXX_Merge 

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

func (*CancelRuns) XXX_Size 

func (m *CancelRuns) XXX_Size() int

func (*CancelRuns) XXX_Unmarshal 

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

type ComputeResource added in v0.4.20 

type ComputeResource struct {
	Resources map[string]*resource.Quantity `` /* 159-byte string literal not displayed */
}

func ComputeResourceFromProtoResources added in v0.8.7 

func ComputeResourceFromProtoResources(r map[string]resource.Quantity) *ComputeResource

func (*ComputeResource) Descriptor added in v0.4.20 

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

func (*ComputeResource) GetResources added in v0.4.20 

func (m *ComputeResource) GetResources() map[string]*resource.Quantity

func (*ComputeResource) Marshal added in v0.4.20 

func (m *ComputeResource) Marshal() (dAtA []byte, err error)

func (*ComputeResource) MarshalTo added in v0.4.20 

func (m *ComputeResource) MarshalTo(dAtA []byte) (int, error)

func (*ComputeResource) MarshalToSizedBuffer added in v0.4.20 

func (m *ComputeResource) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ComputeResource) ProtoMessage added in v0.4.20 

func (*ComputeResource) ProtoMessage()

func (*ComputeResource) Reset added in v0.4.20 

func (m *ComputeResource) Reset()

func (*ComputeResource) Size added in v0.4.20 

func (m *ComputeResource) Size() (n int)

func (*ComputeResource) String added in v0.4.20 

func (m *ComputeResource) String() string

func (*ComputeResource) Unmarshal added in v0.4.20 

func (m *ComputeResource) Unmarshal(dAtA []byte) error

func (*ComputeResource) XXX_DiscardUnknown added in v0.4.20 

func (m *ComputeResource) XXX_DiscardUnknown()

func (*ComputeResource) XXX_Marshal added in v0.4.20 

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

func (*ComputeResource) XXX_Merge added in v0.4.20 

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

func (*ComputeResource) XXX_Size added in v0.4.20 

func (m *ComputeResource) XXX_Size() int

func (*ComputeResource) XXX_Unmarshal added in v0.4.20 

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

type EndMarker 

type EndMarker struct {
}

Indicates the end of the lease stream.

func (*EndMarker) Descriptor 

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

func (*EndMarker) Marshal 

func (m *EndMarker) Marshal() (dAtA []byte, err error)

func (*EndMarker) MarshalTo 

func (m *EndMarker) MarshalTo(dAtA []byte) (int, error)

func (*EndMarker) MarshalToSizedBuffer 

func (m *EndMarker) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EndMarker) ProtoMessage 

func (*EndMarker) ProtoMessage()

func (*EndMarker) Reset 

func (m *EndMarker) Reset()

func (*EndMarker) Size 

func (m *EndMarker) Size() (n int)

func (*EndMarker) String 

func (m *EndMarker) String() string

func (*EndMarker) Unmarshal 

func (m *EndMarker) Unmarshal(dAtA []byte) error

func (*EndMarker) XXX_DiscardUnknown 

func (m *EndMarker) XXX_DiscardUnknown()

func (*EndMarker) XXX_Marshal 

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

func (*EndMarker) XXX_Merge 

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

func (*EndMarker) XXX_Size 

func (m *EndMarker) XXX_Size() int

func (*EndMarker) XXX_Unmarshal 

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

type EventList 

type EventList struct {
	Events []*armadaevents.EventSequence `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
}

func (*EventList) Descriptor 

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

func (*EventList) GetEvents 

func (m *EventList) GetEvents() []*armadaevents.EventSequence

func (*EventList) Marshal 

func (m *EventList) Marshal() (dAtA []byte, err error)

func (*EventList) MarshalTo 

func (m *EventList) MarshalTo(dAtA []byte) (int, error)

func (*EventList) MarshalToSizedBuffer 

func (m *EventList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventList) ProtoMessage 

func (*EventList) ProtoMessage()

func (*EventList) Reset 

func (m *EventList) Reset()

func (*EventList) Size 

func (m *EventList) Size() (n int)

func (*EventList) String 

func (m *EventList) String() string

func (*EventList) Unmarshal 

func (m *EventList) Unmarshal(dAtA []byte) error

func (*EventList) XXX_DiscardUnknown 

func (m *EventList) XXX_DiscardUnknown()

func (*EventList) XXX_Marshal 

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

func (*EventList) XXX_Merge 

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

func (*EventList) XXX_Size 

func (m *EventList) XXX_Size() int

func (*EventList) XXX_Unmarshal 

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

type ExecutorApiClient 

type ExecutorApiClient interface {
	// Reports usage information to the scheduler.
	// In return, the scheduler provides:
	// - Slice of job runs that the executor is currently running that should be cancelled.
	// - Slice of job runs that the executor is currently running that should be preempted.
	// - Slice job runs that the executor is not currently running that should be scheduled.
	// This call also acts as a signal to the scheduler that the executor is alive and accepting jobs.
	LeaseJobRuns(ctx context.Context, opts ...grpc.CallOption) (ExecutorApi_LeaseJobRunsClient, error)
	// Reports job run events to the scheduler.
	ReportEvents(ctx context.Context, in *EventList, opts ...grpc.CallOption) (*types.Empty, error)
}

ExecutorApiClient is the client API for ExecutorApi service.

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

func NewExecutorApiClient 

func NewExecutorApiClient(cc *grpc.ClientConn) ExecutorApiClient

type ExecutorApiServer 

type ExecutorApiServer interface {
	// Reports usage information to the scheduler.
	// In return, the scheduler provides:
	// - Slice of job runs that the executor is currently running that should be cancelled.
	// - Slice of job runs that the executor is currently running that should be preempted.
	// - Slice job runs that the executor is not currently running that should be scheduled.
	// This call also acts as a signal to the scheduler that the executor is alive and accepting jobs.
	LeaseJobRuns(ExecutorApi_LeaseJobRunsServer) error
	// Reports job run events to the scheduler.
	ReportEvents(context.Context, *EventList) (*types.Empty, error)
}

ExecutorApiServer is the server API for ExecutorApi service.

type ExecutorApi_LeaseJobRunsClient 

type ExecutorApi_LeaseJobRunsClient interface {
	Send(*LeaseRequest) error
	Recv() (*LeaseStreamMessage, error)
	grpc.ClientStream
}

type ExecutorApi_LeaseJobRunsServer 

type ExecutorApi_LeaseJobRunsServer interface {
	Send(*LeaseStreamMessage) error
	Recv() (*LeaseRequest, error)
	grpc.ServerStream
}

type JobRunLease 

type JobRunLease struct {
	JobRunId    *armadaevents.Uuid      `protobuf:"bytes,1,opt,name=job_run_id,json=jobRunId,proto3" json:"jobRunId,omitempty"`
	Queue       string                  `protobuf:"bytes,2,opt,name=queue,proto3" json:"queue,omitempty"`
	Jobset      string                  `protobuf:"bytes,3,opt,name=jobset,proto3" json:"jobset,omitempty"`
	User        string                  `protobuf:"bytes,4,opt,name=user,proto3" json:"user,omitempty"`
	Groups      []string                `protobuf:"bytes,5,rep,name=groups,proto3" json:"groups,omitempty"`
	Job         *armadaevents.SubmitJob `protobuf:"bytes,6,opt,name=job,proto3" json:"job,omitempty"`
	JobRunIdStr string                  `protobuf:"bytes,7,opt,name=job_run_id_str,json=jobRunIdStr,proto3" json:"jobRunIdStr,omitempty"`
}

Indicates that a job run is now leased.

func (*JobRunLease) Descriptor 

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

func (*JobRunLease) GetGroups 

func (m *JobRunLease) GetGroups() []string

func (*JobRunLease) GetJob 

func (m *JobRunLease) GetJob() *armadaevents.SubmitJob

func (*JobRunLease) GetJobRunId 

func (m *JobRunLease) GetJobRunId() *armadaevents.Uuid

func (*JobRunLease) GetJobRunIdStr added in v0.12.0 

func (m *JobRunLease) GetJobRunIdStr() string

func (*JobRunLease) GetJobset 

func (m *JobRunLease) GetJobset() string

func (*JobRunLease) GetQueue 

func (m *JobRunLease) GetQueue() string

func (*JobRunLease) GetUser 

func (m *JobRunLease) GetUser() string

func (*JobRunLease) Marshal 

func (m *JobRunLease) Marshal() (dAtA []byte, err error)

func (*JobRunLease) MarshalTo 

func (m *JobRunLease) MarshalTo(dAtA []byte) (int, error)

func (*JobRunLease) MarshalToSizedBuffer 

func (m *JobRunLease) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JobRunLease) ProtoMessage 

func (*JobRunLease) ProtoMessage()

func (*JobRunLease) Reset 

func (m *JobRunLease) Reset()

func (*JobRunLease) Size 

func (m *JobRunLease) Size() (n int)

func (*JobRunLease) String 

func (m *JobRunLease) String() string

func (*JobRunLease) Unmarshal 

func (m *JobRunLease) Unmarshal(dAtA []byte) error

func (*JobRunLease) XXX_DiscardUnknown 

func (m *JobRunLease) XXX_DiscardUnknown()

func (*JobRunLease) XXX_Marshal 

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

func (*JobRunLease) XXX_Merge 

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

func (*JobRunLease) XXX_Size 

func (m *JobRunLease) XXX_Size() int

func (*JobRunLease) XXX_Unmarshal 

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

type LeaseRequest 

type LeaseRequest struct {
	// Each executor has a unique name associated with it.
	ExecutorId string `protobuf:"bytes,1,opt,name=executor_id,json=executorId,proto3" json:"executorId,omitempty"`
	// Nodes are split into pools. This field indicates for which pool jobs are leased.
	Pool string `protobuf:"bytes,2,opt,name=pool,proto3" json:"pool,omitempty"`
	// Total resources available for scheduling across all nodes.
	Resources map[string]*resource.Quantity `` /* 159-byte string literal not displayed */
	// Jobs submitted to this executor must require at least this amount of resources.
	MinimumJobSize map[string]*resource.Quantity `` /* 191-byte string literal not displayed */
	// For each node in the cluster:
	// - The total allocatable resources on that node.
	// - The job runs running on those nodes,
	// - Any taints and labels on the node.
	Nodes []*NodeInfo `protobuf:"bytes,5,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// Run Ids of jobs owned by the executor but not currently assigned to a node.
	UnassignedJobRunIds []*armadaevents.Uuid `protobuf:"bytes,6,rep,name=unassigned_job_run_ids,json=unassignedJobRunIds,proto3" json:"unassignedJobRunIds,omitempty"`
	// Max number of jobs this request should return
	MaxJobsToLease uint32 `protobuf:"varint,7,opt,name=max_jobs_to_lease,json=maxJobsToLease,proto3" json:"maxJobsToLease,omitempty"`
	// Run Ids of jobs owned by the executor but not currently assigned to a node.
	UnassignedJobRunIdsStr []string `` /* 129-byte string literal not displayed */
}

func (*LeaseRequest) Descriptor 

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

func (*LeaseRequest) GetExecutorId 

func (m *LeaseRequest) GetExecutorId() string

func (*LeaseRequest) GetMaxJobsToLease added in v0.3.91 

func (m *LeaseRequest) GetMaxJobsToLease() uint32

func (*LeaseRequest) GetMinimumJobSize 

func (m *LeaseRequest) GetMinimumJobSize() map[string]*resource.Quantity

func (*LeaseRequest) GetNodes 

func (m *LeaseRequest) GetNodes() []*NodeInfo

func (*LeaseRequest) GetPool 

func (m *LeaseRequest) GetPool() string

func (*LeaseRequest) GetResources 

func (m *LeaseRequest) GetResources() map[string]*resource.Quantity

func (*LeaseRequest) GetUnassignedJobRunIds 

func (m *LeaseRequest) GetUnassignedJobRunIds() []*armadaevents.Uuid

func (*LeaseRequest) GetUnassignedJobRunIdsStr added in v0.12.0 

func (m *LeaseRequest) GetUnassignedJobRunIdsStr() []string

func (*LeaseRequest) Marshal 

func (m *LeaseRequest) Marshal() (dAtA []byte, err error)

func (*LeaseRequest) MarshalTo 

func (m *LeaseRequest) MarshalTo(dAtA []byte) (int, error)

func (*LeaseRequest) MarshalToSizedBuffer 

func (m *LeaseRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LeaseRequest) ProtoMessage 

func (*LeaseRequest) ProtoMessage()

func (*LeaseRequest) Reset 

func (m *LeaseRequest) Reset()

func (*LeaseRequest) Size 

func (m *LeaseRequest) Size() (n int)

func (*LeaseRequest) String 

func (m *LeaseRequest) String() string

func (*LeaseRequest) Unmarshal 

func (m *LeaseRequest) Unmarshal(dAtA []byte) error

func (*LeaseRequest) XXX_DiscardUnknown 

func (m *LeaseRequest) XXX_DiscardUnknown()

func (*LeaseRequest) XXX_Marshal 

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

func (*LeaseRequest) XXX_Merge 

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

func (*LeaseRequest) XXX_Size 

func (m *LeaseRequest) XXX_Size() int

func (*LeaseRequest) XXX_Unmarshal 

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

type LeaseStreamMessage 

type LeaseStreamMessage struct {
	// Types that are valid to be assigned to Event:
	//	*LeaseStreamMessage_Lease
	//	*LeaseStreamMessage_CancelRuns
	//	*LeaseStreamMessage_End
	//	*LeaseStreamMessage_PreemptRuns
	Event isLeaseStreamMessage_Event `protobuf_oneof:"event"`
}

func (*LeaseStreamMessage) Descriptor 

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

func (*LeaseStreamMessage) GetCancelRuns 

func (m *LeaseStreamMessage) GetCancelRuns() *CancelRuns

func (*LeaseStreamMessage) GetEnd 

func (m *LeaseStreamMessage) GetEnd() *EndMarker

func (*LeaseStreamMessage) GetEvent 

func (m *LeaseStreamMessage) GetEvent() isLeaseStreamMessage_Event

func (*LeaseStreamMessage) GetLease 

func (m *LeaseStreamMessage) GetLease() *JobRunLease

func (*LeaseStreamMessage) GetPreemptRuns added in v0.3.53 

func (m *LeaseStreamMessage) GetPreemptRuns() *PreemptRuns

func (*LeaseStreamMessage) Marshal 

func (m *LeaseStreamMessage) Marshal() (dAtA []byte, err error)

func (*LeaseStreamMessage) MarshalTo 

func (m *LeaseStreamMessage) MarshalTo(dAtA []byte) (int, error)

func (*LeaseStreamMessage) MarshalToSizedBuffer 

func (m *LeaseStreamMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LeaseStreamMessage) ProtoMessage 

func (*LeaseStreamMessage) ProtoMessage()

func (*LeaseStreamMessage) Reset 

func (m *LeaseStreamMessage) Reset()

func (*LeaseStreamMessage) Size 

func (m *LeaseStreamMessage) Size() (n int)

func (*LeaseStreamMessage) String 

func (m *LeaseStreamMessage) String() string

func (*LeaseStreamMessage) Unmarshal 

func (m *LeaseStreamMessage) Unmarshal(dAtA []byte) error

func (*LeaseStreamMessage) XXX_DiscardUnknown 

func (m *LeaseStreamMessage) XXX_DiscardUnknown()

func (*LeaseStreamMessage) XXX_Marshal 

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

func (*LeaseStreamMessage) XXX_Merge 

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

func (*LeaseStreamMessage) XXX_OneofWrappers 

func (*LeaseStreamMessage) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*LeaseStreamMessage) XXX_Size 

func (m *LeaseStreamMessage) XXX_Size() int

func (*LeaseStreamMessage) XXX_Unmarshal 

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

type LeaseStreamMessage_CancelRuns 

type LeaseStreamMessage_CancelRuns struct {
	CancelRuns *CancelRuns `protobuf:"bytes,2,opt,name=cancel_runs,json=cancelRuns,proto3,oneof" json:"cancelRuns,omitempty"`
}

func (*LeaseStreamMessage_CancelRuns) MarshalTo 

func (m *LeaseStreamMessage_CancelRuns) MarshalTo(dAtA []byte) (int, error)

func (*LeaseStreamMessage_CancelRuns) MarshalToSizedBuffer 

func (m *LeaseStreamMessage_CancelRuns) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LeaseStreamMessage_CancelRuns) Size 

func (m *LeaseStreamMessage_CancelRuns) Size() (n int)

type LeaseStreamMessage_End 

type LeaseStreamMessage_End struct {
	End *EndMarker `protobuf:"bytes,3,opt,name=end,proto3,oneof" json:"end,omitempty"`
}

func (*LeaseStreamMessage_End) MarshalTo 

func (m *LeaseStreamMessage_End) MarshalTo(dAtA []byte) (int, error)

func (*LeaseStreamMessage_End) MarshalToSizedBuffer 

func (m *LeaseStreamMessage_End) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LeaseStreamMessage_End) Size 

func (m *LeaseStreamMessage_End) Size() (n int)

type LeaseStreamMessage_Lease 

type LeaseStreamMessage_Lease struct {
	Lease *JobRunLease `protobuf:"bytes,1,opt,name=lease,proto3,oneof" json:"lease,omitempty"`
}

func (*LeaseStreamMessage_Lease) MarshalTo 

func (m *LeaseStreamMessage_Lease) MarshalTo(dAtA []byte) (int, error)

func (*LeaseStreamMessage_Lease) MarshalToSizedBuffer 

func (m *LeaseStreamMessage_Lease) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LeaseStreamMessage_Lease) Size 

func (m *LeaseStreamMessage_Lease) Size() (n int)

type LeaseStreamMessage_PreemptRuns added in v0.3.53 

type LeaseStreamMessage_PreemptRuns struct {
	PreemptRuns *PreemptRuns `protobuf:"bytes,4,opt,name=preempt_runs,json=preemptRuns,proto3,oneof" json:"preemptRuns,omitempty"`
}

func (*LeaseStreamMessage_PreemptRuns) MarshalTo added in v0.3.53 

func (m *LeaseStreamMessage_PreemptRuns) MarshalTo(dAtA []byte) (int, error)

func (*LeaseStreamMessage_PreemptRuns) MarshalToSizedBuffer added in v0.3.53 

func (m *LeaseStreamMessage_PreemptRuns) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LeaseStreamMessage_PreemptRuns) Size added in v0.3.53 

func (m *LeaseStreamMessage_PreemptRuns) Size() (n int)

type NodeInfo added in v0.4.20 

type NodeInfo struct {
	Name   string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Taints []*v1.Taint       `protobuf:"bytes,2,rep,name=taints,proto3" json:"taints,omitempty"`
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// To be deprecated in favour of total_resources + allocated_resources.
	AllocatableResources map[string]*resource.Quantity `` /* 208-byte string literal not displayed */
	// To be deprecated in favour of total_resources + allocated_resources.
	AvailableResources map[string]*resource.Quantity `` /* 202-byte string literal not displayed */
	// Total node resources.
	// Resources available for allocation is given by the difference between this and allocated_resources.
	TotalResources map[string]*resource.Quantity `` /* 190-byte string literal not displayed */
	// Each pod is created with a priority class. Each priority class has an integer priority associated with it.
	// This is a map from priority to the total amount of resources allocated to pods with that priority.
	// It is used by the scheduler to decide whether more jobs should be sent to an executor.
	// In particular, jobs may be sent to an executor even if all resources are allocated
	// if the sent jobs are of higher priority.
	AllocatedResources map[int32]*ComputeResource `` /* 203-byte string literal not displayed */
	// All run ids of jobs on the node, mapped to their current state
	// this should be of type armadaevents.uuid, but this creates a circular loop
	// once the old scheduler has gone, we can correct this
	RunIdsByState map[string]api.JobState `` /* 208-byte string literal not displayed */
	// The amount of resource allocated to non-armada pods by priority
	NonArmadaAllocatedResources map[int32]*ComputeResource `` /* 232-byte string literal not displayed */
	Unschedulable               bool                       `protobuf:"varint,10,opt,name=unschedulable,proto3" json:"unschedulable,omitempty"`
	// This should only be used for metrics
	// An aggregated real usage of jobs by queue
	ResourceUsageByQueue map[string]*ComputeResource `` /* 211-byte string literal not displayed */
	// This should only be used for metrics
	// This is the type the node should be reported as. It is simple a label to categorise the group the node belongs to
	NodeType string `protobuf:"bytes,12,opt,name=node_type,json=nodeType,proto3" json:"nodeType,omitempty"`
	// The pool that this node belongs to, this is used for scheduling purposes
	Pool string `protobuf:"bytes,13,opt,name=pool,proto3" json:"pool,omitempty"`
}

Used by the scheduler when allocating jobs to executors.

func (*NodeInfo) Descriptor added in v0.4.20 

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

func (*NodeInfo) GetAllocatableResources added in v0.4.20 

func (m *NodeInfo) GetAllocatableResources() map[string]*resource.Quantity

func (*NodeInfo) GetAllocatedResources added in v0.4.20 

func (m *NodeInfo) GetAllocatedResources() map[int32]*ComputeResource

func (*NodeInfo) GetAvailableResources added in v0.4.20 

func (m *NodeInfo) GetAvailableResources() map[string]*resource.Quantity

func (*NodeInfo) GetLabels added in v0.4.20 

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

func (*NodeInfo) GetName added in v0.4.20 

func (m *NodeInfo) GetName() string

func (*NodeInfo) GetNodeType added in v0.4.20 

func (m *NodeInfo) GetNodeType() string

func (*NodeInfo) GetNonArmadaAllocatedResources added in v0.4.20 

func (m *NodeInfo) GetNonArmadaAllocatedResources() map[int32]*ComputeResource

func (*NodeInfo) GetPool added in v0.9.0 

func (m *NodeInfo) GetPool() string

func (*NodeInfo) GetResourceUsageByQueue added in v0.4.20 

func (m *NodeInfo) GetResourceUsageByQueue() map[string]*ComputeResource

func (*NodeInfo) GetRunIdsByState added in v0.4.20 

func (m *NodeInfo) GetRunIdsByState() map[string]api.JobState

func (*NodeInfo) GetTaints added in v0.4.20 

func (m *NodeInfo) GetTaints() []*v1.Taint

func (*NodeInfo) GetTotalResources added in v0.4.20 

func (m *NodeInfo) GetTotalResources() map[string]*resource.Quantity

func (*NodeInfo) GetUnschedulable added in v0.4.20 

func (m *NodeInfo) GetUnschedulable() bool

func (*NodeInfo) Marshal added in v0.4.20 

func (m *NodeInfo) Marshal() (dAtA []byte, err error)

func (*NodeInfo) MarshalTo added in v0.4.20 

func (m *NodeInfo) MarshalTo(dAtA []byte) (int, error)

func (*NodeInfo) MarshalToSizedBuffer added in v0.4.20 

func (m *NodeInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NodeInfo) ProtoMessage added in v0.4.20 

func (*NodeInfo) ProtoMessage()

func (*NodeInfo) Reset added in v0.4.20 

func (m *NodeInfo) Reset()

func (*NodeInfo) Size added in v0.4.20 

func (m *NodeInfo) Size() (n int)

func (*NodeInfo) String added in v0.4.20 

func (m *NodeInfo) String() string

func (*NodeInfo) Unmarshal added in v0.4.20 

func (m *NodeInfo) Unmarshal(dAtA []byte) error

func (*NodeInfo) XXX_DiscardUnknown added in v0.4.20 

func (m *NodeInfo) XXX_DiscardUnknown()

func (*NodeInfo) XXX_Marshal added in v0.4.20 

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

func (*NodeInfo) XXX_Merge added in v0.4.20 

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

func (*NodeInfo) XXX_Size added in v0.4.20 

func (m *NodeInfo) XXX_Size() int

func (*NodeInfo) XXX_Unmarshal added in v0.4.20 

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

type PreemptRuns added in v0.3.53 

type PreemptRuns struct {
	JobRunIdsToPreempt    []*armadaevents.Uuid `protobuf:"bytes,1,rep,name=job_run_ids_to_preempt,json=jobRunIdsToPreempt,proto3" json:"jobRunIdsToPreempt,omitempty"`
	JobRunIdsToPreemptStr []string             `` /* 127-byte string literal not displayed */
}

Indicates that the job runs with the given ids should be preempted.

func (*PreemptRuns) Descriptor added in v0.3.53 

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

func (*PreemptRuns) GetJobRunIdsToPreempt added in v0.3.53 

func (m *PreemptRuns) GetJobRunIdsToPreempt() []*armadaevents.Uuid

func (*PreemptRuns) GetJobRunIdsToPreemptStr added in v0.12.0 

func (m *PreemptRuns) GetJobRunIdsToPreemptStr() []string

func (*PreemptRuns) Marshal added in v0.3.53 

func (m *PreemptRuns) Marshal() (dAtA []byte, err error)

func (*PreemptRuns) MarshalTo added in v0.3.53 

func (m *PreemptRuns) MarshalTo(dAtA []byte) (int, error)

func (*PreemptRuns) MarshalToSizedBuffer added in v0.3.53 

func (m *PreemptRuns) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PreemptRuns) ProtoMessage added in v0.3.53 

func (*PreemptRuns) ProtoMessage()

func (*PreemptRuns) Reset added in v0.3.53 

func (m *PreemptRuns) Reset()

func (*PreemptRuns) Size added in v0.3.53 

func (m *PreemptRuns) Size() (n int)

func (*PreemptRuns) String added in v0.3.53 

func (m *PreemptRuns) String() string

func (*PreemptRuns) Unmarshal added in v0.3.53 

func (m *PreemptRuns) Unmarshal(dAtA []byte) error

func (*PreemptRuns) XXX_DiscardUnknown added in v0.3.53 

func (m *PreemptRuns) XXX_DiscardUnknown()

func (*PreemptRuns) XXX_Marshal added in v0.3.53 

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

func (*PreemptRuns) XXX_Merge added in v0.3.53 

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

func (*PreemptRuns) XXX_Size added in v0.3.53 

func (m *PreemptRuns) XXX_Size() int

func (*PreemptRuns) XXX_Unmarshal added in v0.3.53 

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

type UnimplementedExecutorApiServer 

type UnimplementedExecutorApiServer struct {
}

UnimplementedExecutorApiServer can be embedded to have forward compatible implementations.

func (*UnimplementedExecutorApiServer) LeaseJobRuns 

func (*UnimplementedExecutorApiServer) LeaseJobRuns(srv ExecutorApi_LeaseJobRunsServer) error

func (*UnimplementedExecutorApiServer) ReportEvents 

func (*UnimplementedExecutorApiServer) ReportEvents(ctx context.Context, req *EventList) (*types.Empty, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

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