armadaevents

package
v0.3.65-rc-2b89a23 Latest Latest
Warning

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

Go to latest
Published: May 11, 2023 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthEvents        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEvents          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupEvents = fmt.Errorf("proto: unexpected end of group")
)
View Source
var JobState_name = map[int32]string{
	0: "QUEUED",
	1: "PENDING",
	2: "RUNNING",
}
View Source
var JobState_value = map[string]int32{
	"QUEUED":  0,
	"PENDING": 1,
	"RUNNING": 2,
}
View Source
var KubernetesReason_name = map[int32]string{
	0: "AppError",
	1: "Evicted",
	2: "OOM",
	3: "DeadlineExceeded",
}
View Source
var KubernetesReason_value = map[string]int32{
	"AppError":         0,
	"Evicted":          1,
	"OOM":              2,
	"DeadlineExceeded": 3,
}

Functions

func GetQueue

func GetQueue(ctx context.Context, req *api.QueueGetRequest) (*api.Queue, error)

func GetQueueInfo

func GetQueueInfo(ctx context.Context, req *api.QueueInfoRequest) (*api.QueueInfo, error)

func UlidFromProtoUuid

func UlidFromProtoUuid(protoUuid *Uuid) ulid.ULID

UlidFromProtoUuid creates and returns a ulid.ULID from an armadaevents.Uuid (i.e., the efficient representation used in proto messages).

func UlidStringFromProtoUuid

func UlidStringFromProtoUuid(id *Uuid) (string, error)

UlidStringFromProtoUuid returns a string representation of a proto UUID. Because Kubernetes requires ids to be valid DNS subdomain names, the string is returned in lower-case; see https://kubernetes.io/docs/concepts/overview/working-with-objects/names/#dns-subdomain-names

func UuidFromProtoUuid

func UuidFromProtoUuid(id *Uuid) uuid.UUID

UuidFromProtoUuid creates and returns a uuid.UUID from an armadaevents.Uuid (i.e., the efficient representation used in proto messages).

func UuidStringFromProtoUuid

func UuidStringFromProtoUuid(id *Uuid) (string, error)

Types

type CancelJob

type CancelJob struct {
	JobId *Uuid `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"`
}

A request to cancel a particular job. This will cancel all runs (preempting it if running) for the job (i.e., move them to the failed state) and then cancel job itself (i.e., move it to the failed state).

func (*CancelJob) Descriptor

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

func (*CancelJob) GetJobId

func (m *CancelJob) GetJobId() *Uuid

func (*CancelJob) Marshal

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

func (*CancelJob) MarshalTo

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

func (*CancelJob) MarshalToSizedBuffer

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

func (*CancelJob) ProtoMessage

func (*CancelJob) ProtoMessage()

func (*CancelJob) Reset

func (m *CancelJob) Reset()

func (*CancelJob) Size

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

func (*CancelJob) String

func (m *CancelJob) String() string

func (*CancelJob) Unmarshal

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

func (*CancelJob) XXX_DiscardUnknown

func (m *CancelJob) XXX_DiscardUnknown()

func (*CancelJob) XXX_Marshal

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

func (*CancelJob) XXX_Merge

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

func (*CancelJob) XXX_Size

func (m *CancelJob) XXX_Size() int

func (*CancelJob) XXX_Unmarshal

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

type CancelJobSet

type CancelJobSet struct {
	States []JobState `protobuf:"varint,1,rep,packed,name=states,proto3,enum=armadaevents.JobState" json:"states,omitempty"`
}

Request to cancel all jobs in a job set. Empty set of states means all states

func (*CancelJobSet) Descriptor

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

func (*CancelJobSet) GetStates added in v0.3.49

func (m *CancelJobSet) GetStates() []JobState

func (*CancelJobSet) Marshal

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

func (*CancelJobSet) MarshalTo

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

func (*CancelJobSet) MarshalToSizedBuffer

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

func (*CancelJobSet) ProtoMessage

func (*CancelJobSet) ProtoMessage()

func (*CancelJobSet) Reset

func (m *CancelJobSet) Reset()

func (*CancelJobSet) Size

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

func (*CancelJobSet) String

func (m *CancelJobSet) String() string

func (*CancelJobSet) Unmarshal

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

func (*CancelJobSet) XXX_DiscardUnknown

func (m *CancelJobSet) XXX_DiscardUnknown()

func (*CancelJobSet) XXX_Marshal

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

func (*CancelJobSet) XXX_Merge

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

func (*CancelJobSet) XXX_Size

func (m *CancelJobSet) XXX_Size() int

func (*CancelJobSet) XXX_Unmarshal

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

type CancelledJob

type CancelledJob struct {
	JobId *Uuid `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"`
}

Generated by the scheduler in response to CancelJob and CancelJobSet. One such message is generated per job that was cancelled.

func (*CancelledJob) Descriptor

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

func (*CancelledJob) GetJobId

func (m *CancelledJob) GetJobId() *Uuid

func (*CancelledJob) Marshal

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

func (*CancelledJob) MarshalTo

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

func (*CancelledJob) MarshalToSizedBuffer

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

func (*CancelledJob) ProtoMessage

func (*CancelledJob) ProtoMessage()

func (*CancelledJob) Reset

func (m *CancelledJob) Reset()

func (*CancelledJob) Size

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

func (*CancelledJob) String

func (m *CancelledJob) String() string

func (*CancelledJob) Unmarshal

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

func (*CancelledJob) XXX_DiscardUnknown

func (m *CancelledJob) XXX_DiscardUnknown()

func (*CancelledJob) XXX_Marshal

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

func (*CancelledJob) XXX_Merge

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

func (*CancelledJob) XXX_Size

func (m *CancelledJob) XXX_Size() int

func (*CancelledJob) XXX_Unmarshal

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

type ContainerError

type ContainerError struct {
	// this ObjectMeta identifies the container
	ObjectMeta *ObjectMeta `protobuf:"bytes,1,opt,name=objectMeta,proto3" json:"objectMeta,omitempty"`
	// Exit code of the application running in the container.
	ExitCode int32 `protobuf:"varint,2,opt,name=exit_code,json=exitCode,proto3" json:"exitCode,omitempty"`
	// Corresponds to v1.ContainerStateTerminated.Message
	Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// Corresponds to v1.ContainerStateTerminated.Reason
	Reason string `protobuf:"bytes,4,opt,name=reason,proto3" json:"reason,omitempty"`
	// Reason reported by Kubernetes.
	KubernetesReason KubernetesReason `` /* 144-byte string literal not displayed */
}

func (*ContainerError) Descriptor

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

func (*ContainerError) GetExitCode

func (m *ContainerError) GetExitCode() int32

func (*ContainerError) GetKubernetesReason

func (m *ContainerError) GetKubernetesReason() KubernetesReason

func (*ContainerError) GetMessage

func (m *ContainerError) GetMessage() string

func (*ContainerError) GetObjectMeta

func (m *ContainerError) GetObjectMeta() *ObjectMeta

func (*ContainerError) GetReason

func (m *ContainerError) GetReason() string

func (*ContainerError) Marshal

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

func (*ContainerError) MarshalTo

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

func (*ContainerError) MarshalToSizedBuffer

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

func (*ContainerError) ProtoMessage

func (*ContainerError) ProtoMessage()

func (*ContainerError) Reset

func (m *ContainerError) Reset()

func (*ContainerError) Size

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

func (*ContainerError) String

func (m *ContainerError) String() string

func (*ContainerError) Unmarshal

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

func (*ContainerError) XXX_DiscardUnknown

func (m *ContainerError) XXX_DiscardUnknown()

func (*ContainerError) XXX_Marshal

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

func (*ContainerError) XXX_Merge

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

func (*ContainerError) XXX_Size

func (m *ContainerError) XXX_Size() int

func (*ContainerError) XXX_Unmarshal

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

type Error

type Error struct {
	// If true, this error represents an unrecoverable failure and Armada has given up on this job or job run.
	Terminal bool `protobuf:"varint,1,opt,name=terminal,proto3" json:"terminal,omitempty"`
	// Additional information for this particular combination of component and error. May be set to nil.
	//
	// Types that are valid to be assigned to Reason:
	//	*Error_KubernetesError
	//	*Error_ContainerError
	//	*Error_ExecutorError
	//	*Error_PodUnschedulable
	//	*Error_LeaseExpired
	//	*Error_MaxRunsExceeded
	//	*Error_PodError
	//	*Error_PodLeaseReturned
	//	*Error_PodTerminated
	//	*Error_JobRunPreemptedError
	Reason isError_Reason `protobuf_oneof:"reason"`
}

Represents a failure that took place in the course of a job run (i.e., an attempt to run a job). Each failure is either a resource failure or a system-level failure. Resource failures correspond to a problem with a specific Kubernetes resource (e.g., if a container terminates with a non-zero exit code). System-level failure messages are created by the executor (e.g., a failure by the executor to write to Kubernetes).

This message may only be published to the log as part of a JobRunError message. TODO: Check if the container status contained any useful info for non-failed containers.

func (*Error) Descriptor

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

func (*Error) GetContainerError

func (m *Error) GetContainerError() *ContainerError

func (*Error) GetExecutorError

func (m *Error) GetExecutorError() *ExecutorError

func (*Error) GetJobRunPreemptedError added in v0.3.54

func (m *Error) GetJobRunPreemptedError() *JobRunPreemptedError

func (*Error) GetKubernetesError

func (m *Error) GetKubernetesError() *KubernetesError

func (*Error) GetLeaseExpired

func (m *Error) GetLeaseExpired() *LeaseExpired

func (*Error) GetMaxRunsExceeded

func (m *Error) GetMaxRunsExceeded() *MaxRunsExceeded

func (*Error) GetPodError

func (m *Error) GetPodError() *PodError

func (*Error) GetPodLeaseReturned

func (m *Error) GetPodLeaseReturned() *PodLeaseReturned

func (*Error) GetPodTerminated

func (m *Error) GetPodTerminated() *PodTerminated

func (*Error) GetPodUnschedulable

func (m *Error) GetPodUnschedulable() *PodUnschedulable

func (*Error) GetReason

func (m *Error) GetReason() isError_Reason

func (*Error) GetTerminal

func (m *Error) GetTerminal() bool

func (*Error) Marshal

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

func (*Error) MarshalTo

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

func (*Error) MarshalToSizedBuffer

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

func (*Error) ProtoMessage

func (*Error) ProtoMessage()

func (*Error) Reset

func (m *Error) Reset()

func (*Error) Size

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

func (*Error) String

func (m *Error) String() string

func (*Error) Unmarshal

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

func (*Error) XXX_DiscardUnknown

func (m *Error) XXX_DiscardUnknown()

func (*Error) XXX_Marshal

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

func (*Error) XXX_Merge

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

func (*Error) XXX_OneofWrappers

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*Error) XXX_Size

func (m *Error) XXX_Size() int

func (*Error) XXX_Unmarshal

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

type Error_ContainerError

type Error_ContainerError struct {
	ContainerError *ContainerError `protobuf:"bytes,3,opt,name=containerError,proto3,oneof" json:"containerError,omitempty"`
}

func (*Error_ContainerError) MarshalTo

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

func (*Error_ContainerError) MarshalToSizedBuffer

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

func (*Error_ContainerError) Size

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

type Error_ExecutorError

type Error_ExecutorError struct {
	ExecutorError *ExecutorError `protobuf:"bytes,4,opt,name=executorError,proto3,oneof" json:"executorError,omitempty"`
}

func (*Error_ExecutorError) MarshalTo

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

func (*Error_ExecutorError) MarshalToSizedBuffer

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

func (*Error_ExecutorError) Size

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

type Error_JobRunPreemptedError added in v0.3.54

type Error_JobRunPreemptedError struct {
	JobRunPreemptedError *JobRunPreemptedError `protobuf:"bytes,11,opt,name=jobRunPreemptedError,proto3,oneof" json:"jobRunPreemptedError,omitempty"`
}

func (*Error_JobRunPreemptedError) MarshalTo added in v0.3.54

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

func (*Error_JobRunPreemptedError) MarshalToSizedBuffer added in v0.3.54

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

func (*Error_JobRunPreemptedError) Size added in v0.3.54

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

type Error_KubernetesError

type Error_KubernetesError struct {
	KubernetesError *KubernetesError `protobuf:"bytes,2,opt,name=kubernetesError,proto3,oneof" json:"kubernetesError,omitempty"`
}

func (*Error_KubernetesError) MarshalTo

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

func (*Error_KubernetesError) MarshalToSizedBuffer

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

func (*Error_KubernetesError) Size

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

type Error_LeaseExpired

type Error_LeaseExpired struct {
	LeaseExpired *LeaseExpired `protobuf:"bytes,6,opt,name=leaseExpired,proto3,oneof" json:"leaseExpired,omitempty"`
}

func (*Error_LeaseExpired) MarshalTo

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

func (*Error_LeaseExpired) MarshalToSizedBuffer

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

func (*Error_LeaseExpired) Size

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

type Error_MaxRunsExceeded

type Error_MaxRunsExceeded struct {
	MaxRunsExceeded *MaxRunsExceeded `protobuf:"bytes,7,opt,name=maxRunsExceeded,proto3,oneof" json:"maxRunsExceeded,omitempty"`
}

func (*Error_MaxRunsExceeded) MarshalTo

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

func (*Error_MaxRunsExceeded) MarshalToSizedBuffer

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

func (*Error_MaxRunsExceeded) Size

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

type Error_PodError

type Error_PodError struct {
	PodError *PodError `protobuf:"bytes,8,opt,name=podError,proto3,oneof" json:"podError,omitempty"`
}

func (*Error_PodError) MarshalTo

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

