migrationpb

package
v0.0.0-...-51f9457 Latest Latest
Warning

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

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

Documentation

Overview

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

Index

Constants

This section is empty.

Variables

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

Enum value maps for ReportVerifiedRunRequest_Action.

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

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

Functions

func FileDescriptorSet 

func FileDescriptorSet() *descriptorpb.FileDescriptorSet

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

Will not return nil.

Do NOT modify the returned descriptor.

func RegisterMigrationServer 

func RegisterMigrationServer(s grpc.ServiceRegistrar, srv MigrationServer)

Types

type ActiveRun 

type ActiveRun struct {

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

ActiveRun.

func (*ActiveRun) Descriptor deprecated 

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

Deprecated: Use ActiveRun.ProtoReflect.Descriptor instead.

func (*ActiveRun) GetCls 

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

func (*ActiveRun) GetFyiDeps 

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

func (*ActiveRun) GetId 

func (x *ActiveRun) GetId() string

func (*ActiveRun) ProtoMessage 

func (*ActiveRun) ProtoMessage()

func (*ActiveRun) ProtoReflect 

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

func (*ActiveRun) Reset 

func (x *ActiveRun) Reset()

func (*ActiveRun) String 

func (x *ActiveRun) String() string

type FetchActiveRunsRequest 

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

func (*FetchActiveRunsRequest) Descriptor deprecated 

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

Deprecated: Use FetchActiveRunsRequest.ProtoReflect.Descriptor instead.

func (*FetchActiveRunsRequest) GetLuciProject 

func (x *FetchActiveRunsRequest) GetLuciProject() string

func (*FetchActiveRunsRequest) ProtoMessage 

func (*FetchActiveRunsRequest) ProtoMessage()

func (*FetchActiveRunsRequest) ProtoReflect 

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

func (*FetchActiveRunsRequest) Reset 

func (x *FetchActiveRunsRequest) Reset()

func (*FetchActiveRunsRequest) String 

func (x *FetchActiveRunsRequest) String() string

type FetchActiveRunsResponse 

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

func (*FetchActiveRunsResponse) Descriptor deprecated 

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

Deprecated: Use FetchActiveRunsResponse.ProtoReflect.Descriptor instead.

func (*FetchActiveRunsResponse) GetActiveRuns 

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

func (*FetchActiveRunsResponse) ProtoMessage 

func (*FetchActiveRunsResponse) ProtoMessage()

func (*FetchActiveRunsResponse) ProtoReflect 

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

func (*FetchActiveRunsResponse) Reset 

func (x *FetchActiveRunsResponse) Reset()

func (*FetchActiveRunsResponse) String 

func (x *FetchActiveRunsResponse) String() string

type FetchRunStatusRequest 

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

func (*FetchRunStatusRequest) Descriptor deprecated 

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

Deprecated: Use FetchRunStatusRequest.ProtoReflect.Descriptor instead.

func (*FetchRunStatusRequest) GetAttemptKey 

func (x *FetchRunStatusRequest) GetAttemptKey() string

func (*FetchRunStatusRequest) GetCvId 

func (x *FetchRunStatusRequest) GetCvId() string

func (*FetchRunStatusRequest) GetLuciProject 

func (x *FetchRunStatusRequest) GetLuciProject() string

func (*FetchRunStatusRequest) ProtoMessage 

func (*FetchRunStatusRequest) ProtoMessage()

func (*FetchRunStatusRequest) ProtoReflect 

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

func (*FetchRunStatusRequest) Reset 

func (x *FetchRunStatusRequest) Reset()

func (*FetchRunStatusRequest) String 

func (x *FetchRunStatusRequest) String() string

type FetchRunStatusResponse 

type FetchRunStatusResponse struct {

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

func (*FetchRunStatusResponse) Descriptor deprecated 

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

Deprecated: Use FetchRunStatusResponse.ProtoReflect.Descriptor instead.

func (*FetchRunStatusResponse) GetEvent 

func (x *FetchRunStatusResponse) GetEvent() string

func (*FetchRunStatusResponse) GetExtra 

func (x *FetchRunStatusResponse) GetExtra() string

func (*FetchRunStatusResponse) ProtoMessage 

func (*FetchRunStatusResponse) ProtoMessage()

func (*FetchRunStatusResponse) ProtoReflect 

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

func (*FetchRunStatusResponse) Reset 

func (x *FetchRunStatusResponse) Reset()

func (*FetchRunStatusResponse) String 

func (x *FetchRunStatusResponse) String() string

type MigrationClient 

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

MigrationClient is the client API for Migration service.

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

func NewMigrationClient 

func NewMigrationClient(cc grpc.ClientConnInterface) MigrationClient

type MigrationServer 

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

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

Deprecated: Use PSSAMigration.ProtoReflect.Descriptor instead.

func (*PSSAMigration) GetProjectsBlocklist deprecated 

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 deprecated 

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

Deprecated: Use PostGerritMessageRequest.ProtoReflect.Descriptor instead.

func (*PostGerritMessageRequest) GetAttemptKey 

func (x *PostGerritMessageRequest) GetAttemptKey() string

func (*PostGerritMessageRequest) GetChange 

func (x *PostGerritMessageRequest) GetChange() int64

func (*PostGerritMessageRequest) GetComment 

func (x *PostGerritMessageRequest) GetComment() string

func (*PostGerritMessageRequest) GetHost 

func (x *PostGerritMessageRequest) GetHost() string

func (*PostGerritMessageRequest) GetProject 

func (x *PostGerritMessageRequest) GetProject() string

func (*PostGerritMessageRequest) GetRevision 

func (x *PostGerritMessageRequest) GetRevision() string

func (*PostGerritMessageRequest) GetRunId 

func (x *PostGerritMessageRequest) GetRunId() string

func (*PostGerritMessageRequest) GetSendEmail 

func (x *PostGerritMessageRequest) GetSendEmail() bool

func (*PostGerritMessageRequest) ProtoMessage 

func (*PostGerritMessageRequest) ProtoMessage()

func (*PostGerritMessageRequest) ProtoReflect 

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

func (*PostGerritMessageRequest) Reset 

func (x *PostGerritMessageRequest) Reset()

func (*PostGerritMessageRequest) String 

func (x *PostGerritMessageRequest) String() string

type PostGerritMessageResponse 

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

func (*PostGerritMessageResponse) Descriptor deprecated 

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

Deprecated: Use PostGerritMessageResponse.ProtoReflect.Descriptor instead.

func (*PostGerritMessageResponse) ProtoMessage 

func (*PostGerritMessageResponse) ProtoMessage()

func (*PostGerritMessageResponse) ProtoReflect 

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

func (*PostGerritMessageResponse) Reset 

func (x *PostGerritMessageResponse) Reset()

func (*PostGerritMessageResponse) String 

func (x *PostGerritMessageResponse) String() string

type ReportUsedNetrcRequest 

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

func (*ReportUsedNetrcRequest) Descriptor deprecated 

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

Deprecated: Use ReportUsedNetrcRequest.ProtoReflect.Descriptor instead.

func (*ReportUsedNetrcRequest) GetAccessToken 

func (x *ReportUsedNetrcRequest) GetAccessToken() string

func (*ReportUsedNetrcRequest) GetGerritHost 

func (x *ReportUsedNetrcRequest) GetGerritHost() string

func (*ReportUsedNetrcRequest) ProtoMessage 

func (*ReportUsedNetrcRequest) ProtoMessage()

func (*ReportUsedNetrcRequest) ProtoReflect 

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

func (*ReportUsedNetrcRequest) Reset 

func (x *ReportUsedNetrcRequest) Reset()

func (*ReportUsedNetrcRequest) String 

func (x *ReportUsedNetrcRequest) String() string

type ReportVerifiedRunRequest 

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

func (*ReportVerifiedRunRequest) Descriptor deprecated 

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

Deprecated: Use ReportVerifiedRunRequest.ProtoReflect.Descriptor instead.

func (*ReportVerifiedRunRequest) GetAction 

func (x *ReportVerifiedRunRequest) GetAction() ReportVerifiedRunRequest_Action

func (*ReportVerifiedRunRequest) GetFinalMessage 

func (x *ReportVerifiedRunRequest) GetFinalMessage() string

func (*ReportVerifiedRunRequest) GetRun 

func (x *ReportVerifiedRunRequest) GetRun() *ReportedRun

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) Descriptor() protoreflect.EnumDescriptor

func (ReportVerifiedRunRequest_Action) Enum 

func (x ReportVerifiedRunRequest_Action) Enum() *ReportVerifiedRunRequest_Action

func (ReportVerifiedRunRequest_Action) EnumDescriptor deprecated 

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

Deprecated: Use ReportVerifiedRunRequest_Action.Descriptor instead.

func (ReportVerifiedRunRequest_Action) Number 

func (x ReportVerifiedRunRequest_Action) Number() protoreflect.EnumNumber

func (ReportVerifiedRunRequest_Action) String 

func (x ReportVerifiedRunRequest_Action) String() string

func (ReportVerifiedRunRequest_Action) Type 

func (ReportVerifiedRunRequest_Action) Type() protoreflect.EnumType

type ReportedRun 

type ReportedRun struct {

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

ReportedRun as reported by the CQDaemon to CV.

func (*ReportedRun) Descriptor deprecated 

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

Deprecated: Use ReportedRun.ProtoReflect.Descriptor instead.

func (*ReportedRun) GetAttempt 

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

func (*ReportedRun) GetId 

func (x *ReportedRun) GetId() string

func (*ReportedRun) ProtoMessage 

func (*ReportedRun) ProtoMessage()

func (*ReportedRun) ProtoReflect 

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

func (*ReportedRun) Reset 

func (x *ReportedRun) Reset()

func (*ReportedRun) String 

func (x *ReportedRun) String() string

type RunCL 

type RunCL struct {

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

func (*RunCL) Descriptor deprecated 

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

Deprecated: Use RunCL.ProtoReflect.Descriptor instead.

func (*RunCL) GetDeps 

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

func (*RunCL) GetFiles 

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

func (*RunCL) GetGc 

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

func (*RunCL) GetId 

func (x *RunCL) GetId() int64

func (*RunCL) GetInfo 

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

func (*RunCL) GetTrigger 

func (x *RunCL) GetTrigger() *RunCL_Trigger

func (*RunCL) ProtoMessage 

func (*RunCL) ProtoMessage()

func (*RunCL) ProtoReflect 

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

func (*RunCL) Reset 

func (x *RunCL) Reset()

func (*RunCL) String 

func (x *RunCL) String() string

type RunCL_Dep 

type RunCL_Dep struct {

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

func (*RunCL_Dep) Descriptor deprecated 

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

Deprecated: Use RunCL_Dep.ProtoReflect.Descriptor instead.

func (*RunCL_Dep) GetHard 

func (x *RunCL_Dep) GetHard() bool

func (*RunCL_Dep) GetId 

func (x *RunCL_Dep) GetId() int64

func (*RunCL_Dep) ProtoMessage 

func (*RunCL_Dep) ProtoMessage()

func (*RunCL_Dep) ProtoReflect 

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

func (*RunCL_Dep) Reset 

func (x *RunCL_Dep) Reset()

func (*RunCL_Dep) String 

func (x *RunCL_Dep) String() string

type RunCL_Trigger 

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

func (*RunCL_Trigger) Descriptor deprecated 

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

Deprecated: Use RunCL_Trigger.ProtoReflect.Descriptor instead.

func (*RunCL_Trigger) GetAccountId 

func (x *RunCL_Trigger) GetAccountId() int64

func (*RunCL_Trigger) GetEmail 

func (x *RunCL_Trigger) GetEmail() string

func (*RunCL_Trigger) GetTime 

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

func (*RunCL_Trigger) ProtoMessage 

func (*RunCL_Trigger) ProtoMessage()

func (*RunCL_Trigger) ProtoReflect 

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

func (*RunCL_Trigger) Reset 

func (x *RunCL_Trigger) Reset()

func (*RunCL_Trigger) String 

func (x *RunCL_Trigger) String() string

type Settings 

type Settings struct {

	// CQDaemon doesn't really have a -dev version, therefore to test -dev of CV,
	// 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 deprecated 

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

Deprecated: Use Settings.ProtoReflect.Descriptor instead.

func (*Settings) GetApiHosts 

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

func (*Settings) GetPssaMigration deprecated 

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 deprecated 

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

Deprecated: Use Settings_ApiHost.ProtoReflect.Descriptor instead.

func (*Settings_ApiHost) GetHost 

func (x *Settings_ApiHost) GetHost() string

func (*Settings_ApiHost) GetProd 

func (x *Settings_ApiHost) GetProd() bool

func (*Settings_ApiHost) GetProjectRegexp 

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

func (*Settings_ApiHost) GetProjectRegexpExclude 

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

func (*Settings_ApiHost) ProtoMessage 

func (*Settings_ApiHost) ProtoMessage()

func (*Settings_ApiHost) ProtoReflect 

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

func (*Settings_ApiHost) Reset 

func (x *Settings_ApiHost) Reset()

func (*Settings_ApiHost) String 

func (x *Settings_ApiHost) String() string

type Settings_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 deprecated 

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) FetchActiveRuns(context.Context, *FetchActiveRunsRequest) (*FetchActiveRunsResponse, error)

func (UnimplementedMigrationServer) FetchRunStatus 

func (UnimplementedMigrationServer) FetchRunStatus(context.Context, *FetchRunStatusRequest) (*FetchRunStatusResponse, error)

func (UnimplementedMigrationServer) PostGerritMessage 

func (UnimplementedMigrationServer) PostGerritMessage(context.Context, *PostGerritMessageRequest) (*PostGerritMessageResponse, error)

func (UnimplementedMigrationServer) ReportUsedNetrc 

func (UnimplementedMigrationServer) ReportUsedNetrc(context.Context, *ReportUsedNetrcRequest) (*emptypb.Empty, error)

func (UnimplementedMigrationServer) ReportVerifiedRun 

func (UnimplementedMigrationServer) ReportVerifiedRun(context.Context, *ReportVerifiedRunRequest) (*emptypb.Empty, error)

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.

Source Files

View all Source files

Jump to

Keyboard shortcuts

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