Documentation

Overview

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

Index

Constants

This section is empty.

Variables

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: "ReportRuns",
			Handler:    _Migration_ReportRuns_Handler,
		},
		{
			MethodName: "ReportFinishedRun",
			Handler:    _Migration_ReportFinishedRun_Handler,
		},
		{
			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: "FetchExcludedCLs",
			Handler:    _Migration_FetchExcludedCLs_Handler,
		},
		{
			MethodName: "ReportUsedNetrc",
			Handler:    _Migration_ReportUsedNetrc_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

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

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

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 FetchExcludedCLsRequest

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

func (*FetchExcludedCLsRequest) Descriptor

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

Deprecated: Use FetchExcludedCLsRequest.ProtoReflect.Descriptor instead.

func (*FetchExcludedCLsRequest) GetLuciProject

func (x *FetchExcludedCLsRequest) GetLuciProject() string

func (*FetchExcludedCLsRequest) ProtoMessage

func (*FetchExcludedCLsRequest) ProtoMessage()

func (*FetchExcludedCLsRequest) ProtoReflect

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

func (*FetchExcludedCLsRequest) Reset

func (x *FetchExcludedCLsRequest) Reset()

func (*FetchExcludedCLsRequest) String

func (x *FetchExcludedCLsRequest) String() string

type FetchExcludedCLsResponse

type FetchExcludedCLsResponse struct {

	// Each CL has only host and change number set.
	Cls []*v1.GerritChange `protobuf:"bytes,1,rep,name=cls,proto3" json:"cls,omitempty"`
	// contains filtered or unexported fields
}

func (*FetchExcludedCLsResponse) Descriptor

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

Deprecated: Use FetchExcludedCLsResponse.ProtoReflect.Descriptor instead.

func (*FetchExcludedCLsResponse) GetCls

func (x *FetchExcludedCLsResponse) GetCls() []*v1.GerritChange

func (*FetchExcludedCLsResponse) ProtoMessage

func (*FetchExcludedCLsResponse) ProtoMessage()

func (*FetchExcludedCLsResponse) ProtoReflect

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

func (*FetchExcludedCLsResponse) Reset

func (x *FetchExcludedCLsResponse) Reset()

func (*FetchExcludedCLsResponse) String

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

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

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 {
	// ReportRuns notifies CV of the Runs CQDaemon is currently working with.
	//
	// Used to determine whether CV's view of the world matches that of CQDaemon.
	// Initially, this is just FYI for CV.
	ReportRuns(ctx context.Context, in *ReportRunsRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// ReportFinishedRun notifies CV of the Run CQDaemon has just finalized.
	//
	// The Run may not contain CV's id, but CV can figure out the the ID using
	// Run.Attempt.Key.
	//
	// Called by CQDaemon when CQDaemon is in charge of run management.
	ReportFinishedRun(ctx context.Context, in *ReportFinishedRunRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// 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)
	// FetchExcludedCLs returns all CLs referenced by ReportVerifiedRuns but with
	// not yet ended Runs.
	//
	// CQDaemon uses this to avoid processing these CLs when computing its own
	// list of candidates.
	//
	// Called by CQDaemon when CQDaemon is in charge of run management.
	FetchExcludedCLs(ctx context.Context, in *FetchExcludedCLsRequest, opts ...grpc.CallOption) (*FetchExcludedCLsResponse, error)
	// ReportUsedNetrc notifies CV of the legacy .netrc credentials used by
	// CQDaemon.
	ReportUsedNetrc(ctx context.Context, in *ReportUsedNetrcRequest, 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 {
	// ReportRuns notifies CV of the Runs CQDaemon is currently working with.
	//
	// Used to determine whether CV's view of the world matches that of CQDaemon.
	// Initially, this is just FYI for CV.
	ReportRuns(context.Context, *ReportRunsRequest) (*emptypb.Empty, error)
	// ReportFinishedRun notifies CV of the Run CQDaemon has just finalized.
	//
	// The Run may not contain CV's id, but CV can figure out the the ID using
	// Run.Attempt.Key.
	//
	// Called by CQDaemon when CQDaemon is in charge of run management.
	ReportFinishedRun(context.Context, *ReportFinishedRunRequest) (*emptypb.Empty, error)
	// 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)
	// FetchExcludedCLs returns all CLs referenced by ReportVerifiedRuns but with
	// not yet ended Runs.
	//
	// CQDaemon uses this to avoid processing these CLs when computing its own
	// list of candidates.
	//
	// Called by CQDaemon when CQDaemon is in charge of run management.
	FetchExcludedCLs(context.Context, *FetchExcludedCLsRequest) (*FetchExcludedCLsResponse, error)
	// ReportUsedNetrc notifies CV of the legacy .netrc credentials used by
	// CQDaemon.
	ReportUsedNetrc(context.Context, *ReportUsedNetrcRequest) (*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 PSSAMigration

type PSSAMigration struct {

	// Deprecated: Do not use.
	ProjectsBlocklist []string `protobuf:"bytes,1,rep,name=projects_blocklist,json=projectsBlocklist,proto3" json:"projects_blocklist,omitempty"`
	// contains filtered or unexported fields
}

func (*PSSAMigration) Descriptor

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

Deprecated: Use PSSAMigration.ProtoReflect.Descriptor instead.

func (*PSSAMigration) GetProjectsBlocklist

func (x *PSSAMigration) GetProjectsBlocklist() []string

Deprecated: Do not use.

func (*PSSAMigration) ProtoMessage

func (*PSSAMigration) ProtoMessage()

func (*PSSAMigration) ProtoReflect

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

func (*PSSAMigration) Reset

func (x *PSSAMigration) Reset()

func (*PSSAMigration) String

func (x *PSSAMigration) String() string

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

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

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 ReportFinishedRunRequest

type ReportFinishedRunRequest struct {
	Run *ReportedRun `protobuf:"bytes,1,opt,name=run,proto3" json:"run,omitempty"`
	// contains filtered or unexported fields
}

func (*ReportFinishedRunRequest) Descriptor

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

Deprecated: Use ReportFinishedRunRequest.ProtoReflect.Descriptor instead.

func (*ReportFinishedRunRequest) GetRun

func (*ReportFinishedRunRequest) ProtoMessage

func (*ReportFinishedRunRequest) ProtoMessage()

func (*ReportFinishedRunRequest) ProtoReflect

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

func (*ReportFinishedRunRequest) Reset

func (x *ReportFinishedRunRequest) Reset()

func (*ReportFinishedRunRequest) String

func (x *ReportFinishedRunRequest) String() string

type ReportRunsRequest

type ReportRunsRequest struct {
	Runs []*ReportedRun `protobuf:"bytes,1,rep,name=runs,proto3" json:"runs,omitempty"`
	// contains filtered or unexported fields
}

func (*ReportRunsRequest) Descriptor

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

Deprecated: Use ReportRunsRequest.ProtoReflect.Descriptor instead.

func (*ReportRunsRequest) GetRuns

func (x *ReportRunsRequest) GetRuns() []*ReportedRun

func (*ReportRunsRequest) ProtoMessage

func (*ReportRunsRequest) ProtoMessage()

func (*ReportRunsRequest) ProtoReflect

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

func (*ReportRunsRequest) Reset

func (x *ReportRunsRequest) Reset()

func (*ReportRunsRequest) String

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

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

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

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

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

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

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

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,
	// production CQDaemon can connect to both prod and dev migration API.
	ApiHosts  []*Settings_ApiHost `protobuf:"bytes,1,rep,name=api_hosts,json=apiHosts,proto3" json:"api_hosts,omitempty"`
	UseCvRuns *Settings_UseCVRuns `protobuf:"bytes,3,opt,name=use_cv_runs,json=useCvRuns,proto3" json:"use_cv_runs,omitempty"`
	// TODO(1210686): delete after 2021-05-31, at which point nothing should refer
	// to it.
	//
	// Deprecated: Do not use.
	PssaMigration *PSSAMigration `protobuf:"bytes,2,opt,name=pssa_migration,json=pssaMigration,proto3" json:"pssa_migration,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

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

Deprecated: Use Settings.ProtoReflect.Descriptor instead.

func (*Settings) GetApiHosts

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

func (*Settings) GetPssaMigration

func (x *Settings) GetPssaMigration() *PSSAMigration

Deprecated: Do not use.

func (*Settings) GetUseCvRuns

func (x *Settings) GetUseCvRuns() *Settings_UseCVRuns

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

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_UseCVRuns

type Settings_UseCVRuns 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
}

Determines which projects should start relying on CV for computing Runs to work on.

The project is using CV Runs 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 with prod=true.

func (*Settings_UseCVRuns) Descriptor

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

Deprecated: Use Settings_UseCVRuns.ProtoReflect.Descriptor instead.

func (*Settings_UseCVRuns) GetProjectRegexp

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

func (*Settings_UseCVRuns) GetProjectRegexpExclude

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

func (*Settings_UseCVRuns) ProtoMessage

func (*Settings_UseCVRuns) ProtoMessage()

func (*Settings_UseCVRuns) ProtoReflect

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

func (*Settings_UseCVRuns) Reset

func (x *Settings_UseCVRuns) Reset()

func (*Settings_UseCVRuns) String

func (x *Settings_UseCVRuns) String() string

type UnimplementedMigrationServer

type UnimplementedMigrationServer struct {
}

UnimplementedMigrationServer must be embedded to have forward compatible implementations.

func (UnimplementedMigrationServer) FetchActiveRuns

func (UnimplementedMigrationServer) FetchExcludedCLs

func (UnimplementedMigrationServer) FetchRunStatus

func (UnimplementedMigrationServer) PostGerritMessage

func (UnimplementedMigrationServer) ReportFinishedRun

func (UnimplementedMigrationServer) ReportRuns

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.