func (*Error_PodError) MarshalToSizedBuffer

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

func (*Error_PodError) Size

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

type Error_PodLeaseReturned

type Error_PodLeaseReturned struct {
	PodLeaseReturned *PodLeaseReturned `protobuf:"bytes,9,opt,name=podLeaseReturned,proto3,oneof" json:"podLeaseReturned,omitempty"`
}

func (*Error_PodLeaseReturned) MarshalTo

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

func (*Error_PodLeaseReturned) MarshalToSizedBuffer

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

func (*Error_PodLeaseReturned) Size

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

type Error_PodTerminated

type Error_PodTerminated struct {
	PodTerminated *PodTerminated `protobuf:"bytes,10,opt,name=podTerminated,proto3,oneof" json:"podTerminated,omitempty"`
}

func (*Error_PodTerminated) MarshalTo

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

func (*Error_PodTerminated) MarshalToSizedBuffer

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

func (*Error_PodTerminated) Size

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

type Error_PodUnschedulable

type Error_PodUnschedulable struct {
	PodUnschedulable *PodUnschedulable `protobuf:"bytes,5,opt,name=podUnschedulable,proto3,oneof" json:"podUnschedulable,omitempty"`
}

func (*Error_PodUnschedulable) MarshalTo

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

func (*Error_PodUnschedulable) MarshalToSizedBuffer

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

func (*Error_PodUnschedulable) Size

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

type EventSequence

type EventSequence struct {
	// The system is namespaced by queue, and all events are associated with a job set.
	// Hence, these are included with every message.
	Queue string `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty"`
	// Each job set has a unique name.
	JobSetName string `protobuf:"bytes,2,opt,name=job_set_name,json=jobSetName,proto3" json:"jobSetName,omitempty"`
	// Id of the user submitting the message. Is passed on to Kubernetes.
	// Leave empty for messages generated by Armada itself.
	UserId string `protobuf:"bytes,3,opt,name=user_id,json=userId,proto3" json:"userId,omitempty"`
	// List of groups the user is member of. Is passed on to Kubernetes.
	Groups []string `protobuf:"bytes,4,rep,name=groups,proto3" json:"groups,omitempty"`
	// For efficiency, we bundle several events (i.e., state transitions) in a single log message.
	Events []*EventSequence_Event `protobuf:"bytes,5,rep,name=events,proto3" json:"events,omitempty"`
}

Message representing a sequence of state transitions. This is the only message type that should ever be published to the log.

func ExpectedSequenceFromRequestItem

func ExpectedSequenceFromRequestItem(armadaQueueName, armadaUserId, userNamespace, jobSetName string,
	jobId *Uuid, reqi *api.JobSubmitRequestItem,
) *EventSequence

ExpectedSequenceFromJobRequestItem returns the expected event sequence for a particular job request and response.

func (*EventSequence) Descriptor

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

func (*EventSequence) GetEvents

func (m *EventSequence) GetEvents() []*EventSequence_Event

func (*EventSequence) GetGroups

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

func (*EventSequence) GetJobSetName

func (m *EventSequence) GetJobSetName() string

func (*EventSequence) GetQueue

func (m *EventSequence) GetQueue() string

func (*EventSequence) GetUserId

func (m *EventSequence) GetUserId() string

func (*EventSequence) Marshal

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

func (*EventSequence) MarshalTo

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

func (*EventSequence) MarshalToSizedBuffer

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

func (*EventSequence) ProtoMessage

func (*EventSequence) ProtoMessage()

func (*EventSequence) Reset

func (m *EventSequence) Reset()

func (*EventSequence) Size

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

func (*EventSequence) String

func (m *EventSequence) String() string

func (*EventSequence) Unmarshal

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

func (*EventSequence) XXX_DiscardUnknown

func (m *EventSequence) XXX_DiscardUnknown()

func (*EventSequence) XXX_Marshal

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

func (*EventSequence) XXX_Merge

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

func (*EventSequence) XXX_Size

func (m *EventSequence) XXX_Size() int

func (*EventSequence) XXX_Unmarshal

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

type EventSequence_Event

type EventSequence_Event struct {
	Created *time.Time `protobuf:"bytes,18,opt,name=created,proto3,stdtime" json:"created,omitempty"`
	// Types that are valid to be assigned to Event:
	//	*EventSequence_Event_SubmitJob
	//	*EventSequence_Event_ReprioritiseJob
	//	*EventSequence_Event_ReprioritiseJobSet
	//	*EventSequence_Event_ReprioritisedJob
	//	*EventSequence_Event_CancelJob
	//	*EventSequence_Event_CancelJobSet
	//	*EventSequence_Event_CancelledJob
	//	*EventSequence_Event_JobSucceeded
	//	*EventSequence_Event_JobErrors
	//	*EventSequence_Event_JobRunLeased
	//	*EventSequence_Event_JobRunAssigned
	//	*EventSequence_Event_JobRunRunning
	//	*EventSequence_Event_JobRunSucceeded
	//	*EventSequence_Event_JobRunErrors
	//	*EventSequence_Event_JobDuplicateDetected
	//	*EventSequence_Event_StandaloneIngressInfo
	//	*EventSequence_Event_ResourceUtilisation
	//	*EventSequence_Event_JobRunPreempted
	//	*EventSequence_Event_PartitionMarker
	//	*EventSequence_Event_JobRunPreemptionRequested
	//	*EventSequence_Event_JobRequeued
	Event isEventSequence_Event_Event `protobuf_oneof:"event"`
}

List of possible events, i.e., state transitions.

func (*EventSequence_Event) Descriptor

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

func (*EventSequence_Event) GetCancelJob

func (m *EventSequence_Event) GetCancelJob() *CancelJob

func (*EventSequence_Event) GetCancelJobSet

func (m *EventSequence_Event) GetCancelJobSet() *CancelJobSet

func (*EventSequence_Event) GetCancelledJob

func (m *EventSequence_Event) GetCancelledJob() *CancelledJob

func (*EventSequence_Event) GetCreated

func (m *EventSequence_Event) GetCreated() *time.Time

func (*EventSequence_Event) GetEvent

func (m *EventSequence_Event) GetEvent() isEventSequence_Event_Event

func (*EventSequence_Event) GetJobDuplicateDetected

func (m *EventSequence_Event) GetJobDuplicateDetected() *JobDuplicateDetected

func (*EventSequence_Event) GetJobErrors

func (m *EventSequence_Event) GetJobErrors() *JobErrors

func (*EventSequence_Event) GetJobRequeued added in v0.3.63

func (m *EventSequence_Event) GetJobRequeued() *JobRequeued

func (*EventSequence_Event) GetJobRunAssigned

func (m *EventSequence_Event) GetJobRunAssigned() *JobRunAssigned

func (*EventSequence_Event) GetJobRunErrors

func (m *EventSequence_Event) GetJobRunErrors() *JobRunErrors

func (*EventSequence_Event) GetJobRunLeased

func (m *EventSequence_Event) GetJobRunLeased() *JobRunLeased

func (*EventSequence_Event) GetJobRunPreempted

func (m *EventSequence_Event) GetJobRunPreempted() *JobRunPreempted

func (*EventSequence_Event) GetJobRunPreemptionRequested added in v0.3.53

func (m *EventSequence_Event) GetJobRunPreemptionRequested() *JobRunPreemptionRequested

func (*EventSequence_Event) GetJobRunRunning

func (m *EventSequence_Event) GetJobRunRunning() *JobRunRunning

func (*EventSequence_Event) GetJobRunSucceeded

func (m *EventSequence_Event) GetJobRunSucceeded() *JobRunSucceeded

func (*EventSequence_Event) GetJobSucceeded

func (m *EventSequence_Event) GetJobSucceeded() *JobSucceeded

func (*EventSequence_Event) GetPartitionMarker added in v0.3.48

func (m *EventSequence_Event) GetPartitionMarker() *PartitionMarker

func (*EventSequence_Event) GetReprioritiseJob

func (m *EventSequence_Event) GetReprioritiseJob() *ReprioritiseJob

func (*EventSequence_Event) GetReprioritiseJobSet

func (m *EventSequence_Event) GetReprioritiseJobSet() *ReprioritiseJobSet

func (*EventSequence_Event) GetReprioritisedJob

func (m *EventSequence_Event) GetReprioritisedJob() *ReprioritisedJob

func (*EventSequence_Event) GetResourceUtilisation

func (m *EventSequence_Event) GetResourceUtilisation() *ResourceUtilisation

func (*EventSequence_Event) GetStandaloneIngressInfo

func (m *EventSequence_Event) GetStandaloneIngressInfo() *StandaloneIngressInfo

func (*EventSequence_Event) GetSubmitJob

func (m *EventSequence_Event) GetSubmitJob() *SubmitJob

func (*EventSequence_Event) Marshal

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

func (*EventSequence_Event) MarshalTo

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

func (*EventSequence_Event) MarshalToSizedBuffer

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

func (*EventSequence_Event) ProtoMessage

func (*EventSequence_Event) ProtoMessage()

func (*EventSequence_Event) Reset

func (m *EventSequence_Event) Reset()

func (*EventSequence_Event) Size

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

func (*EventSequence_Event) String

func (m *EventSequence_Event) String() string

func (*EventSequence_Event) Unmarshal

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

func (*EventSequence_Event) UnmarshalJSON

func (ev *EventSequence_Event) UnmarshalJSON(data []byte) error

func (*EventSequence_Event) XXX_DiscardUnknown

func (m *EventSequence_Event) XXX_DiscardUnknown()

func (*EventSequence_Event) XXX_Marshal

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

func (*EventSequence_Event) XXX_Merge

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

func (*EventSequence_Event) XXX_OneofWrappers

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*EventSequence_Event) XXX_Size

func (m *EventSequence_Event) XXX_Size() int

func (*EventSequence_Event) XXX_Unmarshal

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

type EventSequence_Event_CancelJob

type EventSequence_Event_CancelJob struct {
	CancelJob *CancelJob `protobuf:"bytes,5,opt,name=cancelJob,proto3,oneof" json:"cancelJob,omitempty"`
}

func (*EventSequence_Event_CancelJob) MarshalTo

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

func (*EventSequence_Event_CancelJob) MarshalToSizedBuffer

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

func (*EventSequence_Event_CancelJob) Size

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

type EventSequence_Event_CancelJobSet

type EventSequence_Event_CancelJobSet struct {
	CancelJobSet *CancelJobSet `protobuf:"bytes,6,opt,name=cancelJobSet,proto3,oneof" json:"cancelJobSet,omitempty"`
}

func (*EventSequence_Event_CancelJobSet) MarshalTo

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

func (*EventSequence_Event_CancelJobSet) MarshalToSizedBuffer

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

func (*EventSequence_Event_CancelJobSet) Size

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

type EventSequence_Event_CancelledJob

type EventSequence_Event_CancelledJob struct {
	CancelledJob *CancelledJob `protobuf:"bytes,7,opt,name=cancelledJob,proto3,oneof" json:"cancelledJob,omitempty"`
}

func (*EventSequence_Event_CancelledJob) MarshalTo

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

func (*EventSequence_Event_CancelledJob) MarshalToSizedBuffer

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

func (*EventSequence_Event_CancelledJob) Size

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

type EventSequence_Event_JobDuplicateDetected

type EventSequence_Event_JobDuplicateDetected struct {
	JobDuplicateDetected *JobDuplicateDetected `protobuf:"bytes,15,opt,name=jobDuplicateDetected,proto3,oneof" json:"jobDuplicateDetected,omitempty"`
}

func (*EventSequence_Event_JobDuplicateDetected) MarshalTo

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

func (*EventSequence_Event_JobDuplicateDetected) MarshalToSizedBuffer

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

func (*EventSequence_Event_JobDuplicateDetected) Size

type EventSequence_Event_JobErrors

type EventSequence_Event_JobErrors struct {
	JobErrors *JobErrors `protobuf:"bytes,9,opt,name=jobErrors,proto3,oneof" json:"jobErrors,omitempty"`
}

func (*EventSequence_Event_JobErrors) MarshalTo

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

func (*EventSequence_Event_JobErrors) MarshalToSizedBuffer

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

func (*EventSequence_Event_JobErrors) Size

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

type EventSequence_Event_JobRequeued added in v0.3.63

type EventSequence_Event_JobRequeued struct {
	JobRequeued *JobRequeued `protobuf:"bytes,22,opt,name=jobRequeued,proto3,oneof" json:"jobRequeued,omitempty"`
}

func (*EventSequence_Event_JobRequeued) MarshalTo added in v0.3.63

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

func (*EventSequence_Event_JobRequeued) MarshalToSizedBuffer added in v0.3.63

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

func (*EventSequence_Event_JobRequeued) Size added in v0.3.63

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

type EventSequence_Event_JobRunAssigned

type EventSequence_Event_JobRunAssigned struct {
	JobRunAssigned *JobRunAssigned `protobuf:"bytes,11,opt,name=jobRunAssigned,proto3,oneof" json:"jobRunAssigned,omitempty"`
}

func (*EventSequence_Event_JobRunAssigned) MarshalTo

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

func (*EventSequence_Event_JobRunAssigned) MarshalToSizedBuffer

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

func (*EventSequence_Event_JobRunAssigned) Size

type EventSequence_Event_JobRunErrors

type EventSequence_Event_JobRunErrors struct {
	JobRunErrors *JobRunErrors `protobuf:"bytes,14,opt,name=jobRunErrors,proto3,oneof" json:"jobRunErrors,omitempty"`
}

func (*EventSequence_Event_JobRunErrors) MarshalTo

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

func (*EventSequence_Event_JobRunErrors) MarshalToSizedBuffer

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

func (*EventSequence_Event_JobRunErrors) Size

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

