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 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 {
            	Runs []*Run `protobuf:"bytes,1,rep,name=runs,proto3" json:"runs,omitempty"`
            	// contains filtered or unexported fields
            }

            func (*FetchActiveRunsResponse) Descriptor

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

              Deprecated: Use FetchActiveRunsResponse.ProtoReflect.Descriptor instead.

              func (*FetchActiveRunsResponse) GetRuns

              func (x *FetchActiveRunsResponse) GetRuns() []*Run

              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) (*empty.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) (*empty.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) (*empty.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) (*empty.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) (*empty.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) (*empty.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) (*empty.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) (*empty.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 {
                          
                          	// List of LUCI Projects which must ues legacy ~/.netrc credentials,
                          	// because although they have registered project-scoped service account
                          	// (PSSA), their Gerrit ACLs aren't ready yet.
                          	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

                            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"`
                            	// 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) 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 {
                              
                              	// If posting succeeded, this is set to the update time of a Gerrit change.
                              	//
                              	// TODO(tandrii): verify if this is actually required for CQDaemon,
                              	// as getting this timestamp requires 1 extra RPC.
                              	GerritUpdateTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=gerrit_update_time,json=gerritUpdateTime,proto3" json:"gerrit_update_time,omitempty"`
                              	// contains filtered or unexported fields
                              }

                              func (*PostGerritMessageResponse) Descriptor

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

                                Deprecated: Use PostGerritMessageResponse.ProtoReflect.Descriptor instead.

                                func (*PostGerritMessageResponse) GetGerritUpdateTime

                                func (x *PostGerritMessageResponse) GetGerritUpdateTime() *timestamppb.Timestamp

                                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 *Run `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 (x *ReportFinishedRunRequest) GetRun() *Run

                                  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 []*Run `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() []*Run

                                    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    *Run                            `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"`
                                      	// If true, CQDaemon is sending this for the sake of the test, notably before
                                      	// CQDaemon starts getting CV's runs. Thus, Run's CV's ID may be unset.
                                      	//
                                      	// This is used to test codepath calling ReportVerifiedRun in the CQDaemon
                                      	// before the switch to CV Runs.
                                      	TestMode bool `protobuf:"varint,21,opt,name=test_mode,json=testMode,proto3" json:"test_mode,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 (x *ReportVerifiedRunRequest) GetRun() *Run

                                        func (*ReportVerifiedRunRequest) GetTestMode

                                        func (x *ReportVerifiedRunRequest) GetTestMode() bool

                                        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 Run

                                            type Run struct {
                                            	Attempt *v1.Attempt `protobuf:"bytes,1,opt,name=attempt,proto3" json:"attempt,omitempty"`
                                            	// CV's run ID.
                                            	Id  string   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
                                            	Cls []*RunCL `protobuf:"bytes,3,rep,name=cls,proto3" json:"cls,omitempty"`
                                            	// contains filtered or unexported fields
                                            }

                                            func (*Run) Descriptor

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

                                              Deprecated: Use Run.ProtoReflect.Descriptor instead.

                                              func (*Run) GetAttempt

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

                                              func (*Run) GetCls

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

                                              func (*Run) GetId

                                              func (x *Run) GetId() string

                                              func (*Run) ProtoMessage

                                              func (*Run) ProtoMessage()

                                              func (*Run) ProtoReflect

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

                                              func (*Run) Reset

                                              func (x *Run) Reset()

                                              func (*Run) String

                                              func (x *Run) 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(tandrii): move this off migration-specific settings once CQDaemon is
                                                    	// shut down. This is located here only to avoid extra throw away code in
                                                    	// CQDaemon to read & refresh these from a different file.
                                                    	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

                                                        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.