1// Code generated by protoc-gen-go. DO NOT EDIT. 2// source: google/spanner/admin/database/v1/spanner_database_admin.proto 3 4package database // import "google.golang.org/genproto/googleapis/spanner/admin/database/v1" 5 6import proto "github.com/golang/protobuf/proto" 7import fmt "fmt" 8import math "math" 9import empty "github.com/golang/protobuf/ptypes/empty" 10import timestamp "github.com/golang/protobuf/ptypes/timestamp" 11import _ "google.golang.org/genproto/googleapis/api/annotations" 12import v1 "google.golang.org/genproto/googleapis/iam/v1" 13import longrunning "google.golang.org/genproto/googleapis/longrunning" 14 15import ( 16 context "golang.org/x/net/context" 17 grpc "google.golang.org/grpc" 18) 19 20// Reference imports to suppress errors if they are not otherwise used. 21var _ = proto.Marshal 22var _ = fmt.Errorf 23var _ = math.Inf 24 25// This is a compile-time assertion to ensure that this generated file 26// is compatible with the proto package it is being compiled against. 27// A compilation error at this line likely means your copy of the 28// proto package needs to be updated. 29const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package 30 31// Indicates the current state of the database. 32type Database_State int32 33 34const ( 35 // Not specified. 36 Database_STATE_UNSPECIFIED Database_State = 0 37 // The database is still being created. Operations on the database may fail 38 // with `FAILED_PRECONDITION` in this state. 39 Database_CREATING Database_State = 1 40 // The database is fully created and ready for use. 41 Database_READY Database_State = 2 42) 43 44var Database_State_name = map[int32]string{ 45 0: "STATE_UNSPECIFIED", 46 1: "CREATING", 47 2: "READY", 48} 49var Database_State_value = map[string]int32{ 50 "STATE_UNSPECIFIED": 0, 51 "CREATING": 1, 52 "READY": 2, 53} 54 55func (x Database_State) String() string { 56 return proto.EnumName(Database_State_name, int32(x)) 57} 58func (Database_State) EnumDescriptor() ([]byte, []int) { 59 return fileDescriptor_spanner_database_admin_7b69d4ce340cae98, []int{0, 0} 60} 61 62// A Cloud Spanner database. 63type Database struct { 64 // Required. The name of the database. Values are of the form 65 // `projects/<project>/instances/<instance>/databases/<database>`, 66 // where `<database>` is as specified in the `CREATE DATABASE` 67 // statement. This name can be passed to other API methods to 68 // identify the database. 69 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 70 // Output only. The current database state. 71 State Database_State `protobuf:"varint,2,opt,name=state,proto3,enum=google.spanner.admin.database.v1.Database_State" json:"state,omitempty"` 72 XXX_NoUnkeyedLiteral struct{} `json:"-"` 73 XXX_unrecognized []byte `json:"-"` 74 XXX_sizecache int32 `json:"-"` 75} 76 77func (m *Database) Reset() { *m = Database{} } 78func (m *Database) String() string { return proto.CompactTextString(m) } 79func (*Database) ProtoMessage() {} 80func (*Database) Descriptor() ([]byte, []int) { 81 return fileDescriptor_spanner_database_admin_7b69d4ce340cae98, []int{0} 82} 83func (m *Database) XXX_Unmarshal(b []byte) error { 84 return xxx_messageInfo_Database.Unmarshal(m, b) 85} 86func (m *Database) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 87 return xxx_messageInfo_Database.Marshal(b, m, deterministic) 88} 89func (dst *Database) XXX_Merge(src proto.Message) { 90 xxx_messageInfo_Database.Merge(dst, src) 91} 92func (m *Database) XXX_Size() int { 93 return xxx_messageInfo_Database.Size(m) 94} 95func (m *Database) XXX_DiscardUnknown() { 96 xxx_messageInfo_Database.DiscardUnknown(m) 97} 98 99var xxx_messageInfo_Database proto.InternalMessageInfo 100 101func (m *Database) GetName() string { 102 if m != nil { 103 return m.Name 104 } 105 return "" 106} 107 108func (m *Database) GetState() Database_State { 109 if m != nil { 110 return m.State 111 } 112 return Database_STATE_UNSPECIFIED 113} 114 115// The request for [ListDatabases][google.spanner.admin.database.v1.DatabaseAdmin.ListDatabases]. 116type ListDatabasesRequest struct { 117 // Required. The instance whose databases should be listed. 118 // Values are of the form `projects/<project>/instances/<instance>`. 119 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` 120 // Number of databases to be returned in the response. If 0 or less, 121 // defaults to the server's maximum allowed page size. 122 PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` 123 // If non-empty, `page_token` should contain a 124 // [next_page_token][google.spanner.admin.database.v1.ListDatabasesResponse.next_page_token] from a 125 // previous [ListDatabasesResponse][google.spanner.admin.database.v1.ListDatabasesResponse]. 126 PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` 127 XXX_NoUnkeyedLiteral struct{} `json:"-"` 128 XXX_unrecognized []byte `json:"-"` 129 XXX_sizecache int32 `json:"-"` 130} 131 132func (m *ListDatabasesRequest) Reset() { *m = ListDatabasesRequest{} } 133func (m *ListDatabasesRequest) String() string { return proto.CompactTextString(m) } 134func (*ListDatabasesRequest) ProtoMessage() {} 135func (*ListDatabasesRequest) Descriptor() ([]byte, []int) { 136 return fileDescriptor_spanner_database_admin_7b69d4ce340cae98, []int{1} 137} 138func (m *ListDatabasesRequest) XXX_Unmarshal(b []byte) error { 139 return xxx_messageInfo_ListDatabasesRequest.Unmarshal(m, b) 140} 141func (m *ListDatabasesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 142 return xxx_messageInfo_ListDatabasesRequest.Marshal(b, m, deterministic) 143} 144func (dst *ListDatabasesRequest) XXX_Merge(src proto.Message) { 145 xxx_messageInfo_ListDatabasesRequest.Merge(dst, src) 146} 147func (m *ListDatabasesRequest) XXX_Size() int { 148 return xxx_messageInfo_ListDatabasesRequest.Size(m) 149} 150func (m *ListDatabasesRequest) XXX_DiscardUnknown() { 151 xxx_messageInfo_ListDatabasesRequest.DiscardUnknown(m) 152} 153 154var xxx_messageInfo_ListDatabasesRequest proto.InternalMessageInfo 155 156func (m *ListDatabasesRequest) GetParent() string { 157 if m != nil { 158 return m.Parent 159 } 160 return "" 161} 162 163func (m *ListDatabasesRequest) GetPageSize() int32 { 164 if m != nil { 165 return m.PageSize 166 } 167 return 0 168} 169 170func (m *ListDatabasesRequest) GetPageToken() string { 171 if m != nil { 172 return m.PageToken 173 } 174 return "" 175} 176 177// The response for [ListDatabases][google.spanner.admin.database.v1.DatabaseAdmin.ListDatabases]. 178type ListDatabasesResponse struct { 179 // Databases that matched the request. 180 Databases []*Database `protobuf:"bytes,1,rep,name=databases,proto3" json:"databases,omitempty"` 181 // `next_page_token` can be sent in a subsequent 182 // [ListDatabases][google.spanner.admin.database.v1.DatabaseAdmin.ListDatabases] call to fetch more 183 // of the matching databases. 184 NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` 185 XXX_NoUnkeyedLiteral struct{} `json:"-"` 186 XXX_unrecognized []byte `json:"-"` 187 XXX_sizecache int32 `json:"-"` 188} 189 190func (m *ListDatabasesResponse) Reset() { *m = ListDatabasesResponse{} } 191func (m *ListDatabasesResponse) String() string { return proto.CompactTextString(m) } 192func (*ListDatabasesResponse) ProtoMessage() {} 193func (*ListDatabasesResponse) Descriptor() ([]byte, []int) { 194 return fileDescriptor_spanner_database_admin_7b69d4ce340cae98, []int{2} 195} 196func (m *ListDatabasesResponse) XXX_Unmarshal(b []byte) error { 197 return xxx_messageInfo_ListDatabasesResponse.Unmarshal(m, b) 198} 199func (m *ListDatabasesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 200 return xxx_messageInfo_ListDatabasesResponse.Marshal(b, m, deterministic) 201} 202func (dst *ListDatabasesResponse) XXX_Merge(src proto.Message) { 203 xxx_messageInfo_ListDatabasesResponse.Merge(dst, src) 204} 205func (m *ListDatabasesResponse) XXX_Size() int { 206 return xxx_messageInfo_ListDatabasesResponse.Size(m) 207} 208func (m *ListDatabasesResponse) XXX_DiscardUnknown() { 209 xxx_messageInfo_ListDatabasesResponse.DiscardUnknown(m) 210} 211 212var xxx_messageInfo_ListDatabasesResponse proto.InternalMessageInfo 213 214func (m *ListDatabasesResponse) GetDatabases() []*Database { 215 if m != nil { 216 return m.Databases 217 } 218 return nil 219} 220 221func (m *ListDatabasesResponse) GetNextPageToken() string { 222 if m != nil { 223 return m.NextPageToken 224 } 225 return "" 226} 227 228// The request for [CreateDatabase][google.spanner.admin.database.v1.DatabaseAdmin.CreateDatabase]. 229type CreateDatabaseRequest struct { 230 // Required. The name of the instance that will serve the new database. 231 // Values are of the form `projects/<project>/instances/<instance>`. 232 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` 233 // Required. A `CREATE DATABASE` statement, which specifies the ID of the 234 // new database. The database ID must conform to the regular expression 235 // `[a-z][a-z0-9_\-]*[a-z0-9]` and be between 2 and 30 characters in length. 236 // If the database ID is a reserved word or if it contains a hyphen, the 237 // database ID must be enclosed in backticks (`` ` ``). 238 CreateStatement string `protobuf:"bytes,2,opt,name=create_statement,json=createStatement,proto3" json:"create_statement,omitempty"` 239 // An optional list of DDL statements to run inside the newly created 240 // database. Statements can create tables, indexes, etc. These 241 // statements execute atomically with the creation of the database: 242 // if there is an error in any statement, the database is not created. 243 ExtraStatements []string `protobuf:"bytes,3,rep,name=extra_statements,json=extraStatements,proto3" json:"extra_statements,omitempty"` 244 XXX_NoUnkeyedLiteral struct{} `json:"-"` 245 XXX_unrecognized []byte `json:"-"` 246 XXX_sizecache int32 `json:"-"` 247} 248 249func (m *CreateDatabaseRequest) Reset() { *m = CreateDatabaseRequest{} } 250func (m *CreateDatabaseRequest) String() string { return proto.CompactTextString(m) } 251func (*CreateDatabaseRequest) ProtoMessage() {} 252func (*CreateDatabaseRequest) Descriptor() ([]byte, []int) { 253 return fileDescriptor_spanner_database_admin_7b69d4ce340cae98, []int{3} 254} 255func (m *CreateDatabaseRequest) XXX_Unmarshal(b []byte) error { 256 return xxx_messageInfo_CreateDatabaseRequest.Unmarshal(m, b) 257} 258func (m *CreateDatabaseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 259 return xxx_messageInfo_CreateDatabaseRequest.Marshal(b, m, deterministic) 260} 261func (dst *CreateDatabaseRequest) XXX_Merge(src proto.Message) { 262 xxx_messageInfo_CreateDatabaseRequest.Merge(dst, src) 263} 264func (m *CreateDatabaseRequest) XXX_Size() int { 265 return xxx_messageInfo_CreateDatabaseRequest.Size(m) 266} 267func (m *CreateDatabaseRequest) XXX_DiscardUnknown() { 268 xxx_messageInfo_CreateDatabaseRequest.DiscardUnknown(m) 269} 270 271var xxx_messageInfo_CreateDatabaseRequest proto.InternalMessageInfo 272 273func (m *CreateDatabaseRequest) GetParent() string { 274 if m != nil { 275 return m.Parent 276 } 277 return "" 278} 279 280func (m *CreateDatabaseRequest) GetCreateStatement() string { 281 if m != nil { 282 return m.CreateStatement 283 } 284 return "" 285} 286 287func (m *CreateDatabaseRequest) GetExtraStatements() []string { 288 if m != nil { 289 return m.ExtraStatements 290 } 291 return nil 292} 293 294// Metadata type for the operation returned by 295// [CreateDatabase][google.spanner.admin.database.v1.DatabaseAdmin.CreateDatabase]. 296type CreateDatabaseMetadata struct { 297 // The database being created. 298 Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"` 299 XXX_NoUnkeyedLiteral struct{} `json:"-"` 300 XXX_unrecognized []byte `json:"-"` 301 XXX_sizecache int32 `json:"-"` 302} 303 304func (m *CreateDatabaseMetadata) Reset() { *m = CreateDatabaseMetadata{} } 305func (m *CreateDatabaseMetadata) String() string { return proto.CompactTextString(m) } 306func (*CreateDatabaseMetadata) ProtoMessage() {} 307func (*CreateDatabaseMetadata) Descriptor() ([]byte, []int) { 308 return fileDescriptor_spanner_database_admin_7b69d4ce340cae98, []int{4} 309} 310func (m *CreateDatabaseMetadata) XXX_Unmarshal(b []byte) error { 311 return xxx_messageInfo_CreateDatabaseMetadata.Unmarshal(m, b) 312} 313func (m *CreateDatabaseMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 314 return xxx_messageInfo_CreateDatabaseMetadata.Marshal(b, m, deterministic) 315} 316func (dst *CreateDatabaseMetadata) XXX_Merge(src proto.Message) { 317 xxx_messageInfo_CreateDatabaseMetadata.Merge(dst, src) 318} 319func (m *CreateDatabaseMetadata) XXX_Size() int { 320 return xxx_messageInfo_CreateDatabaseMetadata.Size(m) 321} 322func (m *CreateDatabaseMetadata) XXX_DiscardUnknown() { 323 xxx_messageInfo_CreateDatabaseMetadata.DiscardUnknown(m) 324} 325 326var xxx_messageInfo_CreateDatabaseMetadata proto.InternalMessageInfo 327 328func (m *CreateDatabaseMetadata) GetDatabase() string { 329 if m != nil { 330 return m.Database 331 } 332 return "" 333} 334 335// The request for [GetDatabase][google.spanner.admin.database.v1.DatabaseAdmin.GetDatabase]. 336type GetDatabaseRequest struct { 337 // Required. The name of the requested database. Values are of the form 338 // `projects/<project>/instances/<instance>/databases/<database>`. 339 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 340 XXX_NoUnkeyedLiteral struct{} `json:"-"` 341 XXX_unrecognized []byte `json:"-"` 342 XXX_sizecache int32 `json:"-"` 343} 344 345func (m *GetDatabaseRequest) Reset() { *m = GetDatabaseRequest{} } 346func (m *GetDatabaseRequest) String() string { return proto.CompactTextString(m) } 347func (*GetDatabaseRequest) ProtoMessage() {} 348func (*GetDatabaseRequest) Descriptor() ([]byte, []int) { 349 return fileDescriptor_spanner_database_admin_7b69d4ce340cae98, []int{5} 350} 351func (m *GetDatabaseRequest) XXX_Unmarshal(b []byte) error { 352 return xxx_messageInfo_GetDatabaseRequest.Unmarshal(m, b) 353} 354func (m *GetDatabaseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 355 return xxx_messageInfo_GetDatabaseRequest.Marshal(b, m, deterministic) 356} 357func (dst *GetDatabaseRequest) XXX_Merge(src proto.Message) { 358 xxx_messageInfo_GetDatabaseRequest.Merge(dst, src) 359} 360func (m *GetDatabaseRequest) XXX_Size() int { 361 return xxx_messageInfo_GetDatabaseRequest.Size(m) 362} 363func (m *GetDatabaseRequest) XXX_DiscardUnknown() { 364 xxx_messageInfo_GetDatabaseRequest.DiscardUnknown(m) 365} 366 367var xxx_messageInfo_GetDatabaseRequest proto.InternalMessageInfo 368 369func (m *GetDatabaseRequest) GetName() string { 370 if m != nil { 371 return m.Name 372 } 373 return "" 374} 375 376// Enqueues the given DDL statements to be applied, in order but not 377// necessarily all at once, to the database schema at some point (or 378// points) in the future. The server checks that the statements 379// are executable (syntactically valid, name tables that exist, etc.) 380// before enqueueing them, but they may still fail upon 381// later execution (e.g., if a statement from another batch of 382// statements is applied first and it conflicts in some way, or if 383// there is some data-related problem like a `NULL` value in a column to 384// which `NOT NULL` would be added). If a statement fails, all 385// subsequent statements in the batch are automatically cancelled. 386// 387// Each batch of statements is assigned a name which can be used with 388// the [Operations][google.longrunning.Operations] API to monitor 389// progress. See the 390// [operation_id][google.spanner.admin.database.v1.UpdateDatabaseDdlRequest.operation_id] field for more 391// details. 392type UpdateDatabaseDdlRequest struct { 393 // Required. The database to update. 394 Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"` 395 // DDL statements to be applied to the database. 396 Statements []string `protobuf:"bytes,2,rep,name=statements,proto3" json:"statements,omitempty"` 397 // If empty, the new update request is assigned an 398 // automatically-generated operation ID. Otherwise, `operation_id` 399 // is used to construct the name of the resulting 400 // [Operation][google.longrunning.Operation]. 401 // 402 // Specifying an explicit operation ID simplifies determining 403 // whether the statements were executed in the event that the 404 // [UpdateDatabaseDdl][google.spanner.admin.database.v1.DatabaseAdmin.UpdateDatabaseDdl] call is replayed, 405 // or the return value is otherwise lost: the [database][google.spanner.admin.database.v1.UpdateDatabaseDdlRequest.database] and 406 // `operation_id` fields can be combined to form the 407 // [name][google.longrunning.Operation.name] of the resulting 408 // [longrunning.Operation][google.longrunning.Operation]: `<database>/operations/<operation_id>`. 409 // 410 // `operation_id` should be unique within the database, and must be 411 // a valid identifier: `[a-z][a-z0-9_]*`. Note that 412 // automatically-generated operation IDs always begin with an 413 // underscore. If the named operation already exists, 414 // [UpdateDatabaseDdl][google.spanner.admin.database.v1.DatabaseAdmin.UpdateDatabaseDdl] returns 415 // `ALREADY_EXISTS`. 416 OperationId string `protobuf:"bytes,3,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"` 417 XXX_NoUnkeyedLiteral struct{} `json:"-"` 418 XXX_unrecognized []byte `json:"-"` 419 XXX_sizecache int32 `json:"-"` 420} 421 422func (m *UpdateDatabaseDdlRequest) Reset() { *m = UpdateDatabaseDdlRequest{} } 423func (m *UpdateDatabaseDdlRequest) String() string { return proto.CompactTextString(m) } 424func (*UpdateDatabaseDdlRequest) ProtoMessage() {} 425func (*UpdateDatabaseDdlRequest) Descriptor() ([]byte, []int) { 426 return fileDescriptor_spanner_database_admin_7b69d4ce340cae98, []int{6} 427} 428func (m *UpdateDatabaseDdlRequest) XXX_Unmarshal(b []byte) error { 429 return xxx_messageInfo_UpdateDatabaseDdlRequest.Unmarshal(m, b) 430} 431func (m *UpdateDatabaseDdlRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 432 return xxx_messageInfo_UpdateDatabaseDdlRequest.Marshal(b, m, deterministic) 433} 434func (dst *UpdateDatabaseDdlRequest) XXX_Merge(src proto.Message) { 435 xxx_messageInfo_UpdateDatabaseDdlRequest.Merge(dst, src) 436} 437func (m *UpdateDatabaseDdlRequest) XXX_Size() int { 438 return xxx_messageInfo_UpdateDatabaseDdlRequest.Size(m) 439} 440func (m *UpdateDatabaseDdlRequest) XXX_DiscardUnknown() { 441 xxx_messageInfo_UpdateDatabaseDdlRequest.DiscardUnknown(m) 442} 443 444var xxx_messageInfo_UpdateDatabaseDdlRequest proto.InternalMessageInfo 445 446func (m *UpdateDatabaseDdlRequest) GetDatabase() string { 447 if m != nil { 448 return m.Database 449 } 450 return "" 451} 452 453func (m *UpdateDatabaseDdlRequest) GetStatements() []string { 454 if m != nil { 455 return m.Statements 456 } 457 return nil 458} 459 460func (m *UpdateDatabaseDdlRequest) GetOperationId() string { 461 if m != nil { 462 return m.OperationId 463 } 464 return "" 465} 466 467// Metadata type for the operation returned by 468// [UpdateDatabaseDdl][google.spanner.admin.database.v1.DatabaseAdmin.UpdateDatabaseDdl]. 469type UpdateDatabaseDdlMetadata struct { 470 // The database being modified. 471 Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"` 472 // For an update this list contains all the statements. For an 473 // individual statement, this list contains only that statement. 474 Statements []string `protobuf:"bytes,2,rep,name=statements,proto3" json:"statements,omitempty"` 475 // Reports the commit timestamps of all statements that have 476 // succeeded so far, where `commit_timestamps[i]` is the commit 477 // timestamp for the statement `statements[i]`. 478 CommitTimestamps []*timestamp.Timestamp `protobuf:"bytes,3,rep,name=commit_timestamps,json=commitTimestamps,proto3" json:"commit_timestamps,omitempty"` 479 XXX_NoUnkeyedLiteral struct{} `json:"-"` 480 XXX_unrecognized []byte `json:"-"` 481 XXX_sizecache int32 `json:"-"` 482} 483 484func (m *UpdateDatabaseDdlMetadata) Reset() { *m = UpdateDatabaseDdlMetadata{} } 485func (m *UpdateDatabaseDdlMetadata) String() string { return proto.CompactTextString(m) } 486func (*UpdateDatabaseDdlMetadata) ProtoMessage() {} 487func (*UpdateDatabaseDdlMetadata) Descriptor() ([]byte, []int) { 488 return fileDescriptor_spanner_database_admin_7b69d4ce340cae98, []int{7} 489} 490func (m *UpdateDatabaseDdlMetadata) XXX_Unmarshal(b []byte) error { 491 return xxx_messageInfo_UpdateDatabaseDdlMetadata.Unmarshal(m, b) 492} 493func (m *UpdateDatabaseDdlMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 494 return xxx_messageInfo_UpdateDatabaseDdlMetadata.Marshal(b, m, deterministic) 495} 496func (dst *UpdateDatabaseDdlMetadata) XXX_Merge(src proto.Message) { 497 xxx_messageInfo_UpdateDatabaseDdlMetadata.Merge(dst, src) 498} 499func (m *UpdateDatabaseDdlMetadata) XXX_Size() int { 500 return xxx_messageInfo_UpdateDatabaseDdlMetadata.Size(m) 501} 502func (m *UpdateDatabaseDdlMetadata) XXX_DiscardUnknown() { 503 xxx_messageInfo_UpdateDatabaseDdlMetadata.DiscardUnknown(m) 504} 505 506var xxx_messageInfo_UpdateDatabaseDdlMetadata proto.InternalMessageInfo 507 508func (m *UpdateDatabaseDdlMetadata) GetDatabase() string { 509 if m != nil { 510 return m.Database 511 } 512 return "" 513} 514 515func (m *UpdateDatabaseDdlMetadata) GetStatements() []string { 516 if m != nil { 517 return m.Statements 518 } 519 return nil 520} 521 522func (m *UpdateDatabaseDdlMetadata) GetCommitTimestamps() []*timestamp.Timestamp { 523 if m != nil { 524 return m.CommitTimestamps 525 } 526 return nil 527} 528 529// The request for [DropDatabase][google.spanner.admin.database.v1.DatabaseAdmin.DropDatabase]. 530type DropDatabaseRequest struct { 531 // Required. The database to be dropped. 532 Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"` 533 XXX_NoUnkeyedLiteral struct{} `json:"-"` 534 XXX_unrecognized []byte `json:"-"` 535 XXX_sizecache int32 `json:"-"` 536} 537 538func (m *DropDatabaseRequest) Reset() { *m = DropDatabaseRequest{} } 539func (m *DropDatabaseRequest) String() string { return proto.CompactTextString(m) } 540func (*DropDatabaseRequest) ProtoMessage() {} 541func (*DropDatabaseRequest) Descriptor() ([]byte, []int) { 542 return fileDescriptor_spanner_database_admin_7b69d4ce340cae98, []int{8} 543} 544func (m *DropDatabaseRequest) XXX_Unmarshal(b []byte) error { 545 return xxx_messageInfo_DropDatabaseRequest.Unmarshal(m, b) 546} 547func (m *DropDatabaseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 548 return xxx_messageInfo_DropDatabaseRequest.Marshal(b, m, deterministic) 549} 550func (dst *DropDatabaseRequest) XXX_Merge(src proto.Message) { 551 xxx_messageInfo_DropDatabaseRequest.Merge(dst, src) 552} 553func (m *DropDatabaseRequest) XXX_Size() int { 554 return xxx_messageInfo_DropDatabaseRequest.Size(m) 555} 556func (m *DropDatabaseRequest) XXX_DiscardUnknown() { 557 xxx_messageInfo_DropDatabaseRequest.DiscardUnknown(m) 558} 559 560var xxx_messageInfo_DropDatabaseRequest proto.InternalMessageInfo 561 562func (m *DropDatabaseRequest) GetDatabase() string { 563 if m != nil { 564 return m.Database 565 } 566 return "" 567} 568 569// The request for [GetDatabaseDdl][google.spanner.admin.database.v1.DatabaseAdmin.GetDatabaseDdl]. 570type GetDatabaseDdlRequest struct { 571 // Required. The database whose schema we wish to get. 572 Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"` 573 XXX_NoUnkeyedLiteral struct{} `json:"-"` 574 XXX_unrecognized []byte `json:"-"` 575 XXX_sizecache int32 `json:"-"` 576} 577 578func (m *GetDatabaseDdlRequest) Reset() { *m = GetDatabaseDdlRequest{} } 579func (m *GetDatabaseDdlRequest) String() string { return proto.CompactTextString(m) } 580func (*GetDatabaseDdlRequest) ProtoMessage() {} 581func (*GetDatabaseDdlRequest) Descriptor() ([]byte, []int) { 582 return fileDescriptor_spanner_database_admin_7b69d4ce340cae98, []int{9} 583} 584func (m *GetDatabaseDdlRequest) XXX_Unmarshal(b []byte) error { 585 return xxx_messageInfo_GetDatabaseDdlRequest.Unmarshal(m, b) 586} 587func (m *GetDatabaseDdlRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 588 return xxx_messageInfo_GetDatabaseDdlRequest.Marshal(b, m, deterministic) 589} 590func (dst *GetDatabaseDdlRequest) XXX_Merge(src proto.Message) { 591 xxx_messageInfo_GetDatabaseDdlRequest.Merge(dst, src) 592} 593func (m *GetDatabaseDdlRequest) XXX_Size() int { 594 return xxx_messageInfo_GetDatabaseDdlRequest.Size(m) 595} 596func (m *GetDatabaseDdlRequest) XXX_DiscardUnknown() { 597 xxx_messageInfo_GetDatabaseDdlRequest.DiscardUnknown(m) 598} 599 600var xxx_messageInfo_GetDatabaseDdlRequest proto.InternalMessageInfo 601 602func (m *GetDatabaseDdlRequest) GetDatabase() string { 603 if m != nil { 604 return m.Database 605 } 606 return "" 607} 608 609// The response for [GetDatabaseDdl][google.spanner.admin.database.v1.DatabaseAdmin.GetDatabaseDdl]. 610type GetDatabaseDdlResponse struct { 611 // A list of formatted DDL statements defining the schema of the database 612 // specified in the request. 613 Statements []string `protobuf:"bytes,1,rep,name=statements,proto3" json:"statements,omitempty"` 614 XXX_NoUnkeyedLiteral struct{} `json:"-"` 615 XXX_unrecognized []byte `json:"-"` 616 XXX_sizecache int32 `json:"-"` 617} 618 619func (m *GetDatabaseDdlResponse) Reset() { *m = GetDatabaseDdlResponse{} } 620func (m *GetDatabaseDdlResponse) String() string { return proto.CompactTextString(m) } 621func (*GetDatabaseDdlResponse) ProtoMessage() {} 622func (*GetDatabaseDdlResponse) Descriptor() ([]byte, []int) { 623 return fileDescriptor_spanner_database_admin_7b69d4ce340cae98, []int{10} 624} 625func (m *GetDatabaseDdlResponse) XXX_Unmarshal(b []byte) error { 626 return xxx_messageInfo_GetDatabaseDdlResponse.Unmarshal(m, b) 627} 628func (m *GetDatabaseDdlResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 629 return xxx_messageInfo_GetDatabaseDdlResponse.Marshal(b, m, deterministic) 630} 631func (dst *GetDatabaseDdlResponse) XXX_Merge(src proto.Message) { 632 xxx_messageInfo_GetDatabaseDdlResponse.Merge(dst, src) 633} 634func (m *GetDatabaseDdlResponse) XXX_Size() int { 635 return xxx_messageInfo_GetDatabaseDdlResponse.Size(m) 636} 637func (m *GetDatabaseDdlResponse) XXX_DiscardUnknown() { 638 xxx_messageInfo_GetDatabaseDdlResponse.DiscardUnknown(m) 639} 640 641var xxx_messageInfo_GetDatabaseDdlResponse proto.InternalMessageInfo 642 643func (m *GetDatabaseDdlResponse) GetStatements() []string { 644 if m != nil { 645 return m.Statements 646 } 647 return nil 648} 649 650func init() { 651 proto.RegisterType((*Database)(nil), "google.spanner.admin.database.v1.Database") 652 proto.RegisterType((*ListDatabasesRequest)(nil), "google.spanner.admin.database.v1.ListDatabasesRequest") 653 proto.RegisterType((*ListDatabasesResponse)(nil), "google.spanner.admin.database.v1.ListDatabasesResponse") 654 proto.RegisterType((*CreateDatabaseRequest)(nil), "google.spanner.admin.database.v1.CreateDatabaseRequest") 655 proto.RegisterType((*CreateDatabaseMetadata)(nil), "google.spanner.admin.database.v1.CreateDatabaseMetadata") 656 proto.RegisterType((*GetDatabaseRequest)(nil), "google.spanner.admin.database.v1.GetDatabaseRequest") 657 proto.RegisterType((*UpdateDatabaseDdlRequest)(nil), "google.spanner.admin.database.v1.UpdateDatabaseDdlRequest") 658 proto.RegisterType((*UpdateDatabaseDdlMetadata)(nil), "google.spanner.admin.database.v1.UpdateDatabaseDdlMetadata") 659 proto.RegisterType((*DropDatabaseRequest)(nil), "google.spanner.admin.database.v1.DropDatabaseRequest") 660 proto.RegisterType((*GetDatabaseDdlRequest)(nil), "google.spanner.admin.database.v1.GetDatabaseDdlRequest") 661 proto.RegisterType((*GetDatabaseDdlResponse)(nil), "google.spanner.admin.database.v1.GetDatabaseDdlResponse") 662 proto.RegisterEnum("google.spanner.admin.database.v1.Database_State", Database_State_name, Database_State_value) 663} 664 665// Reference imports to suppress errors if they are not otherwise used. 666var _ context.Context 667var _ grpc.ClientConn 668 669// This is a compile-time assertion to ensure that this generated file 670// is compatible with the grpc package it is being compiled against. 671const _ = grpc.SupportPackageIsVersion4 672 673// DatabaseAdminClient is the client API for DatabaseAdmin service. 674// 675// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 676type DatabaseAdminClient interface { 677 // Lists Cloud Spanner databases. 678 ListDatabases(ctx context.Context, in *ListDatabasesRequest, opts ...grpc.CallOption) (*ListDatabasesResponse, error) 679 // Creates a new Cloud Spanner database and starts to prepare it for serving. 680 // The returned [long-running operation][google.longrunning.Operation] will 681 // have a name of the format `<database_name>/operations/<operation_id>` and 682 // can be used to track preparation of the database. The 683 // [metadata][google.longrunning.Operation.metadata] field type is 684 // [CreateDatabaseMetadata][google.spanner.admin.database.v1.CreateDatabaseMetadata]. The 685 // [response][google.longrunning.Operation.response] field type is 686 // [Database][google.spanner.admin.database.v1.Database], if successful. 687 CreateDatabase(ctx context.Context, in *CreateDatabaseRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) 688 // Gets the state of a Cloud Spanner database. 689 GetDatabase(ctx context.Context, in *GetDatabaseRequest, opts ...grpc.CallOption) (*Database, error) 690 // Updates the schema of a Cloud Spanner database by 691 // creating/altering/dropping tables, columns, indexes, etc. The returned 692 // [long-running operation][google.longrunning.Operation] will have a name of 693 // the format `<database_name>/operations/<operation_id>` and can be used to 694 // track execution of the schema change(s). The 695 // [metadata][google.longrunning.Operation.metadata] field type is 696 // [UpdateDatabaseDdlMetadata][google.spanner.admin.database.v1.UpdateDatabaseDdlMetadata]. The operation has no response. 697 UpdateDatabaseDdl(ctx context.Context, in *UpdateDatabaseDdlRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) 698 // Drops (aka deletes) a Cloud Spanner database. 699 DropDatabase(ctx context.Context, in *DropDatabaseRequest, opts ...grpc.CallOption) (*empty.Empty, error) 700 // Returns the schema of a Cloud Spanner database as a list of formatted 701 // DDL statements. This method does not show pending schema updates, those may 702 // be queried using the [Operations][google.longrunning.Operations] API. 703 GetDatabaseDdl(ctx context.Context, in *GetDatabaseDdlRequest, opts ...grpc.CallOption) (*GetDatabaseDdlResponse, error) 704 // Sets the access control policy on a database resource. Replaces any 705 // existing policy. 706 // 707 // Authorization requires `spanner.databases.setIamPolicy` permission on 708 // [resource][google.iam.v1.SetIamPolicyRequest.resource]. 709 SetIamPolicy(ctx context.Context, in *v1.SetIamPolicyRequest, opts ...grpc.CallOption) (*v1.Policy, error) 710 // Gets the access control policy for a database resource. Returns an empty 711 // policy if a database exists but does not have a policy set. 712 // 713 // Authorization requires `spanner.databases.getIamPolicy` permission on 714 // [resource][google.iam.v1.GetIamPolicyRequest.resource]. 715 GetIamPolicy(ctx context.Context, in *v1.GetIamPolicyRequest, opts ...grpc.CallOption) (*v1.Policy, error) 716 // Returns permissions that the caller has on the specified database resource. 717 // 718 // Attempting this RPC on a non-existent Cloud Spanner database will result in 719 // a NOT_FOUND error if the user has `spanner.databases.list` permission on 720 // the containing Cloud Spanner instance. Otherwise returns an empty set of 721 // permissions. 722 TestIamPermissions(ctx context.Context, in *v1.TestIamPermissionsRequest, opts ...grpc.CallOption) (*v1.TestIamPermissionsResponse, error) 723} 724 725type databaseAdminClient struct { 726 cc *grpc.ClientConn 727} 728 729func NewDatabaseAdminClient(cc *grpc.ClientConn) DatabaseAdminClient { 730 return &databaseAdminClient{cc} 731} 732 733func (c *databaseAdminClient) ListDatabases(ctx context.Context, in *ListDatabasesRequest, opts ...grpc.CallOption) (*ListDatabasesResponse, error) { 734 out := new(ListDatabasesResponse) 735 err := c.cc.Invoke(ctx, "/google.spanner.admin.database.v1.DatabaseAdmin/ListDatabases", in, out, opts...) 736 if err != nil { 737 return nil, err 738 } 739 return out, nil 740} 741 742func (c *databaseAdminClient) CreateDatabase(ctx context.Context, in *CreateDatabaseRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) { 743 out := new(longrunning.Operation) 744 err := c.cc.Invoke(ctx, "/google.spanner.admin.database.v1.DatabaseAdmin/CreateDatabase", in, out, opts...) 745 if err != nil { 746 return nil, err 747 } 748 return out, nil 749} 750 751func (c *databaseAdminClient) GetDatabase(ctx context.Context, in *GetDatabaseRequest, opts ...grpc.CallOption) (*Database, error) { 752 out := new(Database) 753 err := c.cc.Invoke(ctx, "/google.spanner.admin.database.v1.DatabaseAdmin/GetDatabase", in, out, opts...) 754 if err != nil { 755 return nil, err 756 } 757 return out, nil 758} 759 760func (c *databaseAdminClient) UpdateDatabaseDdl(ctx context.Context, in *UpdateDatabaseDdlRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) { 761 out := new(longrunning.Operation) 762 err := c.cc.Invoke(ctx, "/google.spanner.admin.database.v1.DatabaseAdmin/UpdateDatabaseDdl", in, out, opts...) 763 if err != nil { 764 return nil, err 765 } 766 return out, nil 767} 768 769func (c *databaseAdminClient) DropDatabase(ctx context.Context, in *DropDatabaseRequest, opts ...grpc.CallOption) (*empty.Empty, error) { 770 out := new(empty.Empty) 771 err := c.cc.Invoke(ctx, "/google.spanner.admin.database.v1.DatabaseAdmin/DropDatabase", in, out, opts...) 772 if err != nil { 773 return nil, err 774 } 775 return out, nil 776} 777 778func (c *databaseAdminClient) GetDatabaseDdl(ctx context.Context, in *GetDatabaseDdlRequest, opts ...grpc.CallOption) (*GetDatabaseDdlResponse, error) { 779 out := new(GetDatabaseDdlResponse) 780 err := c.cc.Invoke(ctx, "/google.spanner.admin.database.v1.DatabaseAdmin/GetDatabaseDdl", in, out, opts...) 781 if err != nil { 782 return nil, err 783 } 784 return out, nil 785} 786 787func (c *databaseAdminClient) SetIamPolicy(ctx context.Context, in *v1.SetIamPolicyRequest, opts ...grpc.CallOption) (*v1.Policy, error) { 788 out := new(v1.Policy) 789 err := c.cc.Invoke(ctx, "/google.spanner.admin.database.v1.DatabaseAdmin/SetIamPolicy", in, out, opts...) 790 if err != nil { 791 return nil, err 792 } 793 return out, nil 794} 795 796func (c *databaseAdminClient) GetIamPolicy(ctx context.Context, in *v1.GetIamPolicyRequest, opts ...grpc.CallOption) (*v1.Policy, error) { 797 out := new(v1.Policy) 798 err := c.cc.Invoke(ctx, "/google.spanner.admin.database.v1.DatabaseAdmin/GetIamPolicy", in, out, opts...) 799 if err != nil { 800 return nil, err 801 } 802 return out, nil 803} 804 805func (c *databaseAdminClient) TestIamPermissions(ctx context.Context, in *v1.TestIamPermissionsRequest, opts ...grpc.CallOption) (*v1.TestIamPermissionsResponse, error) { 806 out := new(v1.TestIamPermissionsResponse) 807 err := c.cc.Invoke(ctx, "/google.spanner.admin.database.v1.DatabaseAdmin/TestIamPermissions", in, out, opts...) 808 if err != nil { 809 return nil, err 810 } 811 return out, nil 812} 813 814// DatabaseAdminServer is the server API for DatabaseAdmin service. 815type DatabaseAdminServer interface { 816 // Lists Cloud Spanner databases. 817 ListDatabases(context.Context, *ListDatabasesRequest) (*ListDatabasesResponse, error) 818 // Creates a new Cloud Spanner database and starts to prepare it for serving. 819 // The returned [long-running operation][google.longrunning.Operation] will 820 // have a name of the format `<database_name>/operations/<operation_id>` and 821 // can be used to track preparation of the database. The 822 // [metadata][google.longrunning.Operation.metadata] field type is 823 // [CreateDatabaseMetadata][google.spanner.admin.database.v1.CreateDatabaseMetadata]. The 824 // [response][google.longrunning.Operation.response] field type is 825 // [Database][google.spanner.admin.database.v1.Database], if successful. 826 CreateDatabase(context.Context, *CreateDatabaseRequest) (*longrunning.Operation, error) 827 // Gets the state of a Cloud Spanner database. 828 GetDatabase(context.Context, *GetDatabaseRequest) (*Database, error) 829 // Updates the schema of a Cloud Spanner database by 830 // creating/altering/dropping tables, columns, indexes, etc. The returned 831 // [long-running operation][google.longrunning.Operation] will have a name of 832 // the format `<database_name>/operations/<operation_id>` and can be used to 833 // track execution of the schema change(s). The 834 // [metadata][google.longrunning.Operation.metadata] field type is 835 // [UpdateDatabaseDdlMetadata][google.spanner.admin.database.v1.UpdateDatabaseDdlMetadata]. The operation has no response. 836 UpdateDatabaseDdl(context.Context, *UpdateDatabaseDdlRequest) (*longrunning.Operation, error) 837 // Drops (aka deletes) a Cloud Spanner database. 838 DropDatabase(context.Context, *DropDatabaseRequest) (*empty.Empty, error) 839 // Returns the schema of a Cloud Spanner database as a list of formatted 840 // DDL statements. This method does not show pending schema updates, those may 841 // be queried using the [Operations][google.longrunning.Operations] API. 842 GetDatabaseDdl(context.Context, *GetDatabaseDdlRequest) (*GetDatabaseDdlResponse, error) 843 // Sets the access control policy on a database resource. Replaces any 844 // existing policy. 845 // 846 // Authorization requires `spanner.databases.setIamPolicy` permission on 847 // [resource][google.iam.v1.SetIamPolicyRequest.resource]. 848 SetIamPolicy(context.Context, *v1.SetIamPolicyRequest) (*v1.Policy, error) 849 // Gets the access control policy for a database resource. Returns an empty 850 // policy if a database exists but does not have a policy set. 851 // 852 // Authorization requires `spanner.databases.getIamPolicy` permission on 853 // [resource][google.iam.v1.GetIamPolicyRequest.resource]. 854 GetIamPolicy(context.Context, *v1.GetIamPolicyRequest) (*v1.Policy, error) 855 // Returns permissions that the caller has on the specified database resource. 856 // 857 // Attempting this RPC on a non-existent Cloud Spanner database will result in 858 // a NOT_FOUND error if the user has `spanner.databases.list` permission on 859 // the containing Cloud Spanner instance. Otherwise returns an empty set of 860 // permissions. 861 TestIamPermissions(context.Context, *v1.TestIamPermissionsRequest) (*v1.TestIamPermissionsResponse, error) 862} 863 864func RegisterDatabaseAdminServer(s *grpc.Server, srv DatabaseAdminServer) { 865 s.RegisterService(&_DatabaseAdmin_serviceDesc, srv) 866} 867 868func _DatabaseAdmin_ListDatabases_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 869 in := new(ListDatabasesRequest) 870 if err := dec(in); err != nil { 871 return nil, err 872 } 873 if interceptor == nil { 874 return srv.(DatabaseAdminServer).ListDatabases(ctx, in) 875 } 876 info := &grpc.UnaryServerInfo{ 877 Server: srv, 878 FullMethod: "/google.spanner.admin.database.v1.DatabaseAdmin/ListDatabases", 879 } 880 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 881 return srv.(DatabaseAdminServer).ListDatabases(ctx, req.(*ListDatabasesRequest)) 882 } 883 return interceptor(ctx, in, info, handler) 884} 885 886func _DatabaseAdmin_CreateDatabase_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 887 in := new(CreateDatabaseRequest) 888 if err := dec(in); err != nil { 889 return nil, err 890 } 891 if interceptor == nil { 892 return srv.(DatabaseAdminServer).CreateDatabase(ctx, in) 893 } 894 info := &grpc.UnaryServerInfo{ 895 Server: srv, 896 FullMethod: "/google.spanner.admin.database.v1.DatabaseAdmin/CreateDatabase", 897 } 898 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 899 return srv.(DatabaseAdminServer).CreateDatabase(ctx, req.(*CreateDatabaseRequest)) 900 } 901 return interceptor(ctx, in, info, handler) 902} 903 904func _DatabaseAdmin_GetDatabase_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 905 in := new(GetDatabaseRequest) 906 if err := dec(in); err != nil { 907 return nil, err 908 } 909 if interceptor == nil { 910 return srv.(DatabaseAdminServer).GetDatabase(ctx, in) 911 } 912 info := &grpc.UnaryServerInfo{ 913 Server: srv, 914 FullMethod: "/google.spanner.admin.database.v1.DatabaseAdmin/GetDatabase", 915 } 916 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 917 return srv.(DatabaseAdminServer).GetDatabase(ctx, req.(*GetDatabaseRequest)) 918 } 919 return interceptor(ctx, in, info, handler) 920} 921 922func _DatabaseAdmin_UpdateDatabaseDdl_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 923 in := new(UpdateDatabaseDdlRequest) 924 if err := dec(in); err != nil { 925 return nil, err 926 } 927 if interceptor == nil { 928 return srv.(DatabaseAdminServer).UpdateDatabaseDdl(ctx, in) 929 } 930 info := &grpc.UnaryServerInfo{ 931 Server: srv, 932 FullMethod: "/google.spanner.admin.database.v1.DatabaseAdmin/UpdateDatabaseDdl", 933 } 934 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 935 return srv.(DatabaseAdminServer).UpdateDatabaseDdl(ctx, req.(*UpdateDatabaseDdlRequest)) 936 } 937 return interceptor(ctx, in, info, handler) 938} 939 940func _DatabaseAdmin_DropDatabase_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 941 in := new(DropDatabaseRequest) 942 if err := dec(in); err != nil { 943 return nil, err 944 } 945 if interceptor == nil { 946 return srv.(DatabaseAdminServer).DropDatabase(ctx, in) 947 } 948 info := &grpc.UnaryServerInfo{ 949 Server: srv, 950 FullMethod: "/google.spanner.admin.database.v1.DatabaseAdmin/DropDatabase", 951 } 952 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 953 return srv.(DatabaseAdminServer).DropDatabase(ctx, req.(*DropDatabaseRequest)) 954 } 955 return interceptor(ctx, in, info, handler) 956} 957 958func _DatabaseAdmin_GetDatabaseDdl_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 959 in := new(GetDatabaseDdlRequest) 960 if err := dec(in); err != nil { 961 return nil, err 962 } 963 if interceptor == nil { 964 return srv.(DatabaseAdminServer).GetDatabaseDdl(ctx, in) 965 } 966 info := &grpc.UnaryServerInfo{ 967 Server: srv, 968 FullMethod: "/google.spanner.admin.database.v1.DatabaseAdmin/GetDatabaseDdl", 969 } 970 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 971 return srv.(DatabaseAdminServer).GetDatabaseDdl(ctx, req.(*GetDatabaseDdlRequest)) 972 } 973 return interceptor(ctx, in, info, handler) 974} 975 976func _DatabaseAdmin_SetIamPolicy_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 977 in := new(v1.SetIamPolicyRequest) 978 if err := dec(in); err != nil { 979 return nil, err 980 } 981 if interceptor == nil { 982 return srv.(DatabaseAdminServer).SetIamPolicy(ctx, in) 983 } 984 info := &grpc.UnaryServerInfo{ 985 Server: srv, 986 FullMethod: "/google.spanner.admin.database.v1.DatabaseAdmin/SetIamPolicy", 987 } 988 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 989 return srv.(DatabaseAdminServer).SetIamPolicy(ctx, req.(*v1.SetIamPolicyRequest)) 990 } 991 return interceptor(ctx, in, info, handler) 992} 993 994func _DatabaseAdmin_GetIamPolicy_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 995 in := new(v1.GetIamPolicyRequest) 996 if err := dec(in); err != nil { 997 return nil, err 998 } 999 if interceptor == nil { 1000 return srv.(DatabaseAdminServer).GetIamPolicy(ctx, in) 1001 } 1002 info := &grpc.UnaryServerInfo{ 1003 Server: srv, 1004 FullMethod: "/google.spanner.admin.database.v1.DatabaseAdmin/GetIamPolicy", 1005 } 1006 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1007 return srv.(DatabaseAdminServer).GetIamPolicy(ctx, req.(*v1.GetIamPolicyRequest)) 1008 } 1009 return interceptor(ctx, in, info, handler) 1010} 1011 1012func _DatabaseAdmin_TestIamPermissions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1013 in := new(v1.TestIamPermissionsRequest) 1014 if err := dec(in); err != nil { 1015 return nil, err 1016 } 1017 if interceptor == nil { 1018 return srv.(DatabaseAdminServer).TestIamPermissions(ctx, in) 1019 } 1020 info := &grpc.UnaryServerInfo{ 1021 Server: srv, 1022 FullMethod: "/google.spanner.admin.database.v1.DatabaseAdmin/TestIamPermissions", 1023 } 1024 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1025 return srv.(DatabaseAdminServer).TestIamPermissions(ctx, req.(*v1.TestIamPermissionsRequest)) 1026 } 1027 return interceptor(ctx, in, info, handler) 1028} 1029 1030var _DatabaseAdmin_serviceDesc = grpc.ServiceDesc{ 1031 ServiceName: "google.spanner.admin.database.v1.DatabaseAdmin", 1032 HandlerType: (*DatabaseAdminServer)(nil), 1033 Methods: []grpc.MethodDesc{ 1034 { 1035 MethodName: "ListDatabases", 1036 Handler: _DatabaseAdmin_ListDatabases_Handler, 1037 }, 1038 { 1039 MethodName: "CreateDatabase", 1040 Handler: _DatabaseAdmin_CreateDatabase_Handler, 1041 }, 1042 { 1043 MethodName: "GetDatabase", 1044 Handler: _DatabaseAdmin_GetDatabase_Handler, 1045 }, 1046 { 1047 MethodName: "UpdateDatabaseDdl", 1048 Handler: _DatabaseAdmin_UpdateDatabaseDdl_Handler, 1049 }, 1050 { 1051 MethodName: "DropDatabase", 1052 Handler: _DatabaseAdmin_DropDatabase_Handler, 1053 }, 1054 { 1055 MethodName: "GetDatabaseDdl", 1056 Handler: _DatabaseAdmin_GetDatabaseDdl_Handler, 1057 }, 1058 { 1059 MethodName: "SetIamPolicy", 1060 Handler: _DatabaseAdmin_SetIamPolicy_Handler, 1061 }, 1062 { 1063 MethodName: "GetIamPolicy", 1064 Handler: _DatabaseAdmin_GetIamPolicy_Handler, 1065 }, 1066 { 1067 MethodName: "TestIamPermissions", 1068 Handler: _DatabaseAdmin_TestIamPermissions_Handler, 1069 }, 1070 }, 1071 Streams: []grpc.StreamDesc{}, 1072 Metadata: "google/spanner/admin/database/v1/spanner_database_admin.proto", 1073} 1074 1075func init() { 1076 proto.RegisterFile("google/spanner/admin/database/v1/spanner_database_admin.proto", fileDescriptor_spanner_database_admin_7b69d4ce340cae98) 1077} 1078 1079var fileDescriptor_spanner_database_admin_7b69d4ce340cae98 = []byte{ 1080 // 1033 bytes of a gzipped FileDescriptorProto 1081 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xbc, 0x96, 0xcf, 0x6f, 0x1b, 0x45, 1082 0x14, 0xc7, 0x19, 0xa7, 0xa9, 0x92, 0x17, 0x27, 0x75, 0x06, 0x1c, 0xb9, 0x5b, 0x5a, 0xcc, 0x82, 1083 0x2a, 0xd7, 0x12, 0xbb, 0xd8, 0x69, 0x48, 0x30, 0x0a, 0x22, 0xb5, 0x5d, 0xd7, 0x12, 0xb4, 0x96, 1084 0xed, 0x56, 0x02, 0x59, 0xb2, 0x26, 0xf6, 0xb0, 0xda, 0xe2, 0xfd, 0xc1, 0xce, 0xb8, 0x6a, 0x8b, 1085 0x7a, 0x41, 0xe2, 0xc0, 0x19, 0x90, 0xb8, 0x81, 0x38, 0x70, 0xe0, 0xc4, 0x0d, 0x89, 0x23, 0x47, 1086 0xae, 0xfc, 0x01, 0x5c, 0xf8, 0x43, 0xd0, 0xcc, 0xee, 0xd8, 0xeb, 0x75, 0x12, 0xdb, 0x1c, 0xb8, 1087 0x79, 0xdf, 0xfb, 0xbe, 0x79, 0x9f, 0x79, 0x3b, 0xdf, 0xf1, 0xc2, 0xb1, 0xe5, 0x79, 0xd6, 0x88, 1088 0x9a, 0xcc, 0x27, 0xae, 0x4b, 0x03, 0x93, 0x0c, 0x1d, 0xdb, 0x35, 0x87, 0x84, 0x93, 0x53, 0xc2, 1089 0xa8, 0xf9, 0xa4, 0xa4, 0x32, 0x7d, 0x15, 0xeb, 0x4b, 0x89, 0xe1, 0x07, 0x1e, 0xf7, 0x70, 0x3e, 1090 0x2c, 0x37, 0x22, 0x91, 0x11, 0xe6, 0x94, 0xd4, 0x78, 0x52, 0xd2, 0x5e, 0x8d, 0x1a, 0x10, 0xdf, 1091 0x36, 0x89, 0xeb, 0x7a, 0x9c, 0x70, 0xdb, 0x73, 0x59, 0x58, 0xaf, 0xdd, 0x88, 0xb2, 0x36, 0x71, 1092 0x44, 0x2f, 0x9b, 0x38, 0x7d, 0xdf, 0x1b, 0xd9, 0x83, 0x67, 0x51, 0x5e, 0x9b, 0xcd, 0xcf, 0xe4, 1093 0xde, 0x88, 0x72, 0x23, 0xcf, 0xb5, 0x82, 0xb1, 0xeb, 0xda, 0xae, 0x65, 0x7a, 0x3e, 0x0d, 0x66, 1094 0x1a, 0x5c, 0x8b, 0x44, 0xf2, 0xe9, 0x74, 0xfc, 0xa9, 0x49, 0x1d, 0x9f, 0xab, 0x15, 0x5e, 0x4b, 1095 0x26, 0xb9, 0xed, 0x50, 0xc6, 0x89, 0xe3, 0x87, 0x02, 0xfd, 0x07, 0x04, 0x1b, 0xb5, 0x68, 0x33, 1096 0x18, 0xc3, 0x25, 0x97, 0x38, 0x34, 0x87, 0xf2, 0xa8, 0xb0, 0xd9, 0x96, 0xbf, 0xf1, 0x5d, 0x58, 1097 0x67, 0x9c, 0x70, 0x9a, 0x4b, 0xe5, 0x51, 0x61, 0xa7, 0xfc, 0xb6, 0xb1, 0x68, 0x1e, 0x86, 0x5a, 1098 0xce, 0xe8, 0x88, 0xba, 0x76, 0x58, 0xae, 0x1f, 0xc2, 0xba, 0x7c, 0xc6, 0x59, 0xd8, 0xed, 0x74, 1099 0x4f, 0xba, 0xf5, 0xfe, 0xc3, 0xfb, 0x9d, 0x56, 0xbd, 0xda, 0xbc, 0xdb, 0xac, 0xd7, 0x32, 0x2f, 1100 0xe1, 0x34, 0x6c, 0x54, 0xdb, 0xf5, 0x93, 0x6e, 0xf3, 0x7e, 0x23, 0x83, 0xf0, 0x26, 0xac, 0xb7, 1101 0xeb, 0x27, 0xb5, 0x8f, 0x33, 0x29, 0xfd, 0x31, 0xbc, 0xf2, 0xa1, 0xcd, 0xb8, 0x5a, 0x95, 0xb5, 1102 0xe9, 0xe7, 0x63, 0xca, 0x38, 0xde, 0x83, 0xcb, 0x3e, 0x09, 0xa8, 0xcb, 0x23, 0xdc, 0xe8, 0x09, 1103 0x5f, 0x83, 0x4d, 0x9f, 0x58, 0xb4, 0xcf, 0xec, 0xe7, 0x34, 0xb7, 0x96, 0x47, 0x85, 0xf5, 0xf6, 1104 0x86, 0x08, 0x74, 0xec, 0xe7, 0x14, 0x5f, 0x07, 0x90, 0x49, 0xee, 0x7d, 0x46, 0xdd, 0xdc, 0x25, 1105 0x59, 0x28, 0xe5, 0x5d, 0x11, 0xd0, 0xbf, 0x46, 0x90, 0x4d, 0x34, 0x63, 0xbe, 0xe7, 0x32, 0x8a, 1106 0xef, 0xc1, 0xa6, 0xda, 0x23, 0xcb, 0xa1, 0xfc, 0x5a, 0x61, 0xab, 0x5c, 0x5c, 0x7e, 0x14, 0xed, 1107 0x69, 0x31, 0xbe, 0x09, 0x57, 0x5c, 0xfa, 0x94, 0xf7, 0x63, 0x1c, 0x29, 0xc9, 0xb1, 0x2d, 0xc2, 1108 0xad, 0x09, 0xcb, 0x57, 0x08, 0xb2, 0xd5, 0x80, 0x12, 0x4e, 0x27, 0xab, 0x2c, 0xd8, 0xf9, 0x2d, 1109 0xc8, 0x0c, 0x64, 0x41, 0x5f, 0x8e, 0xdc, 0x11, 0x8a, 0x70, 0xe9, 0x2b, 0x61, 0xbc, 0xa3, 0xc2, 1110 0x42, 0x4a, 0x9f, 0xf2, 0x80, 0x4c, 0x95, 0x2c, 0xb7, 0x96, 0x5f, 0x13, 0x52, 0x19, 0x9f, 0x28, 1111 0x99, 0x7e, 0x1b, 0xf6, 0x66, 0x31, 0x3e, 0xa2, 0x9c, 0x88, 0xed, 0x60, 0x0d, 0x36, 0xd4, 0xb6, 1112 0x22, 0x92, 0xc9, 0xb3, 0x5e, 0x00, 0xdc, 0xa0, 0x3c, 0x49, 0x7e, 0xc6, 0x01, 0xd3, 0x9f, 0x41, 1113 0xee, 0xa1, 0x3f, 0x8c, 0xad, 0x5f, 0x1b, 0x8e, 0x94, 0xfe, 0x82, 0x0e, 0xf8, 0x06, 0x40, 0x0c, 1114 0x3e, 0x25, 0xe1, 0x63, 0x11, 0xfc, 0x3a, 0xa4, 0x27, 0x5e, 0xe9, 0xdb, 0x43, 0x79, 0x14, 0x36, 1115 0xdb, 0x5b, 0x93, 0x58, 0x73, 0xa8, 0xff, 0x88, 0xe0, 0xea, 0x5c, 0xef, 0x65, 0xb6, 0xb7, 0xb0, 1116 0x79, 0x03, 0x76, 0x07, 0x9e, 0xe3, 0xd8, 0xbc, 0x3f, 0x31, 0x5c, 0x38, 0xe0, 0xad, 0xb2, 0xa6, 1117 0x8e, 0x8d, 0xf2, 0xa4, 0xd1, 0x55, 0x92, 0x76, 0x26, 0x2c, 0x9a, 0x04, 0x98, 0x5e, 0x82, 0x97, 1118 0x6b, 0x81, 0xe7, 0x27, 0x07, 0x79, 0xd1, 0xe8, 0xf7, 0x21, 0x1b, 0x1b, 0xfd, 0x72, 0xd3, 0xd4, 1119 0x8f, 0x60, 0x2f, 0x59, 0x14, 0x9d, 0xfc, 0xd9, 0xad, 0xa2, 0xe4, 0x56, 0xcb, 0xdf, 0xa5, 0x61, 1120 0x5b, 0xd5, 0x9d, 0x08, 0x07, 0xe0, 0xdf, 0x10, 0x6c, 0xcf, 0xb8, 0x08, 0xbf, 0xb3, 0xd8, 0x2a, 1121 0x67, 0x79, 0x5c, 0x3b, 0x5c, 0xb9, 0x2e, 0x84, 0xd6, 0x0f, 0xbe, 0xfc, 0xeb, 0x9f, 0x6f, 0x52, 1122 0x26, 0x7e, 0x4b, 0xdc, 0xa9, 0x5f, 0x84, 0xfe, 0x38, 0xf6, 0x03, 0xef, 0x31, 0x1d, 0x70, 0x66, 1123 0x16, 0x4d, 0xdb, 0x65, 0x9c, 0xb8, 0x03, 0xca, 0xcc, 0xe2, 0x0b, 0x73, 0xea, 0xcd, 0x9f, 0x10, 1124 0xec, 0xcc, 0x1e, 0x76, 0xbc, 0x04, 0xc2, 0x99, 0x2e, 0xd5, 0xae, 0xab, 0xc2, 0xd8, 0xed, 0x6d, 1125 0x3c, 0x50, 0xa7, 0x4f, 0x3f, 0x92, 0x84, 0x65, 0x7d, 0x35, 0xc2, 0x0a, 0x2a, 0xe2, 0x9f, 0x11, 1126 0x6c, 0xc5, 0xde, 0x15, 0xbe, 0xbd, 0x98, 0x70, 0xde, 0x8a, 0xda, 0x0a, 0xb7, 0x57, 0x62, 0x9a, 1127 0xc2, 0xb5, 0xe7, 0x90, 0x4e, 0x41, 0xcd, 0xe2, 0x0b, 0xfc, 0x2b, 0x82, 0xdd, 0x39, 0x7b, 0xe1, 1128 0xca, 0xe2, 0xc6, 0xe7, 0xdd, 0x07, 0x8b, 0x66, 0xfa, 0x81, 0xe4, 0xac, 0x94, 0x0f, 0x24, 0xa7, 1129 0x5a, 0x71, 0x19, 0x56, 0x73, 0x38, 0x1c, 0x89, 0xd9, 0x7e, 0x8f, 0x20, 0x1d, 0xf7, 0x1b, 0x3e, 1130 0x58, 0x62, 0x4c, 0xf3, 0xfe, 0xd4, 0xf6, 0xe6, 0x4c, 0x5e, 0x17, 0xff, 0xca, 0xfa, 0xbb, 0x92, 1131 0x70, 0xbf, 0x58, 0x5a, 0x99, 0x10, 0xff, 0x81, 0x60, 0x67, 0xd6, 0xa2, 0xcb, 0x9c, 0xcd, 0x33, 1132 0x6f, 0x02, 0xed, 0x68, 0xf5, 0xc2, 0xc8, 0x58, 0xc7, 0x72, 0x03, 0x87, 0xf8, 0xbf, 0x8d, 0x18, 1133 0x7f, 0x8b, 0x20, 0xdd, 0xa1, 0xbc, 0x49, 0x9c, 0x96, 0xfc, 0xd0, 0xc1, 0xba, 0x22, 0xb1, 0x89, 1134 0x23, 0xda, 0xc6, 0x93, 0x8a, 0x36, 0x9b, 0xd0, 0x84, 0x59, 0xbd, 0x29, 0x51, 0xaa, 0xfa, 0xfb, 1135 0x12, 0x25, 0xa0, 0xcc, 0x1b, 0x07, 0x83, 0xa5, 0x50, 0x2a, 0x2c, 0xd6, 0x45, 0xbc, 0x76, 0x81, 1136 0xd5, 0xb8, 0x08, 0xab, 0xf1, 0xbf, 0x60, 0x59, 0x09, 0xac, 0xdf, 0x11, 0xe0, 0x2e, 0x65, 0x32, 1137 0x48, 0x03, 0xc7, 0x66, 0x4c, 0x7c, 0xf7, 0xe1, 0x42, 0xa2, 0xf1, 0xbc, 0x44, 0x21, 0xde, 0x5a, 1138 0x42, 0x19, 0xbd, 0xd8, 0x07, 0x12, 0xbb, 0xa9, 0xd7, 0x56, 0xc7, 0xe6, 0x73, 0xab, 0x56, 0x50, 1139 0xf1, 0xce, 0xdf, 0x08, 0xde, 0x1c, 0x78, 0xce, 0xc2, 0x93, 0x76, 0xe7, 0x6a, 0x27, 0x4c, 0xcd, 1140 0xfc, 0x89, 0xb4, 0x84, 0x6f, 0x5a, 0xe8, 0x93, 0x7b, 0x51, 0xb9, 0xe5, 0x8d, 0x88, 0x6b, 0x19, 1141 0x5e, 0x60, 0x99, 0x16, 0x75, 0xa5, 0xab, 0xcc, 0x30, 0x45, 0x7c, 0x9b, 0x9d, 0xff, 0x71, 0xff, 1142 0x9e, 0xfa, 0xfd, 0x4b, 0xea, 0x66, 0x23, 0x5c, 0xaa, 0x3a, 0xf2, 0xc6, 0x43, 0x23, 0x6a, 0x6a, 1143 0xc8, 0x6e, 0xd3, 0x6f, 0xd6, 0x47, 0xa5, 0x3f, 0x95, 0xb0, 0x27, 0x85, 0xbd, 0x48, 0xd8, 0x93, 1144 0xc2, 0x9e, 0x12, 0xf6, 0x1e, 0x95, 0x4e, 0x2f, 0x4b, 0x8c, 0xfd, 0x7f, 0x03, 0x00, 0x00, 0xff, 1145 0xff, 0x1d, 0xbc, 0x89, 0x54, 0x62, 0x0c, 0x00, 0x00, 1146} 1147