type EventSequence_Event_JobRunLeased

type EventSequence_Event_JobRunLeased struct {
	JobRunLeased *JobRunLeased `protobuf:"bytes,10,opt,name=jobRunLeased,proto3,oneof" json:"jobRunLeased,omitempty"`
}

func (*EventSequence_Event_JobRunLeased) MarshalTo

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

func (*EventSequence_Event_JobRunLeased) MarshalToSizedBuffer

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

func (*EventSequence_Event_JobRunLeased) Size

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

type EventSequence_Event_JobRunPreempted

type EventSequence_Event_JobRunPreempted struct {
	JobRunPreempted *JobRunPreempted `protobuf:"bytes,19,opt,name=jobRunPreempted,proto3,oneof" json:"jobRunPreempted,omitempty"`
}

func (*EventSequence_Event_JobRunPreempted) MarshalTo

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

func (*EventSequence_Event_JobRunPreempted) MarshalToSizedBuffer

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

func (*EventSequence_Event_JobRunPreempted) Size

type EventSequence_Event_JobRunPreemptionRequested added in v0.3.53

type EventSequence_Event_JobRunPreemptionRequested struct {
	JobRunPreemptionRequested *JobRunPreemptionRequested `protobuf:"bytes,21,opt,name=jobRunPreemptionRequested,proto3,oneof" json:"jobRunPreemptionRequested,omitempty"`
}

func (*EventSequence_Event_JobRunPreemptionRequested) MarshalTo added in v0.3.53

func (*EventSequence_Event_JobRunPreemptionRequested) MarshalToSizedBuffer added in v0.3.53

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

func (*EventSequence_Event_JobRunPreemptionRequested) Size added in v0.3.53

type EventSequence_Event_JobRunRunning

type EventSequence_Event_JobRunRunning struct {
	JobRunRunning *JobRunRunning `protobuf:"bytes,12,opt,name=jobRunRunning,proto3,oneof" json:"jobRunRunning,omitempty"`
}

func (*EventSequence_Event_JobRunRunning) MarshalTo

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

func (*EventSequence_Event_JobRunRunning) MarshalToSizedBuffer

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

func (*EventSequence_Event_JobRunRunning) Size

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

type EventSequence_Event_JobRunSucceeded

type EventSequence_Event_JobRunSucceeded struct {
	JobRunSucceeded *JobRunSucceeded `protobuf:"bytes,13,opt,name=jobRunSucceeded,proto3,oneof" json:"jobRunSucceeded,omitempty"`
}

func (*EventSequence_Event_JobRunSucceeded) MarshalTo

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

func (*EventSequence_Event_JobRunSucceeded) MarshalToSizedBuffer

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

func (*EventSequence_Event_JobRunSucceeded) Size

type EventSequence_Event_JobSucceeded

type EventSequence_Event_JobSucceeded struct {
	JobSucceeded *JobSucceeded `protobuf:"bytes,8,opt,name=jobSucceeded,proto3,oneof" json:"jobSucceeded,omitempty"`
}

func (*EventSequence_Event_JobSucceeded) MarshalTo

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

func (*EventSequence_Event_JobSucceeded) MarshalToSizedBuffer

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

func (*EventSequence_Event_JobSucceeded) Size

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

type EventSequence_Event_PartitionMarker added in v0.3.48

type EventSequence_Event_PartitionMarker struct {
	PartitionMarker *PartitionMarker `protobuf:"bytes,20,opt,name=partitionMarker,proto3,oneof" json:"partitionMarker,omitempty"`
}

func (*EventSequence_Event_PartitionMarker) MarshalTo added in v0.3.48

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

func (*EventSequence_Event_PartitionMarker) MarshalToSizedBuffer added in v0.3.48

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

func (*EventSequence_Event_PartitionMarker) Size added in v0.3.48

type EventSequence_Event_ReprioritiseJob

type EventSequence_Event_ReprioritiseJob struct {
	ReprioritiseJob *ReprioritiseJob `protobuf:"bytes,2,opt,name=reprioritiseJob,proto3,oneof" json:"reprioritiseJob,omitempty"`
}

func (*EventSequence_Event_ReprioritiseJob) MarshalTo

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

func (*EventSequence_Event_ReprioritiseJob) MarshalToSizedBuffer

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

func (*EventSequence_Event_ReprioritiseJob) Size

type EventSequence_Event_ReprioritiseJobSet

type EventSequence_Event_ReprioritiseJobSet struct {
	ReprioritiseJobSet *ReprioritiseJobSet `protobuf:"bytes,3,opt,name=reprioritiseJobSet,proto3,oneof" json:"reprioritiseJobSet,omitempty"`
}

func (*EventSequence_Event_ReprioritiseJobSet) MarshalTo

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

func (*EventSequence_Event_ReprioritiseJobSet) MarshalToSizedBuffer

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

func (*EventSequence_Event_ReprioritiseJobSet) Size

type EventSequence_Event_ReprioritisedJob

type EventSequence_Event_ReprioritisedJob struct {
	ReprioritisedJob *ReprioritisedJob `protobuf:"bytes,4,opt,name=reprioritisedJob,proto3,oneof" json:"reprioritisedJob,omitempty"`
}

func (*EventSequence_Event_ReprioritisedJob) MarshalTo

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

func (*EventSequence_Event_ReprioritisedJob) MarshalToSizedBuffer

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

func (*EventSequence_Event_ReprioritisedJob) Size

type EventSequence_Event_ResourceUtilisation

type EventSequence_Event_ResourceUtilisation struct {
	ResourceUtilisation *ResourceUtilisation `protobuf:"bytes,17,opt,name=resourceUtilisation,proto3,oneof" json:"resourceUtilisation,omitempty"`
}

func (*EventSequence_Event_ResourceUtilisation) MarshalTo

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

func (*EventSequence_Event_ResourceUtilisation) MarshalToSizedBuffer

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

func (*EventSequence_Event_ResourceUtilisation) Size

type EventSequence_Event_StandaloneIngressInfo

type EventSequence_Event_StandaloneIngressInfo struct {
	StandaloneIngressInfo *StandaloneIngressInfo `protobuf:"bytes,16,opt,name=standaloneIngressInfo,proto3,oneof" json:"standaloneIngressInfo,omitempty"`
}

func (*EventSequence_Event_StandaloneIngressInfo) MarshalTo

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

func (*EventSequence_Event_StandaloneIngressInfo) MarshalToSizedBuffer

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

func (*EventSequence_Event_StandaloneIngressInfo) Size

type EventSequence_Event_SubmitJob

type EventSequence_Event_SubmitJob struct {
	SubmitJob *SubmitJob `protobuf:"bytes,1,opt,name=submitJob,proto3,oneof" json:"submitJob,omitempty"`
}

func (*EventSequence_Event_SubmitJob) MarshalTo

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

func (*EventSequence_Event_SubmitJob) MarshalToSizedBuffer

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

func (*EventSequence_Event_SubmitJob) Size

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

type ExecutorError

type ExecutorError struct {
}

func (*ExecutorError) Descriptor

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

func (*ExecutorError) Marshal

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

func (*ExecutorError) MarshalTo

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

func (*ExecutorError) MarshalToSizedBuffer

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

func (*ExecutorError) ProtoMessage

func (*ExecutorError) ProtoMessage()

func (*ExecutorError) Reset

func (m *ExecutorError) Reset()

func (*ExecutorError) Size

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

func (*ExecutorError) String

func (m *ExecutorError) String() string

func (*ExecutorError) Unmarshal

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

func (*ExecutorError) XXX_DiscardUnknown

func (m *ExecutorError) XXX_DiscardUnknown()

func (*ExecutorError) XXX_Marshal

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

func (*ExecutorError) XXX_Merge

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

func (*ExecutorError) XXX_Size

func (m *ExecutorError) XXX_Size() int

func (*ExecutorError) XXX_Unmarshal

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

type IngressInfo

type IngressInfo struct {
	// TODO: Why a node name?
	NodeName string `protobuf:"bytes,1,opt,name=node_name,json=nodeName,proto3" json:"nodeName,omitempty"`
	// TODO: Why a map?
	IngressAddresses map[int32]string `` /* 197-byte string literal not displayed */
}

Runtime information of an ingress.

func (*IngressInfo) Descriptor

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

func (*IngressInfo) GetIngressAddresses

func (m *IngressInfo) GetIngressAddresses() map[int32]string

func (*IngressInfo) GetNodeName

func (m *IngressInfo) GetNodeName() string

func (*IngressInfo) Marshal

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

func (*IngressInfo) MarshalTo

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

func (*IngressInfo) MarshalToSizedBuffer

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

func (*IngressInfo) ProtoMessage

func (*IngressInfo) ProtoMessage()

func (*IngressInfo) Reset

func (m *IngressInfo) Reset()

func (*IngressInfo) Size

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

func (*IngressInfo) String

func (m *IngressInfo) String() string

func (*IngressInfo) Unmarshal

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

func (*IngressInfo) XXX_DiscardUnknown

func (m *IngressInfo) XXX_DiscardUnknown()

func (*IngressInfo) XXX_Marshal

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

func (*IngressInfo) XXX_Merge

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

func (*IngressInfo) XXX_Size

func (m *IngressInfo) XXX_Size() int

func (*IngressInfo) XXX_Unmarshal

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

type JobDuplicateDetected

type JobDuplicateDetected struct {
	NewJobId *Uuid `protobuf:"bytes,1,opt,name=new_job_id,json=newJobId,proto3" json:"newJobId,omitempty"`
	OldJobId *Uuid `protobuf:"bytes,2,opt,name=old_job_id,json=oldJobId,proto3" json:"oldJobId,omitempty"`
}

Generated by the scheduler whenever it detects a SubmitJob message that includes a previously used deduplication id (i.e., when it detects a duplicate job submission).

func (*JobDuplicateDetected) Descriptor

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

func (*JobDuplicateDetected) GetNewJobId

func (m *JobDuplicateDetected) GetNewJobId() *Uuid

func (*JobDuplicateDetected) GetOldJobId

func (m *JobDuplicateDetected) GetOldJobId() *Uuid

func (*JobDuplicateDetected) Marshal

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

func (*JobDuplicateDetected) MarshalTo

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

func (*JobDuplicateDetected) MarshalToSizedBuffer

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

func (*JobDuplicateDetected) ProtoMessage

func (*JobDuplicateDetected) ProtoMessage()

func (*JobDuplicateDetected) Reset

func (m *JobDuplicateDetected) Reset()

func (*JobDuplicateDetected) Size

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

func (*JobDuplicateDetected) String

func (m *JobDuplicateDetected) String() string

func (*JobDuplicateDetected) Unmarshal

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

func (*JobDuplicateDetected) XXX_DiscardUnknown

func (m *JobDuplicateDetected) XXX_DiscardUnknown()

func (*JobDuplicateDetected) XXX_Marshal

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

func (*JobDuplicateDetected) XXX_Merge

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

func (*JobDuplicateDetected) XXX_Size

func (m *JobDuplicateDetected) XXX_Size() int

func (*JobDuplicateDetected) XXX_Unmarshal

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

type JobErrors

type JobErrors struct {
	JobId *Uuid `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"`
	// A set of errors that occurred within some context.
	Errors []*Error `protobuf:"bytes,2,rep,name=errors,proto3" json:"errors,omitempty"`
}

Message containing a set of errors associated with a particular job. Contains a flag, which if set to true indicates that the job has failed. Otherwise, this message represents a set of errors from which the system has recovered.

func (*JobErrors) Descriptor

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

func (*JobErrors) GetErrors

func (m *JobErrors) GetErrors() []*Error

func (*JobErrors) GetJobId

func (m *JobErrors) GetJobId() *Uuid

func (*JobErrors) Marshal

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

func (*JobErrors) MarshalTo

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

func (*JobErrors) MarshalToSizedBuffer

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

func (*JobErrors) ProtoMessage

func (*JobErrors) ProtoMessage()

func (*JobErrors) Reset

func (m *JobErrors) Reset()

func (*JobErrors) Size

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

func (*JobErrors) String

func (m *JobErrors) String() string

func (*JobErrors) Unmarshal

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

func (*JobErrors) XXX_DiscardUnknown

func (m *JobErrors) XXX_DiscardUnknown()

func (*JobErrors) XXX_Marshal

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

func (*JobErrors) XXX_Merge

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

func (*JobErrors) XXX_Size

func (m *JobErrors) XXX_Size() int

func (*JobErrors) XXX_Unmarshal

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

type JobRequeued added in v0.3.63

type JobRequeued struct {
	JobId          *Uuid                               `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"`
	SchedulingInfo *schedulerobjects.JobSchedulingInfo `protobuf:"bytes,2,opt,name=scheduling_info,json=schedulingInfo,proto3" json:"schedulingInfo,omitempty"`
	// Used by the scheduler to maintain a consistent state
	UpdateSequenceNumber int32 `protobuf:"varint,3,opt,name=update_sequence_number,json=updateSequenceNumber,proto3" json:"updateSequenceNumber,omitempty"`
}

func (*JobRequeued) Descriptor added in v0.3.63

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

func (*JobRequeued) GetJobId added in v0.3.63

func (m *JobRequeued) GetJobId() *Uuid

func (*JobRequeued) GetSchedulingInfo added in v0.3.63

func (m *JobRequeued) GetSchedulingInfo() *schedulerobjects.JobSchedulingInfo

func (*JobRequeued) GetUpdateSequenceNumber added in v0.3.63

func (m *JobRequeued) GetUpdateSequenceNumber() int32

func (*JobRequeued) Marshal added in v0.3.63

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

func (*JobRequeued) MarshalTo added in v0.3.63

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

