armadaevents

package
v0.3.46 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const (
	PULSAR_UTILISATION_MESSAGE = "utilisation"
	PULSAR_CONTROL_MESSAGE     = "control"
)
View Source 
const PULSAR_MESSAGE_TYPE_PROPERTY = "type"

PULSAR_MESSAGE_TYPE_PROPERTY is the key of a property included with Pulsar messages. It's value indicates if the message is a control message or a utilisation message.

We need this because, we currently submit legacy utilisation messages directly to the log (i.e., not as part of an EventSequence).

Hence, consumers can distinguish between control and utilisation messages by inspecting this property. If the property isn't included, the message should be interpreted as a control message.

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")
)

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 IsControlMessage 

func IsControlMessage(msg pulsar.Message) bool

IsControlMessage returns true if msg is a control message, and false otherwise.

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 {
}

Request to cancel all jobs in a job set.

func (*CancelJobSet) Descriptor 

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

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.
	//
	// Types that are valid to be assigned to KubernetesReason:
	//	*ContainerError_OutOfMemory_
	//	*ContainerError_Error
	//	*ContainerError_Evicted_
	//	*ContainerError_DeadlineExceeded_
	KubernetesReason isContainerError_KubernetesReason `protobuf_oneof:"KubernetesReason"`
}

func (*ContainerError) Descriptor 

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

func (*ContainerError) GetDeadlineExceeded 

func (m *ContainerError) GetDeadlineExceeded() *ContainerError_DeadlineExceeded

func (*ContainerError) GetError 

func (m *ContainerError) GetError() *Error

func (*ContainerError) GetEvicted 

func (m *ContainerError) GetEvicted() *ContainerError_Evicted

func (*ContainerError) GetExitCode 

func (m *ContainerError) GetExitCode() int32

func (*ContainerError) GetKubernetesReason 

func (m *ContainerError) GetKubernetesReason() isContainerError_KubernetesReason

func (*ContainerError) GetMessage 

func (m *ContainerError) GetMessage() string

func (*ContainerError) GetObjectMeta 

func (m *ContainerError) GetObjectMeta() *ObjectMeta

func (*ContainerError) GetOutOfMemory 

func (m *ContainerError) GetOutOfMemory() *ContainerError_OutOfMemory

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_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ContainerError) XXX_Size 

func (m *ContainerError) XXX_Size() int

func (*ContainerError) XXX_Unmarshal 

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

type ContainerError_ContainerError 

type ContainerError_ContainerError struct {
}

func (*ContainerError_ContainerError) Descriptor 

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

func (*ContainerError_ContainerError) Marshal 

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

func (*ContainerError_ContainerError) MarshalTo 

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

func (*ContainerError_ContainerError) MarshalToSizedBuffer 

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

func (*ContainerError_ContainerError) ProtoMessage 

func (*ContainerError_ContainerError) ProtoMessage()

func (*ContainerError_ContainerError) Reset 

func (m *ContainerError_ContainerError) Reset()

func (*ContainerError_ContainerError) Size 

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

func (*ContainerError_ContainerError) String 

func (m *ContainerError_ContainerError) String() string

func (*ContainerError_ContainerError) Unmarshal 

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

func (*ContainerError_ContainerError) XXX_DiscardUnknown 

func (m *ContainerError_ContainerError) XXX_DiscardUnknown()

func (*ContainerError_ContainerError) XXX_Marshal 

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

func (*ContainerError_ContainerError) XXX_Merge 

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

func (*ContainerError_ContainerError) XXX_Size 

func (m *ContainerError_ContainerError) XXX_Size() int

func (*ContainerError_ContainerError) XXX_Unmarshal 

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

type ContainerError_DeadlineExceeded 

type ContainerError_DeadlineExceeded struct {
}

func (*ContainerError_DeadlineExceeded) Descriptor 

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

func (*ContainerError_DeadlineExceeded) Marshal 

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

func (*ContainerError_DeadlineExceeded) MarshalTo 

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

func (*ContainerError_DeadlineExceeded) MarshalToSizedBuffer 

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

func (*ContainerError_DeadlineExceeded) ProtoMessage 

func (*ContainerError_DeadlineExceeded) ProtoMessage()

func (*ContainerError_DeadlineExceeded) Reset 

func (m *ContainerError_DeadlineExceeded) Reset()

func (*ContainerError_DeadlineExceeded) Size 

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

func (*ContainerError_DeadlineExceeded) String 

func (m *ContainerError_DeadlineExceeded) String() string

func (*ContainerError_DeadlineExceeded) Unmarshal 

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

func (*ContainerError_DeadlineExceeded) XXX_DiscardUnknown 

func (m *ContainerError_DeadlineExceeded) XXX_DiscardUnknown()

func (*ContainerError_DeadlineExceeded) XXX_Marshal 

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

func (*ContainerError_DeadlineExceeded) XXX_Merge 

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

func (*ContainerError_DeadlineExceeded) XXX_Size 

