migrationpb

package
v0.0.0-...-ddee7fb Latest Latest
Warning

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

Go to latest
Published: Nov 9, 2021 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Overview

Package migrationpb is internal to LUCI CV and CQDaemon. DO NOT USE.

Index

Constants

This section is empty.

Variables

View Source
var (
	TryjobStatus_name = map[int32]string{
		0: "TRYJOB_STATUS_UNSPECIFIED",
		1: "NOT_TRIGGERED",
		2: "PENDING",
		3: "RUNNING",
		4: "SUCCEEDED",
		5: "FAILED",
		6: "TIMED_OUT",
	}
	TryjobStatus_value = map[string]int32{
		"TRYJOB_STATUS_UNSPECIFIED": 0,
		"NOT_TRIGGERED":             1,
		"PENDING":                   2,
		"RUNNING":                   3,
		"SUCCEEDED":                 4,
		"FAILED":                    5,
		"TIMED_OUT":                 6,
	}
)

Enum value maps for TryjobStatus.

View Source
var (
	ReportVerifiedRunRequest_Action_name = map[int32]string{
		0: "ACTION_UNSPECIFIED",
		1: "ACTION_SUBMIT",
		2: "ACTION_DRY_RUN_OK",
		3: "ACTION_FAIL",
	}
	ReportVerifiedRunRequest_Action_value = map[string]int32{
		"ACTION_UNSPECIFIED": 0,
		"ACTION_SUBMIT":      1,
		"ACTION_DRY_RUN_OK":  2,
		"ACTION_FAIL":        3,
	}
)

Enum value maps for ReportVerifiedRunRequest_Action.

View Source
var File_go_chromium_org_luci_cv_api_migration_migration_proto protoreflect.FileDescriptor
View Source
var File_go_chromium_org_luci_cv_api_migration_settings_proto protoreflect.FileDescriptor
View Source
var Migration_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "migration.Migration",
	HandlerType: (*MigrationServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ReportVerifiedRun",
			Handler:    _Migration_ReportVerifiedRun_Handler,
		},
		{
			MethodName: "FetchRunStatus",
			Handler:    _Migration_FetchRunStatus_Handler,
		},
		{
			MethodName: "PostGerritMessage",
			Handler:    _Migration_PostGerritMessage_Handler,
		},
		{
			MethodName: "FetchActiveRuns",
			Handler:    _Migration_FetchActiveRuns_Handler,
		},
		{
			MethodName: "ReportUsedNetrc",
			Handler:    _Migration_ReportUsedNetrc_Handler,
		},
		{
			MethodName: "ReportTryjobs",
			Handler:    _Migration_ReportTryjobs_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "go.chromium.org/luci/cv/api/migration/migration.proto",
}

Migration_ServiceDesc is the grpc.ServiceDesc for Migration service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func FileDescriptorSet

func FileDescriptorSet() *descriptorpb.FileDescriptorSet

FileDescriptorSet returns a descriptor set for this proto package, which includes all defined services, and all transitive dependencies.

Will not return nil.

Do NOT modify the returned descriptor.

func RegisterMigrationServer

func RegisterMigrationServer(s grpc.ServiceRegistrar, srv MigrationServer)

Types

type ActiveRun

type ActiveRun struct {

	// CV Run ID.
	Id  string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Cls []*RunCL `protobuf:"bytes,2,rep,name=cls,proto3" json:"cls,omitempty"`
	// Deps of Run CLs which aren't part of the Run themself.
	// Unlike `cls` above, their .trigger and .deps aren't set.
	FyiDeps []*RunCL `protobuf:"bytes,3,rep,name=fyi_deps,json=fyiDeps,proto3" json:"fyi_deps,omitempty"`
	// contains filtered or unexported fields
}

ActiveRun.

func (*ActiveRun) Descriptor deprecated

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

Deprecated: Use ActiveRun.ProtoReflect.Descriptor instead.

func (*ActiveRun) GetCls

func (x *ActiveRun) GetCls() []*RunCL

func (*ActiveRun) GetFyiDeps

func (x *ActiveRun) GetFyiDeps() []*RunCL

func (*ActiveRun) GetId

func (x *ActiveRun) GetId() string

func (*ActiveRun) ProtoMessage

func (*ActiveRun) ProtoMessage()

func (*ActiveRun) ProtoReflect

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

func (*ActiveRun) Reset

func (x *ActiveRun) Reset()

func (*ActiveRun) String

func (x *ActiveRun) String() string

type FetchActiveRunsRequest

type FetchActiveRunsRequest struct {
	LuciProject string `protobuf:"bytes,1,opt,name=luci_project,json=luciProject,proto3" json:"luci_project,omitempty"`
	// contains filtered or unexported fields
}