func (*JobRequeued) MarshalToSizedBuffer added in v0.3.63

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

func (*JobRequeued) ProtoMessage added in v0.3.63

func (*JobRequeued) ProtoMessage()

func (*JobRequeued) Reset added in v0.3.63

func (m *JobRequeued) Reset()

func (*JobRequeued) Size added in v0.3.63

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

func (*JobRequeued) String added in v0.3.63

func (m *JobRequeued) String() string

func (*JobRequeued) Unmarshal added in v0.3.63

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

func (*JobRequeued) XXX_DiscardUnknown added in v0.3.63

func (m *JobRequeued) XXX_DiscardUnknown()

func (*JobRequeued) XXX_Marshal added in v0.3.63

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

func (*JobRequeued) XXX_Merge added in v0.3.63

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

func (*JobRequeued) XXX_Size added in v0.3.63

func (m *JobRequeued) XXX_Size() int

func (*JobRequeued) XXX_Unmarshal added in v0.3.63

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

type JobRunAssigned

type JobRunAssigned struct {
	RunId *Uuid `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"runId,omitempty"`
	JobId *Uuid `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"`
	// Runtime information, e.g., which node the job is running on, its IP address etc,
	// for each resource created for the job run.
	// Included here and in JobRunRunning for compatibility with legacy messages.
	ResourceInfos []*KubernetesResourceInfo `protobuf:"bytes,3,rep,name=resourceInfos,proto3" json:"resourceInfos,omitempty"`
}

Indicates that a job has been assigned to nodes by Kubernetes.

func (*JobRunAssigned) Descriptor

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

func (*JobRunAssigned) GetJobId

func (m *JobRunAssigned) GetJobId() *Uuid

func (*JobRunAssigned) GetResourceInfos

func (m *JobRunAssigned) GetResourceInfos() []*KubernetesResourceInfo

func (*JobRunAssigned) GetRunId

func (m *JobRunAssigned) GetRunId() *Uuid

func (*JobRunAssigned) Marshal

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

func (*JobRunAssigned) MarshalTo

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

func (*JobRunAssigned) MarshalToSizedBuffer

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

func (*JobRunAssigned) ProtoMessage

func (*JobRunAssigned) ProtoMessage()

func (*JobRunAssigned) Reset

func (m *JobRunAssigned) Reset()

func (*JobRunAssigned) Size

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

func (*JobRunAssigned) String

func (m *JobRunAssigned) String() string

func (*JobRunAssigned) Unmarshal

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

func (*JobRunAssigned) XXX_DiscardUnknown

func (m *JobRunAssigned) XXX_DiscardUnknown()

func (*JobRunAssigned) XXX_Marshal

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

func (*JobRunAssigned) XXX_Merge

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

func (*JobRunAssigned) XXX_Size

func (m *JobRunAssigned) XXX_Size() int

func (*JobRunAssigned) XXX_Unmarshal

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

type JobRunErrors

type JobRunErrors struct {
	RunId *Uuid `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"runId,omitempty"`
	JobId *Uuid `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"`
	// A set of errors that occurred within some context.
	Errors []*Error `protobuf:"bytes,3,rep,name=errors,proto3" json:"errors,omitempty"`
}

Message containing a set of errors associated with a particular job run. Contains a flag, which if set to true indicates that the job run has failed. Otherwise, this message represents a set of errors from which the system has recovered.

Because each error may specify a parent error, the set of errors form a tree.

Services may listen for these messages to obtain realtime information about errors associated with jobs.

func (*JobRunErrors) Descriptor

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

func (*JobRunErrors) GetErrors

func (m *JobRunErrors) GetErrors() []*Error

func (*JobRunErrors) GetJobId

func (m *JobRunErrors) GetJobId() *Uuid

func (*JobRunErrors) GetRunId

func (m *JobRunErrors) GetRunId() *Uuid

func (*JobRunErrors) Marshal

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

func (*JobRunErrors) MarshalTo

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

func (*JobRunErrors) MarshalToSizedBuffer

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

func (*JobRunErrors) ProtoMessage

func (*JobRunErrors) ProtoMessage()

func (*JobRunErrors) Reset

func (m *JobRunErrors) Reset()

func (*JobRunErrors) Size

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

func (*JobRunErrors) String

func (m *JobRunErrors) String() string

func (*JobRunErrors) Unmarshal

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

func (*JobRunErrors) XXX_DiscardUnknown

func (m *JobRunErrors) XXX_DiscardUnknown()

func (*JobRunErrors) XXX_Marshal

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

func (*JobRunErrors) XXX_Merge

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

func (*JobRunErrors) XXX_Size

func (m *JobRunErrors) XXX_Size() int

func (*JobRunErrors) XXX_Unmarshal

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

type JobRunLeased

type JobRunLeased struct {
	RunId *Uuid `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"runId,omitempty"`
	JobId *Uuid `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"`
	// Each cluster is represented by an executor.
	ExecutorId string `protobuf:"bytes,3,opt,name=executor_id,json=executorId,proto3" json:"executorId,omitempty"`
	NodeId     string `protobuf:"bytes,4,opt,name=node_id,json=nodeId,proto3" json:"nodeId,omitempty"`
	// Used by the scheduler to maintain a consistent state
	UpdateSequenceNumber int32 `protobuf:"varint,5,opt,name=update_sequence_number,json=updateSequenceNumber,proto3" json:"updateSequenceNumber,omitempty"`
}

Indicates that a job has been leased to a cluster by the Armada scheduler.

func (*JobRunLeased) Descriptor

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

func (*JobRunLeased) GetExecutorId

func (m *JobRunLeased) GetExecutorId() string

func (*JobRunLeased) GetJobId

func (m *JobRunLeased) GetJobId() *Uuid

func (*JobRunLeased) GetNodeId added in v0.3.50

func (m *JobRunLeased) GetNodeId() string

func (*JobRunLeased) GetRunId

func (m *JobRunLeased) GetRunId() *Uuid

func (*JobRunLeased) GetUpdateSequenceNumber added in v0.3.63

func (m *JobRunLeased) GetUpdateSequenceNumber() int32

func (*JobRunLeased) Marshal

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

func (*JobRunLeased) MarshalTo

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

func (*JobRunLeased) MarshalToSizedBuffer

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

func (*JobRunLeased) ProtoMessage

func (*JobRunLeased) ProtoMessage()

func (*JobRunLeased) Reset

func (m *JobRunLeased) Reset()

func (*JobRunLeased) Size

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

func (*JobRunLeased) String

func (m *JobRunLeased) String() string

func (*JobRunLeased) Unmarshal

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

func (*JobRunLeased) XXX_DiscardUnknown

func (m *JobRunLeased) XXX_DiscardUnknown()

func (*JobRunLeased) XXX_Marshal

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

func (*JobRunLeased) XXX_Merge

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

func (*JobRunLeased) XXX_Size

func (m *JobRunLeased) XXX_Size() int

func (*JobRunLeased) XXX_Unmarshal

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

type JobRunPreempted

type JobRunPreempted struct {
	// Uuid of the job that was preempted
	PreemptedJobId *Uuid `protobuf:"bytes,1,opt,name=preempted_job_id,json=preemptedJobId,proto3" json:"preemptedJobId,omitempty"`
	// Uuid of the job run that was preempted.
	PreemptedRunId *Uuid `protobuf:"bytes,2,opt,name=preempted_run_id,json=preemptedRunId,proto3" json:"preemptedRunId,omitempty"`
	// Uuid of the job that caused the preemption.
	PreemptiveJobId *Uuid `protobuf:"bytes,3,opt,name=preemptive_job_id,json=preemptiveJobId,proto3" json:"preemptiveJobId,omitempty"`
	// Uuid of the job run that caused the preemption.
	PreemptiveRunId *Uuid `protobuf:"bytes,4,opt,name=preemptive_run_id,json=preemptiveRunId,proto3" json:"preemptiveRunId,omitempty"`
}

Message to indicate that a JobRun has been preempted.

func (*JobRunPreempted) Descriptor

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

func (*JobRunPreempted) GetPreemptedJobId

func (m *JobRunPreempted) GetPreemptedJobId() *Uuid

func (*JobRunPreempted) GetPreemptedRunId

func (m *JobRunPreempted) GetPreemptedRunId() *Uuid

func (*JobRunPreempted) GetPreemptiveJobId

func (m *JobRunPreempted) GetPreemptiveJobId() *Uuid

func (*JobRunPreempted) GetPreemptiveRunId

func (m *JobRunPreempted) GetPreemptiveRunId() *Uuid

func (*JobRunPreempted) Marshal

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

func (*JobRunPreempted) MarshalTo

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

func (*JobRunPreempted) MarshalToSizedBuffer

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

func (*JobRunPreempted) ProtoMessage

func (*JobRunPreempted) ProtoMessage()

func (*JobRunPreempted) Reset

func (m *JobRunPreempted) Reset()

func (*JobRunPreempted) Size

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

func (*JobRunPreempted) String

func (m *JobRunPreempted) String() string

func (*JobRunPreempted) Unmarshal

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

func (*JobRunPreempted) XXX_DiscardUnknown

func (m *JobRunPreempted) XXX_DiscardUnknown()

func (*JobRunPreempted) XXX_Marshal

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

func (*JobRunPreempted) XXX_Merge

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

func (*JobRunPreempted) XXX_Size

func (m *JobRunPreempted) XXX_Size() int

func (*JobRunPreempted) XXX_Unmarshal

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

type JobRunPreemptedError added in v0.3.54

type JobRunPreemptedError struct {
}

func (*JobRunPreemptedError) Descriptor added in v0.3.54

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

func (*JobRunPreemptedError) Marshal added in v0.3.54

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

func (*JobRunPreemptedError) MarshalTo added in v0.3.54

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

func (*JobRunPreemptedError) MarshalToSizedBuffer added in v0.3.54

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

func (*JobRunPreemptedError) ProtoMessage added in v0.3.54

func (*JobRunPreemptedError) ProtoMessage()

func (*JobRunPreemptedError) Reset added in v0.3.54

func (m *JobRunPreemptedError) Reset()

func (*JobRunPreemptedError) Size added in v0.3.54

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

func (*JobRunPreemptedError) String added in v0.3.54

func (m *JobRunPreemptedError) String() string

func (*JobRunPreemptedError) Unmarshal added in v0.3.54

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

func (*JobRunPreemptedError) XXX_DiscardUnknown added in v0.3.54

func (m *JobRunPreemptedError) XXX_DiscardUnknown()

func (*JobRunPreemptedError) XXX_Marshal added in v0.3.54

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

func (*JobRunPreemptedError) XXX_Merge added in v0.3.54

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

func (*JobRunPreemptedError) XXX_Size added in v0.3.54

func (m *JobRunPreemptedError) XXX_Size() int

func (*JobRunPreemptedError) XXX_Unmarshal added in v0.3.54

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

type JobRunPreemptionRequested added in v0.3.53

type JobRunPreemptionRequested struct {
	RunId *Uuid `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"runId,omitempty"`
	JobId *Uuid `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"`
}

Indicates that the scheduler has requested for the job run to be pre-empted.

func (*JobRunPreemptionRequested) Descriptor added in v0.3.53

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

func (*JobRunPreemptionRequested) GetJobId added in v0.3.53

func (m *JobRunPreemptionRequested) GetJobId() *Uuid

func (*JobRunPreemptionRequested) GetRunId added in v0.3.53

func (m *JobRunPreemptionRequested) GetRunId() *Uuid

func (*JobRunPreemptionRequested) Marshal added in v0.3.53

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

func (*JobRunPreemptionRequested) MarshalTo added in v0.3.53

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

func (*JobRunPreemptionRequested) MarshalToSizedBuffer added in v0.3.53

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

func (*JobRunPreemptionRequested) ProtoMessage added in v0.3.53

func (*JobRunPreemptionRequested) ProtoMessage()

func (*JobRunPreemptionRequested) Reset added in v0.3.53

func (m *JobRunPreemptionRequested) Reset()

func (*JobRunPreemptionRequested) Size added in v0.3.53

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

func (*JobRunPreemptionRequested) String added in v0.3.53

func (m *JobRunPreemptionRequested) String() string

func (*JobRunPreemptionRequested) Unmarshal added in v0.3.53

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

func (*JobRunPreemptionRequested) XXX_DiscardUnknown added in v0.3.53

func (m *JobRunPreemptionRequested) XXX_DiscardUnknown()

func (*JobRunPreemptionRequested) XXX_Marshal added in v0.3.53

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

func (*JobRunPreemptionRequested) XXX_Merge added in v0.3.53

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

func (*JobRunPreemptionRequested) XXX_Size added in v0.3.53

func (m *JobRunPreemptionRequested) XXX_Size() int

func (*JobRunPreemptionRequested) XXX_Unmarshal added in v0.3.53

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

type JobRunRunning

type JobRunRunning struct {
	RunId *Uuid `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"runId,omitempty"`
	JobId *Uuid `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"`
	// Runtime information, e.g., which node the job is running on, its IP address etc,
	// for each resource created for the job run.
	ResourceInfos []*KubernetesResourceInfo `protobuf:"bytes,3,rep,name=resourceInfos,proto3" json:"resourceInfos,omitempty"`
}

Indicates that the resources required by the job have been created and that the job is now running.

func (*JobRunRunning) Descriptor

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

func (*JobRunRunning) GetJobId

func (m *JobRunRunning) GetJobId() *Uuid

func (*JobRunRunning) GetResourceInfos

func (m *JobRunRunning) GetResourceInfos() []*KubernetesResourceInfo

func (*JobRunRunning) GetRunId

func (m *JobRunRunning) GetRunId() *Uuid

func (*JobRunRunning) Marshal

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

