run

package
v0.0.0-...-650f6e2 Latest Latest
Warning

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

 Go to latest Published: Apr 27, 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 

func (b LoadRunsBuilder) Checker(c LoadRunChecker) LoadRunsBuilder

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

func (LoadRunsBuilder) Do 

func (b LoadRunsBuilder) Do(ctx context.Context) ([]*Run, errors.MultiError)

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 

func (e LogEntriesValidationError) Error() string

Error satisfies the builtin error interface

func (LogEntriesValidationError) ErrorName 

func (e LogEntriesValidationError) ErrorName() string

ErrorName returns error name.

func (LogEntriesValidationError) Field 

func (e LogEntriesValidationError) Field() string

Field function returns field value.

func (LogEntriesValidationError) Key 

func (e LogEntriesValidationError) Key() bool

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 (x *LogEntry_AcquiredSubmitQueue) ProtoReflect() protoreflect.Message

func (*LogEntry_AcquiredSubmitQueue) Reset 

func (x *LogEntry_AcquiredSubmitQueue) Reset()

func (*LogEntry_AcquiredSubmitQueue) String 

func (x *LogEntry_AcquiredSubmitQueue) String() 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 

func (m LogEntry_AcquiredSubmitQueueMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LogEntry_AcquiredSubmitQueueMultiError) Error 

func (m LogEntry_AcquiredSubmitQueueMultiError) Error() string

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 

func (e LogEntry_AcquiredSubmitQueueValidationError) Cause() error

Cause function returns cause value.

func (LogEntry_AcquiredSubmitQueueValidationError) Error 

func (e LogEntry_AcquiredSubmitQueueValidationError) Error() string

Error satisfies the builtin error interface

func (LogEntry_AcquiredSubmitQueueValidationError) ErrorName 

func (e LogEntry_AcquiredSubmitQueueValidationError) ErrorName() string

ErrorName returns error name.

func (LogEntry_AcquiredSubmitQueueValidationError) Field 

func (e LogEntry_AcquiredSubmitQueueValidationError) Field() string

Field function returns field value.

func (LogEntry_AcquiredSubmitQueueValidationError) Key 

func (e LogEntry_AcquiredSubmitQueueValidationError) Key() bool

Key function returns key value.

func (LogEntry_AcquiredSubmitQueueValidationError) Reason 

func (e LogEntry_AcquiredSubmitQueueValidationError) Reason() string

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 

func (m LogEntry_CLSubmittedMultiError) Error() string

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 

func (e LogEntry_CLSubmittedValidationError) Cause() error

Cause function returns cause value.

func (LogEntry_CLSubmittedValidationError) Error 

func (e LogEntry_CLSubmittedValidationError) Error() string

Error satisfies the builtin error interface

func (LogEntry_CLSubmittedValidationError) ErrorName 

func (e LogEntry_CLSubmittedValidationError) ErrorName() string

ErrorName returns error name.

func (LogEntry_CLSubmittedValidationError) Field 

func (e LogEntry_CLSubmittedValidationError) Field() string

Field function returns field value.

func (LogEntry_CLSubmittedValidationError) Key 

func (e LogEntry_CLSubmittedValidationError) Key() bool

Key function returns key value.

func (LogEntry_CLSubmittedValidationError) Reason 

func (e LogEntry_CLSubmittedValidationError) Reason() string

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 

func (m LogEntry_ConfigChangedMultiError) Error() string

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 

func (e LogEntry_ConfigChangedValidationError) Cause() error

Cause function returns cause value.

func (LogEntry_ConfigChangedValidationError) Error 

func (e LogEntry_ConfigChangedValidationError) Error() string

Error satisfies the builtin error interface

func (LogEntry_ConfigChangedValidationError) ErrorName 

func (e LogEntry_ConfigChangedValidationError) ErrorName() string

ErrorName returns error name.

func (LogEntry_ConfigChangedValidationError) Field 

func (e LogEntry_ConfigChangedValidationError) Field() string

Field function returns field value.

func (LogEntry_ConfigChangedValidationError) Key 

