eventpb

package
v0.0.0-...-2cc3bea Latest Latest
Warning

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

Go to latest
Published: May 4, 2024 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Overview

Package eventpb stores protos for event processing of RunManager.

Index

Constants

View Source
const (
	// ManageRunTaskClass is the ID of ManageRunTask Class.
	ManageRunTaskClass = "manage-run"
	// ManageRunLongOpTaskClass is the ID of the ManageRunLongOp Class.
	ManageRunLongOpTaskClass = "manage-run-long-op"
)

Variables

View Source
var (
	LongOpCompleted_Status_name = map[int32]string{
		0: "LONG_OP_STATUS_UNSPECIFIED",
		1: "SUCCEEDED",
		2: "FAILED",
		3: "CANCELLED",
		4: "EXPIRED",
	}
	LongOpCompleted_Status_value = map[string]int32{
		"LONG_OP_STATUS_UNSPECIFIED": 0,
		"SUCCEEDED":                  1,
		"FAILED":                     2,
		"CANCELLED":                  3,
		"EXPIRED":                    4,
	}
)

Enum value maps for LongOpCompleted_Status.

View Source
var (
	SubmissionResult_name = map[int32]string{
		0: "SUBMISSION_RESULT_UNSPECIFIED",
		1: "SUCCEEDED",
		2: "FAILED_TRANSIENT",
		3: "FAILED_PERMANENT",
	}
	SubmissionResult_value = map[string]int32{
		"SUBMISSION_RESULT_UNSPECIFIED": 0,
		"SUCCEEDED":                     1,
		"FAILED_TRANSIENT":              2,
		"FAILED_PERMANENT":              3,
	}
)

Enum value maps for SubmissionResult.

View Source
var File_go_chromium_org_luci_cv_internal_run_eventpb_events_proto protoreflect.FileDescriptor
View Source
var File_go_chromium_org_luci_cv_internal_run_eventpb_longop_proto protoreflect.FileDescriptor
View Source
var File_go_chromium_org_luci_cv_internal_run_eventpb_submission_proto protoreflect.FileDescriptor
View Source
var File_go_chromium_org_luci_cv_internal_run_eventpb_tasks_proto protoreflect.FileDescriptor

Functions

func InstallMockDispatcher

func InstallMockDispatcher(ctx context.Context, f func(runID string, eta time.Time)) context.Context

InstallMockDispatcher is used in test to run tests emitting RM events without actually dispatching RM tasks.

See runtest.MockDispatch().

Types

type CLsSubmitted

type CLsSubmitted struct {

	// Internal ID of CLs that were submitted successfully.
	Clids []int64 `protobuf:"varint,1,rep,packed,name=clids,proto3" json:"clids,omitempty"`
	// contains filtered or unexported fields
}

func (*CLsSubmitted) Descriptor deprecated

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

Deprecated: Use CLsSubmitted.ProtoReflect.Descriptor instead.

func (*CLsSubmitted) GetClids

func (x *CLsSubmitted) GetClids() []int64

func (*CLsSubmitted) ProtoMessage

func (*CLsSubmitted) ProtoMessage()

func (*CLsSubmitted) ProtoReflect

func (x *CLsSubmitted) ProtoReflect() protoreflect.Message

func (*CLsSubmitted) Reset

func (x *CLsSubmitted) Reset()

func (*CLsSubmitted) String

func (x *CLsSubmitted) String() string

func (*CLsSubmitted) Validate

func (m *CLsSubmitted) Validate() error

Validate checks the field values on CLsSubmitted with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*CLsSubmitted) ValidateAll

func (m *CLsSubmitted) ValidateAll() error

ValidateAll checks the field values on CLsSubmitted with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in CLsSubmittedMultiError, or nil if none found.

type CLsSubmittedMultiError

type CLsSubmittedMultiError []error

CLsSubmittedMultiError is an error wrapping multiple validation errors returned by CLsSubmitted.ValidateAll() if the designated constraints aren't met.

func (CLsSubmittedMultiError) AllErrors

func (m CLsSubmittedMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CLsSubmittedMultiError) Error

