executorapi

Oct 9, 2024

Changes in this version

type NodeInfo

+ ResourceUsageByQueueAndPool []*PoolQueueResource

+ func (m *NodeInfo) GetResourceUsageByQueueAndPool() []*PoolQueueResource

+ type PoolQueueResource struct

+ Pool string

+ Queue string

+ Resources map[string]*resource.Quantity

+ func (*PoolQueueResource) Descriptor() ([]byte, []int)

+ func (*PoolQueueResource) ProtoMessage()

+ func (m *PoolQueueResource) GetPool() string

+ func (m *PoolQueueResource) GetQueue() string

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

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

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

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

+ func (m *PoolQueueResource) Reset()

+ func (m *PoolQueueResource) Size() (n int)

+ func (m *PoolQueueResource) String() string

+ func (m *PoolQueueResource) Unmarshal(dAtA []byte) error

+ func (m *PoolQueueResource) XXX_DiscardUnknown()

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

+ func (m *PoolQueueResource) XXX_Merge(src proto.Message)

+ func (m *PoolQueueResource) XXX_Size() int

+ func (m *PoolQueueResource) XXX_Unmarshal(b []byte) error

Sep 12, 2024

Changes in this version

type CancelRuns

+ JobRunIdsToCancelStr []string

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

type JobRunLease

+ JobRunIdStr string

+ func (m *JobRunLease) GetJobRunIdStr() string

type LeaseRequest

+ UnassignedJobRunIdsStr []string

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

type PreemptRuns

+ JobRunIdsToPreemptStr []string

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

Jul 9, 2024

Changes in this version

type NodeInfo

+ Pool string

+ func (m *NodeInfo) GetPool() string

Jul 4, 2024

Changes in this version

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

type ComputeResource

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

Feb 15, 2024

Changes in this version

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

+ type ComputeResource struct

+ Resources map[string]resource.Quantity

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

+ func (*ComputeResource) ProtoMessage()

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

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

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

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

+ func (m *ComputeResource) Reset()

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

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

+ func (m *ComputeResource) XXX_DiscardUnknown()

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

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

+ func (m *ComputeResource) XXX_Size() int

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

+ func (this *ComputeResource) String() string

+ type NodeInfo struct

+ AllocatableResources map[string]resource.Quantity

+ AllocatedResources map[int32]ComputeResource

+ AvailableResources map[string]resource.Quantity

+ Labels map[string]string

+ Name string

+ NodeType string

+ NonArmadaAllocatedResources map[int32]ComputeResource

+ ResourceUsageByQueue map[string]*ComputeResource

+ RunIdsByState map[string]api.JobState

+ Taints []v1.Taint

+ TotalResources map[string]resource.Quantity

+ Unschedulable bool

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

+ func (*NodeInfo) ProtoMessage()

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

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

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

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

+ func (m *NodeInfo) GetName() string

+ func (m *NodeInfo) GetNodeType() string

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

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

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

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

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

+ func (m *NodeInfo) GetUnschedulable() bool

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

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

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

+ func (m *NodeInfo) Reset()

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

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

+ func (m *NodeInfo) XXX_DiscardUnknown()

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

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

+ func (m *NodeInfo) XXX_Size() int

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

+ func (this *NodeInfo) String() string

Aug 31, 2023

Changes in this version

type LeaseRequest

+ MaxJobsToLease uint32

+ func (m *LeaseRequest) GetMaxJobsToLease() uint32

Mar 2, 2023

Changes in this version

type LeaseStreamMessage

+ func (m *LeaseStreamMessage) GetPreemptRuns() *PreemptRuns

+ type LeaseStreamMessage_PreemptRuns struct

+ PreemptRuns *PreemptRuns

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

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

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

+ func (this *LeaseStreamMessage_PreemptRuns) String() string

+ type PreemptRuns struct

+ JobRunIdsToPreempt []*armadaevents.Uuid

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

+ func (*PreemptRuns) ProtoMessage()

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

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

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

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

+ func (m *PreemptRuns) Reset()

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

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

+ func (m *PreemptRuns) XXX_DiscardUnknown()

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

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

+ func (m *PreemptRuns) XXX_Size() int

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

+ func (this *PreemptRuns) String() string

Jan 23, 2023

Changes in this version

+ var ErrIntOverflowExecutorapi = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthExecutorapi = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupExecutorapi = fmt.Errorf("proto: unexpected end of group")

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

+ type CancelRuns struct

+ JobRunIdsToCancel []*armadaevents.Uuid

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

+ func (*CancelRuns) ProtoMessage()

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

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

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

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

+ func (m *CancelRuns) Reset()

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

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

+ func (m *CancelRuns) XXX_DiscardUnknown()

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

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

