taskspb

package
v0.0.0-...-7d6be15 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_go_chromium_org_luci_analysis_internal_tasks_taskspb_tasks_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Backfill 

type Backfill struct {

	// The day to backfill data for. E.g. 2024-03-01 00:00:00 UTC
	// to denote the day of March 1st, 2024.
	Day *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=day,proto3" json:"day,omitempty"`
	// contains filtered or unexported fields
}

Payload of the Backfill task.

func (*Backfill) Descriptor deprecated 

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

Deprecated: Use Backfill.ProtoReflect.Descriptor instead.

func (*Backfill) GetDay 

func (x *Backfill) GetDay() *timestamppb.Timestamp

func (*Backfill) ProtoMessage 

func (*Backfill) ProtoMessage()

func (*Backfill) ProtoReflect 

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

func (*Backfill) Reset 

func (x *Backfill) Reset()

func (*Backfill) String 

func (x *Backfill) String() string

type GroupChangepoints 

type GroupChangepoints struct {

	// A timestamp that select a particular week for grouping and exporting changepoints.
	// Eg. 2024-09-08 00:00:00 UTC to denote the day of September 8th, 2024.
	//
	// A week in this context refers to the period from Sunday at 00:00:00 AM UTC (inclusive)
	// to the following Sunday at 00:00:00 AM UTC (exclusive).
	// The week field MUST be a timestamp representing the start of a week (Sunday at 00:00:00 AM UTC).
	// Providing a timestamp that does not align with the start of a week will result in an error.
	Week *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=week,proto3" json:"week,omitempty"`
	// The time the task was scheduled.
	// This is used to prevent the task queue from becoming overly congested
	// when task takes unexpectedly long time to finish.
	ScheduleTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=schedule_time,json=scheduleTime,proto3" json:"schedule_time,omitempty"`
	// contains filtered or unexported fields
}

Payload of the GroupChangepoints task.

func (*GroupChangepoints) Descriptor deprecated 

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

Deprecated: Use GroupChangepoints.ProtoReflect.Descriptor instead.

func (*GroupChangepoints) GetScheduleTime 

func (x *GroupChangepoints) GetScheduleTime() *timestamppb.Timestamp

func (*GroupChangepoints) GetWeek 

func (x *GroupChangepoints) GetWeek() *timestamppb.Timestamp

func (*GroupChangepoints) ProtoMessage 

func (*GroupChangepoints) ProtoMessage()

func (*GroupChangepoints) ProtoReflect 

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

func (*GroupChangepoints) Reset 

func (x *GroupChangepoints) Reset()

func (*GroupChangepoints) String 

func (x *GroupChangepoints) String() string

type IngestTestResults 

type IngestTestResults struct {

	// The ResultDB invocation ready for export notification that triggered
	// the ingestion of test results.
	Notification *v1.InvocationReadyForExportNotification `protobuf:"bytes,1,opt,name=notification,proto3" json:"notification,omitempty"`
	// The page token value to use when calling ListTestResults.
	// For the first task, this should be "". For subsequent tasks,
	// this is the next_page_token value returned by the last call.
	PageToken string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// The task number of test results task. 1 for the first
	// task, 2 for the second task, and so on. Used to avoid creating
	// duplicate tasks.
	TaskIndex int64 `protobuf:"varint,3,opt,name=task_index,json=taskIndex,proto3" json:"task_index,omitempty"`
	// contains filtered or unexported fields
}

Payload of IngestTestResults task.

func (*IngestTestResults) Descriptor deprecated 

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

Deprecated: Use IngestTestResults.ProtoReflect.Descriptor instead.

func (*IngestTestResults) GetNotification 

func (x *IngestTestResults) GetNotification() *v1.InvocationReadyForExportNotification

func (*IngestTestResults) GetPageToken 

func (x *IngestTestResults) GetPageToken() string

func (*IngestTestResults) GetTaskIndex 

func (x *IngestTestResults) GetTaskIndex() int64

func (*IngestTestResults) ProtoMessage 

func (*IngestTestResults) ProtoMessage()

func (*IngestTestResults) ProtoReflect 

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