func (*JobRunRunning) MarshalTo

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

func (*JobRunRunning) MarshalToSizedBuffer

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

func (*JobRunRunning) ProtoMessage

func (*JobRunRunning) ProtoMessage()

func (*JobRunRunning) Reset

func (m *JobRunRunning) Reset()

func (*JobRunRunning) Size

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

func (*JobRunRunning) String

func (m *JobRunRunning) String() string

func (*JobRunRunning) Unmarshal

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

func (*JobRunRunning) XXX_DiscardUnknown

func (m *JobRunRunning) XXX_DiscardUnknown()

func (*JobRunRunning) XXX_Marshal

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

func (*JobRunRunning) XXX_Merge

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

func (*JobRunRunning) XXX_Size

func (m *JobRunRunning) XXX_Size() int

func (*JobRunRunning) XXX_Unmarshal

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

type JobRunSucceeded

type JobRunSucceeded struct {
	RunId *Uuid `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"runId,omitempty"`
	JobId *Uuid `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"`
	// Runtime information, e.g., which node the job is running on, its IP address etc,
	// for each resource created for the job run.
	// TODO: remove this once we have fixed the external api
	ResourceInfos []*KubernetesResourceInfo `protobuf:"bytes,3,rep,name=resourceInfos,proto3" json:"resourceInfos,omitempty"`
}

Indicates that the job finished successfully (i.e., in the expected manner).

func (*JobRunSucceeded) Descriptor

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

func (*JobRunSucceeded) GetJobId

func (m *JobRunSucceeded) GetJobId() *Uuid

func (*JobRunSucceeded) GetResourceInfos

func (m *JobRunSucceeded) GetResourceInfos() []*KubernetesResourceInfo

func (*JobRunSucceeded) GetRunId

func (m *JobRunSucceeded) GetRunId() *Uuid

func (*JobRunSucceeded) Marshal

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

func (*JobRunSucceeded) MarshalTo

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

func (*JobRunSucceeded) MarshalToSizedBuffer

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

func (*JobRunSucceeded) ProtoMessage

func (*JobRunSucceeded) ProtoMessage()

func (*JobRunSucceeded) Reset

func (m *JobRunSucceeded) Reset()

func (*JobRunSucceeded) Size

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

func (*JobRunSucceeded) String

func (m *JobRunSucceeded) String() string

func (*JobRunSucceeded) Unmarshal

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

func (*JobRunSucceeded) XXX_DiscardUnknown

func (m *JobRunSucceeded) XXX_DiscardUnknown()

func (*JobRunSucceeded) XXX_Marshal

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

func (*JobRunSucceeded) XXX_Merge

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

func (*JobRunSucceeded) XXX_Size

func (m *JobRunSucceeded) XXX_Size() int

func (*JobRunSucceeded) XXX_Unmarshal

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

type JobSetFilter added in v0.3.49

type JobSetFilter struct {
	States []JobState `protobuf:"varint,1,rep,packed,name=states,proto3,enum=armadaevents.JobState" json:"states,omitempty"`
}

Filter to be used when cancelling job sets This allows users to cancel all jobs in a given state for a specific job set

func (*JobSetFilter) Descriptor added in v0.3.49

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

func (*JobSetFilter) GetStates added in v0.3.49

func (m *JobSetFilter) GetStates() []JobState

func (*JobSetFilter) Marshal added in v0.3.49

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

func (*JobSetFilter) MarshalTo added in v0.3.49

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

func (*JobSetFilter) MarshalToSizedBuffer added in v0.3.49

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

func (*JobSetFilter) ProtoMessage added in v0.3.49

func (*JobSetFilter) ProtoMessage()

func (*JobSetFilter) Reset added in v0.3.49

func (m *JobSetFilter) Reset()

func (*JobSetFilter) Size added in v0.3.49

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

func (*JobSetFilter) String added in v0.3.49

func (m *JobSetFilter) String() string

func (*JobSetFilter) Unmarshal added in v0.3.49

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

func (*JobSetFilter) XXX_DiscardUnknown added in v0.3.49

func (m *JobSetFilter) XXX_DiscardUnknown()

func (*JobSetFilter) XXX_Marshal added in v0.3.49

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

func (*JobSetFilter) XXX_Merge added in v0.3.49

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

func (*JobSetFilter) XXX_Size added in v0.3.49

func (m *JobSetFilter) XXX_Size() int

func (*JobSetFilter) XXX_Unmarshal added in v0.3.49

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

type JobState added in v0.3.49

type JobState int32
const (
	JobState_QUEUED  JobState = 0
	JobState_PENDING JobState = 1
	JobState_RUNNING JobState = 2
)

func (JobState) EnumDescriptor added in v0.3.49

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

func (JobState) String added in v0.3.49

func (x JobState) String() string

type JobSucceeded

type JobSucceeded struct {
	JobId *Uuid `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"`
	// Runtime information, e.g., which node the job is running on, its IP address etc,
	// for each resource created for the job run.
	// TODO: remove this once we have fixed the external api
	ResourceInfos []*KubernetesResourceInfo `protobuf:"bytes,2,rep,name=resourceInfos,proto3" json:"resourceInfos,omitempty"`
}

func (*JobSucceeded) Descriptor

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

func (*JobSucceeded) GetJobId

func (m *JobSucceeded) GetJobId() *Uuid

func (*JobSucceeded) GetResourceInfos

func (m *JobSucceeded) GetResourceInfos() []*KubernetesResourceInfo

func (*JobSucceeded) Marshal

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

func (*JobSucceeded) MarshalTo

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

func (*JobSucceeded) MarshalToSizedBuffer

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

func (*JobSucceeded) ProtoMessage

func (*JobSucceeded) ProtoMessage()

func (*JobSucceeded) Reset

func (m *JobSucceeded) Reset()

func (*JobSucceeded) Size

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

func (*JobSucceeded) String

func (m *JobSucceeded) String() string

func (*JobSucceeded) Unmarshal

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

func (*JobSucceeded) XXX_DiscardUnknown

func (m *JobSucceeded) XXX_DiscardUnknown()

func (*JobSucceeded) XXX_Marshal

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

func (*JobSucceeded) XXX_Merge

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

func (*JobSucceeded) XXX_Size

func (m *JobSucceeded) XXX_Size() int

func (*JobSucceeded) XXX_Unmarshal

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

type KubernetesError

type KubernetesError struct {
	// Type of Kubernetes resource (e.g., ingress).
	ResourceType string `protobuf:"bytes,1,opt,name=resourceType,proto3" json:"resourceType,omitempty"`
	// Id assigned to the resource by Kubernetes.
	ResourceId *Uuid `protobuf:"bytes,2,opt,name=resourceId,proto3" json:"resourceId,omitempty"`
}

Represents an error associated with a particular Kubernetes resource.

func (*KubernetesError) Descriptor

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

func (*KubernetesError) GetResourceId

func (m *KubernetesError) GetResourceId() *Uuid

func (*KubernetesError) GetResourceType

func (m *KubernetesError) GetResourceType() string

func (*KubernetesError) Marshal

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

func (*KubernetesError) MarshalTo

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

func (*KubernetesError) MarshalToSizedBuffer

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

func (*KubernetesError) ProtoMessage

func (*KubernetesError) ProtoMessage()

func (*KubernetesError) Reset

func (m *KubernetesError) Reset()

func (*KubernetesError) Size

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

func (*KubernetesError) String

func (m *KubernetesError) String() string

func (*KubernetesError) Unmarshal

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

func (*KubernetesError) XXX_DiscardUnknown

func (m *KubernetesError) XXX_DiscardUnknown()

func (*KubernetesError) XXX_Marshal

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

func (*KubernetesError) XXX_Merge

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

func (*KubernetesError) XXX_Size

func (m *KubernetesError) XXX_Size() int

func (*KubernetesError) XXX_Unmarshal

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

type KubernetesMainObject

type KubernetesMainObject struct {
	ObjectMeta *ObjectMeta `protobuf:"bytes,1,opt,name=objectMeta,proto3" json:"objectMeta,omitempty"`
	// Types that are valid to be assigned to Object:
	//	*KubernetesMainObject_PodSpec
	Object isKubernetesMainObject_Object `protobuf_oneof:"object"`
}

Kubernetes objects that can serve as main objects for an Armada job.

func (*KubernetesMainObject) Descriptor

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

func (*KubernetesMainObject) GetObject

func (m *KubernetesMainObject) GetObject() isKubernetesMainObject_Object

func (*KubernetesMainObject) GetObjectMeta

func (m *KubernetesMainObject) GetObjectMeta() *ObjectMeta

func (*KubernetesMainObject) GetPodSpec

func (m *KubernetesMainObject) GetPodSpec() *PodSpecWithAvoidList

func (*KubernetesMainObject) Marshal

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

func (*KubernetesMainObject) MarshalTo

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

func (*KubernetesMainObject) MarshalToSizedBuffer

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

func (*KubernetesMainObject) ProtoMessage

func (*KubernetesMainObject) ProtoMessage()

func (*KubernetesMainObject) Reset

func (m *KubernetesMainObject) Reset()

func (*KubernetesMainObject) Size

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

func (*KubernetesMainObject) String

func (m *KubernetesMainObject) String() string

func (*KubernetesMainObject) Unmarshal

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

func (*KubernetesMainObject) UnmarshalJSON

func (kmo *KubernetesMainObject) UnmarshalJSON(data []byte) error

func (*KubernetesMainObject) XXX_DiscardUnknown

func (m *KubernetesMainObject) XXX_DiscardUnknown()

func (*KubernetesMainObject) XXX_Marshal

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

func (*KubernetesMainObject) XXX_Merge

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

func (*KubernetesMainObject) XXX_OneofWrappers

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*KubernetesMainObject) XXX_Size

func (m *KubernetesMainObject) XXX_Size() int

func (*KubernetesMainObject) XXX_Unmarshal

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

type KubernetesMainObject_PodSpec

type KubernetesMainObject_PodSpec struct {
	PodSpec *PodSpecWithAvoidList `protobuf:"bytes,2,opt,name=pod_spec,json=podSpec,proto3,oneof" json:"podSpec,omitempty"`
}

func (*KubernetesMainObject_PodSpec) MarshalTo

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

func (*KubernetesMainObject_PodSpec) MarshalToSizedBuffer

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

func (*KubernetesMainObject_PodSpec) Size

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

type KubernetesObject

type KubernetesObject struct {
	ObjectMeta *ObjectMeta `protobuf:"bytes,1,opt,name=objectMeta,proto3" json:"objectMeta,omitempty"`
	// Types that are valid to be assigned to Object:
	//	*KubernetesObject_PodSpec
	//	*KubernetesObject_Ingress
	//	*KubernetesObject_Service
	//	*KubernetesObject_ConfigMap
	Object isKubernetesObject_Object `protobuf_oneof:"object"`
}

Kubernetes objects that can be created as part of an Armada.

func (*KubernetesObject) Descriptor

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

func (*KubernetesObject) GetConfigMap

func (m *KubernetesObject) GetConfigMap() *v11.ConfigMap

func (*KubernetesObject) GetIngress

func (m *KubernetesObject) GetIngress() *v1.IngressSpec

func (*KubernetesObject) GetObject

func (m *KubernetesObject) GetObject() isKubernetesObject_Object

func (*KubernetesObject) GetObjectMeta

func (m *KubernetesObject) GetObjectMeta() *ObjectMeta

func (*KubernetesObject) GetPodSpec

func (m *KubernetesObject) GetPodSpec() *PodSpecWithAvoidList

func (*KubernetesObject) GetService

func (m *KubernetesObject) GetService() *v11.ServiceSpec

func (*KubernetesObject) Marshal

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

func (*KubernetesObject) MarshalTo

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

func (*KubernetesObject) MarshalToSizedBuffer

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

func (*KubernetesObject) ProtoMessage

func (*KubernetesObject) ProtoMessage()

func (*KubernetesObject) Reset

func (m *KubernetesObject) Reset()

func (*KubernetesObject) Size

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

func (*KubernetesObject) String

func (m *KubernetesObject) String() string

func (*KubernetesObject) Unmarshal

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

func (*KubernetesObject) UnmarshalJSON

func (ko *KubernetesObject) UnmarshalJSON(data []byte) error

func (*KubernetesObject) XXX_DiscardUnknown

func (m *KubernetesObject) XXX_DiscardUnknown()

func (*KubernetesObject) XXX_Marshal

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

func (*KubernetesObject) XXX_Merge

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

func (*KubernetesObject) XXX_OneofWrappers

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*KubernetesObject) XXX_Size

func (m *KubernetesObject) XXX_Size() int

func (*KubernetesObject) XXX_Unmarshal

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

type KubernetesObject_ConfigMap

type KubernetesObject_ConfigMap struct {
	ConfigMap *v11.ConfigMap `protobuf:"bytes,5,opt,name=configMap,proto3,oneof" json:"configMap,omitempty"`
}

func (*KubernetesObject_ConfigMap) MarshalTo

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

func (*KubernetesObject_ConfigMap) MarshalToSizedBuffer

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

func (*KubernetesObject_ConfigMap) Size

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

type KubernetesObject_Ingress

type KubernetesObject_Ingress struct {
	Ingress *v1.IngressSpec `protobuf:"bytes,3,opt,name=ingress,proto3,oneof" json:"ingress,omitempty"`
}

func (*KubernetesObject_Ingress) MarshalTo

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

func (*KubernetesObject_Ingress) MarshalToSizedBuffer

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

func (*KubernetesObject_Ingress) Size

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

type KubernetesObject_PodSpec