func (e LogEntry_ConfigChangedValidationError) Key() bool

Key function returns key value.

func (LogEntry_ConfigChangedValidationError) Reason 

func (e LogEntry_ConfigChangedValidationError) Reason() string

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 

func (m LogEntry_CreatedMultiError) Error() string

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 

func (e LogEntry_CreatedValidationError) Cause() error

Cause function returns cause value.

func (LogEntry_CreatedValidationError) Error 

func (e LogEntry_CreatedValidationError) Error() string

Error satisfies the builtin error interface

func (LogEntry_CreatedValidationError) ErrorName 

func (e LogEntry_CreatedValidationError) ErrorName() string

ErrorName returns error name.

func (LogEntry_CreatedValidationError) Field 

func (e LogEntry_CreatedValidationError) Field() string

Field function returns field value.

func (LogEntry_CreatedValidationError) Key 

func (e LogEntry_CreatedValidationError) Key() bool

Key function returns key value.

func (LogEntry_CreatedValidationError) Reason 

func (e LogEntry_CreatedValidationError) Reason() string

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 

func (e LogEntry_InfoValidationError) Cause() error

Cause function returns cause value.

func (LogEntry_InfoValidationError) Error 

func (e LogEntry_InfoValidationError) Error() string

Error satisfies the builtin error interface

func (LogEntry_InfoValidationError) ErrorName 

func (e LogEntry_InfoValidationError) ErrorName() string

ErrorName returns error name.

func (LogEntry_InfoValidationError) Field 

func (e LogEntry_InfoValidationError) Field() string

Field function returns field value.

func (LogEntry_InfoValidationError) Key 

func (e LogEntry_InfoValidationError) Key() bool

Key function returns key value.

func (LogEntry_InfoValidationError) Reason 

func (e LogEntry_InfoValidationError) Reason() string

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 (x *LogEntry_ReleasedSubmitQueue) ProtoReflect() protoreflect.Message

func (*LogEntry_ReleasedSubmitQueue) Reset 

func (x *LogEntry_ReleasedSubmitQueue) Reset()

func (*LogEntry_ReleasedSubmitQueue) String 

func (x *LogEntry_ReleasedSubmitQueue) String() 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 

func (m LogEntry_ReleasedSubmitQueueMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LogEntry_ReleasedSubmitQueueMultiError) Error 

func (m LogEntry_ReleasedSubmitQueueMultiError) Error() string

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 

func (e LogEntry_ReleasedSubmitQueueValidationError) Cause() error

Cause function returns cause value.

func (LogEntry_ReleasedSubmitQueueValidationError) Error 

func (e LogEntry_ReleasedSubmitQueueValidationError) Error() string

Error satisfies the builtin error interface

func (LogEntry_ReleasedSubmitQueueValidationError) ErrorName 

func (e LogEntry_ReleasedSubmitQueueValidationError) ErrorName() string

ErrorName returns error name.

func (LogEntry_ReleasedSubmitQueueValidationError) Field 

func (e LogEntry_ReleasedSubmitQueueValidationError) Field() string

Field function returns field value.

func (LogEntry_ReleasedSubmitQueueValidationError) Key 

func (e LogEntry_ReleasedSubmitQueueValidationError) Key() bool

Key function returns key value.

func (LogEntry_ReleasedSubmitQueueValidationError) Reason 

func (e LogEntry_ReleasedSubmitQueueValidationError) Reason() string

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 

func (m LogEntry_RunEndedMultiError) Error() string

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 

func (e LogEntry_RunEndedValidationError) Cause() error

Cause function returns cause value.

func (LogEntry_RunEndedValidationError) Error 

func (e LogEntry_RunEndedValidationError) Error() string

Error satisfies the builtin error interface

func (LogEntry_RunEndedValidationError) ErrorName 

func (e LogEntry_RunEndedValidationError) ErrorName() string

ErrorName returns error name.

func (LogEntry_RunEndedValidationError) Field 

func (e LogEntry_RunEndedValidationError) Field() string

Field function returns field value.

func (LogEntry_RunEndedValidationError) Key 