+ func (m *CancelRuns) XXX_Size() int

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

+ func (this *CancelRuns) String() string

+ type EndMarker struct

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

+ func (*EndMarker) ProtoMessage()

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

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

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

+ func (m *EndMarker) Reset()

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

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

+ func (m *EndMarker) XXX_DiscardUnknown()

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

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

+ func (m *EndMarker) XXX_Size() int

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

+ func (this *EndMarker) String() string

+ type EventList struct

+ Events []*armadaevents.EventSequence

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

+ func (*EventList) ProtoMessage()

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

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

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

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

+ func (m *EventList) Reset()

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

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

+ func (m *EventList) XXX_DiscardUnknown()

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

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

+ func (m *EventList) XXX_Size() int

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

+ func (this *EventList) String() string

+ type ExecutorApiClient interface

+ LeaseJobRuns func(ctx context.Context, opts ...grpc.CallOption) (ExecutorApi_LeaseJobRunsClient, error)

+ ReportEvents func(ctx context.Context, in *EventList, opts ...grpc.CallOption) (*types.Empty, error)

+ func NewExecutorApiClient(cc *grpc.ClientConn) ExecutorApiClient

+ type ExecutorApiServer interface

+ LeaseJobRuns func(ExecutorApi_LeaseJobRunsServer) error

+ ReportEvents func(context.Context, *EventList) (*types.Empty, error)

+ type ExecutorApi_LeaseJobRunsClient interface

+ Recv func() (*LeaseStreamMessage, error)

+ Send func(*LeaseRequest) error

+ type ExecutorApi_LeaseJobRunsServer interface

+ Recv func() (*LeaseRequest, error)

+ Send func(*LeaseStreamMessage) error

+ type JobRunLease struct

+ Groups []string

+ Job *armadaevents.SubmitJob

+ JobRunId *armadaevents.Uuid

+ Jobset string

+ Queue string

+ User string

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

+ func (*JobRunLease) ProtoMessage()

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

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

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

+ func (m *JobRunLease) GetJobset() string

+ func (m *JobRunLease) GetQueue() string

+ func (m *JobRunLease) GetUser() string

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

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

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

+ func (m *JobRunLease) Reset()

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

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

+ func (m *JobRunLease) XXX_DiscardUnknown()

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

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

+ func (m *JobRunLease) XXX_Size() int

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

+ func (this *JobRunLease) String() string

+ type LeaseRequest struct

+ ExecutorId string

+ MinimumJobSize map[string]resource.Quantity

+ Nodes []*api.NodeInfo

+ Pool string

+ Resources map[string]resource.Quantity

+ UnassignedJobRunIds []armadaevents.Uuid

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

+ func (*LeaseRequest) ProtoMessage()

+ func (m *LeaseRequest) GetExecutorId() string

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

+ func (m *LeaseRequest) GetNodes() []*api.NodeInfo

+ func (m *LeaseRequest) GetPool() string

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

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

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

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

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

+ func (m *LeaseRequest) Reset()

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

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

+ func (m *LeaseRequest) XXX_DiscardUnknown()

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

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

+ func (m *LeaseRequest) XXX_Size() int

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

+ func (this *LeaseRequest) String() string

+ type LeaseStreamMessage struct

+ Event isLeaseStreamMessage_Event

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

+ func (*LeaseStreamMessage) ProtoMessage()

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

+ func (m *LeaseStreamMessage) GetCancelRuns() *CancelRuns

+ func (m *LeaseStreamMessage) GetEnd() *EndMarker

+ func (m *LeaseStreamMessage) GetEvent() isLeaseStreamMessage_Event

+ func (m *LeaseStreamMessage) GetLease() *JobRunLease

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

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

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

+ func (m *LeaseStreamMessage) Reset()

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

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

+ func (m *LeaseStreamMessage) XXX_DiscardUnknown()

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

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

+ func (m *LeaseStreamMessage) XXX_Size() int

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

+ func (this *LeaseStreamMessage) String() string

+ type LeaseStreamMessage_CancelRuns struct

+ CancelRuns *CancelRuns

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

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

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

+ func (this *LeaseStreamMessage_CancelRuns) String() string

+ type LeaseStreamMessage_End struct

+ End *EndMarker

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

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

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

+ func (this *LeaseStreamMessage_End) String() string

+ type LeaseStreamMessage_Lease struct

+ Lease *JobRunLease

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

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

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

+ func (this *LeaseStreamMessage_Lease) String() string

+ type UnimplementedExecutorApiServer struct

+ func (*UnimplementedExecutorApiServer) LeaseJobRuns(srv ExecutorApi_LeaseJobRunsServer) error

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