type KubernetesObject_PodSpec struct {
	PodSpec *PodSpecWithAvoidList `protobuf:"bytes,2,opt,name=pod_spec,json=podSpec,proto3,oneof" json:"podSpec,omitempty"`
}

func (*KubernetesObject_PodSpec) MarshalTo

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

func (*KubernetesObject_PodSpec) MarshalToSizedBuffer

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

func (*KubernetesObject_PodSpec) Size

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

type KubernetesObject_Service

type KubernetesObject_Service struct {
	Service *v11.ServiceSpec `protobuf:"bytes,4,opt,name=service,proto3,oneof" json:"service,omitempty"`
}

func (*KubernetesObject_Service) MarshalTo

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

func (*KubernetesObject_Service) MarshalToSizedBuffer

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

func (*KubernetesObject_Service) Size

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

type KubernetesReason added in v0.3.48

type KubernetesReason int32

Reason reported by Kubernetes.

const (
	KubernetesReason_AppError         KubernetesReason = 0
	KubernetesReason_Evicted          KubernetesReason = 1
	KubernetesReason_OOM              KubernetesReason = 2
	KubernetesReason_DeadlineExceeded KubernetesReason = 3
)

func (KubernetesReason) EnumDescriptor added in v0.3.48

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

func (KubernetesReason) String added in v0.3.48

func (x KubernetesReason) String() string

type KubernetesResourceInfo

type KubernetesResourceInfo struct {
	ObjectMeta *ObjectMeta `protobuf:"bytes,1,opt,name=objectMeta,proto3" json:"objectMeta,omitempty"`
	// Types that are valid to be assigned to Info:
	//	*KubernetesResourceInfo_PodInfo
	//	*KubernetesResourceInfo_IngressInfo
	Info isKubernetesResourceInfo_Info `protobuf_oneof:"info"`
}

Message containing runtime information about some resource created for a job.

func (*KubernetesResourceInfo) Descriptor

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

func (*KubernetesResourceInfo) GetInfo

func (m *KubernetesResourceInfo) GetInfo() isKubernetesResourceInfo_Info

func (*KubernetesResourceInfo) GetIngressInfo

func (m *KubernetesResourceInfo) GetIngressInfo() *IngressInfo

func (*KubernetesResourceInfo) GetObjectMeta

func (m *KubernetesResourceInfo) GetObjectMeta() *ObjectMeta

func (*KubernetesResourceInfo) GetPodInfo

func (m *KubernetesResourceInfo) GetPodInfo() *PodInfo

func (*KubernetesResourceInfo) Marshal

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

func (*KubernetesResourceInfo) MarshalTo

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

func (*KubernetesResourceInfo) MarshalToSizedBuffer

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

func (*KubernetesResourceInfo) ProtoMessage

func (*KubernetesResourceInfo) ProtoMessage()

func (*KubernetesResourceInfo) Reset

func (m *KubernetesResourceInfo) Reset()

func (*KubernetesResourceInfo) Size

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

func (*KubernetesResourceInfo) String

func (m *KubernetesResourceInfo) String() string

func (*KubernetesResourceInfo) Unmarshal

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

func (*KubernetesResourceInfo) UnmarshalJSON

func (kri *KubernetesResourceInfo) UnmarshalJSON(data []byte) error

func (*KubernetesResourceInfo) XXX_DiscardUnknown

func (m *KubernetesResourceInfo) XXX_DiscardUnknown()

func (*KubernetesResourceInfo) XXX_Marshal

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

func (*KubernetesResourceInfo) XXX_Merge

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

func (*KubernetesResourceInfo) XXX_OneofWrappers

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*KubernetesResourceInfo) XXX_Size

func (m *KubernetesResourceInfo) XXX_Size() int

func (*KubernetesResourceInfo) XXX_Unmarshal

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

type KubernetesResourceInfo_IngressInfo

type KubernetesResourceInfo_IngressInfo struct {
	IngressInfo *IngressInfo `protobuf:"bytes,3,opt,name=ingressInfo,proto3,oneof" json:"ingressInfo,omitempty"`
}

func (*KubernetesResourceInfo_IngressInfo) MarshalTo

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

func (*KubernetesResourceInfo_IngressInfo) MarshalToSizedBuffer

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

func (*KubernetesResourceInfo_IngressInfo) Size

type KubernetesResourceInfo_PodInfo

type KubernetesResourceInfo_PodInfo struct {
	PodInfo *PodInfo `protobuf:"bytes,2,opt,name=podInfo,proto3,oneof" json:"podInfo,omitempty"`
}

func (*KubernetesResourceInfo_PodInfo) MarshalTo

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

func (*KubernetesResourceInfo_PodInfo) MarshalToSizedBuffer

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

func (*KubernetesResourceInfo_PodInfo) Size

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

type LeaseExpired

type LeaseExpired struct {
}

func (*LeaseExpired) Descriptor

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

func (*LeaseExpired) Marshal

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

func (*LeaseExpired) MarshalTo

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

func (*LeaseExpired) MarshalToSizedBuffer

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

func (*LeaseExpired) ProtoMessage

func (*LeaseExpired) ProtoMessage()

func (*LeaseExpired) Reset

func (m *LeaseExpired) Reset()

func (*LeaseExpired) Size

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

func (*LeaseExpired) String

func (m *LeaseExpired) String() string

func (*LeaseExpired) Unmarshal

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

func (*LeaseExpired) XXX_DiscardUnknown

func (m *LeaseExpired) XXX_DiscardUnknown()

func (*LeaseExpired) XXX_Marshal

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

func (*LeaseExpired) XXX_Merge

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

func (*LeaseExpired) XXX_Size

func (m *LeaseExpired) XXX_Size() int

func (*LeaseExpired) XXX_Unmarshal

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

type MaxRunsExceeded

type MaxRunsExceeded struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
}

func (*MaxRunsExceeded) Descriptor

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

func (*MaxRunsExceeded) GetMessage added in v0.3.63

func (m *MaxRunsExceeded) GetMessage() string

func (*MaxRunsExceeded) Marshal

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

func (*MaxRunsExceeded) MarshalTo

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

func (*MaxRunsExceeded) MarshalToSizedBuffer

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

func (*MaxRunsExceeded) ProtoMessage

func (*MaxRunsExceeded) ProtoMessage()

func (*MaxRunsExceeded) Reset

func (m *MaxRunsExceeded) Reset()

func (*MaxRunsExceeded) Size

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

func (*MaxRunsExceeded) String

func (m *MaxRunsExceeded) String() string

func (*MaxRunsExceeded) Unmarshal

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

func (*MaxRunsExceeded) XXX_DiscardUnknown

func (m *MaxRunsExceeded) XXX_DiscardUnknown()

func (*MaxRunsExceeded) XXX_Marshal

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

func (*MaxRunsExceeded) XXX_Merge

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

func (*MaxRunsExceeded) XXX_Size

func (m *MaxRunsExceeded) XXX_Size() int

func (*MaxRunsExceeded) XXX_Unmarshal

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

type ObjectMeta

type ObjectMeta struct {
	// Unique id of the executor responsible for the Kubernetes cluster that created the object.
	// Is set by the executor on object creation.
	ExecutorId string `protobuf:"bytes,1,opt,name=executor_id,json=executorId,proto3" json:"executorId,omitempty"`
	Namespace  string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Name       string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// Unique id assigned to the object by Kubernetes (typically a 128-bit UUID).
	// Should be left empty on job creation, but should be set, e.g., when in the JobRunRunning message.
	// Stored as a string because Kubernetes doesn't always use UUIDs; see
	// https://github.com/kubernetes/apimachinery/blob/master/pkg/types/uid.go#L19
	KubernetesId string            `protobuf:"bytes,4,opt,name=kubernetes_id,json=kubernetesId,proto3" json:"kubernetesId,omitempty"`
	Annotations  map[string]string `` /* 163-byte string literal not displayed */
	Labels       map[string]string `` /* 153-byte string literal not displayed */
}

Auxiliary information needed to instantiate the object in Kubernetes. Inspired by the Kubernetes ObjectMeta object; see: https://github.com/kubernetes/apimachinery/blob/master/pkg/apis/meta/v1/generated.proto#L641

func (*ObjectMeta) Descriptor

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

func (*ObjectMeta) GetAnnotations

func (m *ObjectMeta) GetAnnotations() map[string]string

func (*ObjectMeta) GetExecutorId

func (m *ObjectMeta) GetExecutorId() string

func (*ObjectMeta) GetKubernetesId

func (m *ObjectMeta) GetKubernetesId() string

func (*ObjectMeta) GetLabels

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

func (*ObjectMeta) GetName

func (m *ObjectMeta) GetName() string

func (*ObjectMeta) GetNamespace

func (m *ObjectMeta) GetNamespace() string

func (*ObjectMeta) Marshal

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

func (*ObjectMeta) MarshalTo

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

func (*ObjectMeta) MarshalToSizedBuffer

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

func (*ObjectMeta) ProtoMessage

func (*ObjectMeta) ProtoMessage()

func (*ObjectMeta) Reset

func (m *ObjectMeta) Reset()

func (*ObjectMeta) Size

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

func (*ObjectMeta) String

func (m *ObjectMeta) String() string

func (*ObjectMeta) Unmarshal

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

func (*ObjectMeta) XXX_DiscardUnknown

func (m *ObjectMeta) XXX_DiscardUnknown()

func (*ObjectMeta) XXX_Marshal

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

func (*ObjectMeta) XXX_Merge

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

func (*ObjectMeta) XXX_Size

func (m *ObjectMeta) XXX_Size() int

func (*ObjectMeta) XXX_Unmarshal

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

type PartitionMarker

type PartitionMarker struct {
	// group id ties together multiple messages across different partitions
	GroupId *Uuid `protobuf:"bytes,1,opt,name=group_id,json=groupId,proto3" json:"groupId,omitempty"`
	// The pulsar partition on which this message was sent
	Partition uint32 `protobuf:"varint,2,opt,name=partition,proto3" json:"partition,omitempty"`
}

Message used internally by Armada to see if messages can be propagated through a pulsar partition

func (*PartitionMarker) Descriptor

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

func (*PartitionMarker) GetGroupId

func (m *PartitionMarker) GetGroupId() *Uuid

func (*PartitionMarker) GetPartition

func (m *PartitionMarker) GetPartition() uint32

func (*PartitionMarker) Marshal

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

func (*PartitionMarker) MarshalTo

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

func (*PartitionMarker) MarshalToSizedBuffer

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

func (*PartitionMarker) ProtoMessage

func (*PartitionMarker) ProtoMessage()

func (*PartitionMarker) Reset

func (m *PartitionMarker) Reset()

func (*PartitionMarker) Size

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

func (*PartitionMarker) String

func (m *PartitionMarker) String() string

func (*PartitionMarker) Unmarshal

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

func (*PartitionMarker) XXX_DiscardUnknown

func (m *PartitionMarker) XXX_DiscardUnknown()

func (*PartitionMarker) XXX_Marshal

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

func (*PartitionMarker) XXX_Merge

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

func (*PartitionMarker) XXX_Size

func (m *PartitionMarker) XXX_Size() int

func (*PartitionMarker) XXX_Unmarshal

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

type PodError

type PodError struct {
	// This ObjectMeta identifies the Pod.
	ObjectMeta       *ObjectMeta       `protobuf:"bytes,1,opt,name=objectMeta,proto3" json:"objectMeta,omitempty"`
	Message          string            `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	NodeName         string            `protobuf:"bytes,3,opt,name=node_name,json=nodeName,proto3" json:"nodeName,omitempty"`
	PodNumber        int32             `protobuf:"varint,4,opt,name=pod_number,json=podNumber,proto3" json:"podNumber,omitempty"`
	ContainerErrors  []*ContainerError `protobuf:"bytes,5,rep,name=containerErrors,proto3" json:"containerErrors,omitempty"`
	KubernetesReason KubernetesReason  `` /* 144-byte string literal not displayed */
}

Indicates one or more of the containers in the pod failed.

func (*PodError) Descriptor

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

func (*PodError) GetContainerErrors

func (m *PodError) GetContainerErrors() []*ContainerError

func (*PodError) GetKubernetesReason added in v0.3.48

func (m *PodError) GetKubernetesReason() KubernetesReason

func (*PodError) GetMessage

func (m *PodError) GetMessage() string

func (*PodError) GetNodeName

func (m *PodError) GetNodeName() string

func (*PodError) GetObjectMeta

func (m *PodError) GetObjectMeta() *ObjectMeta

func (*PodError) GetPodNumber

func (m *PodError) GetPodNumber() int32

func (*PodError) Marshal

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

func (*PodError) MarshalTo

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

func (*PodError) MarshalToSizedBuffer

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

func (*PodError) ProtoMessage

func (*PodError) ProtoMessage()

func (*PodError) Reset

func (m *PodError) Reset()

func (*PodError) Size

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

func (*PodError) String

func (m *PodError) String() string

func (*PodError) Unmarshal

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

func (*PodError) XXX_DiscardUnknown

func (m *PodError) XXX_DiscardUnknown()

func (*PodError) XXX_Marshal

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

func (*PodError) XXX_Merge

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

func (*PodError) XXX_Size

func (m *PodError) XXX_Size() int

func (*PodError) XXX_Unmarshal

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

type PodInfo

type PodInfo struct {
	NodeName  string `protobuf:"bytes,1,opt,name=node_name,json=nodeName,proto3" json:"nodeName,omitempty"`
	PodNumber int32  `protobuf:"varint,2,opt,name=pod_number,json=podNumber,proto3" json:"podNumber,omitempty"`
}

Runtime information of a pod.

func (*PodInfo) Descriptor

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

func (*PodInfo) GetNodeName

func (m *PodInfo) GetNodeName() string

func (*PodInfo) GetPodNumber

func (m *PodInfo) GetPodNumber() int32

func (*PodInfo) Marshal

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

func (*PodInfo) MarshalTo

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

func (*PodInfo) MarshalToSizedBuffer

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

func (*PodInfo) ProtoMessage

func (*PodInfo) ProtoMessage()

func (*PodInfo) Reset

func (m *PodInfo) Reset()

func (*PodInfo) Size

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

func (*PodInfo) String

func (m *PodInfo) String() string

func (*PodInfo) Unmarshal

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

func (*PodInfo) XXX_DiscardUnknown

func (m *PodInfo) XXX_DiscardUnknown()

func (*PodInfo) XXX_Marshal

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

func (*PodInfo) XXX_Merge

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

func (*PodInfo) XXX_Size

func (m *PodInfo) XXX_Size() int

func (*PodInfo) XXX_Unmarshal

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

type PodLeaseReturned

type PodLeaseReturned struct {
	ObjectMeta   *ObjectMeta `protobuf:"bytes,1,opt,name=objectMeta,proto3" json:"objectMeta,omitempty"`
	Message      string      `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	PodNumber    int32       `protobuf:"varint,3,opt,name=pod_number,json=podNumber,proto3" json:"podNumber,omitempty"`
	RunAttempted bool        `protobuf:"varint,4,opt,name=run_attempted,json=runAttempted,proto3" json:"runAttempted,omitempty"`
}