func (e LogEntry_RunEndedValidationError) Key() bool

Key function returns key value.

func (LogEntry_RunEndedValidationError) Reason 

func (e LogEntry_RunEndedValidationError) Reason() string

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 

func (m LogEntry_StartedMultiError) Error() string

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 

func (e LogEntry_StartedValidationError) Cause() error

Cause function returns cause value.

func (LogEntry_StartedValidationError) Error 

func (e LogEntry_StartedValidationError) Error() string

Error satisfies the builtin error interface

func (LogEntry_StartedValidationError) ErrorName 

func (e LogEntry_StartedValidationError) ErrorName() string

ErrorName returns error name.

func (LogEntry_StartedValidationError) Field 

func (e LogEntry_StartedValidationError) Field() string

Field function returns field value.

func (LogEntry_StartedValidationError) Key 

func (e LogEntry_StartedValidationError) Key() bool

Key function returns key value.

func (LogEntry_StartedValidationError) Reason 

func (e LogEntry_StartedValidationError) Reason() string

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 (x *LogEntry_SubmissionFailure) GetEvent() *eventpb.SubmissionCompleted

func (*LogEntry_SubmissionFailure) ProtoMessage 

func (*LogEntry_SubmissionFailure) ProtoMessage()

func (*LogEntry_SubmissionFailure) ProtoReflect 

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

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 

func (m LogEntry_SubmissionFailureMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LogEntry_SubmissionFailureMultiError) Error 

func (m LogEntry_SubmissionFailureMultiError) Error() string

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 

func (e LogEntry_SubmissionFailureValidationError) Cause() error

Cause function returns cause value.

func (LogEntry_SubmissionFailureValidationError) Error 

func (e LogEntry_SubmissionFailureValidationError) Error() string

Error satisfies the builtin error interface

func (LogEntry_SubmissionFailureValidationError) ErrorName 

func (e LogEntry_SubmissionFailureValidationError) ErrorName() string

ErrorName returns error name.

func (LogEntry_SubmissionFailureValidationError) Field 

func (e LogEntry_SubmissionFailureValidationError) Field() string

Field function returns field value.

func (LogEntry_SubmissionFailureValidationError) Key 

func (e LogEntry_SubmissionFailureValidationError) Key() bool

Key function returns key value.

func (LogEntry_SubmissionFailureValidationError) Reason 

func (e LogEntry_SubmissionFailureValidationError) Reason() string

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 

func (m LogEntry_TreeCheckedMultiError) Error() string

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 

func (e LogEntry_TreeCheckedValidationError) Cause() error

Cause function returns cause value.

func (LogEntry_TreeCheckedValidationError) Error 

func (e LogEntry_TreeCheckedValidationError) Error() string

Error satisfies the builtin error interface

func (LogEntry_TreeCheckedValidationError) ErrorName 

func (e LogEntry_TreeCheckedValidationError) ErrorName() string

ErrorName returns error name.

func (LogEntry_TreeCheckedValidationError) Field 

func (e LogEntry_TreeCheckedValidationError) Field() string

Field function returns field value.

func (LogEntry_TreeCheckedValidationError) Key 

func (e LogEntry_TreeCheckedValidationError) Key() bool

Key function returns key value.

func (LogEntry_TreeCheckedValidationError) Reason 

func (e LogEntry_TreeCheckedValidationError) Reason() string

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 (x *LogEntry_TryjobsRequirementUpdated) ProtoReflect() protoreflect.Message

func (*LogEntry_TryjobsRequirementUpdated) Reset 

func (x *LogEntry_TryjobsRequirementUpdated) Reset()

func (*LogEntry_TryjobsRequirementUpdated) String 

func (x *LogEntry_TryjobsRequirementUpdated) String() string

func (*LogEntry_TryjobsRequirementUpdated) Validate 

func (m *LogEntry_TryjobsRequirementUpdated) Validate() error

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 

func (m LogEntry_TryjobsRequirementUpdatedMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LogEntry_TryjobsRequirementUpdatedMultiError) Error 