func (*FetchActiveRunsRequest) Descriptor deprecated

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

Deprecated: Use FetchActiveRunsRequest.ProtoReflect.Descriptor instead.

func (*FetchActiveRunsRequest) GetLuciProject

func (x *FetchActiveRunsRequest) GetLuciProject() string

func (*FetchActiveRunsRequest) ProtoMessage

func (*FetchActiveRunsRequest) ProtoMessage()

func (*FetchActiveRunsRequest) ProtoReflect

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

func (*FetchActiveRunsRequest) Reset

func (x *FetchActiveRunsRequest) Reset()

func (*FetchActiveRunsRequest) String

func (x *FetchActiveRunsRequest) String() string

type FetchActiveRunsResponse

type FetchActiveRunsResponse struct {
	ActiveRuns []*ActiveRun `protobuf:"bytes,2,rep,name=active_runs,json=activeRuns,proto3" json:"active_runs,omitempty"`
	// contains filtered or unexported fields
}

func (*FetchActiveRunsResponse) Descriptor deprecated

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

Deprecated: Use FetchActiveRunsResponse.ProtoReflect.Descriptor instead.

func (*FetchActiveRunsResponse) GetActiveRuns

func (x *FetchActiveRunsResponse) GetActiveRuns() []*ActiveRun

func (*FetchActiveRunsResponse) ProtoMessage

func (*FetchActiveRunsResponse) ProtoMessage()

func (*FetchActiveRunsResponse) ProtoReflect

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

func (*FetchActiveRunsResponse) Reset

func (x *FetchActiveRunsResponse) Reset()

func (*FetchActiveRunsResponse) String

func (x *FetchActiveRunsResponse) String() string

type FetchRunStatusRequest

type FetchRunStatusRequest struct {
	LuciProject string `protobuf:"bytes,1,opt,name=luci_project,json=luciProject,proto3" json:"luci_project,omitempty"`
	CvId        string `protobuf:"bytes,2,opt,name=cv_id,json=cvId,proto3" json:"cv_id,omitempty"`
	AttemptKey  string `protobuf:"bytes,3,opt,name=attempt_key,json=attemptKey,proto3" json:"attempt_key,omitempty"`
	// contains filtered or unexported fields
}

func (*FetchRunStatusRequest) Descriptor deprecated

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

Deprecated: Use FetchRunStatusRequest.ProtoReflect.Descriptor instead.

func (*FetchRunStatusRequest) GetAttemptKey

func (x *FetchRunStatusRequest) GetAttemptKey() string

func (*FetchRunStatusRequest) GetCvId

func (x *FetchRunStatusRequest) GetCvId() string

func (*FetchRunStatusRequest) GetLuciProject

func (x *FetchRunStatusRequest) GetLuciProject() string

func (*FetchRunStatusRequest) ProtoMessage

func (*FetchRunStatusRequest) ProtoMessage()

func (*FetchRunStatusRequest) ProtoReflect

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

func (*FetchRunStatusRequest) Reset

func (x *FetchRunStatusRequest) Reset()

func (*FetchRunStatusRequest) String

func (x *FetchRunStatusRequest) String() string

type FetchRunStatusResponse