Indicates that the pod could not be scheduled for some reason.

func (*PodLeaseReturned) Descriptor

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

func (*PodLeaseReturned) GetMessage

func (m *PodLeaseReturned) GetMessage() string

func (*PodLeaseReturned) GetObjectMeta

func (m *PodLeaseReturned) GetObjectMeta() *ObjectMeta

func (*PodLeaseReturned) GetPodNumber

func (m *PodLeaseReturned) GetPodNumber() int32

func (*PodLeaseReturned) GetRunAttempted added in v0.3.48

func (m *PodLeaseReturned) GetRunAttempted() bool

func (*PodLeaseReturned) Marshal

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

func (*PodLeaseReturned) MarshalTo

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

func (*PodLeaseReturned) MarshalToSizedBuffer

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

func (*PodLeaseReturned) ProtoMessage

func (*PodLeaseReturned) ProtoMessage()

func (*PodLeaseReturned) Reset

func (m *PodLeaseReturned) Reset()

func (*PodLeaseReturned) Size

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

func (*PodLeaseReturned) String

func (m *PodLeaseReturned) String() string

func (*PodLeaseReturned) Unmarshal

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

func (*PodLeaseReturned) XXX_DiscardUnknown

func (m *PodLeaseReturned) XXX_DiscardUnknown()

func (*PodLeaseReturned) XXX_Marshal

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

func (*PodLeaseReturned) XXX_Merge

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

func (*PodLeaseReturned) XXX_Size

func (m *PodLeaseReturned) XXX_Size() int

func (*PodLeaseReturned) XXX_Unmarshal

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

type PodSpecWithAvoidList

type PodSpecWithAvoidList struct {
	PodSpec *v11.PodSpec `protobuf:"bytes,1,opt,name=pod_spec,json=podSpec,proto3" json:"podSpec,omitempty"`
	// List of nodes to avoid scheduling this pod on.
	// TODO: Could this be done with selectors, taints, etc?
	NodeAvoidlist []string `protobuf:"bytes,2,rep,name=node_avoidlist,json=nodeAvoidlist,proto3" json:"nodeAvoidlist,omitempty"`
}

Kubernetes pod spec. with a bundled list of pods to avoid scheduling the pod to.

func (*PodSpecWithAvoidList) Descriptor

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

func (*PodSpecWithAvoidList) GetNodeAvoidlist

func (m *PodSpecWithAvoidList) GetNodeAvoidlist() []string

func (*PodSpecWithAvoidList) GetPodSpec

func (m *PodSpecWithAvoidList) GetPodSpec() *v11.PodSpec

func (*PodSpecWithAvoidList) Marshal

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

func (*PodSpecWithAvoidList) MarshalTo

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

func (*PodSpecWithAvoidList) MarshalToSizedBuffer

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

func (*PodSpecWithAvoidList) ProtoMessage

func (*PodSpecWithAvoidList) ProtoMessage()

func (*PodSpecWithAvoidList) Reset

func (m *PodSpecWithAvoidList) Reset()

func (*PodSpecWithAvoidList) Size

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

func (*PodSpecWithAvoidList) String

func (m *PodSpecWithAvoidList) String() string

func (*PodSpecWithAvoidList) Unmarshal

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

func (*PodSpecWithAvoidList) XXX_DiscardUnknown

func (m *PodSpecWithAvoidList) XXX_DiscardUnknown()

func (*PodSpecWithAvoidList) XXX_Marshal

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

func (*PodSpecWithAvoidList) XXX_Merge

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

func (*PodSpecWithAvoidList) XXX_Size

func (m *PodSpecWithAvoidList) XXX_Size() int

func (*PodSpecWithAvoidList) XXX_Unmarshal

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

type PodTerminated

type PodTerminated struct {
	// This ObjectMeta identifies the Pod.
	ObjectMeta *ObjectMeta `protobuf:"bytes,1,opt,name=objectMeta,proto3" json:"objectMeta,omitempty"`
	Message    string      `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	NodeName   string      `protobuf:"bytes,3,opt,name=node_name,json=nodeName,proto3" json:"nodeName,omitempty"`
	PodNumber  int32       `protobuf:"varint,4,opt,name=pod_number,json=podNumber,proto3" json:"podNumber,omitempty"`
}

Indicates that the lease on the job that the pod was part of could not be renewed. If this happens, the executor deletes the pod and generates a JobRunError with this message as the reason.

func (*PodTerminated) Descriptor

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

func (*PodTerminated) GetMessage

func (m *PodTerminated) GetMessage() string

func (*PodTerminated) GetNodeName

func (m *PodTerminated) GetNodeName() string

func (*PodTerminated) GetObjectMeta

func (m *PodTerminated) GetObjectMeta() *ObjectMeta

func (*PodTerminated) GetPodNumber

func (m *PodTerminated) GetPodNumber() int32

func (*PodTerminated) Marshal

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

func (*PodTerminated) MarshalTo

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

func (*PodTerminated) MarshalToSizedBuffer

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

func (*PodTerminated) ProtoMessage

func (*PodTerminated) ProtoMessage()

func (*PodTerminated) Reset

func (m *PodTerminated) Reset()

func (*PodTerminated) Size

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

func (*PodTerminated) String

func (m *PodTerminated) String() string

func (*PodTerminated) Unmarshal

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

func (*PodTerminated) XXX_DiscardUnknown

func (m *PodTerminated) XXX_DiscardUnknown()

func (*PodTerminated) XXX_Marshal

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

func (*PodTerminated) XXX_Merge

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

func (*PodTerminated) XXX_Size

func (m *PodTerminated) XXX_Size() int

func (*PodTerminated) XXX_Unmarshal

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

type PodUnschedulable

type PodUnschedulable struct {
	// this ObjectMeta identifies the Pod
	ObjectMeta *ObjectMeta `protobuf:"bytes,1,opt,name=objectMeta,proto3" json:"objectMeta,omitempty"`
	Message    string      `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	NodeName   string      `protobuf:"bytes,3,opt,name=node_name,json=nodeName,proto3" json:"nodeName,omitempty"`
	PodNumber  int32       `protobuf:"varint,4,opt,name=pod_number,json=podNumber,proto3" json:"podNumber,omitempty"`
}

func (*PodUnschedulable) Descriptor

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

func (*PodUnschedulable) GetMessage

func (m *PodUnschedulable) GetMessage() string

func (*PodUnschedulable) GetNodeName

func (m *PodUnschedulable) GetNodeName() string

func (*PodUnschedulable) GetObjectMeta

func (m *PodUnschedulable) GetObjectMeta() *ObjectMeta

func (*PodUnschedulable) GetPodNumber

func (m *PodUnschedulable) GetPodNumber() int32

func (*PodUnschedulable) Marshal

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

func (*PodUnschedulable) MarshalTo

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

func (*PodUnschedulable) MarshalToSizedBuffer

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

func (*PodUnschedulable) ProtoMessage

func (*PodUnschedulable) ProtoMessage()

func (*PodUnschedulable) Reset

func (m *PodUnschedulable) Reset()

func (*PodUnschedulable) Size

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

func (*PodUnschedulable) String

func (m *PodUnschedulable) String() string

func (*PodUnschedulable) Unmarshal

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

func (*PodUnschedulable) XXX_DiscardUnknown

func (m *PodUnschedulable) XXX_DiscardUnknown()

func (*PodUnschedulable) XXX_Marshal

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

func (*PodUnschedulable) XXX_Merge

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

func (*PodUnschedulable) XXX_Size

func (m *PodUnschedulable) XXX_Size() int

func (*PodUnschedulable) XXX_Unmarshal

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

type PulsarQueryServer

type PulsarQueryServer struct {
	api.UnimplementedSubmitServer
}

PulsarQueryServer responds to queue info queries based on the log messages.

type ReprioritiseJob

type ReprioritiseJob struct {
	JobId    *Uuid  `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"`
	Priority uint32 `protobuf:"varint,2,opt,name=priority,proto3" json:"priority,omitempty"`
}

Set the priority of a particular job.

func (*ReprioritiseJob) Descriptor

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

func (*ReprioritiseJob) GetJobId

func (m *ReprioritiseJob) GetJobId() *Uuid

func (*ReprioritiseJob) GetPriority

func (m *ReprioritiseJob) GetPriority() uint32

func (*ReprioritiseJob) Marshal

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

func (*ReprioritiseJob) MarshalTo

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

func (*ReprioritiseJob) MarshalToSizedBuffer

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

func (*ReprioritiseJob) ProtoMessage

func (*ReprioritiseJob) ProtoMessage()

func (*ReprioritiseJob) Reset

func (m *ReprioritiseJob) Reset()

func (*ReprioritiseJob) Size

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

func (*ReprioritiseJob) String

func (m *ReprioritiseJob) String() string

func (*ReprioritiseJob) Unmarshal

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

func (*ReprioritiseJob) XXX_DiscardUnknown

func (m *ReprioritiseJob) XXX_DiscardUnknown()

func (*ReprioritiseJob) XXX_Marshal

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

func (*ReprioritiseJob) XXX_Merge

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

func (*ReprioritiseJob) XXX_Size

func (m *ReprioritiseJob) XXX_Size() int

func (*ReprioritiseJob) XXX_Unmarshal

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

type ReprioritiseJobSet

type ReprioritiseJobSet struct {
	Priority uint32 `protobuf:"varint,1,opt,name=priority,proto3" json:"priority,omitempty"`
}

Set the priority of all jobs part of a job set. This sets the priority of all jobs in the job set currently in the queued state.

func (*ReprioritiseJobSet) Descriptor

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

func (*ReprioritiseJobSet) GetPriority

func (m *ReprioritiseJobSet) GetPriority() uint32

func (*ReprioritiseJobSet) Marshal

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

func (*ReprioritiseJobSet) MarshalTo

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

func (*ReprioritiseJobSet) MarshalToSizedBuffer

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

func (*ReprioritiseJobSet) ProtoMessage

func (*ReprioritiseJobSet) ProtoMessage()

func (*ReprioritiseJobSet) Reset

func (m *ReprioritiseJobSet) Reset()

func (*ReprioritiseJobSet) Size

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

func (*ReprioritiseJobSet) String

func (m *ReprioritiseJobSet) String() string

func (*ReprioritiseJobSet) Unmarshal

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

func (*ReprioritiseJobSet) XXX_DiscardUnknown

func (m *ReprioritiseJobSet) XXX_DiscardUnknown()

func (*ReprioritiseJobSet) XXX_Marshal

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

func (*ReprioritiseJobSet) XXX_Merge

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

func (*ReprioritiseJobSet) XXX_Size

func (m *ReprioritiseJobSet) XXX_Size() int

func (*ReprioritiseJobSet) XXX_Unmarshal

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

type ReprioritisedJob

type ReprioritisedJob struct {
	JobId    *Uuid  `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"`
	Priority uint32 `protobuf:"varint,2,opt,name=priority,proto3" json:"priority,omitempty"`
}

Generated by the scheduler in response to ReprioritiseJob and ReprioritiseJobSet. One such message is generated per job that was re-prioritised and includes the new priority.

func (*ReprioritisedJob) Descriptor

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

func (*ReprioritisedJob) GetJobId

func (m *ReprioritisedJob) GetJobId() *Uuid

func (*ReprioritisedJob) GetPriority

func (m *ReprioritisedJob) GetPriority() uint32

func (*ReprioritisedJob) Marshal

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

func (*ReprioritisedJob) MarshalTo

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

func (*ReprioritisedJob) MarshalToSizedBuffer

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

func (*ReprioritisedJob) ProtoMessage

func (*ReprioritisedJob) ProtoMessage()

func (*ReprioritisedJob) Reset

func (m *ReprioritisedJob) Reset()

func (*ReprioritisedJob) Size

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

func (*ReprioritisedJob) String

func (m *ReprioritisedJob) String() string

func (*ReprioritisedJob) Unmarshal

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

func (*ReprioritisedJob) XXX_DiscardUnknown

func (m *ReprioritisedJob) XXX_DiscardUnknown()

func (*ReprioritisedJob) XXX_Marshal

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

func (*ReprioritisedJob) XXX_Merge

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

func (*ReprioritisedJob) XXX_Size

func (m *ReprioritisedJob) XXX_Size() int

func (*ReprioritisedJob) XXX_Unmarshal

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

