run

package
v0.0.0-...-a8f2654 Latest Latest
Warning

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

Go to latest
Published: Dec 3, 2024 License: Apache-2.0 Imports: 40 Imported by: 0

Documentation

Overview

Package run implements public interface for Run Manager.

Index

Constants

View Source
const (
	// RunCLKind is the Datastore entity kind for RunCL.
	RunCLKind = "RunCL"
	// RunLogKind is the Datastore entity kind for RunLog.
	RunLogKind = "RunLog"

	// MaxTryjobs limits maximum number of tryjobs that a single Run can track.
	//
	// Because all Run's tryjobs' results are kept in a Run.Tryjobs,
	// a single Datastore entity size limit of 1 MiB applies.
	//
	// 1024 is chosen because:
	//   * it is a magnitude above what was observed in practice before;
	//   * although stored tryjob results are user-influenced,
	//     they should be highly compressible, so even at 1KiB each,
	//     1024 tryjob results should amount to much less than 1 MiB.
	MaxTryjobs = 1024
)

Variables

View Source
var (
	Status_name = map[int32]string{
		0:  "STATUS_UNSPECIFIED",
		1:  "PENDING",
		2:  "RUNNING",
		4:  "WAITING_FOR_SUBMISSION",
		5:  "SUBMITTING",
		64: "ENDED_MASK",
		65: "SUCCEEDED",
		66: "FAILED",
		67: "CANCELLED",
	}
	Status_value = map[string]int32{
		"STATUS_UNSPECIFIED":     0,
		"PENDING":                1,
		"RUNNING":                2,
		"WAITING_FOR_SUBMISSION": 4,
		"SUBMITTING":             5,
		"ENDED_MASK":             64,
		"SUCCEEDED":              65,
		"FAILED":                 66,
		"CANCELLED":              67,
	}
)

Enum value maps for Status.

View Source
var File_go_chromium_org_luci_cv_internal_run_storage_proto protoreflect.FileDescriptor

Functions

func ComputeCLGroupKey

func ComputeCLGroupKey(cls []*RunCL, isEquivalent bool) string

ComputeCLGroupKey constructs keys for ClGroupKey and the related EquivalentClGroupKey.

These are meant to be opaque keys unique to particular set of CLs and patchsets for the purpose of grouping together Runs for the same sets of patchsets. if isEquivalent is true, then the "min equivalent patchset" is used instead of the latest patchset, so that trivial patchsets such as minor rebases and CL description updates don't change the key.

func DefaultAllowedModes

func DefaultAllowedModes() []string

DefaultAllowedModes is the list of RunModes implied by an empty ModeAllowList in tryjob verifier configuration.

func EventboxRecipient

func EventboxRecipient(ctx context.Context, runID common.RunID) eventbox.Recipient

EventboxRecipient returns eventbox.Recipient for a given Run.

func HasTriggerChanged

func HasTriggerChanged(old *Trigger, ts *Triggers, clURL string) string

HasTriggerChanged checks whether a trigger is no longer valid for a given CL.

A trigger is no longer valid if it is no longer found in the CL.

func IsEnded

func IsEnded(status Status) bool

IsEnded returns true if the given status is final.

func ShouldSubmit

func ShouldSubmit(r *Run) bool

ShouldSubmit returns true if the run should submit the CL(s) at the end.

Types

type LoadRunChecker

type LoadRunChecker interface {
	// Before is called by LoadRun before attempting to load Run from Datastore.
	//
	// If Before returns an error, it's returned as is to the caller of LoadRun.
	Before(ctx context.Context, id common.RunID) error
	// After is called by LoadRun after loading Run from Datastore.
	//
	// If Run wasn't found, nil is passed.
	//
	// If After returns an error, it's returned as is to the caller of LoadRun.
	After(ctx context.Context, runIfFound *Run) error
}

LoadRunChecker allows to plug ACL checking when loading Run from Datastore.

See LoadRun().

type LoadRunsBuilder

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

LoadRunsBuilder implements builder pattern for loading Runs.

func LoadRunsFromIDs

func LoadRunsFromIDs(ids ...common.RunID) LoadRunsBuilder

LoadRunsFromIDs prepares loading a Run for each given Run ID.

func LoadRunsFromKeys

func LoadRunsFromKeys(keys ...*datastore.Key) LoadRunsBuilder

LoadRunsFromKeys prepares loading a Run for each given Datastore Key.

func (LoadRunsBuilder) Checker

Checker installs LoadRunChecker to perform checks before/after loading each Run, typically used for checking read permission.

func (LoadRunsBuilder) Do

Do loads Runs returning an error per each Run.

If Run doesn't exist, the corresponding error is datastore.ErrNoSuchEntity or whatever Checker.After() returned if Checker is given.

This is useful if you need to collate each loaded Run and its error with another original slice from which Run's keys or IDs were derived, e.g. an API request.

ids := make(common.RunIDs, len(batchReq))
for i, req := range batchReq {
  ids[i] = common.RunID(req.GetRunID())
}
runs, errs := run.LoadRunsFromIDs(ids...).Checker(acls.NewRunReadChecker()).Do(ctx)
respBatch := ...
for i := range ids {
  switch id, r, err := ids[i], runs[i], errs[i];{
  case err != nil:
    respBatch[i] = &respOne{Error: ...}
  default:
    respBatch[i] = &respOne{Run: ...}
  }
}

func (LoadRunsBuilder) DoIgnoreNotFound

func (b LoadRunsBuilder) DoIgnoreNotFound(ctx context.Context) ([]*Run, error)

DoIgnoreNotFound loads and returns Runs in the same order as the input, but omitting not found ones.

If used together with Checker:

  • if Checker.Before returns error with NotFound code, treats such Run as not found.
  • if Run is not found in Datastore, Checker.After isn't called on it.
  • if Checker.After returns error with NotFound code, treats such Run as not found.

Returns a singular first encountered error.

type LogEntries