func (m *ContainerError_DeadlineExceeded) XXX_Size() int

func (*ContainerError_DeadlineExceeded) XXX_Unmarshal 

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

type ContainerError_DeadlineExceeded_ 

type ContainerError_DeadlineExceeded_ struct {
	DeadlineExceeded *ContainerError_DeadlineExceeded `protobuf:"bytes,8,opt,name=deadlineExceeded,proto3,oneof" json:"deadlineExceeded,omitempty"`
}

func (*ContainerError_DeadlineExceeded_) MarshalTo 

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

func (*ContainerError_DeadlineExceeded_) MarshalToSizedBuffer 

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

func (*ContainerError_DeadlineExceeded_) Size 

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

type ContainerError_Error 

type ContainerError_Error struct {
	Error *Error `protobuf:"bytes,6,opt,name=error,proto3,oneof" json:"error,omitempty"`
}

func (*ContainerError_Error) MarshalTo 

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

func (*ContainerError_Error) MarshalToSizedBuffer 

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

func (*ContainerError_Error) Size 

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

type ContainerError_Evicted 

type ContainerError_Evicted struct {
}

func (*ContainerError_Evicted) Descriptor 

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

func (*ContainerError_Evicted) Marshal 

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

func (*ContainerError_Evicted) MarshalTo 

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

func (*ContainerError_Evicted) MarshalToSizedBuffer 

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

func (*ContainerError_Evicted) ProtoMessage 

func (*ContainerError_Evicted) ProtoMessage()

func (*ContainerError_Evicted) Reset 

func (m *ContainerError_Evicted) Reset()

func (*ContainerError_Evicted) Size 

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

func (*ContainerError_Evicted) String 

func (m *ContainerError_Evicted) String() string

func (*ContainerError_Evicted) Unmarshal 

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

func (*ContainerError_Evicted) XXX_DiscardUnknown 

func (m *ContainerError_Evicted) XXX_DiscardUnknown()

func (*ContainerError_Evicted) XXX_Marshal 

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

func (*ContainerError_Evicted) XXX_Merge 

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

func (*ContainerError_Evicted) XXX_Size 

func (m *ContainerError_Evicted) XXX_Size() int

func (*ContainerError_Evicted) XXX_Unmarshal 

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

type ContainerError_Evicted_ 

type ContainerError_Evicted_ struct {
	Evicted *ContainerError_Evicted `protobuf:"bytes,7,opt,name=evicted,proto3,oneof" json:"evicted,omitempty"`
}

func (*ContainerError_Evicted_) MarshalTo 

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

func (*ContainerError_Evicted_) MarshalToSizedBuffer 

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

func (*ContainerError_Evicted_) Size 

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

type ContainerError_OutOfMemory 

type ContainerError_OutOfMemory struct {
}

These messages represent the reason for why the container failed. We use empty messages to give the option of adding fields specific to each cause later.

func (*ContainerError_OutOfMemory) Descriptor 

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

func (*ContainerError_OutOfMemory) Marshal 

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

func (*ContainerError_OutOfMemory) MarshalTo 

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

func (*ContainerError_OutOfMemory) MarshalToSizedBuffer 

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

func (*ContainerError_OutOfMemory) ProtoMessage 

func (*ContainerError_OutOfMemory) ProtoMessage()

func (*ContainerError_OutOfMemory) Reset 

func (m *ContainerError_OutOfMemory) Reset()

func (*ContainerError_OutOfMemory) Size 

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

func (*ContainerError_OutOfMemory) String 

func (m *ContainerError_OutOfMemory) String() string

func (*ContainerError_OutOfMemory) Unmarshal 

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

func (*ContainerError_OutOfMemory) XXX_DiscardUnknown 

func (m *ContainerError_OutOfMemory) XXX_DiscardUnknown()

func (*ContainerError_OutOfMemory) XXX_Marshal 

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

func (*ContainerError_OutOfMemory) XXX_Merge 

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

func (*ContainerError_OutOfMemory) XXX_Size 

func (m *ContainerError_OutOfMemory) XXX_Size() int

func (*ContainerError_OutOfMemory) XXX_Unmarshal 

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

type ContainerError_OutOfMemory_ 

type ContainerError_OutOfMemory_ struct {
	OutOfMemory *ContainerError_OutOfMemory `protobuf:"bytes,5,opt,name=outOfMemory,proto3,oneof" json:"outOfMemory,omitempty"`
}

func (*ContainerError_OutOfMemory_) MarshalTo 

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

func (*ContainerError_OutOfMemory_) MarshalToSizedBuffer 

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

func (*ContainerError_OutOfMemory_) Size 

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

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
	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) 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_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
	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) 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) 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) 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 

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

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_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 

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

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 

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

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 

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

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_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 

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

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 

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

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 

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

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 

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

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 

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

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

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) GetRunId 

func (m *JobRunLeased) GetRunId() *Uuid

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 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 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 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 

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

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 {
}

func (*MaxRunsExceeded) Descriptor 

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

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

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

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

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) 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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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