type ResourceUtilisation

type ResourceUtilisation struct {
	RunId                 *Uuid                        `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"runId,omitempty"`
	JobId                 *Uuid                        `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"`
	ResourceInfo          *KubernetesResourceInfo      `protobuf:"bytes,3,opt,name=resource_info,json=resourceInfo,proto3" json:"resourceInfo,omitempty"`
	MaxResourcesForPeriod map[string]resource.Quantity `` /* 203-byte string literal not displayed */
	TotalCumulativeUsage  map[string]resource.Quantity `` /* 199-byte string literal not displayed */
}

Resource usage of a particular k8s object created as part of a job.

func (*ResourceUtilisation) Descriptor

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

func (*ResourceUtilisation) GetJobId

func (m *ResourceUtilisation) GetJobId() *Uuid

func (*ResourceUtilisation) GetMaxResourcesForPeriod

func (m *ResourceUtilisation) GetMaxResourcesForPeriod() map[string]resource.Quantity

func (*ResourceUtilisation) GetResourceInfo

func (m *ResourceUtilisation) GetResourceInfo() *KubernetesResourceInfo

func (*ResourceUtilisation) GetRunId

func (m *ResourceUtilisation) GetRunId() *Uuid

func (*ResourceUtilisation) GetTotalCumulativeUsage

func (m *ResourceUtilisation) GetTotalCumulativeUsage() map[string]resource.Quantity

func (*ResourceUtilisation) Marshal

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

func (*ResourceUtilisation) MarshalTo

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

func (*ResourceUtilisation) MarshalToSizedBuffer

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

func (*ResourceUtilisation) ProtoMessage

func (*ResourceUtilisation) ProtoMessage()

func (*ResourceUtilisation) Reset

func (m *ResourceUtilisation) Reset()

func (*ResourceUtilisation) Size

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

func (*ResourceUtilisation) String

func (m *ResourceUtilisation) String() string

func (*ResourceUtilisation) Unmarshal

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

func (*ResourceUtilisation) XXX_DiscardUnknown

func (m *ResourceUtilisation) XXX_DiscardUnknown()

func (*ResourceUtilisation) XXX_Marshal

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

func (*ResourceUtilisation) XXX_Merge

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

func (*ResourceUtilisation) XXX_Size

func (m *ResourceUtilisation) XXX_Size() int

func (*ResourceUtilisation) XXX_Unmarshal

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

type StandaloneIngressInfo

type StandaloneIngressInfo struct {
	RunId *Uuid `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"runId,omitempty"`
	JobId *Uuid `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"`
	// ObjectMeta associated with the ingress.
	ObjectMeta       *ObjectMeta      `protobuf:"bytes,3,opt,name=objectMeta,proto3" json:"objectMeta,omitempty"`
	IngressAddresses map[int32]string `` /* 197-byte string literal not displayed */
	// The legacy message bundles info associated with the pod.
	NodeName     string `protobuf:"bytes,5,opt,name=node_name,json=nodeName,proto3" json:"nodeName,omitempty"`
	PodNumber    int32  `protobuf:"varint,6,opt,name=pod_number,json=podNumber,proto3" json:"podNumber,omitempty"`
	PodName      string `protobuf:"bytes,7,opt,name=pod_name,json=podName,proto3" json:"podName,omitempty"`
	PodNamespace string `protobuf:"bytes,8,opt,name=pod_namespace,json=podNamespace,proto3" json:"podNamespace,omitempty"`
}

For sending details associated with a created ingress. Used for compatibility with legacy messages, which send ingress info as its own message. Later, this info should be bundled with the JobRunRunning message.

func (*StandaloneIngressInfo) Descriptor

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

func (*StandaloneIngressInfo) GetIngressAddresses

func (m *StandaloneIngressInfo) GetIngressAddresses() map[int32]string

func (*StandaloneIngressInfo) GetJobId

func (m *StandaloneIngressInfo) GetJobId() *Uuid

func (*StandaloneIngressInfo) GetNodeName

func (m *StandaloneIngressInfo) GetNodeName() string

func (*StandaloneIngressInfo) GetObjectMeta

func (m *StandaloneIngressInfo) GetObjectMeta() *ObjectMeta

func (*StandaloneIngressInfo) GetPodName

func (m *StandaloneIngressInfo) GetPodName() string

func (*StandaloneIngressInfo) GetPodNamespace

func (m *StandaloneIngressInfo) GetPodNamespace() string

func (*StandaloneIngressInfo) GetPodNumber

func (m *StandaloneIngressInfo) GetPodNumber() int32

func (*StandaloneIngressInfo) GetRunId

func (m *StandaloneIngressInfo) GetRunId() *Uuid

func (*StandaloneIngressInfo) Marshal

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

func (*StandaloneIngressInfo) MarshalTo

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

func (*StandaloneIngressInfo) MarshalToSizedBuffer

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

func (*StandaloneIngressInfo) ProtoMessage

func (*StandaloneIngressInfo) ProtoMessage()

func (*StandaloneIngressInfo) Reset

func (m *StandaloneIngressInfo) Reset()

func (*StandaloneIngressInfo) Size

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

func (*StandaloneIngressInfo) String

func (m *StandaloneIngressInfo) String() string

func (*StandaloneIngressInfo) Unmarshal

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

func (*StandaloneIngressInfo) XXX_DiscardUnknown

func (m *StandaloneIngressInfo) XXX_DiscardUnknown()

func (*StandaloneIngressInfo) XXX_Marshal

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

func (*StandaloneIngressInfo) XXX_Merge

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

func (*StandaloneIngressInfo) XXX_Size

func (m *StandaloneIngressInfo) XXX_Size() int

func (*StandaloneIngressInfo) XXX_Unmarshal

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

type SubmitJob

type SubmitJob struct {
	// Each application may be run multiple times. This id uniquely identifies this job.
	JobId *Uuid `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"`
	// User-provided id used for server-side deduplication.
	// I.e., jobs submitted with the same deduplication_id as an existing job are discarded.
	// TODO: If we can deduplicate at the API endpoint, we don't need this on the log.
	DeduplicationId string `protobuf:"bytes,2,opt,name=deduplication_id,json=deduplicationId,proto3" json:"deduplicationId,omitempty"`
	// Priority of this job. Measured relative to other jobs in the same queue.
	Priority uint32 `protobuf:"varint,3,opt,name=priority,proto3" json:"priority,omitempty"`
	// Shared ObjectMeta for all Kubernetes objects in this job.
	// If provided, the namespace therein is used for all objects that do not explicitly specify another.
	// And the labels and annotations therein are applied to all objects part of the job.
	ObjectMeta *ObjectMeta `protobuf:"bytes,4,opt,name=objectMeta,proto3" json:"objectMeta,omitempty"`
	// Main object that determines when an application has finished.
	MainObject *KubernetesMainObject `protobuf:"bytes,5,opt,name=mainObject,proto3" json:"mainObject,omitempty"`
	// Set of additional Kubernetes objects to create as part of the job.
	Objects []*KubernetesObject `protobuf:"bytes,6,rep,name=objects,proto3" json:"objects,omitempty"`
	// Maximum lifetime of the job in seconds. Zero indicates an infinite lifetime.
	Lifetime uint32 `protobuf:"varint,7,opt,name=lifetime,proto3" json:"lifetime,omitempty"`
	// If true, the job is run at most once, i.e., at most one job run will be created for it.
	// If false, the job may be re-leased on failure, which may cause the job to run more than once
	// (e.g., if a job run succeeds but the executor fails before it can report job success).
	AtMostOnce bool `protobuf:"varint,8,opt,name=atMostOnce,proto3" json:"atMostOnce,omitempty"`
	// If true, Armada may preempt the job while running.
	Preemptible bool `protobuf:"varint,9,opt,name=preemptible,proto3" json:"preemptible,omitempty"`
	// If true, Armada may optimistically run several instances of the job concurrently
	// (typically on different clusters).
	// If false, a new job run may only be created once Armada is certain that all existing runs have finished.
	ConcurrencySafe bool `protobuf:"varint,10,opt,name=concurrencySafe,proto3" json:"concurrencySafe,omitempty"`
	// Indicates which scheduler should manage this job.
	// If empty, the default scheduler is used.
	Scheduler string `protobuf:"bytes,11,opt,name=scheduler,proto3" json:"scheduler,omitempty"`
	// Indicates whether job is a duplicate
	IsDuplicate bool `protobuf:"varint,12,opt,name=isDuplicate,proto3" json:"isDuplicate,omitempty"`
}

A request to run an Armada job. Each job consists of a set of Kubernetes objects, one of which is the main object (typically a pod spec.) and has a priority associated with it. When the main object exits, all other objects are cleaned up. The priority, together with the queue the job is submitted to, determines the order in which jobs are run.

func (*SubmitJob) Descriptor

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

func (*SubmitJob) GetAtMostOnce

func (m *SubmitJob) GetAtMostOnce() bool

func (*SubmitJob) GetConcurrencySafe

func (m *SubmitJob) GetConcurrencySafe() bool

func (*SubmitJob) GetDeduplicationId

func (m *SubmitJob) GetDeduplicationId() string

func (*SubmitJob) GetIsDuplicate added in v0.3.61

func (m *SubmitJob) GetIsDuplicate() bool

func (*SubmitJob) GetJobId

func (m *SubmitJob) GetJobId() *Uuid

func (*SubmitJob) GetLifetime

func (m *SubmitJob) GetLifetime() uint32

func (*SubmitJob) GetMainObject

func (m *SubmitJob) GetMainObject() *KubernetesMainObject

func (*SubmitJob) GetObjectMeta

func (m *SubmitJob) GetObjectMeta() *ObjectMeta

func (*SubmitJob) GetObjects

func (m *SubmitJob) GetObjects() []*KubernetesObject

func (*SubmitJob) GetPreemptible

func (m *SubmitJob) GetPreemptible() bool

func (*SubmitJob) GetPriority

func (m *SubmitJob) GetPriority() uint32

func (*SubmitJob) GetScheduler

func (m *SubmitJob) GetScheduler() string

func (*SubmitJob) Marshal

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

func (*SubmitJob) MarshalTo

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

func (*SubmitJob) MarshalToSizedBuffer

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

func (*SubmitJob) ProtoMessage

func (*SubmitJob) ProtoMessage()

func (*SubmitJob) Reset

func (m *SubmitJob) Reset()

func (*SubmitJob) Size

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

func (*SubmitJob) String

func (m *SubmitJob) String() string

func (*SubmitJob) Unmarshal

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

func (*SubmitJob) XXX_DiscardUnknown

func (m *SubmitJob) XXX_DiscardUnknown()

func (*SubmitJob) XXX_Marshal

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

func (*SubmitJob) XXX_Merge

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

func (*SubmitJob) XXX_Size

func (m *SubmitJob) XXX_Size() int

func (*SubmitJob) XXX_Unmarshal

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

type Uuid

type Uuid struct {
	// The high 64 bits of the UUID - MSB -> LSB: time_low (32 bits) | time_mid (16 bits) | time_hi_and_version (16 bits).
	High64 uint64 `protobuf:"fixed64,1,opt,name=high64,proto3" json:"high64,omitempty"`
	// The low 64 bits of the UUID - MSB -> LSB: clock_seq_hi_and_reserved (8 bits) | clock_seq_low (8 bits) | node (48 bits).
	Low64 uint64 `protobuf:"fixed64,2,opt,name=low64,proto3" json:"low64,omitempty"`
}

A UUID, encoded in accordance with section 4.1.2 of RFC 4122 (technically equivalent to ITU-T Rec. X.667 and ISO/IEC 9834-8). As of March 2022, this seems to be the most efficient way to include UUIDs in proto messages; see https://github.com/protocolbuffers/protobuf/issues/2224#issuecomment-760635430

func JobIdFromEvent

func JobIdFromEvent(event *EventSequence_Event) (*Uuid, error)

func ProtoUuidFromUlid

func ProtoUuidFromUlid(id ulid.ULID) *Uuid

ProtoUuidFromUlid returns an efficient representation of a UUID meant for embedding in proto messages from a uuid.UUID.

func ProtoUuidFromUlidString

func ProtoUuidFromUlidString(ulidString string) (*Uuid, error)

ProtoUuidFromUlidString parses a ULID string into a proto UUID and returns it.

func ProtoUuidFromUuid

func ProtoUuidFromUuid(id uuid.UUID) *Uuid

ProtoUuidFromUuid returns an efficient representation of a UUID meant for embedding in proto messages from a uuid.UUID.

func ProtoUuidFromUuidString

func ProtoUuidFromUuidString(uuidString string) (*Uuid, error)

ProtoUuidFromUuidString parses a UUID string into a proto UUID and returns it.

func (*Uuid) Descriptor

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

func (*Uuid) GetHigh64

func (m *Uuid) GetHigh64() uint64

func (*Uuid) GetLow64

func (m *Uuid) GetLow64() uint64

func (*Uuid) Marshal

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

func (*Uuid) MarshalTo

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

func (*Uuid) MarshalToSizedBuffer

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

func (*Uuid) ProtoMessage

func (*Uuid) ProtoMessage()

func (*Uuid) Reset

func (m *Uuid) Reset()

func (*Uuid) Size

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

func (*Uuid) String

func (m *Uuid) String() string

func (*Uuid) Unmarshal

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

func (*Uuid) XXX_DiscardUnknown

func (m *Uuid) XXX_DiscardUnknown()

func (*Uuid) XXX_Marshal

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

func (*Uuid) XXX_Merge

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

func (*Uuid) XXX_Size

func (m *Uuid) XXX_Size() int

func (*Uuid) XXX_Unmarshal

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

Jump to

Keyboard shortcuts

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