func (m LogEntry_TryjobsRequirementUpdatedMultiError) Error() string

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 

func (e LogEntry_TryjobsRequirementUpdatedValidationError) Cause() error

Cause function returns cause value.

func (LogEntry_TryjobsRequirementUpdatedValidationError) Error 

func (e LogEntry_TryjobsRequirementUpdatedValidationError) Error() string

Error satisfies the builtin error interface

func (LogEntry_TryjobsRequirementUpdatedValidationError) ErrorName 

func (e LogEntry_TryjobsRequirementUpdatedValidationError) ErrorName() string

ErrorName returns error name.

func (LogEntry_TryjobsRequirementUpdatedValidationError) Field 

func (e LogEntry_TryjobsRequirementUpdatedValidationError) Field() string

Field function returns field value.

func (LogEntry_TryjobsRequirementUpdatedValidationError) Key 

func (e LogEntry_TryjobsRequirementUpdatedValidationError) Key() bool

Key function returns key value.

func (LogEntry_TryjobsRequirementUpdatedValidationError) Reason 

func (e LogEntry_TryjobsRequirementUpdatedValidationError) Reason() string

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 

func (m LogEntry_TryjobsUpdatedMultiError) Error() string

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 

func (e LogEntry_TryjobsUpdatedValidationError) Cause() error

Cause function returns cause value.

func (LogEntry_TryjobsUpdatedValidationError) Error 

func (e LogEntry_TryjobsUpdatedValidationError) Error() string

Error satisfies the builtin error interface

func (LogEntry_TryjobsUpdatedValidationError) ErrorName 

func (e LogEntry_TryjobsUpdatedValidationError) ErrorName() string

ErrorName returns error name.

func (LogEntry_TryjobsUpdatedValidationError) Field 

func (e LogEntry_TryjobsUpdatedValidationError) Field() string

Field function returns field value.

func (LogEntry_TryjobsUpdatedValidationError) Key 

func (e LogEntry_TryjobsUpdatedValidationError) Key() bool

Key function returns key value.

func (LogEntry_TryjobsUpdatedValidationError) Reason 

func (e LogEntry_TryjobsUpdatedValidationError) Reason() string

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 

func (m LogEntry_WaitlistedMultiError) Error() string

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 

func (e LogEntry_WaitlistedValidationError) Cause() error

Cause function returns cause value.

func (LogEntry_WaitlistedValidationError) Error 

func (e LogEntry_WaitlistedValidationError) Error() string

Error satisfies the builtin error interface

func (LogEntry_WaitlistedValidationError) ErrorName 

func (e LogEntry_WaitlistedValidationError) ErrorName() string

ErrorName returns error name.

func (LogEntry_WaitlistedValidationError) Field 

func (e LogEntry_WaitlistedValidationError) Field() string

Field function returns field value.

func (LogEntry_WaitlistedValidationError) Key 

func (e LogEntry_WaitlistedValidationError) Key() bool

Key function returns key value.

func (LogEntry_WaitlistedValidationError) Reason 

func (e LogEntry_WaitlistedValidationError) Reason() string

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 

func (e OngoingLongOpsValidationError) Cause() error

Cause function returns cause value.

func (OngoingLongOpsValidationError) Error 

func (e OngoingLongOpsValidationError) Error() string

Error satisfies the builtin error interface

func (OngoingLongOpsValidationError) ErrorName 

func (e OngoingLongOpsValidationError) ErrorName() string

ErrorName returns error name.

func (OngoingLongOpsValidationError) Field 

func (e OngoingLongOpsValidationError) Field() string

Field function returns field value.

func (OngoingLongOpsValidationError) Key 

func (e OngoingLongOpsValidationError) Key() bool

Key function returns key value.

func (OngoingLongOpsValidationError) Reason 

func (e OngoingLongOpsValidationError) Reason() string

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 (x *OngoingLongOps_Op) GetExecutePostAction() *OngoingLongOps_Op_ExecutePostActionPayload

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 

func (m OngoingLongOps_OpMultiError) Error() string

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 

func (e OngoingLongOps_OpValidationError) Cause() error