type FetchRunStatusResponse struct {

	// If event is not "", CQDaemon will call async_push's
	// `send_patch_event(..., event, extra)`.
	Event string `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	Extra string `protobuf:"bytes,2,opt,name=extra,proto3" json:"extra,omitempty"`
	// contains filtered or unexported fields
}

func (*FetchRunStatusResponse) Descriptor deprecated

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

Deprecated: Use FetchRunStatusResponse.ProtoReflect.Descriptor instead.

func (*FetchRunStatusResponse) GetEvent

func (x *FetchRunStatusResponse) GetEvent() string

func (*FetchRunStatusResponse) GetExtra

func (x *FetchRunStatusResponse) GetExtra() string

func (*FetchRunStatusResponse) ProtoMessage

func (*FetchRunStatusResponse) ProtoMessage()

func (*FetchRunStatusResponse) ProtoReflect

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

func (*FetchRunStatusResponse) Reset

func (x *FetchRunStatusResponse) Reset()

func (*FetchRunStatusResponse) String

func (x *FetchRunStatusResponse) String() string

type MigrationClient

type MigrationClient interface {
	// ReportVerifiedRun notifies CV of the Run CQDaemon has just finished
	// verifying.
	//
	// The Run may not contain CV's id, but CV can figure out the the ID using
	// Run.Attempt.Key.
	//
	// Called by CQDaemon when CV is in charge of run management.
	ReportVerifiedRun(ctx context.Context, in *ReportVerifiedRunRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// FetchRunStatus provides to CQDaemon info about a completed Run in order to
	// send to CQ Status app.
	//
	// The Run may not contain CV's id, but CV can figure out the the ID using
	// Run.Attempt.Key.
	//
	// Called by CQDaemon when CV is in charge of run management.
	FetchRunStatus(ctx context.Context, in *FetchRunStatusRequest, opts ...grpc.CallOption) (*FetchRunStatusResponse, error)
	// PostGerritMessage posts a unique per run message to Gerrit.
	//
	// Best effort, since Gerrit doesn't provide for idempotent or conditional
	// (etag like) updates.
	//
	// Use-cases:
	//  * CQDaemon linter posting a warning/error.
	//  * GerritCQAbility verifier posting error on each of Run's CL before
	//    failing entire attempt.
	//
	// Error handling:
	//  * If presumably transient Gerrit error, fails with Internal error (for
	//    simplicity). CQDaemon will have to retry.
	//  * If Gerrit error is 403, 404 or 412 (Precondition error), responds with
	//    corresponding gRPC code.
	PostGerritMessage(ctx context.Context, in *PostGerritMessageRequest, opts ...grpc.CallOption) (*PostGerritMessageResponse, error)
	// FetchActiveRuns returns all currently RUNNING runs in CV for the given
	// project.
	FetchActiveRuns(ctx context.Context, in *FetchActiveRunsRequest, opts ...grpc.CallOption) (*FetchActiveRunsResponse, error)
	// ReportUsedNetrc notifies CV of the legacy .netrc credentials used by
	// CQDaemon.
	ReportUsedNetrc(ctx context.Context, in *ReportUsedNetrcRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// ReportTryjobs notifies CV of the tryjobs applicable to a Run.
	ReportTryjobs(ctx context.Context, in *ReportTryjobsRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

MigrationClient is the client API for Migration service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewMigrationClient

func NewMigrationClient(cc grpc.ClientConnInterface) MigrationClient

type MigrationServer

type MigrationServer interface {
	// ReportVerifiedRun notifies CV of the Run CQDaemon has just finished
	// verifying.
	//
	// The Run may not contain CV's id, but CV can figure out the the ID using
	// Run.Attempt.Key.
	//
	// Called by CQDaemon when CV is in charge of run management.
	ReportVerifiedRun(context.Context, *ReportVerifiedRunRequest) (*emptypb.Empty, error)
	// FetchRunStatus provides to CQDaemon info about a completed Run in order to
	// send to CQ Status app.
	//
	// The Run may not contain CV's id, but CV can figure out the the ID using
	// Run.Attempt.Key.
	//
	// Called by CQDaemon when CV is in charge of run management.
	FetchRunStatus(context.Context, *FetchRunStatusRequest) (*FetchRunStatusResponse, error)
	// PostGerritMessage posts a unique per run message to Gerrit.
	//
	// Best effort, since Gerrit doesn't provide for idempotent or conditional
	// (etag like) updates.
	//
	// Use-cases:
	//  * CQDaemon linter posting a warning/error.
	//  * GerritCQAbility verifier posting error on each of Run's CL before
	//    failing entire attempt.
	//
	// Error handling:
	//  * If presumably transient Gerrit error, fails with Internal error (for
	//    simplicity). CQDaemon will have to retry.
	//  * If Gerrit error is 403, 404 or 412 (Precondition error), responds with
	//    corresponding gRPC code.
	PostGerritMessage(context.Context, *PostGerritMessageRequest) (*PostGerritMessageResponse, error)
	// FetchActiveRuns returns all currently RUNNING runs in CV for the given
	// project.
	FetchActiveRuns(context.Context, *FetchActiveRunsRequest) (*FetchActiveRunsResponse, error)
	// ReportUsedNetrc notifies CV of the legacy .netrc credentials used by
	// CQDaemon.
	ReportUsedNetrc(context.Context, *ReportUsedNetrcRequest) (*emptypb.Empty, error)
	// ReportTryjobs notifies CV of the tryjobs applicable to a Run.
	ReportTryjobs(context.Context, *ReportTryjobsRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

MigrationServer is the server API for Migration service. All implementations must embed UnimplementedMigrationServer for forward compatibility

type PostGerritMessageRequest

type PostGerritMessageRequest struct {

	// CV's run ID. May be not set iff CQDaemon does this before it takes Runs
	// from CV.
	RunId string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// LUCI Project. If run_id is specified, this is redundant.
	Project string `protobuf:"bytes,2,opt,name=project,proto3" json:"project,omitempty"`
	// CQD native Run identifier.
	AttemptKey string `protobuf:"bytes,3,opt,name=attempt_key,json=attemptKey,proto3" json:"attempt_key,omitempty"`
	// Gerrit host.
	Host     string `protobuf:"bytes,11,opt,name=host,proto3" json:"host,omitempty"`
	Change   int64  `protobuf:"varint,12,opt,name=change,proto3" json:"change,omitempty"`
	Revision string `protobuf:"bytes,15,opt,name=revision,proto3" json:"revision,omitempty"`
	// String comment to post.
	Comment string `protobuf:"bytes,13,opt,name=comment,proto3" json:"comment,omitempty"`
	// If true, send email to:
	//   * OWNER_REVIEWERS if full run
	//   * OWNER+all CQ voters if dry run
	SendEmail bool `protobuf:"varint,14,opt,name=send_email,json=sendEmail,proto3" json:"send_email,omitempty"`
	// contains filtered or unexported fields
}

func (*PostGerritMessageRequest) Descriptor deprecated

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

Deprecated: Use PostGerritMessageRequest.ProtoReflect.Descriptor instead.

func (*PostGerritMessageRequest) GetAttemptKey

func (x *PostGerritMessageRequest) GetAttemptKey() string

func (*PostGerritMessageRequest) GetChange

func (x *PostGerritMessageRequest) GetChange() int64

func (*PostGerritMessageRequest) GetComment

func (x *PostGerritMessageRequest) GetComment() string

func (*PostGerritMessageRequest) GetHost

func (x *PostGerritMessageRequest) GetHost() string

func (*PostGerritMessageRequest) GetProject

func (x *PostGerritMessageRequest) GetProject() string

func (*PostGerritMessageRequest) GetRevision

func (x *PostGerritMessageRequest) GetRevision() string

func (*PostGerritMessageRequest) GetRunId

func (x *PostGerritMessageRequest) GetRunId() string

func (*PostGerritMessageRequest) GetSendEmail

func (x *PostGerritMessageRequest) GetSendEmail() bool

func (*PostGerritMessageRequest) ProtoMessage

func (*PostGerritMessageRequest) ProtoMessage()

func (*PostGerritMessageRequest) ProtoReflect

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

func (*PostGerritMessageRequest) Reset

func (x *PostGerritMessageRequest) Reset()

func (*PostGerritMessageRequest) String

func (x *PostGerritMessageRequest) String() string

type PostGerritMessageResponse

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

func (*PostGerritMessageResponse) Descriptor deprecated

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

Deprecated: Use PostGerritMessageResponse.ProtoReflect.Descriptor instead.

func (*PostGerritMessageResponse) ProtoMessage

func (*PostGerritMessageResponse) ProtoMessage()

func (*PostGerritMessageResponse) ProtoReflect

func (*PostGerritMessageResponse) Reset

func (x *PostGerritMessageResponse) Reset()

func (*PostGerritMessageResponse) String

func (x *PostGerritMessageResponse) String() string

type ReportTryjobsRequest

type ReportTryjobsRequest struct {

	// RunID identifies which Run these tryjobs belong to,
	// and implicitly identifies the LUCI project.
	RunId   string    `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	Tryjobs []*Tryjob `protobuf:"bytes,2,rep,name=tryjobs,proto3" json:"tryjobs,omitempty"`
	// The Git revision of the LUCI project config under which CQDaemon is
	// operating.
	ConfigRevision string `protobuf:"bytes,3,opt,name=config_revision,json=configRevision,proto3" json:"config_revision,omitempty"`
	// contains filtered or unexported fields
}