type LogEntries struct {
	Entries []*LogEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

LogEntries contains 1+ LogEntry ordered from logically oldest to newest.

func (*LogEntries) Descriptor deprecated

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

Deprecated: Use LogEntries.ProtoReflect.Descriptor instead.

func (*LogEntries) GetEntries

func (x *LogEntries) GetEntries() []*LogEntry

func (*LogEntries) ProtoMessage

func (*LogEntries) ProtoMessage()

func (*LogEntries) ProtoReflect

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

func (*LogEntries) Reset

func (x *LogEntries) Reset()

func (*LogEntries) String

func (x *LogEntries) String() string

func (*LogEntries) Validate

func (m *LogEntries) Validate() error

Validate checks the field values on LogEntries 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 (*LogEntries) ValidateAll

func (m *LogEntries) ValidateAll() error

ValidateAll checks the field values on LogEntries 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 LogEntriesMultiError, or nil if none found.

type LogEntriesMultiError

type LogEntriesMultiError []error

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

func (LogEntriesMultiError) AllErrors

func (m LogEntriesMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LogEntriesMultiError) Error

func (m LogEntriesMultiError) Error() string

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

type LogEntriesValidationError

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

LogEntriesValidationError is the validation error returned by LogEntries.Validate if the designated constraints aren't met.

func (LogEntriesValidationError) Cause

func (e LogEntriesValidationError) Cause() error

Cause function returns cause value.

func (LogEntriesValidationError) Error

Error satisfies the builtin error interface

func (LogEntriesValidationError) ErrorName

func (e LogEntriesValidationError) ErrorName() string

ErrorName returns error name.

func (LogEntriesValidationError) Field

Field function returns field value.

func (LogEntriesValidationError) Key

Key function returns key value.

func (LogEntriesValidationError) Reason

func (e LogEntriesValidationError) Reason() string

Reason function returns reason value.

type LogEntry

type LogEntry struct {

	// Time is when something was changed.
	Time *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"`
	// Types that are assignable to Kind:
	//
	//	*LogEntry_Created_
	//	*LogEntry_Started_
	//	*LogEntry_ConfigChanged_
	//	*LogEntry_TryjobsRequirementUpdated_
	//	*LogEntry_TryjobsUpdated_
	//	*LogEntry_Info_
	//	*LogEntry_TreeChecked_
	//	*LogEntry_Waitlisted_
	//	*LogEntry_AcquiredSubmitQueue_
	//	*LogEntry_ReleasedSubmitQueue_
	//	*LogEntry_ClSubmitted
	//	*LogEntry_SubmissionFailure_
	//	*LogEntry_RunEnded_
	Kind isLogEntry_Kind `protobuf_oneof:"kind"`
	// contains filtered or unexported fields
}

LogEntry records what changed in a Run.

func LoadRunLogEntries

func LoadRunLogEntries(ctx context.Context, runID common.RunID) ([]*LogEntry, error)

LoadRunLogEntries loads all log entries of a given Run.

Ordered from logically oldest to newest.

func (*LogEntry) Descriptor deprecated

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

Deprecated: Use LogEntry.ProtoReflect.Descriptor instead.

func (*LogEntry) GetAcquiredSubmitQueue

func (x *LogEntry) GetAcquiredSubmitQueue() *LogEntry_AcquiredSubmitQueue

func (*LogEntry) GetClSubmitted

func (x *LogEntry) GetClSubmitted() *LogEntry_CLSubmitted

func (*LogEntry) GetConfigChanged

func (x *LogEntry) GetConfigChanged() *LogEntry_ConfigChanged

func (*LogEntry) GetCreated

func (x *LogEntry) GetCreated() *LogEntry_Created

func (*LogEntry) GetInfo

func (x *LogEntry) GetInfo() *LogEntry_Info

func (*LogEntry) GetKind

func (m *LogEntry) GetKind() isLogEntry_Kind

func (*LogEntry) GetReleasedSubmitQueue

func (x *LogEntry) GetReleasedSubmitQueue() *LogEntry_ReleasedSubmitQueue

func (*LogEntry) GetRunEnded

func (x *LogEntry) GetRunEnded() *LogEntry_RunEnded

func (*LogEntry) GetStarted

func (x *LogEntry) GetStarted() *LogEntry_Started

func (*LogEntry) GetSubmissionFailure

func (x *LogEntry) GetSubmissionFailure() *LogEntry_SubmissionFailure

func (*LogEntry) GetTime

func (x *LogEntry) GetTime() *timestamppb.Timestamp

func (*LogEntry) GetTreeChecked

func (x *LogEntry) GetTreeChecked() *LogEntry_TreeChecked

func (*LogEntry) GetTryjobsRequirementUpdated

func (x *LogEntry) GetTryjobsRequirementUpdated() *LogEntry_TryjobsRequirementUpdated

func (*LogEntry) GetTryjobsUpdated

func (x *LogEntry) GetTryjobsUpdated() *LogEntry_TryjobsUpdated

func (*LogEntry) GetWaitlisted

func (x *LogEntry) GetWaitlisted() *LogEntry_Waitlisted

func (*LogEntry) ProtoMessage

func (*LogEntry) ProtoMessage()

func (*LogEntry) ProtoReflect

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

func (*LogEntry) Reset

func (x *LogEntry) Reset()

func (*LogEntry) String

func (x *LogEntry) String() string

func (*LogEntry) Validate

func (m *LogEntry) Validate() error

Validate checks the field values on LogEntry 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 (*LogEntry) ValidateAll

func (m *LogEntry) ValidateAll() error

ValidateAll checks the field values on LogEntry 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 LogEntryMultiError, or nil if none found.

type LogEntryMultiError

type LogEntryMultiError []error

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

func (LogEntryMultiError) AllErrors

func (m LogEntryMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LogEntryMultiError) Error

func (m LogEntryMultiError) Error() string

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

type LogEntryValidationError

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

LogEntryValidationError is the validation error returned by LogEntry.Validate if the designated constraints aren't met.

func (LogEntryValidationError) Cause

func (e LogEntryValidationError) Cause() error

Cause function returns cause value.

func (LogEntryValidationError) Error

func (e LogEntryValidationError) Error() string

Error satisfies the builtin error interface

func (LogEntryValidationError) ErrorName

func (e LogEntryValidationError) ErrorName() string

ErrorName returns error name.

func (LogEntryValidationError) Field

func (e LogEntryValidationError) Field() string

Field function returns field value.

func (LogEntryValidationError) Key

func (e LogEntryValidationError) Key() bool

Key function returns key value.

func (LogEntryValidationError) Reason

func (e LogEntryValidationError) Reason() string

Reason function returns reason value.

type LogEntry_AcquiredSubmitQueue

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

func (*LogEntry_AcquiredSubmitQueue) Descriptor deprecated

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

Deprecated: Use LogEntry_AcquiredSubmitQueue.ProtoReflect.Descriptor instead.

func (*LogEntry_AcquiredSubmitQueue) ProtoMessage

func (*LogEntry_AcquiredSubmitQueue) ProtoMessage()

func (*LogEntry_AcquiredSubmitQueue) ProtoReflect

func (*LogEntry_AcquiredSubmitQueue) Reset

func (x *LogEntry_AcquiredSubmitQueue) Reset()

func (*LogEntry_AcquiredSubmitQueue) String

func (*LogEntry_AcquiredSubmitQueue) Validate

func (m *LogEntry_AcquiredSubmitQueue) Validate() error

Validate checks the field values on LogEntry_AcquiredSubmitQueue 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 (*LogEntry_AcquiredSubmitQueue) ValidateAll

func (m *LogEntry_AcquiredSubmitQueue) ValidateAll() error

ValidateAll checks the field values on LogEntry_AcquiredSubmitQueue 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 LogEntry_AcquiredSubmitQueueMultiError, or nil if none found.

type LogEntry_AcquiredSubmitQueueMultiError

type LogEntry_AcquiredSubmitQueueMultiError []error

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

func (LogEntry_AcquiredSubmitQueueMultiError) AllErrors

AllErrors returns a list of validation violation errors.

func (LogEntry_AcquiredSubmitQueueMultiError) Error

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

type LogEntry_AcquiredSubmitQueueValidationError

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

LogEntry_AcquiredSubmitQueueValidationError is the validation error returned by LogEntry_AcquiredSubmitQueue.Validate if the designated constraints aren't met.

func (LogEntry_AcquiredSubmitQueueValidationError) Cause

Cause function returns cause value.

func (LogEntry_AcquiredSubmitQueueValidationError) Error

Error satisfies the builtin error interface

func (LogEntry_AcquiredSubmitQueueValidationError) ErrorName

ErrorName returns error name.

func (LogEntry_AcquiredSubmitQueueValidationError) Field

Field function returns field value.

func (LogEntry_AcquiredSubmitQueueValidationError) Key

Key function returns key value.

func (LogEntry_AcquiredSubmitQueueValidationError) Reason

Reason function returns reason value.

type LogEntry_AcquiredSubmitQueue_

type LogEntry_AcquiredSubmitQueue_ struct {
	// The run is current on the queue.
	AcquiredSubmitQueue *LogEntry_AcquiredSubmitQueue `protobuf:"bytes,10,opt,name=acquired_submit_queue,json=acquiredSubmitQueue,proto3,oneof"`
}

type LogEntry_CLSubmitted

type LogEntry_CLSubmitted struct {

	// The CLs that were submitted in this event.
	NewlySubmittedCls []int64 `protobuf:"varint,1,rep,packed,name=newly_submitted_cls,json=newlySubmittedCls,proto3" json:"newly_submitted_cls,omitempty"`
	// The number of CLs submitted for this run, so far.
	TotalSubmitted int64 `protobuf:"varint,2,opt,name=total_submitted,json=totalSubmitted,proto3" json:"total_submitted,omitempty"`
	// contains filtered or unexported fields
}

func (*LogEntry_CLSubmitted) Descriptor deprecated

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

Deprecated: Use LogEntry_CLSubmitted.ProtoReflect.Descriptor instead.

func (*LogEntry_CLSubmitted) GetNewlySubmittedCls

func (x *LogEntry_CLSubmitted) GetNewlySubmittedCls() []int64

func (*LogEntry_CLSubmitted) GetTotalSubmitted

func (x *LogEntry_CLSubmitted) GetTotalSubmitted() int64

func (*LogEntry_CLSubmitted) ProtoMessage

func (*LogEntry_CLSubmitted) ProtoMessage()

func (*LogEntry_CLSubmitted) ProtoReflect

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

func (*LogEntry_CLSubmitted) Reset

func (x *LogEntry_CLSubmitted) Reset()

func (*LogEntry_CLSubmitted) String

func (x *LogEntry_CLSubmitted) String() string

func (*LogEntry_CLSubmitted) Validate

func (m *LogEntry_CLSubmitted) Validate() error

Validate checks the field values on LogEntry_CLSubmitted 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 (*LogEntry_CLSubmitted) ValidateAll

func (m *LogEntry_CLSubmitted) ValidateAll() error

ValidateAll checks the field values on LogEntry_CLSubmitted 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 LogEntry_CLSubmittedMultiError, or nil if none found.

type LogEntry_CLSubmittedMultiError

type LogEntry_CLSubmittedMultiError []error

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

func (LogEntry_CLSubmittedMultiError) AllErrors

func (m LogEntry_CLSubmittedMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LogEntry_CLSubmittedMultiError) Error

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

type LogEntry_CLSubmittedValidationError

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

LogEntry_CLSubmittedValidationError is the validation error returned by LogEntry_CLSubmitted.Validate if the designated constraints aren't met.

func (LogEntry_CLSubmittedValidationError) Cause

Cause function returns cause value.

func (LogEntry_CLSubmittedValidationError) Error

Error satisfies the builtin error interface

func (LogEntry_CLSubmittedValidationError) ErrorName

ErrorName returns error name.

func (LogEntry_CLSubmittedValidationError) Field

Field function returns field value.

func (LogEntry_CLSubmittedValidationError) Key

Key function returns key value.

func (LogEntry_CLSubmittedValidationError) Reason

Reason function returns reason value.

type LogEntry_ClSubmitted

type LogEntry_ClSubmitted struct {
	// CL(s) submitted successfully.
	ClSubmitted *LogEntry_CLSubmitted `protobuf:"bytes,12,opt,name=cl_submitted,json=clSubmitted,proto3,oneof"`
}

type LogEntry_ConfigChanged

type LogEntry_ConfigChanged struct {
	ConfigGroupId string `protobuf:"bytes,1,opt,name=config_group_id,json=configGroupId,proto3" json:"config_group_id,omitempty"`
	// contains filtered or unexported fields
}

func (*LogEntry_ConfigChanged) Descriptor deprecated

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

Deprecated: Use LogEntry_ConfigChanged.ProtoReflect.Descriptor instead.

func (*LogEntry_ConfigChanged) GetConfigGroupId

func (x *LogEntry_ConfigChanged) GetConfigGroupId() string

func (*LogEntry_ConfigChanged) ProtoMessage

func (*LogEntry_ConfigChanged) ProtoMessage()

func (*LogEntry_ConfigChanged) ProtoReflect

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

func (*LogEntry_ConfigChanged) Reset

func (x *LogEntry_ConfigChanged) Reset()

func (*LogEntry_ConfigChanged) String

func (x *LogEntry_ConfigChanged) String() string

func (*LogEntry_ConfigChanged) Validate

func (m *LogEntry_ConfigChanged) Validate() error

Validate checks the field values on LogEntry_ConfigChanged 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 (*LogEntry_ConfigChanged) ValidateAll

func (m *LogEntry_ConfigChanged) ValidateAll() error

ValidateAll checks the field values on LogEntry_ConfigChanged 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 LogEntry_ConfigChangedMultiError, or nil if none found.

type LogEntry_ConfigChangedMultiError

type LogEntry_ConfigChangedMultiError []error

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

func (LogEntry_ConfigChangedMultiError) AllErrors

func (m LogEntry_ConfigChangedMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LogEntry_ConfigChangedMultiError) Error

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

type LogEntry_ConfigChangedValidationError

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

LogEntry_ConfigChangedValidationError is the validation error returned by LogEntry_ConfigChanged.Validate if the designated constraints aren't met.

func (LogEntry_ConfigChangedValidationError) Cause

Cause function returns cause value.

func (LogEntry_ConfigChangedValidationError) Error

Error satisfies the builtin error interface

func (LogEntry_ConfigChangedValidationError) ErrorName

ErrorName returns error name.

func (LogEntry_ConfigChangedValidationError) Field

Field function returns field value.

func (LogEntry_ConfigChangedValidationError) Key

Key function returns key value.

func (LogEntry_ConfigChangedValidationError) Reason

Reason function returns reason value.

type LogEntry_ConfigChanged_

type LogEntry_ConfigChanged_ struct {
	// Run updated to a new project config version.
	ConfigChanged *LogEntry_ConfigChanged `protobuf:"bytes,3,opt,name=config_changed,json=configChanged,proto3,oneof"`
}

type LogEntry_Created

type LogEntry_Created struct {
	ConfigGroupId string `protobuf:"bytes,1,opt,name=config_group_id,json=configGroupId,proto3" json:"config_group_id,omitempty"`
	// contains filtered or unexported fields
}

func (*LogEntry_Created) Descriptor deprecated

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

Deprecated: Use LogEntry_Created.ProtoReflect.Descriptor instead.

func (*LogEntry_Created) GetConfigGroupId

func (x *LogEntry_Created) GetConfigGroupId() string

func (*LogEntry_Created) ProtoMessage

func (*LogEntry_Created) ProtoMessage()

func (*LogEntry_Created) ProtoReflect

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

func (*LogEntry_Created) Reset

func (x *LogEntry_Created) Reset()

func (*LogEntry_Created) String

func (x *LogEntry_Created) String() string

func (*LogEntry_Created) Validate

func (m *LogEntry_Created) Validate() error

Validate checks the field values on LogEntry_Created 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 (*LogEntry_Created) ValidateAll

func (m *LogEntry_Created) ValidateAll() error

ValidateAll checks the field values on LogEntry_Created 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 LogEntry_CreatedMultiError, or nil if none found.

type LogEntry_CreatedMultiError

type LogEntry_CreatedMultiError []error

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

func (LogEntry_CreatedMultiError) AllErrors

func (m LogEntry_CreatedMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LogEntry_CreatedMultiError) Error

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

type LogEntry_CreatedValidationError

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

LogEntry_CreatedValidationError is the validation error returned by LogEntry_Created.Validate if the designated constraints aren't met.

func (LogEntry_CreatedValidationError) Cause

Cause function returns cause value.

func (LogEntry_CreatedValidationError) Error

Error satisfies the builtin error interface

func (LogEntry_CreatedValidationError) ErrorName

ErrorName returns error name.

func (LogEntry_CreatedValidationError) Field

Field function returns field value.

func (LogEntry_CreatedValidationError) Key

Key function returns key value.

func (LogEntry_CreatedValidationError) Reason

Reason function returns reason value.

type LogEntry_Created_

type LogEntry_Created_ struct {
	// Run was created.
	Created *LogEntry_Created `protobuf:"bytes,2,opt,name=created,proto3,oneof"`
}

type LogEntry_Info

type LogEntry_Info struct {

	// If you have the need to add fields here, consider instead adding a new
	// dedicated kind
	Label   string `protobuf:"bytes,1,opt,name=label,proto3" json:"label,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*LogEntry_Info) Descriptor deprecated

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

Deprecated: Use LogEntry_Info.ProtoReflect.Descriptor instead.

func (*LogEntry_Info) GetLabel

func (x *LogEntry_Info) GetLabel() string

func (*LogEntry_Info) GetMessage

func (x *LogEntry_Info) GetMessage() string

func (*LogEntry_Info) ProtoMessage

func (*LogEntry_Info) ProtoMessage()

func (*LogEntry_Info) ProtoReflect

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

func (*LogEntry_Info) Reset

func (x *LogEntry_Info) Reset()

func (*LogEntry_Info) String

func (x *LogEntry_Info) String() string

func (*LogEntry_Info) Validate

func (m *LogEntry_Info) Validate() error

Validate checks the field values on LogEntry_Info 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 (*LogEntry_Info) ValidateAll

func (m *LogEntry_Info) ValidateAll() error

ValidateAll checks the field values on LogEntry_Info 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 LogEntry_InfoMultiError, or nil if none found.

type LogEntry_InfoMultiError

type LogEntry_InfoMultiError []error

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

func (LogEntry_InfoMultiError) AllErrors

func (m LogEntry_InfoMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LogEntry_InfoMultiError) Error

func (m LogEntry_InfoMultiError) Error() string

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

type LogEntry_InfoValidationError

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

LogEntry_InfoValidationError is the validation error returned by LogEntry_Info.Validate if the designated constraints aren't met.

func (LogEntry_InfoValidationError) Cause

Cause function returns cause value.

func (LogEntry_InfoValidationError) Error

Error satisfies the builtin error interface

func (LogEntry_InfoValidationError) ErrorName

func (e LogEntry_InfoValidationError) ErrorName() string

ErrorName returns error name.

func (LogEntry_InfoValidationError) Field

Field function returns field value.

func (LogEntry_InfoValidationError) Key

Key function returns key value.

func (LogEntry_InfoValidationError) Reason

Reason function returns reason value.

type LogEntry_Info_

type LogEntry_Info_ struct {
	// Intended for informational logs (E.g. temporary/during migration)
	Info *LogEntry_Info `protobuf:"bytes,7,opt,name=info,proto3,oneof"`
}

type LogEntry_ReleasedSubmitQueue

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

func (*LogEntry_ReleasedSubmitQueue) Descriptor deprecated

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

Deprecated: Use LogEntry_ReleasedSubmitQueue.ProtoReflect.Descriptor instead.

func (*LogEntry_ReleasedSubmitQueue) ProtoMessage

func (*LogEntry_ReleasedSubmitQueue) ProtoMessage()

func (*LogEntry_ReleasedSubmitQueue) ProtoReflect

func (*LogEntry_ReleasedSubmitQueue) Reset

func (x *LogEntry_ReleasedSubmitQueue) Reset()

func (*LogEntry_ReleasedSubmitQueue) String

func (*LogEntry_ReleasedSubmitQueue) Validate

func (m *LogEntry_ReleasedSubmitQueue) Validate() error

Validate checks the field values on LogEntry_ReleasedSubmitQueue 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 (*LogEntry_ReleasedSubmitQueue) ValidateAll

func (m *LogEntry_ReleasedSubmitQueue) ValidateAll() error

ValidateAll checks the field values on LogEntry_ReleasedSubmitQueue 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 LogEntry_ReleasedSubmitQueueMultiError, or nil if none found.

type LogEntry_ReleasedSubmitQueueMultiError

type LogEntry_ReleasedSubmitQueueMultiError []error

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

func (LogEntry_ReleasedSubmitQueueMultiError) AllErrors

AllErrors returns a list of validation violation errors.

func (LogEntry_ReleasedSubmitQueueMultiError) Error

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

type LogEntry_ReleasedSubmitQueueValidationError

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

LogEntry_ReleasedSubmitQueueValidationError is the validation error returned by LogEntry_ReleasedSubmitQueue.Validate if the designated constraints aren't met.

func (LogEntry_ReleasedSubmitQueueValidationError) Cause

Cause function returns cause value.

func (LogEntry_ReleasedSubmitQueueValidationError) Error

Error satisfies the builtin error interface

func (LogEntry_ReleasedSubmitQueueValidationError) ErrorName

ErrorName returns error name.

func (LogEntry_ReleasedSubmitQueueValidationError) Field

Field function returns field value.

func (LogEntry_ReleasedSubmitQueueValidationError) Key

Key function returns key value.

func (LogEntry_ReleasedSubmitQueueValidationError) Reason

Reason function returns reason value.

type LogEntry_ReleasedSubmitQueue_

type LogEntry_ReleasedSubmitQueue_ struct {
	ReleasedSubmitQueue *LogEntry_ReleasedSubmitQueue `protobuf:"bytes,11,opt,name=released_submit_queue,json=releasedSubmitQueue,proto3,oneof"`
}

type LogEntry_RunEnded

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

func (*LogEntry_RunEnded) Descriptor deprecated

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

Deprecated: Use LogEntry_RunEnded.ProtoReflect.Descriptor instead.

func (*LogEntry_RunEnded) ProtoMessage

func (*LogEntry_RunEnded) ProtoMessage()

func (*LogEntry_RunEnded) ProtoReflect

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

func (*LogEntry_RunEnded) Reset

func (x *LogEntry_RunEnded) Reset()

func (*LogEntry_RunEnded) String

func (x *LogEntry_RunEnded) String() string

func (*LogEntry_RunEnded) Validate

func (m *LogEntry_RunEnded) Validate() error

Validate checks the field values on LogEntry_RunEnded 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 (*LogEntry_RunEnded) ValidateAll

func (m *LogEntry_RunEnded) ValidateAll() error

ValidateAll checks the field values on LogEntry_RunEnded 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 LogEntry_RunEndedMultiError, or nil if none found.

type LogEntry_RunEndedMultiError

type LogEntry_RunEndedMultiError []error

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

func (LogEntry_RunEndedMultiError) AllErrors

func (m LogEntry_RunEndedMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LogEntry_RunEndedMultiError) Error

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

type LogEntry_RunEndedValidationError

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

LogEntry_RunEndedValidationError is the validation error returned by LogEntry_RunEnded.Validate if the designated constraints aren't met.

func (LogEntry_RunEndedValidationError) Cause

Cause function returns cause value.

func (LogEntry_RunEndedValidationError) Error

Error satisfies the builtin error interface

func (LogEntry_RunEndedValidationError) ErrorName

ErrorName returns error name.

func (LogEntry_RunEndedValidationError) Field

Field function returns field value.

func (LogEntry_RunEndedValidationError) Key

Key function returns key value.

func (LogEntry_RunEndedValidationError) Reason

Reason function returns reason value.

type LogEntry_RunEnded_

type LogEntry_RunEnded_ struct {
	RunEnded *LogEntry_RunEnded `protobuf:"bytes,14,opt,name=run_ended,json=runEnded,proto3,oneof"`
}

type LogEntry_Started

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

func (*LogEntry_Started) Descriptor deprecated

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

Deprecated: Use LogEntry_Started.ProtoReflect.Descriptor instead.

func (*LogEntry_Started) ProtoMessage

func (*LogEntry_Started) ProtoMessage()

func (*LogEntry_Started) ProtoReflect

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

func (*LogEntry_Started) Reset

func (x *LogEntry_Started) Reset()

func (*LogEntry_Started) String

func (x *LogEntry_Started) String() string

func (*LogEntry_Started) Validate

func (m *LogEntry_Started) Validate() error

Validate checks the field values on LogEntry_Started 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 (*LogEntry_Started) ValidateAll

func (m *LogEntry_Started) ValidateAll() error

ValidateAll checks the field values on LogEntry_Started 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 LogEntry_StartedMultiError, or nil if none found.

type LogEntry_StartedMultiError

type LogEntry_StartedMultiError []error

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

func (LogEntry_StartedMultiError) AllErrors

func (m LogEntry_StartedMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LogEntry_StartedMultiError) Error

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

type LogEntry_StartedValidationError

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

LogEntry_StartedValidationError is the validation error returned by LogEntry_Started.Validate if the designated constraints aren't met.

func (LogEntry_StartedValidationError) Cause

Cause function returns cause value.

func (LogEntry_StartedValidationError) Error

Error satisfies the builtin error interface

func (LogEntry_StartedValidationError) ErrorName

ErrorName returns error name.

func (LogEntry_StartedValidationError) Field

Field function returns field value.

func (LogEntry_StartedValidationError) Key

Key function returns key value.

func (LogEntry_StartedValidationError) Reason

Reason function returns reason value.

type LogEntry_Started_

type LogEntry_Started_ struct {
	// Run was started.
	Started *LogEntry_Started `protobuf:"bytes,6,opt,name=started,proto3,oneof"`
}

type LogEntry_SubmissionFailure

type LogEntry_SubmissionFailure struct {
	Event *eventpb.SubmissionCompleted `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

func (*LogEntry_SubmissionFailure) Descriptor deprecated

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

Deprecated: Use LogEntry_SubmissionFailure.ProtoReflect.Descriptor instead.

func (*LogEntry_SubmissionFailure) GetEvent

func (*LogEntry_SubmissionFailure) ProtoMessage

func (*LogEntry_SubmissionFailure) ProtoMessage()

func (*LogEntry_SubmissionFailure) ProtoReflect

func (*LogEntry_SubmissionFailure) Reset

func (x *LogEntry_SubmissionFailure) Reset()

func (*LogEntry_SubmissionFailure) String

func (x *LogEntry_SubmissionFailure) String() string

func (*LogEntry_SubmissionFailure) Validate

func (m *LogEntry_SubmissionFailure) Validate() error

Validate checks the field values on LogEntry_SubmissionFailure 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 (*LogEntry_SubmissionFailure) ValidateAll

func (m *LogEntry_SubmissionFailure) ValidateAll() error

ValidateAll checks the field values on LogEntry_SubmissionFailure 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 LogEntry_SubmissionFailureMultiError, or nil if none found.

type LogEntry_SubmissionFailureMultiError

type LogEntry_SubmissionFailureMultiError []error

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

func (LogEntry_SubmissionFailureMultiError) AllErrors

AllErrors returns a list of validation violation errors.

func (LogEntry_SubmissionFailureMultiError) Error

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

type LogEntry_SubmissionFailureValidationError

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

LogEntry_SubmissionFailureValidationError is the validation error returned by LogEntry_SubmissionFailure.Validate if the designated constraints aren't met.

func (LogEntry_SubmissionFailureValidationError) Cause

Cause function returns cause value.

func (LogEntry_SubmissionFailureValidationError) Error

Error satisfies the builtin error interface

func (LogEntry_SubmissionFailureValidationError) ErrorName

ErrorName returns error name.

func (LogEntry_SubmissionFailureValidationError) Field

Field function returns field value.

func (LogEntry_SubmissionFailureValidationError) Key

Key function returns key value.

func (LogEntry_SubmissionFailureValidationError) Reason

Reason function returns reason value.

type LogEntry_SubmissionFailure_

type LogEntry_SubmissionFailure_ struct {
	// Submission failed.
	SubmissionFailure *LogEntry_SubmissionFailure `protobuf:"bytes,13,opt,name=submission_failure,json=submissionFailure,proto3,oneof"`
}

type LogEntry_TreeChecked

type LogEntry_TreeChecked struct {
	Open bool `protobuf:"varint,1,opt,name=open,proto3" json:"open,omitempty"`
	// contains filtered or unexported fields
}

func (*LogEntry_TreeChecked) Descriptor deprecated

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

Deprecated: Use LogEntry_TreeChecked.ProtoReflect.Descriptor instead.

func (*LogEntry_TreeChecked) GetOpen

func (x *LogEntry_TreeChecked) GetOpen() bool

func (*LogEntry_TreeChecked) ProtoMessage

func (*LogEntry_TreeChecked) ProtoMessage()

func (*LogEntry_TreeChecked) ProtoReflect

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

func (*LogEntry_TreeChecked) Reset

func (x *LogEntry_TreeChecked) Reset()

func (*LogEntry_TreeChecked) String

func (x *LogEntry_TreeChecked) String() string

func (*LogEntry_TreeChecked) Validate

func (m *LogEntry_TreeChecked) Validate() error

Validate checks the field values on LogEntry_TreeChecked 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 (*LogEntry_TreeChecked) ValidateAll

func (m *LogEntry_TreeChecked) ValidateAll() error

ValidateAll checks the field values on LogEntry_TreeChecked 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 LogEntry_TreeCheckedMultiError, or nil if none found.

type LogEntry_TreeCheckedMultiError

type LogEntry_TreeCheckedMultiError []error

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

func (LogEntry_TreeCheckedMultiError) AllErrors

func (m LogEntry_TreeCheckedMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LogEntry_TreeCheckedMultiError) Error

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

type LogEntry_TreeCheckedValidationError

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

LogEntry_TreeCheckedValidationError is the validation error returned by LogEntry_TreeChecked.Validate if the designated constraints aren't met.

func (LogEntry_TreeCheckedValidationError) Cause

Cause function returns cause value.

func (LogEntry_TreeCheckedValidationError) Error

Error satisfies the builtin error interface

func (LogEntry_TreeCheckedValidationError) ErrorName

ErrorName returns error name.

func (LogEntry_TreeCheckedValidationError) Field

Field function returns field value.

func (LogEntry_TreeCheckedValidationError) Key

Key function returns key value.

func (LogEntry_TreeCheckedValidationError) Reason

Reason function returns reason value.

type LogEntry_TreeChecked_

type LogEntry_TreeChecked_ struct {
	// The tree is configured and was checked.
	TreeChecked *LogEntry_TreeChecked `protobuf:"bytes,8,opt,name=tree_checked,json=treeChecked,proto3,oneof"`
}

type LogEntry_TryjobsRequirementUpdated

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

func (*LogEntry_TryjobsRequirementUpdated) Descriptor deprecated

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

Deprecated: Use LogEntry_TryjobsRequirementUpdated.ProtoReflect.Descriptor instead.

func (*LogEntry_TryjobsRequirementUpdated) ProtoMessage

func (*LogEntry_TryjobsRequirementUpdated) ProtoMessage()

func (*LogEntry_TryjobsRequirementUpdated) ProtoReflect

func (*LogEntry_TryjobsRequirementUpdated) Reset

func (*LogEntry_TryjobsRequirementUpdated) String

func (*LogEntry_TryjobsRequirementUpdated) Validate

Validate checks the field values on LogEntry_TryjobsRequirementUpdated 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 (*LogEntry_TryjobsRequirementUpdated) ValidateAll

func (m *LogEntry_TryjobsRequirementUpdated) ValidateAll() error

ValidateAll checks the field values on LogEntry_TryjobsRequirementUpdated 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 LogEntry_TryjobsRequirementUpdatedMultiError, or nil if none found.

type LogEntry_TryjobsRequirementUpdatedMultiError

type LogEntry_TryjobsRequirementUpdatedMultiError []error

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

func (LogEntry_TryjobsRequirementUpdatedMultiError) AllErrors

AllErrors returns a list of validation violation errors.

func (LogEntry_TryjobsRequirementUpdatedMultiError) Error

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

type LogEntry_TryjobsRequirementUpdatedValidationError

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

LogEntry_TryjobsRequirementUpdatedValidationError is the validation error returned by LogEntry_TryjobsRequirementUpdated.Validate if the designated constraints aren't met.

func (LogEntry_TryjobsRequirementUpdatedValidationError) Cause

Cause function returns cause value.

func (LogEntry_TryjobsRequirementUpdatedValidationError) Error

Error satisfies the builtin error interface

func (LogEntry_TryjobsRequirementUpdatedValidationError) ErrorName

ErrorName returns error name.

func (LogEntry_TryjobsRequirementUpdatedValidationError) Field

Field function returns field value.

func (LogEntry_TryjobsRequirementUpdatedValidationError) Key

Key function returns key value.

func (LogEntry_TryjobsRequirementUpdatedValidationError) Reason

Reason function returns reason value.

type LogEntry_TryjobsRequirementUpdated_

type LogEntry_TryjobsRequirementUpdated_ struct {
	// Tryjobs requirement was (re-)computed.
	TryjobsRequirementUpdated *LogEntry_TryjobsRequirementUpdated `protobuf:"bytes,4,opt,name=tryjobs_requirement_updated,json=tryjobsRequirementUpdated,proto3,oneof"`
}

type LogEntry_TryjobsUpdated

type LogEntry_TryjobsUpdated struct {

	// Which tryjobs had a meaningful change (e.g. change of status).
	Tryjobs []*Tryjob `protobuf:"bytes,2,rep,name=tryjobs,proto3" json:"tryjobs,omitempty"`
	// contains filtered or unexported fields
}

func (*LogEntry_TryjobsUpdated) Descriptor deprecated

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

Deprecated: Use LogEntry_TryjobsUpdated.ProtoReflect.Descriptor instead.

func (*LogEntry_TryjobsUpdated) GetTryjobs

func (x *LogEntry_TryjobsUpdated) GetTryjobs() []*Tryjob

func (*LogEntry_TryjobsUpdated) ProtoMessage

func (*LogEntry_TryjobsUpdated) ProtoMessage()

func (*LogEntry_TryjobsUpdated) ProtoReflect

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

func (*LogEntry_TryjobsUpdated) Reset

func (x *LogEntry_TryjobsUpdated) Reset()

func (*LogEntry_TryjobsUpdated) String

func (x *LogEntry_TryjobsUpdated) String() string

func (*LogEntry_TryjobsUpdated) Validate

func (m *LogEntry_TryjobsUpdated) Validate() error

Validate checks the field values on LogEntry_TryjobsUpdated 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 (*LogEntry_TryjobsUpdated) ValidateAll

func (m *LogEntry_TryjobsUpdated) ValidateAll() error

ValidateAll checks the field values on LogEntry_TryjobsUpdated 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 LogEntry_TryjobsUpdatedMultiError, or nil if none found.

type LogEntry_TryjobsUpdatedMultiError

type LogEntry_TryjobsUpdatedMultiError []error

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

func (LogEntry_TryjobsUpdatedMultiError) AllErrors

func (m LogEntry_TryjobsUpdatedMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LogEntry_TryjobsUpdatedMultiError) Error

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

type LogEntry_TryjobsUpdatedValidationError

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

LogEntry_TryjobsUpdatedValidationError is the validation error returned by LogEntry_TryjobsUpdated.Validate if the designated constraints aren't met.

func (LogEntry_TryjobsUpdatedValidationError) Cause

Cause function returns cause value.

func (LogEntry_TryjobsUpdatedValidationError) Error

Error satisfies the builtin error interface

func (LogEntry_TryjobsUpdatedValidationError) ErrorName

ErrorName returns error name.

func (LogEntry_TryjobsUpdatedValidationError) Field

Field function returns field value.

func (LogEntry_TryjobsUpdatedValidationError) Key

Key function returns key value.

func (LogEntry_TryjobsUpdatedValidationError) Reason

Reason function returns reason value.

type LogEntry_TryjobsUpdated_

type LogEntry_TryjobsUpdated_ struct {
	// Applicable tryjobs were updated.
	TryjobsUpdated *LogEntry_TryjobsUpdated `protobuf:"bytes,5,opt,name=tryjobs_updated,json=tryjobsUpdated,proto3,oneof"`
}

type LogEntry_Waitlisted

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

func (*LogEntry_Waitlisted) Descriptor deprecated

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

Deprecated: Use LogEntry_Waitlisted.ProtoReflect.Descriptor instead.

func (*LogEntry_Waitlisted) ProtoMessage

func (*LogEntry_Waitlisted) ProtoMessage()

func (*LogEntry_Waitlisted) ProtoReflect

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

func (*LogEntry_Waitlisted) Reset

func (x *LogEntry_Waitlisted) Reset()

func (*LogEntry_Waitlisted) String

func (x *LogEntry_Waitlisted) String() string

func (*LogEntry_Waitlisted) Validate

func (m *LogEntry_Waitlisted) Validate() error

Validate checks the field values on LogEntry_Waitlisted 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 (*LogEntry_Waitlisted) ValidateAll

func (m *LogEntry_Waitlisted) ValidateAll() error

ValidateAll checks the field values on LogEntry_Waitlisted 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 LogEntry_WaitlistedMultiError, or nil if none found.

type LogEntry_WaitlistedMultiError

type LogEntry_WaitlistedMultiError []error

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

func (LogEntry_WaitlistedMultiError) AllErrors

func (m LogEntry_WaitlistedMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LogEntry_WaitlistedMultiError) Error

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

type LogEntry_WaitlistedValidationError

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

LogEntry_WaitlistedValidationError is the validation error returned by LogEntry_Waitlisted.Validate if the designated constraints aren't met.

func (LogEntry_WaitlistedValidationError) Cause

Cause function returns cause value.

func (LogEntry_WaitlistedValidationError) Error

Error satisfies the builtin error interface

func (LogEntry_WaitlistedValidationError) ErrorName

ErrorName returns error name.

func (LogEntry_WaitlistedValidationError) Field

Field function returns field value.

func (LogEntry_WaitlistedValidationError) Key

Key function returns key value.

func (LogEntry_WaitlistedValidationError) Reason

Reason function returns reason value.

type LogEntry_Waitlisted_

type LogEntry_Waitlisted_ struct {
	// The run has been added to the submit queue's waitlist.
	Waitlisted *LogEntry_Waitlisted `protobuf:"bytes,9,opt,name=waitlisted,proto3,oneof"`
}

type Mode

type Mode string

Mode dictates the behavior of this Run.

The end goal is to have arbitrary user-defined Mode names. For now, CQDaemon/LUCI CV operates with just 3 pre-defined modes, whose values are fixed based on legacy CQ BQ export.

const (
	// DryRun triggers configured Tryjobs, but doesn't submit.
	DryRun Mode = "DRY_RUN"
	// FullRun is DryRun followed by submit.
	FullRun Mode = "FULL_RUN"
	// NewPatchsetRun is triggered by uploading a new patchset.
	// It only runs tryjobs explicitly allowed in this mode.
	NewPatchsetRun Mode = "NEW_PATCHSET_RUN"
)

func ModeFromBQAttempt

func ModeFromBQAttempt(m bqpb.Mode) (Mode, error)

ModeFromBQAttempt returns Mode from CQ BQ export.

func (Mode) BQAttemptMode

func (m Mode) BQAttemptMode() bqpb.Mode

BQAttemptMode returns corresponding value for legacy CQ BQ export.

func (Mode) GerritMessageTag

func (m Mode) GerritMessageTag() string

GerritMessageTag returns corresponding value for the Gerrit message tag.

Tag value set by CQDaemon sadly became part of the API surface, see https://crbug.com/1263652. TODO(crbug.com/1264046): delete this API surface after users migrate away.

func (Mode) GerritNotifyTargets

func (m Mode) GerritNotifyTargets() gerrit.Whoms

GerritNotifyTargets gets the default set of user roles to notify depending on the given RunMode.

In general, for CQ runs (dry or else), it would notify the owner of the CL and those who triggered the run by voting on the cq label; and in the case of Runs triggered by uploading a new patchset, it would notify the owner of the CL and the uploader of the given patchset.

func (Mode) IsStandard

func (m Mode) IsStandard() bool

IsStandard reports whether mode is standard mode supported by LUCI CV.

type Notifier

type Notifier struct {
	// TasksBinding are used to register handlers of RM implementation to avoid
	// circular dependency.
	TasksBinding eventpb.TasksBinding
}

Notifier notifies Run Manager.

func NewNotifier

func NewNotifier(tqd *tq.Dispatcher) *Notifier

func (*Notifier) Cancel

func (n *Notifier) Cancel(ctx context.Context, runID common.RunID, reason string) error

Cancel tells RunManager to cancel the given Run.

func (*Notifier) Invoke

func (n *Notifier) Invoke(ctx context.Context, runID common.RunID, eta time.Time) error

Invoke invokes Run Manager to process events at the provided `eta`.

If the provided `eta` is zero, invokes immediately.

func (*Notifier) NotifyCLsSubmitted

func (n *Notifier) NotifyCLsSubmitted(ctx context.Context, runID common.RunID, clids common.CLIDs) error

NotifyCLsSubmitted informs RunManager that the provided CLs are submitted.

Unlike other event-sending funcs, this function only delivers the event to Run's eventbox, but does not dispatch the task. This is because it is okay to process all events of this kind together to record the submission result for each individual CLs after submission completes. Waking up RM unnecessarily may increase the contention of Run entity.

func (*Notifier) NotifyCLsUpdated

func (n *Notifier) NotifyCLsUpdated(ctx context.Context, runID common.RunID, cls *changelist.CLUpdatedEvents) error

NotifyCLsUpdated informs RunManager that given CLs have new versions available.

func (*Notifier) NotifyLongOpCompleted

func (n *Notifier) NotifyLongOpCompleted(ctx context.Context, runID common.RunID, res *eventpb.LongOpCompleted) error

NotifyLongOpCompleted tells RunManager that a long operation has completed.

func (*Notifier) NotifyParentRunCompleted

func (n *Notifier) NotifyParentRunCompleted(ctx context.Context, runID common.RunID) error

NotifyParentRunCompleted tells RunManager that a parent run has completed.

func (*Notifier) NotifyReadyForSubmission

func (n *Notifier) NotifyReadyForSubmission(ctx context.Context, runID common.RunID, eta time.Time) error

NotifyReadyForSubmission informs RunManager that the provided Run will be ready for submission at `eta`.

func (*Notifier) NotifySubmissionCompleted

func (n *Notifier) NotifySubmissionCompleted(ctx context.Context, runID common.RunID, sc *eventpb.SubmissionCompleted, invokeRM bool) error

NotifySubmissionCompleted informs RunManager that the submission of the provided Run has completed.

func (*Notifier) NotifyTryjobsUpdated

func (n *Notifier) NotifyTryjobsUpdated(ctx context.Context, runID common.RunID, tryjobs *tryjob.TryjobUpdatedEvents) error

NotifyTryjobsUpdated tells RunManager that tryjobs entities were updated.

func (*Notifier) PokeAfter

func (n *Notifier) PokeAfter(ctx context.Context, runID common.RunID, after time.Duration) error

PokeAfter tells RunManager to check its own state after the given duration.

Providing a non-positive duration is equivalent to `PokeNow(...)`.

func (*Notifier) PokeAt

func (n *Notifier) PokeAt(ctx context.Context, runID common.RunID, eta time.Time) error

PokeAt tells RunManager to check its own state at around `eta`.

Guarantees no earlier than `eta` but may not be exactly at `eta`. Providing an earlier timestamp than the current is equivalent to `PokeNow(...)`.

func (*Notifier) PokeNow

func (n *Notifier) PokeNow(ctx context.Context, runID common.RunID) error

PokeNow tells RunManager to check its own state immediately.

It's a shorthand of `PokeAfter(ctx, runID, after)` where `after` <= 0 or `PokeAt(ctx, runID, eta)` where `eta` is an earlier timestamp.

func (*Notifier) Send

func (n *Notifier) Send(ctx context.Context, runID common.RunID, evt *eventpb.Event, eta time.Time) error

Send sends the event to Run's eventbox and invokes RunManager at `eta`.

func (*Notifier) SendNow

func (n *Notifier) SendNow(ctx context.Context, runID common.RunID, evt *eventpb.Event) error

SendNow sends the event to Run's eventbox and invokes RunManager immediately.

func (*Notifier) Start

func (n *Notifier) Start(ctx context.Context, runID common.RunID) error

Start tells RunManager to start the given run.

func (*Notifier) UpdateConfig

func (n *Notifier) UpdateConfig(ctx context.Context, runID common.RunID, hash string, eversion int64) error

UpdateConfig tells RunManager to update the given Run to new config.

type OngoingLongOps

type OngoingLongOps struct {

	// Ops map operation ID to details.
	Ops map[string]*OngoingLongOps_Op `` /* 147-byte string literal not displayed */
	// contains filtered or unexported fields
}

OngoingLongOps tracks ongoing long operations.

func (*OngoingLongOps) Descriptor deprecated

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

Deprecated: Use OngoingLongOps.ProtoReflect.Descriptor instead.

func (*OngoingLongOps) GetOps

func (x *OngoingLongOps) GetOps() map[string]*OngoingLongOps_Op

func (*OngoingLongOps) ProtoMessage

func (*OngoingLongOps) ProtoMessage()

func (*OngoingLongOps) ProtoReflect

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

func (*OngoingLongOps) Reset

func (x *OngoingLongOps) Reset()

func (*OngoingLongOps) String

func (x *OngoingLongOps) String() string

func (*OngoingLongOps) Validate

func (m *OngoingLongOps) Validate() error

Validate checks the field values on OngoingLongOps 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 (*OngoingLongOps) ValidateAll

func (m *OngoingLongOps) ValidateAll() error

ValidateAll checks the field values on OngoingLongOps 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 OngoingLongOpsMultiError, or nil if none found.

type OngoingLongOpsMultiError

type OngoingLongOpsMultiError []error

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

func (OngoingLongOpsMultiError) AllErrors

func (m OngoingLongOpsMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (OngoingLongOpsMultiError) Error

func (m OngoingLongOpsMultiError) Error() string

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

type OngoingLongOpsValidationError

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

OngoingLongOpsValidationError is the validation error returned by OngoingLongOps.Validate if the designated constraints aren't met.

func (OngoingLongOpsValidationError) Cause

Cause function returns cause value.

func (OngoingLongOpsValidationError) Error

Error satisfies the builtin error interface

func (OngoingLongOpsValidationError) ErrorName

func (e OngoingLongOpsValidationError) ErrorName() string

ErrorName returns error name.

func (OngoingLongOpsValidationError) Field

Field function returns field value.

func (OngoingLongOpsValidationError) Key

Key function returns key value.

func (OngoingLongOpsValidationError) Reason

Reason function returns reason value.

type OngoingLongOps_Op

type OngoingLongOps_Op struct {

	// Deadline best-effort limits the lifetime of this work.
	//
	// Run Manager expects to receive a LongOpCompleted event by this deadline.
	Deadline *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=deadline,proto3" json:"deadline,omitempty"`
	// If true, signals to the Long Op handler that it should stop as soon
	// possible.
	CancelRequested bool `protobuf:"varint,2,opt,name=cancel_requested,json=cancelRequested,proto3" json:"cancel_requested,omitempty"`
	// Types that are assignable to Work:
	//
	//	*OngoingLongOps_Op_PostStartMessage
	//	*OngoingLongOps_Op_ResetTriggers_
	//	*OngoingLongOps_Op_ExecuteTryjobs
	//	*OngoingLongOps_Op_ExecutePostAction
	//	*OngoingLongOps_Op_PostGerritMessage_
	Work isOngoingLongOps_Op_Work `protobuf_oneof:"work"`
	// contains filtered or unexported fields
}

func (*OngoingLongOps_Op) Descriptor deprecated

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

Deprecated: Use OngoingLongOps_Op.ProtoReflect.Descriptor instead.

func (*OngoingLongOps_Op) GetCancelRequested

func (x *OngoingLongOps_Op) GetCancelRequested() bool

func (*OngoingLongOps_Op) GetDeadline

func (x *OngoingLongOps_Op) GetDeadline() *timestamppb.Timestamp

func (*OngoingLongOps_Op) GetExecutePostAction

func (*OngoingLongOps_Op) GetExecuteTryjobs

func (x *OngoingLongOps_Op) GetExecuteTryjobs() *tryjob.ExecuteTryjobsPayload

func (*OngoingLongOps_Op) GetPostGerritMessage

func (x *OngoingLongOps_Op) GetPostGerritMessage() *OngoingLongOps_Op_PostGerritMessage

func (*OngoingLongOps_Op) GetPostStartMessage

func (x *OngoingLongOps_Op) GetPostStartMessage() bool

func (*OngoingLongOps_Op) GetResetTriggers

func (x *OngoingLongOps_Op) GetResetTriggers() *OngoingLongOps_Op_ResetTriggers

func (*OngoingLongOps_Op) GetWork

func (m *OngoingLongOps_Op) GetWork() isOngoingLongOps_Op_Work

func (*OngoingLongOps_Op) ProtoMessage

func (*OngoingLongOps_Op) ProtoMessage()

func (*OngoingLongOps_Op) ProtoReflect

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

func (*OngoingLongOps_Op) Reset

func (x *OngoingLongOps_Op) Reset()

func (*OngoingLongOps_Op) String

func (x *OngoingLongOps_Op) String() string

func (*OngoingLongOps_Op) Validate

func (m *OngoingLongOps_Op) Validate() error

Validate checks the field values on OngoingLongOps_Op 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 (*OngoingLongOps_Op) ValidateAll

func (m *OngoingLongOps_Op) ValidateAll() error

ValidateAll checks the field values on OngoingLongOps_Op 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 OngoingLongOps_OpMultiError, or nil if none found.

type OngoingLongOps_OpMultiError

type OngoingLongOps_OpMultiError []error

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

func (OngoingLongOps_OpMultiError) AllErrors

func (m OngoingLongOps_OpMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (OngoingLongOps_OpMultiError) Error

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

type OngoingLongOps_OpValidationError

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

OngoingLongOps_OpValidationError is the validation error returned by OngoingLongOps_Op.Validate if the designated constraints aren't met.

func (OngoingLongOps_OpValidationError) Cause

Cause function returns cause value.

func (OngoingLongOps_OpValidationError) Error

Error satisfies the builtin error interface

func (OngoingLongOps_OpValidationError) ErrorName

ErrorName returns error name.

func (OngoingLongOps_OpValidationError) Field

Field function returns field value.

func (OngoingLongOps_OpValidationError) Key

Key function returns key value.

func (OngoingLongOps_OpValidationError) Reason

Reason function returns reason value.

type OngoingLongOps_Op_ExecutePostAction

type OngoingLongOps_Op_ExecutePostAction struct {
	// The PostActions from different runs can race each other in case
	// the actions from an earlier Run transiently failed and are being
	// retried. However, the resolution depends on the type of the post
	// action.
	//
	// If the action is to export the Run records to BQ, each of the Run
	// records should be exported, and CV should still attempt to execute post
	// actions for all the Runs ever triggered.
	//
	// In contrast, if the action is to vote a label, the post action handler
	// should check if the originated patchset is still the latest at the time
	// of the long-op processing time, and skip the action, if the patchset
	// is no longer the latest.
	ExecutePostAction *OngoingLongOps_Op_ExecutePostActionPayload `protobuf:"bytes,7,opt,name=execute_post_action,json=executePostAction,proto3,oneof"`
}

type OngoingLongOps_Op_ExecutePostActionPayload

type OngoingLongOps_Op_ExecutePostActionPayload struct {

	// Name of the post action.
	//
	// For config action, it should be the same as the name in the config
	// action.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Types that are assignable to Kind:
	//
	//	*OngoingLongOps_Op_ExecutePostActionPayload_ConfigAction
	//	*OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuota_
	Kind isOngoingLongOps_Op_ExecutePostActionPayload_Kind `protobuf_oneof:"kind"`
	// contains filtered or unexported fields
}

ExecutePostActionPayload is the payload of a long-op task that executes a given post action.

func (*OngoingLongOps_Op_ExecutePostActionPayload) Descriptor deprecated

Deprecated: Use OngoingLongOps_Op_ExecutePostActionPayload.ProtoReflect.Descriptor instead.

func (*OngoingLongOps_Op_ExecutePostActionPayload) GetConfigAction

func (*OngoingLongOps_Op_ExecutePostActionPayload) GetCreditRunQuota

func (*OngoingLongOps_Op_ExecutePostActionPayload) GetKind

func (m *OngoingLongOps_Op_ExecutePostActionPayload) GetKind() isOngoingLongOps_Op_ExecutePostActionPayload_Kind

func (*OngoingLongOps_Op_ExecutePostActionPayload) GetName

func (*OngoingLongOps_Op_ExecutePostActionPayload) ProtoMessage

func (*OngoingLongOps_Op_ExecutePostActionPayload) ProtoReflect

func (*OngoingLongOps_Op_ExecutePostActionPayload) Reset

func (*OngoingLongOps_Op_ExecutePostActionPayload) String

func (*OngoingLongOps_Op_ExecutePostActionPayload) Validate

Validate checks the field values on OngoingLongOps_Op_ExecutePostActionPayload 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 (*OngoingLongOps_Op_ExecutePostActionPayload) ValidateAll

ValidateAll checks the field values on OngoingLongOps_Op_ExecutePostActionPayload 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 OngoingLongOps_Op_ExecutePostActionPayloadMultiError, or nil if none found.

type OngoingLongOps_Op_ExecutePostActionPayloadMultiError

type OngoingLongOps_Op_ExecutePostActionPayloadMultiError []error

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

func (OngoingLongOps_Op_ExecutePostActionPayloadMultiError) AllErrors

AllErrors returns a list of validation violation errors.

func (OngoingLongOps_Op_ExecutePostActionPayloadMultiError) Error

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

type OngoingLongOps_Op_ExecutePostActionPayloadValidationError

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

OngoingLongOps_Op_ExecutePostActionPayloadValidationError is the validation error returned by OngoingLongOps_Op_ExecutePostActionPayload.Validate if the designated constraints aren't met.

func (OngoingLongOps_Op_ExecutePostActionPayloadValidationError) Cause

Cause function returns cause value.

func (OngoingLongOps_Op_ExecutePostActionPayloadValidationError) Error

Error satisfies the builtin error interface

func (OngoingLongOps_Op_ExecutePostActionPayloadValidationError) ErrorName

ErrorName returns error name.

func (OngoingLongOps_Op_ExecutePostActionPayloadValidationError) Field

Field function returns field value.

func (OngoingLongOps_Op_ExecutePostActionPayloadValidationError) Key

Key function returns key value.

func (OngoingLongOps_Op_ExecutePostActionPayloadValidationError) Reason

Reason function returns reason value.

type OngoingLongOps_Op_ExecutePostActionPayload_ConfigAction

type OngoingLongOps_Op_ExecutePostActionPayload_ConfigAction struct {
	// ConfigAction is the post action defined in the config group.
	ConfigAction *v2.ConfigGroup_PostAction `protobuf:"bytes,3,opt,name=config_action,json=configAction,proto3,oneof"`
}

type OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuota

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

func (*OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuota) Descriptor deprecated

Deprecated: Use OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuota.ProtoReflect.Descriptor instead.

func (*OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuota) ProtoMessage

func (*OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuota) ProtoReflect

func (*OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuota) Reset

func (*OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuota) String

func (*OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuota) Validate

Validate checks the field values on OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuota 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 (*OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuota) ValidateAll

ValidateAll checks the field values on OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuota 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 OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuotaMultiError, or nil if none found.

type OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuotaMultiError

type OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuotaMultiError []error

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

func (OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuotaMultiError) AllErrors

AllErrors returns a list of validation violation errors.

func (OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuotaMultiError) Error

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

type OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuotaValidationError

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

OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuotaValidationError is the validation error returned by OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuota.Validate if the designated constraints aren't met.

func (OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuotaValidationError) Cause

Cause function returns cause value.

func (OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuotaValidationError) Error

Error satisfies the builtin error interface

func (OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuotaValidationError) ErrorName

ErrorName returns error name.

func (OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuotaValidationError) Field

Field function returns field value.

func (OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuotaValidationError) Key

Key function returns key value.

func (OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuotaValidationError) Reason

Reason function returns reason value.

type OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuota_

type OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuota_ struct {
	// CreditRunQuota credits the quota back to the run creator and ask
	// next run that is blocked on the quota to start.
	CreditRunQuota *OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuota `protobuf:"bytes,4,opt,name=credit_run_quota,json=creditRunQuota,proto3,oneof"`
}

type OngoingLongOps_Op_ExecuteTryjobs

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

type OngoingLongOps_Op_PostGerritMessage

type OngoingLongOps_Op_PostGerritMessage struct {

	// Message to post to gerrit. The current implementation treats the
	// message as a unique key to achieve idempotence. If multiple payloads
	// with the same message is triggered for the same run, only one would
	// be posted.
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

PostGerritMessage is the payload for posting a bot message within a run's gerrit CLs.

func (*OngoingLongOps_Op_PostGerritMessage) Descriptor deprecated

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

Deprecated: Use OngoingLongOps_Op_PostGerritMessage.ProtoReflect.Descriptor instead.

func (*OngoingLongOps_Op_PostGerritMessage) GetMessage

func (*OngoingLongOps_Op_PostGerritMessage) ProtoMessage

func (*OngoingLongOps_Op_PostGerritMessage) ProtoMessage()

func (*OngoingLongOps_Op_PostGerritMessage) ProtoReflect

func (*OngoingLongOps_Op_PostGerritMessage) Reset

func (*OngoingLongOps_Op_PostGerritMessage) String

func (*OngoingLongOps_Op_PostGerritMessage) Validate

Validate checks the field values on OngoingLongOps_Op_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 (*OngoingLongOps_Op_PostGerritMessage) ValidateAll

func (m *OngoingLongOps_Op_PostGerritMessage) ValidateAll() error

ValidateAll checks the field values on OngoingLongOps_Op_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 OngoingLongOps_Op_PostGerritMessageMultiError, or nil if none found.

type OngoingLongOps_Op_PostGerritMessageMultiError

type OngoingLongOps_Op_PostGerritMessageMultiError []error

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

func (OngoingLongOps_Op_PostGerritMessageMultiError) AllErrors

AllErrors returns a list of validation violation errors.

func (OngoingLongOps_Op_PostGerritMessageMultiError) Error

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

type OngoingLongOps_Op_PostGerritMessageValidationError

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

OngoingLongOps_Op_PostGerritMessageValidationError is the validation error returned by OngoingLongOps_Op_PostGerritMessage.Validate if the designated constraints aren't met.

func (OngoingLongOps_Op_PostGerritMessageValidationError) Cause

Cause function returns cause value.

func (OngoingLongOps_Op_PostGerritMessageValidationError) Error

Error satisfies the builtin error interface

func (OngoingLongOps_Op_PostGerritMessageValidationError) ErrorName

ErrorName returns error name.

func (OngoingLongOps_Op_PostGerritMessageValidationError) Field

Field function returns field value.

func (OngoingLongOps_Op_PostGerritMessageValidationError) Key

Key function returns key value.

func (OngoingLongOps_Op_PostGerritMessageValidationError) Reason

Reason function returns reason value.

type OngoingLongOps_Op_PostGerritMessage_

type OngoingLongOps_Op_PostGerritMessage_ struct {
	// Post a custom message to all the CLs linked to a run.
	PostGerritMessage *OngoingLongOps_Op_PostGerritMessage `protobuf:"bytes,8,opt,name=post_gerrit_message,json=postGerritMessage,proto3,oneof"`
}

type OngoingLongOps_Op_PostStartMessage

type OngoingLongOps_Op_PostStartMessage struct {
	// If true, posts a start message.
	PostStartMessage bool `protobuf:"varint,3,opt,name=post_start_message,json=postStartMessage,proto3,oneof"`
}

type OngoingLongOps_Op_ResetTriggers

type OngoingLongOps_Op_ResetTriggers struct {
	Requests []*OngoingLongOps_Op_ResetTriggers_Request `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
	// The status Run will transition to if all triggers are successfully
	// cancelled.
	//
	// Must be one of the terminal statues.
	RunStatusIfSucceeded Status `` /* 154-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*OngoingLongOps_Op_ResetTriggers) Descriptor deprecated

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

Deprecated: Use OngoingLongOps_Op_ResetTriggers.ProtoReflect.Descriptor instead.

func (*OngoingLongOps_Op_ResetTriggers) GetRequests

func (*OngoingLongOps_Op_ResetTriggers) GetRunStatusIfSucceeded

func (x *OngoingLongOps_Op_ResetTriggers) GetRunStatusIfSucceeded() Status

func (*OngoingLongOps_Op_ResetTriggers) ProtoMessage

func (*OngoingLongOps_Op_ResetTriggers) ProtoMessage()

func (*OngoingLongOps_Op_ResetTriggers) ProtoReflect

func (*OngoingLongOps_Op_ResetTriggers) Reset

func (*OngoingLongOps_Op_ResetTriggers) String

func (*OngoingLongOps_Op_ResetTriggers) Validate

func (m *OngoingLongOps_Op_ResetTriggers) Validate() error

Validate checks the field values on OngoingLongOps_Op_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 (*OngoingLongOps_Op_ResetTriggers) ValidateAll

func (m *OngoingLongOps_Op_ResetTriggers) ValidateAll() error

ValidateAll checks the field values on OngoingLongOps_Op_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 OngoingLongOps_Op_ResetTriggersMultiError, or nil if none found.

type OngoingLongOps_Op_ResetTriggersMultiError

type OngoingLongOps_Op_ResetTriggersMultiError []error

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

func (OngoingLongOps_Op_ResetTriggersMultiError) AllErrors

AllErrors returns a list of validation violation errors.

func (OngoingLongOps_Op_ResetTriggersMultiError) Error

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

type OngoingLongOps_Op_ResetTriggersValidationError

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

OngoingLongOps_Op_ResetTriggersValidationError is the validation error returned by OngoingLongOps_Op_ResetTriggers.Validate if the designated constraints aren't met.

func (OngoingLongOps_Op_ResetTriggersValidationError) Cause

Cause function returns cause value.

func (OngoingLongOps_Op_ResetTriggersValidationError) Error

Error satisfies the builtin error interface

func (OngoingLongOps_Op_ResetTriggersValidationError) ErrorName

ErrorName returns error name.

func (OngoingLongOps_Op_ResetTriggersValidationError) Field

Field function returns field value.

func (OngoingLongOps_Op_ResetTriggersValidationError) Key

Key function returns key value.

func (OngoingLongOps_Op_ResetTriggersValidationError) Reason

Reason function returns reason value.

type OngoingLongOps_Op_ResetTriggers_

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

type OngoingLongOps_Op_ResetTriggers_Request

type OngoingLongOps_Op_ResetTriggers_Request struct {

	// internal CLID.
	Clid int64 `protobuf:"varint,1,opt,name=clid,proto3" json:"clid,omitempty"`
	// Message explains why trigger is reset. Will be posted to the CL.
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// Whom to notify.
	Notify []gerrit.Whom `protobuf:"varint,3,rep,packed,name=notify,proto3,enum=cv.internal.gerrit.Whom" json:"notify,omitempty"`
	// Whom to add to the attention set.
	AddToAttention []gerrit.Whom `` /* 142-byte string literal not displayed */
	// Reason explains the reason of attention set change.
	AddToAttentionReason string `protobuf:"bytes,5,opt,name=add_to_attention_reason,json=addToAttentionReason,proto3" json:"add_to_attention_reason,omitempty"`
	// contains filtered or unexported fields
}

Request is to request resetting the trigger of a CL.

func (*OngoingLongOps_Op_ResetTriggers_Request) Descriptor deprecated

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

Deprecated: Use OngoingLongOps_Op_ResetTriggers_Request.ProtoReflect.Descriptor instead.

func (*OngoingLongOps_Op_ResetTriggers_Request) GetAddToAttention

func (x *OngoingLongOps_Op_ResetTriggers_Request) GetAddToAttention() []gerrit.Whom

func (*OngoingLongOps_Op_ResetTriggers_Request) GetAddToAttentionReason

func (x *OngoingLongOps_Op_ResetTriggers_Request) GetAddToAttentionReason() string

func (*OngoingLongOps_Op_ResetTriggers_Request) GetClid

func (*OngoingLongOps_Op_ResetTriggers_Request) GetMessage

func (*OngoingLongOps_Op_ResetTriggers_Request) GetNotify

func (*OngoingLongOps_Op_ResetTriggers_Request) ProtoMessage

func (*OngoingLongOps_Op_ResetTriggers_Request) ProtoReflect

func (*OngoingLongOps_Op_ResetTriggers_Request) Reset

func (*OngoingLongOps_Op_ResetTriggers_Request) String

func (*OngoingLongOps_Op_ResetTriggers_Request) Validate

Validate checks the field values on OngoingLongOps_Op_ResetTriggers_Request 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 (*OngoingLongOps_Op_ResetTriggers_Request) ValidateAll

ValidateAll checks the field values on OngoingLongOps_Op_ResetTriggers_Request 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 OngoingLongOps_Op_ResetTriggers_RequestMultiError, or nil if none found.

type OngoingLongOps_Op_ResetTriggers_RequestMultiError

type OngoingLongOps_Op_ResetTriggers_RequestMultiError []error

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

func (OngoingLongOps_Op_ResetTriggers_RequestMultiError) AllErrors

AllErrors returns a list of validation violation errors.

func (OngoingLongOps_Op_ResetTriggers_RequestMultiError) Error

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

type OngoingLongOps_Op_ResetTriggers_RequestValidationError

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

OngoingLongOps_Op_ResetTriggers_RequestValidationError is the validation error returned by OngoingLongOps_Op_ResetTriggers_Request.Validate if the designated constraints aren't met.

func (OngoingLongOps_Op_ResetTriggers_RequestValidationError) Cause

Cause function returns cause value.

func (OngoingLongOps_Op_ResetTriggers_RequestValidationError) Error

Error satisfies the builtin error interface

func (OngoingLongOps_Op_ResetTriggers_RequestValidationError) ErrorName

ErrorName returns error name.

func (OngoingLongOps_Op_ResetTriggers_RequestValidationError) Field

Field function returns field value.

func (OngoingLongOps_Op_ResetTriggers_RequestValidationError) Key

Key function returns key value.

func (OngoingLongOps_Op_ResetTriggers_RequestValidationError) Reason

Reason function returns reason value.

type Options

type Options struct {

	// If true, submitting the Run isn't blocked on open tree.
	//
	// If false (default), respects project configuration.
	SkipTreeChecks bool `protobuf:"varint,1,opt,name=skip_tree_checks,json=skipTreeChecks,proto3" json:"skip_tree_checks,omitempty"`
	// If true, `builders.equivalent_to{...}` sections are ignored when triggering
	// tryjobs.
	//
	// If false (default), respects project configuration.
	SkipEquivalentBuilders bool `` /* 130-byte string literal not displayed */
	// If true, no longer useful tryjobs won't be cancelled.
	//
	// If false (default), respects project configuration.
	AvoidCancellingTryjobs bool `` /* 130-byte string literal not displayed */
	// If true, no tryjobs will be triggered except "presubmit" regardless of
	// project configuration.
	//
	// "presubmit" builders are legacy which are currently configured with
	// "disable_reuse: true" in project config. To skip triggering them,
	// skip_presubmit must be set to true.
	// TODO(https://crbug.com/950074): ignore.
	//
	// If false (default), respects project configuration.
	SkipTryjobs bool `protobuf:"varint,4,opt,name=skip_tryjobs,json=skipTryjobs,proto3" json:"skip_tryjobs,omitempty"`
	// Deprecated per https://crbug.com/950074.
	// See skip_tryjobs doc.
	SkipPresubmit bool `protobuf:"varint,5,opt,name=skip_presubmit,json=skipPresubmit,proto3" json:"skip_presubmit,omitempty"`
	// Contains the directives to include specific builder in the Run.
	//
	// Its elements are strings of the form:
	// project/bucket:builder1,builder2;project2/bucket:builder3
	//
	// Note that there may be duplication in the directives, it's up to the
	// consumer of this information to handle it.
	//
	// Mutually exclusive with `overridden_tryjobs` option.
	// This option is ignored if `skip_tryjobs` is true.
	IncludedTryjobs []string `protobuf:"bytes,6,rep,name=included_tryjobs,json=includedTryjobs,proto3" json:"included_tryjobs,omitempty"`
	// Overrides all the Tryjobs triggered for this Run regardless of Project
	// configuration.
	//
	// Its elements are strings of the form:
	// project/bucket:builder1,builder2;project2/bucket:builder3
	//
	// Note that there may be duplication in the directives, it's up to the
	// consumer of this information to handle it.
	//
	// Mutually exclusive with `included_tryjobs` option.
	// This option is ignored if `skip_tryjobs` is true.
	OverriddenTryjobs []string `protobuf:"bytes,8,rep,name=overridden_tryjobs,json=overriddenTryjobs,proto3" json:"overridden_tryjobs,omitempty"`
	// Contains the custom Tryjob tags that should be added when launching
	// Tryjobs for this Run.
	//
	// Each element SHOULD be in the format of "$tag_key:$tag_value" and the
	// character set for tag key is [a-z0-9_\-].
	CustomTryjobTags []string `protobuf:"bytes,7,rep,name=custom_tryjob_tags,json=customTryjobTags,proto3" json:"custom_tryjob_tags,omitempty"`
	// contains filtered or unexported fields
}

Options are Run-specific additions on top of LUCI project config.

func ExtractOptions

func ExtractOptions(snapshot *changelist.Snapshot) *Options

ExtractOptions computes the Run Options from 1 CL.

func MergeOptions

func MergeOptions(a, b *Options) *Options

MergeOptions merges two Run Options.

Does not modify the passed object, but may return either of them.

func (*Options) Descriptor deprecated

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

Deprecated: Use Options.ProtoReflect.Descriptor instead.

func (*Options) GetAvoidCancellingTryjobs

func (x *Options) GetAvoidCancellingTryjobs() bool

func (*Options) GetCustomTryjobTags

func (x *Options) GetCustomTryjobTags() []string

func (*Options) GetIncludedTryjobs

func (x *Options) GetIncludedTryjobs() []string

func (*Options) GetOverriddenTryjobs

func (x *Options) GetOverriddenTryjobs() []string

func (*Options) GetSkipEquivalentBuilders

func (x *Options) GetSkipEquivalentBuilders() bool

func (*Options) GetSkipPresubmit

func (x *Options) GetSkipPresubmit() bool

func (*Options) GetSkipTreeChecks

func (x *Options) GetSkipTreeChecks() bool

func (*Options) GetSkipTryjobs

func (x *Options) GetSkipTryjobs() bool

func (*Options) ProtoMessage

func (*Options) ProtoMessage()

func (*Options) ProtoReflect

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

func (*Options) Reset

func (x *Options) Reset()

func (*Options) String

func (x *Options) String() string

func (*Options) Validate

func (m *Options) Validate() error

Validate checks the field values on Options 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 (*Options) ValidateAll

func (m *Options) ValidateAll() error

ValidateAll checks the field values on Options 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 OptionsMultiError, or nil if none found.

type OptionsMultiError

type OptionsMultiError []error

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

func (OptionsMultiError) AllErrors

func (m OptionsMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (OptionsMultiError) Error

func (m OptionsMultiError) Error() string

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

type OptionsValidationError

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

OptionsValidationError is the validation error returned by Options.Validate if the designated constraints aren't met.

func (OptionsValidationError) Cause

func (e OptionsValidationError) Cause() error

Cause function returns cause value.

func (OptionsValidationError) Error

func (e OptionsValidationError) Error() string

Error satisfies the builtin error interface

func (OptionsValidationError) ErrorName

func (e OptionsValidationError) ErrorName() string

ErrorName returns error name.

func (OptionsValidationError) Field

func (e OptionsValidationError) Field() string

Field function returns field value.

func (OptionsValidationError) Key

func (e OptionsValidationError) Key() bool

Key function returns key value.

func (OptionsValidationError) Reason

func (e OptionsValidationError) Reason() string

Reason function returns reason value.

type Run

type Run struct {

	// ID is the RunID generated at triggering time.
	//
	// See doc for type `common.RunID` about the format.
	ID common.RunID `gae:"$id"`
	// CreationOperationID is a string used to de-dup Run creation attempts.
	CreationOperationID string `gae:",noindex"`
	// Mode dictates the behavior of this Run.
	Mode Mode `gae:",noindex"`
	// ModeDefinition is the definition for non-standard run mode.
	//
	// It is supplied in the project config. Note that ModeDefinition is fixed
	// after the run creation and wouldn't be changed even if the mode definition
	// has changed in the project config unless the mode name has changed. In that
	// case, the run would be cancelled and a new run with new mode name would be
	// created.
	ModeDefinition *cfgpb.Mode
	// Status describes the status of this Run.
	Status Status
	// EVersion is the entity version.
	//
	// It increments by one upon every successful modification.
	EVersion int64 `gae:",noindex"`
	// CreateTime is the timestamp when this Run was created.
	//
	// This is the timestamp of the last vote, on a Gerrit CL, that triggers this Run.
	CreateTime time.Time `gae:",noindex"`
	// StartTime is the timestamp when this Run was started.
	StartTime time.Time `gae:",noindex"`
	// UpdateTime is the timestamp when this entity was last updated.
	UpdateTime time.Time `gae:",noindex"`
	// EndTime is the timestamp when this Run has completed.
	EndTime time.Time `gae:",noindex"`
	// Owner is the identity of the owner of this Run.
	//
	// Currently, it is the same as owner of the CL. If `combine_cls` is
	// enabled for the ConfigGroup used by this Run, the owner is the CL which
	// has the latest triggering timestamp.
	Owner identity.Identity `gae:",noindex"`
	// CreatedBy is the identity that creates this Run.
	//
	// For dry run and full run, it is the identity of the user who *first* makes
	// the Gerrit vote that triggers this run.  If the Run contains multiple CLs
	// (i.e. `combine_cls` is enabled), it is the identity of the user who
	// triggers the CL which has the latest triggering timestamp. For new
	// patchset run, it is the  the identity of the user who uploads the new
	// patchset.
	CreatedBy identity.Identity `gae:",noindex"`
	// BilledTo is the identity whose Run quota is consumed for the Run start.
	BilledTo identity.Identity
	// ConfigGroupID is ID of the ConfigGroup that is used by this Run.
	//
	// RunManager may update the ConfigGroup in the middle of the Run if it is
	// notified that a new version of Config has been imported into CV.
	ConfigGroupID prjcfg.ConfigGroupID `gae:",noindex"`
	// CLs are IDs of all CLs involved in this Run.
	//
	// The index of Runs by CL is provided via RunCL's `IndexedID` field.
	CLs common.CLIDs `gae:",noindex"`
	// RootCL is the CL in `CLs` that triggers this Run in the combined mode.
	//
	// For example, for a stack of 2 CLs, if the top CL gains a vote that triggers
	// a Dry Run for the stack, the top CL is the origin CL.
	RootCL common.CLID `gae:",noindex"`
	// Options are Run-specific additions on top of LUCI project config.
	Options *Options
	// CancellationReasons are the reasons for cancelling a Run.
	//
	// Typically, only one reason will be available. But it's possible that Run
	// Manager received multiple cancellation requested at the approximately
	// the same time.
	//
	// Reasons should not contain duplication and empty reason.
	CancellationReasons []string `gae:",noindex"`
	// OngoingLongOps tracks long operations currently happening.
	OngoingLongOps *OngoingLongOps
	// Submission is the state of Run Submission.
	//
	// If set, Submission is in progress or has completed.
	Submission *Submission
	// Tryjobs is the state of the Run tryjobs.
	Tryjobs *Tryjobs
	// LatestCLsRefresh is the latest time when Run Manager scheduled async
	// refresh of CLs.
	LatestCLsRefresh time.Time `gae:",noindex"`
	// LatestTryjobsRefresh is the latest time when Run Manager scheduled async
	// refresh of Tryjobs.
	LatestTryjobsRefresh time.Time `gae:",noindex"`
	// DepRuns is a slice of Runs that this Run depends on.
	//
	// If this is set and mode == FullRun, this run
	// - will not start before all the deps start.
	// - will be canceled if any of the deps is canceled or failed.
	// - will be submitted only after all the deps are submitted.
	DepRuns common.RunIDs

	// QuotaExhaustionMsgLongOpRequested is set true when the current run
	// already has a pending msg posted.
	QuotaExhaustionMsgLongOpRequested bool `gae:",noindex"`
	// contains filtered or unexported fields
}

Run is an entity that contains high-level information about a CV Run.

In production, Run entities are created only by the "runcreator" package.

Detailed information about CLs and Tryjobs are stored in its child entities.

func LoadChildRuns

func LoadChildRuns(ctx context.Context, runID common.RunID) ([]*Run, error)

LoadChildRuns loads all Runs with the given Run in their dep_runs.

func LoadRun

func LoadRun(ctx context.Context, id common.RunID, checkers ...LoadRunChecker) (*Run, error)

LoadRun returns Run from Datastore, optionally performing before/after checks, typically used for checking read permissions.

If Run isn't found, returns (nil, nil), unless optional checker returns an error.

func (*Run) HasRootCL

func (r *Run) HasRootCL() bool

HasRootCL returns true if this Run has root CL specified.

It means this run is instantly triggered Run in combined CLs mode (i.e. multi-Cl mode).

type RunCL

type RunCL struct {
	ID         common.CLID           `gae:"$id"`
	Run        *datastore.Key        `gae:"$parent"`
	ExternalID changelist.ExternalID `gae:",noindex"`
	Detail     *changelist.Snapshot
	Trigger    *Trigger

	// IndexedID is a copy of ID to get an index on just the CLID,
	// as the primary automatic index is on (Run(parent), ID).
	IndexedID common.CLID
	// contains filtered or unexported fields
}

RunCL is an immutable snapshot of a CL at the time of the Run start.

func LoadRunCLs

func LoadRunCLs(ctx context.Context, runID common.RunID, clids common.CLIDs) ([]*RunCL, error)

LoadRunCLs loads `RunCL` entities of the provided cls in the Run.

type RunLog

type RunLog struct {

	// ID is the value Run.EVersion which was saved transactionally with the
	// creation of the RunLog entity.
	//
	// Thus, ordering by ID (default Datastore ordering) will automatically
	// provide semantically chronological order.
	ID  int64          `gae:"$id"`
	Run *datastore.Key `gae:"$parent"`
	// Entries record what happened to the Run.
	//
	// There is always at least one.
	// Ordered from logically oldest to newest.
	//
	// Entries are stored as a protobuf in order to expose them using Admin API
	// with ease.
	// This is however opaque to Datastore, and so it has a downside of inability
	// to index or filter by kinds of LogEntry within the Datastore itself.
	// However, total number of LogEntries per Run should be <<1000 and the
	// intended consumption are humans, therefore indexing isn't a deal breaker.
	Entries *LogEntries
	// contains filtered or unexported fields
}

RunLog is an immutable entry for meaningful changes to a Run's state.

RunLog entity is written

type Status

type Status int32

Status describes the status of a CV Run.

const (
	// Unspecified status.
	Status_STATUS_UNSPECIFIED Status = 0
	// Run is pending to start.
	//
	// It is either because Run Manager hasn't processed the StartEvent yet or
	// the RunOwner has exhausted all the quota and waiting for new quota to
	// be available.
	Status_PENDING Status = 1
	// Run is running.
	Status_RUNNING Status = 2
	// Run is waiting for submission.
	//
	// Run is in this status if one of the following scenario is true:
	//  1. Tree is closed at the time Run attempts to submit.
	//  2. There is another Run in the same LUCI Project that is currently
	//     submitting.
	//  3. The submission is rate limited according to the submit option in
	//     Project Config.
	//
	// This status is cancellable.
	Status_WAITING_FOR_SUBMISSION Status = 4
	// Run is submitting.
	//
	// A Run can't be cancelled while submitting. A Run may transition from
	// this status to either `WAITING_FOR_SUBMISSION` status or a non-cancelled
	// terminal status.
	Status_SUBMITTING Status = 5
	// ENDED_MASK can be used as a bitmask to check if a Run has ended.
	// This MUST NOT be used as the status of a Run.
	Status_ENDED_MASK Status = 64
	// Run ends successfully.
	Status_SUCCEEDED Status = 65
	// Run ends unsuccessfully.
	Status_FAILED Status = 66
	// Run is cancelled.
	Status_CANCELLED Status = 67
)

func (Status) Descriptor

func (Status) Descriptor() protoreflect.EnumDescriptor

func (Status) Enum

func (x Status) Enum() *Status

func (Status) EnumDescriptor deprecated

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

Deprecated: Use Status.Descriptor instead.

func (Status) Number

func (x Status) Number() protoreflect.EnumNumber

func (Status) String

func (x Status) String() string

func (Status) Type

func (Status) Type() protoreflect.EnumType

type Submission

type Submission struct {

	// The deadline of this submission.
	//
	// If the deadline is not set or has already expired, a RunManager task
	// can claim the exclusive privilege by setting the deadline to a future
	// timestamp (generally, end of task deadline).
	Deadline *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=deadline,proto3" json:"deadline,omitempty"`
	// ID of the task that executes this submission.
	TaskId string `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// IDs of all CLs that should be submitted in this submission.
	//
	// Must be ordered in submission order.
	Cls []int64 `protobuf:"varint,3,rep,packed,name=cls,proto3" json:"cls,omitempty"`
	// IDs of all CLs that have been submitted successfully already.
	SubmittedCls []int64 `protobuf:"varint,4,rep,packed,name=submitted_cls,json=submittedCls,proto3" json:"submitted_cls,omitempty"`
	// IDs of all CLs that fails to submit if any.
	//
	// CLs that are neither in this list nor in the `submitted_cls` should be
	// treated as if CV has never attempted to submit them.
	//
	// This could be empty even when the entire submission fails, which would be
	// typically caused by faulty infrastructure (e.g. Task Queue not executing
	// a Run Manager task before the whole submission timeout is reached).
	FailedCls []int64 `protobuf:"varint,5,rep,packed,name=failed_cls,json=failedCls,proto3" json:"failed_cls,omitempty"`
	// If True, Tree is currently in open state.
	TreeOpen bool `protobuf:"varint,10,opt,name=tree_open,json=treeOpen,proto3" json:"tree_open,omitempty"`
	// The timestamp when the last attempt to fetch the Tree status occurred.
	LastTreeCheckTime *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=last_tree_check_time,json=lastTreeCheckTime,proto3" json:"last_tree_check_time,omitempty"`
	// The timestamp when an attempt to fetch the Tree status first resulted in
	// an error.
	TreeErrorSince *timestamppb.Timestamp `protobuf:"bytes,12,opt,name=tree_error_since,json=treeErrorSince,proto3" json:"tree_error_since,omitempty"`
	// contains filtered or unexported fields
}

Submission describes the state of Run submission.

func (*Submission) Descriptor deprecated

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

Deprecated: Use Submission.ProtoReflect.Descriptor instead.

func (*Submission) GetCls

func (x *Submission) GetCls() []int64

func (*Submission) GetDeadline

func (x *Submission) GetDeadline() *timestamppb.Timestamp

func (*Submission) GetFailedCls

func (x *Submission) GetFailedCls() []int64

func (*Submission) GetLastTreeCheckTime

func (x *Submission) GetLastTreeCheckTime() *timestamppb.Timestamp

func (*Submission) GetSubmittedCls

func (x *Submission) GetSubmittedCls() []int64

func (*Submission) GetTaskId

func (x *Submission) GetTaskId() string

func (*Submission) GetTreeErrorSince

func (x *Submission) GetTreeErrorSince() *timestamppb.Timestamp

func (*Submission) GetTreeOpen

func (x *Submission) GetTreeOpen() bool

func (*Submission) ProtoMessage

func (*Submission) ProtoMessage()

func (*Submission) ProtoReflect

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

func (*Submission) Reset

func (x *Submission) Reset()

func (*Submission) String

func (x *Submission) String() string

func (*Submission) Validate

func (m *Submission) Validate() error

Validate checks the field values on Submission 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 (*Submission) ValidateAll

func (m *Submission) ValidateAll() error

ValidateAll checks the field values on Submission 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 SubmissionMultiError, or nil if none found.

type SubmissionMultiError

type SubmissionMultiError []error

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

func (SubmissionMultiError) AllErrors

func (m SubmissionMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (SubmissionMultiError) Error

func (m SubmissionMultiError) Error() string

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

type SubmissionValidationError

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

SubmissionValidationError is the validation error returned by Submission.Validate if the designated constraints aren't met.

func (SubmissionValidationError) Cause

func (e SubmissionValidationError) Cause() error

Cause function returns cause value.

func (SubmissionValidationError) Error

Error satisfies the builtin error interface

func (SubmissionValidationError) ErrorName

func (e SubmissionValidationError) ErrorName() string

ErrorName returns error name.

func (SubmissionValidationError) Field

Field function returns field value.

func (SubmissionValidationError) Key

Key function returns key value.

func (SubmissionValidationError) Reason

func (e SubmissionValidationError) Reason() string

Reason function returns reason value.

type Trigger

type Trigger struct {
	Time *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"`
	// Mode is string value of run.Mode.
	Mode string `protobuf:"bytes,2,opt,name=mode,proto3" json:"mode,omitempty"`
	// ModeDefinition is the definition of the mode in case `mode` is not standard
	// modes supported by LUCI CV (e.g. DRY_RUN, FULL_RUN, NEW_PATCHSET_RUN) but
	// is provided through project configuration.
	//
	// This field is empty if `mode` is standard mode in LUCI CV.
	ModeDefinition *v2.Mode `protobuf:"bytes,6,opt,name=mode_definition,json=modeDefinition,proto3" json:"mode_definition,omitempty"`
	// Triggering user email. Always known for Runs created since July 2021.
	//
	// Gerrit doesn't guarantee that every user has set their preferred email,
	// but LUCI ACLs are based entirely on user emails. Thus, Project Manager will
	// refuse starting Runs for users without the email.
	Email string `protobuf:"bytes,3,opt,name=email,proto3" json:"email,omitempty"`
	// Gerrit account ID. Always known.
	GerritAccountId int64 `protobuf:"varint,4,opt,name=gerrit_account_id,json=gerritAccountId,proto3" json:"gerrit_account_id,omitempty"`
	// contains filtered or unexported fields
}

Trigger describes who/how CV was triggered on a specific CL.

func (*Trigger) Descriptor deprecated

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

Deprecated: Use Trigger.ProtoReflect.Descriptor instead.

func (*Trigger) GetEmail

func (x *Trigger) GetEmail() string

func (*Trigger) GetGerritAccountId

func (x *Trigger) GetGerritAccountId() int64

func (*Trigger) GetMode

func (x *Trigger) GetMode() string

func (*Trigger) GetModeDefinition

func (x *Trigger) GetModeDefinition() *v2.Mode

func (*Trigger) GetTime

func (x *Trigger) GetTime() *timestamppb.Timestamp

func (*Trigger) ProtoMessage

func (*Trigger) ProtoMessage()

func (*Trigger) ProtoReflect

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

func (*Trigger) Reset

func (x *Trigger) Reset()

func (*Trigger) String

func (x *Trigger) String() string

func (*Trigger) Validate

func (m *Trigger) Validate() error

Validate checks the field values on Trigger 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 (*Trigger) ValidateAll

func (m *Trigger) ValidateAll() error

ValidateAll checks the field values on Trigger 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 TriggerMultiError, or nil if none found.

type TriggerMultiError

type TriggerMultiError []error

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

func (TriggerMultiError) AllErrors

func (m TriggerMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TriggerMultiError) Error

func (m TriggerMultiError) Error() string

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

type TriggerValidationError

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

TriggerValidationError is the validation error returned by Trigger.Validate if the designated constraints aren't met.

func (TriggerValidationError) Cause

func (e TriggerValidationError) Cause() error

Cause function returns cause value.

func (TriggerValidationError) Error

func (e TriggerValidationError) Error() string

Error satisfies the builtin error interface

func (TriggerValidationError) ErrorName

func (e TriggerValidationError) ErrorName() string

ErrorName returns error name.

func (TriggerValidationError) Field

func (e TriggerValidationError) Field() string

Field function returns field value.

func (TriggerValidationError) Key

func (e TriggerValidationError) Key() bool

Key function returns key value.

func (TriggerValidationError) Reason

func (e TriggerValidationError) Reason() string

Reason function returns reason value.

type Triggers

type Triggers struct {

	// CQVoteTrigger is the trigger that corresponds to a vote on the
	// `Commit-Queue` Gerrit label.
	CqVoteTrigger *Trigger `protobuf:"bytes,1,opt,name=cq_vote_trigger,json=cqVoteTrigger,proto3" json:"cq_vote_trigger,omitempty"`
	// NewPatchsetRunTrigger is the trigger that is created automatically by
	// uploading a new patchset.
	//
	// This is only populated if the CL matches a config group that allows this.
	NewPatchsetRunTrigger *Trigger `` /* 128-byte string literal not displayed */
	// contains filtered or unexported fields
}

Triggers describes the triggers associated with a CL.

func (*Triggers) Descriptor deprecated

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

Deprecated: Use Triggers.ProtoReflect.Descriptor instead.

func (*Triggers) GetCqVoteTrigger

func (x *Triggers) GetCqVoteTrigger() *Trigger

func (*Triggers) GetNewPatchsetRunTrigger

func (x *Triggers) GetNewPatchsetRunTrigger() *Trigger

func (*Triggers) ProtoMessage

func (*Triggers) ProtoMessage()

func (*Triggers) ProtoReflect

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

func (*Triggers) Reset

func (x *Triggers) Reset()

func (*Triggers) String

func (x *Triggers) String() string

func (*Triggers) Validate

func (m *Triggers) Validate() error

Validate checks the field values on Triggers 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 (*Triggers) ValidateAll

func (m *Triggers) ValidateAll() error

ValidateAll checks the field values on Triggers 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 TriggersMultiError, or nil if none found.

func (*Triggers) WithTrigger

func (ts *Triggers) WithTrigger(t *Trigger) *Triggers

WithTrigger assigns the given Trigger to the correct slot of the Triggers struct depending on the trigger mode. I.e. distinguish CQ Vote triggers from New Patchset triggers.

Returns a reference to the modified/instantiated Triggers.

type TriggersMultiError

type TriggersMultiError []error

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

func (TriggersMultiError) AllErrors

func (m TriggersMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TriggersMultiError) Error

func (m TriggersMultiError) Error() string

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

type TriggersValidationError

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

TriggersValidationError is the validation error returned by Triggers.Validate if the designated constraints aren't met.

func (TriggersValidationError) Cause

func (e TriggersValidationError) Cause() error

Cause function returns cause value.

func (TriggersValidationError) Error

func (e TriggersValidationError) Error() string

Error satisfies the builtin error interface

func (TriggersValidationError) ErrorName

func (e TriggersValidationError) ErrorName() string

ErrorName returns error name.

func (TriggersValidationError) Field

func (e TriggersValidationError) Field() string

Field function returns field value.

func (TriggersValidationError) Key

func (e TriggersValidationError) Key() bool

Key function returns key value.

func (TriggersValidationError) Reason

func (e TriggersValidationError) Reason() string

Reason function returns reason value.

type Tryjob

type Tryjob struct {
	Definition *tryjob.Definition `protobuf:"bytes,1,opt,name=definition,proto3" json:"definition,omitempty"`
	// ID is a CV internal Tryjob ID, corresponding to a Datastore entity.
	//
	// During migration from CQDaemon, the ID may be not set but then ExternalID
	// is set.
	// TODO(crbug/1227523): make this field required.
	Id int64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	// EVersion of the Tryjob entity last observed by this Run.
	Eversion int64 `protobuf:"varint,3,opt,name=eversion,proto3" json:"eversion,omitempty"`
	// ExternalID is the external job ID.
	//
	// It's kept here for ease of URL generation and to ease migration from
	// CQDaemon.
	// TODO(crbug/1227523): update comment above after CQDaemon migration.
	ExternalId string `protobuf:"bytes,4,opt,name=external_id,json=externalId,proto3" json:"external_id,omitempty"`
	// Status of the Tryjob.
	Status tryjob.Status `protobuf:"varint,5,opt,name=status,proto3,enum=cv.internal.tryjob.Status" json:"status,omitempty"`
	// Reused is true, if this tryjob wasn't triggered by CV for this Run.
	//
	// In other words, either:
	//   - tryjob was triggered by CV for a previous Run
	//   - tryjob was triggered by non-CV.
	Reused bool `protobuf:"varint,6,opt,name=reused,proto3" json:"reused,omitempty"`
	// If true, indicates this tryjob must pass in order for the Run to be
	// considered successful.
	//
	// It is typically true when the tryjob is NOT experimental or triggered
	// because of `Cq-Include-TryBot` git footer.
	Critical bool `protobuf:"varint,9,opt,name=critical,proto3" json:"critical,omitempty"`
	// Result of the tryjob.
	Result *tryjob.Result `protobuf:"bytes,7,opt,name=result,proto3" json:"result,omitempty"`
	// If true, this Tryjob was computed based on CQDaemon's input.
	//
	// TODO(crbug/1227523): delete after CQDaemon migration.
	CqdDerived bool `protobuf:"varint,8,opt,name=cqd_derived,json=cqdDerived,proto3" json:"cqd_derived,omitempty"`
	// contains filtered or unexported fields
}

Tryjob represents a Run's view of a tryjob.

func (*Tryjob) Descriptor deprecated

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

Deprecated: Use Tryjob.ProtoReflect.Descriptor instead.

func (*Tryjob) GetCqdDerived

func (x *Tryjob) GetCqdDerived() bool

func (*Tryjob) GetCritical

func (x *Tryjob) GetCritical() bool

func (*Tryjob) GetDefinition

func (x *Tryjob) GetDefinition() *tryjob.Definition

func (*Tryjob) GetEversion

func (x *Tryjob) GetEversion() int64

func (*Tryjob) GetExternalId

func (x *Tryjob) GetExternalId() string

func (*Tryjob) GetId

func (x *Tryjob) GetId() int64

func (*Tryjob) GetResult

func (x *Tryjob) GetResult() *tryjob.Result

func (*Tryjob) GetReused

func (x *Tryjob) GetReused() bool

func (*Tryjob) GetStatus

func (x *Tryjob) GetStatus() tryjob.Status

func (*Tryjob) ProtoMessage

func (*Tryjob) ProtoMessage()

func (*Tryjob) ProtoReflect

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

func (*Tryjob) Reset

func (x *Tryjob) Reset()

func (*Tryjob) String

func (x *Tryjob) String() string

func (*Tryjob) Validate

func (m *Tryjob) Validate() error

Validate checks the field values on Tryjob 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 (*Tryjob) ValidateAll

func (m *Tryjob) ValidateAll() error

ValidateAll checks the field values on Tryjob 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 TryjobMultiError, or nil if none found.

type TryjobMultiError

type TryjobMultiError []error

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

func (TryjobMultiError) AllErrors

func (m TryjobMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TryjobMultiError) Error

func (m TryjobMultiError) Error() string

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

type TryjobValidationError

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

TryjobValidationError is the validation error returned by Tryjob.Validate if the designated constraints aren't met.

func (TryjobValidationError) Cause

func (e TryjobValidationError) Cause() error

Cause function returns cause value.

func (TryjobValidationError) Error

func (e TryjobValidationError) Error() string

Error satisfies the builtin error interface

func (TryjobValidationError) ErrorName

func (e TryjobValidationError) ErrorName() string

ErrorName returns error name.

func (TryjobValidationError) Field

func (e TryjobValidationError) Field() string

Field function returns field value.

func (TryjobValidationError) Key

func (e TryjobValidationError) Key() bool

Key function returns key value.

func (TryjobValidationError) Reason

func (e TryjobValidationError) Reason() string

Reason function returns reason value.

type Tryjobs

type Tryjobs struct {

	// Requirement is what has to happen to verify a given Run.
	Requirement *tryjob.Requirement `protobuf:"bytes,1,opt,name=requirement,proto3" json:"requirement,omitempty"`
	// StagingRequirement will be promoted to requirement.
	//
	// It is typically set when the existing requirement is executing and waiting
	// to be cancelled. For example:
	//
	//	T0: Run starts and computes the requirement. A long op task is executing
	//	    the requirement.
	//	T1: A new config is ingested and results in a new requirement. RM
	//	    requests a cancellation for the long op task and set the new
	//	    requirement to this field.
	//	T2: The long op task is successfully cancelled. RM promotes the
	//	    staging requirement to requirement and enqueue a new long op task to
	//	    execute the new requirement.
	StagingRequirement *tryjob.Requirement `protobuf:"bytes,4,opt,name=staging_requirement,json=stagingRequirement,proto3" json:"staging_requirement,omitempty"`
	// RequirementVersion increments by 1 every time this requirement changes.
	//
	// Starts with 1.
	RequirementVersion int32 `protobuf:"varint,6,opt,name=requirement_version,json=requirementVersion,proto3" json:"requirement_version,omitempty"`
	// The timestamp when the requirement is last computed.
	//
	// Every requirement computation will update this field even if the result
	// requirement is the same as the existing one.
	RequirementComputedAt *timestamppb.Timestamp `` /* 126-byte string literal not displayed */
	// Tryjobs tracks tryjobs of a Run.
	//
	// It may contain Tryjobs which are no longer required.
	// It does contain all Tryjobs which weren't reused even if no longer
	// required.
	//
	// TODO(crbug/1227363): replace this field in favor of `state`
	//
	// Deprecated: Marked as deprecated in go.chromium.org/luci/cv/internal/run/storage.proto.
	Tryjobs []*Tryjob `protobuf:"bytes,2,rep,name=tryjobs,proto3" json:"tryjobs,omitempty"`
	// The timestamp of the CQDaemon report last incorporated into `tryjobs`.
	//
	// TODO(crbug/1227523): delete this field.
	CqdUpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=cqd_update_time,json=cqdUpdateTime,proto3" json:"cqd_update_time,omitempty"`
	// State is the latest state reported by Tryjob Executor task.
	//
	// Once the Run is ended, this state is finalized.
	State *tryjob.ExecutionState `protobuf:"bytes,5,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

Tryjobs is the state of Run's tryjobs.

func (*Tryjobs) Descriptor deprecated

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

Deprecated: Use Tryjobs.ProtoReflect.Descriptor instead.

func (*Tryjobs) GetCqdUpdateTime

func (x *Tryjobs) GetCqdUpdateTime() *timestamppb.Timestamp

func (*Tryjobs) GetRequirement

func (x *Tryjobs) GetRequirement() *tryjob.Requirement

func (*Tryjobs) GetRequirementComputedAt

func (x *Tryjobs) GetRequirementComputedAt() *timestamppb.Timestamp

func (*Tryjobs) GetRequirementVersion

func (x *Tryjobs) GetRequirementVersion() int32

func (*Tryjobs) GetStagingRequirement

func (x *Tryjobs) GetStagingRequirement() *tryjob.Requirement

func (*Tryjobs) GetState

func (x *Tryjobs) GetState() *tryjob.ExecutionState

func (*Tryjobs) GetTryjobs deprecated

func (x *Tryjobs) GetTryjobs() []*Tryjob

Deprecated: Marked as deprecated in go.chromium.org/luci/cv/internal/run/storage.proto.

func (*Tryjobs) ProtoMessage

func (*Tryjobs) ProtoMessage()

func (*Tryjobs) ProtoReflect

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

func (*Tryjobs) Reset

func (x *Tryjobs) Reset()

func (*Tryjobs) String

func (x *Tryjobs) String() string

func (*Tryjobs) Validate

func (m *Tryjobs) Validate() error

Validate checks the field values on Tryjobs 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 (*Tryjobs) ValidateAll

func (m *Tryjobs) ValidateAll() error

ValidateAll checks the field values on Tryjobs 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 TryjobsMultiError, or nil if none found.

type TryjobsMultiError

type TryjobsMultiError []error

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

func (TryjobsMultiError) AllErrors

func (m TryjobsMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TryjobsMultiError) Error

func (m TryjobsMultiError) Error() string

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

type TryjobsValidationError

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

TryjobsValidationError is the validation error returned by Tryjobs.Validate if the designated constraints aren't met.

func (TryjobsValidationError) Cause

func (e TryjobsValidationError) Cause() error

Cause function returns cause value.

func (TryjobsValidationError) Error

func (e TryjobsValidationError) Error() string

Error satisfies the builtin error interface

func (TryjobsValidationError) ErrorName

func (e TryjobsValidationError) ErrorName() string

ErrorName returns error name.

func (TryjobsValidationError) Field

func (e TryjobsValidationError) Field() string

Field function returns field value.

func (TryjobsValidationError) Key

func (e TryjobsValidationError) Key() bool

Key function returns key value.

func (TryjobsValidationError) Reason

func (e TryjobsValidationError) Reason() string

Reason function returns reason value.

Directories

Path Synopsis
Package bq provides functionality for sending finished Run rows to BigQuery.
Package bq provides functionality for sending finished Run rows to BigQuery.
Package eventpb stores protos for event processing of RunManager.
Package eventpb stores protos for event processing of RunManager.
Package impl implements a RunManager.
Package impl implements a RunManager.
handler
Package handler implements handlers that handles run events.
Package handler implements handlers that handles run events.
longops
Package longops implements long operations of the Run Manager.
Package longops implements long operations of the Run Manager.
state
Package state defines the model for a Run state.
Package state defines the model for a Run state.
submit
Package submit contains utilities for Run submission.
Package submit contains utilities for Run submission.
util
Package util contains the common utility functions shared by RunManager.
Package util contains the common utility functions shared by RunManager.
Package postaction executes post actions for run termination events.
Package postaction executes post actions for run termination events.
Package pubsub implements utility functions for publishing various Run events to Cloud PubSub.
Package pubsub implements utility functions for publishing various Run events to Cloud PubSub.
Package rdb provides functionality for notifying ResultDB of successfully merged invocations.
Package rdb provides functionality for notifying ResultDB of successfully merged invocations.
Package runcreator creates new Runs.
Package runcreator creates new Runs.
Package runquery contains logic to query runs.
Package runquery contains logic to query runs.
Package runtest implements tests for working with Run Manager.
Package runtest implements tests for working with Run Manager.

Jump to

Keyboard shortcuts

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