Cause function returns cause value.

func (OngoingLongOps_OpValidationError) Error 

func (e OngoingLongOps_OpValidationError) Error() string

Error satisfies the builtin error interface

func (OngoingLongOps_OpValidationError) ErrorName 

func (e OngoingLongOps_OpValidationError) ErrorName() string

ErrorName returns error name.

func (OngoingLongOps_OpValidationError) Field 

func (e OngoingLongOps_OpValidationError) Field() string

Field function returns field value.

func (OngoingLongOps_OpValidationError) Key 

func (e OngoingLongOps_OpValidationError) Key() bool

Key function returns key value.

func (OngoingLongOps_OpValidationError) Reason 

func (e OngoingLongOps_OpValidationError) Reason() string

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 

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

Deprecated: Use OngoingLongOps_Op_ExecutePostActionPayload.ProtoReflect.Descriptor instead.

func (*OngoingLongOps_Op_ExecutePostActionPayload) GetConfigAction 

func (x *OngoingLongOps_Op_ExecutePostActionPayload) GetConfigAction() *v2.ConfigGroup_PostAction

func (*OngoingLongOps_Op_ExecutePostActionPayload) GetCreditRunQuota 

func (x *OngoingLongOps_Op_ExecutePostActionPayload) GetCreditRunQuota() *OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuota

func (*OngoingLongOps_Op_ExecutePostActionPayload) GetKind 

func (m *OngoingLongOps_Op_ExecutePostActionPayload) GetKind() isOngoingLongOps_Op_ExecutePostActionPayload_Kind

func (*OngoingLongOps_Op_ExecutePostActionPayload) GetName 

func (x *OngoingLongOps_Op_ExecutePostActionPayload) GetName() string

func (*OngoingLongOps_Op_ExecutePostActionPayload) ProtoMessage 

func (*OngoingLongOps_Op_ExecutePostActionPayload) ProtoMessage()

func (*OngoingLongOps_Op_ExecutePostActionPayload) ProtoReflect 

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

func (*OngoingLongOps_Op_ExecutePostActionPayload) Reset 

func (x *OngoingLongOps_Op_ExecutePostActionPayload) Reset()

func (*OngoingLongOps_Op_ExecutePostActionPayload) String 

func (x *OngoingLongOps_Op_ExecutePostActionPayload) String() string

func (*OngoingLongOps_Op_ExecutePostActionPayload) Validate 

func (m *OngoingLongOps_Op_ExecutePostActionPayload) Validate() error

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 

func (m *OngoingLongOps_Op_ExecutePostActionPayload) ValidateAll() error

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 