func (m CLsSubmittedMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type CLsSubmittedValidationError

type CLsSubmittedValidationError struct {
	// contains filtered or unexported fields
}

CLsSubmittedValidationError is the validation error returned by CLsSubmitted.Validate if the designated constraints aren't met.

func (CLsSubmittedValidationError) Cause

Cause function returns cause value.

func (CLsSubmittedValidationError) Error

Error satisfies the builtin error interface

func (CLsSubmittedValidationError) ErrorName

func (e CLsSubmittedValidationError) ErrorName() string

ErrorName returns error name.

func (CLsSubmittedValidationError) Field

Field function returns field value.

func (CLsSubmittedValidationError) Key

Key function returns key value.

func (CLsSubmittedValidationError) Reason

Reason function returns reason value.

type Cancel

type Cancel struct {

	// reason for cancelling the run.
	Reason string `protobuf:"bytes,1,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*Cancel) Descriptor deprecated

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

Deprecated: Use Cancel.ProtoReflect.Descriptor instead.

func (*Cancel) GetReason

func (x *Cancel) GetReason() string

func (*Cancel) ProtoMessage

func (*Cancel) ProtoMessage()

func (*Cancel) ProtoReflect

func (x *Cancel) ProtoReflect() protoreflect.Message

func (*Cancel) Reset

func (x *Cancel) Reset()

func (*Cancel) String

func (x *Cancel) String() string

func (*Cancel) Validate

func (m *Cancel) Validate() error

Validate checks the field values on Cancel with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Cancel) ValidateAll

func (m *Cancel) ValidateAll() error

ValidateAll checks the field values on Cancel with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in CancelMultiError, or nil if none found.

type CancelMultiError

type CancelMultiError []error

CancelMultiError is an error wrapping multiple validation errors returned by Cancel.ValidateAll() if the designated constraints aren't met.

func (CancelMultiError) AllErrors

func (m CancelMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CancelMultiError) Error

func (m CancelMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type CancelValidationError

type CancelValidationError struct {
	// contains filtered or unexported fields
}

CancelValidationError is the validation error returned by Cancel.Validate if the designated constraints aren't met.

func (CancelValidationError) Cause

func (e CancelValidationError) Cause() error

Cause function returns cause value.

func (CancelValidationError) Error

func (e CancelValidationError) Error() string

Error satisfies the builtin error interface

func (CancelValidationError) ErrorName

func (e CancelValidationError) ErrorName() string

ErrorName returns error name.

func (CancelValidationError) Field

func (e CancelValidationError) Field() string

Field function returns field value.

func (CancelValidationError) Key

func (e CancelValidationError) Key() bool

Key function returns key value.

func (CancelValidationError) Reason

func (e CancelValidationError) Reason() string

Reason function returns reason value.

type Event

type Event struct {

	// Types that are assignable to Event:
	//
	//	*Event_Start
	//	*Event_Cancel
	//	*Event_Poke
	//	*Event_NewConfig
	//	*Event_ClsUpdated
	//	*Event_ReadyForSubmission
	//	*Event_ClsSubmitted
	//	*Event_SubmissionCompleted
	//	*Event_LongOpCompleted
	//	*Event_TryjobsUpdated
	//	*Event_ParentRunCompleted
	Event isEvent_Event `protobuf_oneof:"event"`
	// Instructs Run Manager that this event can only be processed after
	// this timestamp.
	ProcessAfter *timestamppb.Timestamp `protobuf:"bytes,20,opt,name=process_after,json=processAfter,proto3" json:"process_after,omitempty"`
	// contains filtered or unexported fields
}

Event is a container for all kinds of events a Run Manager can receive.

func (*Event) Descriptor deprecated

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetCancel

func (x *Event) GetCancel() *Cancel

func (*Event) GetClsSubmitted

func (x *Event) GetClsSubmitted() *CLsSubmitted

func (*Event) GetClsUpdated

func (x *Event) GetClsUpdated() *changelist.CLUpdatedEvents

func (*Event) GetEvent

func (m *Event) GetEvent() isEvent_Event

func (*Event) GetLongOpCompleted

func (x *Event) GetLongOpCompleted() *LongOpCompleted

func (*Event) GetNewConfig

func (x *Event) GetNewConfig() *NewConfig

func (*Event) GetParentRunCompleted

func (x *Event) GetParentRunCompleted() *ParentRunCompleted

func (*Event) GetPoke

func (x *Event) GetPoke() *Poke

func (*Event) GetProcessAfter

func (x *Event) GetProcessAfter() *timestamppb.Timestamp

func (*Event) GetReadyForSubmission

func (x *Event) GetReadyForSubmission() *ReadyForSubmission

func (*Event) GetStart

func (x *Event) GetStart() *Start

func (*Event) GetSubmissionCompleted

func (x *Event) GetSubmissionCompleted() *SubmissionCompleted

func (*Event) GetTryjobsUpdated

func (x *Event) GetTryjobsUpdated() *tryjob.TryjobUpdatedEvents

func (*Event) ProtoMessage

func (*Event) ProtoMessage()

func (*Event) ProtoReflect

func (x *Event) ProtoReflect() protoreflect.Message

func (*Event) Reset

func (x *Event) Reset()

func (*Event) String

func (x *Event) String() string

func (*Event) Validate

func (m *Event) Validate() error

Validate checks the field values on Event with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Event) ValidateAll

func (m *Event) ValidateAll() error

ValidateAll checks the field values on Event with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in EventMultiError, or nil if none found.

type EventMultiError

type EventMultiError []error

EventMultiError is an error wrapping multiple validation errors returned by Event.ValidateAll() if the designated constraints aren't met.

func (EventMultiError) AllErrors

func (m EventMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (EventMultiError) Error

func (m EventMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type EventValidationError

type EventValidationError struct {
	// contains filtered or unexported fields
}

EventValidationError is the validation error returned by Event.Validate if the designated constraints aren't met.

func (EventValidationError) Cause

func (e EventValidationError) Cause() error

Cause function returns cause value.

func (EventValidationError) Error

func (e EventValidationError) Error() string

Error satisfies the builtin error interface

func (EventValidationError) ErrorName

func (e EventValidationError) ErrorName() string

ErrorName returns error name.

func (EventValidationError) Field

func (e EventValidationError) Field() string

Field function returns field value.

func (EventValidationError) Key

func (e EventValidationError) Key() bool

Key function returns key value.

func (EventValidationError) Reason

func (e EventValidationError) Reason() string

Reason function returns reason value.

type Event_Cancel

type Event_Cancel struct {
	// On Cancel event, Run Manager will cancel the Run.
	Cancel *Cancel `protobuf:"bytes,2,opt,name=cancel,proto3,oneof"`
}

type Event_ClsSubmitted

type Event_ClsSubmitted struct {
	// On CLSubmitted event, Run Manager will mark this CL as submitted.
	ClsSubmitted *CLsSubmitted `protobuf:"bytes,12,opt,name=cls_submitted,json=clsSubmitted,proto3,oneof"`
}

type Event_ClsUpdated

type Event_ClsUpdated struct {
	// On cls_updated event, Run Manager will decide whether to cancel the Run
	// based on the current CL state.
	ClsUpdated *changelist.CLUpdatedEvents `protobuf:"bytes,9,opt,name=cls_updated,json=clsUpdated,proto3,oneof"`
}

type Event_LongOpCompleted

type Event_LongOpCompleted struct {
	// On LongOpCompleted event is sent by Run Manager to itself to mark
	// completion of a long operation.
	LongOpCompleted *LongOpCompleted `protobuf:"bytes,10,opt,name=long_op_completed,json=longOpCompleted,proto3,oneof"`
}

type Event_NewConfig

type Event_NewConfig struct {
	// On NewConfig event, Run Manager will update config the Run for the
	// given RunID.
	//
	// Sent by Project Manager, which guarantees these events are sent in order
	// of config updates. See also its `eversion` field.
	NewConfig *NewConfig `protobuf:"bytes,4,opt,name=new_config,json=newConfig,proto3,oneof"`
}

type Event_ParentRunCompleted

type Event_ParentRunCompleted struct {
	// On parent_run_completed event, Run Manager decides the next step for
	// the child run.
	ParentRunCompleted *ParentRunCompleted `protobuf:"bytes,13,opt,name=parent_run_completed,json=parentRunCompleted,proto3,oneof"`
}

type Event_Poke

type Event_Poke struct {
	// On Poke event, Run Manager will check the state of the Run and perform
	// any action if necessary.
	//
	// Sent periodically by Project Manager.
	Poke *Poke `protobuf:"bytes,3,opt,name=poke,proto3,oneof"`
}

type Event_ReadyForSubmission

type Event_ReadyForSubmission struct {
	// On ReadyForSubmission event, Run Manager will try to submit CLs in
	// this Run.
	ReadyForSubmission *ReadyForSubmission `protobuf:"bytes,6,opt,name=ready_for_submission,json=readyForSubmission,proto3,oneof"`
}

type Event_Start

type Event_Start struct {
	// On Start event, Run Manager will start the Run.
	//
	// The Run entity must already exist.
	Start *Start `protobuf:"bytes,1,opt,name=start,proto3,oneof"`
}

type Event_SubmissionCompleted

type Event_SubmissionCompleted struct {
	// On SubmissionCompleted event, Run Manager will look at the submission
	// result and decide whether to retry this submission or succeed or fail
	// the Run.
	SubmissionCompleted *SubmissionCompleted `protobuf:"bytes,8,opt,name=submission_completed,json=submissionCompleted,proto3,oneof"`
}

type Event_TryjobsUpdated

type Event_TryjobsUpdated struct {
	// On tryjobs_updated event, Run Manager decides the next step for those
	// tryjobs (e.g. retry) and this Run (e.g. fail the Run for critical
	// tryjob failure).
	TryjobsUpdated *tryjob.TryjobUpdatedEvents `protobuf:"bytes,11,opt,name=tryjobs_updated,json=tryjobsUpdated,proto3,oneof"`
}

type KickManageRunTask

type KickManageRunTask struct {
	RunId string                 `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	Eta   *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=eta,proto3" json:"eta,omitempty"`
	// contains filtered or unexported fields
}

KickManageRunTask starts a task to actually enqueue ManageRunTask. It exists in order to send a deduplicatable ManageRunTask from a transaction.

Queue: "kick-manage-run".

func (*KickManageRunTask) Descriptor deprecated

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

Deprecated: Use KickManageRunTask.ProtoReflect.Descriptor instead.

func (*KickManageRunTask) GetEta

func (*KickManageRunTask) GetRunId

func (x *KickManageRunTask) GetRunId() string

func (*KickManageRunTask) ProtoMessage

func (*KickManageRunTask) ProtoMessage()

func (*KickManageRunTask) ProtoReflect

func (x *KickManageRunTask) ProtoReflect() protoreflect.Message

func (*KickManageRunTask) Reset

func (x *KickManageRunTask) Reset()

func (*KickManageRunTask) String

func (x *KickManageRunTask) String() string

func (*KickManageRunTask) Validate

func (m *KickManageRunTask) Validate() error

Validate checks the field values on KickManageRunTask with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*KickManageRunTask) ValidateAll

func (m *KickManageRunTask) ValidateAll() error

ValidateAll checks the field values on KickManageRunTask with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in KickManageRunTaskMultiError, or nil if none found.

type KickManageRunTaskMultiError

type KickManageRunTaskMultiError []error

KickManageRunTaskMultiError is an error wrapping multiple validation errors returned by KickManageRunTask.ValidateAll() if the designated constraints aren't met.

func (KickManageRunTaskMultiError) AllErrors