func (*IngestTestResults) Reset 

func (x *IngestTestResults) Reset()

func (*IngestTestResults) String 

func (x *IngestTestResults) String() string

type IngestTestVerdicts 

type IngestTestVerdicts struct {

	// The LUCI project of the invocation and build (if exists) in this ingestion task.
	Project string `protobuf:"bytes,6,opt,name=project,proto3" json:"project,omitempty"`
	// Timestamp representing the start of the data retention period
	// for the ingested test verdicts. This is the time the ingested invocation
	// was created in Spanner.
	PartitionTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=partition_time,json=partitionTime,proto3" json:"partition_time,omitempty"`
	// ID of this ingestion.
	// This matches to the ingestionID in the IngestionJoins spanner table.
	IngestionId string `protobuf:"bytes,7,opt,name=ingestion_id,json=ingestionId,proto3" json:"ingestion_id,omitempty"`
	// The invocation that is being ingested. Only
	// populated if the ingestion has an invocation.
	Invocation *proto.InvocationResult `protobuf:"bytes,8,opt,name=invocation,proto3" json:"invocation,omitempty"`
	// The build that is being ingested. Only
	// populated if the ingestion has a build.
	Build *proto.BuildResult `protobuf:"bytes,2,opt,name=build,proto3" json:"build,omitempty"`
	// Context about the presubmit run the build was a part of. Only
	// populated if the build is a presubmit run.
	PresubmitRun *proto.PresubmitResult `protobuf:"bytes,3,opt,name=presubmit_run,json=presubmitRun,proto3" json:"presubmit_run,omitempty"`
	// The page token value to use when calling QueryTestVariants.
	// For the first task, this should be "". For subsequent tasks,
	// this is the next_page_token value returned by the last call.
	PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// The task number of test results task. 1 for the first
	// task, 2 for the second task, and so on. Used to avoid creating
	// duplicate tasks.
	TaskIndex int64 `protobuf:"varint,5,opt,name=task_index,json=taskIndex,proto3" json:"task_index,omitempty"`
	// contains filtered or unexported fields
}

Payload of IngestTestVerdicts task. Next ID: 9.

func (*IngestTestVerdicts) Descriptor deprecated 

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

Deprecated: Use IngestTestVerdicts.ProtoReflect.Descriptor instead.

func (*IngestTestVerdicts) GetBuild 

func (x *IngestTestVerdicts) GetBuild() *proto.BuildResult

func (*IngestTestVerdicts) GetIngestionId 

func (x *IngestTestVerdicts) GetIngestionId() string

func (*IngestTestVerdicts) GetInvocation 

func (x *IngestTestVerdicts) GetInvocation() *proto.InvocationResult

func (*IngestTestVerdicts) GetPageToken 

func (x *IngestTestVerdicts) GetPageToken() string

func (*IngestTestVerdicts) GetPartitionTime 

func (x *IngestTestVerdicts) GetPartitionTime() *timestamppb.Timestamp

func (*IngestTestVerdicts) GetPresubmitRun 

func (x *IngestTestVerdicts) GetPresubmitRun() *proto.PresubmitResult

func (*IngestTestVerdicts) GetProject 

func (x *IngestTestVerdicts) GetProject() string

func (*IngestTestVerdicts) GetTaskIndex 

func (x *IngestTestVerdicts) GetTaskIndex() int64

func (*IngestTestVerdicts) ProtoMessage 

func (*IngestTestVerdicts) ProtoMessage()

func (*IngestTestVerdicts) ProtoReflect 

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

func (*IngestTestVerdicts) Reset 

func (x *IngestTestVerdicts) Reset()

func (*IngestTestVerdicts) String 

func (x *IngestTestVerdicts) String() string

type JoinBuild 