func (m OngoingLongOps_Op_ExecutePostActionPayloadMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (OngoingLongOps_Op_ExecutePostActionPayloadMultiError) Error 

func (m OngoingLongOps_Op_ExecutePostActionPayloadMultiError) Error() string

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 

func (e OngoingLongOps_Op_ExecutePostActionPayloadValidationError) Cause() error

Cause function returns cause value.

func (OngoingLongOps_Op_ExecutePostActionPayloadValidationError) Error 

func (e OngoingLongOps_Op_ExecutePostActionPayloadValidationError) Error() string

Error satisfies the builtin error interface

func (OngoingLongOps_Op_ExecutePostActionPayloadValidationError) ErrorName 

func (e OngoingLongOps_Op_ExecutePostActionPayloadValidationError) ErrorName() string

ErrorName returns error name.

func (OngoingLongOps_Op_ExecutePostActionPayloadValidationError) Field 

func (e OngoingLongOps_Op_ExecutePostActionPayloadValidationError) Field() string

Field function returns field value.

func (OngoingLongOps_Op_ExecutePostActionPayloadValidationError) Key 

func (e OngoingLongOps_Op_ExecutePostActionPayloadValidationError) Key() bool

Key function returns key value.

func (OngoingLongOps_Op_ExecutePostActionPayloadValidationError) Reason 

func (e OngoingLongOps_Op_ExecutePostActionPayloadValidationError) Reason() string

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 

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

Deprecated: Use OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuota.ProtoReflect.Descriptor instead.

func (*OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuota) ProtoMessage 

func (*OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuota) ProtoMessage()

func (*OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuota) ProtoReflect 

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

func (*OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuota) Reset 

func (x *OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuota) Reset()

func (*OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuota) String 

func (x *OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuota) String() string

func (*OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuota) Validate 

func (m *OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuota) Validate() error

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 

func (m *OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuota) ValidateAll() error

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 

func (m OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuotaMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuotaMultiError) Error 

func (m OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuotaMultiError) Error() string

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 

func (e OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuotaValidationError) Cause() error

Cause function returns cause value.

func (OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuotaValidationError) Error 

func (e OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuotaValidationError) Error() string

Error satisfies the builtin error interface

func (OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuotaValidationError) ErrorName 

func (e OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuotaValidationError) ErrorName() string

ErrorName returns error name.

func (OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuotaValidationError) Field 

func (e OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuotaValidationError) Field() string

Field function returns field value.

func (OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuotaValidationError) Key 

func (e OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuotaValidationError) Key() bool

Key function returns key value.

func (OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuotaValidationError) Reason 

func (e OngoingLongOps_Op_ExecutePostActionPayload_CreditRunQuotaValidationError) Reason() string

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 (x *OngoingLongOps_Op_PostGerritMessage) GetMessage() string

func (*OngoingLongOps_Op_PostGerritMessage) ProtoMessage 

func (*OngoingLongOps_Op_PostGerritMessage) ProtoMessage()

func (*OngoingLongOps_Op_PostGerritMessage) ProtoReflect 

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

func (*OngoingLongOps_Op_PostGerritMessage) Reset 

func (x *OngoingLongOps_Op_PostGerritMessage) Reset()

func (*OngoingLongOps_Op_PostGerritMessage) String 

func (x *OngoingLongOps_Op_PostGerritMessage) String() string

func (*OngoingLongOps_Op_PostGerritMessage) Validate 

func (m *OngoingLongOps_Op_PostGerritMessage) Validate() error

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 

func (m OngoingLongOps_Op_PostGerritMessageMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (OngoingLongOps_Op_PostGerritMessageMultiError) Error 

func (m OngoingLongOps_Op_PostGerritMessageMultiError) Error() string

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 

func (e OngoingLongOps_Op_PostGerritMessageValidationError) Cause() error

Cause function returns cause value.

func (OngoingLongOps_Op_PostGerritMessageValidationError) Error 

func (e OngoingLongOps_Op_PostGerritMessageValidationError) Error() string

Error satisfies the builtin error interface

func (OngoingLongOps_Op_PostGerritMessageValidationError) ErrorName 

func (e OngoingLongOps_Op_PostGerritMessageValidationError) ErrorName() string

ErrorName returns error name.

func (OngoingLongOps_Op_PostGerritMessageValidationError) Field 

func (e OngoingLongOps_Op_PostGerritMessageValidationError) Field() string

Field function returns field value.

func (OngoingLongOps_Op_PostGerritMessageValidationError) Key 

func (e OngoingLongOps_Op_PostGerritMessageValidationError) Key() bool

Key function returns key value.

func (OngoingLongOps_Op_PostGerritMessageValidationError) Reason 

func (e OngoingLongOps_Op_PostGerritMessageValidationError) Reason() string

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 (x *OngoingLongOps_Op_ResetTriggers) GetRequests() []*OngoingLongOps_Op_ResetTriggers_Request

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 (x *OngoingLongOps_Op_ResetTriggers) ProtoReflect() protoreflect.Message

func (*OngoingLongOps_Op_ResetTriggers) Reset 

func (x *OngoingLongOps_Op_ResetTriggers) Reset()

func (*OngoingLongOps_Op_ResetTriggers) String 

func (x *OngoingLongOps_Op_ResetTriggers) String() 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 

func (m OngoingLongOps_Op_ResetTriggersMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (OngoingLongOps_Op_ResetTriggersMultiError) Error 

func (m OngoingLongOps_Op_ResetTriggersMultiError) Error() string

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 

func (e OngoingLongOps_Op_ResetTriggersValidationError) Cause() error

Cause function returns cause value.

func (OngoingLongOps_Op_ResetTriggersValidationError) Error 

func (e OngoingLongOps_Op_ResetTriggersValidationError) Error() string

Error satisfies the builtin error interface

func (OngoingLongOps_Op_ResetTriggersValidationError) ErrorName 

func (e OngoingLongOps_Op_ResetTriggersValidationError) ErrorName() string

ErrorName returns error name.

func (OngoingLongOps_Op_ResetTriggersValidationError) Field 

func (e OngoingLongOps_Op_ResetTriggersValidationError) Field() string

Field function returns field value.

func (OngoingLongOps_Op_ResetTriggersValidationError) Key 

func (e OngoingLongOps_Op_ResetTriggersValidationError) Key() bool

Key function returns key value.

func (OngoingLongOps_Op_ResetTriggersValidationError) Reason 

func (e OngoingLongOps_Op_ResetTriggersValidationError) Reason() string

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 (x *OngoingLongOps_Op_ResetTriggers_Request) GetClid() int64

func (*OngoingLongOps_Op_ResetTriggers_Request) GetMessage 

func (x *OngoingLongOps_Op_ResetTriggers_Request) GetMessage() string

func (*OngoingLongOps_Op_ResetTriggers_Request) GetNotify 

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

func (*OngoingLongOps_Op_ResetTriggers_Request) ProtoMessage 

func (*OngoingLongOps_Op_ResetTriggers_Request) ProtoMessage()

func (*OngoingLongOps_Op_ResetTriggers_Request) ProtoReflect 

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

func (*OngoingLongOps_Op_ResetTriggers_Request) Reset 

func (x *OngoingLongOps_Op_ResetTriggers_Request) Reset()

func (*OngoingLongOps_Op_ResetTriggers_Request) String 

func (x *OngoingLongOps_Op_ResetTriggers_Request) String() string

func (*OngoingLongOps_Op_ResetTriggers_Request) Validate 

func (m *OngoingLongOps_Op_ResetTriggers_Request) Validate() error

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 

func (m *OngoingLongOps_Op_ResetTriggers_Request) ValidateAll() error

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 

func (m OngoingLongOps_Op_ResetTriggers_RequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (OngoingLongOps_Op_ResetTriggers_RequestMultiError) Error 

func (m OngoingLongOps_Op_ResetTriggers_RequestMultiError) Error() string

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 

func (e OngoingLongOps_Op_ResetTriggers_RequestValidationError) Cause() error

Cause function returns cause value.

func (OngoingLongOps_Op_ResetTriggers_RequestValidationError) Error 

func (e OngoingLongOps_Op_ResetTriggers_RequestValidationError) Error() string

Error satisfies the builtin error interface

func (OngoingLongOps_Op_ResetTriggers_RequestValidationError) ErrorName 

func (e OngoingLongOps_Op_ResetTriggers_RequestValidationError) ErrorName() string

ErrorName returns error name.

func (OngoingLongOps_Op_ResetTriggers_RequestValidationError) Field 

func (e OngoingLongOps_Op_ResetTriggers_RequestValidationError) Field() string

Field function returns field value.

func (OngoingLongOps_Op_ResetTriggers_RequestValidationError) Key 

func (e OngoingLongOps_Op_ResetTriggers_RequestValidationError) Key() bool

Key function returns key value.

func (OngoingLongOps_Op_ResetTriggers_RequestValidationError) Reason 

func (e OngoingLongOps_Op_ResetTriggers_RequestValidationError) Reason() string

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 

func (e SubmissionValidationError) Error() string

Error satisfies the builtin error interface

func (SubmissionValidationError) ErrorName 

func (e SubmissionValidationError) ErrorName() string

ErrorName returns error name.

func (SubmissionValidationError) Field 

func (e SubmissionValidationError) Field() string

Field function returns field value.

func (SubmissionValidationError) Key 

func (e SubmissionValidationError) Key() bool

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.

Source Files

View all Source files

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
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.