func (m KickManageRunTaskMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (KickManageRunTaskMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type KickManageRunTaskValidationError

type KickManageRunTaskValidationError struct {
	// contains filtered or unexported fields
}

KickManageRunTaskValidationError is the validation error returned by KickManageRunTask.Validate if the designated constraints aren't met.

func (KickManageRunTaskValidationError) Cause

Cause function returns cause value.

func (KickManageRunTaskValidationError) Error

Error satisfies the builtin error interface

func (KickManageRunTaskValidationError) ErrorName

ErrorName returns error name.

func (KickManageRunTaskValidationError) Field

Field function returns field value.

func (KickManageRunTaskValidationError) Key

Key function returns key value.

func (KickManageRunTaskValidationError) Reason

Reason function returns reason value.

type LongOpCompleted

type LongOpCompleted struct {

	// Long Operation ID.
	OperationId string `protobuf:"bytes,1,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"`
	// Status of the long operation.
	Status LongOpCompleted_Status `protobuf:"varint,2,opt,name=status,proto3,enum=cv.internal.run.eventpb.LongOpCompleted_Status" json:"status,omitempty"`
	// Types that are assignable to Result:
	//
	//	*LongOpCompleted_PostStartMessage_
	//	*LongOpCompleted_ResetTriggers_
	//	*LongOpCompleted_ExecuteTryjobs
	//	*LongOpCompleted_ExecutePostAction
	//	*LongOpCompleted_PostGerritMessage_
	Result isLongOpCompleted_Result `protobuf_oneof:"result"`
	// contains filtered or unexported fields
}

func (*LongOpCompleted) Descriptor deprecated

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

Deprecated: Use LongOpCompleted.ProtoReflect.Descriptor instead.

func (*LongOpCompleted) GetExecutePostAction

func (x *LongOpCompleted) GetExecutePostAction() *LongOpCompleted_ExecutePostActionResult

func (*LongOpCompleted) GetExecuteTryjobs

func (x *LongOpCompleted) GetExecuteTryjobs() *tryjob.ExecuteTryjobsResult

func (*LongOpCompleted) GetOperationId

func (x *LongOpCompleted) GetOperationId() string

func (*LongOpCompleted) GetPostGerritMessage

func (x *LongOpCompleted) GetPostGerritMessage() *LongOpCompleted_PostGerritMessage

func (*LongOpCompleted) GetPostStartMessage

func (x *LongOpCompleted) GetPostStartMessage() *LongOpCompleted_PostStartMessage

func (*LongOpCompleted) GetResetTriggers

func (x *LongOpCompleted) GetResetTriggers() *LongOpCompleted_ResetTriggers

func (*LongOpCompleted) GetResult

func (m *LongOpCompleted) GetResult() isLongOpCompleted_Result

func (*LongOpCompleted) GetStatus

func (x *LongOpCompleted) GetStatus() LongOpCompleted_Status

func (*LongOpCompleted) ProtoMessage

func (*LongOpCompleted) ProtoMessage()

func (*LongOpCompleted) ProtoReflect

func (x *LongOpCompleted) ProtoReflect() protoreflect.Message

func (*LongOpCompleted) Reset

func (x *LongOpCompleted) Reset()

func (*LongOpCompleted) String

func (x *LongOpCompleted) String() string

func (*LongOpCompleted) Validate

func (m *LongOpCompleted) Validate() error

Validate checks the field values on LongOpCompleted with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*LongOpCompleted) ValidateAll

func (m *LongOpCompleted) ValidateAll() error

ValidateAll checks the field values on LongOpCompleted with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in LongOpCompletedMultiError, or nil if none found.

type LongOpCompletedMultiError

type LongOpCompletedMultiError []error

LongOpCompletedMultiError is an error wrapping multiple validation errors returned by LongOpCompleted.ValidateAll() if the designated constraints aren't met.

func (LongOpCompletedMultiError) AllErrors

func (m LongOpCompletedMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LongOpCompletedMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type LongOpCompletedValidationError

type LongOpCompletedValidationError struct {
	// contains filtered or unexported fields
}

LongOpCompletedValidationError is the validation error returned by LongOpCompleted.Validate if the designated constraints aren't met.

func (LongOpCompletedValidationError) Cause

Cause function returns cause value.

func (LongOpCompletedValidationError) Error

Error satisfies the builtin error interface

func (LongOpCompletedValidationError) ErrorName

func (e LongOpCompletedValidationError) ErrorName() string

ErrorName returns error name.

func (LongOpCompletedValidationError) Field

Field function returns field value.

func (LongOpCompletedValidationError) Key

Key function returns key value.

func (LongOpCompletedValidationError) Reason

Reason function returns reason value.

type LongOpCompleted_ExecutePostAction

type LongOpCompleted_ExecutePostAction struct {
	ExecutePostAction *LongOpCompleted_ExecutePostActionResult `protobuf:"bytes,7,opt,name=execute_post_action,json=executePostAction,proto3,oneof"`
}

type LongOpCompleted_ExecutePostActionResult

type LongOpCompleted_ExecutePostActionResult struct {
	Summary string `protobuf:"bytes,1,opt,name=summary,proto3" json:"summary,omitempty"`
	// contains filtered or unexported fields
}

func (*LongOpCompleted_ExecutePostActionResult) Descriptor deprecated

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

Deprecated: Use LongOpCompleted_ExecutePostActionResult.ProtoReflect.Descriptor instead.

func (*LongOpCompleted_ExecutePostActionResult) GetSummary

func (*LongOpCompleted_ExecutePostActionResult) ProtoMessage

func (*LongOpCompleted_ExecutePostActionResult) ProtoReflect

func (*LongOpCompleted_ExecutePostActionResult) Reset

func (*LongOpCompleted_ExecutePostActionResult) String

func (*LongOpCompleted_ExecutePostActionResult) Validate

Validate checks the field values on LongOpCompleted_ExecutePostActionResult with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*LongOpCompleted_ExecutePostActionResult) ValidateAll

ValidateAll checks the field values on LongOpCompleted_ExecutePostActionResult with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in LongOpCompleted_ExecutePostActionResultMultiError, or nil if none found.

type LongOpCompleted_ExecutePostActionResultMultiError

type LongOpCompleted_ExecutePostActionResultMultiError []error

LongOpCompleted_ExecutePostActionResultMultiError is an error wrapping multiple validation errors returned by LongOpCompleted_ExecutePostActionResult.ValidateAll() if the designated constraints aren't met.

func (LongOpCompleted_ExecutePostActionResultMultiError) AllErrors

AllErrors returns a list of validation violation errors.

func (LongOpCompleted_ExecutePostActionResultMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type LongOpCompleted_ExecutePostActionResultValidationError

type LongOpCompleted_ExecutePostActionResultValidationError struct {
	// contains filtered or unexported fields
}

LongOpCompleted_ExecutePostActionResultValidationError is the validation error returned by LongOpCompleted_ExecutePostActionResult.Validate if the designated constraints aren't met.

func (LongOpCompleted_ExecutePostActionResultValidationError) Cause

Cause function returns cause value.

func (LongOpCompleted_ExecutePostActionResultValidationError) Error

Error satisfies the builtin error interface

func (LongOpCompleted_ExecutePostActionResultValidationError) ErrorName

ErrorName returns error name.

func (LongOpCompleted_ExecutePostActionResultValidationError) Field

Field function returns field value.

func (LongOpCompleted_ExecutePostActionResultValidationError) Key

Key function returns key value.

func (LongOpCompleted_ExecutePostActionResultValidationError) Reason

Reason function returns reason value.

type LongOpCompleted_ExecuteTryjobs

type LongOpCompleted_ExecuteTryjobs struct {
	ExecuteTryjobs *tryjob.ExecuteTryjobsResult `protobuf:"bytes,5,opt,name=execute_tryjobs,json=executeTryjobs,proto3,oneof"`
}

type LongOpCompleted_PostGerritMessage

type LongOpCompleted_PostGerritMessage struct {

	// Approximate time when CV became certain that the message was posted on
	// the last CL.
	Time *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*LongOpCompleted_PostGerritMessage) Descriptor deprecated

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

Deprecated: Use LongOpCompleted_PostGerritMessage.ProtoReflect.Descriptor instead.

func (*LongOpCompleted_PostGerritMessage) GetTime

func (*LongOpCompleted_PostGerritMessage) ProtoMessage

func (*LongOpCompleted_PostGerritMessage) ProtoMessage()

func (*LongOpCompleted_PostGerritMessage) ProtoReflect

func (*LongOpCompleted_PostGerritMessage) Reset

func (*LongOpCompleted_PostGerritMessage) String

func (*LongOpCompleted_PostGerritMessage) Validate

Validate checks the field values on LongOpCompleted_PostGerritMessage with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*LongOpCompleted_PostGerritMessage) ValidateAll

func (m *LongOpCompleted_PostGerritMessage) ValidateAll() error

ValidateAll checks the field values on LongOpCompleted_PostGerritMessage with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in LongOpCompleted_PostGerritMessageMultiError, or nil if none found.

type LongOpCompleted_PostGerritMessageMultiError

type LongOpCompleted_PostGerritMessageMultiError []error

LongOpCompleted_PostGerritMessageMultiError is an error wrapping multiple validation errors returned by LongOpCompleted_PostGerritMessage.ValidateAll() if the designated constraints aren't met.

func (LongOpCompleted_PostGerritMessageMultiError) AllErrors

AllErrors returns a list of validation violation errors.

func (LongOpCompleted_PostGerritMessageMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type LongOpCompleted_PostGerritMessageValidationError

type LongOpCompleted_PostGerritMessageValidationError struct {
	// contains filtered or unexported fields
}

LongOpCompleted_PostGerritMessageValidationError is the validation error returned by LongOpCompleted_PostGerritMessage.Validate if the designated constraints aren't met.

func (LongOpCompleted_PostGerritMessageValidationError) Cause

Cause function returns cause value.

func (LongOpCompleted_PostGerritMessageValidationError) Error

Error satisfies the builtin error interface

func (LongOpCompleted_PostGerritMessageValidationError) ErrorName

ErrorName returns error name.

func (LongOpCompleted_PostGerritMessageValidationError) Field

Field function returns field value.

func (LongOpCompleted_PostGerritMessageValidationError) Key

Key function returns key value.

func (LongOpCompleted_PostGerritMessageValidationError) Reason

Reason function returns reason value.

type LongOpCompleted_PostGerritMessage_

type LongOpCompleted_PostGerritMessage_ struct {
	PostGerritMessage *LongOpCompleted_PostGerritMessage `protobuf:"bytes,8,opt,name=post_gerrit_message,json=postGerritMessage,proto3,oneof"`
}

type LongOpCompleted_PostStartMessage

type LongOpCompleted_PostStartMessage struct {

	// Approximate time when CV became certain that the message was posted on
	// the last CL.
	Time *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*LongOpCompleted_PostStartMessage) Descriptor deprecated

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

Deprecated: Use LongOpCompleted_PostStartMessage.ProtoReflect.Descriptor instead.

func (*LongOpCompleted_PostStartMessage) GetTime

func (*LongOpCompleted_PostStartMessage) ProtoMessage

func (*LongOpCompleted_PostStartMessage) ProtoMessage()

func (*LongOpCompleted_PostStartMessage) ProtoReflect

func (*LongOpCompleted_PostStartMessage) Reset

func (*LongOpCompleted_PostStartMessage) String

func (*LongOpCompleted_PostStartMessage) Validate

Validate checks the field values on LongOpCompleted_PostStartMessage with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*LongOpCompleted_PostStartMessage) ValidateAll

func (m *LongOpCompleted_PostStartMessage) ValidateAll() error

ValidateAll checks the field values on LongOpCompleted_PostStartMessage with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in LongOpCompleted_PostStartMessageMultiError, or nil if none found.

type LongOpCompleted_PostStartMessageMultiError

type LongOpCompleted_PostStartMessageMultiError []error

LongOpCompleted_PostStartMessageMultiError is an error wrapping multiple validation errors returned by LongOpCompleted_PostStartMessage.ValidateAll() if the designated constraints aren't met.

func (LongOpCompleted_PostStartMessageMultiError) AllErrors

AllErrors returns a list of validation violation errors.

func (LongOpCompleted_PostStartMessageMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type LongOpCompleted_PostStartMessageValidationError

type LongOpCompleted_PostStartMessageValidationError struct {
	// contains filtered or unexported fields
}

LongOpCompleted_PostStartMessageValidationError is the validation error returned by LongOpCompleted_PostStartMessage.Validate if the designated constraints aren't met.

func (LongOpCompleted_PostStartMessageValidationError) Cause

Cause function returns cause value.

func (LongOpCompleted_PostStartMessageValidationError) Error

Error satisfies the builtin error interface

func (LongOpCompleted_PostStartMessageValidationError) ErrorName

ErrorName returns error name.

func (LongOpCompleted_PostStartMessageValidationError) Field

Field function returns field value.

func (LongOpCompleted_PostStartMessageValidationError) Key

Key function returns key value.

func (LongOpCompleted_PostStartMessageValidationError) Reason

Reason function returns reason value.

type LongOpCompleted_PostStartMessage_

type LongOpCompleted_PostStartMessage_ struct {
	PostStartMessage *LongOpCompleted_PostStartMessage `protobuf:"bytes,3,opt,name=post_start_message,json=postStartMessage,proto3,oneof"`
}

type LongOpCompleted_ResetTriggers

type LongOpCompleted_ResetTriggers struct {

	// The top-level long ops status will be SUCCEEDED iff all triggers are
	// reset successfully, in other word, all results have `reset_at` set.
	Results []*LongOpCompleted_ResetTriggers_Result `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

func (*LongOpCompleted_ResetTriggers) Descriptor deprecated

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

Deprecated: Use LongOpCompleted_ResetTriggers.ProtoReflect.Descriptor instead.

func (*LongOpCompleted_ResetTriggers) GetResults

func (*LongOpCompleted_ResetTriggers) ProtoMessage

func (*LongOpCompleted_ResetTriggers) ProtoMessage()

func (*LongOpCompleted_ResetTriggers) ProtoReflect

func (*LongOpCompleted_ResetTriggers) Reset

func (x *LongOpCompleted_ResetTriggers) Reset()

func (*LongOpCompleted_ResetTriggers) String

func (*LongOpCompleted_ResetTriggers) Validate

func (m *LongOpCompleted_ResetTriggers) Validate() error

Validate checks the field values on LongOpCompleted_ResetTriggers with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*LongOpCompleted_ResetTriggers) ValidateAll

func (m *LongOpCompleted_ResetTriggers) ValidateAll() error

ValidateAll checks the field values on LongOpCompleted_ResetTriggers with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in LongOpCompleted_ResetTriggersMultiError, or nil if none found.

type LongOpCompleted_ResetTriggersMultiError

type LongOpCompleted_ResetTriggersMultiError []error

LongOpCompleted_ResetTriggersMultiError is an error wrapping multiple validation errors returned by LongOpCompleted_ResetTriggers.ValidateAll() if the designated constraints aren't met.

func (LongOpCompleted_ResetTriggersMultiError) AllErrors

AllErrors returns a list of validation violation errors.

func (LongOpCompleted_ResetTriggersMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type LongOpCompleted_ResetTriggersValidationError

type LongOpCompleted_ResetTriggersValidationError struct {
	// contains filtered or unexported fields
}

LongOpCompleted_ResetTriggersValidationError is the validation error returned by LongOpCompleted_ResetTriggers.Validate if the designated constraints aren't met.

func (LongOpCompleted_ResetTriggersValidationError) Cause

Cause function returns cause value.

func (LongOpCompleted_ResetTriggersValidationError) Error

Error satisfies the builtin error interface

func (LongOpCompleted_ResetTriggersValidationError) ErrorName

ErrorName returns error name.

func (LongOpCompleted_ResetTriggersValidationError) Field

Field function returns field value.

func (LongOpCompleted_ResetTriggersValidationError) Key

Key function returns key value.

func (LongOpCompleted_ResetTriggersValidationError) Reason

Reason function returns reason value.

type LongOpCompleted_ResetTriggers_

type LongOpCompleted_ResetTriggers_ struct {
	ResetTriggers *LongOpCompleted_ResetTriggers `protobuf:"bytes,6,opt,name=reset_triggers,json=resetTriggers,proto3,oneof"`
}

type LongOpCompleted_ResetTriggers_Result

type LongOpCompleted_ResetTriggers_Result struct {

	// ID of the CL that this long op is trying to reset its trigger.
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// The external id of the CL.
	ExternalId string `protobuf:"bytes,2,opt,name=external_id,json=externalId,proto3" json:"external_id,omitempty"`
	// Types that are assignable to Detail:
	//
	//	*LongOpCompleted_ResetTriggers_Result_SuccessInfo
	//	*LongOpCompleted_ResetTriggers_Result_FailureInfo
	Detail isLongOpCompleted_ResetTriggers_Result_Detail `protobuf_oneof:"detail"`
	// contains filtered or unexported fields
}

func (*LongOpCompleted_ResetTriggers_Result) Descriptor deprecated

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

Deprecated: Use LongOpCompleted_ResetTriggers_Result.ProtoReflect.Descriptor instead.

func (*LongOpCompleted_ResetTriggers_Result) GetDetail

func (m *LongOpCompleted_ResetTriggers_Result) GetDetail() isLongOpCompleted_ResetTriggers_Result_Detail

func (*LongOpCompleted_ResetTriggers_Result) GetExternalId

func (x *LongOpCompleted_ResetTriggers_Result) GetExternalId() string

func (*LongOpCompleted_ResetTriggers_Result) GetFailureInfo

func (*LongOpCompleted_ResetTriggers_Result) GetId

func (*LongOpCompleted_ResetTriggers_Result) GetSuccessInfo

func (*LongOpCompleted_ResetTriggers_Result) ProtoMessage

func (*LongOpCompleted_ResetTriggers_Result) ProtoMessage()

func (*LongOpCompleted_ResetTriggers_Result) ProtoReflect

func (*LongOpCompleted_ResetTriggers_Result) Reset

func (*LongOpCompleted_ResetTriggers_Result) String

func (*LongOpCompleted_ResetTriggers_Result) Validate

Validate checks the field values on LongOpCompleted_ResetTriggers_Result with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*LongOpCompleted_ResetTriggers_Result) ValidateAll

ValidateAll checks the field values on LongOpCompleted_ResetTriggers_Result with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in LongOpCompleted_ResetTriggers_ResultMultiError, or nil if none found.

type LongOpCompleted_ResetTriggers_ResultMultiError

type LongOpCompleted_ResetTriggers_ResultMultiError []error

LongOpCompleted_ResetTriggers_ResultMultiError is an error wrapping multiple validation errors returned by LongOpCompleted_ResetTriggers_Result.ValidateAll() if the designated constraints aren't met.

func (LongOpCompleted_ResetTriggers_ResultMultiError) AllErrors

AllErrors returns a list of validation violation errors.

func (LongOpCompleted_ResetTriggers_ResultMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type LongOpCompleted_ResetTriggers_ResultValidationError

type LongOpCompleted_ResetTriggers_ResultValidationError struct {
	// contains filtered or unexported fields
}

LongOpCompleted_ResetTriggers_ResultValidationError is the validation error returned by LongOpCompleted_ResetTriggers_Result.Validate if the designated constraints aren't met.

func (LongOpCompleted_ResetTriggers_ResultValidationError) Cause

Cause function returns cause value.

func (LongOpCompleted_ResetTriggers_ResultValidationError) Error

Error satisfies the builtin error interface

func (LongOpCompleted_ResetTriggers_ResultValidationError) ErrorName

ErrorName returns error name.

func (LongOpCompleted_ResetTriggers_ResultValidationError) Field

Field function returns field value.

func (LongOpCompleted_ResetTriggers_ResultValidationError) Key

Key function returns key value.

func (LongOpCompleted_ResetTriggers_ResultValidationError) Reason

Reason function returns reason value.

type LongOpCompleted_ResetTriggers_Result_Failure

type LongOpCompleted_ResetTriggers_Result_Failure struct {

	// The message when CV failed to reset the trigger.
	FailureMessage string `protobuf:"bytes,1,opt,name=failure_message,json=failureMessage,proto3" json:"failure_message,omitempty"`
	// contains filtered or unexported fields
}

func (*LongOpCompleted_ResetTriggers_Result_Failure) Descriptor deprecated

Deprecated: Use LongOpCompleted_ResetTriggers_Result_Failure.ProtoReflect.Descriptor instead.

func (*LongOpCompleted_ResetTriggers_Result_Failure) GetFailureMessage

func (*LongOpCompleted_ResetTriggers_Result_Failure) ProtoMessage

func (*LongOpCompleted_ResetTriggers_Result_Failure) ProtoReflect

func (*LongOpCompleted_ResetTriggers_Result_Failure) Reset

func (*LongOpCompleted_ResetTriggers_Result_Failure) String

func (*LongOpCompleted_ResetTriggers_Result_Failure) Validate

Validate checks the field values on LongOpCompleted_ResetTriggers_Result_Failure with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*LongOpCompleted_ResetTriggers_Result_Failure) ValidateAll

ValidateAll checks the field values on LongOpCompleted_ResetTriggers_Result_Failure with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in LongOpCompleted_ResetTriggers_Result_FailureMultiError, or nil if none found.

type LongOpCompleted_ResetTriggers_Result_FailureInfo

type LongOpCompleted_ResetTriggers_Result_FailureInfo struct {
	FailureInfo *LongOpCompleted_ResetTriggers_Result_Failure `protobuf:"bytes,4,opt,name=failure_info,json=failureInfo,proto3,oneof"`
}

type LongOpCompleted_ResetTriggers_Result_FailureMultiError

type LongOpCompleted_ResetTriggers_Result_FailureMultiError []error

LongOpCompleted_ResetTriggers_Result_FailureMultiError is an error wrapping multiple validation errors returned by LongOpCompleted_ResetTriggers_Result_Failure.ValidateAll() if the designated constraints aren't met.

func (LongOpCompleted_ResetTriggers_Result_FailureMultiError) AllErrors

AllErrors returns a list of validation violation errors.

func (LongOpCompleted_ResetTriggers_Result_FailureMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type LongOpCompleted_ResetTriggers_Result_FailureValidationError

type LongOpCompleted_ResetTriggers_Result_FailureValidationError struct {
	// contains filtered or unexported fields
}

LongOpCompleted_ResetTriggers_Result_FailureValidationError is the validation error returned by LongOpCompleted_ResetTriggers_Result_Failure.Validate if the designated constraints aren't met.

func (LongOpCompleted_ResetTriggers_Result_FailureValidationError) Cause

Cause function returns cause value.

func (LongOpCompleted_ResetTriggers_Result_FailureValidationError) Error

Error satisfies the builtin error interface

func (LongOpCompleted_ResetTriggers_Result_FailureValidationError) ErrorName

ErrorName returns error name.

func (LongOpCompleted_ResetTriggers_Result_FailureValidationError) Field

Field function returns field value.

func (LongOpCompleted_ResetTriggers_Result_FailureValidationError) Key

Key function returns key value.

func (LongOpCompleted_ResetTriggers_Result_FailureValidationError) Reason

Reason function returns reason value.

type LongOpCompleted_ResetTriggers_Result_Success

type LongOpCompleted_ResetTriggers_Result_Success struct {

	// The timestamp when trigger is successfully reset from LUCI CV
	// PoV.
	//
	// It is possible by the time LUCI CV is trying to reset the trigger,
	// it has already been removed by the user. Therefore, this timestamp
	// is the time when LUCI CV observes that trigger is removed.
	ResetAt *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=reset_at,json=resetAt,proto3" json:"reset_at,omitempty"`
	// contains filtered or unexported fields
}

func (*LongOpCompleted_ResetTriggers_Result_Success) Descriptor deprecated

Deprecated: Use LongOpCompleted_ResetTriggers_Result_Success.ProtoReflect.Descriptor instead.

func (*LongOpCompleted_ResetTriggers_Result_Success) GetResetAt

func (*LongOpCompleted_ResetTriggers_Result_Success) ProtoMessage

func (*LongOpCompleted_ResetTriggers_Result_Success) ProtoReflect

func (*LongOpCompleted_ResetTriggers_Result_Success) Reset

func (*LongOpCompleted_ResetTriggers_Result_Success) String

func (*LongOpCompleted_ResetTriggers_Result_Success) Validate

Validate checks the field values on LongOpCompleted_ResetTriggers_Result_Success with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*LongOpCompleted_ResetTriggers_Result_Success) ValidateAll

ValidateAll checks the field values on LongOpCompleted_ResetTriggers_Result_Success with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in LongOpCompleted_ResetTriggers_Result_SuccessMultiError, or nil if none found.

type LongOpCompleted_ResetTriggers_Result_SuccessInfo

type LongOpCompleted_ResetTriggers_Result_SuccessInfo struct {
	SuccessInfo *LongOpCompleted_ResetTriggers_Result_Success `protobuf:"bytes,3,opt,name=success_info,json=successInfo,proto3,oneof"`
}

type LongOpCompleted_ResetTriggers_Result_SuccessMultiError

type LongOpCompleted_ResetTriggers_Result_SuccessMultiError []error

LongOpCompleted_ResetTriggers_Result_SuccessMultiError is an error wrapping multiple validation errors returned by LongOpCompleted_ResetTriggers_Result_Success.ValidateAll() if the designated constraints aren't met.

func (LongOpCompleted_ResetTriggers_Result_SuccessMultiError) AllErrors

AllErrors returns a list of validation violation errors.

func (LongOpCompleted_ResetTriggers_Result_SuccessMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type LongOpCompleted_ResetTriggers_Result_SuccessValidationError

type LongOpCompleted_ResetTriggers_Result_SuccessValidationError struct {
	// contains filtered or unexported fields
}

LongOpCompleted_ResetTriggers_Result_SuccessValidationError is the validation error returned by LongOpCompleted_ResetTriggers_Result_Success.Validate if the designated constraints aren't met.

func (LongOpCompleted_ResetTriggers_Result_SuccessValidationError) Cause

Cause function returns cause value.

func (LongOpCompleted_ResetTriggers_Result_SuccessValidationError) Error

Error satisfies the builtin error interface

func (LongOpCompleted_ResetTriggers_Result_SuccessValidationError) ErrorName

ErrorName returns error name.

func (LongOpCompleted_ResetTriggers_Result_SuccessValidationError) Field

Field function returns field value.

func (LongOpCompleted_ResetTriggers_Result_SuccessValidationError) Key

Key function returns key value.

func (LongOpCompleted_ResetTriggers_Result_SuccessValidationError) Reason

Reason function returns reason value.

type LongOpCompleted_Status

type LongOpCompleted_Status int32
const (
	LongOpCompleted_LONG_OP_STATUS_UNSPECIFIED LongOpCompleted_Status = 0
	// SUCCEEDED means the long operation succeeded.
	LongOpCompleted_SUCCEEDED LongOpCompleted_Status = 1
	// FAILED means the long operation experienced a failure.
	LongOpCompleted_FAILED LongOpCompleted_Status = 2
	// Cancelled is true if the LongOp detected that it was cancelled by the Run
	// Manager and thus stopped its working before completion.
	LongOpCompleted_CANCELLED LongOpCompleted_Status = 3
	// Expired means the long operation expired.
	//
	// If this is the case, the `result` field may be unset: this should be rare
	// but may happen if Run Manager detects expiry before a LongOpCompleted
	// event is sent by the long operation handling task.
	LongOpCompleted_EXPIRED LongOpCompleted_Status = 4
)

func (LongOpCompleted_Status) Descriptor

func (LongOpCompleted_Status) Enum

func (LongOpCompleted_Status) EnumDescriptor deprecated

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

Deprecated: Use LongOpCompleted_Status.Descriptor instead.

func (LongOpCompleted_Status) Number

func (LongOpCompleted_Status) String

func (x LongOpCompleted_Status) String() string

func (LongOpCompleted_Status) Type

type ManageRunLongOpTask

type ManageRunLongOpTask struct {
	RunId       string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	OperationId string `protobuf:"bytes,2,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"`
	// contains filtered or unexported fields
}

ManageRunLongOpTask performs potentially slow work on behalf a Run.

A task of this kind is always created transactionally with the Run entity modification recording the operation in OngoingLongOps.

A task of this kind does not modify the Run entity directly, but communicates back with Run Manager by sending at least the completion event, and possibly other events.

Queue: "manage-run-long-op".

func (*ManageRunLongOpTask) Descriptor deprecated

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

Deprecated: Use ManageRunLongOpTask.ProtoReflect.Descriptor instead.

func (*ManageRunLongOpTask) GetOperationId

func (x *ManageRunLongOpTask) GetOperationId() string

func (*ManageRunLongOpTask) GetRunId

func (x *ManageRunLongOpTask) GetRunId() string

func (*ManageRunLongOpTask) ProtoMessage

func (*ManageRunLongOpTask) ProtoMessage()

func (*ManageRunLongOpTask) ProtoReflect

func (x *ManageRunLongOpTask) ProtoReflect() protoreflect.Message

func (*ManageRunLongOpTask) Reset

func (x *ManageRunLongOpTask) Reset()

func (*ManageRunLongOpTask) String

func (x *ManageRunLongOpTask) String() string

func (*ManageRunLongOpTask) Validate

func (m *ManageRunLongOpTask) Validate() error

Validate checks the field values on ManageRunLongOpTask with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ManageRunLongOpTask) ValidateAll

func (m *ManageRunLongOpTask) ValidateAll() error

ValidateAll checks the field values on ManageRunLongOpTask with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ManageRunLongOpTaskMultiError, or nil if none found.

type ManageRunLongOpTaskMultiError

type ManageRunLongOpTaskMultiError []error

ManageRunLongOpTaskMultiError is an error wrapping multiple validation errors returned by ManageRunLongOpTask.ValidateAll() if the designated constraints aren't met.

func (ManageRunLongOpTaskMultiError) AllErrors

func (m ManageRunLongOpTaskMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ManageRunLongOpTaskMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type ManageRunLongOpTaskValidationError

type ManageRunLongOpTaskValidationError struct {
	// contains filtered or unexported fields
}

ManageRunLongOpTaskValidationError is the validation error returned by ManageRunLongOpTask.Validate if the designated constraints aren't met.

func (ManageRunLongOpTaskValidationError) Cause

Cause function returns cause value.

func (ManageRunLongOpTaskValidationError) Error

Error satisfies the builtin error interface

func (ManageRunLongOpTaskValidationError) ErrorName

ErrorName returns error name.

func (ManageRunLongOpTaskValidationError) Field

Field function returns field value.

func (ManageRunLongOpTaskValidationError) Key

Key function returns key value.

func (ManageRunLongOpTaskValidationError) Reason

Reason function returns reason value.

type ManageRunTask

type ManageRunTask struct {
	RunId string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// contains filtered or unexported fields
}

ManageRunTask sends a signal to RunManager to process events.

Always used with de-duplication and thus can't be created from a transaction.

Queue: "manage-run".

func (*ManageRunTask) Descriptor deprecated

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

Deprecated: Use ManageRunTask.ProtoReflect.Descriptor instead.

func (*ManageRunTask) GetRunId

func (x *ManageRunTask) GetRunId() string

func (*ManageRunTask) ProtoMessage

func (*ManageRunTask) ProtoMessage()

func (*ManageRunTask) ProtoReflect

func (x *ManageRunTask) ProtoReflect() protoreflect.Message

func (*ManageRunTask) Reset

func (x *ManageRunTask) Reset()

func (*ManageRunTask) String

func (x *ManageRunTask) String() string

func (*ManageRunTask) Validate

func (m *ManageRunTask) Validate() error

Validate checks the field values on ManageRunTask with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ManageRunTask) ValidateAll

func (m *ManageRunTask) ValidateAll() error

ValidateAll checks the field values on ManageRunTask with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ManageRunTaskMultiError, or nil if none found.

type ManageRunTaskMultiError

type ManageRunTaskMultiError []error

ManageRunTaskMultiError is an error wrapping multiple validation errors returned by ManageRunTask.ValidateAll() if the designated constraints aren't met.

func (ManageRunTaskMultiError) AllErrors

func (m ManageRunTaskMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ManageRunTaskMultiError) Error

func (m ManageRunTaskMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ManageRunTaskValidationError

type ManageRunTaskValidationError struct {
	// contains filtered or unexported fields
}

ManageRunTaskValidationError is the validation error returned by ManageRunTask.Validate if the designated constraints aren't met.

func (ManageRunTaskValidationError) Cause

Cause function returns cause value.

func (ManageRunTaskValidationError) Error

Error satisfies the builtin error interface

func (ManageRunTaskValidationError) ErrorName

func (e ManageRunTaskValidationError) ErrorName() string

ErrorName returns error name.

func (ManageRunTaskValidationError) Field

Field function returns field value.

func (ManageRunTaskValidationError) Key

Key function returns key value.

func (ManageRunTaskValidationError) Reason

Reason function returns reason value.

type NewConfig

type NewConfig struct {

	// Hash identifying project config version to update to.
	Hash string `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	// Eversion of the project config version identify by hash.
	//
	// Provided for identifying the latest NewConfig message
	// if there are more than one outstanding NewConfig event.
	Eversion int64 `protobuf:"varint,2,opt,name=eversion,proto3" json:"eversion,omitempty"`
	// contains filtered or unexported fields
}

func (*NewConfig) Descriptor deprecated

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

Deprecated: Use NewConfig.ProtoReflect.Descriptor instead.

func (*NewConfig) GetEversion

func (x *NewConfig) GetEversion() int64

func (*NewConfig) GetHash

func (x *NewConfig) GetHash() string

func (*NewConfig) ProtoMessage

func (*NewConfig) ProtoMessage()

func (*NewConfig) ProtoReflect

func (x *NewConfig) ProtoReflect() protoreflect.Message

func (*NewConfig) Reset

func (x *NewConfig) Reset()

func (*NewConfig) String

func (x *NewConfig) String() string

func (*NewConfig) Validate

func (m *NewConfig) Validate() error

Validate checks the field values on NewConfig with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*NewConfig) ValidateAll

func (m *NewConfig) ValidateAll() error

ValidateAll checks the field values on NewConfig with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in NewConfigMultiError, or nil if none found.

type NewConfigMultiError

type NewConfigMultiError []error

NewConfigMultiError is an error wrapping multiple validation errors returned by NewConfig.ValidateAll() if the designated constraints aren't met.

func (NewConfigMultiError) AllErrors

func (m NewConfigMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (NewConfigMultiError) Error

func (m NewConfigMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type NewConfigValidationError

type NewConfigValidationError struct {
	// contains filtered or unexported fields
}

NewConfigValidationError is the validation error returned by NewConfig.Validate if the designated constraints aren't met.

func (NewConfigValidationError) Cause

func (e NewConfigValidationError) Cause() error

Cause function returns cause value.

func (NewConfigValidationError) Error

func (e NewConfigValidationError) Error() string

Error satisfies the builtin error interface

func (NewConfigValidationError) ErrorName

func (e NewConfigValidationError) ErrorName() string

ErrorName returns error name.

func (NewConfigValidationError) Field

func (e NewConfigValidationError) Field() string

Field function returns field value.

func (NewConfigValidationError) Key

Key function returns key value.

func (NewConfigValidationError) Reason

func (e NewConfigValidationError) Reason() string

Reason function returns reason value.

type ParentRunCompleted

type ParentRunCompleted struct {
	// contains filtered or unexported fields
}

func (*ParentRunCompleted) Descriptor deprecated

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

Deprecated: Use ParentRunCompleted.ProtoReflect.Descriptor instead.

func (*ParentRunCompleted) ProtoMessage

func (*ParentRunCompleted) ProtoMessage()

func (*ParentRunCompleted) ProtoReflect

func (x *ParentRunCompleted) ProtoReflect() protoreflect.Message

func (*ParentRunCompleted) Reset

func (x *ParentRunCompleted) Reset()

func (*ParentRunCompleted) String

func (x *ParentRunCompleted) String() string

func (*ParentRunCompleted) Validate

func (m *ParentRunCompleted) Validate() error

Validate checks the field values on ParentRunCompleted with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ParentRunCompleted) ValidateAll

func (m *ParentRunCompleted) ValidateAll() error

ValidateAll checks the field values on ParentRunCompleted with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ParentRunCompletedMultiError, or nil if none found.

type ParentRunCompletedMultiError

type ParentRunCompletedMultiError []error

ParentRunCompletedMultiError is an error wrapping multiple validation errors returned by ParentRunCompleted.ValidateAll() if the designated constraints aren't met.

func (ParentRunCompletedMultiError) AllErrors

func (m ParentRunCompletedMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ParentRunCompletedMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type ParentRunCompletedValidationError

type ParentRunCompletedValidationError struct {
	// contains filtered or unexported fields
}

ParentRunCompletedValidationError is the validation error returned by ParentRunCompleted.Validate if the designated constraints aren't met.

func (ParentRunCompletedValidationError) Cause

Cause function returns cause value.

func (ParentRunCompletedValidationError) Error

Error satisfies the builtin error interface

func (ParentRunCompletedValidationError) ErrorName

ErrorName returns error name.

func (ParentRunCompletedValidationError) Field

Field function returns field value.

func (ParentRunCompletedValidationError) Key

Key function returns key value.

func (ParentRunCompletedValidationError) Reason

Reason function returns reason value.

type Poke

type Poke struct {
	// contains filtered or unexported fields
}

func (*Poke) Descriptor deprecated

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

Deprecated: Use Poke.ProtoReflect.Descriptor instead.

func (*Poke) ProtoMessage

func (*Poke) ProtoMessage()

func (*Poke) ProtoReflect

func (x *Poke) ProtoReflect() protoreflect.Message

func (*Poke) Reset

func (x *Poke) Reset()

func (*Poke) String

func (x *Poke) String() string

func (*Poke) Validate

func (m *Poke) Validate() error

Validate checks the field values on Poke with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Poke) ValidateAll

func (m *Poke) ValidateAll() error

ValidateAll checks the field values on Poke with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PokeMultiError, or nil if none found.

type PokeMultiError

type PokeMultiError []error

PokeMultiError is an error wrapping multiple validation errors returned by Poke.ValidateAll() if the designated constraints aren't met.

func (PokeMultiError) AllErrors

func (m PokeMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PokeMultiError) Error

func (m PokeMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type PokeValidationError

type PokeValidationError struct {
	// contains filtered or unexported fields
}

PokeValidationError is the validation error returned by Poke.Validate if the designated constraints aren't met.

func (PokeValidationError) Cause

func (e PokeValidationError) Cause() error

Cause function returns cause value.

func (PokeValidationError) Error

func (e PokeValidationError) Error() string

Error satisfies the builtin error interface

func (PokeValidationError) ErrorName

func (e PokeValidationError) ErrorName() string

ErrorName returns error name.

func (PokeValidationError) Field

func (e PokeValidationError) Field() string

Field function returns field value.

func (PokeValidationError) Key

func (e PokeValidationError) Key() bool

Key function returns key value.

func (PokeValidationError) Reason

func (e PokeValidationError) Reason() string

Reason function returns reason value.

type ReadyForSubmission

type ReadyForSubmission struct {
	// contains filtered or unexported fields
}

func (*ReadyForSubmission) Descriptor deprecated

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

Deprecated: Use ReadyForSubmission.ProtoReflect.Descriptor instead.

func (*ReadyForSubmission) ProtoMessage

func (*ReadyForSubmission) ProtoMessage()

func (*ReadyForSubmission) ProtoReflect

func (x *ReadyForSubmission) ProtoReflect() protoreflect.Message

func (*ReadyForSubmission) Reset

func (x *ReadyForSubmission) Reset()

func (*ReadyForSubmission) String

func (x *ReadyForSubmission) String() string

func (*ReadyForSubmission) Validate

func (m *ReadyForSubmission) Validate() error

Validate checks the field values on ReadyForSubmission with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ReadyForSubmission) ValidateAll

func (m *ReadyForSubmission) ValidateAll() error

ValidateAll checks the field values on ReadyForSubmission with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ReadyForSubmissionMultiError, or nil if none found.

type ReadyForSubmissionMultiError

type ReadyForSubmissionMultiError []error

ReadyForSubmissionMultiError is an error wrapping multiple validation errors returned by ReadyForSubmission.ValidateAll() if the designated constraints aren't met.

func (ReadyForSubmissionMultiError) AllErrors

func (m ReadyForSubmissionMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ReadyForSubmissionMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type ReadyForSubmissionValidationError

type ReadyForSubmissionValidationError struct {
	// contains filtered or unexported fields
}

ReadyForSubmissionValidationError is the validation error returned by ReadyForSubmission.Validate if the designated constraints aren't met.

func (ReadyForSubmissionValidationError) Cause

Cause function returns cause value.

func (ReadyForSubmissionValidationError) Error

Error satisfies the builtin error interface

func (ReadyForSubmissionValidationError) ErrorName

ErrorName returns error name.

func (ReadyForSubmissionValidationError) Field

Field function returns field value.

func (ReadyForSubmissionValidationError) Key

Key function returns key value.

func (ReadyForSubmissionValidationError) Reason

Reason function returns reason value.

type Start

type Start struct {
	// contains filtered or unexported fields
}

func (*Start) Descriptor deprecated

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

Deprecated: Use Start.ProtoReflect.Descriptor instead.

func (*Start) ProtoMessage

func (*Start) ProtoMessage()

func (*Start) ProtoReflect

func (x *Start) ProtoReflect() protoreflect.Message

func (*Start) Reset

func (x *Start) Reset()

func (*Start) String

func (x *Start) String() string

func (*Start) Validate

func (m *Start) Validate() error

Validate checks the field values on Start with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Start) ValidateAll

func (m *Start) ValidateAll() error

ValidateAll checks the field values on Start with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in StartMultiError, or nil if none found.

type StartMultiError

type StartMultiError []error

StartMultiError is an error wrapping multiple validation errors returned by Start.ValidateAll() if the designated constraints aren't met.

func (StartMultiError) AllErrors

func (m StartMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StartMultiError) Error

func (m StartMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type StartValidationError

type StartValidationError struct {
	// contains filtered or unexported fields
}

StartValidationError is the validation error returned by Start.Validate if the designated constraints aren't met.

func (StartValidationError) Cause

func (e StartValidationError) Cause() error

Cause function returns cause value.

func (StartValidationError) Error

func (e StartValidationError) Error() string

Error satisfies the builtin error interface

func (StartValidationError) ErrorName

func (e StartValidationError) ErrorName() string

ErrorName returns error name.

func (StartValidationError) Field

func (e StartValidationError) Field() string

Field function returns field value.

func (StartValidationError) Key

func (e StartValidationError) Key() bool

Key function returns key value.

func (StartValidationError) Reason

func (e StartValidationError) Reason() string

Reason function returns reason value.

type SubmissionCompleted

type SubmissionCompleted struct {

	// Result of this submission.
	Result                SubmissionResult       `protobuf:"varint,1,opt,name=result,proto3,enum=cv.internal.run.eventpb.SubmissionResult" json:"result,omitempty"`
	QueueReleaseTimestamp *timestamppb.Timestamp `` /* 126-byte string literal not displayed */
	// Types that are assignable to FailureReason:
	//
	//	*SubmissionCompleted_Timeout
	//	*SubmissionCompleted_ClFailures
	FailureReason isSubmissionCompleted_FailureReason `protobuf_oneof:"failure_reason"`
	// contains filtered or unexported fields
}

func (*SubmissionCompleted) Descriptor deprecated

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

Deprecated: Use SubmissionCompleted.ProtoReflect.Descriptor instead.

func (*SubmissionCompleted) GetClFailures

func (*SubmissionCompleted) GetFailureReason

func (m *SubmissionCompleted) GetFailureReason() isSubmissionCompleted_FailureReason

func (*SubmissionCompleted) GetQueueReleaseTimestamp

func (x *SubmissionCompleted) GetQueueReleaseTimestamp() *timestamppb.Timestamp

func (*SubmissionCompleted) GetResult

func (x *SubmissionCompleted) GetResult() SubmissionResult

func (*SubmissionCompleted) GetTimeout

func (x *SubmissionCompleted) GetTimeout() bool

func (*SubmissionCompleted) ProtoMessage

func (*SubmissionCompleted) ProtoMessage()

func (*SubmissionCompleted) ProtoReflect

func (x *SubmissionCompleted) ProtoReflect() protoreflect.Message

func (*SubmissionCompleted) Reset

func (x *SubmissionCompleted) Reset()

func (*SubmissionCompleted) String

func (x *SubmissionCompleted) String() string

func (*SubmissionCompleted) Validate

func (m *SubmissionCompleted) Validate() error

Validate checks the field values on SubmissionCompleted with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*SubmissionCompleted) ValidateAll

func (m *SubmissionCompleted) ValidateAll() error

ValidateAll checks the field values on SubmissionCompleted with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in SubmissionCompletedMultiError, or nil if none found.

type SubmissionCompletedMultiError

type SubmissionCompletedMultiError []error

SubmissionCompletedMultiError is an error wrapping multiple validation errors returned by SubmissionCompleted.ValidateAll() if the designated constraints aren't met.

func (SubmissionCompletedMultiError) AllErrors

func (m SubmissionCompletedMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (SubmissionCompletedMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type SubmissionCompletedValidationError

type SubmissionCompletedValidationError struct {
	// contains filtered or unexported fields
}

SubmissionCompletedValidationError is the validation error returned by SubmissionCompleted.Validate if the designated constraints aren't met.

func (SubmissionCompletedValidationError) Cause

Cause function returns cause value.

func (SubmissionCompletedValidationError) Error

Error satisfies the builtin error interface

func (SubmissionCompletedValidationError) ErrorName

ErrorName returns error name.

func (SubmissionCompletedValidationError) Field

Field function returns field value.

func (SubmissionCompletedValidationError) Key

Key function returns key value.

func (SubmissionCompletedValidationError) Reason

Reason function returns reason value.

type SubmissionCompleted_CLSubmissionFailure

type SubmissionCompleted_CLSubmissionFailure struct {
	Clid    int64  `protobuf:"varint,1,opt,name=clid,proto3" json:"clid,omitempty"`      // Required
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // Required
	// contains filtered or unexported fields
}

func (*SubmissionCompleted_CLSubmissionFailure) Descriptor deprecated

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

Deprecated: Use SubmissionCompleted_CLSubmissionFailure.ProtoReflect.Descriptor instead.

func (*SubmissionCompleted_CLSubmissionFailure) GetClid

func (*SubmissionCompleted_CLSubmissionFailure) GetMessage

func (*SubmissionCompleted_CLSubmissionFailure) ProtoMessage

func (*SubmissionCompleted_CLSubmissionFailure) ProtoReflect

func (*SubmissionCompleted_CLSubmissionFailure) Reset

func (*SubmissionCompleted_CLSubmissionFailure) String

func (*SubmissionCompleted_CLSubmissionFailure) Validate

Validate checks the field values on SubmissionCompleted_CLSubmissionFailure with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*SubmissionCompleted_CLSubmissionFailure) ValidateAll

ValidateAll checks the field values on SubmissionCompleted_CLSubmissionFailure with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in SubmissionCompleted_CLSubmissionFailureMultiError, or nil if none found.

type SubmissionCompleted_CLSubmissionFailureMultiError

type SubmissionCompleted_CLSubmissionFailureMultiError []error

SubmissionCompleted_CLSubmissionFailureMultiError is an error wrapping multiple validation errors returned by SubmissionCompleted_CLSubmissionFailure.ValidateAll() if the designated constraints aren't met.

func (SubmissionCompleted_CLSubmissionFailureMultiError) AllErrors

AllErrors returns a list of validation violation errors.

func (SubmissionCompleted_CLSubmissionFailureMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type SubmissionCompleted_CLSubmissionFailureValidationError

type SubmissionCompleted_CLSubmissionFailureValidationError struct {
	// contains filtered or unexported fields
}

SubmissionCompleted_CLSubmissionFailureValidationError is the validation error returned by SubmissionCompleted_CLSubmissionFailure.Validate if the designated constraints aren't met.

func (SubmissionCompleted_CLSubmissionFailureValidationError) Cause

Cause function returns cause value.

func (SubmissionCompleted_CLSubmissionFailureValidationError) Error

Error satisfies the builtin error interface

func (SubmissionCompleted_CLSubmissionFailureValidationError) ErrorName

ErrorName returns error name.

func (SubmissionCompleted_CLSubmissionFailureValidationError) Field

Field function returns field value.

func (SubmissionCompleted_CLSubmissionFailureValidationError) Key

Key function returns key value.

func (SubmissionCompleted_CLSubmissionFailureValidationError) Reason

Reason function returns reason value.

type SubmissionCompleted_CLSubmissionFailures

type SubmissionCompleted_CLSubmissionFailures struct {
	Failures []*SubmissionCompleted_CLSubmissionFailure `protobuf:"bytes,1,rep,name=failures,proto3" json:"failures,omitempty"`
	// contains filtered or unexported fields
}

func (*SubmissionCompleted_CLSubmissionFailures) Descriptor deprecated

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

Deprecated: Use SubmissionCompleted_CLSubmissionFailures.ProtoReflect.Descriptor instead.

func (*SubmissionCompleted_CLSubmissionFailures) GetFailures

func (*SubmissionCompleted_CLSubmissionFailures) ProtoMessage

func (*SubmissionCompleted_CLSubmissionFailures) ProtoReflect

func (*SubmissionCompleted_CLSubmissionFailures) Reset

func (*SubmissionCompleted_CLSubmissionFailures) String

func (*SubmissionCompleted_CLSubmissionFailures) Validate

Validate checks the field values on SubmissionCompleted_CLSubmissionFailures with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*SubmissionCompleted_CLSubmissionFailures) ValidateAll

ValidateAll checks the field values on SubmissionCompleted_CLSubmissionFailures with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in SubmissionCompleted_CLSubmissionFailuresMultiError, or nil if none found.

type SubmissionCompleted_CLSubmissionFailuresMultiError

type SubmissionCompleted_CLSubmissionFailuresMultiError []error

SubmissionCompleted_CLSubmissionFailuresMultiError is an error wrapping multiple validation errors returned by SubmissionCompleted_CLSubmissionFailures.ValidateAll() if the designated constraints aren't met.

func (SubmissionCompleted_CLSubmissionFailuresMultiError) AllErrors

AllErrors returns a list of validation violation errors.

func (SubmissionCompleted_CLSubmissionFailuresMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type SubmissionCompleted_CLSubmissionFailuresValidationError

type SubmissionCompleted_CLSubmissionFailuresValidationError struct {
	// contains filtered or unexported fields
}

SubmissionCompleted_CLSubmissionFailuresValidationError is the validation error returned by SubmissionCompleted_CLSubmissionFailures.Validate if the designated constraints aren't met.

func (SubmissionCompleted_CLSubmissionFailuresValidationError) Cause

Cause function returns cause value.

func (SubmissionCompleted_CLSubmissionFailuresValidationError) Error

Error satisfies the builtin error interface

func (SubmissionCompleted_CLSubmissionFailuresValidationError) ErrorName

ErrorName returns error name.

func (SubmissionCompleted_CLSubmissionFailuresValidationError) Field

Field function returns field value.

func (SubmissionCompleted_CLSubmissionFailuresValidationError) Key

Key function returns key value.

func (SubmissionCompleted_CLSubmissionFailuresValidationError) Reason

Reason function returns reason value.

type SubmissionCompleted_ClFailures

type SubmissionCompleted_ClFailures struct {
	// CLs that fail to submit. Could be transient or permanent.
	//
	// As of June 2021, CLs are submitted serially and submitter returns
	// immediately upon failure so `cl_failures` will have only one entry.
	// However, submitter may report multiple CL submission failures in the
	// future (e.g. CV supports parallel CL submission or CV submits a CL
	// stack in one RPC).
	ClFailures *SubmissionCompleted_CLSubmissionFailures `protobuf:"bytes,4,opt,name=cl_failures,json=clFailures,proto3,oneof"`
}

type SubmissionCompleted_Timeout

type SubmissionCompleted_Timeout struct {
	// Submission deadline is exceeded. Must be permanent failure.
	Timeout bool `protobuf:"varint,3,opt,name=timeout,proto3,oneof"`
}

type SubmissionResult

type SubmissionResult int32
const (
	SubmissionResult_SUBMISSION_RESULT_UNSPECIFIED SubmissionResult = 0
	// All CLs have been submitted successfully.
	SubmissionResult_SUCCEEDED SubmissionResult = 1
	// Encountered transient failure.
	//
	// RM should retry if the deadline hasn't been exceeded.
	SubmissionResult_FAILED_TRANSIENT SubmissionResult = 2
	// Encountered permanent failure.
	//
	// For example, lack of submit permission or experienced merge conflict.
	SubmissionResult_FAILED_PERMANENT SubmissionResult = 3
)

func (SubmissionResult) Descriptor

func (SubmissionResult) Enum

func (SubmissionResult) EnumDescriptor deprecated

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

Deprecated: Use SubmissionResult.Descriptor instead.

func (SubmissionResult) Number

func (SubmissionResult) String

func (x SubmissionResult) String() string

func (SubmissionResult) Type

type TasksBinding

type TasksBinding struct {
	ManageRun       tq.TaskClassRef
	KickManage      tq.TaskClassRef
	ManageRunLongOp tq.TaskClassRef
	TQDispatcher    *tq.Dispatcher
}

TasksBinding binds Run Manager tasks to a TQ Dispatcher.

This struct exists to separate task creation and handling, which in turns avoids circular dependency.

func Register

func Register(tqd *tq.Dispatcher) TasksBinding

Register registers tasks with the given TQ Dispatcher.

func (TasksBinding) Dispatch

func (tr TasksBinding) Dispatch(ctx context.Context, runID string, eta time.Time) error

Dispatch ensures invocation of RunManager via ManageRunTask.

RunManager will be invoked at approximately no earlier than both:

  • eta time (if given)
  • next possible.

To avoid actually dispatching TQ tasks in tests, use runtest.MockDispatch().

Jump to

Keyboard shortcuts

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