func (*ReportTryjobsRequest) Descriptor deprecated

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

Deprecated: Use ReportTryjobsRequest.ProtoReflect.Descriptor instead.

func (*ReportTryjobsRequest) GetConfigRevision

func (x *ReportTryjobsRequest) GetConfigRevision() string

func (*ReportTryjobsRequest) GetRunId

func (x *ReportTryjobsRequest) GetRunId() string

func (*ReportTryjobsRequest) GetTryjobs

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

func (*ReportTryjobsRequest) ProtoMessage

func (*ReportTryjobsRequest) ProtoMessage()

func (*ReportTryjobsRequest) ProtoReflect

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

func (*ReportTryjobsRequest) Reset

func (x *ReportTryjobsRequest) Reset()

func (*ReportTryjobsRequest) String

func (x *ReportTryjobsRequest) String() string

type ReportUsedNetrcRequest

type ReportUsedNetrcRequest struct {
	GerritHost  string `protobuf:"bytes,1,opt,name=gerrit_host,json=gerritHost,proto3" json:"gerrit_host,omitempty"`
	AccessToken string `protobuf:"bytes,2,opt,name=access_token,json=accessToken,proto3" json:"access_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ReportUsedNetrcRequest) Descriptor deprecated

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

Deprecated: Use ReportUsedNetrcRequest.ProtoReflect.Descriptor instead.

func (*ReportUsedNetrcRequest) GetAccessToken

func (x *ReportUsedNetrcRequest) GetAccessToken() string

func (*ReportUsedNetrcRequest) GetGerritHost

func (x *ReportUsedNetrcRequest) GetGerritHost() string

func (*ReportUsedNetrcRequest) ProtoMessage

func (*ReportUsedNetrcRequest) ProtoMessage()

func (*ReportUsedNetrcRequest) ProtoReflect

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

func (*ReportUsedNetrcRequest) Reset

func (x *ReportUsedNetrcRequest) Reset()

func (*ReportUsedNetrcRequest) String

func (x *ReportUsedNetrcRequest) String() string

type ReportVerifiedRunRequest

type ReportVerifiedRunRequest struct {
	Run    *ReportedRun                    `protobuf:"bytes,1,opt,name=run,proto3" json:"run,omitempty"`
	Action ReportVerifiedRunRequest_Action `protobuf:"varint,11,opt,name=action,proto3,enum=migration.ReportVerifiedRunRequest_Action" json:"action,omitempty"`
	// Final message to post to Gerrit in case of ACTION_FAIL.
	FinalMessage string `protobuf:"bytes,12,opt,name=final_message,json=finalMessage,proto3" json:"final_message,omitempty"`
	// contains filtered or unexported fields
}

func (*ReportVerifiedRunRequest) Descriptor deprecated

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

Deprecated: Use ReportVerifiedRunRequest.ProtoReflect.Descriptor instead.

func (*ReportVerifiedRunRequest) GetAction

func (*ReportVerifiedRunRequest) GetFinalMessage

func (x *ReportVerifiedRunRequest) GetFinalMessage() string

func (*ReportVerifiedRunRequest) GetRun

func (*ReportVerifiedRunRequest) ProtoMessage

func (*ReportVerifiedRunRequest) ProtoMessage()

func (*ReportVerifiedRunRequest) ProtoReflect

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

func (*ReportVerifiedRunRequest) Reset

func (x *ReportVerifiedRunRequest) Reset()

func (*ReportVerifiedRunRequest) String

func (x *ReportVerifiedRunRequest) String() string

type ReportVerifiedRunRequest_Action

type ReportVerifiedRunRequest_Action int32

Action that CV SHOULD do on a Run.

Should instead of must because CV may be already finalizing the Run.

In pure CQDaemon, the action would have been done by CQDaemon itself.

const (
	ReportVerifiedRunRequest_ACTION_UNSPECIFIED ReportVerifiedRunRequest_Action = 0
	ReportVerifiedRunRequest_ACTION_SUBMIT      ReportVerifiedRunRequest_Action = 1 // requires a full run
	ReportVerifiedRunRequest_ACTION_DRY_RUN_OK  ReportVerifiedRunRequest_Action = 2 // requires a dry run
	ReportVerifiedRunRequest_ACTION_FAIL        ReportVerifiedRunRequest_Action = 3 // final_message must be set
)

func (ReportVerifiedRunRequest_Action) Descriptor

func (ReportVerifiedRunRequest_Action) Enum

func (ReportVerifiedRunRequest_Action) EnumDescriptor deprecated

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

Deprecated: Use ReportVerifiedRunRequest_Action.Descriptor instead.

func (ReportVerifiedRunRequest_Action) Number

func (ReportVerifiedRunRequest_Action) String

func (ReportVerifiedRunRequest_Action) Type

type ReportedRun

type ReportedRun struct {

	// CV's run ID if known.
	Id      string      `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Attempt *v1.Attempt `protobuf:"bytes,1,opt,name=attempt,proto3" json:"attempt,omitempty"`
	// contains filtered or unexported fields
}