type JoinBuild struct {

	// Buildbucket build ID, unique per Buildbucket instance.
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Buildbucket host, e.g. "cr-buildbucket.appspot.com".
	Host string `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	// The LUCI Project to which the build belongs.
	Project string `protobuf:"bytes,3,opt,name=project,proto3" json:"project,omitempty"`
	// contains filtered or unexported fields
}

Payload of the JoinBuild task.

func (*JoinBuild) Descriptor deprecated 

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

Deprecated: Use JoinBuild.ProtoReflect.Descriptor instead.

func (*JoinBuild) GetHost 

func (x *JoinBuild) GetHost() string

func (*JoinBuild) GetId 

func (x *JoinBuild) GetId() int64

func (*JoinBuild) GetProject 

func (x *JoinBuild) GetProject() string

func (*JoinBuild) ProtoMessage 

func (*JoinBuild) ProtoMessage()

func (*JoinBuild) ProtoReflect 

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

func (*JoinBuild) Reset 

func (x *JoinBuild) Reset()

func (*JoinBuild) String 

func (x *JoinBuild) String() string

type ReclusterChunkState 

type ReclusterChunkState struct {

	// The exclusive lower bound of Chunk IDs processed to date.
	CurrentChunkId string `protobuf:"bytes,1,opt,name=current_chunk_id,json=currentChunkId,proto3" json:"current_chunk_id,omitempty"`
	// The next time a progress report should be made.
	NextReportDue *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=next_report_due,json=nextReportDue,proto3" json:"next_report_due,omitempty"`
	// contains filtered or unexported fields
}

ReclusterChunkState captures state passed from one execution of a ReclusterChunks task to the next.

func (*ReclusterChunkState) Descriptor deprecated 

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

Deprecated: Use ReclusterChunkState.ProtoReflect.Descriptor instead.

func (*ReclusterChunkState) GetCurrentChunkId 

func (x *ReclusterChunkState) GetCurrentChunkId() string

func (*ReclusterChunkState) GetNextReportDue 

func (x *ReclusterChunkState) GetNextReportDue() *timestamppb.Timestamp

func (*ReclusterChunkState) ProtoMessage 

func (*ReclusterChunkState) ProtoMessage()

func (*ReclusterChunkState) ProtoReflect 

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

func (*ReclusterChunkState) Reset 

func (x *ReclusterChunkState) Reset()

func (*ReclusterChunkState) String 

func (x *ReclusterChunkState) String() string

type ReclusterChunks 

