Documentation
Overview ¶
Package migrationpb is internal to LUCI CV and CQDaemon. DO NOT USE.
Index ¶
- Variables
- func FileDescriptorSet() *descriptorpb.FileDescriptorSet
- func RegisterMigrationServer(s grpc.ServiceRegistrar, srv MigrationServer)
- type MigrationClient
- type MigrationServer
- type PSSAMigration
- type ReportFinishedRunRequest
- func (*ReportFinishedRunRequest) Descriptor() ([]byte, []int)
- func (x *ReportFinishedRunRequest) GetRun() *ReportedRun
- func (*ReportFinishedRunRequest) ProtoMessage()
- func (x *ReportFinishedRunRequest) ProtoReflect() protoreflect.Message
- func (x *ReportFinishedRunRequest) Reset()
- func (x *ReportFinishedRunRequest) String() string
- type ReportRunsRequest
- type ReportUsedNetrcRequest
- func (*ReportUsedNetrcRequest) Descriptor() ([]byte, []int)
- func (x *ReportUsedNetrcRequest) GetAccessToken() string
- func (x *ReportUsedNetrcRequest) GetGerritHost() string
- func (*ReportUsedNetrcRequest) ProtoMessage()
- func (x *ReportUsedNetrcRequest) ProtoReflect() protoreflect.Message
- func (x *ReportUsedNetrcRequest) Reset()
- func (x *ReportUsedNetrcRequest) String() string
- type ReportedRun
- type Settings
- func (*Settings) Descriptor() ([]byte, []int)
- func (x *Settings) GetApiHosts() []*Settings_ApiHost
- func (x *Settings) GetPssaMigration() *PSSAMigration
- func (*Settings) ProtoMessage()
- func (x *Settings) ProtoReflect() protoreflect.Message
- func (x *Settings) Reset()
- func (x *Settings) String() string
- type Settings_ApiHost
- func (*Settings_ApiHost) Descriptor() ([]byte, []int)
- func (x *Settings_ApiHost) GetHost() string
- func (x *Settings_ApiHost) GetProd() bool
- func (x *Settings_ApiHost) GetProjectRegexp() []string
- func (*Settings_ApiHost) ProtoMessage()
- func (x *Settings_ApiHost) ProtoReflect() protoreflect.Message
- func (x *Settings_ApiHost) Reset()
- func (x *Settings_ApiHost) String() string
- type UnimplementedMigrationServer
- func (UnimplementedMigrationServer) ReportFinishedRun(context.Context, *ReportFinishedRunRequest) (*empty.Empty, error)
- func (UnimplementedMigrationServer) ReportRuns(context.Context, *ReportRunsRequest) (*empty.Empty, error)
- func (UnimplementedMigrationServer) ReportUsedNetrc(context.Context, *ReportUsedNetrcRequest) (*empty.Empty, error)
- type UnsafeMigrationServer
Constants ¶
Variables ¶
var File_go_chromium_org_luci_cv_api_migration_migration_proto protoreflect.FileDescriptor
var File_go_chromium_org_luci_cv_api_migration_settings_proto protoreflect.FileDescriptor
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 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. ReportFinishedRun(ctx context.Context, in *ReportFinishedRunRequest, opts ...grpc.CallOption) (*empty.Empty, 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. ReportFinishedRun(context.Context, *ReportFinishedRunRequest) (*empty.Empty, 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 althouhg 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 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 (x *ReportFinishedRunRequest) GetRun() *ReportedRun
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 ReportedRun ¶
type ReportedRun struct { // Re-use BQ attempt for now. Attempt *v1.Attempt `protobuf:"bytes,1,opt,name=attempt,proto3" json:"attempt,omitempty"` // contains filtered or unexported fields }
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) 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 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"` // TODO(tandrii): move this off migration-specific settings once CQDaemon is // shutdown. 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 ¶
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) ProtoMessage ¶
func (*Settings) ProtoMessage()
func (*Settings) ProtoReflect ¶
func (x *Settings) ProtoReflect() protoreflect.Message
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 the regexps, // 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"` // 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) 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 UnimplementedMigrationServer ¶
type UnimplementedMigrationServer struct { }
UnimplementedMigrationServer must be embedded to have forward compatible implementations.
func (UnimplementedMigrationServer) ReportFinishedRun ¶
func (UnimplementedMigrationServer) ReportFinishedRun(context.Context, *ReportFinishedRunRequest) (*empty.Empty, error)
func (UnimplementedMigrationServer) ReportRuns ¶
func (UnimplementedMigrationServer) ReportRuns(context.Context, *ReportRunsRequest) (*empty.Empty, error)
func (UnimplementedMigrationServer) ReportUsedNetrc ¶
func (UnimplementedMigrationServer) ReportUsedNetrc(context.Context, *ReportUsedNetrcRequest) (*empty.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.