ReportedRun as reported by the CQDaemon to CV.

func (*ReportedRun) Descriptor deprecated

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

Deprecated: Use ReportedRun.ProtoReflect.Descriptor instead.

func (*ReportedRun) GetAttempt

func (x *ReportedRun) GetAttempt() *v1.Attempt

func (*ReportedRun) GetId

func (x *ReportedRun) GetId() string

func (*ReportedRun) ProtoMessage

func (*ReportedRun) ProtoMessage()

func (*ReportedRun) ProtoReflect

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

func (*ReportedRun) Reset

func (x *ReportedRun) Reset()

func (*ReportedRun) String

func (x *ReportedRun) String() string

type RunCL

type RunCL struct {

	// CV's CLID. Used to identify Deps.
	Id int64            `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Gc *v1.GerritChange `protobuf:"bytes,2,opt,name=gc,proto3" json:"gc,omitempty"`
	// The following are copy-pasted from CV's snapshot.
	// Info is guaranteed to have current revision with the same patchset as
	// as specified in bigquery.GerritChange.
	Info    *gerrit.ChangeInfo `protobuf:"bytes,3,opt,name=info,proto3" json:"info,omitempty"`
	Files   []string           `protobuf:"bytes,4,rep,name=files,proto3" json:"files,omitempty"`
	Trigger *RunCL_Trigger     `protobuf:"bytes,5,opt,name=trigger,proto3" json:"trigger,omitempty"`
	Deps    []*RunCL_Dep       `protobuf:"bytes,6,rep,name=deps,proto3" json:"deps,omitempty"`
	// contains filtered or unexported fields
}

func (*RunCL) Descriptor deprecated

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

Deprecated: Use RunCL.ProtoReflect.Descriptor instead.

func (*RunCL) GetDeps

func (x *RunCL) GetDeps() []*RunCL_Dep

func (*RunCL) GetFiles

func (x *RunCL) GetFiles() []string

func (*RunCL) GetGc

func (x *RunCL) GetGc() *v1.GerritChange

func (*RunCL) GetId

func (x *RunCL) GetId() int64

func (*RunCL) GetInfo

func (x *RunCL) GetInfo() *gerrit.ChangeInfo

func (*RunCL) GetTrigger

func (x *RunCL) GetTrigger() *RunCL_Trigger

func (*RunCL) ProtoMessage

func (*RunCL) ProtoMessage()

func (*RunCL) ProtoReflect

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

func (*RunCL) Reset

func (x *RunCL) Reset()

func (*RunCL) String

func (x *RunCL) String() string

type RunCL_Dep

type RunCL_Dep struct {

	// CV's CLID. Guaranteed to match one of the RunCL in the same Run.
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// True means Dep is the immediate git parent and must be submitted first.
	Hard bool `protobuf:"varint,2,opt,name=hard,proto3" json:"hard,omitempty"`
	// contains filtered or unexported fields
}

func (*RunCL_Dep) Descriptor deprecated

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

Deprecated: Use RunCL_Dep.ProtoReflect.Descriptor instead.

func (*RunCL_Dep) GetHard

func (x *RunCL_Dep) GetHard() bool

func (*RunCL_Dep) GetId

func (x *RunCL_Dep) GetId() int64

func (*RunCL_Dep) ProtoMessage

func (*RunCL_Dep) ProtoMessage()

func (*RunCL_Dep) ProtoReflect

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

func (*RunCL_Dep) Reset

func (x *RunCL_Dep) Reset()

func (*RunCL_Dep) String

func (x *RunCL_Dep) String() string

type RunCL_Trigger

type RunCL_Trigger struct {
	Time *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"`
	// Gerrit account ID.
	AccountId int64 `protobuf:"varint,3,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
	// User email, if known.
	Email string `protobuf:"bytes,4,opt,name=email,proto3" json:"email,omitempty"`
	// contains filtered or unexported fields
}

func (*RunCL_Trigger) Descriptor deprecated

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

Deprecated: Use RunCL_Trigger.ProtoReflect.Descriptor instead.

func (*RunCL_Trigger) GetAccountId

func (x *RunCL_Trigger) GetAccountId() int64

func (*RunCL_Trigger) GetEmail

func (x *RunCL_Trigger) GetEmail() string

func (*RunCL_Trigger) GetTime

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

func (*RunCL_Trigger) ProtoMessage

func (*RunCL_Trigger) ProtoMessage()

func (*RunCL_Trigger) ProtoReflect

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

func (*RunCL_Trigger) Reset

func (x *RunCL_Trigger) Reset()

func (*RunCL_Trigger) String

func (x *RunCL_Trigger) String() string

type Settings

type Settings struct {

	// CQDaemon doesn't really have a -dev version, therefore to test -dev of CV,
	// CQDaemon can connect to either prod and dev migration API.
	// WARNING: don't connect to two CV host at the same time, as it doesn't work
	// any more.
	ApiHosts []*Settings_ApiHost `protobuf:"bytes,1,rep,name=api_hosts,json=apiHosts,proto3" json:"api_hosts,omitempty"`
	// Deprecated.
	//
	// Deprecated: Do not use.
	UseCvStatus       *Settings_UseCVStatus       `protobuf:"bytes,4,opt,name=use_cv_status,json=useCvStatus,proto3" json:"use_cv_status,omitempty"`
	UseCvStartMessage *Settings_UseCVStartMessage `protobuf:"bytes,5,opt,name=use_cv_start_message,json=useCvStartMessage,proto3" json:"use_cv_start_message,omitempty"`
	// contains filtered or unexported fields
}

Settings is schema of service-wide commit-queue/migration-settings.cfg which is used only during migration. It applies to all LUCI projects and is read by CQDaemon and LUCI CV.

func (*Settings) Descriptor deprecated

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

Deprecated: Use Settings.ProtoReflect.Descriptor instead.

func (*Settings) GetApiHosts

func (x *Settings) GetApiHosts() []*Settings_ApiHost

func (*Settings) GetUseCvStartMessage

func (x *Settings) GetUseCvStartMessage() *Settings_UseCVStartMessage

func (*Settings) GetUseCvStatus deprecated

func (x *Settings) GetUseCvStatus() *Settings_UseCVStatus

Deprecated: Do not use.

func (*Settings) ProtoMessage

func (*Settings) ProtoMessage()

func (*Settings) ProtoReflect

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

func (*Settings) Reset

func (x *Settings) Reset()

func (*Settings) String

func (x *Settings) String() string

type Settings_ApiHost

type Settings_ApiHost struct {

	// e.g. "luci-change-verifier-dev.appspot.com".
	Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	// If a LUCI Project matches any of regexps and none of _exclude ones,
	// CQDaemon will connect to the above Migration API host.
	ProjectRegexp        []string `protobuf:"bytes,2,rep,name=project_regexp,json=projectRegexp,proto3" json:"project_regexp,omitempty"`
	ProjectRegexpExclude []string `protobuf:"bytes,4,rep,name=project_regexp_exclude,json=projectRegexpExclude,proto3" json:"project_regexp_exclude,omitempty"`
	// If true and several hosts are configured, all other hosts' responses are
	// ignored.
	Prod bool `protobuf:"varint,3,opt,name=prod,proto3" json:"prod,omitempty"`
	// contains filtered or unexported fields
}

func (*Settings_ApiHost) Descriptor deprecated

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

Deprecated: Use Settings_ApiHost.ProtoReflect.Descriptor instead.

func (*Settings_ApiHost) GetHost

func (x *Settings_ApiHost) GetHost() string

func (*Settings_ApiHost) GetProd

func (x *Settings_ApiHost) GetProd() bool

func (*Settings_ApiHost) GetProjectRegexp

func (x *Settings_ApiHost) GetProjectRegexp() []string

func (*Settings_ApiHost) GetProjectRegexpExclude

func (x *Settings_ApiHost) GetProjectRegexpExclude() []string

func (*Settings_ApiHost) ProtoMessage

func (*Settings_ApiHost) ProtoMessage()

func (*Settings_ApiHost) ProtoReflect

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

func (*Settings_ApiHost) Reset

func (x *Settings_ApiHost) Reset()

func (*Settings_ApiHost) String

func (x *Settings_ApiHost) String() string

type Settings_UseCVStartMessage

type Settings_UseCVStartMessage struct {
	ProjectRegexp        []string `protobuf:"bytes,1,rep,name=project_regexp,json=projectRegexp,proto3" json:"project_regexp,omitempty"`
	ProjectRegexpExclude []string `protobuf:"bytes,2,rep,name=project_regexp_exclude,json=projectRegexpExclude,proto3" json:"project_regexp_exclude,omitempty"`
	// contains filtered or unexported fields
}

Post starting message in CV.

The project is opted to CV posting starting message if and only if all 3 hold:

  • project matches at least one project_regexp.
  • project matches no project_regexp_exclude.
  • project matches exactly one ApiHost overall OR exactly one with prod=true.

func (*Settings_UseCVStartMessage) Descriptor deprecated

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

Deprecated: Use Settings_UseCVStartMessage.ProtoReflect.Descriptor instead.

func (*Settings_UseCVStartMessage) GetProjectRegexp

func (x *Settings_UseCVStartMessage) GetProjectRegexp() []string

func (*Settings_UseCVStartMessage) GetProjectRegexpExclude

func (x *Settings_UseCVStartMessage) GetProjectRegexpExclude() []string

func (*Settings_UseCVStartMessage) ProtoMessage

func (*Settings_UseCVStartMessage) ProtoMessage()

func (*Settings_UseCVStartMessage) ProtoReflect

func (*Settings_UseCVStartMessage) Reset

func (x *Settings_UseCVStartMessage) Reset()

func (*Settings_UseCVStartMessage) String

func (x *Settings_UseCVStartMessage) String() string

type Settings_UseCVStatus

type Settings_UseCVStatus struct {
	ProjectRegexp        []string `protobuf:"bytes,1,rep,name=project_regexp,json=projectRegexp,proto3" json:"project_regexp,omitempty"`
	ProjectRegexpExclude []string `protobuf:"bytes,2,rep,name=project_regexp_exclude,json=projectRegexpExclude,proto3" json:"project_regexp_exclude,omitempty"`
	// contains filtered or unexported fields
}

Post link to CV status instead of legacy CQ status app when starting the Run.

The project is opted to CV status if and only if all 3 hold:

  • project matches at least one project_regexp.
  • project matches no project_regexp_exclude.
  • project matches exactly one ApiHost overall OR exactly one with prod=true.

func (*Settings_UseCVStatus) Descriptor deprecated

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

Deprecated: Use Settings_UseCVStatus.ProtoReflect.Descriptor instead.

func (*Settings_UseCVStatus) GetProjectRegexp

func (x *Settings_UseCVStatus) GetProjectRegexp() []string

func (*Settings_UseCVStatus) GetProjectRegexpExclude

func (x *Settings_UseCVStatus) GetProjectRegexpExclude() []string

func (*Settings_UseCVStatus) ProtoMessage

func (*Settings_UseCVStatus) ProtoMessage()

func (*Settings_UseCVStatus) ProtoReflect

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

func (*Settings_UseCVStatus) Reset

func (x *Settings_UseCVStatus) Reset()

func (*Settings_UseCVStatus) String

func (x *Settings_UseCVStatus) String() string

type Tryjob

type Tryjob struct {
	Build      *v1.Build              `protobuf:"bytes,1,opt,name=build,proto3" json:"build,omitempty"`
	Status     TryjobStatus           `protobuf:"varint,2,opt,name=status,proto3,enum=migration.TryjobStatus" json:"status,omitempty"`
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	Builder    *proto.BuilderID       `protobuf:"bytes,4,opt,name=builder,proto3" json:"builder,omitempty"`
	// contains filtered or unexported fields
}

func (*Tryjob) Descriptor deprecated

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

Deprecated: Use Tryjob.ProtoReflect.Descriptor instead.

func (*Tryjob) GetBuild

func (x *Tryjob) GetBuild() *v1.Build

func (*Tryjob) GetBuilder

func (x *Tryjob) GetBuilder() *proto.BuilderID

func (*Tryjob) GetCreateTime

func (x *Tryjob) GetCreateTime() *timestamppb.Timestamp

func (*Tryjob) GetStatus

func (x *Tryjob) GetStatus() TryjobStatus

func (*Tryjob) ProtoMessage

func (*Tryjob) ProtoMessage()

func (*Tryjob) ProtoReflect

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

func (*Tryjob) Reset

func (x *Tryjob) Reset()

func (*Tryjob) String

func (x *Tryjob) String() string

type TryjobStatus

type TryjobStatus int32

TryjobStatus mirrors CQDaemon's verification.tryjob_utils.Job.Status.

const (
	TryjobStatus_TRYJOB_STATUS_UNSPECIFIED TryjobStatus = 0
	TryjobStatus_NOT_TRIGGERED             TryjobStatus = 1
	TryjobStatus_PENDING                   TryjobStatus = 2
	TryjobStatus_RUNNING                   TryjobStatus = 3
	TryjobStatus_SUCCEEDED                 TryjobStatus = 4
	TryjobStatus_FAILED                    TryjobStatus = 5
	TryjobStatus_TIMED_OUT                 TryjobStatus = 6
)

func (TryjobStatus) Descriptor

func (TryjobStatus) Enum

func (x TryjobStatus) Enum() *TryjobStatus

func (TryjobStatus) EnumDescriptor deprecated

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

Deprecated: Use TryjobStatus.Descriptor instead.

func (TryjobStatus) Number

func (TryjobStatus) String

func (x TryjobStatus) String() string

func (TryjobStatus) Type

type UnimplementedMigrationServer

type UnimplementedMigrationServer struct {
}

UnimplementedMigrationServer must be embedded to have forward compatible implementations.

func (UnimplementedMigrationServer) FetchActiveRuns

func (UnimplementedMigrationServer) FetchRunStatus

func (UnimplementedMigrationServer) PostGerritMessage

func (UnimplementedMigrationServer) ReportTryjobs

func (UnimplementedMigrationServer) ReportUsedNetrc

func (UnimplementedMigrationServer) ReportVerifiedRun

type UnsafeMigrationServer

type UnsafeMigrationServer interface {
	// contains filtered or unexported methods
}

UnsafeMigrationServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MigrationServer will result in compilation errors.

Jump to

Keyboard shortcuts

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