type ReclusterChunks struct {

	// The number of the reclustering shard being processed by this task.
	// A shard corresponds to a project + Chunk ID keyspace fraction that
	// is being re-clustered.
	// Shards are numbered sequentially, starting at one.
	ShardNumber int64 `protobuf:"varint,6,opt,name=shard_number,json=shardNumber,proto3" json:"shard_number,omitempty"`
	// The LUCI Project containing test results to be re-clustered.
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// The attempt time for which this task is. This should be cross-referenced
	// with the ReclusteringRuns table to identify the reclustering parameters.
	// This is also the soft deadline for the task.
	AttemptTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=attempt_time,json=attemptTime,proto3" json:"attempt_time,omitempty"`
	// The exclusive lower bound defining the range of Chunk IDs to
	// be re-clustered. To define the table start, use the empty string ("").
	StartChunkId string `protobuf:"bytes,3,opt,name=start_chunk_id,json=startChunkId,proto3" json:"start_chunk_id,omitempty"`
	// The inclusive upper bound defining the range of Chunk IDs to
	// be re-clustered. To define the table end use "ff" x 16, i.e.
	// "ffffffffffffffffffffffffffffffff".
	EndChunkId string `protobuf:"bytes,4,opt,name=end_chunk_id,json=endChunkId,proto3" json:"end_chunk_id,omitempty"`
	// The version of algorithms to re-cluster to. If the worker executing the
	// task is not running at least this version of algorithms, it is an error.
	AlgorithmsVersion int64 `protobuf:"varint,7,opt,name=algorithms_version,json=algorithmsVersion,proto3" json:"algorithms_version,omitempty"`
	// The version of rules to recluster to.
	RulesVersion *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=rules_version,json=rulesVersion,proto3" json:"rules_version,omitempty"`
	// The version of project configuration to recluster to.
	ConfigVersion *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=config_version,json=configVersion,proto3" json:"config_version,omitempty"`
	// State to be passed from one execution of the task to the next.
	// To fit with autoscaling, each task aims to execute only for a short time
	// before enqueuing another task to act as its continuation.
	// Must be populated on all tasks, even on the initial task.
	State *ReclusterChunkState `protobuf:"bytes,5,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

Payload of the ReclusterChunks task.

func (*ReclusterChunks) Descriptor deprecated 

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

Deprecated: Use ReclusterChunks.ProtoReflect.Descriptor instead.

func (*ReclusterChunks) GetAlgorithmsVersion 

func (x *ReclusterChunks) GetAlgorithmsVersion() int64

func (*ReclusterChunks) GetAttemptTime 

func (x *ReclusterChunks) GetAttemptTime() *timestamppb.Timestamp

func (*ReclusterChunks) GetConfigVersion 

func (x *ReclusterChunks) GetConfigVersion() *timestamppb.Timestamp

func (*ReclusterChunks) GetEndChunkId 

func (x *ReclusterChunks) GetEndChunkId() string

func (*ReclusterChunks) GetProject 

func (x *ReclusterChunks) GetProject() string

func (*ReclusterChunks) GetRulesVersion 

func (x *ReclusterChunks) GetRulesVersion() *timestamppb.Timestamp

func (*ReclusterChunks) GetShardNumber 

func (x *ReclusterChunks) GetShardNumber() int64

func (*ReclusterChunks) GetStartChunkId 

func (x *ReclusterChunks) GetStartChunkId() string

func (*ReclusterChunks) GetState 

func (x *ReclusterChunks) GetState() *ReclusterChunkState

func (*ReclusterChunks) ProtoMessage 

func (*ReclusterChunks) ProtoMessage()

func (*ReclusterChunks) ProtoReflect 

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

func (*ReclusterChunks) Reset 

func (x *ReclusterChunks) Reset()

func (*ReclusterChunks) String 

func (x *ReclusterChunks) String() string

type UpdateBugs 

type UpdateBugs struct {

	// The LUCI Project to update bugs for.
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// The reclustering attempt minute that reflects the reclustering
	// state of the failures summarized by the cluster_summaries table.
	//
	// Explanation:
	// Bug management relies upon knowing when reclustering
	// is ongoing for rules and algorithms to inhibit erroneous bug updates
	// for those rules / algorithms as cluster metrics may be invalid.
	//
	// The re-clustering progress tracked in ReclusteringRuns table tracks
	// the progress applying re-clustering to the clustered_failures
	// table (not the cluster_summaries table).
	// As there is a delay between when clustered_failures table
	// is updated and when cluster_summaries is updated, we cannot
	// use the latest reclustering run but need to read the run
	// that was current when the clustered_failures table was
	// summarized into the cluster_summaries table.
	//
	// This will be the run that was current when the BigQuery
	// job to recompute cluster_summaries table from the
	// clustered_failures table started.
	ReclusteringAttemptMinute *timestamppb.Timestamp `` /* 138-byte string literal not displayed */
	// The time the task should be completed by to avoid overruning
	// the next bug update task.
	Deadline *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=deadline,proto3" json:"deadline,omitempty"`
	// contains filtered or unexported fields
}

Payload of the UpdateBugs task. Prior to running this task, the cluster_summaries table should have been updated from the contents of the clustered_failures table.

func (*UpdateBugs) Descriptor deprecated 

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

Deprecated: Use UpdateBugs.ProtoReflect.Descriptor instead.

func (*UpdateBugs) GetDeadline 

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

func (*UpdateBugs) GetProject 

func (x *UpdateBugs) GetProject() string

func (*UpdateBugs) GetReclusteringAttemptMinute 

func (x *UpdateBugs) GetReclusteringAttemptMinute() *timestamppb.Timestamp

func (*UpdateBugs) ProtoMessage 

func (*UpdateBugs) ProtoMessage()

func (*UpdateBugs) ProtoReflect 

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

func (*UpdateBugs) Reset 

func (x *UpdateBugs) Reset()

func (*UpdateBugs) String 

func (x *UpdateBugs) String() string

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.