prjpb

package
v0.0.0-...-df660c4 Latest Latest
Warning

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

 Go to latest Published: Apr 23, 2024 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Overview

Package prjpb stores protos for event processing of ProjectManager.

Index

Constants

View Source 
const (
	// PMTaskInterval is target frequency of executions of ManageProjectTask.
	//
	// See Dispatch() for details.
	PMTaskInterval = time.Second

	// MaxAcceptableDelay prevents TQ tasks which arrive too late from invoking PM.
	//
	// MaxAcceptableDelay / PMTaskInterval effectively limits # concurrent
	// invocations of PM on the same project that may happen due to task retries,
	// delays, and queue throttling.
	//
	// Do not set too low, as this may prevent actual PM invoking from happening at
	// all if the TQ is overloaded.
	MaxAcceptableDelay = 60 * time.Second

	ManageProjectTaskClass        = "manage-project"
	KickManageProjectTaskClass    = "kick-" + ManageProjectTaskClass
	PurgeProjectCLTaskClass       = "purge-project-cl"
	TriggerProjectCLDepsTaskClass = "trigger-project-cl-deps"
)
View Source 
const MaxTriggeringCLDepsDuration = 8 * time.Minute

MaxTriggeringCLDepsDuration limits the time that a TQ task has to execute a given TrigggeringCLDesp task.

Once the deadline is exceeded, PM will will remove the task from PStat to retriage the CL and see if it has to reschedule another TriggeringCLDeps for the CL with its deps.

Variables

View Source 
var (
	Status_name = map[int32]string{
		0: "STATUS_UNSPECIFIED",
		1: "STARTED",
		2: "STOPPING",
		3: "STOPPED",
	}
	Status_value = map[string]int32{
		"STATUS_UNSPECIFIED": 0,
		"STARTED":            1,
		"STOPPING":           2,
		"STOPPED":            3,
	}
)

Enum value maps for Status.

View Source 
var (
	LogReason_name = map[int32]string{
		0: "LOG_REASON_UNSPECIFIED",
		1: "FYI_PERIODIC",
		2: "STATUS_CHANGED",
		3: "CONFIG_CHANGED",
		4: "DEBUG",
	}
	LogReason_value = map[string]int32{
		"LOG_REASON_UNSPECIFIED": 0,
		"FYI_PERIODIC":           1,
		"STATUS_CHANGED":         2,
		"CONFIG_CHANGED":         3,
		"DEBUG":                  4,
	}
)

Enum value maps for LogReason.

View Source 
var (
	PCL_Status_name = map[int32]string{
		0: "PCL_STATUS_UNSPECIFIED",

		1: "UNKNOWN",
		2: "UNWATCHED",
		3: "DELETED",
	}
	PCL_Status_value = map[string]int32{
		"PCL_STATUS_UNSPECIFIED": 0,
		"OK":                     0,
		"UNKNOWN":                1,
		"UNWATCHED":              2,
		"DELETED":                3,
	}
)

Enum value maps for PCL_Status.

View Source 
var File_go_chromium_org_luci_cv_internal_prjmanager_prjpb_events_proto protoreflect.FileDescriptor
View Source 
var File_go_chromium_org_luci_cv_internal_prjmanager_prjpb_storage_proto protoreflect.FileDescriptor
View Source 
var File_go_chromium_org_luci_cv_internal_prjmanager_prjpb_tasks_proto protoreflect.FileDescriptor

Functions

func FormatLogReasons 

func FormatLogReasons(in []LogReason) string

FormatLogReasons produces "[HUMAN, READABLE]" string for a list of statuses.

func InstallMockDispatcher 

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

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

See pmtest.MockDispatch().

func SortPRuns 

func SortPRuns(pruns []*PRun)

Types

type Component 

type Component struct {

	// CL IDs of the tracked CLs in this component. Sorted.
	//
	// Each referenced CL must be in PState.PCLs list.
	// Each referenced CL may have deps not in this list if they are either
	// PCL.Status.UNKNOWN or PCL.Status.UNWATCHED.
	//
	// A referenced CL is normally watched by this LUCI project. In rare cases,
	// referenced CL is no longer watched by this LUCI project but is still kept
	// in a component because the CL is still a member of an incomplete Run in
	// this component. In this case, the CL's deps are no longer tracked.
	Clids []int64 `protobuf:"varint,1,rep,packed,name=clids,proto3" json:"clids,omitempty"`
	// Decision time is the earliest time when this component should be
	// re-evaluated.
	//
	// Can be set to far future meaning no need for re-evaluation without an
	// external event (e.g., CLUpdated or RunFinished).
	DecisionTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=decision_time,json=decisionTime,proto3" json:"decision_time,omitempty"`
	// Incomplete Runs working on CLs from this component.
	//
	// Sorted by Run's ID.
	Pruns []*PRun `protobuf:"bytes,3,rep,name=pruns,proto3" json:"pruns,omitempty"`
	// If true, this component must be triaged as soon as possible.
	TriageRequired bool `protobuf:"varint,11,opt,name=triage_required,json=triageRequired,proto3" json:"triage_required,omitempty"`
	// contains filtered or unexported fields
}

Component is a set of CLs related to each other.

func (*Component) COWPRuns 

func (component *Component) COWPRuns(m func(*PRun) *PRun, toAdd []*PRun) ([]*PRun, bool)

COWPRuns copy-on-write modifies component's runs.

func (*Component) CloneShallow 

func (c *Component) CloneShallow() *Component

CloneShallow creates a new shallow clone.

func (*Component) Descriptor deprecated 

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

Deprecated: Use Component.ProtoReflect.Descriptor instead.

func (*Component) GetClids 

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

func (*Component) GetDecisionTime 

func (x *Component) GetDecisionTime() *timestamppb.Timestamp

func (*Component) GetPruns 

func (x *Component) GetPruns() []*PRun

func (*Component) GetTriageRequired 

func (x *Component) GetTriageRequired() bool

func (*Component) ProtoMessage 

func (*Component) ProtoMessage()

func (*Component) ProtoReflect 

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

func (*Component) Reset 

func (x *Component) Reset()

func (*Component) String 

func (x *Component) String() string

func (*Component) Validate 

func (m *Component) Validate() error

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

func (m *Component) ValidateAll() error

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

type ComponentMultiError 

type ComponentMultiError []error

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

func (ComponentMultiError) AllErrors 

func (m ComponentMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ComponentMultiError) Error 

func (m ComponentMultiError) Error() string

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

type ComponentValidationError 

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

ComponentValidationError is the validation error returned by Component.Validate if the designated constraints aren't met.

func (ComponentValidationError) Cause 

func (e ComponentValidationError) Cause() error

Cause function returns cause value.

func (ComponentValidationError) Error 

func (e ComponentValidationError) Error() string

Error satisfies the builtin error interface

func (ComponentValidationError) ErrorName 

func (e ComponentValidationError) ErrorName() string

ErrorName returns error name.

func (ComponentValidationError) Field 

func (e ComponentValidationError) Field() string

Field function returns field value.

func (ComponentValidationError) Key 

func (e ComponentValidationError) Key() bool

Key function returns key value.

func (ComponentValidationError) Reason 

func (e ComponentValidationError) Reason() string

Reason function returns reason value.

type Event 

type Event struct {

	// Types that are assignable to Event:
	//
	//	*Event_NewConfig
	//	*Event_Poke
	//	*Event_ClsUpdated
	//	*Event_RunCreated
	//	*Event_RunFinished
	//	*Event_PurgeCompleted
	//	*Event_TriggeringClDepsCompleted
	Event isEvent_Event `protobuf_oneof:"event"`
	// contains filtered or unexported fields
}

Event is a container for all kinds of events a project manager can receive.

func (*Event) Descriptor deprecated 

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetClsUpdated 

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

func (*Event) GetEvent 

func (m *Event) GetEvent() isEvent_Event

func (*Event) GetNewConfig 

func (x *Event) GetNewConfig() *NewConfig

func (*Event) GetPoke 

func (x *Event) GetPoke() *Poke

func (*Event) GetPurgeCompleted 

func (x *Event) GetPurgeCompleted() *PurgeCompleted

func (*Event) GetRunCreated 

func (x *Event) GetRunCreated() *RunCreated

func (*Event) GetRunFinished 

func (x *Event) GetRunFinished() *RunFinished

func (*Event) GetTriggeringClDepsCompleted 

func (x *Event) GetTriggeringClDepsCompleted() *TriggeringCLDepsCompleted

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect 

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

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) String 

func (x *Event) String() string

func (*Event) Validate 

func (m *Event) Validate() error

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

func (*Event) ValidateAll 

func (m *Event) ValidateAll() error

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

type EventMultiError 

type EventMultiError []error

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

func (EventMultiError) AllErrors 

func (m EventMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (EventMultiError) Error 

func (m EventMultiError) Error() string

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

type EventValidationError 

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

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

func (EventValidationError) Cause 

func (e EventValidationError) Cause() error

Cause function returns cause value.

func (EventValidationError) Error 

func (e EventValidationError) Error() string

Error satisfies the builtin error interface

func (EventValidationError) ErrorName 

func (e EventValidationError) ErrorName() string

ErrorName returns error name.

func (EventValidationError) Field 

func (e EventValidationError) Field() string

Field function returns field value.

func (EventValidationError) Key 

func (e EventValidationError) Key() bool

Key function returns key value.

func (EventValidationError) Reason 

func (e EventValidationError) Reason() string

Reason function returns reason value.

type Event_ClsUpdated 

type Event_ClsUpdated struct {
	ClsUpdated *changelist.CLUpdatedEvents `protobuf:"bytes,7,opt,name=cls_updated,json=clsUpdated,proto3,oneof"`
}

type Event_NewConfig 

type Event_NewConfig struct {
	NewConfig *NewConfig `protobuf:"bytes,1,opt,name=new_config,json=newConfig,proto3,oneof"`
}

type Event_Poke 

type Event_Poke struct {
	Poke *Poke `protobuf:"bytes,2,opt,name=poke,proto3,oneof"`
}

type Event_PurgeCompleted 

type Event_PurgeCompleted struct {
	PurgeCompleted *PurgeCompleted `protobuf:"bytes,6,opt,name=purge_completed,json=purgeCompleted,proto3,oneof"`
}

type Event_RunCreated 

type Event_RunCreated struct {
	RunCreated *RunCreated `protobuf:"bytes,4,opt,name=run_created,json=runCreated,proto3,oneof"`
}

type Event_RunFinished 

type Event_RunFinished struct {
	RunFinished *RunFinished `protobuf:"bytes,5,opt,name=run_finished,json=runFinished,proto3,oneof"`
}

type Event_TriggeringClDepsCompleted 

type Event_TriggeringClDepsCompleted struct {
	TriggeringClDepsCompleted *TriggeringCLDepsCompleted `protobuf:"bytes,9,opt,name=triggering_cl_deps_completed,json=triggeringClDepsCompleted,proto3,oneof"`
}

type KickManageProjectTask 

type KickManageProjectTask struct {
	LuciProject string                 `protobuf:"bytes,1,opt,name=luci_project,json=luciProject,proto3" json:"luci_project,omitempty"`
	Eta         *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=eta,proto3" json:"eta,omitempty"`
	// contains filtered or unexported fields
}

KickManageProjectTask starts a task to actually enqueue ManageProjectTask.

It exists in order to send a deduplicatable ManageProjectTask from a transaction.

Queue: "kick-manage-project".

func (*KickManageProjectTask) Descriptor deprecated 

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

Deprecated: Use KickManageProjectTask.ProtoReflect.Descriptor instead.

func (*KickManageProjectTask) GetEta 

func (x *KickManageProjectTask) GetEta() *timestamppb.Timestamp

func (*KickManageProjectTask) GetLuciProject 

func (x *KickManageProjectTask) GetLuciProject() string

func (*KickManageProjectTask) ProtoMessage 

func (*KickManageProjectTask) ProtoMessage()

func (*KickManageProjectTask) ProtoReflect 

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

func (*KickManageProjectTask) Reset 

func (x *KickManageProjectTask) Reset()

func (*KickManageProjectTask) String 

func (x *KickManageProjectTask) String() string

func (*KickManageProjectTask) Validate 

func (m *KickManageProjectTask) Validate() error

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

func (m *KickManageProjectTask) ValidateAll() error

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

type KickManageProjectTaskMultiError 

type KickManageProjectTaskMultiError []error

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

func (KickManageProjectTaskMultiError) AllErrors 

func (m KickManageProjectTaskMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (KickManageProjectTaskMultiError) Error 

func (m KickManageProjectTaskMultiError) Error() string

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

type KickManageProjectTaskValidationError 

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

KickManageProjectTaskValidationError is the validation error returned by KickManageProjectTask.Validate if the designated constraints aren't met.

func (KickManageProjectTaskValidationError) Cause 

func (e KickManageProjectTaskValidationError) Cause() error

Cause function returns cause value.

func (KickManageProjectTaskValidationError) Error 

func (e KickManageProjectTaskValidationError) Error() string

Error satisfies the builtin error interface

func (KickManageProjectTaskValidationError) ErrorName 

func (e KickManageProjectTaskValidationError) ErrorName() string

ErrorName returns error name.

func (KickManageProjectTaskValidationError) Field 

func (e KickManageProjectTaskValidationError) Field() string

Field function returns field value.

func (KickManageProjectTaskValidationError) Key 

func (e KickManageProjectTaskValidationError) Key() bool

Key function returns key value.

func (KickManageProjectTaskValidationError) Reason 

func (e KickManageProjectTaskValidationError) Reason() string

Reason function returns reason value.

type LogReason 

type LogReason int32

LogReason records why a change to the project state was logged.

See ProjectLog entity. 

const (
	LogReason_LOG_REASON_UNSPECIFIED LogReason = 0
	// Due to passage of time or number of versions.
	LogReason_FYI_PERIODIC   LogReason = 1
	LogReason_STATUS_CHANGED LogReason = 2
	LogReason_CONFIG_CHANGED LogReason = 3
	// On-demand save for debugging reasons, e.g. on caught panic.
	LogReason_DEBUG LogReason = 4
)

func SortAndDedupeLogReasons 

func SortAndDedupeLogReasons(in []LogReason) []LogReason

SortAndDedupeLogReasons does what its name says without modifying input.

func (LogReason) Descriptor 

func (LogReason) Descriptor() protoreflect.EnumDescriptor

func (LogReason) Enum 

func (x LogReason) Enum() *LogReason

func (LogReason) EnumDescriptor deprecated 

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

Deprecated: Use LogReason.Descriptor instead.

func (LogReason) Number 

func (x LogReason) Number() protoreflect.EnumNumber

func (LogReason) String 

func (x LogReason) String() string

func (LogReason) Type 

func (LogReason) Type() protoreflect.EnumType

type LogReasons 

type LogReasons struct {
	Reasons []LogReason `protobuf:"varint,1,rep,packed,name=reasons,proto3,enum=cv.internal.prjmanager.prjpb.LogReason" json:"reasons,omitempty"`
	// contains filtered or unexported fields
}

func (*LogReasons) Descriptor deprecated 

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

Deprecated: Use LogReasons.ProtoReflect.Descriptor instead.

func (*LogReasons) GetReasons 

func (x *LogReasons) GetReasons() []LogReason

func (*LogReasons) ProtoMessage 

func (*LogReasons) ProtoMessage()

func (*LogReasons) ProtoReflect 

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

func (*LogReasons) Reset 

func (x *LogReasons) Reset()

func (*LogReasons) String 

func (x *LogReasons) String() string

func (*LogReasons) Validate 

func (m *LogReasons) Validate() error

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

func (m *LogReasons) ValidateAll() error

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

type LogReasonsMultiError 

type LogReasonsMultiError []error

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

func (LogReasonsMultiError) AllErrors 

func (m LogReasonsMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LogReasonsMultiError) Error 

func (m LogReasonsMultiError) Error() string

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

type LogReasonsValidationError 

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

LogReasonsValidationError is the validation error returned by LogReasons.Validate if the designated constraints aren't met.

func (LogReasonsValidationError) Cause 

func (e LogReasonsValidationError) Cause() error

Cause function returns cause value.

func (LogReasonsValidationError) Error 

func (e LogReasonsValidationError) Error() string

Error satisfies the builtin error interface

func (LogReasonsValidationError) ErrorName 

func (e LogReasonsValidationError) ErrorName() string

ErrorName returns error name.

func (LogReasonsValidationError) Field 

func (e LogReasonsValidationError) Field() string

Field function returns field value.

func (LogReasonsValidationError) Key 

func (e LogReasonsValidationError) Key() bool

Key function returns key value.

func (LogReasonsValidationError) Reason 

func (e LogReasonsValidationError) Reason() string

Reason function returns reason value.

type ManageProjectTask 

type ManageProjectTask struct {
	LuciProject string                 `protobuf:"bytes,1,opt,name=luci_project,json=luciProject,proto3" json:"luci_project,omitempty"`
	Eta         *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=eta,proto3" json:"eta,omitempty"`
	// contains filtered or unexported fields
}

ManageProjectTask sends a signal to ProjectManager to process events.

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

Queue: "manage-project".

func (*ManageProjectTask) Descriptor deprecated 

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

Deprecated: Use ManageProjectTask.ProtoReflect.Descriptor instead.

func (*ManageProjectTask) GetEta 

func (x *ManageProjectTask) GetEta() *timestamppb.Timestamp

func (*ManageProjectTask) GetLuciProject 

func (x *ManageProjectTask) GetLuciProject() string

func (*ManageProjectTask) ProtoMessage 

func (*ManageProjectTask) ProtoMessage()

func (*ManageProjectTask) ProtoReflect 

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

func (*ManageProjectTask) Reset 

func (x *ManageProjectTask) Reset()

func (*ManageProjectTask) String 

func (x *ManageProjectTask) String() string

func (*ManageProjectTask) Validate 

func (m *ManageProjectTask) Validate() error

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

func (m *ManageProjectTask) ValidateAll() error

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

type ManageProjectTaskMultiError 

type ManageProjectTaskMultiError []error

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

func (ManageProjectTaskMultiError) AllErrors 

func (m ManageProjectTaskMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ManageProjectTaskMultiError) Error 

func (m ManageProjectTaskMultiError) Error() string

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

type ManageProjectTaskValidationError 

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

ManageProjectTaskValidationError is the validation error returned by ManageProjectTask.Validate if the designated constraints aren't met.

func (ManageProjectTaskValidationError) Cause 

func (e ManageProjectTaskValidationError) Cause() error

Cause function returns cause value.

func (ManageProjectTaskValidationError) Error 

func (e ManageProjectTaskValidationError) Error() string

Error satisfies the builtin error interface

func (ManageProjectTaskValidationError) ErrorName 

func (e ManageProjectTaskValidationError) ErrorName() string

ErrorName returns error name.

func (ManageProjectTaskValidationError) Field 

func (e ManageProjectTaskValidationError) Field() string

Field function returns field value.

func (ManageProjectTaskValidationError) Key 

func (e ManageProjectTaskValidationError) Key() bool

Key function returns key value.

func (ManageProjectTaskValidationError) Reason 

func (e ManageProjectTaskValidationError) Reason() string

Reason function returns reason value.

type NewConfig 

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

NewConfig is sent to PM by Project Config updater upon saving newest config in datastore.

func (*NewConfig) Descriptor deprecated 

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

Deprecated: Use NewConfig.ProtoReflect.Descriptor instead.

func (*NewConfig) ProtoMessage 

func (*NewConfig) ProtoMessage()

func (*NewConfig) ProtoReflect 

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

func (*NewConfig) Reset 

func (x *NewConfig) Reset()

func (*NewConfig) String 

func (x *NewConfig) String() string

func (*NewConfig) Validate 

func (m *NewConfig) Validate() error

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

func (*NewConfig) ValidateAll 

func (m *NewConfig) ValidateAll() error

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

type NewConfigMultiError 

type NewConfigMultiError []error

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

func (NewConfigMultiError) AllErrors 

func (m NewConfigMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (NewConfigMultiError) Error 

func (m NewConfigMultiError) Error() string

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

type NewConfigValidationError 

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

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

func (NewConfigValidationError) Cause 

func (e NewConfigValidationError) Cause() error

Cause function returns cause value.

func (NewConfigValidationError) Error 

func (e NewConfigValidationError) Error() string

Error satisfies the builtin error interface

func (NewConfigValidationError) ErrorName 

func (e NewConfigValidationError) ErrorName() string

ErrorName returns error name.

func (NewConfigValidationError) Field 

func (e NewConfigValidationError) Field() string

Field function returns field value.

func (NewConfigValidationError) Key 

func (e NewConfigValidationError) Key() bool

Key function returns key value.

func (NewConfigValidationError) Reason 

func (e NewConfigValidationError) Reason() string

Reason function returns reason value.

type PCL 

type PCL struct {
	Clid     int64      `protobuf:"varint,1,opt,name=clid,proto3" json:"clid,omitempty"`
	Eversion int64      `protobuf:"varint,2,opt,name=eversion,proto3" json:"eversion,omitempty"`
	Status   PCL_Status `protobuf:"varint,3,opt,name=status,proto3,enum=cv.internal.prjmanager.prjpb.PCL_Status" json:"status,omitempty"`
	// Indexes in PState.config_group_names identifying ConfigGroup which watches
	// this CL.
	//
	// Normally, contains exactly 1 index.
	// May have > 1 index, which means 2+ non-fallback config groups watch this
	// CL, which is not allowed and will be signalled to CV users.
	// TODO(tandrii): move >1 index case to be tracked via `errors` field.
	ConfigGroupIndexes []int32 `protobuf:"varint,4,rep,packed,name=config_group_indexes,json=configGroupIndexes,proto3" json:"config_group_indexes,omitempty"`
	// Deps refers to CLs in PState.PCLs which are dependencies of the PCL.
	Deps []*changelist.Dep `protobuf:"bytes,11,rep,name=deps,proto3" json:"deps,omitempty"`
	// Triggers are the triggers currently active on the CL.
	//
	// Note that due to NewPatchsetRuns, CLs can be associated with more than one
	// Run at any given time, for this reason, it is required that a PCL be able
	// to track multiple triggers.
	//
	// It may be empty if CL is not triggered but nevertheless tracked as either:
	//   - a dependency of another CL.
	//   - previously triggered member of an incomplete Run, which is probably
	//     being finalized right now by its Run Manager.
	//
	// Doesn't store email nor Gerrit account ID.
	Triggers *run.Triggers `protobuf:"bytes,16,opt,name=triggers,proto3" json:"triggers,omitempty"`
	// Submitted means CV isn't going to work on a CL, but CL is still tracked as
	// a dep of another CL or as a member of an incomplete Run (though the other
	// Run will probably finish soon).
	Submitted bool `protobuf:"varint,13,opt,name=submitted,proto3" json:"submitted,omitempty"`
	// Deprecated in favor of purge_reasons.
	//
	// Deprecated: Marked as deprecated in go.chromium.org/luci/cv/internal/prjmanager/prjpb/storage.proto.
	Errors []*changelist.CLError `protobuf:"bytes,15,rep,name=errors,proto3" json:"errors,omitempty"`
	// If set, describes problems that require that some or all of the PCL's
	// triggers be purged.
	PurgeReasons []*PurgeReason `protobuf:"bytes,17,rep,name=purge_reasons,json=purgeReasons,proto3" json:"purge_reasons,omitempty"`
	// Outdated if set means Snapshot must be considered likely outdated due to
	// recent CV mutations.
	//
	// In particular, Project Manager does not act on the CLs with .Outdated set.
	Outdated *changelist.Snapshot_Outdated `protobuf:"bytes,18,opt,name=outdated,proto3" json:"outdated,omitempty"`
	// contains filtered or unexported fields
}

PCL is a tracked CL.

func (*PCL) Descriptor deprecated 

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

Deprecated: Use PCL.ProtoReflect.Descriptor instead.

func (*PCL) GetClid 

func (x *PCL) GetClid() int64

func (*PCL) GetConfigGroupIndexes 

func (x *PCL) GetConfigGroupIndexes() []int32

func (*PCL) GetDeps 

func (x *PCL) GetDeps() []*changelist.Dep

func (*PCL) GetErrors deprecated 

func (x *PCL) GetErrors() []*changelist.CLError

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

func (*PCL) GetEversion 

func (x *PCL) GetEversion() int64

func (*PCL) GetOutdated 

func (x *PCL) GetOutdated() *changelist.Snapshot_Outdated

func (*PCL) GetPurgeReasons 

func (x *PCL) GetPurgeReasons() []*PurgeReason

func (*PCL) GetStatus 

func (x *PCL) GetStatus() PCL_Status

func (*PCL) GetSubmitted 

func (x *PCL) GetSubmitted() bool

func (*PCL) GetTriggers 

func (x *PCL) GetTriggers() *run.Triggers

func (*PCL) ProtoMessage 

func (*PCL) ProtoMessage()

func (*PCL) ProtoReflect 

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

func (*PCL) Reset 

func (x *PCL) Reset()

func (*PCL) String 

func (x *PCL) String() string

func (*PCL) Validate 

func (m *PCL) Validate() error

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

func (m *PCL) ValidateAll() error

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

type PCLMultiError 

type PCLMultiError []error

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

func (PCLMultiError) AllErrors 

func (m PCLMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PCLMultiError) Error 

func (m PCLMultiError) Error() string

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

type PCLValidationError 

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

PCLValidationError is the validation error returned by PCL.Validate if the designated constraints aren't met.

func (PCLValidationError) Cause 

func (e PCLValidationError) Cause() error

Cause function returns cause value.

func (PCLValidationError) Error 

func (e PCLValidationError) Error() string

Error satisfies the builtin error interface

func (PCLValidationError) ErrorName 

func (e PCLValidationError) ErrorName() string

ErrorName returns error name.

func (PCLValidationError) Field 

func (e PCLValidationError) Field() string

Field function returns field value.

func (PCLValidationError) Key 

func (e PCLValidationError) Key() bool

Key function returns key value.

func (PCLValidationError) Reason 

func (e PCLValidationError) Reason() string

Reason function returns reason value.

type PCL_Status 

type PCL_Status int32
const (
	PCL_PCL_STATUS_UNSPECIFIED PCL_Status = 0
	// OK means CL metadata below is correct and CL is watched by this project.
	//
	// Value 0 is chosen such that it's not serialized, since this is the most
	// common state.
	PCL_OK PCL_Status = 0
	// UNKNOWN means Datastore CL entity doesn't have the info yet.
	PCL_UNKNOWN PCL_Status = 1
	// UNWATCHED means CL isn't watched by this LUCI project.
	PCL_UNWATCHED PCL_Status = 2
	// DELETED means CL's Datastore entity got deleted.
	//
	// This is used to temporary mark a PCL before deleting it entirely from
	// PState to avoid dangling references from components.
	PCL_DELETED PCL_Status = 3
)

func (PCL_Status) Descriptor 

func (PCL_Status) Descriptor() protoreflect.EnumDescriptor

func (PCL_Status) Enum 

func (x PCL_Status) Enum() *PCL_Status

func (PCL_Status) EnumDescriptor deprecated 

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

Deprecated: Use PCL_Status.Descriptor instead.

func (PCL_Status) Number 

func (x PCL_Status) Number() protoreflect.EnumNumber

func (PCL_Status) String 

func (x PCL_Status) String() string

func (PCL_Status) Type 

func (PCL_Status) Type() protoreflect.EnumType

type PRun 

type PRun struct {

	// CV's Run ID.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// IDs of CLs involved. Sorted.
	//
	// Actual Run may orders its CLs in a different way.
	Clids []int64 `protobuf:"varint,2,rep,packed,name=clids,proto3" json:"clids,omitempty"`
	// The mode of the Run referenced by this message.
	//
	// It uses the string value of run.Mode.
	Mode string `protobuf:"bytes,3,opt,name=mode,proto3" json:"mode,omitempty"`
	// ID of the root CL that triggers this Run in the combined mode.
	//
	// It is the same as `run.root_cl`.
	RootClid int64 `protobuf:"varint,4,opt,name=root_clid,json=rootClid,proto3" json:"root_clid,omitempty"`
	// contains filtered or unexported fields
}

PRun is an incomplete Run on which CV is currently working.

It is referenced by at most 1 component.

func MakePRun 

func MakePRun(r *run.Run) *PRun

MakePRun creates a PRun given a Run.

func (*PRun) Descriptor deprecated 

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

Deprecated: Use PRun.ProtoReflect.Descriptor instead.

func (*PRun) GetClids 

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

func (*PRun) GetId 

func (x *PRun) GetId() string

func (*PRun) GetMode 

func (x *PRun) GetMode() string

func (*PRun) GetRootClid 

func (x *PRun) GetRootClid() int64

func (*PRun) ProtoMessage 

func (*PRun) ProtoMessage()

func (*PRun) ProtoReflect 

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

func (*PRun) Reset 

func (x *PRun) Reset()

func (*PRun) String 

func (x *PRun) String() string

func (*PRun) Validate 

func (m *PRun) Validate() error

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

func (m *PRun) ValidateAll() error

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

type PRunMultiError 

type PRunMultiError []error

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

func (PRunMultiError) AllErrors 

func (m PRunMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PRunMultiError) Error 

func (m PRunMultiError) Error() string

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

type PRunValidationError 

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

PRunValidationError is the validation error returned by PRun.Validate if the designated constraints aren't met.

func (PRunValidationError) Cause 

func (e PRunValidationError) Cause() error

Cause function returns cause value.

func (PRunValidationError) Error 

func (e PRunValidationError) Error() string

Error satisfies the builtin error interface

func (PRunValidationError) ErrorName 

func (e PRunValidationError) ErrorName() string

ErrorName returns error name.

func (PRunValidationError) Field 

func (e PRunValidationError) Field() string

Field function returns field value.

func (PRunValidationError) Key 

func (e PRunValidationError) Key() bool

Key function returns key value.

func (PRunValidationError) Reason 

func (e PRunValidationError) Reason() string

Reason function returns reason value.

type PState 

type PState struct {

	// Name of LUCI project.
	LuciProject string `protobuf:"bytes,1,opt,name=luci_project,json=luciProject,proto3" json:"luci_project,omitempty"`
	// Status of the Project.
	Status Status `protobuf:"varint,2,opt,name=status,proto3,enum=cv.internal.prjmanager.prjpb.Status" json:"status,omitempty"`
	// Config hash pins specific project config version.
	ConfigHash string `protobuf:"bytes,3,opt,name=config_hash,json=configHash,proto3" json:"config_hash,omitempty"`
	// Config group names intern the names referenced in PCL entities to reduce
	// memory and at-rest footprint.
	//
	// See also https://en.wikipedia.org/wiki/String_interning.
	ConfigGroupNames []string `protobuf:"bytes,4,rep,name=config_group_names,json=configGroupNames,proto3" json:"config_group_names,omitempty"`
	// PCLs are currently tracked CLs.
	//
	// Includes deps which are of not yet known kind (because CL doesn't yet have
	// a snapshot) or unwatched.
	//
	// Sorted by CL ID.
	Pcls []*PCL `protobuf:"bytes,11,rep,name=pcls,proto3" json:"pcls,omitempty"`
	// Components are a partition of CLs in the list above.
	//
	// An active CL (watched or used to be watched and still member of a Run) may
	// belong to at most 1 component, while unwatched dep may be referenced by
	// several.
	Components []*Component `protobuf:"bytes,12,rep,name=components,proto3" json:"components,omitempty"`
	// PurgingCLs are CLs currently being purged.
	//
	// They are tracked in PState to avoid creating Runs with such CLs.
	//
	// A CL being purged does not necessarily have a corresponding PCL.
	// A PurgingCL is kept in PState until purging process stops, regardless of
	// whether purging was successful or failed.
	//
	// See more in PurgingCL doc.
	//
	// Sorted by CL ID.
	PurgingCls []*PurgingCL `protobuf:"bytes,13,rep,name=purging_cls,json=purgingCls,proto3" json:"purging_cls,omitempty"`
	// TriggeringCLDeps are the CLs of which deps are being triggered.
	//
	// They are tracked in PState to avoid creating duplicate triggering tasks.
	//
	// Sorted by the origin ID.
	TriggeringClDeps []*TriggeringCLDeps `protobuf:"bytes,15,rep,name=triggering_cl_deps,json=triggeringClDeps,proto3" json:"triggering_cl_deps,omitempty"`
	// If true, components partition must be redone as soon as possible.
	RepartitionRequired bool `protobuf:"varint,21,opt,name=repartition_required,json=repartitionRequired,proto3" json:"repartition_required,omitempty"`
	// PRuns which can't yet be added to any component but should be. Sorted by
	// Run ID.
	//
	// In response to OnRunCreated event, PM may append to this list new Runs if
	// either:
	//   - not all Run's CLs are already known to PM;
	//   - Run's CLs are currently partitioned into different components.
	//
	// Thus,
	//   - CLs referenced by these PRuns may not be tracked;
	//   - If this field is not empty, re-partioning may be required.
	CreatedPruns []*PRun `protobuf:"bytes,22,rep,name=created_pruns,json=createdPruns,proto3" json:"created_pruns,omitempty"`
	// If set, establishes when components should be re-evaluated.
	NextEvalTime *timestamppb.Timestamp `protobuf:"bytes,23,opt,name=next_eval_time,json=nextEvalTime,proto3" json:"next_eval_time,omitempty"`
	// contains filtered or unexported fields
}

PState is the PM state of a specific LUCI project.

Semantically, it's a collection of CLs somehow grouped into components (see Component message below), each of which may have several active (a.k.a. Incomplete) Runs valid at a specific project's config version.

Most CLs are watched by the LUCI project, but to assist with error reporting, it also tracks unwatched CLs if they are dependencies of some actually watched CLs.

func (*PState) COWComponents 

func (p *PState) COWComponents(m func(*Component) *Component, toAdd []*Component) ([]*Component, bool)

COWComponents copy-on-write modifies components.

func (*PState) COWCreatedRuns 

func (p *PState) COWCreatedRuns(m func(*PRun) *PRun, toAdd []*PRun) ([]*PRun, bool)

COWCreatedRuns copy-on-write modifies CreatedRuns.

func (*PState) COWPCLs 

func (p *PState) COWPCLs(m func(*PCL) *PCL, toAdd []*PCL) ([]*PCL, bool)

COWPCLs copy-on-write modifies PCLs.

func (*PState) COWPurgingCLs 

func (p *PState) COWPurgingCLs(m func(*PurgingCL) *PurgingCL, toAdd []*PurgingCL) ([]*PurgingCL, bool)

COWPurgingCLs copy-on-write modifies PurgingCLs.

func (*PState) COWTriggeringCLDeps 

func (p *PState) COWTriggeringCLDeps(m func(*TriggeringCLDeps) *TriggeringCLDeps, toAdd []*TriggeringCLDeps) ([]*TriggeringCLDeps, bool)

COWTriggeringCLDeps copy-on-write modifies TriggeringCLDeps.

func (*PState) Descriptor deprecated 

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

Deprecated: Use PState.ProtoReflect.Descriptor instead.

func (*PState) GetComponents 

func (x *PState) GetComponents() []*Component

func (*PState) GetConfigGroupNames 

func (x *PState) GetConfigGroupNames() []string

func (*PState) GetConfigHash 

func (x *PState) GetConfigHash() string

func (*PState) GetCreatedPruns 

func (x *PState) GetCreatedPruns() []*PRun

func (*PState) GetLuciProject 

func (x *PState) GetLuciProject() string

func (*PState) GetNextEvalTime 

func (x *PState) GetNextEvalTime() *timestamppb.Timestamp

func (*PState) GetPCL 

func (p *PState) GetPCL(clid int64) *PCL

GetPCL returns the PCL of a given clid or nil, if not found.

func (*PState) GetPcls 

func (x *PState) GetPcls() []*PCL

func (*PState) GetPurgingCL 

func (p *PState) GetPurgingCL(clid int64) *PurgingCL

GetPurgingCL returns the PurgingCL of a given clid or nil, if not found.

func (*PState) GetPurgingCls 

func (x *PState) GetPurgingCls() []*PurgingCL

func (*PState) GetRepartitionRequired 

func (x *PState) GetRepartitionRequired() bool

func (*PState) GetStatus 

func (x *PState) GetStatus() Status

func (*PState) GetTriggeringCLDeps 

func (p *PState) GetTriggeringCLDeps(clid int64) *TriggeringCLDeps

GetTriggeringCLDeps returns the TriggeringCLDeps of a given origin clid.

Returns nil, if not found.

func (*PState) GetTriggeringClDeps 

func (x *PState) GetTriggeringClDeps() []*TriggeringCLDeps

func (*PState) IncompleteRuns 

func (p *PState) IncompleteRuns() (ids common.RunIDs)

IncompleteRuns are IDs of Runs which aren't yet completed.

func (*PState) IterIncompleteRuns 

func (p *PState) IterIncompleteRuns(callback func(r *PRun, c *Component) (stop bool))

IterIncompleteRuns executes callback on each tracked Run.

Callback is given a Component if Run is assigned to a component, or a nil Component if Run is part of `.CreatedRuns` not yet assigned to any component. Stops iteration if callback returns true.

func (*PState) ProtoMessage 

func (*PState) ProtoMessage()

func (*PState) ProtoReflect 

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

func (*PState) Reset 

func (x *PState) Reset()

func (*PState) String 

func (x *PState) String() string

func (*PState) Validate 

func (m *PState) Validate() error

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

func (m *PState) ValidateAll() error

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

type PStateMultiError 

type PStateMultiError []error

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

func (PStateMultiError) AllErrors 

func (m PStateMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PStateMultiError) Error 

func (m PStateMultiError) Error() string

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

type PStateValidationError 

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

PStateValidationError is the validation error returned by PState.Validate if the designated constraints aren't met.

func (PStateValidationError) Cause 

func (e PStateValidationError) Cause() error

Cause function returns cause value.

func (PStateValidationError) Error 

func (e PStateValidationError) Error() string

Error satisfies the builtin error interface

func (PStateValidationError) ErrorName 

func (e PStateValidationError) ErrorName() string

ErrorName returns error name.

func (PStateValidationError) Field 

func (e PStateValidationError) Field() string

Field function returns field value.

func (PStateValidationError) Key 

func (e PStateValidationError) Key() bool

Key function returns key value.

func (PStateValidationError) Reason 

func (e PStateValidationError) Reason() string

Reason function returns reason value.

type Poke 

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

Poke is sent to PM by Project Config updater.

func (*Poke) Descriptor deprecated 

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

Deprecated: Use Poke.ProtoReflect.Descriptor instead.

func (*Poke) ProtoMessage 

func (*Poke) ProtoMessage()

func (*Poke) ProtoReflect 

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

func (*Poke) Reset 

func (x *Poke) Reset()

func (*Poke) String 

func (x *Poke) String() string

func (*Poke) Validate 

func (m *Poke) Validate() error

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

func (*Poke) ValidateAll 

func (m *Poke) ValidateAll() error

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

type PokeMultiError 

type PokeMultiError []error

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

func (PokeMultiError) AllErrors 

func (m PokeMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PokeMultiError) Error 

func (m PokeMultiError) Error() string

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

type PokeValidationError 

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

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

func (PokeValidationError) Cause 

func (e PokeValidationError) Cause() error

Cause function returns cause value.

func (PokeValidationError) Error 

func (e PokeValidationError) Error() string

Error satisfies the builtin error interface

func (PokeValidationError) ErrorName 

func (e PokeValidationError) ErrorName() string

ErrorName returns error name.

func (PokeValidationError) Field 

func (e PokeValidationError) Field() string

Field function returns field value.

func (PokeValidationError) Key 

func (e PokeValidationError) Key() bool

Key function returns key value.

func (PokeValidationError) Reason 

func (e PokeValidationError) Reason() string

Reason function returns reason value.

type PurgeCLTask 

type PurgeCLTask struct {
	LuciProject  string         `protobuf:"bytes,1,opt,name=luci_project,json=luciProject,proto3" json:"luci_project,omitempty"`
	PurgingCl    *PurgingCL     `protobuf:"bytes,2,opt,name=purging_cl,json=purgingCl,proto3" json:"purging_cl,omitempty"`
	PurgeReasons []*PurgeReason `protobuf:"bytes,7,rep,name=purge_reasons,json=purgeReasons,proto3" json:"purge_reasons,omitempty"`
	// Applicable config groups of this CL within the given LUCI Project.
	ConfigGroups []string `protobuf:"bytes,6,rep,name=config_groups,json=configGroups,proto3" json:"config_groups,omitempty"`
	// contains filtered or unexported fields
}

PurgeCLTask starts a task to purge a CL.

Queue: "purge-project-cl".

func (*PurgeCLTask) Descriptor deprecated 

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

Deprecated: Use PurgeCLTask.ProtoReflect.Descriptor instead.

func (*PurgeCLTask) GetConfigGroups 

func (x *PurgeCLTask) GetConfigGroups() []string

func (*PurgeCLTask) GetLuciProject 

func (x *PurgeCLTask) GetLuciProject() string

func (*PurgeCLTask) GetPurgeReasons 

func (x *PurgeCLTask) GetPurgeReasons() []*PurgeReason

func (*PurgeCLTask) GetPurgingCl 

func (x *PurgeCLTask) GetPurgingCl() *PurgingCL

func (*PurgeCLTask) ProtoMessage 

func (*PurgeCLTask) ProtoMessage()

func (*PurgeCLTask) ProtoReflect 

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

func (*PurgeCLTask) Reset 

func (x *PurgeCLTask) Reset()

func (*PurgeCLTask) String 

func (x *PurgeCLTask) String() string

func (*PurgeCLTask) Validate 

func (m *PurgeCLTask) Validate() error

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

func (m *PurgeCLTask) ValidateAll() error

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

type PurgeCLTaskMultiError 

type PurgeCLTaskMultiError []error

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

func (PurgeCLTaskMultiError) AllErrors 

func (m PurgeCLTaskMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PurgeCLTaskMultiError) Error 

func (m PurgeCLTaskMultiError) Error() string

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

type PurgeCLTaskValidationError 

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

PurgeCLTaskValidationError is the validation error returned by PurgeCLTask.Validate if the designated constraints aren't met.

func (PurgeCLTaskValidationError) Cause 

func (e PurgeCLTaskValidationError) Cause() error

Cause function returns cause value.

func (PurgeCLTaskValidationError) Error 

func (e PurgeCLTaskValidationError) Error() string

Error satisfies the builtin error interface

func (PurgeCLTaskValidationError) ErrorName 

func (e PurgeCLTaskValidationError) ErrorName() string

ErrorName returns error name.

func (PurgeCLTaskValidationError) Field 

func (e PurgeCLTaskValidationError) Field() string

Field function returns field value.

func (PurgeCLTaskValidationError) Key 

func (e PurgeCLTaskValidationError) Key() bool

Key function returns key value.

func (PurgeCLTaskValidationError) Reason 

func (e PurgeCLTaskValidationError) Reason() string

Reason function returns reason value.

type PurgeCompleted 

type PurgeCompleted struct {

	// Operation ID suffices to identify a purge.
	OperationId string `protobuf:"bytes,1,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"`
	// ID of the CL that was purged.
	Clid int64 `protobuf:"varint,2,opt,name=clid,proto3" json:"clid,omitempty"`
	// contains filtered or unexported fields
}

PurgingCompleted is sent to PM by TQ task purging a CL.

See storage.proto:PurgingCL doc.

There is no status of the purge because it's the CL state that matters, hence success or failure will reach PM via CLUpdatedEvent.

func (*PurgeCompleted) Descriptor deprecated 

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

Deprecated: Use PurgeCompleted.ProtoReflect.Descriptor instead.

func (*PurgeCompleted) GetClid 

func (x *PurgeCompleted) GetClid() int64

func (*PurgeCompleted) GetOperationId 

func (x *PurgeCompleted) GetOperationId() string

func (*PurgeCompleted) ProtoMessage 

func (*PurgeCompleted) ProtoMessage()

func (*PurgeCompleted) ProtoReflect 

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

func (*PurgeCompleted) Reset 

func (x *PurgeCompleted) Reset()

func (*PurgeCompleted) String 

func (x *PurgeCompleted) String() string

func (*PurgeCompleted) Validate 

func (m *PurgeCompleted) Validate() error

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

func (m *PurgeCompleted) ValidateAll() error

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

type PurgeCompletedMultiError 

type PurgeCompletedMultiError []error

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

func (PurgeCompletedMultiError) AllErrors 

func (m PurgeCompletedMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PurgeCompletedMultiError) Error 

func (m PurgeCompletedMultiError) Error() string

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

type PurgeCompletedValidationError 

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

PurgeCompletedValidationError is the validation error returned by PurgeCompleted.Validate if the designated constraints aren't met.

func (PurgeCompletedValidationError) Cause 

func (e PurgeCompletedValidationError) Cause() error

Cause function returns cause value.

func (PurgeCompletedValidationError) Error 

func (e PurgeCompletedValidationError) Error() string

Error satisfies the builtin error interface

func (PurgeCompletedValidationError) ErrorName 

func (e PurgeCompletedValidationError) ErrorName() string

ErrorName returns error name.

func (PurgeCompletedValidationError) Field 

func (e PurgeCompletedValidationError) Field() string

Field function returns field value.

func (PurgeCompletedValidationError) Key 

func (e PurgeCompletedValidationError) Key() bool

Key function returns key value.

func (PurgeCompletedValidationError) Reason 

func (e PurgeCompletedValidationError) Reason() string

Reason function returns reason value.

type PurgeReason 

type PurgeReason struct {

	// ClErrors are a list of errors associated with Trigger below, or with the
	// a whole CL if Trigger is not given.
	ClError *changelist.CLError `protobuf:"bytes,1,opt,name=cl_error,json=clError,proto3" json:"cl_error,omitempty"`
	// What trigger(s) the error above applies to.
	//
	// Types that are assignable to ApplyTo:
	//
	//	*PurgeReason_Triggers
	//	*PurgeReason_AllActiveTriggers
	ApplyTo isPurgeReason_ApplyTo `protobuf_oneof:"apply_to"`
	// contains filtered or unexported fields
}

PurgeReason represent a list of errors with the CL that would require that the given trigger (or the whole CL if no trigger is given) be purged.

Trying to purge multiple triggers of the same type on the same CL will result in only purging one of them. This is not possible today, but may have an unexpected effect on future features.

func (*PurgeReason) Descriptor deprecated 

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

Deprecated: Use PurgeReason.ProtoReflect.Descriptor instead.

func (*PurgeReason) GetAllActiveTriggers 

func (x *PurgeReason) GetAllActiveTriggers() bool

func (*PurgeReason) GetApplyTo 

func (m *PurgeReason) GetApplyTo() isPurgeReason_ApplyTo

func (*PurgeReason) GetClError 

func (x *PurgeReason) GetClError() *changelist.CLError

func (*PurgeReason) GetTriggers 

func (x *PurgeReason) GetTriggers() *run.Triggers

func (*PurgeReason) ProtoMessage 

func (*PurgeReason) ProtoMessage()

func (*PurgeReason) ProtoReflect 

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

func (*PurgeReason) Reset 

func (x *PurgeReason) Reset()

func (*PurgeReason) String 

func (x *PurgeReason) String() string

func (*PurgeReason) Validate 

func (m *PurgeReason) Validate() error

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

func (m *PurgeReason) ValidateAll() error

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

type PurgeReasonMultiError 

type PurgeReasonMultiError []error

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

func (PurgeReasonMultiError) AllErrors 

func (m PurgeReasonMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PurgeReasonMultiError) Error 

func (m PurgeReasonMultiError) Error() string

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

type PurgeReasonValidationError 

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

PurgeReasonValidationError is the validation error returned by PurgeReason.Validate if the designated constraints aren't met.

func (PurgeReasonValidationError) Cause 

func (e PurgeReasonValidationError) Cause() error

Cause function returns cause value.

func (PurgeReasonValidationError) Error 

func (e PurgeReasonValidationError) Error() string

Error satisfies the builtin error interface

func (PurgeReasonValidationError) ErrorName 

func (e PurgeReasonValidationError) ErrorName() string

ErrorName returns error name.

func (PurgeReasonValidationError) Field 

func (e PurgeReasonValidationError) Field() string

Field function returns field value.

func (PurgeReasonValidationError) Key 

func (e PurgeReasonValidationError) Key() bool

Key function returns key value.

func (PurgeReasonValidationError) Reason 

func (e PurgeReasonValidationError) Reason() string

Reason function returns reason value.

type PurgeReason_AllActiveTriggers 

type PurgeReason_AllActiveTriggers struct {
	AllActiveTriggers bool `protobuf:"varint,3,opt,name=all_active_triggers,json=allActiveTriggers,proto3,oneof"`
}

type PurgeReason_Triggers 

type PurgeReason_Triggers struct {
	Triggers *run.Triggers `protobuf:"bytes,2,opt,name=triggers,proto3,oneof"`
}

type PurgingCL 

type PurgingCL struct {

	// CL ID which is being purged.
	Clid int64 `protobuf:"varint,1,opt,name=clid,proto3" json:"clid,omitempty"`
	// Operation ID is a unique within a project identifier of a purge operation
	// to use in PurgeCompleted events.
	OperationId string `protobuf:"bytes,2,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"`
	// Deadline is obeyed by the purging TQ task.
	//
	// TQ task SHOULD not modify a CL (e.g. via Gerrit RPCs) beyond this point.
	// This is merely best effort, as an RPC to external system initiated before
	// this deadline may still complete after it.
	//
	// If PM doesn't receive PurgeCompleted event before this deadline + some grace
	// period, PM will consider purge operation expired and it'll be removed from
	// PState.
	Deadline *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=deadline,proto3" json:"deadline,omitempty"`
	// What trigger(s) are being purged.
	//
	// Types that are assignable to ApplyTo:
	//
	//	*PurgingCL_Triggers
	//	*PurgingCL_AllActiveTriggers
	ApplyTo isPurgingCL_ApplyTo `protobuf_oneof:"apply_to"`
	// If specified, the Gerrit request will be sent with the notify and
	// attention.
	Notification *PurgingCL_Notification `protobuf:"bytes,6,opt,name=notification,proto3" json:"notification,omitempty"`
	// contains filtered or unexported fields
}

PurgingCL represents purging of a CL due to some problem.

The purging process is initiated during PM state mutation while atomically adding a TQ task to perform the actual purge.

Purging itself constitutes removing whatever triggered CV on a CL as well as posting the reason for purging to the user.

Individual CLs are purged independently, even if CLs are related.

Trying to purge multiple triggers of the same type on the same CL will result in only purging one of them. This is not possible today, but may have an unexpected effect on future features.

Upon TQ task completion, the task handler notifies PM back via an PurgeCompleted event. For fail-safe reasons, there is a deadline to perform the purge. PM keeps the PurgingCL in PState until either deadline is reached OR PurgeCompleted event is received.

func (*PurgingCL) Descriptor deprecated 

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

Deprecated: Use PurgingCL.ProtoReflect.Descriptor instead.

func (*PurgingCL) GetAllActiveTriggers 

func (x *PurgingCL) GetAllActiveTriggers() bool

func (*PurgingCL) GetApplyTo 

func (m *PurgingCL) GetApplyTo() isPurgingCL_ApplyTo

func (*PurgingCL) GetClid 

func (x *PurgingCL) GetClid() int64

func (*PurgingCL) GetDeadline 

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

func (*PurgingCL) GetNotification 

func (x *PurgingCL) GetNotification() *PurgingCL_Notification

func (*PurgingCL) GetOperationId 

func (x *PurgingCL) GetOperationId() string

func (*PurgingCL) GetTriggers 

func (x *PurgingCL) GetTriggers() *run.Triggers

func (*PurgingCL) ProtoMessage 

func (*PurgingCL) ProtoMessage()

func (*PurgingCL) ProtoReflect 

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

func (*PurgingCL) Reset 

func (x *PurgingCL) Reset()

func (*PurgingCL) String 

func (x *PurgingCL) String() string

func (*PurgingCL) Validate 

func (m *PurgingCL) Validate() error

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

func (m *PurgingCL) ValidateAll() error

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

type PurgingCLMultiError 

type PurgingCLMultiError []error

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

func (PurgingCLMultiError) AllErrors 

func (m PurgingCLMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PurgingCLMultiError) Error 

func (m PurgingCLMultiError) Error() string

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

type PurgingCLValidationError 

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

PurgingCLValidationError is the validation error returned by PurgingCL.Validate if the designated constraints aren't met.

func (PurgingCLValidationError) Cause 

func (e PurgingCLValidationError) Cause() error

Cause function returns cause value.

func (PurgingCLValidationError) Error 

func (e PurgingCLValidationError) Error() string

Error satisfies the builtin error interface

func (PurgingCLValidationError) ErrorName 

func (e PurgingCLValidationError) ErrorName() string

ErrorName returns error name.

func (PurgingCLValidationError) Field 

func (e PurgingCLValidationError) Field() string

Field function returns field value.

func (PurgingCLValidationError) Key 

func (e PurgingCLValidationError) Key() bool

Key function returns key value.

func (PurgingCLValidationError) Reason 

func (e PurgingCLValidationError) Reason() string

Reason function returns reason value.

type PurgingCL_AllActiveTriggers 

type PurgingCL_AllActiveTriggers struct {
	AllActiveTriggers bool `protobuf:"varint,5,opt,name=all_active_triggers,json=allActiveTriggers,proto3,oneof"`
}

type PurgingCL_Notification 

type PurgingCL_Notification struct {

	// Whom value(s) to set in Notify of the SetReview request.
	//
	// If omitted, no one will receive a notification.
	Notify []gerrit.Whom `protobuf:"varint,1,rep,packed,name=notify,proto3,enum=cv.internal.gerrit.Whom" json:"notify,omitempty"`
	// Whom value(s) to set in AddToAttentionSet of the SetReview request.
	//
	// If omitted, no one will be added into the attention set.
	Attention []gerrit.Whom `protobuf:"varint,2,rep,packed,name=attention,proto3,enum=cv.internal.gerrit.Whom" json:"attention,omitempty"`
	// contains filtered or unexported fields
}

func (*PurgingCL_Notification) Descriptor deprecated 

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

Deprecated: Use PurgingCL_Notification.ProtoReflect.Descriptor instead.

func (*PurgingCL_Notification) GetAttention 

func (x *PurgingCL_Notification) GetAttention() []gerrit.Whom

func (*PurgingCL_Notification) GetNotify 

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

func (*PurgingCL_Notification) ProtoMessage 

func (*PurgingCL_Notification) ProtoMessage()

func (*PurgingCL_Notification) ProtoReflect 

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

func (*PurgingCL_Notification) Reset 

func (x *PurgingCL_Notification) Reset()

func (*PurgingCL_Notification) String 

func (x *PurgingCL_Notification) String() string

func (*PurgingCL_Notification) Validate 

func (m *PurgingCL_Notification) Validate() error

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

func (m *PurgingCL_Notification) ValidateAll() error

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

type PurgingCL_NotificationMultiError 

type PurgingCL_NotificationMultiError []error

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

func (PurgingCL_NotificationMultiError) AllErrors 

func (m PurgingCL_NotificationMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PurgingCL_NotificationMultiError) Error 

func (m PurgingCL_NotificationMultiError) Error() string

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

type PurgingCL_NotificationValidationError 

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

PurgingCL_NotificationValidationError is the validation error returned by PurgingCL_Notification.Validate if the designated constraints aren't met.

func (PurgingCL_NotificationValidationError) Cause 

func (e PurgingCL_NotificationValidationError) Cause() error

Cause function returns cause value.

func (PurgingCL_NotificationValidationError) Error 

func (e PurgingCL_NotificationValidationError) Error() string

Error satisfies the builtin error interface

func (PurgingCL_NotificationValidationError) ErrorName 

func (e PurgingCL_NotificationValidationError) ErrorName() string

ErrorName returns error name.

func (PurgingCL_NotificationValidationError) Field 

func (e PurgingCL_NotificationValidationError) Field() string

Field function returns field value.

func (PurgingCL_NotificationValidationError) Key 

func (e PurgingCL_NotificationValidationError) Key() bool

Key function returns key value.

func (PurgingCL_NotificationValidationError) Reason 

func (e PurgingCL_NotificationValidationError) Reason() string

Reason function returns reason value.

type PurgingCL_Triggers 

type PurgingCL_Triggers struct {
	Triggers *run.Triggers `protobuf:"bytes,4,opt,name=triggers,proto3,oneof"`
}

type RunCreated 

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

RunCreated is sent to PM by either itself or API-based Run creation.

func (*RunCreated) Descriptor deprecated 

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

Deprecated: Use RunCreated.ProtoReflect.Descriptor instead.

func (*RunCreated) GetRunId 

func (x *RunCreated) GetRunId() string

func (*RunCreated) ProtoMessage 

func (*RunCreated) ProtoMessage()

func (*RunCreated) ProtoReflect 

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

func (*RunCreated) Reset 

func (x *RunCreated) Reset()

func (*RunCreated) String 

func (x *RunCreated) String() string

func (*RunCreated) Validate 

func (m *RunCreated) Validate() error

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

func (m *RunCreated) ValidateAll() error

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

type RunCreatedMultiError 

type RunCreatedMultiError []error

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

func (RunCreatedMultiError) AllErrors 

func (m RunCreatedMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (RunCreatedMultiError) Error 

func (m RunCreatedMultiError) Error() string

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

type RunCreatedValidationError 

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

RunCreatedValidationError is the validation error returned by RunCreated.Validate if the designated constraints aren't met.

func (RunCreatedValidationError) Cause 

func (e RunCreatedValidationError) Cause() error

Cause function returns cause value.

func (RunCreatedValidationError) Error 

func (e RunCreatedValidationError) Error() string

Error satisfies the builtin error interface

func (RunCreatedValidationError) ErrorName 

func (e RunCreatedValidationError) ErrorName() string

ErrorName returns error name.

func (RunCreatedValidationError) Field 

func (e RunCreatedValidationError) Field() string

Field function returns field value.

func (RunCreatedValidationError) Key 

func (e RunCreatedValidationError) Key() bool

Key function returns key value.

func (RunCreatedValidationError) Reason 

func (e RunCreatedValidationError) Reason() string

Reason function returns reason value.

type RunFinished 

type RunFinished struct {
	RunId string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// the terminal status.
	Status run.Status `protobuf:"varint,2,opt,name=status,proto3,enum=cv.internal.run.Status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

RunFinished is sent to PM by Run Manager after or atomically with changing Run's status to a final status.

func (*RunFinished) Descriptor deprecated 

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

Deprecated: Use RunFinished.ProtoReflect.Descriptor instead.

func (*RunFinished) GetRunId 

func (x *RunFinished) GetRunId() string

func (*RunFinished) GetStatus 

func (x *RunFinished) GetStatus() run.Status

func (*RunFinished) ProtoMessage 

func (*RunFinished) ProtoMessage()

func (*RunFinished) ProtoReflect 

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

func (*RunFinished) Reset 

func (x *RunFinished) Reset()

func (*RunFinished) String 

func (x *RunFinished) String() string

func (*RunFinished) Validate 

func (m *RunFinished) Validate() error

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

func (m *RunFinished) ValidateAll() error

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

type RunFinishedMultiError 

type RunFinishedMultiError []error

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

func (RunFinishedMultiError) AllErrors 

func (m RunFinishedMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (RunFinishedMultiError) Error 

func (m RunFinishedMultiError) Error() string

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

type RunFinishedValidationError 

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

RunFinishedValidationError is the validation error returned by RunFinished.Validate if the designated constraints aren't met.

func (RunFinishedValidationError) Cause 

func (e RunFinishedValidationError) Cause() error

Cause function returns cause value.

func (RunFinishedValidationError) Error 

func (e RunFinishedValidationError) Error() string

Error satisfies the builtin error interface

func (RunFinishedValidationError) ErrorName 

func (e RunFinishedValidationError) ErrorName() string

ErrorName returns error name.

func (RunFinishedValidationError) Field 

func (e RunFinishedValidationError) Field() string

Field function returns field value.

func (RunFinishedValidationError) Key 

func (e RunFinishedValidationError) Key() bool

Key function returns key value.

func (RunFinishedValidationError) Reason 

func (e RunFinishedValidationError) Reason() string

Reason function returns reason value.

type Status 

type Status int32
const (
	Status_STATUS_UNSPECIFIED Status = 0
	Status_STARTED            Status = 1
	Status_STOPPING           Status = 2
	Status_STOPPED            Status = 3
)

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 TasksBinding 

type TasksBinding struct {
	ManageProject        tq.TaskClassRef
	KickManageProject    tq.TaskClassRef
	PurgeProjectCL       tq.TaskClassRef
	TriggerProjectCLs    tq.TaskClassRef
	TriggerProjectCLDeps tq.TaskClassRef
	TQDispatcher         *tq.Dispatcher
}

TasksBinding binds Project Manager tasks to a TQ Dispatcher.

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

func Register 

func Register(tqd *tq.Dispatcher) TasksBinding

func (TasksBinding) Dispatch 

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

Dispatch ensures invocation of ProjectManager via ManageProjectTask.

ProjectManager will be invoked at approximately no earlier than both: * eta time * next possible.

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

type TriggeringCLDeps 

type TriggeringCLDeps struct {

	// Origin CL of which dep CLs are to propagate the trigger to.
	OriginClid int64 `protobuf:"varint,1,opt,name=origin_clid,json=originClid,proto3" json:"origin_clid,omitempty"`
	// Dep CLs to propagate the trigger to.
	DepClids []int64 `protobuf:"varint,2,rep,packed,name=dep_clids,json=depClids,proto3" json:"dep_clids,omitempty"`
	// Operation ID uniquely identifies this op within the project.
	OperationId string `protobuf:"bytes,3,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"`
	// Deadline is obeyed by the TQ task handler.
	//
	// TQ task SHOULD NOT modify a CL (e.g., via Gerrit RPCs) beyond this point.
	// If PM doesn't receive TriggerCLDepsCompleted event before
	// this deadline + grace period, PM will consider the task expired and
	// the task will be removed from PState, so that the deps will be re-triaged
	// and PM may schedule another TQ task for the triggering operation
	// for the CL.
	Deadline *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=deadline,proto3" json:"deadline,omitempty"`
	// Trigger to propagate.
	Trigger *run.Trigger `protobuf:"bytes,5,opt,name=trigger,proto3" json:"trigger,omitempty"`
	// Name of the config group watching the origin CL.
	ConfigGroupName string `protobuf:"bytes,6,opt,name=config_group_name,json=configGroupName,proto3" json:"config_group_name,omitempty"`
	// contains filtered or unexported fields
}

TriggeringCLDeps propagates the trigger to the deps of a given CL.

func (*TriggeringCLDeps) Descriptor deprecated 

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

Deprecated: Use TriggeringCLDeps.ProtoReflect.Descriptor instead.

func (*TriggeringCLDeps) GetConfigGroupName 

func (x *TriggeringCLDeps) GetConfigGroupName() string

func (*TriggeringCLDeps) GetDeadline 

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

func (*TriggeringCLDeps) GetDepClids 

func (x *TriggeringCLDeps) GetDepClids() []int64

func (*TriggeringCLDeps) GetOperationId 

func (x *TriggeringCLDeps) GetOperationId() string

func (*TriggeringCLDeps) GetOriginClid 

func (x *TriggeringCLDeps) GetOriginClid() int64

func (*TriggeringCLDeps) GetTrigger 

func (x *TriggeringCLDeps) GetTrigger() *run.Trigger

func (*TriggeringCLDeps) ProtoMessage 

func (*TriggeringCLDeps) ProtoMessage()

func (*TriggeringCLDeps) ProtoReflect 

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

func (*TriggeringCLDeps) Reset 

func (x *TriggeringCLDeps) Reset()

func (*TriggeringCLDeps) String 

func (x *TriggeringCLDeps) String() string

func (*TriggeringCLDeps) Validate 

func (m *TriggeringCLDeps) Validate() error

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

func (m *TriggeringCLDeps) ValidateAll() error

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

type TriggeringCLDepsCompleted 

type TriggeringCLDepsCompleted struct {

	// Operational ID, uniquely identifying a given TriggeringCLDepsCompleted
	// event in the LUCI project.
	OperationId string `protobuf:"bytes,1,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"`
	// ID of the Originating CL that issued the TriggeringCLDeps task.
	Origin int64 `protobuf:"varint,2,opt,name=origin,proto3" json:"origin,omitempty"`
	// IDs of the dependent CLs that cltriggerer successfully triggered.
	Succeeded []int64 `protobuf:"varint,3,rep,packed,name=succeeded,proto3" json:"succeeded,omitempty"`
	// CLs that cltriggerer failed to trigger.
	Failed []*changelist.CLError_TriggerDeps `protobuf:"bytes,4,rep,name=failed,proto3" json:"failed,omitempty"`
	// CLs that cltriggerer couldn't trigger.
	//
	// It's either cltriggerer couldn't even attempt the trigger, or
	// attempted but the request failed transiently.
	Incompleted []int64 `protobuf:"varint,5,rep,packed,name=incompleted,proto3" json:"incompleted,omitempty"`
	// contains filtered or unexported fields
}

TriggeringCLDepsCompleted is sent to PM on a TriggeringCLDepsTask completion.

func (*TriggeringCLDepsCompleted) Descriptor deprecated 

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

Deprecated: Use TriggeringCLDepsCompleted.ProtoReflect.Descriptor instead.

func (*TriggeringCLDepsCompleted) GetFailed 

func (x *TriggeringCLDepsCompleted) GetFailed() []*changelist.CLError_TriggerDeps

func (*TriggeringCLDepsCompleted) GetIncompleted 

func (x *TriggeringCLDepsCompleted) GetIncompleted() []int64

func (*TriggeringCLDepsCompleted) GetOperationId 

func (x *TriggeringCLDepsCompleted) GetOperationId() string

func (*TriggeringCLDepsCompleted) GetOrigin 

func (x *TriggeringCLDepsCompleted) GetOrigin() int64

func (*TriggeringCLDepsCompleted) GetSucceeded 

func (x *TriggeringCLDepsCompleted) GetSucceeded() []int64

func (*TriggeringCLDepsCompleted) ProtoMessage 

func (*TriggeringCLDepsCompleted) ProtoMessage()

func (*TriggeringCLDepsCompleted) ProtoReflect 

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

func (*TriggeringCLDepsCompleted) Reset 

func (x *TriggeringCLDepsCompleted) Reset()

func (*TriggeringCLDepsCompleted) String 

func (x *TriggeringCLDepsCompleted) String() string

func (*TriggeringCLDepsCompleted) Validate 

func (m *TriggeringCLDepsCompleted) Validate() error

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

func (m *TriggeringCLDepsCompleted) ValidateAll() error

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

type TriggeringCLDepsCompletedMultiError 

type TriggeringCLDepsCompletedMultiError []error

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

func (TriggeringCLDepsCompletedMultiError) AllErrors 

func (m TriggeringCLDepsCompletedMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TriggeringCLDepsCompletedMultiError) Error 

func (m TriggeringCLDepsCompletedMultiError) Error() string

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

type TriggeringCLDepsCompletedValidationError 

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

TriggeringCLDepsCompletedValidationError is the validation error returned by TriggeringCLDepsCompleted.Validate if the designated constraints aren't met.

func (TriggeringCLDepsCompletedValidationError) Cause 

func (e TriggeringCLDepsCompletedValidationError) Cause() error

Cause function returns cause value.

func (TriggeringCLDepsCompletedValidationError) Error 

func (e TriggeringCLDepsCompletedValidationError) Error() string

Error satisfies the builtin error interface

func (TriggeringCLDepsCompletedValidationError) ErrorName 

func (e TriggeringCLDepsCompletedValidationError) ErrorName() string

ErrorName returns error name.

func (TriggeringCLDepsCompletedValidationError) Field 

func (e TriggeringCLDepsCompletedValidationError) Field() string

Field function returns field value.

func (TriggeringCLDepsCompletedValidationError) Key 

func (e TriggeringCLDepsCompletedValidationError) Key() bool

Key function returns key value.

func (TriggeringCLDepsCompletedValidationError) Reason 

func (e TriggeringCLDepsCompletedValidationError) Reason() string

Reason function returns reason value.

type TriggeringCLDepsMultiError 

type TriggeringCLDepsMultiError []error

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

func (TriggeringCLDepsMultiError) AllErrors 

func (m TriggeringCLDepsMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TriggeringCLDepsMultiError) Error 

func (m TriggeringCLDepsMultiError) Error() string

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

type TriggeringCLDepsTask 

type TriggeringCLDepsTask struct {
	LuciProject      string            `protobuf:"bytes,1,opt,name=luci_project,json=luciProject,proto3" json:"luci_project,omitempty"`
	TriggeringClDeps *TriggeringCLDeps `protobuf:"bytes,2,opt,name=triggering_cl_deps,json=triggeringClDeps,proto3" json:"triggering_cl_deps,omitempty"`
	// contains filtered or unexported fields
}

TriggeringDepsTask starts a task to trigger the deps of a CL.

Queue: "trigger-project-cl-deps"

func (*TriggeringCLDepsTask) Descriptor deprecated 

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

Deprecated: Use TriggeringCLDepsTask.ProtoReflect.Descriptor instead.

func (*TriggeringCLDepsTask) GetLuciProject 

func (x *TriggeringCLDepsTask) GetLuciProject() string

func (*TriggeringCLDepsTask) GetTriggeringClDeps 

func (x *TriggeringCLDepsTask) GetTriggeringClDeps() *TriggeringCLDeps

func (*TriggeringCLDepsTask) ProtoMessage 

func (*TriggeringCLDepsTask) ProtoMessage()

func (*TriggeringCLDepsTask) ProtoReflect 

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

func (*TriggeringCLDepsTask) Reset 

func (x *TriggeringCLDepsTask) Reset()

func (*TriggeringCLDepsTask) String 

func (x *TriggeringCLDepsTask) String() string

func (*TriggeringCLDepsTask) Validate 

func (m *TriggeringCLDepsTask) Validate() error

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

func (m *TriggeringCLDepsTask) ValidateAll() error

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

type TriggeringCLDepsTaskMultiError 

type TriggeringCLDepsTaskMultiError []error

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

func (TriggeringCLDepsTaskMultiError) AllErrors 

func (m TriggeringCLDepsTaskMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TriggeringCLDepsTaskMultiError) Error 

func (m TriggeringCLDepsTaskMultiError) Error() string

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

type TriggeringCLDepsTaskValidationError 

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

TriggeringCLDepsTaskValidationError is the validation error returned by TriggeringCLDepsTask.Validate if the designated constraints aren't met.

func (TriggeringCLDepsTaskValidationError) Cause 

func (e TriggeringCLDepsTaskValidationError) Cause() error

Cause function returns cause value.

func (TriggeringCLDepsTaskValidationError) Error 

func (e TriggeringCLDepsTaskValidationError) Error() string

Error satisfies the builtin error interface

func (TriggeringCLDepsTaskValidationError) ErrorName 

func (e TriggeringCLDepsTaskValidationError) ErrorName() string

ErrorName returns error name.

func (TriggeringCLDepsTaskValidationError) Field 

func (e TriggeringCLDepsTaskValidationError) Field() string

Field function returns field value.

func (TriggeringCLDepsTaskValidationError) Key 

func (e TriggeringCLDepsTaskValidationError) Key() bool

Key function returns key value.

func (TriggeringCLDepsTaskValidationError) Reason 

func (e TriggeringCLDepsTaskValidationError) Reason() string

Reason function returns reason value.

type TriggeringCLDepsValidationError 

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

TriggeringCLDepsValidationError is the validation error returned by TriggeringCLDeps.Validate if the designated constraints aren't met.

func (TriggeringCLDepsValidationError) Cause 

func (e TriggeringCLDepsValidationError) Cause() error

Cause function returns cause value.

func (TriggeringCLDepsValidationError) Error 

func (e TriggeringCLDepsValidationError) Error() string

Error satisfies the builtin error interface

func (TriggeringCLDepsValidationError) ErrorName 

func (e TriggeringCLDepsValidationError) ErrorName() string

ErrorName returns error name.

func (TriggeringCLDepsValidationError) Field 

func (e TriggeringCLDepsValidationError) Field() string

Field function returns field value.

func (TriggeringCLDepsValidationError) Key 

func (e TriggeringCLDepsValidationError) Key() bool

Key function returns key value.

func (TriggeringCLDepsValidationError) Reason 

func (e TriggeringCLDepsValidationError) Reason() string

Reason function returns reason value.

Source Files

View all Source files

Jump to

Keyboard shortcuts

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