executorapi

package
v0.4.37 Latest Latest
Warning

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

Go to latest
Published: Apr 8, 2024 License: Apache-2.0 Imports: 22 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)

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"`
}

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) 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 (this *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 `` /* 149-byte string literal not displayed */
}

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 (this *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 (this *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 (this *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"`
}

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) 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 (this *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 `` /* 149-byte string literal not displayed */
	// Jobs submitted to this executor must require at least this amount of resources.
	MinimumJobSize map[string]resource.Quantity `` /* 181-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"`
	// 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"`
}

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) 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 (this *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 (this *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)

func (*LeaseStreamMessage_CancelRuns) String

func (this *LeaseStreamMessage_CancelRuns) String() string

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)

func (*LeaseStreamMessage_End) String

func (this *LeaseStreamMessage_End) String() string

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)

func (*LeaseStreamMessage_Lease) String

func (this *LeaseStreamMessage_Lease) String() string

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)

func (*LeaseStreamMessage_PreemptRuns) String added in v0.3.53

func (this *LeaseStreamMessage_PreemptRuns) String() string

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"`
	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 `` /* 198-byte string literal not displayed */
	// To be deprecated in favour of total_resources + allocated_resources.
	AvailableResources map[string]resource.Quantity `` /* 192-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 `` /* 180-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 `` /* 193-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 `` /* 198-byte string literal not displayed */
	// The amount of resource allocated to non-armada pods by priority
	NonArmadaAllocatedResources map[int32]ComputeResource `` /* 222-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"`
}

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) 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 (this *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"`
}

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) 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 (this *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) ReportEvents

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL