1// Code generated by protoc-gen-go. DO NOT EDIT. 2// source: google/cloud/bigquery/datatransfer/v1/datatransfer.proto 3 4package datatransfer 5 6import ( 7 context "context" 8 fmt "fmt" 9 math "math" 10 11 proto "github.com/golang/protobuf/proto" 12 duration "github.com/golang/protobuf/ptypes/duration" 13 empty "github.com/golang/protobuf/ptypes/empty" 14 timestamp "github.com/golang/protobuf/ptypes/timestamp" 15 wrappers "github.com/golang/protobuf/ptypes/wrappers" 16 _ "google.golang.org/genproto/googleapis/api/annotations" 17 field_mask "google.golang.org/genproto/protobuf/field_mask" 18 grpc "google.golang.org/grpc" 19 codes "google.golang.org/grpc/codes" 20 status "google.golang.org/grpc/status" 21) 22 23// Reference imports to suppress errors if they are not otherwise used. 24var _ = proto.Marshal 25var _ = fmt.Errorf 26var _ = math.Inf 27 28// This is a compile-time assertion to ensure that this generated file 29// is compatible with the proto package it is being compiled against. 30// A compilation error at this line likely means your copy of the 31// proto package needs to be updated. 32const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package 33 34// Parameter type. 35type DataSourceParameter_Type int32 36 37const ( 38 // Type unspecified. 39 DataSourceParameter_TYPE_UNSPECIFIED DataSourceParameter_Type = 0 40 // String parameter. 41 DataSourceParameter_STRING DataSourceParameter_Type = 1 42 // Integer parameter (64-bits). 43 // Will be serialized to json as string. 44 DataSourceParameter_INTEGER DataSourceParameter_Type = 2 45 // Double precision floating point parameter. 46 DataSourceParameter_DOUBLE DataSourceParameter_Type = 3 47 // Boolean parameter. 48 DataSourceParameter_BOOLEAN DataSourceParameter_Type = 4 49 // Deprecated. This field has no effect. 50 DataSourceParameter_RECORD DataSourceParameter_Type = 5 51 // Page ID for a Google+ Page. 52 DataSourceParameter_PLUS_PAGE DataSourceParameter_Type = 6 53) 54 55var DataSourceParameter_Type_name = map[int32]string{ 56 0: "TYPE_UNSPECIFIED", 57 1: "STRING", 58 2: "INTEGER", 59 3: "DOUBLE", 60 4: "BOOLEAN", 61 5: "RECORD", 62 6: "PLUS_PAGE", 63} 64 65var DataSourceParameter_Type_value = map[string]int32{ 66 "TYPE_UNSPECIFIED": 0, 67 "STRING": 1, 68 "INTEGER": 2, 69 "DOUBLE": 3, 70 "BOOLEAN": 4, 71 "RECORD": 5, 72 "PLUS_PAGE": 6, 73} 74 75func (x DataSourceParameter_Type) String() string { 76 return proto.EnumName(DataSourceParameter_Type_name, int32(x)) 77} 78 79func (DataSourceParameter_Type) EnumDescriptor() ([]byte, []int) { 80 return fileDescriptor_8edec8f64c27b8a4, []int{0, 0} 81} 82 83// The type of authorization needed for this data source. 84type DataSource_AuthorizationType int32 85 86const ( 87 // Type unspecified. 88 DataSource_AUTHORIZATION_TYPE_UNSPECIFIED DataSource_AuthorizationType = 0 89 // Use OAuth 2 authorization codes that can be exchanged 90 // for a refresh token on the backend. 91 DataSource_AUTHORIZATION_CODE DataSource_AuthorizationType = 1 92 // Return an authorization code for a given Google+ page that can then be 93 // exchanged for a refresh token on the backend. 94 DataSource_GOOGLE_PLUS_AUTHORIZATION_CODE DataSource_AuthorizationType = 2 95) 96 97var DataSource_AuthorizationType_name = map[int32]string{ 98 0: "AUTHORIZATION_TYPE_UNSPECIFIED", 99 1: "AUTHORIZATION_CODE", 100 2: "GOOGLE_PLUS_AUTHORIZATION_CODE", 101} 102 103var DataSource_AuthorizationType_value = map[string]int32{ 104 "AUTHORIZATION_TYPE_UNSPECIFIED": 0, 105 "AUTHORIZATION_CODE": 1, 106 "GOOGLE_PLUS_AUTHORIZATION_CODE": 2, 107} 108 109func (x DataSource_AuthorizationType) String() string { 110 return proto.EnumName(DataSource_AuthorizationType_name, int32(x)) 111} 112 113func (DataSource_AuthorizationType) EnumDescriptor() ([]byte, []int) { 114 return fileDescriptor_8edec8f64c27b8a4, []int{1, 0} 115} 116 117// Represents how the data source supports data auto refresh. 118type DataSource_DataRefreshType int32 119 120const ( 121 // The data source won't support data auto refresh, which is default value. 122 DataSource_DATA_REFRESH_TYPE_UNSPECIFIED DataSource_DataRefreshType = 0 123 // The data source supports data auto refresh, and runs will be scheduled 124 // for the past few days. Does not allow custom values to be set for each 125 // transfer config. 126 DataSource_SLIDING_WINDOW DataSource_DataRefreshType = 1 127 // The data source supports data auto refresh, and runs will be scheduled 128 // for the past few days. Allows custom values to be set for each transfer 129 // config. 130 DataSource_CUSTOM_SLIDING_WINDOW DataSource_DataRefreshType = 2 131) 132 133var DataSource_DataRefreshType_name = map[int32]string{ 134 0: "DATA_REFRESH_TYPE_UNSPECIFIED", 135 1: "SLIDING_WINDOW", 136 2: "CUSTOM_SLIDING_WINDOW", 137} 138 139var DataSource_DataRefreshType_value = map[string]int32{ 140 "DATA_REFRESH_TYPE_UNSPECIFIED": 0, 141 "SLIDING_WINDOW": 1, 142 "CUSTOM_SLIDING_WINDOW": 2, 143} 144 145func (x DataSource_DataRefreshType) String() string { 146 return proto.EnumName(DataSource_DataRefreshType_name, int32(x)) 147} 148 149func (DataSource_DataRefreshType) EnumDescriptor() ([]byte, []int) { 150 return fileDescriptor_8edec8f64c27b8a4, []int{1, 1} 151} 152 153// Represents which runs should be pulled. 154type ListTransferRunsRequest_RunAttempt int32 155 156const ( 157 // All runs should be returned. 158 ListTransferRunsRequest_RUN_ATTEMPT_UNSPECIFIED ListTransferRunsRequest_RunAttempt = 0 159 // Only latest run per day should be returned. 160 ListTransferRunsRequest_LATEST ListTransferRunsRequest_RunAttempt = 1 161) 162 163var ListTransferRunsRequest_RunAttempt_name = map[int32]string{ 164 0: "RUN_ATTEMPT_UNSPECIFIED", 165 1: "LATEST", 166} 167 168var ListTransferRunsRequest_RunAttempt_value = map[string]int32{ 169 "RUN_ATTEMPT_UNSPECIFIED": 0, 170 "LATEST": 1, 171} 172 173func (x ListTransferRunsRequest_RunAttempt) String() string { 174 return proto.EnumName(ListTransferRunsRequest_RunAttempt_name, int32(x)) 175} 176 177func (ListTransferRunsRequest_RunAttempt) EnumDescriptor() ([]byte, []int) { 178 return fileDescriptor_8edec8f64c27b8a4, []int{13, 0} 179} 180 181// Represents a data source parameter with validation rules, so that 182// parameters can be rendered in the UI. These parameters are given to us by 183// supported data sources, and include all needed information for rendering 184// and validation. 185// Thus, whoever uses this api can decide to generate either generic ui, 186// or custom data source specific forms. 187type DataSourceParameter struct { 188 // Parameter identifier. 189 ParamId string `protobuf:"bytes,1,opt,name=param_id,json=paramId,proto3" json:"param_id,omitempty"` 190 // Parameter display name in the user interface. 191 DisplayName string `protobuf:"bytes,2,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"` 192 // Parameter description. 193 Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"` 194 // Parameter type. 195 Type DataSourceParameter_Type `protobuf:"varint,4,opt,name=type,proto3,enum=google.cloud.bigquery.datatransfer.v1.DataSourceParameter_Type" json:"type,omitempty"` 196 // Is parameter required. 197 Required bool `protobuf:"varint,5,opt,name=required,proto3" json:"required,omitempty"` 198 // Deprecated. This field has no effect. 199 Repeated bool `protobuf:"varint,6,opt,name=repeated,proto3" json:"repeated,omitempty"` 200 // Regular expression which can be used for parameter validation. 201 ValidationRegex string `protobuf:"bytes,7,opt,name=validation_regex,json=validationRegex,proto3" json:"validation_regex,omitempty"` 202 // All possible values for the parameter. 203 AllowedValues []string `protobuf:"bytes,8,rep,name=allowed_values,json=allowedValues,proto3" json:"allowed_values,omitempty"` 204 // For integer and double values specifies minimum allowed value. 205 MinValue *wrappers.DoubleValue `protobuf:"bytes,9,opt,name=min_value,json=minValue,proto3" json:"min_value,omitempty"` 206 // For integer and double values specifies maxminum allowed value. 207 MaxValue *wrappers.DoubleValue `protobuf:"bytes,10,opt,name=max_value,json=maxValue,proto3" json:"max_value,omitempty"` 208 // Deprecated. This field has no effect. 209 Fields []*DataSourceParameter `protobuf:"bytes,11,rep,name=fields,proto3" json:"fields,omitempty"` 210 // Description of the requirements for this field, in case the user input does 211 // not fulfill the regex pattern or min/max values. 212 ValidationDescription string `protobuf:"bytes,12,opt,name=validation_description,json=validationDescription,proto3" json:"validation_description,omitempty"` 213 // URL to a help document to further explain the naming requirements. 214 ValidationHelpUrl string `protobuf:"bytes,13,opt,name=validation_help_url,json=validationHelpUrl,proto3" json:"validation_help_url,omitempty"` 215 // Cannot be changed after initial creation. 216 Immutable bool `protobuf:"varint,14,opt,name=immutable,proto3" json:"immutable,omitempty"` 217 // Deprecated. This field has no effect. 218 Recurse bool `protobuf:"varint,15,opt,name=recurse,proto3" json:"recurse,omitempty"` 219 // If true, it should not be used in new transfers, and it should not be 220 // visible to users. 221 Deprecated bool `protobuf:"varint,20,opt,name=deprecated,proto3" json:"deprecated,omitempty"` 222 XXX_NoUnkeyedLiteral struct{} `json:"-"` 223 XXX_unrecognized []byte `json:"-"` 224 XXX_sizecache int32 `json:"-"` 225} 226 227func (m *DataSourceParameter) Reset() { *m = DataSourceParameter{} } 228func (m *DataSourceParameter) String() string { return proto.CompactTextString(m) } 229func (*DataSourceParameter) ProtoMessage() {} 230func (*DataSourceParameter) Descriptor() ([]byte, []int) { 231 return fileDescriptor_8edec8f64c27b8a4, []int{0} 232} 233 234func (m *DataSourceParameter) XXX_Unmarshal(b []byte) error { 235 return xxx_messageInfo_DataSourceParameter.Unmarshal(m, b) 236} 237func (m *DataSourceParameter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 238 return xxx_messageInfo_DataSourceParameter.Marshal(b, m, deterministic) 239} 240func (m *DataSourceParameter) XXX_Merge(src proto.Message) { 241 xxx_messageInfo_DataSourceParameter.Merge(m, src) 242} 243func (m *DataSourceParameter) XXX_Size() int { 244 return xxx_messageInfo_DataSourceParameter.Size(m) 245} 246func (m *DataSourceParameter) XXX_DiscardUnknown() { 247 xxx_messageInfo_DataSourceParameter.DiscardUnknown(m) 248} 249 250var xxx_messageInfo_DataSourceParameter proto.InternalMessageInfo 251 252func (m *DataSourceParameter) GetParamId() string { 253 if m != nil { 254 return m.ParamId 255 } 256 return "" 257} 258 259func (m *DataSourceParameter) GetDisplayName() string { 260 if m != nil { 261 return m.DisplayName 262 } 263 return "" 264} 265 266func (m *DataSourceParameter) GetDescription() string { 267 if m != nil { 268 return m.Description 269 } 270 return "" 271} 272 273func (m *DataSourceParameter) GetType() DataSourceParameter_Type { 274 if m != nil { 275 return m.Type 276 } 277 return DataSourceParameter_TYPE_UNSPECIFIED 278} 279 280func (m *DataSourceParameter) GetRequired() bool { 281 if m != nil { 282 return m.Required 283 } 284 return false 285} 286 287func (m *DataSourceParameter) GetRepeated() bool { 288 if m != nil { 289 return m.Repeated 290 } 291 return false 292} 293 294func (m *DataSourceParameter) GetValidationRegex() string { 295 if m != nil { 296 return m.ValidationRegex 297 } 298 return "" 299} 300 301func (m *DataSourceParameter) GetAllowedValues() []string { 302 if m != nil { 303 return m.AllowedValues 304 } 305 return nil 306} 307 308func (m *DataSourceParameter) GetMinValue() *wrappers.DoubleValue { 309 if m != nil { 310 return m.MinValue 311 } 312 return nil 313} 314 315func (m *DataSourceParameter) GetMaxValue() *wrappers.DoubleValue { 316 if m != nil { 317 return m.MaxValue 318 } 319 return nil 320} 321 322func (m *DataSourceParameter) GetFields() []*DataSourceParameter { 323 if m != nil { 324 return m.Fields 325 } 326 return nil 327} 328 329func (m *DataSourceParameter) GetValidationDescription() string { 330 if m != nil { 331 return m.ValidationDescription 332 } 333 return "" 334} 335 336func (m *DataSourceParameter) GetValidationHelpUrl() string { 337 if m != nil { 338 return m.ValidationHelpUrl 339 } 340 return "" 341} 342 343func (m *DataSourceParameter) GetImmutable() bool { 344 if m != nil { 345 return m.Immutable 346 } 347 return false 348} 349 350func (m *DataSourceParameter) GetRecurse() bool { 351 if m != nil { 352 return m.Recurse 353 } 354 return false 355} 356 357func (m *DataSourceParameter) GetDeprecated() bool { 358 if m != nil { 359 return m.Deprecated 360 } 361 return false 362} 363 364// Represents data source metadata. Metadata is sufficient to 365// render UI and request proper OAuth tokens. 366type DataSource struct { 367 // Output only. Data source resource name. 368 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 369 // Data source id. 370 DataSourceId string `protobuf:"bytes,2,opt,name=data_source_id,json=dataSourceId,proto3" json:"data_source_id,omitempty"` 371 // User friendly data source name. 372 DisplayName string `protobuf:"bytes,3,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"` 373 // User friendly data source description string. 374 Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"` 375 // Data source client id which should be used to receive refresh token. 376 ClientId string `protobuf:"bytes,5,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"` 377 // Api auth scopes for which refresh token needs to be obtained. These are 378 // scopes needed by a data source to prepare data and ingest them into 379 // BigQuery, e.g., https://www.googleapis.com/auth/bigquery 380 Scopes []string `protobuf:"bytes,6,rep,name=scopes,proto3" json:"scopes,omitempty"` 381 // Deprecated. This field has no effect. 382 TransferType TransferType `protobuf:"varint,7,opt,name=transfer_type,json=transferType,proto3,enum=google.cloud.bigquery.datatransfer.v1.TransferType" json:"transfer_type,omitempty"` // Deprecated: Do not use. 383 // Deprecated. This field has no effect. 384 SupportsMultipleTransfers bool `protobuf:"varint,8,opt,name=supports_multiple_transfers,json=supportsMultipleTransfers,proto3" json:"supports_multiple_transfers,omitempty"` // Deprecated: Do not use. 385 // The number of seconds to wait for an update from the data source 386 // before the Data Transfer Service marks the transfer as FAILED. 387 UpdateDeadlineSeconds int32 `protobuf:"varint,9,opt,name=update_deadline_seconds,json=updateDeadlineSeconds,proto3" json:"update_deadline_seconds,omitempty"` 388 // Default data transfer schedule. 389 // Examples of valid schedules include: 390 // `1st,3rd monday of month 15:30`, 391 // `every wed,fri of jan,jun 13:15`, and 392 // `first sunday of quarter 00:00`. 393 DefaultSchedule string `protobuf:"bytes,10,opt,name=default_schedule,json=defaultSchedule,proto3" json:"default_schedule,omitempty"` 394 // Specifies whether the data source supports a user defined schedule, or 395 // operates on the default schedule. 396 // When set to `true`, user can override default schedule. 397 SupportsCustomSchedule bool `protobuf:"varint,11,opt,name=supports_custom_schedule,json=supportsCustomSchedule,proto3" json:"supports_custom_schedule,omitempty"` 398 // Data source parameters. 399 Parameters []*DataSourceParameter `protobuf:"bytes,12,rep,name=parameters,proto3" json:"parameters,omitempty"` 400 // Url for the help document for this data source. 401 HelpUrl string `protobuf:"bytes,13,opt,name=help_url,json=helpUrl,proto3" json:"help_url,omitempty"` 402 // Indicates the type of authorization. 403 AuthorizationType DataSource_AuthorizationType `protobuf:"varint,14,opt,name=authorization_type,json=authorizationType,proto3,enum=google.cloud.bigquery.datatransfer.v1.DataSource_AuthorizationType" json:"authorization_type,omitempty"` 404 // Specifies whether the data source supports automatic data refresh for the 405 // past few days, and how it's supported. 406 // For some data sources, data might not be complete until a few days later, 407 // so it's useful to refresh data automatically. 408 DataRefreshType DataSource_DataRefreshType `protobuf:"varint,15,opt,name=data_refresh_type,json=dataRefreshType,proto3,enum=google.cloud.bigquery.datatransfer.v1.DataSource_DataRefreshType" json:"data_refresh_type,omitempty"` 409 // Default data refresh window on days. 410 // Only meaningful when `data_refresh_type` = `SLIDING_WINDOW`. 411 DefaultDataRefreshWindowDays int32 `protobuf:"varint,16,opt,name=default_data_refresh_window_days,json=defaultDataRefreshWindowDays,proto3" json:"default_data_refresh_window_days,omitempty"` 412 // Disables backfilling and manual run scheduling 413 // for the data source. 414 ManualRunsDisabled bool `protobuf:"varint,17,opt,name=manual_runs_disabled,json=manualRunsDisabled,proto3" json:"manual_runs_disabled,omitempty"` 415 // The minimum interval for scheduler to schedule runs. 416 MinimumScheduleInterval *duration.Duration `protobuf:"bytes,18,opt,name=minimum_schedule_interval,json=minimumScheduleInterval,proto3" json:"minimum_schedule_interval,omitempty"` 417 XXX_NoUnkeyedLiteral struct{} `json:"-"` 418 XXX_unrecognized []byte `json:"-"` 419 XXX_sizecache int32 `json:"-"` 420} 421 422func (m *DataSource) Reset() { *m = DataSource{} } 423func (m *DataSource) String() string { return proto.CompactTextString(m) } 424func (*DataSource) ProtoMessage() {} 425func (*DataSource) Descriptor() ([]byte, []int) { 426 return fileDescriptor_8edec8f64c27b8a4, []int{1} 427} 428 429func (m *DataSource) XXX_Unmarshal(b []byte) error { 430 return xxx_messageInfo_DataSource.Unmarshal(m, b) 431} 432func (m *DataSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 433 return xxx_messageInfo_DataSource.Marshal(b, m, deterministic) 434} 435func (m *DataSource) XXX_Merge(src proto.Message) { 436 xxx_messageInfo_DataSource.Merge(m, src) 437} 438func (m *DataSource) XXX_Size() int { 439 return xxx_messageInfo_DataSource.Size(m) 440} 441func (m *DataSource) XXX_DiscardUnknown() { 442 xxx_messageInfo_DataSource.DiscardUnknown(m) 443} 444 445var xxx_messageInfo_DataSource proto.InternalMessageInfo 446 447func (m *DataSource) GetName() string { 448 if m != nil { 449 return m.Name 450 } 451 return "" 452} 453 454func (m *DataSource) GetDataSourceId() string { 455 if m != nil { 456 return m.DataSourceId 457 } 458 return "" 459} 460 461func (m *DataSource) GetDisplayName() string { 462 if m != nil { 463 return m.DisplayName 464 } 465 return "" 466} 467 468func (m *DataSource) GetDescription() string { 469 if m != nil { 470 return m.Description 471 } 472 return "" 473} 474 475func (m *DataSource) GetClientId() string { 476 if m != nil { 477 return m.ClientId 478 } 479 return "" 480} 481 482func (m *DataSource) GetScopes() []string { 483 if m != nil { 484 return m.Scopes 485 } 486 return nil 487} 488 489// Deprecated: Do not use. 490func (m *DataSource) GetTransferType() TransferType { 491 if m != nil { 492 return m.TransferType 493 } 494 return TransferType_TRANSFER_TYPE_UNSPECIFIED 495} 496 497// Deprecated: Do not use. 498func (m *DataSource) GetSupportsMultipleTransfers() bool { 499 if m != nil { 500 return m.SupportsMultipleTransfers 501 } 502 return false 503} 504 505func (m *DataSource) GetUpdateDeadlineSeconds() int32 { 506 if m != nil { 507 return m.UpdateDeadlineSeconds 508 } 509 return 0 510} 511 512func (m *DataSource) GetDefaultSchedule() string { 513 if m != nil { 514 return m.DefaultSchedule 515 } 516 return "" 517} 518 519func (m *DataSource) GetSupportsCustomSchedule() bool { 520 if m != nil { 521 return m.SupportsCustomSchedule 522 } 523 return false 524} 525 526func (m *DataSource) GetParameters() []*DataSourceParameter { 527 if m != nil { 528 return m.Parameters 529 } 530 return nil 531} 532 533func (m *DataSource) GetHelpUrl() string { 534 if m != nil { 535 return m.HelpUrl 536 } 537 return "" 538} 539 540func (m *DataSource) GetAuthorizationType() DataSource_AuthorizationType { 541 if m != nil { 542 return m.AuthorizationType 543 } 544 return DataSource_AUTHORIZATION_TYPE_UNSPECIFIED 545} 546 547func (m *DataSource) GetDataRefreshType() DataSource_DataRefreshType { 548 if m != nil { 549 return m.DataRefreshType 550 } 551 return DataSource_DATA_REFRESH_TYPE_UNSPECIFIED 552} 553 554func (m *DataSource) GetDefaultDataRefreshWindowDays() int32 { 555 if m != nil { 556 return m.DefaultDataRefreshWindowDays 557 } 558 return 0 559} 560 561func (m *DataSource) GetManualRunsDisabled() bool { 562 if m != nil { 563 return m.ManualRunsDisabled 564 } 565 return false 566} 567 568func (m *DataSource) GetMinimumScheduleInterval() *duration.Duration { 569 if m != nil { 570 return m.MinimumScheduleInterval 571 } 572 return nil 573} 574 575// A request to get data source info. 576type GetDataSourceRequest struct { 577 // Required. The field will contain name of the resource requested, for example: 578 // `projects/{project_id}/dataSources/{data_source_id}` or 579 // `projects/{project_id}/locations/{location_id}/dataSources/{data_source_id}` 580 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 581 XXX_NoUnkeyedLiteral struct{} `json:"-"` 582 XXX_unrecognized []byte `json:"-"` 583 XXX_sizecache int32 `json:"-"` 584} 585 586func (m *GetDataSourceRequest) Reset() { *m = GetDataSourceRequest{} } 587func (m *GetDataSourceRequest) String() string { return proto.CompactTextString(m) } 588func (*GetDataSourceRequest) ProtoMessage() {} 589func (*GetDataSourceRequest) Descriptor() ([]byte, []int) { 590 return fileDescriptor_8edec8f64c27b8a4, []int{2} 591} 592 593func (m *GetDataSourceRequest) XXX_Unmarshal(b []byte) error { 594 return xxx_messageInfo_GetDataSourceRequest.Unmarshal(m, b) 595} 596func (m *GetDataSourceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 597 return xxx_messageInfo_GetDataSourceRequest.Marshal(b, m, deterministic) 598} 599func (m *GetDataSourceRequest) XXX_Merge(src proto.Message) { 600 xxx_messageInfo_GetDataSourceRequest.Merge(m, src) 601} 602func (m *GetDataSourceRequest) XXX_Size() int { 603 return xxx_messageInfo_GetDataSourceRequest.Size(m) 604} 605func (m *GetDataSourceRequest) XXX_DiscardUnknown() { 606 xxx_messageInfo_GetDataSourceRequest.DiscardUnknown(m) 607} 608 609var xxx_messageInfo_GetDataSourceRequest proto.InternalMessageInfo 610 611func (m *GetDataSourceRequest) GetName() string { 612 if m != nil { 613 return m.Name 614 } 615 return "" 616} 617 618// Request to list supported data sources and their data transfer settings. 619type ListDataSourcesRequest struct { 620 // Required. The BigQuery project id for which data sources should be returned. 621 // Must be in the form: `projects/{project_id}` or 622 // `projects/{project_id}/locations/{location_id} 623 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` 624 // Pagination token, which can be used to request a specific page 625 // of `ListDataSourcesRequest` list results. For multiple-page 626 // results, `ListDataSourcesResponse` outputs 627 // a `next_page` token, which can be used as the 628 // `page_token` value to request the next page of list results. 629 PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` 630 // Page size. The default page size is the maximum value of 1000 results. 631 PageSize int32 `protobuf:"varint,4,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` 632 XXX_NoUnkeyedLiteral struct{} `json:"-"` 633 XXX_unrecognized []byte `json:"-"` 634 XXX_sizecache int32 `json:"-"` 635} 636 637func (m *ListDataSourcesRequest) Reset() { *m = ListDataSourcesRequest{} } 638func (m *ListDataSourcesRequest) String() string { return proto.CompactTextString(m) } 639func (*ListDataSourcesRequest) ProtoMessage() {} 640func (*ListDataSourcesRequest) Descriptor() ([]byte, []int) { 641 return fileDescriptor_8edec8f64c27b8a4, []int{3} 642} 643 644func (m *ListDataSourcesRequest) XXX_Unmarshal(b []byte) error { 645 return xxx_messageInfo_ListDataSourcesRequest.Unmarshal(m, b) 646} 647func (m *ListDataSourcesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 648 return xxx_messageInfo_ListDataSourcesRequest.Marshal(b, m, deterministic) 649} 650func (m *ListDataSourcesRequest) XXX_Merge(src proto.Message) { 651 xxx_messageInfo_ListDataSourcesRequest.Merge(m, src) 652} 653func (m *ListDataSourcesRequest) XXX_Size() int { 654 return xxx_messageInfo_ListDataSourcesRequest.Size(m) 655} 656func (m *ListDataSourcesRequest) XXX_DiscardUnknown() { 657 xxx_messageInfo_ListDataSourcesRequest.DiscardUnknown(m) 658} 659 660var xxx_messageInfo_ListDataSourcesRequest proto.InternalMessageInfo 661 662func (m *ListDataSourcesRequest) GetParent() string { 663 if m != nil { 664 return m.Parent 665 } 666 return "" 667} 668 669func (m *ListDataSourcesRequest) GetPageToken() string { 670 if m != nil { 671 return m.PageToken 672 } 673 return "" 674} 675 676func (m *ListDataSourcesRequest) GetPageSize() int32 { 677 if m != nil { 678 return m.PageSize 679 } 680 return 0 681} 682 683// Returns list of supported data sources and their metadata. 684type ListDataSourcesResponse struct { 685 // List of supported data sources and their transfer settings. 686 DataSources []*DataSource `protobuf:"bytes,1,rep,name=data_sources,json=dataSources,proto3" json:"data_sources,omitempty"` 687 // Output only. The next-pagination token. For multiple-page list results, 688 // this token can be used as the 689 // `ListDataSourcesRequest.page_token` 690 // to request the next page of list results. 691 NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` 692 XXX_NoUnkeyedLiteral struct{} `json:"-"` 693 XXX_unrecognized []byte `json:"-"` 694 XXX_sizecache int32 `json:"-"` 695} 696 697func (m *ListDataSourcesResponse) Reset() { *m = ListDataSourcesResponse{} } 698func (m *ListDataSourcesResponse) String() string { return proto.CompactTextString(m) } 699func (*ListDataSourcesResponse) ProtoMessage() {} 700func (*ListDataSourcesResponse) Descriptor() ([]byte, []int) { 701 return fileDescriptor_8edec8f64c27b8a4, []int{4} 702} 703 704func (m *ListDataSourcesResponse) XXX_Unmarshal(b []byte) error { 705 return xxx_messageInfo_ListDataSourcesResponse.Unmarshal(m, b) 706} 707func (m *ListDataSourcesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 708 return xxx_messageInfo_ListDataSourcesResponse.Marshal(b, m, deterministic) 709} 710func (m *ListDataSourcesResponse) XXX_Merge(src proto.Message) { 711 xxx_messageInfo_ListDataSourcesResponse.Merge(m, src) 712} 713func (m *ListDataSourcesResponse) XXX_Size() int { 714 return xxx_messageInfo_ListDataSourcesResponse.Size(m) 715} 716func (m *ListDataSourcesResponse) XXX_DiscardUnknown() { 717 xxx_messageInfo_ListDataSourcesResponse.DiscardUnknown(m) 718} 719 720var xxx_messageInfo_ListDataSourcesResponse proto.InternalMessageInfo 721 722func (m *ListDataSourcesResponse) GetDataSources() []*DataSource { 723 if m != nil { 724 return m.DataSources 725 } 726 return nil 727} 728 729func (m *ListDataSourcesResponse) GetNextPageToken() string { 730 if m != nil { 731 return m.NextPageToken 732 } 733 return "" 734} 735 736// A request to create a data transfer configuration. If new credentials are 737// needed for this transfer configuration, an authorization code must be 738// provided. If an authorization code is provided, the transfer configuration 739// will be associated with the user id corresponding to the 740// authorization code. Otherwise, the transfer configuration will be associated 741// with the calling user. 742type CreateTransferConfigRequest struct { 743 // Required. The BigQuery project id where the transfer configuration should be created. 744 // Must be in the format projects/{project_id}/locations/{location_id} or 745 // projects/{project_id}. If specified location and location of the 746 // destination bigquery dataset do not match - the request will fail. 747 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` 748 // Required. Data transfer configuration to create. 749 TransferConfig *TransferConfig `protobuf:"bytes,2,opt,name=transfer_config,json=transferConfig,proto3" json:"transfer_config,omitempty"` 750 // Optional OAuth2 authorization code to use with this transfer configuration. 751 // This is required if new credentials are needed, as indicated by 752 // `CheckValidCreds`. 753 // In order to obtain authorization_code, please make a 754 // request to 755 // https://www.gstatic.com/bigquerydatatransfer/oauthz/auth?client_id=<datatransferapiclientid>&scope=<data_source_scopes>&redirect_uri=<redirect_uri> 756 // 757 // * client_id should be OAuth client_id of BigQuery DTS API for the given 758 // data source returned by ListDataSources method. 759 // * data_source_scopes are the scopes returned by ListDataSources method. 760 // * redirect_uri is an optional parameter. If not specified, then 761 // authorization code is posted to the opener of authorization flow window. 762 // Otherwise it will be sent to the redirect uri. A special value of 763 // urn:ietf:wg:oauth:2.0:oob means that authorization code should be 764 // returned in the title bar of the browser, with the page text prompting 765 // the user to copy the code and paste it in the application. 766 AuthorizationCode string `protobuf:"bytes,3,opt,name=authorization_code,json=authorizationCode,proto3" json:"authorization_code,omitempty"` 767 // Optional version info. If users want to find a very recent access token, 768 // that is, immediately after approving access, users have to set the 769 // version_info claim in the token request. To obtain the version_info, users 770 // must use the "none+gsession" response type. which be return a 771 // version_info back in the authorization response which be be put in a JWT 772 // claim in the token request. 773 VersionInfo string `protobuf:"bytes,5,opt,name=version_info,json=versionInfo,proto3" json:"version_info,omitempty"` 774 // Optional service account name. If this field is set, transfer config will 775 // be created with this service account credentials. It requires that 776 // requesting user calling this API has permissions to act as this service 777 // account. 778 ServiceAccountName string `protobuf:"bytes,6,opt,name=service_account_name,json=serviceAccountName,proto3" json:"service_account_name,omitempty"` 779 XXX_NoUnkeyedLiteral struct{} `json:"-"` 780 XXX_unrecognized []byte `json:"-"` 781 XXX_sizecache int32 `json:"-"` 782} 783 784func (m *CreateTransferConfigRequest) Reset() { *m = CreateTransferConfigRequest{} } 785func (m *CreateTransferConfigRequest) String() string { return proto.CompactTextString(m) } 786func (*CreateTransferConfigRequest) ProtoMessage() {} 787func (*CreateTransferConfigRequest) Descriptor() ([]byte, []int) { 788 return fileDescriptor_8edec8f64c27b8a4, []int{5} 789} 790 791func (m *CreateTransferConfigRequest) XXX_Unmarshal(b []byte) error { 792 return xxx_messageInfo_CreateTransferConfigRequest.Unmarshal(m, b) 793} 794func (m *CreateTransferConfigRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 795 return xxx_messageInfo_CreateTransferConfigRequest.Marshal(b, m, deterministic) 796} 797func (m *CreateTransferConfigRequest) XXX_Merge(src proto.Message) { 798 xxx_messageInfo_CreateTransferConfigRequest.Merge(m, src) 799} 800func (m *CreateTransferConfigRequest) XXX_Size() int { 801 return xxx_messageInfo_CreateTransferConfigRequest.Size(m) 802} 803func (m *CreateTransferConfigRequest) XXX_DiscardUnknown() { 804 xxx_messageInfo_CreateTransferConfigRequest.DiscardUnknown(m) 805} 806 807var xxx_messageInfo_CreateTransferConfigRequest proto.InternalMessageInfo 808 809func (m *CreateTransferConfigRequest) GetParent() string { 810 if m != nil { 811 return m.Parent 812 } 813 return "" 814} 815 816func (m *CreateTransferConfigRequest) GetTransferConfig() *TransferConfig { 817 if m != nil { 818 return m.TransferConfig 819 } 820 return nil 821} 822 823func (m *CreateTransferConfigRequest) GetAuthorizationCode() string { 824 if m != nil { 825 return m.AuthorizationCode 826 } 827 return "" 828} 829 830func (m *CreateTransferConfigRequest) GetVersionInfo() string { 831 if m != nil { 832 return m.VersionInfo 833 } 834 return "" 835} 836 837func (m *CreateTransferConfigRequest) GetServiceAccountName() string { 838 if m != nil { 839 return m.ServiceAccountName 840 } 841 return "" 842} 843 844// A request to update a transfer configuration. To update the user id of the 845// transfer configuration, an authorization code needs to be provided. 846type UpdateTransferConfigRequest struct { 847 // Required. Data transfer configuration to create. 848 TransferConfig *TransferConfig `protobuf:"bytes,1,opt,name=transfer_config,json=transferConfig,proto3" json:"transfer_config,omitempty"` 849 // Optional OAuth2 authorization code to use with this transfer configuration. 850 // If it is provided, the transfer configuration will be associated with the 851 // authorizing user. 852 // In order to obtain authorization_code, please make a 853 // request to 854 // https://www.gstatic.com/bigquerydatatransfer/oauthz/auth?client_id=<datatransferapiclientid>&scope=<data_source_scopes>&redirect_uri=<redirect_uri> 855 // 856 // * client_id should be OAuth client_id of BigQuery DTS API for the given 857 // data source returned by ListDataSources method. 858 // * data_source_scopes are the scopes returned by ListDataSources method. 859 // * redirect_uri is an optional parameter. If not specified, then 860 // authorization code is posted to the opener of authorization flow window. 861 // Otherwise it will be sent to the redirect uri. A special value of 862 // urn:ietf:wg:oauth:2.0:oob means that authorization code should be 863 // returned in the title bar of the browser, with the page text prompting 864 // the user to copy the code and paste it in the application. 865 AuthorizationCode string `protobuf:"bytes,3,opt,name=authorization_code,json=authorizationCode,proto3" json:"authorization_code,omitempty"` 866 // Required. Required list of fields to be updated in this request. 867 UpdateMask *field_mask.FieldMask `protobuf:"bytes,4,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"` 868 // Optional version info. If users want to find a very recent access token, 869 // that is, immediately after approving access, users have to set the 870 // version_info claim in the token request. To obtain the version_info, users 871 // must use the "none+gsession" response type. which be return a 872 // version_info back in the authorization response which be be put in a JWT 873 // claim in the token request. 874 VersionInfo string `protobuf:"bytes,5,opt,name=version_info,json=versionInfo,proto3" json:"version_info,omitempty"` 875 // Optional service account name. If this field is set and 876 // "service_account_name" is set in update_mask, transfer config will be 877 // updated to use this service account credentials. It requires that 878 // requesting user calling this API has permissions to act as this service 879 // account. 880 ServiceAccountName string `protobuf:"bytes,6,opt,name=service_account_name,json=serviceAccountName,proto3" json:"service_account_name,omitempty"` 881 XXX_NoUnkeyedLiteral struct{} `json:"-"` 882 XXX_unrecognized []byte `json:"-"` 883 XXX_sizecache int32 `json:"-"` 884} 885 886func (m *UpdateTransferConfigRequest) Reset() { *m = UpdateTransferConfigRequest{} } 887func (m *UpdateTransferConfigRequest) String() string { return proto.CompactTextString(m) } 888func (*UpdateTransferConfigRequest) ProtoMessage() {} 889func (*UpdateTransferConfigRequest) Descriptor() ([]byte, []int) { 890 return fileDescriptor_8edec8f64c27b8a4, []int{6} 891} 892 893func (m *UpdateTransferConfigRequest) XXX_Unmarshal(b []byte) error { 894 return xxx_messageInfo_UpdateTransferConfigRequest.Unmarshal(m, b) 895} 896func (m *UpdateTransferConfigRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 897 return xxx_messageInfo_UpdateTransferConfigRequest.Marshal(b, m, deterministic) 898} 899func (m *UpdateTransferConfigRequest) XXX_Merge(src proto.Message) { 900 xxx_messageInfo_UpdateTransferConfigRequest.Merge(m, src) 901} 902func (m *UpdateTransferConfigRequest) XXX_Size() int { 903 return xxx_messageInfo_UpdateTransferConfigRequest.Size(m) 904} 905func (m *UpdateTransferConfigRequest) XXX_DiscardUnknown() { 906 xxx_messageInfo_UpdateTransferConfigRequest.DiscardUnknown(m) 907} 908 909var xxx_messageInfo_UpdateTransferConfigRequest proto.InternalMessageInfo 910 911func (m *UpdateTransferConfigRequest) GetTransferConfig() *TransferConfig { 912 if m != nil { 913 return m.TransferConfig 914 } 915 return nil 916} 917 918func (m *UpdateTransferConfigRequest) GetAuthorizationCode() string { 919 if m != nil { 920 return m.AuthorizationCode 921 } 922 return "" 923} 924 925func (m *UpdateTransferConfigRequest) GetUpdateMask() *field_mask.FieldMask { 926 if m != nil { 927 return m.UpdateMask 928 } 929 return nil 930} 931 932func (m *UpdateTransferConfigRequest) GetVersionInfo() string { 933 if m != nil { 934 return m.VersionInfo 935 } 936 return "" 937} 938 939func (m *UpdateTransferConfigRequest) GetServiceAccountName() string { 940 if m != nil { 941 return m.ServiceAccountName 942 } 943 return "" 944} 945 946// A request to get data transfer information. 947type GetTransferConfigRequest struct { 948 // Required. The field will contain name of the resource requested, for example: 949 // `projects/{project_id}/transferConfigs/{config_id}` or 950 // `projects/{project_id}/locations/{location_id}/transferConfigs/{config_id}` 951 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 952 XXX_NoUnkeyedLiteral struct{} `json:"-"` 953 XXX_unrecognized []byte `json:"-"` 954 XXX_sizecache int32 `json:"-"` 955} 956 957func (m *GetTransferConfigRequest) Reset() { *m = GetTransferConfigRequest{} } 958func (m *GetTransferConfigRequest) String() string { return proto.CompactTextString(m) } 959func (*GetTransferConfigRequest) ProtoMessage() {} 960func (*GetTransferConfigRequest) Descriptor() ([]byte, []int) { 961 return fileDescriptor_8edec8f64c27b8a4, []int{7} 962} 963 964func (m *GetTransferConfigRequest) XXX_Unmarshal(b []byte) error { 965 return xxx_messageInfo_GetTransferConfigRequest.Unmarshal(m, b) 966} 967func (m *GetTransferConfigRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 968 return xxx_messageInfo_GetTransferConfigRequest.Marshal(b, m, deterministic) 969} 970func (m *GetTransferConfigRequest) XXX_Merge(src proto.Message) { 971 xxx_messageInfo_GetTransferConfigRequest.Merge(m, src) 972} 973func (m *GetTransferConfigRequest) XXX_Size() int { 974 return xxx_messageInfo_GetTransferConfigRequest.Size(m) 975} 976func (m *GetTransferConfigRequest) XXX_DiscardUnknown() { 977 xxx_messageInfo_GetTransferConfigRequest.DiscardUnknown(m) 978} 979 980var xxx_messageInfo_GetTransferConfigRequest proto.InternalMessageInfo 981 982func (m *GetTransferConfigRequest) GetName() string { 983 if m != nil { 984 return m.Name 985 } 986 return "" 987} 988 989// A request to delete data transfer information. All associated transfer runs 990// and log messages will be deleted as well. 991type DeleteTransferConfigRequest struct { 992 // Required. The field will contain name of the resource requested, for example: 993 // `projects/{project_id}/transferConfigs/{config_id}` or 994 // `projects/{project_id}/locations/{location_id}/transferConfigs/{config_id}` 995 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 996 XXX_NoUnkeyedLiteral struct{} `json:"-"` 997 XXX_unrecognized []byte `json:"-"` 998 XXX_sizecache int32 `json:"-"` 999} 1000 1001func (m *DeleteTransferConfigRequest) Reset() { *m = DeleteTransferConfigRequest{} } 1002func (m *DeleteTransferConfigRequest) String() string { return proto.CompactTextString(m) } 1003func (*DeleteTransferConfigRequest) ProtoMessage() {} 1004func (*DeleteTransferConfigRequest) Descriptor() ([]byte, []int) { 1005 return fileDescriptor_8edec8f64c27b8a4, []int{8} 1006} 1007 1008func (m *DeleteTransferConfigRequest) XXX_Unmarshal(b []byte) error { 1009 return xxx_messageInfo_DeleteTransferConfigRequest.Unmarshal(m, b) 1010} 1011func (m *DeleteTransferConfigRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1012 return xxx_messageInfo_DeleteTransferConfigRequest.Marshal(b, m, deterministic) 1013} 1014func (m *DeleteTransferConfigRequest) XXX_Merge(src proto.Message) { 1015 xxx_messageInfo_DeleteTransferConfigRequest.Merge(m, src) 1016} 1017func (m *DeleteTransferConfigRequest) XXX_Size() int { 1018 return xxx_messageInfo_DeleteTransferConfigRequest.Size(m) 1019} 1020func (m *DeleteTransferConfigRequest) XXX_DiscardUnknown() { 1021 xxx_messageInfo_DeleteTransferConfigRequest.DiscardUnknown(m) 1022} 1023 1024var xxx_messageInfo_DeleteTransferConfigRequest proto.InternalMessageInfo 1025 1026func (m *DeleteTransferConfigRequest) GetName() string { 1027 if m != nil { 1028 return m.Name 1029 } 1030 return "" 1031} 1032 1033// A request to get data transfer run information. 1034type GetTransferRunRequest struct { 1035 // Required. The field will contain name of the resource requested, for example: 1036 // `projects/{project_id}/transferConfigs/{config_id}/runs/{run_id}` or 1037 // `projects/{project_id}/locations/{location_id}/transferConfigs/{config_id}/runs/{run_id}` 1038 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 1039 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1040 XXX_unrecognized []byte `json:"-"` 1041 XXX_sizecache int32 `json:"-"` 1042} 1043 1044func (m *GetTransferRunRequest) Reset() { *m = GetTransferRunRequest{} } 1045func (m *GetTransferRunRequest) String() string { return proto.CompactTextString(m) } 1046func (*GetTransferRunRequest) ProtoMessage() {} 1047func (*GetTransferRunRequest) Descriptor() ([]byte, []int) { 1048 return fileDescriptor_8edec8f64c27b8a4, []int{9} 1049} 1050 1051func (m *GetTransferRunRequest) XXX_Unmarshal(b []byte) error { 1052 return xxx_messageInfo_GetTransferRunRequest.Unmarshal(m, b) 1053} 1054func (m *GetTransferRunRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1055 return xxx_messageInfo_GetTransferRunRequest.Marshal(b, m, deterministic) 1056} 1057func (m *GetTransferRunRequest) XXX_Merge(src proto.Message) { 1058 xxx_messageInfo_GetTransferRunRequest.Merge(m, src) 1059} 1060func (m *GetTransferRunRequest) XXX_Size() int { 1061 return xxx_messageInfo_GetTransferRunRequest.Size(m) 1062} 1063func (m *GetTransferRunRequest) XXX_DiscardUnknown() { 1064 xxx_messageInfo_GetTransferRunRequest.DiscardUnknown(m) 1065} 1066 1067var xxx_messageInfo_GetTransferRunRequest proto.InternalMessageInfo 1068 1069func (m *GetTransferRunRequest) GetName() string { 1070 if m != nil { 1071 return m.Name 1072 } 1073 return "" 1074} 1075 1076// A request to delete data transfer run information. 1077type DeleteTransferRunRequest struct { 1078 // Required. The field will contain name of the resource requested, for example: 1079 // `projects/{project_id}/transferConfigs/{config_id}/runs/{run_id}` or 1080 // `projects/{project_id}/locations/{location_id}/transferConfigs/{config_id}/runs/{run_id}` 1081 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 1082 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1083 XXX_unrecognized []byte `json:"-"` 1084 XXX_sizecache int32 `json:"-"` 1085} 1086 1087func (m *DeleteTransferRunRequest) Reset() { *m = DeleteTransferRunRequest{} } 1088func (m *DeleteTransferRunRequest) String() string { return proto.CompactTextString(m) } 1089func (*DeleteTransferRunRequest) ProtoMessage() {} 1090func (*DeleteTransferRunRequest) Descriptor() ([]byte, []int) { 1091 return fileDescriptor_8edec8f64c27b8a4, []int{10} 1092} 1093 1094func (m *DeleteTransferRunRequest) XXX_Unmarshal(b []byte) error { 1095 return xxx_messageInfo_DeleteTransferRunRequest.Unmarshal(m, b) 1096} 1097func (m *DeleteTransferRunRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1098 return xxx_messageInfo_DeleteTransferRunRequest.Marshal(b, m, deterministic) 1099} 1100func (m *DeleteTransferRunRequest) XXX_Merge(src proto.Message) { 1101 xxx_messageInfo_DeleteTransferRunRequest.Merge(m, src) 1102} 1103func (m *DeleteTransferRunRequest) XXX_Size() int { 1104 return xxx_messageInfo_DeleteTransferRunRequest.Size(m) 1105} 1106func (m *DeleteTransferRunRequest) XXX_DiscardUnknown() { 1107 xxx_messageInfo_DeleteTransferRunRequest.DiscardUnknown(m) 1108} 1109 1110var xxx_messageInfo_DeleteTransferRunRequest proto.InternalMessageInfo 1111 1112func (m *DeleteTransferRunRequest) GetName() string { 1113 if m != nil { 1114 return m.Name 1115 } 1116 return "" 1117} 1118 1119// A request to list data transfers configured for a BigQuery project. 1120type ListTransferConfigsRequest struct { 1121 // Required. The BigQuery project id for which data sources 1122 // should be returned: `projects/{project_id}` or 1123 // `projects/{project_id}/locations/{location_id}` 1124 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` 1125 // When specified, only configurations of requested data sources are returned. 1126 DataSourceIds []string `protobuf:"bytes,2,rep,name=data_source_ids,json=dataSourceIds,proto3" json:"data_source_ids,omitempty"` 1127 // Pagination token, which can be used to request a specific page 1128 // of `ListTransfersRequest` list results. For multiple-page 1129 // results, `ListTransfersResponse` outputs 1130 // a `next_page` token, which can be used as the 1131 // `page_token` value to request the next page of list results. 1132 PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` 1133 // Page size. The default page size is the maximum value of 1000 results. 1134 PageSize int32 `protobuf:"varint,4,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` 1135 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1136 XXX_unrecognized []byte `json:"-"` 1137 XXX_sizecache int32 `json:"-"` 1138} 1139 1140func (m *ListTransferConfigsRequest) Reset() { *m = ListTransferConfigsRequest{} } 1141func (m *ListTransferConfigsRequest) String() string { return proto.CompactTextString(m) } 1142func (*ListTransferConfigsRequest) ProtoMessage() {} 1143func (*ListTransferConfigsRequest) Descriptor() ([]byte, []int) { 1144 return fileDescriptor_8edec8f64c27b8a4, []int{11} 1145} 1146 1147func (m *ListTransferConfigsRequest) XXX_Unmarshal(b []byte) error { 1148 return xxx_messageInfo_ListTransferConfigsRequest.Unmarshal(m, b) 1149} 1150func (m *ListTransferConfigsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1151 return xxx_messageInfo_ListTransferConfigsRequest.Marshal(b, m, deterministic) 1152} 1153func (m *ListTransferConfigsRequest) XXX_Merge(src proto.Message) { 1154 xxx_messageInfo_ListTransferConfigsRequest.Merge(m, src) 1155} 1156func (m *ListTransferConfigsRequest) XXX_Size() int { 1157 return xxx_messageInfo_ListTransferConfigsRequest.Size(m) 1158} 1159func (m *ListTransferConfigsRequest) XXX_DiscardUnknown() { 1160 xxx_messageInfo_ListTransferConfigsRequest.DiscardUnknown(m) 1161} 1162 1163var xxx_messageInfo_ListTransferConfigsRequest proto.InternalMessageInfo 1164 1165func (m *ListTransferConfigsRequest) GetParent() string { 1166 if m != nil { 1167 return m.Parent 1168 } 1169 return "" 1170} 1171 1172func (m *ListTransferConfigsRequest) GetDataSourceIds() []string { 1173 if m != nil { 1174 return m.DataSourceIds 1175 } 1176 return nil 1177} 1178 1179func (m *ListTransferConfigsRequest) GetPageToken() string { 1180 if m != nil { 1181 return m.PageToken 1182 } 1183 return "" 1184} 1185 1186func (m *ListTransferConfigsRequest) GetPageSize() int32 { 1187 if m != nil { 1188 return m.PageSize 1189 } 1190 return 0 1191} 1192 1193// The returned list of pipelines in the project. 1194type ListTransferConfigsResponse struct { 1195 // Output only. The stored pipeline transfer configurations. 1196 TransferConfigs []*TransferConfig `protobuf:"bytes,1,rep,name=transfer_configs,json=transferConfigs,proto3" json:"transfer_configs,omitempty"` 1197 // Output only. The next-pagination token. For multiple-page list results, 1198 // this token can be used as the 1199 // `ListTransferConfigsRequest.page_token` 1200 // to request the next page of list results. 1201 NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` 1202 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1203 XXX_unrecognized []byte `json:"-"` 1204 XXX_sizecache int32 `json:"-"` 1205} 1206 1207func (m *ListTransferConfigsResponse) Reset() { *m = ListTransferConfigsResponse{} } 1208func (m *ListTransferConfigsResponse) String() string { return proto.CompactTextString(m) } 1209func (*ListTransferConfigsResponse) ProtoMessage() {} 1210func (*ListTransferConfigsResponse) Descriptor() ([]byte, []int) { 1211 return fileDescriptor_8edec8f64c27b8a4, []int{12} 1212} 1213 1214func (m *ListTransferConfigsResponse) XXX_Unmarshal(b []byte) error { 1215 return xxx_messageInfo_ListTransferConfigsResponse.Unmarshal(m, b) 1216} 1217func (m *ListTransferConfigsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1218 return xxx_messageInfo_ListTransferConfigsResponse.Marshal(b, m, deterministic) 1219} 1220func (m *ListTransferConfigsResponse) XXX_Merge(src proto.Message) { 1221 xxx_messageInfo_ListTransferConfigsResponse.Merge(m, src) 1222} 1223func (m *ListTransferConfigsResponse) XXX_Size() int { 1224 return xxx_messageInfo_ListTransferConfigsResponse.Size(m) 1225} 1226func (m *ListTransferConfigsResponse) XXX_DiscardUnknown() { 1227 xxx_messageInfo_ListTransferConfigsResponse.DiscardUnknown(m) 1228} 1229 1230var xxx_messageInfo_ListTransferConfigsResponse proto.InternalMessageInfo 1231 1232func (m *ListTransferConfigsResponse) GetTransferConfigs() []*TransferConfig { 1233 if m != nil { 1234 return m.TransferConfigs 1235 } 1236 return nil 1237} 1238 1239func (m *ListTransferConfigsResponse) GetNextPageToken() string { 1240 if m != nil { 1241 return m.NextPageToken 1242 } 1243 return "" 1244} 1245 1246// A request to list data transfer runs. UI can use this method to show/filter 1247// specific data transfer runs. The data source can use this method to request 1248// all scheduled transfer runs. 1249type ListTransferRunsRequest struct { 1250 // Required. Name of transfer configuration for which transfer runs should be retrieved. 1251 // Format of transfer configuration resource name is: 1252 // `projects/{project_id}/transferConfigs/{config_id}` or 1253 // `projects/{project_id}/locations/{location_id}/transferConfigs/{config_id}`. 1254 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` 1255 // When specified, only transfer runs with requested states are returned. 1256 States []TransferState `protobuf:"varint,2,rep,packed,name=states,proto3,enum=google.cloud.bigquery.datatransfer.v1.TransferState" json:"states,omitempty"` 1257 // Pagination token, which can be used to request a specific page 1258 // of `ListTransferRunsRequest` list results. For multiple-page 1259 // results, `ListTransferRunsResponse` outputs 1260 // a `next_page` token, which can be used as the 1261 // `page_token` value to request the next page of list results. 1262 PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` 1263 // Page size. The default page size is the maximum value of 1000 results. 1264 PageSize int32 `protobuf:"varint,4,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` 1265 // Indicates how run attempts are to be pulled. 1266 RunAttempt ListTransferRunsRequest_RunAttempt `protobuf:"varint,5,opt,name=run_attempt,json=runAttempt,proto3,enum=google.cloud.bigquery.datatransfer.v1.ListTransferRunsRequest_RunAttempt" json:"run_attempt,omitempty"` 1267 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1268 XXX_unrecognized []byte `json:"-"` 1269 XXX_sizecache int32 `json:"-"` 1270} 1271 1272func (m *ListTransferRunsRequest) Reset() { *m = ListTransferRunsRequest{} } 1273func (m *ListTransferRunsRequest) String() string { return proto.CompactTextString(m) } 1274func (*ListTransferRunsRequest) ProtoMessage() {} 1275func (*ListTransferRunsRequest) Descriptor() ([]byte, []int) { 1276 return fileDescriptor_8edec8f64c27b8a4, []int{13} 1277} 1278 1279func (m *ListTransferRunsRequest) XXX_Unmarshal(b []byte) error { 1280 return xxx_messageInfo_ListTransferRunsRequest.Unmarshal(m, b) 1281} 1282func (m *ListTransferRunsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1283 return xxx_messageInfo_ListTransferRunsRequest.Marshal(b, m, deterministic) 1284} 1285func (m *ListTransferRunsRequest) XXX_Merge(src proto.Message) { 1286 xxx_messageInfo_ListTransferRunsRequest.Merge(m, src) 1287} 1288func (m *ListTransferRunsRequest) XXX_Size() int { 1289 return xxx_messageInfo_ListTransferRunsRequest.Size(m) 1290} 1291func (m *ListTransferRunsRequest) XXX_DiscardUnknown() { 1292 xxx_messageInfo_ListTransferRunsRequest.DiscardUnknown(m) 1293} 1294 1295var xxx_messageInfo_ListTransferRunsRequest proto.InternalMessageInfo 1296 1297func (m *ListTransferRunsRequest) GetParent() string { 1298 if m != nil { 1299 return m.Parent 1300 } 1301 return "" 1302} 1303 1304func (m *ListTransferRunsRequest) GetStates() []TransferState { 1305 if m != nil { 1306 return m.States 1307 } 1308 return nil 1309} 1310 1311func (m *ListTransferRunsRequest) GetPageToken() string { 1312 if m != nil { 1313 return m.PageToken 1314 } 1315 return "" 1316} 1317 1318func (m *ListTransferRunsRequest) GetPageSize() int32 { 1319 if m != nil { 1320 return m.PageSize 1321 } 1322 return 0 1323} 1324 1325func (m *ListTransferRunsRequest) GetRunAttempt() ListTransferRunsRequest_RunAttempt { 1326 if m != nil { 1327 return m.RunAttempt 1328 } 1329 return ListTransferRunsRequest_RUN_ATTEMPT_UNSPECIFIED 1330} 1331 1332// The returned list of pipelines in the project. 1333type ListTransferRunsResponse struct { 1334 // Output only. The stored pipeline transfer runs. 1335 TransferRuns []*TransferRun `protobuf:"bytes,1,rep,name=transfer_runs,json=transferRuns,proto3" json:"transfer_runs,omitempty"` 1336 // Output only. The next-pagination token. For multiple-page list results, 1337 // this token can be used as the 1338 // `ListTransferRunsRequest.page_token` 1339 // to request the next page of list results. 1340 NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` 1341 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1342 XXX_unrecognized []byte `json:"-"` 1343 XXX_sizecache int32 `json:"-"` 1344} 1345 1346func (m *ListTransferRunsResponse) Reset() { *m = ListTransferRunsResponse{} } 1347func (m *ListTransferRunsResponse) String() string { return proto.CompactTextString(m) } 1348func (*ListTransferRunsResponse) ProtoMessage() {} 1349func (*ListTransferRunsResponse) Descriptor() ([]byte, []int) { 1350 return fileDescriptor_8edec8f64c27b8a4, []int{14} 1351} 1352 1353func (m *ListTransferRunsResponse) XXX_Unmarshal(b []byte) error { 1354 return xxx_messageInfo_ListTransferRunsResponse.Unmarshal(m, b) 1355} 1356func (m *ListTransferRunsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1357 return xxx_messageInfo_ListTransferRunsResponse.Marshal(b, m, deterministic) 1358} 1359func (m *ListTransferRunsResponse) XXX_Merge(src proto.Message) { 1360 xxx_messageInfo_ListTransferRunsResponse.Merge(m, src) 1361} 1362func (m *ListTransferRunsResponse) XXX_Size() int { 1363 return xxx_messageInfo_ListTransferRunsResponse.Size(m) 1364} 1365func (m *ListTransferRunsResponse) XXX_DiscardUnknown() { 1366 xxx_messageInfo_ListTransferRunsResponse.DiscardUnknown(m) 1367} 1368 1369var xxx_messageInfo_ListTransferRunsResponse proto.InternalMessageInfo 1370 1371func (m *ListTransferRunsResponse) GetTransferRuns() []*TransferRun { 1372 if m != nil { 1373 return m.TransferRuns 1374 } 1375 return nil 1376} 1377 1378func (m *ListTransferRunsResponse) GetNextPageToken() string { 1379 if m != nil { 1380 return m.NextPageToken 1381 } 1382 return "" 1383} 1384 1385// A request to get user facing log messages associated with data transfer run. 1386type ListTransferLogsRequest struct { 1387 // Required. Transfer run name in the form: 1388 // `projects/{project_id}/transferConfigs/{config_id}/runs/{run_id}` or 1389 // `projects/{project_id}/locations/{location_id}/transferConfigs/{config_id}/runs/{run_id}` 1390 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` 1391 // Pagination token, which can be used to request a specific page 1392 // of `ListTransferLogsRequest` list results. For multiple-page 1393 // results, `ListTransferLogsResponse` outputs 1394 // a `next_page` token, which can be used as the 1395 // `page_token` value to request the next page of list results. 1396 PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` 1397 // Page size. The default page size is the maximum value of 1000 results. 1398 PageSize int32 `protobuf:"varint,5,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` 1399 // Message types to return. If not populated - INFO, WARNING and ERROR 1400 // messages are returned. 1401 MessageTypes []TransferMessage_MessageSeverity `protobuf:"varint,6,rep,packed,name=message_types,json=messageTypes,proto3,enum=google.cloud.bigquery.datatransfer.v1.TransferMessage_MessageSeverity" json:"message_types,omitempty"` 1402 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1403 XXX_unrecognized []byte `json:"-"` 1404 XXX_sizecache int32 `json:"-"` 1405} 1406 1407func (m *ListTransferLogsRequest) Reset() { *m = ListTransferLogsRequest{} } 1408func (m *ListTransferLogsRequest) String() string { return proto.CompactTextString(m) } 1409func (*ListTransferLogsRequest) ProtoMessage() {} 1410func (*ListTransferLogsRequest) Descriptor() ([]byte, []int) { 1411 return fileDescriptor_8edec8f64c27b8a4, []int{15} 1412} 1413 1414func (m *ListTransferLogsRequest) XXX_Unmarshal(b []byte) error { 1415 return xxx_messageInfo_ListTransferLogsRequest.Unmarshal(m, b) 1416} 1417func (m *ListTransferLogsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1418 return xxx_messageInfo_ListTransferLogsRequest.Marshal(b, m, deterministic) 1419} 1420func (m *ListTransferLogsRequest) XXX_Merge(src proto.Message) { 1421 xxx_messageInfo_ListTransferLogsRequest.Merge(m, src) 1422} 1423func (m *ListTransferLogsRequest) XXX_Size() int { 1424 return xxx_messageInfo_ListTransferLogsRequest.Size(m) 1425} 1426func (m *ListTransferLogsRequest) XXX_DiscardUnknown() { 1427 xxx_messageInfo_ListTransferLogsRequest.DiscardUnknown(m) 1428} 1429 1430var xxx_messageInfo_ListTransferLogsRequest proto.InternalMessageInfo 1431 1432func (m *ListTransferLogsRequest) GetParent() string { 1433 if m != nil { 1434 return m.Parent 1435 } 1436 return "" 1437} 1438 1439func (m *ListTransferLogsRequest) GetPageToken() string { 1440 if m != nil { 1441 return m.PageToken 1442 } 1443 return "" 1444} 1445 1446func (m *ListTransferLogsRequest) GetPageSize() int32 { 1447 if m != nil { 1448 return m.PageSize 1449 } 1450 return 0 1451} 1452 1453func (m *ListTransferLogsRequest) GetMessageTypes() []TransferMessage_MessageSeverity { 1454 if m != nil { 1455 return m.MessageTypes 1456 } 1457 return nil 1458} 1459 1460// The returned list transfer run messages. 1461type ListTransferLogsResponse struct { 1462 // Output only. The stored pipeline transfer messages. 1463 TransferMessages []*TransferMessage `protobuf:"bytes,1,rep,name=transfer_messages,json=transferMessages,proto3" json:"transfer_messages,omitempty"` 1464 // Output only. The next-pagination token. For multiple-page list results, 1465 // this token can be used as the 1466 // `GetTransferRunLogRequest.page_token` 1467 // to request the next page of list results. 1468 NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` 1469 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1470 XXX_unrecognized []byte `json:"-"` 1471 XXX_sizecache int32 `json:"-"` 1472} 1473 1474func (m *ListTransferLogsResponse) Reset() { *m = ListTransferLogsResponse{} } 1475func (m *ListTransferLogsResponse) String() string { return proto.CompactTextString(m) } 1476func (*ListTransferLogsResponse) ProtoMessage() {} 1477func (*ListTransferLogsResponse) Descriptor() ([]byte, []int) { 1478 return fileDescriptor_8edec8f64c27b8a4, []int{16} 1479} 1480 1481func (m *ListTransferLogsResponse) XXX_Unmarshal(b []byte) error { 1482 return xxx_messageInfo_ListTransferLogsResponse.Unmarshal(m, b) 1483} 1484func (m *ListTransferLogsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1485 return xxx_messageInfo_ListTransferLogsResponse.Marshal(b, m, deterministic) 1486} 1487func (m *ListTransferLogsResponse) XXX_Merge(src proto.Message) { 1488 xxx_messageInfo_ListTransferLogsResponse.Merge(m, src) 1489} 1490func (m *ListTransferLogsResponse) XXX_Size() int { 1491 return xxx_messageInfo_ListTransferLogsResponse.Size(m) 1492} 1493func (m *ListTransferLogsResponse) XXX_DiscardUnknown() { 1494 xxx_messageInfo_ListTransferLogsResponse.DiscardUnknown(m) 1495} 1496 1497var xxx_messageInfo_ListTransferLogsResponse proto.InternalMessageInfo 1498 1499func (m *ListTransferLogsResponse) GetTransferMessages() []*TransferMessage { 1500 if m != nil { 1501 return m.TransferMessages 1502 } 1503 return nil 1504} 1505 1506func (m *ListTransferLogsResponse) GetNextPageToken() string { 1507 if m != nil { 1508 return m.NextPageToken 1509 } 1510 return "" 1511} 1512 1513// A request to determine whether the user has valid credentials. This method 1514// is used to limit the number of OAuth popups in the user interface. The 1515// user id is inferred from the API call context. 1516// If the data source has the Google+ authorization type, this method 1517// returns false, as it cannot be determined whether the credentials are 1518// already valid merely based on the user id. 1519type CheckValidCredsRequest struct { 1520 // Required. The data source in the form: 1521 // `projects/{project_id}/dataSources/{data_source_id}` or 1522 // `projects/{project_id}/locations/{location_id}/dataSources/{data_source_id}`. 1523 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 1524 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1525 XXX_unrecognized []byte `json:"-"` 1526 XXX_sizecache int32 `json:"-"` 1527} 1528 1529func (m *CheckValidCredsRequest) Reset() { *m = CheckValidCredsRequest{} } 1530func (m *CheckValidCredsRequest) String() string { return proto.CompactTextString(m) } 1531func (*CheckValidCredsRequest) ProtoMessage() {} 1532func (*CheckValidCredsRequest) Descriptor() ([]byte, []int) { 1533 return fileDescriptor_8edec8f64c27b8a4, []int{17} 1534} 1535 1536func (m *CheckValidCredsRequest) XXX_Unmarshal(b []byte) error { 1537 return xxx_messageInfo_CheckValidCredsRequest.Unmarshal(m, b) 1538} 1539func (m *CheckValidCredsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1540 return xxx_messageInfo_CheckValidCredsRequest.Marshal(b, m, deterministic) 1541} 1542func (m *CheckValidCredsRequest) XXX_Merge(src proto.Message) { 1543 xxx_messageInfo_CheckValidCredsRequest.Merge(m, src) 1544} 1545func (m *CheckValidCredsRequest) XXX_Size() int { 1546 return xxx_messageInfo_CheckValidCredsRequest.Size(m) 1547} 1548func (m *CheckValidCredsRequest) XXX_DiscardUnknown() { 1549 xxx_messageInfo_CheckValidCredsRequest.DiscardUnknown(m) 1550} 1551 1552var xxx_messageInfo_CheckValidCredsRequest proto.InternalMessageInfo 1553 1554func (m *CheckValidCredsRequest) GetName() string { 1555 if m != nil { 1556 return m.Name 1557 } 1558 return "" 1559} 1560 1561// A response indicating whether the credentials exist and are valid. 1562type CheckValidCredsResponse struct { 1563 // If set to `true`, the credentials exist and are valid. 1564 HasValidCreds bool `protobuf:"varint,1,opt,name=has_valid_creds,json=hasValidCreds,proto3" json:"has_valid_creds,omitempty"` 1565 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1566 XXX_unrecognized []byte `json:"-"` 1567 XXX_sizecache int32 `json:"-"` 1568} 1569 1570func (m *CheckValidCredsResponse) Reset() { *m = CheckValidCredsResponse{} } 1571func (m *CheckValidCredsResponse) String() string { return proto.CompactTextString(m) } 1572func (*CheckValidCredsResponse) ProtoMessage() {} 1573func (*CheckValidCredsResponse) Descriptor() ([]byte, []int) { 1574 return fileDescriptor_8edec8f64c27b8a4, []int{18} 1575} 1576 1577func (m *CheckValidCredsResponse) XXX_Unmarshal(b []byte) error { 1578 return xxx_messageInfo_CheckValidCredsResponse.Unmarshal(m, b) 1579} 1580func (m *CheckValidCredsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1581 return xxx_messageInfo_CheckValidCredsResponse.Marshal(b, m, deterministic) 1582} 1583func (m *CheckValidCredsResponse) XXX_Merge(src proto.Message) { 1584 xxx_messageInfo_CheckValidCredsResponse.Merge(m, src) 1585} 1586func (m *CheckValidCredsResponse) XXX_Size() int { 1587 return xxx_messageInfo_CheckValidCredsResponse.Size(m) 1588} 1589func (m *CheckValidCredsResponse) XXX_DiscardUnknown() { 1590 xxx_messageInfo_CheckValidCredsResponse.DiscardUnknown(m) 1591} 1592 1593var xxx_messageInfo_CheckValidCredsResponse proto.InternalMessageInfo 1594 1595func (m *CheckValidCredsResponse) GetHasValidCreds() bool { 1596 if m != nil { 1597 return m.HasValidCreds 1598 } 1599 return false 1600} 1601 1602// A request to schedule transfer runs for a time range. 1603type ScheduleTransferRunsRequest struct { 1604 // Required. Transfer configuration name in the form: 1605 // `projects/{project_id}/transferConfigs/{config_id}` or 1606 // `projects/{project_id}/locations/{location_id}/transferConfigs/{config_id}`. 1607 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` 1608 // Required. Start time of the range of transfer runs. For example, 1609 // `"2017-05-25T00:00:00+00:00"`. 1610 StartTime *timestamp.Timestamp `protobuf:"bytes,2,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"` 1611 // Required. End time of the range of transfer runs. For example, 1612 // `"2017-05-30T00:00:00+00:00"`. 1613 EndTime *timestamp.Timestamp `protobuf:"bytes,3,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"` 1614 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1615 XXX_unrecognized []byte `json:"-"` 1616 XXX_sizecache int32 `json:"-"` 1617} 1618 1619func (m *ScheduleTransferRunsRequest) Reset() { *m = ScheduleTransferRunsRequest{} } 1620func (m *ScheduleTransferRunsRequest) String() string { return proto.CompactTextString(m) } 1621func (*ScheduleTransferRunsRequest) ProtoMessage() {} 1622func (*ScheduleTransferRunsRequest) Descriptor() ([]byte, []int) { 1623 return fileDescriptor_8edec8f64c27b8a4, []int{19} 1624} 1625 1626func (m *ScheduleTransferRunsRequest) XXX_Unmarshal(b []byte) error { 1627 return xxx_messageInfo_ScheduleTransferRunsRequest.Unmarshal(m, b) 1628} 1629func (m *ScheduleTransferRunsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1630 return xxx_messageInfo_ScheduleTransferRunsRequest.Marshal(b, m, deterministic) 1631} 1632func (m *ScheduleTransferRunsRequest) XXX_Merge(src proto.Message) { 1633 xxx_messageInfo_ScheduleTransferRunsRequest.Merge(m, src) 1634} 1635func (m *ScheduleTransferRunsRequest) XXX_Size() int { 1636 return xxx_messageInfo_ScheduleTransferRunsRequest.Size(m) 1637} 1638func (m *ScheduleTransferRunsRequest) XXX_DiscardUnknown() { 1639 xxx_messageInfo_ScheduleTransferRunsRequest.DiscardUnknown(m) 1640} 1641 1642var xxx_messageInfo_ScheduleTransferRunsRequest proto.InternalMessageInfo 1643 1644func (m *ScheduleTransferRunsRequest) GetParent() string { 1645 if m != nil { 1646 return m.Parent 1647 } 1648 return "" 1649} 1650 1651func (m *ScheduleTransferRunsRequest) GetStartTime() *timestamp.Timestamp { 1652 if m != nil { 1653 return m.StartTime 1654 } 1655 return nil 1656} 1657 1658func (m *ScheduleTransferRunsRequest) GetEndTime() *timestamp.Timestamp { 1659 if m != nil { 1660 return m.EndTime 1661 } 1662 return nil 1663} 1664 1665// A response to schedule transfer runs for a time range. 1666type ScheduleTransferRunsResponse struct { 1667 // The transfer runs that were scheduled. 1668 Runs []*TransferRun `protobuf:"bytes,1,rep,name=runs,proto3" json:"runs,omitempty"` 1669 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1670 XXX_unrecognized []byte `json:"-"` 1671 XXX_sizecache int32 `json:"-"` 1672} 1673 1674func (m *ScheduleTransferRunsResponse) Reset() { *m = ScheduleTransferRunsResponse{} } 1675func (m *ScheduleTransferRunsResponse) String() string { return proto.CompactTextString(m) } 1676func (*ScheduleTransferRunsResponse) ProtoMessage() {} 1677func (*ScheduleTransferRunsResponse) Descriptor() ([]byte, []int) { 1678 return fileDescriptor_8edec8f64c27b8a4, []int{20} 1679} 1680 1681func (m *ScheduleTransferRunsResponse) XXX_Unmarshal(b []byte) error { 1682 return xxx_messageInfo_ScheduleTransferRunsResponse.Unmarshal(m, b) 1683} 1684func (m *ScheduleTransferRunsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1685 return xxx_messageInfo_ScheduleTransferRunsResponse.Marshal(b, m, deterministic) 1686} 1687func (m *ScheduleTransferRunsResponse) XXX_Merge(src proto.Message) { 1688 xxx_messageInfo_ScheduleTransferRunsResponse.Merge(m, src) 1689} 1690func (m *ScheduleTransferRunsResponse) XXX_Size() int { 1691 return xxx_messageInfo_ScheduleTransferRunsResponse.Size(m) 1692} 1693func (m *ScheduleTransferRunsResponse) XXX_DiscardUnknown() { 1694 xxx_messageInfo_ScheduleTransferRunsResponse.DiscardUnknown(m) 1695} 1696 1697var xxx_messageInfo_ScheduleTransferRunsResponse proto.InternalMessageInfo 1698 1699func (m *ScheduleTransferRunsResponse) GetRuns() []*TransferRun { 1700 if m != nil { 1701 return m.Runs 1702 } 1703 return nil 1704} 1705 1706// A request to start manual transfer runs. 1707type StartManualTransferRunsRequest struct { 1708 // Transfer configuration name in the form: 1709 // `projects/{project_id}/transferConfigs/{config_id}` or 1710 // `projects/{project_id}/locations/{location_id}/transferConfigs/{config_id}`. 1711 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` 1712 // The requested time specification - this can be a time range or a specific 1713 // run_time. 1714 // 1715 // Types that are valid to be assigned to Time: 1716 // *StartManualTransferRunsRequest_RequestedTimeRange 1717 // *StartManualTransferRunsRequest_RequestedRunTime 1718 Time isStartManualTransferRunsRequest_Time `protobuf_oneof:"time"` 1719 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1720 XXX_unrecognized []byte `json:"-"` 1721 XXX_sizecache int32 `json:"-"` 1722} 1723 1724func (m *StartManualTransferRunsRequest) Reset() { *m = StartManualTransferRunsRequest{} } 1725func (m *StartManualTransferRunsRequest) String() string { return proto.CompactTextString(m) } 1726func (*StartManualTransferRunsRequest) ProtoMessage() {} 1727func (*StartManualTransferRunsRequest) Descriptor() ([]byte, []int) { 1728 return fileDescriptor_8edec8f64c27b8a4, []int{21} 1729} 1730 1731func (m *StartManualTransferRunsRequest) XXX_Unmarshal(b []byte) error { 1732 return xxx_messageInfo_StartManualTransferRunsRequest.Unmarshal(m, b) 1733} 1734func (m *StartManualTransferRunsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1735 return xxx_messageInfo_StartManualTransferRunsRequest.Marshal(b, m, deterministic) 1736} 1737func (m *StartManualTransferRunsRequest) XXX_Merge(src proto.Message) { 1738 xxx_messageInfo_StartManualTransferRunsRequest.Merge(m, src) 1739} 1740func (m *StartManualTransferRunsRequest) XXX_Size() int { 1741 return xxx_messageInfo_StartManualTransferRunsRequest.Size(m) 1742} 1743func (m *StartManualTransferRunsRequest) XXX_DiscardUnknown() { 1744 xxx_messageInfo_StartManualTransferRunsRequest.DiscardUnknown(m) 1745} 1746 1747var xxx_messageInfo_StartManualTransferRunsRequest proto.InternalMessageInfo 1748 1749func (m *StartManualTransferRunsRequest) GetParent() string { 1750 if m != nil { 1751 return m.Parent 1752 } 1753 return "" 1754} 1755 1756type isStartManualTransferRunsRequest_Time interface { 1757 isStartManualTransferRunsRequest_Time() 1758} 1759 1760type StartManualTransferRunsRequest_RequestedTimeRange struct { 1761 RequestedTimeRange *StartManualTransferRunsRequest_TimeRange `protobuf:"bytes,3,opt,name=requested_time_range,json=requestedTimeRange,proto3,oneof"` 1762} 1763 1764type StartManualTransferRunsRequest_RequestedRunTime struct { 1765 RequestedRunTime *timestamp.Timestamp `protobuf:"bytes,4,opt,name=requested_run_time,json=requestedRunTime,proto3,oneof"` 1766} 1767 1768func (*StartManualTransferRunsRequest_RequestedTimeRange) isStartManualTransferRunsRequest_Time() {} 1769 1770func (*StartManualTransferRunsRequest_RequestedRunTime) isStartManualTransferRunsRequest_Time() {} 1771 1772func (m *StartManualTransferRunsRequest) GetTime() isStartManualTransferRunsRequest_Time { 1773 if m != nil { 1774 return m.Time 1775 } 1776 return nil 1777} 1778 1779func (m *StartManualTransferRunsRequest) GetRequestedTimeRange() *StartManualTransferRunsRequest_TimeRange { 1780 if x, ok := m.GetTime().(*StartManualTransferRunsRequest_RequestedTimeRange); ok { 1781 return x.RequestedTimeRange 1782 } 1783 return nil 1784} 1785 1786func (m *StartManualTransferRunsRequest) GetRequestedRunTime() *timestamp.Timestamp { 1787 if x, ok := m.GetTime().(*StartManualTransferRunsRequest_RequestedRunTime); ok { 1788 return x.RequestedRunTime 1789 } 1790 return nil 1791} 1792 1793// XXX_OneofWrappers is for the internal use of the proto package. 1794func (*StartManualTransferRunsRequest) XXX_OneofWrappers() []interface{} { 1795 return []interface{}{ 1796 (*StartManualTransferRunsRequest_RequestedTimeRange)(nil), 1797 (*StartManualTransferRunsRequest_RequestedRunTime)(nil), 1798 } 1799} 1800 1801// A specification for a time range, this will request transfer runs with 1802// run_time between start_time (inclusive) and end_time (exclusive). 1803type StartManualTransferRunsRequest_TimeRange struct { 1804 // Start time of the range of transfer runs. For example, 1805 // `"2017-05-25T00:00:00+00:00"`. The start_time must be strictly less than 1806 // the end_time. Creates transfer runs where run_time is in the range betwen 1807 // start_time (inclusive) and end_time (exlusive). 1808 StartTime *timestamp.Timestamp `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"` 1809 // End time of the range of transfer runs. For example, 1810 // `"2017-05-30T00:00:00+00:00"`. The end_time must not be in the future. 1811 // Creates transfer runs where run_time is in the range betwen start_time 1812 // (inclusive) and end_time (exlusive). 1813 EndTime *timestamp.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"` 1814 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1815 XXX_unrecognized []byte `json:"-"` 1816 XXX_sizecache int32 `json:"-"` 1817} 1818 1819func (m *StartManualTransferRunsRequest_TimeRange) Reset() { 1820 *m = StartManualTransferRunsRequest_TimeRange{} 1821} 1822func (m *StartManualTransferRunsRequest_TimeRange) String() string { return proto.CompactTextString(m) } 1823func (*StartManualTransferRunsRequest_TimeRange) ProtoMessage() {} 1824func (*StartManualTransferRunsRequest_TimeRange) Descriptor() ([]byte, []int) { 1825 return fileDescriptor_8edec8f64c27b8a4, []int{21, 0} 1826} 1827 1828func (m *StartManualTransferRunsRequest_TimeRange) XXX_Unmarshal(b []byte) error { 1829 return xxx_messageInfo_StartManualTransferRunsRequest_TimeRange.Unmarshal(m, b) 1830} 1831func (m *StartManualTransferRunsRequest_TimeRange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1832 return xxx_messageInfo_StartManualTransferRunsRequest_TimeRange.Marshal(b, m, deterministic) 1833} 1834func (m *StartManualTransferRunsRequest_TimeRange) XXX_Merge(src proto.Message) { 1835 xxx_messageInfo_StartManualTransferRunsRequest_TimeRange.Merge(m, src) 1836} 1837func (m *StartManualTransferRunsRequest_TimeRange) XXX_Size() int { 1838 return xxx_messageInfo_StartManualTransferRunsRequest_TimeRange.Size(m) 1839} 1840func (m *StartManualTransferRunsRequest_TimeRange) XXX_DiscardUnknown() { 1841 xxx_messageInfo_StartManualTransferRunsRequest_TimeRange.DiscardUnknown(m) 1842} 1843 1844var xxx_messageInfo_StartManualTransferRunsRequest_TimeRange proto.InternalMessageInfo 1845 1846func (m *StartManualTransferRunsRequest_TimeRange) GetStartTime() *timestamp.Timestamp { 1847 if m != nil { 1848 return m.StartTime 1849 } 1850 return nil 1851} 1852 1853func (m *StartManualTransferRunsRequest_TimeRange) GetEndTime() *timestamp.Timestamp { 1854 if m != nil { 1855 return m.EndTime 1856 } 1857 return nil 1858} 1859 1860// A response to start manual transfer runs. 1861type StartManualTransferRunsResponse struct { 1862 // The transfer runs that were created. 1863 Runs []*TransferRun `protobuf:"bytes,1,rep,name=runs,proto3" json:"runs,omitempty"` 1864 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1865 XXX_unrecognized []byte `json:"-"` 1866 XXX_sizecache int32 `json:"-"` 1867} 1868 1869func (m *StartManualTransferRunsResponse) Reset() { *m = StartManualTransferRunsResponse{} } 1870func (m *StartManualTransferRunsResponse) String() string { return proto.CompactTextString(m) } 1871func (*StartManualTransferRunsResponse) ProtoMessage() {} 1872func (*StartManualTransferRunsResponse) Descriptor() ([]byte, []int) { 1873 return fileDescriptor_8edec8f64c27b8a4, []int{22} 1874} 1875 1876func (m *StartManualTransferRunsResponse) XXX_Unmarshal(b []byte) error { 1877 return xxx_messageInfo_StartManualTransferRunsResponse.Unmarshal(m, b) 1878} 1879func (m *StartManualTransferRunsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1880 return xxx_messageInfo_StartManualTransferRunsResponse.Marshal(b, m, deterministic) 1881} 1882func (m *StartManualTransferRunsResponse) XXX_Merge(src proto.Message) { 1883 xxx_messageInfo_StartManualTransferRunsResponse.Merge(m, src) 1884} 1885func (m *StartManualTransferRunsResponse) XXX_Size() int { 1886 return xxx_messageInfo_StartManualTransferRunsResponse.Size(m) 1887} 1888func (m *StartManualTransferRunsResponse) XXX_DiscardUnknown() { 1889 xxx_messageInfo_StartManualTransferRunsResponse.DiscardUnknown(m) 1890} 1891 1892var xxx_messageInfo_StartManualTransferRunsResponse proto.InternalMessageInfo 1893 1894func (m *StartManualTransferRunsResponse) GetRuns() []*TransferRun { 1895 if m != nil { 1896 return m.Runs 1897 } 1898 return nil 1899} 1900 1901func init() { 1902 proto.RegisterEnum("google.cloud.bigquery.datatransfer.v1.DataSourceParameter_Type", DataSourceParameter_Type_name, DataSourceParameter_Type_value) 1903 proto.RegisterEnum("google.cloud.bigquery.datatransfer.v1.DataSource_AuthorizationType", DataSource_AuthorizationType_name, DataSource_AuthorizationType_value) 1904 proto.RegisterEnum("google.cloud.bigquery.datatransfer.v1.DataSource_DataRefreshType", DataSource_DataRefreshType_name, DataSource_DataRefreshType_value) 1905 proto.RegisterEnum("google.cloud.bigquery.datatransfer.v1.ListTransferRunsRequest_RunAttempt", ListTransferRunsRequest_RunAttempt_name, ListTransferRunsRequest_RunAttempt_value) 1906 proto.RegisterType((*DataSourceParameter)(nil), "google.cloud.bigquery.datatransfer.v1.DataSourceParameter") 1907 proto.RegisterType((*DataSource)(nil), "google.cloud.bigquery.datatransfer.v1.DataSource") 1908 proto.RegisterType((*GetDataSourceRequest)(nil), "google.cloud.bigquery.datatransfer.v1.GetDataSourceRequest") 1909 proto.RegisterType((*ListDataSourcesRequest)(nil), "google.cloud.bigquery.datatransfer.v1.ListDataSourcesRequest") 1910 proto.RegisterType((*ListDataSourcesResponse)(nil), "google.cloud.bigquery.datatransfer.v1.ListDataSourcesResponse") 1911 proto.RegisterType((*CreateTransferConfigRequest)(nil), "google.cloud.bigquery.datatransfer.v1.CreateTransferConfigRequest") 1912 proto.RegisterType((*UpdateTransferConfigRequest)(nil), "google.cloud.bigquery.datatransfer.v1.UpdateTransferConfigRequest") 1913 proto.RegisterType((*GetTransferConfigRequest)(nil), "google.cloud.bigquery.datatransfer.v1.GetTransferConfigRequest") 1914 proto.RegisterType((*DeleteTransferConfigRequest)(nil), "google.cloud.bigquery.datatransfer.v1.DeleteTransferConfigRequest") 1915 proto.RegisterType((*GetTransferRunRequest)(nil), "google.cloud.bigquery.datatransfer.v1.GetTransferRunRequest") 1916 proto.RegisterType((*DeleteTransferRunRequest)(nil), "google.cloud.bigquery.datatransfer.v1.DeleteTransferRunRequest") 1917 proto.RegisterType((*ListTransferConfigsRequest)(nil), "google.cloud.bigquery.datatransfer.v1.ListTransferConfigsRequest") 1918 proto.RegisterType((*ListTransferConfigsResponse)(nil), "google.cloud.bigquery.datatransfer.v1.ListTransferConfigsResponse") 1919 proto.RegisterType((*ListTransferRunsRequest)(nil), "google.cloud.bigquery.datatransfer.v1.ListTransferRunsRequest") 1920 proto.RegisterType((*ListTransferRunsResponse)(nil), "google.cloud.bigquery.datatransfer.v1.ListTransferRunsResponse") 1921 proto.RegisterType((*ListTransferLogsRequest)(nil), "google.cloud.bigquery.datatransfer.v1.ListTransferLogsRequest") 1922 proto.RegisterType((*ListTransferLogsResponse)(nil), "google.cloud.bigquery.datatransfer.v1.ListTransferLogsResponse") 1923 proto.RegisterType((*CheckValidCredsRequest)(nil), "google.cloud.bigquery.datatransfer.v1.CheckValidCredsRequest") 1924 proto.RegisterType((*CheckValidCredsResponse)(nil), "google.cloud.bigquery.datatransfer.v1.CheckValidCredsResponse") 1925 proto.RegisterType((*ScheduleTransferRunsRequest)(nil), "google.cloud.bigquery.datatransfer.v1.ScheduleTransferRunsRequest") 1926 proto.RegisterType((*ScheduleTransferRunsResponse)(nil), "google.cloud.bigquery.datatransfer.v1.ScheduleTransferRunsResponse") 1927 proto.RegisterType((*StartManualTransferRunsRequest)(nil), "google.cloud.bigquery.datatransfer.v1.StartManualTransferRunsRequest") 1928 proto.RegisterType((*StartManualTransferRunsRequest_TimeRange)(nil), "google.cloud.bigquery.datatransfer.v1.StartManualTransferRunsRequest.TimeRange") 1929 proto.RegisterType((*StartManualTransferRunsResponse)(nil), "google.cloud.bigquery.datatransfer.v1.StartManualTransferRunsResponse") 1930} 1931 1932func init() { 1933 proto.RegisterFile("google/cloud/bigquery/datatransfer/v1/datatransfer.proto", fileDescriptor_8edec8f64c27b8a4) 1934} 1935 1936var fileDescriptor_8edec8f64c27b8a4 = []byte{ 1937 // 2850 bytes of a gzipped FileDescriptorProto 1938 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xc4, 0x5a, 0xcd, 0x6f, 0x1b, 0xc7, 1939 0x15, 0xcf, 0x52, 0xb2, 0x3e, 0x1e, 0xf5, 0x41, 0x4d, 0x64, 0x69, 0x4d, 0x39, 0x8e, 0xb2, 0xa9, 1940 0x13, 0x59, 0x75, 0xc8, 0x58, 0x8e, 0x9d, 0x44, 0x69, 0xec, 0x52, 0x24, 0x25, 0x33, 0x90, 0x45, 1941 0x65, 0x49, 0xd9, 0xad, 0x60, 0x60, 0xbb, 0xe2, 0x8e, 0xa8, 0x8d, 0x97, 0xbb, 0x9b, 0x9d, 0x5d, 1942 0xc9, 0x8a, 0xe1, 0x1e, 0xd2, 0x1e, 0x8a, 0xa6, 0x45, 0xd1, 0xf6, 0x1a, 0x14, 0x68, 0xd0, 0x5c, 1943 0xda, 0x53, 0x7a, 0xe8, 0xa9, 0xb7, 0x1e, 0x1a, 0x04, 0xe8, 0xa5, 0xed, 0xc9, 0xbd, 0xa4, 0x68, 1944 0x51, 0xa0, 0x05, 0xfa, 0x07, 0x34, 0x97, 0x16, 0x33, 0x3b, 0x4b, 0xee, 0x92, 0x94, 0xb4, 0xa4, 1945 0x1c, 0xf4, 0x64, 0xee, 0x7b, 0xf3, 0xde, 0x9b, 0xf7, 0x7b, 0x1f, 0xf3, 0x66, 0x2c, 0x78, 0xad, 1946 0x6e, 0x59, 0x75, 0x03, 0x67, 0x6b, 0x86, 0xe5, 0x69, 0xd9, 0x1d, 0xbd, 0xfe, 0xae, 0x87, 0x9d, 1947 0xc3, 0xac, 0xa6, 0xba, 0xaa, 0xeb, 0xa8, 0x26, 0xd9, 0xc5, 0x4e, 0x76, 0xff, 0x4a, 0xe4, 0x3b, 1948 0x63, 0x3b, 0x96, 0x6b, 0xa1, 0x8b, 0xbe, 0x64, 0x86, 0x49, 0x66, 0x02, 0xc9, 0x4c, 0x64, 0xe5, 1949 0xfe, 0x95, 0xf4, 0x79, 0x6e, 0x40, 0xb5, 0xf5, 0xac, 0x6a, 0x9a, 0x96, 0xab, 0xba, 0xba, 0x65, 1950 0x12, 0x5f, 0x49, 0x7a, 0x36, 0xc4, 0xad, 0x19, 0x3a, 0x36, 0x5d, 0xce, 0x78, 0x36, 0xc4, 0xd8, 1951 0xd5, 0xb1, 0xa1, 0x29, 0x3b, 0x78, 0x4f, 0xdd, 0xd7, 0x2d, 0x6e, 0x3e, 0x7d, 0x2e, 0xb4, 0xc0, 1952 0xc1, 0xc4, 0xf2, 0x9c, 0x1a, 0xe6, 0xac, 0x57, 0xe2, 0xf9, 0x14, 0xf5, 0x27, 0x7d, 0x81, 0x4b, 1953 0xb1, 0xaf, 0x1d, 0x6f, 0x37, 0xab, 0x79, 0x0e, 0xdb, 0x2b, 0xe7, 0xcf, 0xb5, 0xf3, 0x71, 0xc3, 1954 0x76, 0x0f, 0x39, 0x73, 0xbe, 0x9d, 0xe9, 0xef, 0xb9, 0xa1, 0x92, 0xfb, 0x6d, 0x0e, 0x35, 0x57, 1955 0xb8, 0x7a, 0x03, 0x13, 0x57, 0x6d, 0xd8, 0x47, 0xd9, 0x3f, 0x70, 0x54, 0xdb, 0xc6, 0x0e, 0x87, 1956 0x4a, 0xfa, 0x74, 0x08, 0x9e, 0x2e, 0xa8, 0xae, 0x5a, 0x61, 0xae, 0x6e, 0xaa, 0x8e, 0xda, 0xc0, 1957 0x2e, 0x76, 0xd0, 0x39, 0x18, 0xb1, 0xe9, 0x87, 0xa2, 0x6b, 0xa2, 0x30, 0x2f, 0x2c, 0x8c, 0xca, 1958 0xc3, 0xec, 0xbb, 0xa4, 0xa1, 0xe7, 0x60, 0x4c, 0xd3, 0x89, 0x6d, 0xa8, 0x87, 0x8a, 0xa9, 0x36, 1959 0xb0, 0x98, 0x60, 0xec, 0x24, 0xa7, 0x6d, 0xa8, 0x0d, 0x8c, 0xe6, 0x21, 0xa9, 0x61, 0x52, 0x73, 1960 0x74, 0x9b, 0xba, 0x2a, 0x0e, 0xf0, 0x15, 0x2d, 0x12, 0xaa, 0xc0, 0xa0, 0x7b, 0x68, 0x63, 0x71, 1961 0x70, 0x5e, 0x58, 0x98, 0x58, 0xba, 0x99, 0x89, 0x15, 0xf6, 0x4c, 0x97, 0x9d, 0x66, 0xaa, 0x87, 1962 0x36, 0x96, 0x99, 0x32, 0x94, 0x86, 0x11, 0x07, 0xbf, 0xeb, 0xe9, 0x0e, 0xd6, 0xc4, 0x33, 0xf3, 1963 0xc2, 0xc2, 0x88, 0xdc, 0xfc, 0xf6, 0x79, 0x36, 0x56, 0x5d, 0xac, 0x89, 0x43, 0x01, 0xcf, 0xff, 1964 0x46, 0x97, 0x20, 0xb5, 0xaf, 0x1a, 0xba, 0xc6, 0x02, 0xa3, 0x38, 0xb8, 0x8e, 0x1f, 0x88, 0xc3, 1965 0x6c, 0xcf, 0x93, 0x2d, 0xba, 0x4c, 0xc9, 0xe8, 0x22, 0x4c, 0xa8, 0x86, 0x61, 0x1d, 0x60, 0x4d, 1966 0xd9, 0x57, 0x0d, 0x0f, 0x13, 0x71, 0x64, 0x7e, 0x60, 0x61, 0x54, 0x1e, 0xe7, 0xd4, 0x3b, 0x8c, 1967 0x88, 0x5e, 0x87, 0xd1, 0x86, 0x6e, 0xfa, 0x4b, 0xc4, 0xd1, 0x79, 0x61, 0x21, 0xb9, 0x74, 0x3e, 1968 0xf0, 0x31, 0x08, 0x45, 0xa6, 0x60, 0x79, 0x3b, 0x06, 0x66, 0x12, 0xf2, 0x48, 0x43, 0x37, 0xd9, 1969 0x2f, 0x26, 0xaa, 0x3e, 0xe0, 0xa2, 0x10, 0x4b, 0x54, 0x7d, 0xe0, 0x8b, 0xca, 0x30, 0xc4, 0x32, 1970 0x84, 0x88, 0xc9, 0xf9, 0x81, 0x85, 0xe4, 0xd2, 0x72, 0xff, 0xb0, 0xca, 0x5c, 0x13, 0xba, 0x06, 1971 0x33, 0x21, 0x6c, 0xc2, 0x51, 0x1d, 0x63, 0x08, 0x9d, 0x6d, 0x71, 0x0b, 0xa1, 0xf8, 0x66, 0xe0, 1972 0xe9, 0x90, 0xd8, 0x1e, 0x36, 0x6c, 0xc5, 0x73, 0x0c, 0x71, 0x9c, 0xc9, 0x4c, 0xb5, 0x58, 0xb7, 1973 0xb0, 0x61, 0x6f, 0x39, 0x06, 0x3a, 0x0f, 0xa3, 0x7a, 0xa3, 0xe1, 0xb9, 0xea, 0x8e, 0x81, 0xc5, 1974 0x09, 0x16, 0x9f, 0x16, 0x01, 0x89, 0x30, 0xec, 0xe0, 0x9a, 0xe7, 0x10, 0x2c, 0x4e, 0x32, 0x5e, 1975 0xf0, 0x89, 0x2e, 0x00, 0x68, 0xd8, 0x76, 0x70, 0x8d, 0x05, 0x76, 0x9a, 0x31, 0x43, 0x14, 0x49, 1976 0x87, 0x41, 0x9a, 0x20, 0x68, 0x1a, 0x52, 0xd5, 0x6f, 0x6e, 0x16, 0x95, 0xad, 0x8d, 0xca, 0x66, 1977 0x31, 0x5f, 0x5a, 0x2d, 0x15, 0x0b, 0xa9, 0xa7, 0x10, 0xc0, 0x50, 0xa5, 0x2a, 0x97, 0x36, 0xd6, 1978 0x52, 0x02, 0x4a, 0xc2, 0x70, 0x69, 0xa3, 0x5a, 0x5c, 0x2b, 0xca, 0xa9, 0x04, 0x65, 0x14, 0xca, 1979 0x5b, 0x2b, 0xeb, 0xc5, 0xd4, 0x00, 0x65, 0xac, 0x94, 0xcb, 0xeb, 0xc5, 0xdc, 0x46, 0x6a, 0x90, 1980 0x32, 0xe4, 0x62, 0xbe, 0x2c, 0x17, 0x52, 0x67, 0xd0, 0x38, 0x8c, 0x6e, 0xae, 0x6f, 0x55, 0x94, 1981 0xcd, 0xdc, 0x5a, 0x31, 0x35, 0x24, 0x7d, 0x92, 0x04, 0x68, 0x21, 0x89, 0x66, 0x61, 0x90, 0x95, 1982 0x07, 0xab, 0x9e, 0x95, 0x81, 0xcf, 0x73, 0x03, 0x32, 0x23, 0xa0, 0xaf, 0xc0, 0x04, 0x0d, 0x80, 1983 0xe2, 0x77, 0x17, 0x5a, 0x60, 0x7e, 0x05, 0x8d, 0x69, 0x4d, 0xe1, 0x2e, 0x55, 0x36, 0x70, 0x62, 1984 0x95, 0x0d, 0x76, 0x56, 0xd9, 0x1c, 0x8c, 0xfa, 0xfd, 0x8f, 0x5a, 0x39, 0xc3, 0xf8, 0x23, 0x3e, 1985 0xa1, 0xa4, 0xa1, 0x19, 0x18, 0x22, 0x35, 0xcb, 0xc6, 0x44, 0x1c, 0x62, 0x29, 0xcc, 0xbf, 0xd0, 1986 0x3d, 0x18, 0x0f, 0x92, 0x43, 0x61, 0x35, 0x3a, 0xcc, 0x6a, 0xf4, 0x6a, 0xcc, 0x64, 0xaa, 0xf2, 1987 0xdf, 0x14, 0xf6, 0x95, 0x84, 0x28, 0xc8, 0x63, 0x6e, 0x88, 0x82, 0x56, 0x60, 0x8e, 0x78, 0xb6, 1988 0x6d, 0x39, 0x2e, 0x51, 0x1a, 0x9e, 0xe1, 0xea, 0xb6, 0x81, 0x95, 0x60, 0x05, 0xad, 0x26, 0x61, 1989 0x61, 0x84, 0x89, 0x9d, 0x0b, 0x96, 0xdd, 0xe6, 0xab, 0x02, 0xc5, 0x04, 0x5d, 0x87, 0x59, 0xcf, 1990 0xd6, 0x54, 0x17, 0x2b, 0x1a, 0x56, 0x35, 0x43, 0x37, 0xb1, 0x42, 0x70, 0xcd, 0x32, 0x35, 0xc2, 1991 0x6a, 0xed, 0x8c, 0x7c, 0xd6, 0x67, 0x17, 0x38, 0xb7, 0xe2, 0x33, 0x69, 0x9d, 0x6b, 0x78, 0x57, 1992 0xf5, 0x0c, 0x57, 0x21, 0xb5, 0x3d, 0xac, 0x79, 0x86, 0x5f, 0x61, 0xa3, 0xf2, 0x24, 0xa7, 0x57, 1993 0x38, 0x19, 0xbd, 0x06, 0x62, 0x73, 0x9b, 0x35, 0x8f, 0xb8, 0x56, 0xa3, 0x25, 0x92, 0x64, 0x59, 1994 0x36, 0x13, 0xf0, 0xf3, 0x8c, 0xdd, 0x94, 0xdc, 0x06, 0xb0, 0x83, 0x2a, 0x22, 0xe2, 0xd8, 0xa9, 1995 0x0b, 0x31, 0xa4, 0x8d, 0x76, 0xe5, 0xb6, 0x52, 0x1a, 0xde, 0xe3, 0x05, 0xe4, 0x00, 0x52, 0x3d, 1996 0x77, 0xcf, 0x72, 0xf4, 0xf7, 0xfc, 0x9a, 0x63, 0xa1, 0x9b, 0x60, 0xa1, 0xcb, 0xf7, 0x6c, 0x3e, 1997 0x93, 0x0b, 0xeb, 0x62, 0x2d, 0x76, 0x4a, 0x6d, 0x27, 0xa1, 0x06, 0x4c, 0xb1, 0x4c, 0x76, 0xf0, 1998 0xae, 0x83, 0xc9, 0x9e, 0x6f, 0x72, 0x92, 0x99, 0xcc, 0xf5, 0x6e, 0x92, 0xfe, 0x94, 0x7d, 0x4d, 1999 0xcc, 0xe0, 0xa4, 0x16, 0x25, 0xa0, 0x55, 0x98, 0x0f, 0xc2, 0x17, 0x31, 0x7b, 0xa0, 0x9b, 0x9a, 2000 0x75, 0xa0, 0x68, 0xea, 0x21, 0x11, 0x53, 0x2c, 0xfe, 0xe7, 0xf9, 0xba, 0x90, 0xca, 0xbb, 0x6c, 2001 0x51, 0x41, 0x3d, 0x24, 0xe8, 0x65, 0x98, 0x6e, 0xa8, 0xa6, 0xa7, 0x1a, 0x8a, 0xe3, 0x99, 0x44, 2002 0xd1, 0x74, 0x42, 0x9b, 0x8c, 0x26, 0x4e, 0xb1, 0xb8, 0x22, 0x9f, 0x27, 0x7b, 0x26, 0x29, 0x70, 2003 0x0e, 0xda, 0x82, 0x73, 0x0d, 0xdd, 0xd4, 0x1b, 0x5e, 0x2b, 0x0b, 0x14, 0xdd, 0x74, 0xb1, 0xb3, 2004 0xaf, 0x1a, 0x22, 0x62, 0x3d, 0xfa, 0x5c, 0x67, 0x8f, 0xe6, 0x27, 0xbd, 0x3c, 0xcb, 0x65, 0x83, 2005 0x14, 0x29, 0x71, 0x49, 0x89, 0xc0, 0x54, 0x07, 0xce, 0x48, 0x82, 0x0b, 0xb9, 0xad, 0xea, 0xad, 2006 0xb2, 0x5c, 0xda, 0xce, 0x55, 0x4b, 0xe5, 0x0d, 0xa5, 0x4b, 0xdf, 0x9a, 0x01, 0x14, 0x5d, 0x93, 2007 0x2f, 0x17, 0x8a, 0x29, 0x81, 0xca, 0xae, 0x95, 0xcb, 0x6b, 0xeb, 0x45, 0x85, 0x35, 0xa6, 0x2e, 2008 0x6b, 0x12, 0x52, 0x0d, 0x26, 0xdb, 0x90, 0x46, 0xcf, 0xc1, 0x33, 0x85, 0x5c, 0x35, 0xa7, 0xc8, 2009 0xc5, 0x55, 0xb9, 0x58, 0xb9, 0xd5, 0xcd, 0x22, 0x82, 0x89, 0xca, 0x7a, 0xa9, 0x50, 0xda, 0x58, 2010 0x53, 0xee, 0x96, 0x36, 0x0a, 0xe5, 0xbb, 0x29, 0x01, 0x9d, 0x83, 0xb3, 0xf9, 0xad, 0x4a, 0xb5, 2011 0x7c, 0x5b, 0x69, 0x63, 0x25, 0x96, 0x3f, 0x16, 0xfe, 0x95, 0xfb, 0xb9, 0x00, 0xcd, 0xb8, 0x47, 2012 0xc2, 0xee, 0x03, 0xa5, 0xda, 0x3a, 0xc9, 0xd4, 0xac, 0x46, 0x36, 0xd4, 0x33, 0x2f, 0xdb, 0x8e, 2013 0xf5, 0x0e, 0xae, 0xb9, 0x24, 0xfb, 0x90, 0xff, 0x7a, 0x94, 0x6d, 0x75, 0x45, 0x92, 0x7d, 0x18, 2014 0x6a, 0x9c, 0x8f, 0x50, 0xae, 0xcb, 0x6a, 0xc3, 0xaa, 0xf9, 0xa3, 0x60, 0xf6, 0x61, 0xf0, 0xf3, 2015 0x18, 0x15, 0xd2, 0x0e, 0x4c, 0xaf, 0x61, 0xb7, 0xb5, 0x03, 0x19, 0xbf, 0xeb, 0x61, 0xe2, 0xa2, 2016 0xb7, 0x22, 0xcd, 0xfb, 0xfa, 0xe7, 0xb9, 0xc4, 0x17, 0xb9, 0x97, 0x7b, 0x75, 0xc7, 0xef, 0xf7, 2017 0xd2, 0x2f, 0x04, 0x98, 0x59, 0xd7, 0x49, 0xc8, 0x0a, 0x09, 0xcc, 0x6c, 0xc0, 0x90, 0xad, 0x3a, 2018 0xd8, 0x74, 0xa3, 0x86, 0x50, 0xaf, 0x86, 0xb8, 0x16, 0xf4, 0x0c, 0xed, 0x3d, 0x75, 0xac, 0xb8, 2019 0xd6, 0x7d, 0x1c, 0x8c, 0x5d, 0xa3, 0x94, 0x52, 0xa5, 0x04, 0x7a, 0x1c, 0x30, 0x36, 0xd1, 0xdf, 2020 0xf3, 0x27, 0xaf, 0x33, 0xf2, 0x08, 0x25, 0x54, 0xf4, 0xf7, 0xb0, 0xf4, 0xa1, 0x00, 0xb3, 0x1d, 2021 0xdb, 0x24, 0xb6, 0x65, 0x12, 0x8c, 0xaa, 0x30, 0x16, 0x82, 0x8d, 0x88, 0x02, 0xeb, 0x6a, 0x57, 2022 0x7a, 0xae, 0x71, 0x39, 0x19, 0x0a, 0x05, 0xfa, 0x2a, 0x4c, 0x9a, 0xf8, 0x81, 0xab, 0x84, 0xb6, 2023 0x9c, 0x68, 0x1d, 0x96, 0xe3, 0x94, 0xb7, 0x19, 0xec, 0x5d, 0x7a, 0x9c, 0x80, 0xb9, 0xbc, 0x43, 2024 0xe7, 0xb5, 0xe0, 0x1c, 0xc8, 0x5b, 0xe6, 0xae, 0x5e, 0x0f, 0xa0, 0x94, 0xdb, 0xa0, 0x5c, 0x66, 2025 0x50, 0xbe, 0x82, 0x96, 0xe2, 0x40, 0xd9, 0xa6, 0x32, 0x80, 0xb3, 0x06, 0x93, 0xcd, 0x93, 0xb0, 2026 0xc6, 0x58, 0x6c, 0x83, 0xc9, 0xa5, 0x6b, 0x3d, 0x9e, 0x85, 0xbe, 0x5e, 0xea, 0x57, 0x42, 0x9e, 2027 0x70, 0x23, 0x44, 0xf4, 0x52, 0x7b, 0xe3, 0xae, 0x59, 0x5a, 0x70, 0xdc, 0x47, 0x7b, 0x6e, 0xde, 2028 0xd2, 0x68, 0xad, 0x8e, 0xed, 0x63, 0x87, 0xd0, 0x85, 0xba, 0xb9, 0x6b, 0xf1, 0x53, 0x3d, 0xc9, 2029 0x69, 0x25, 0x73, 0xd7, 0xa2, 0xfd, 0x8d, 0x60, 0x67, 0x5f, 0xaf, 0x61, 0x45, 0xad, 0xd5, 0x2c, 2030 0xcf, 0x74, 0xfd, 0x11, 0x62, 0x88, 0x2d, 0x45, 0x9c, 0x97, 0xf3, 0x59, 0x74, 0x92, 0x90, 0x3e, 2031 0x4d, 0xc0, 0xdc, 0x16, 0x3b, 0x32, 0xbb, 0x83, 0xdb, 0x05, 0x08, 0xe1, 0xff, 0x0d, 0xc4, 0xd7, 2032 0x21, 0xc9, 0x87, 0x00, 0x7a, 0x1f, 0x62, 0xe9, 0x9c, 0x5c, 0x4a, 0x77, 0x74, 0xe1, 0x55, 0x3a, 2033 0xc6, 0xde, 0x56, 0xc9, 0x7d, 0xdf, 0x28, 0xf8, 0x32, 0x94, 0xf0, 0xe5, 0x40, 0xf9, 0x0e, 0x88, 2034 0x6b, 0xd8, 0xed, 0x0e, 0xe3, 0x46, 0xa4, 0xab, 0xf0, 0x0c, 0x85, 0x7e, 0x32, 0xd4, 0xef, 0x2c, 2035 0x0d, 0x98, 0x2b, 0x60, 0x03, 0x1f, 0x15, 0xb5, 0x27, 0x6d, 0xee, 0x1e, 0x9c, 0x0d, 0xb9, 0x26, 2036 0x7b, 0x66, 0x60, 0x28, 0x1f, 0x31, 0x94, 0x65, 0x86, 0x2e, 0xc1, 0x8b, 0x71, 0x0c, 0x51, 0x2d, 2037 0xbe, 0x76, 0x05, 0xc4, 0xa8, 0x33, 0x4f, 0xda, 0xc0, 0x9f, 0x05, 0x48, 0xd3, 0x06, 0x17, 0xf5, 2038 0x8d, 0x7c, 0x99, 0x0d, 0xe4, 0x05, 0x98, 0x8c, 0x8e, 0xfa, 0x44, 0x4c, 0xf8, 0xd7, 0xc5, 0xf0, 2039 0xac, 0x4f, 0x4e, 0xd5, 0xb7, 0x3f, 0x11, 0x60, 0xae, 0xab, 0x5b, 0xbc, 0x77, 0x63, 0x48, 0xb5, 2040 0xd5, 0x6e, 0xd0, 0xbf, 0xfb, 0x2f, 0xde, 0x01, 0x79, 0x32, 0x5a, 0xbc, 0x3d, 0x36, 0xf3, 0x1f, 2041 0x0d, 0xf8, 0x67, 0x4d, 0x28, 0xd4, 0xcd, 0x38, 0xac, 0xb5, 0xc5, 0x81, 0x47, 0x1b, 0xc5, 0x8e, 2042 0x76, 0x00, 0xfe, 0x3a, 0x0c, 0x11, 0x57, 0x75, 0xb1, 0x8f, 0xf9, 0xc4, 0xd2, 0x2b, 0x3d, 0xba, 2043 0x5b, 0xa1, 0xc2, 0x32, 0xd7, 0x71, 0x9a, 0x10, 0xa1, 0x77, 0x20, 0xe9, 0x78, 0xa6, 0xa2, 0xba, 2044 0x2e, 0x6e, 0xd8, 0x2e, 0xeb, 0x33, 0x13, 0x4b, 0xa5, 0x98, 0xdb, 0x39, 0x02, 0xa7, 0x8c, 0xec, 2045 0x99, 0x39, 0x5f, 0xa1, 0x0c, 0x4e, 0xf3, 0xb7, 0x74, 0x0d, 0xa0, 0xc5, 0x41, 0x73, 0x30, 0x2b, 2046 0x6f, 0x6d, 0x28, 0xb9, 0x6a, 0xb5, 0x78, 0x7b, 0xb3, 0xda, 0x79, 0xfb, 0x5d, 0xcf, 0x55, 0x8b, 2047 0x95, 0x6a, 0x4a, 0x90, 0x3e, 0x16, 0x40, 0xec, 0xb4, 0xc4, 0x53, 0x28, 0x7c, 0x23, 0xa4, 0x23, 2048 0x33, 0xcf, 0x9f, 0xa5, 0x1e, 0x01, 0x95, 0x3d, 0xd3, 0xcf, 0x86, 0xe6, 0x8d, 0x90, 0x5a, 0xe9, 2049 0x2d, 0x73, 0x3e, 0x48, 0x44, 0x33, 0x67, 0xdd, 0xaa, 0x9f, 0x94, 0x39, 0xd0, 0x73, 0xe6, 0x44, 2050 0x63, 0x3d, 0x78, 0x6c, 0xac, 0xcf, 0xb4, 0xc5, 0xfa, 0x3e, 0x8c, 0x37, 0x30, 0x21, 0x4c, 0xfc, 2051 0x30, 0xb8, 0x5c, 0x4f, 0x2c, 0xad, 0xf6, 0x88, 0xd5, 0x6d, 0x5f, 0x47, 0x86, 0xff, 0x5b, 0xc1, 2052 0xfb, 0xd8, 0xd1, 0xdd, 0x43, 0x79, 0x8c, 0x2b, 0xa7, 0x73, 0x3b, 0xa1, 0xb5, 0x2f, 0x76, 0xa2, 2053 0xc1, 0xa3, 0xb6, 0x07, 0x53, 0xcd, 0xa8, 0x71, 0xa9, 0x20, 0x72, 0xd7, 0xfb, 0xdb, 0x8d, 0x1f, 2054 0x91, 0x66, 0x3b, 0xe1, 0xd4, 0x1e, 0x23, 0xa8, 0xc1, 0x4c, 0x7e, 0x0f, 0xd7, 0xee, 0xdf, 0x51, 2055 0x0d, 0x5d, 0xcb, 0x3b, 0x58, 0x23, 0x5f, 0xc6, 0xd0, 0x9d, 0x83, 0xd9, 0x0e, 0x2b, 0x1c, 0x97, 2056 0x17, 0x60, 0x72, 0x4f, 0x25, 0x0a, 0x7b, 0x83, 0x52, 0x6a, 0x94, 0xc5, 0x2c, 0x8e, 0xc8, 0xe3, 2057 0x7b, 0x2a, 0x69, 0xad, 0x97, 0xfe, 0x2d, 0xc0, 0x5c, 0x70, 0x65, 0xeb, 0xd6, 0xa8, 0x8e, 0x38, 2058 0x30, 0xe0, 0x34, 0x07, 0xc6, 0x0d, 0x00, 0xe2, 0xaa, 0x8e, 0xab, 0xb8, 0x3a, 0x7f, 0x59, 0xed, 2059 0x36, 0xd3, 0x54, 0x83, 0x47, 0x5e, 0x7f, 0xa6, 0x19, 0x65, 0x22, 0x94, 0x88, 0x96, 0x61, 0x04, 2060 0x9b, 0x9a, 0x2f, 0x3d, 0x10, 0x4f, 0x7a, 0x18, 0x9b, 0x1a, 0x25, 0x49, 0xbb, 0x70, 0xbe, 0xbb, 2061 0xbb, 0x1c, 0xb7, 0x55, 0x18, 0x3c, 0x5d, 0xf1, 0xcb, 0x4c, 0x5e, 0xfa, 0x6c, 0x00, 0x2e, 0x54, 2062 0xe8, 0x8e, 0x6f, 0xb3, 0x8b, 0x76, 0x37, 0x68, 0xcb, 0x6d, 0xd0, 0xbe, 0x7a, 0x5a, 0x5c, 0xbf, 2063 0x23, 0xc0, 0xb4, 0xe3, 0x2b, 0xc7, 0x3e, 0x3c, 0x8a, 0xa3, 0x9a, 0xf5, 0x00, 0xa4, 0x72, 0x4c, 2064 0x67, 0x8e, 0xdf, 0x36, 0x43, 0x56, 0xa6, 0x6a, 0x6f, 0x3d, 0x25, 0xa3, 0xa6, 0xb9, 0x26, 0x15, 2065 0xbd, 0x05, 0x2d, 0x2a, 0x6d, 0xa4, 0x7e, 0x9c, 0x06, 0x4f, 0x8a, 0xd3, 0xad, 0xa7, 0xe4, 0x54, 2066 0x53, 0x4e, 0xf6, 0x4c, 0xca, 0x48, 0x3f, 0x82, 0xd1, 0x96, 0xe2, 0xd7, 0x23, 0x69, 0x23, 0x9c, 2067 0xa4, 0x30, 0x9c, 0x31, 0xd7, 0x42, 0x19, 0x73, 0x62, 0xbe, 0x35, 0x93, 0x65, 0x65, 0x08, 0x06, 2068 0xa9, 0x88, 0xa4, 0xc3, 0xb3, 0x47, 0x82, 0xf2, 0x64, 0xf3, 0x66, 0xe9, 0x77, 0xcf, 0xfa, 0xff, 2069 0x55, 0xd1, 0x3c, 0x9f, 0xfd, 0xe1, 0x1b, 0xfd, 0x43, 0x80, 0xf1, 0xc8, 0x25, 0x1e, 0xbd, 0x11, 2070 0xd3, 0x46, 0xb7, 0xab, 0x7f, 0xba, 0xf7, 0x5b, 0xad, 0x84, 0x1f, 0xe7, 0x58, 0xd7, 0x79, 0xff, 2071 0x4f, 0x7f, 0xff, 0x69, 0xe2, 0x1b, 0x28, 0x9b, 0xdd, 0xbf, 0x92, 0x7d, 0x48, 0x09, 0x6f, 0x36, 2072 0x5f, 0x28, 0x16, 0x43, 0x2f, 0x13, 0x8b, 0x91, 0x07, 0x89, 0xc5, 0x47, 0xdb, 0x17, 0xd1, 0xf3, 2073 0x5d, 0x45, 0xa2, 0xcb, 0xd0, 0x7f, 0x04, 0x98, 0x6c, 0xbb, 0xa1, 0xa3, 0x37, 0x7b, 0x98, 0x22, 2074 0x3a, 0x1f, 0x20, 0xd2, 0x37, 0xfa, 0x15, 0xf7, 0x63, 0x2b, 0xd5, 0x1f, 0xe7, 0x78, 0x89, 0x45, 2075 0x7c, 0xf7, 0x49, 0x47, 0x78, 0x1f, 0x79, 0x8f, 0x69, 0xfa, 0xde, 0x21, 0x12, 0x59, 0x86, 0x7e, 2076 0x93, 0x80, 0xe9, 0x6e, 0xd7, 0x7f, 0xb4, 0x12, 0xd3, 0x83, 0x63, 0xde, 0x0e, 0xd2, 0xfd, 0x0d, 2077 0xc2, 0xd2, 0x47, 0xc2, 0xe3, 0xdc, 0x8c, 0xbf, 0xef, 0xcb, 0x6d, 0x23, 0x36, 0x43, 0xe3, 0x7d, 2078 0x41, 0xba, 0x1a, 0x07, 0x8e, 0xb6, 0x51, 0x7a, 0xb9, 0xfd, 0xae, 0xbd, 0xbd, 0x2c, 0xbd, 0x78, 2079 0x14, 0x46, 0x27, 0xc9, 0xa2, 0xbf, 0x24, 0x60, 0xba, 0xdb, 0xd5, 0x3e, 0x36, 0x70, 0xc7, 0xbc, 2080 0x0b, 0xf4, 0x0b, 0xdc, 0xef, 0x85, 0xc7, 0xb9, 0xb9, 0xb6, 0x8d, 0x5e, 0x0e, 0x5d, 0xe6, 0x19, 2081 0x7a, 0x1f, 0x09, 0x4b, 0x79, 0xe6, 0x75, 0xdb, 0xc2, 0xcc, 0x71, 0x85, 0xd5, 0x06, 0x47, 0x76, 2082 0xf1, 0x51, 0x27, 0x9a, 0x6f, 0x2d, 0xbd, 0x1a, 0x4b, 0x6f, 0x0c, 0x5d, 0xe8, 0xaf, 0x02, 0x4c, 2083 0x77, 0xbb, 0x82, 0xc7, 0x46, 0xf7, 0x98, 0xfb, 0x7b, 0x7a, 0xa6, 0xa3, 0x11, 0x17, 0x1b, 0xb6, 2084 0x7b, 0x28, 0x35, 0xc2, 0xed, 0xe6, 0x5b, 0x8b, 0x57, 0x4f, 0x6c, 0x37, 0x9d, 0x9e, 0x6c, 0x5f, 2085 0x5a, 0x7c, 0xb1, 0xab, 0x58, 0xe7, 0x52, 0xf4, 0x85, 0x00, 0x53, 0x1d, 0x4f, 0x1a, 0xe8, 0x66, 2086 0xfc, 0x1e, 0xfb, 0x44, 0x73, 0x27, 0xea, 0x3c, 0xea, 0xcf, 0x79, 0x14, 0xdb, 0xf9, 0x1f, 0x26, 2087 0xe0, 0xe9, 0x2e, 0xb7, 0x6b, 0x94, 0xeb, 0xe3, 0xf6, 0x16, 0x7d, 0x70, 0x48, 0xaf, 0x9c, 0x46, 2088 0x05, 0xef, 0xbf, 0x56, 0xb4, 0xff, 0x06, 0x78, 0xf4, 0xd6, 0x70, 0x9a, 0x78, 0x9c, 0xdc, 0x5f, 2089 0xd0, 0x1f, 0x12, 0x30, 0xdd, 0x6d, 0x4a, 0x8c, 0x9d, 0xf0, 0xc7, 0x4c, 0xd4, 0xe9, 0xfc, 0xa9, 2090 0x74, 0x70, 0x48, 0x7e, 0x25, 0x3c, 0xce, 0xa5, 0x79, 0x57, 0x6e, 0x0d, 0x45, 0x97, 0x83, 0x21, 2091 0x87, 0xe1, 0xf4, 0x5d, 0x41, 0x5a, 0x39, 0x19, 0xa8, 0x6e, 0x1d, 0x20, 0xf8, 0xef, 0x1f, 0x6a, 2092 0x72, 0x59, 0x58, 0xdc, 0x7e, 0x43, 0xba, 0x7e, 0x84, 0xa2, 0x93, 0x85, 0xbf, 0x97, 0x10, 0xd0, 2093 0x6f, 0x13, 0x30, 0x7b, 0xc4, 0x00, 0x85, 0x8a, 0x4f, 0x64, 0x2a, 0x4d, 0xaf, 0x9e, 0x56, 0x0d, 2094 0x07, 0xf6, 0xc7, 0x02, 0xc3, 0xee, 0xfb, 0x82, 0x54, 0xec, 0x13, 0xbb, 0x96, 0x81, 0x00, 0xbe, 2095 0x1b, 0xd2, 0xeb, 0x3d, 0xc0, 0xd7, 0x21, 0x8f, 0xfe, 0x2b, 0xc0, 0x44, 0xf4, 0x4d, 0x12, 0x7d, 2096 0xad, 0xf7, 0xc6, 0xd4, 0x7a, 0x69, 0x4c, 0xf7, 0x31, 0x9e, 0x4a, 0x0f, 0xc3, 0x2d, 0xc9, 0x44, 2097 0xcb, 0xbd, 0xb7, 0xa4, 0x2c, 0x1d, 0x70, 0x69, 0x67, 0x7a, 0x19, 0x65, 0xe2, 0x75, 0xa6, 0x40, 2098 0x02, 0xfd, 0x53, 0x80, 0xa9, 0x8e, 0x77, 0xd3, 0xd8, 0xdd, 0xf9, 0xa8, 0x17, 0xd7, 0x23, 0xcf, 2099 0x9e, 0xa8, 0xaf, 0x8b, 0xa7, 0xf2, 0x75, 0xb1, 0x57, 0x5f, 0x7f, 0x92, 0x80, 0x54, 0xfb, 0x23, 2100 0x15, 0xba, 0x71, 0xba, 0x77, 0xb4, 0xf4, 0xcd, 0xbe, 0xe5, 0x79, 0x5d, 0x3c, 0x8a, 0xf6, 0xe0, 2101 0x20, 0x01, 0x7a, 0x2d, 0x0f, 0xe6, 0x65, 0x33, 0x01, 0xe2, 0x14, 0x04, 0x93, 0x40, 0xbf, 0x6e, 2102 0x03, 0x65, 0xdd, 0xaa, 0xf7, 0x07, 0x4a, 0xe8, 0x29, 0xad, 0x2f, 0x50, 0xc2, 0x8f, 0x4f, 0xd2, 2103 0x87, 0x42, 0x14, 0x95, 0x1f, 0x08, 0xa8, 0xd4, 0x0f, 0x2c, 0x41, 0xec, 0x9b, 0x1c, 0x6a, 0x65, 2104 0xfb, 0x26, 0x7a, 0x33, 0x2e, 0x4a, 0x5d, 0x15, 0xa0, 0x9f, 0x25, 0x60, 0xb2, 0xed, 0x7d, 0x28, 2105 0xf6, 0x55, 0xaa, 0xfb, 0xeb, 0x55, 0xec, 0xab, 0xd4, 0x11, 0xcf, 0x52, 0xd2, 0x07, 0x42, 0xb8, 2106 0xb4, 0xbe, 0x2d, 0xdd, 0xec, 0xf1, 0x16, 0xb9, 0x5c, 0x8b, 0x2a, 0xa6, 0xed, 0xf5, 0x35, 0xe9, 2107 0x6a, 0x8c, 0x8b, 0x65, 0x17, 0xc9, 0xf4, 0xdd, 0xcf, 0x72, 0xcf, 0xc7, 0x78, 0x6f, 0xf9, 0x63, 2108 0x2e, 0xb3, 0xe7, 0xba, 0x36, 0x59, 0xce, 0x66, 0x0f, 0x0e, 0x0e, 0xda, 0x1f, 0x63, 0x54, 0xcf, 2109 0xdd, 0xf3, 0xff, 0x5e, 0xf2, 0x25, 0xdb, 0x50, 0xdd, 0x5d, 0xcb, 0x69, 0xac, 0xfc, 0x4d, 0x80, 2110 0x4b, 0x35, 0xab, 0x11, 0x0f, 0xac, 0x95, 0xa9, 0xf0, 0x85, 0x7f, 0x93, 0xb6, 0xa2, 0x4d, 0x61, 2111 0xfb, 0x6d, 0x2e, 0x5b, 0xb7, 0x0c, 0xd5, 0xac, 0x67, 0x2c, 0xa7, 0x9e, 0xad, 0x63, 0x93, 0x35, 2112 0xaa, 0x6c, 0x6b, 0x07, 0x27, 0xfc, 0xa1, 0xe6, 0x1b, 0xe1, 0xef, 0x5f, 0x26, 0x2e, 0xae, 0xf9, 2113 0x3a, 0xf3, 0x6c, 0x3f, 0x2b, 0x7a, 0xfd, 0x6d, 0xb6, 0x9f, 0xb0, 0xf9, 0xcc, 0x9d, 0x2b, 0x9f, 2114 0x05, 0xeb, 0xee, 0xb1, 0x75, 0xf7, 0x82, 0x75, 0xf7, 0xc2, 0xeb, 0xee, 0xdd, 0xb9, 0xb2, 0x33, 2115 0xc4, 0x76, 0x73, 0xf5, 0x7f, 0x01, 0x00, 0x00, 0xff, 0xff, 0x62, 0xee, 0xf2, 0x20, 0x09, 0x2b, 2116 0x00, 0x00, 2117} 2118 2119// Reference imports to suppress errors if they are not otherwise used. 2120var _ context.Context 2121var _ grpc.ClientConn 2122 2123// This is a compile-time assertion to ensure that this generated file 2124// is compatible with the grpc package it is being compiled against. 2125const _ = grpc.SupportPackageIsVersion4 2126 2127// DataTransferServiceClient is the client API for DataTransferService service. 2128// 2129// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 2130type DataTransferServiceClient interface { 2131 // Retrieves a supported data source and returns its settings, 2132 // which can be used for UI rendering. 2133 GetDataSource(ctx context.Context, in *GetDataSourceRequest, opts ...grpc.CallOption) (*DataSource, error) 2134 // Lists supported data sources and returns their settings, 2135 // which can be used for UI rendering. 2136 ListDataSources(ctx context.Context, in *ListDataSourcesRequest, opts ...grpc.CallOption) (*ListDataSourcesResponse, error) 2137 // Creates a new data transfer configuration. 2138 CreateTransferConfig(ctx context.Context, in *CreateTransferConfigRequest, opts ...grpc.CallOption) (*TransferConfig, error) 2139 // Updates a data transfer configuration. 2140 // All fields must be set, even if they are not updated. 2141 UpdateTransferConfig(ctx context.Context, in *UpdateTransferConfigRequest, opts ...grpc.CallOption) (*TransferConfig, error) 2142 // Deletes a data transfer configuration, 2143 // including any associated transfer runs and logs. 2144 DeleteTransferConfig(ctx context.Context, in *DeleteTransferConfigRequest, opts ...grpc.CallOption) (*empty.Empty, error) 2145 // Returns information about a data transfer config. 2146 GetTransferConfig(ctx context.Context, in *GetTransferConfigRequest, opts ...grpc.CallOption) (*TransferConfig, error) 2147 // Returns information about all data transfers in the project. 2148 ListTransferConfigs(ctx context.Context, in *ListTransferConfigsRequest, opts ...grpc.CallOption) (*ListTransferConfigsResponse, error) 2149 // Creates transfer runs for a time range [start_time, end_time]. 2150 // For each date - or whatever granularity the data source supports - in the 2151 // range, one transfer run is created. 2152 // Note that runs are created per UTC time in the time range. 2153 // DEPRECATED: use StartManualTransferRuns instead. 2154 // 2155 // Deprecated: Do not use. 2156 ScheduleTransferRuns(ctx context.Context, in *ScheduleTransferRunsRequest, opts ...grpc.CallOption) (*ScheduleTransferRunsResponse, error) 2157 // Start manual transfer runs to be executed now with schedule_time equal to 2158 // current time. The transfer runs can be created for a time range where the 2159 // run_time is between start_time (inclusive) and end_time (exclusive), or for 2160 // a specific run_time. 2161 StartManualTransferRuns(ctx context.Context, in *StartManualTransferRunsRequest, opts ...grpc.CallOption) (*StartManualTransferRunsResponse, error) 2162 // Returns information about the particular transfer run. 2163 GetTransferRun(ctx context.Context, in *GetTransferRunRequest, opts ...grpc.CallOption) (*TransferRun, error) 2164 // Deletes the specified transfer run. 2165 DeleteTransferRun(ctx context.Context, in *DeleteTransferRunRequest, opts ...grpc.CallOption) (*empty.Empty, error) 2166 // Returns information about running and completed jobs. 2167 ListTransferRuns(ctx context.Context, in *ListTransferRunsRequest, opts ...grpc.CallOption) (*ListTransferRunsResponse, error) 2168 // Returns user facing log messages for the data transfer run. 2169 ListTransferLogs(ctx context.Context, in *ListTransferLogsRequest, opts ...grpc.CallOption) (*ListTransferLogsResponse, error) 2170 // Returns true if valid credentials exist for the given data source and 2171 // requesting user. 2172 // Some data sources doesn't support service account, so we need to talk to 2173 // them on behalf of the end user. This API just checks whether we have OAuth 2174 // token for the particular user, which is a pre-requisite before user can 2175 // create a transfer config. 2176 CheckValidCreds(ctx context.Context, in *CheckValidCredsRequest, opts ...grpc.CallOption) (*CheckValidCredsResponse, error) 2177} 2178 2179type dataTransferServiceClient struct { 2180 cc *grpc.ClientConn 2181} 2182 2183func NewDataTransferServiceClient(cc *grpc.ClientConn) DataTransferServiceClient { 2184 return &dataTransferServiceClient{cc} 2185} 2186 2187func (c *dataTransferServiceClient) GetDataSource(ctx context.Context, in *GetDataSourceRequest, opts ...grpc.CallOption) (*DataSource, error) { 2188 out := new(DataSource) 2189 err := c.cc.Invoke(ctx, "/google.cloud.bigquery.datatransfer.v1.DataTransferService/GetDataSource", in, out, opts...) 2190 if err != nil { 2191 return nil, err 2192 } 2193 return out, nil 2194} 2195 2196func (c *dataTransferServiceClient) ListDataSources(ctx context.Context, in *ListDataSourcesRequest, opts ...grpc.CallOption) (*ListDataSourcesResponse, error) { 2197 out := new(ListDataSourcesResponse) 2198 err := c.cc.Invoke(ctx, "/google.cloud.bigquery.datatransfer.v1.DataTransferService/ListDataSources", in, out, opts...) 2199 if err != nil { 2200 return nil, err 2201 } 2202 return out, nil 2203} 2204 2205func (c *dataTransferServiceClient) CreateTransferConfig(ctx context.Context, in *CreateTransferConfigRequest, opts ...grpc.CallOption) (*TransferConfig, error) { 2206 out := new(TransferConfig) 2207 err := c.cc.Invoke(ctx, "/google.cloud.bigquery.datatransfer.v1.DataTransferService/CreateTransferConfig", in, out, opts...) 2208 if err != nil { 2209 return nil, err 2210 } 2211 return out, nil 2212} 2213 2214func (c *dataTransferServiceClient) UpdateTransferConfig(ctx context.Context, in *UpdateTransferConfigRequest, opts ...grpc.CallOption) (*TransferConfig, error) { 2215 out := new(TransferConfig) 2216 err := c.cc.Invoke(ctx, "/google.cloud.bigquery.datatransfer.v1.DataTransferService/UpdateTransferConfig", in, out, opts...) 2217 if err != nil { 2218 return nil, err 2219 } 2220 return out, nil 2221} 2222 2223func (c *dataTransferServiceClient) DeleteTransferConfig(ctx context.Context, in *DeleteTransferConfigRequest, opts ...grpc.CallOption) (*empty.Empty, error) { 2224 out := new(empty.Empty) 2225 err := c.cc.Invoke(ctx, "/google.cloud.bigquery.datatransfer.v1.DataTransferService/DeleteTransferConfig", in, out, opts...) 2226 if err != nil { 2227 return nil, err 2228 } 2229 return out, nil 2230} 2231 2232func (c *dataTransferServiceClient) GetTransferConfig(ctx context.Context, in *GetTransferConfigRequest, opts ...grpc.CallOption) (*TransferConfig, error) { 2233 out := new(TransferConfig) 2234 err := c.cc.Invoke(ctx, "/google.cloud.bigquery.datatransfer.v1.DataTransferService/GetTransferConfig", in, out, opts...) 2235 if err != nil { 2236 return nil, err 2237 } 2238 return out, nil 2239} 2240 2241func (c *dataTransferServiceClient) ListTransferConfigs(ctx context.Context, in *ListTransferConfigsRequest, opts ...grpc.CallOption) (*ListTransferConfigsResponse, error) { 2242 out := new(ListTransferConfigsResponse) 2243 err := c.cc.Invoke(ctx, "/google.cloud.bigquery.datatransfer.v1.DataTransferService/ListTransferConfigs", in, out, opts...) 2244 if err != nil { 2245 return nil, err 2246 } 2247 return out, nil 2248} 2249 2250// Deprecated: Do not use. 2251func (c *dataTransferServiceClient) ScheduleTransferRuns(ctx context.Context, in *ScheduleTransferRunsRequest, opts ...grpc.CallOption) (*ScheduleTransferRunsResponse, error) { 2252 out := new(ScheduleTransferRunsResponse) 2253 err := c.cc.Invoke(ctx, "/google.cloud.bigquery.datatransfer.v1.DataTransferService/ScheduleTransferRuns", in, out, opts...) 2254 if err != nil { 2255 return nil, err 2256 } 2257 return out, nil 2258} 2259 2260func (c *dataTransferServiceClient) StartManualTransferRuns(ctx context.Context, in *StartManualTransferRunsRequest, opts ...grpc.CallOption) (*StartManualTransferRunsResponse, error) { 2261 out := new(StartManualTransferRunsResponse) 2262 err := c.cc.Invoke(ctx, "/google.cloud.bigquery.datatransfer.v1.DataTransferService/StartManualTransferRuns", in, out, opts...) 2263 if err != nil { 2264 return nil, err 2265 } 2266 return out, nil 2267} 2268 2269func (c *dataTransferServiceClient) GetTransferRun(ctx context.Context, in *GetTransferRunRequest, opts ...grpc.CallOption) (*TransferRun, error) { 2270 out := new(TransferRun) 2271 err := c.cc.Invoke(ctx, "/google.cloud.bigquery.datatransfer.v1.DataTransferService/GetTransferRun", in, out, opts...) 2272 if err != nil { 2273 return nil, err 2274 } 2275 return out, nil 2276} 2277 2278func (c *dataTransferServiceClient) DeleteTransferRun(ctx context.Context, in *DeleteTransferRunRequest, opts ...grpc.CallOption) (*empty.Empty, error) { 2279 out := new(empty.Empty) 2280 err := c.cc.Invoke(ctx, "/google.cloud.bigquery.datatransfer.v1.DataTransferService/DeleteTransferRun", in, out, opts...) 2281 if err != nil { 2282 return nil, err 2283 } 2284 return out, nil 2285} 2286 2287func (c *dataTransferServiceClient) ListTransferRuns(ctx context.Context, in *ListTransferRunsRequest, opts ...grpc.CallOption) (*ListTransferRunsResponse, error) { 2288 out := new(ListTransferRunsResponse) 2289 err := c.cc.Invoke(ctx, "/google.cloud.bigquery.datatransfer.v1.DataTransferService/ListTransferRuns", in, out, opts...) 2290 if err != nil { 2291 return nil, err 2292 } 2293 return out, nil 2294} 2295 2296func (c *dataTransferServiceClient) ListTransferLogs(ctx context.Context, in *ListTransferLogsRequest, opts ...grpc.CallOption) (*ListTransferLogsResponse, error) { 2297 out := new(ListTransferLogsResponse) 2298 err := c.cc.Invoke(ctx, "/google.cloud.bigquery.datatransfer.v1.DataTransferService/ListTransferLogs", in, out, opts...) 2299 if err != nil { 2300 return nil, err 2301 } 2302 return out, nil 2303} 2304 2305func (c *dataTransferServiceClient) CheckValidCreds(ctx context.Context, in *CheckValidCredsRequest, opts ...grpc.CallOption) (*CheckValidCredsResponse, error) { 2306 out := new(CheckValidCredsResponse) 2307 err := c.cc.Invoke(ctx, "/google.cloud.bigquery.datatransfer.v1.DataTransferService/CheckValidCreds", in, out, opts...) 2308 if err != nil { 2309 return nil, err 2310 } 2311 return out, nil 2312} 2313 2314// DataTransferServiceServer is the server API for DataTransferService service. 2315type DataTransferServiceServer interface { 2316 // Retrieves a supported data source and returns its settings, 2317 // which can be used for UI rendering. 2318 GetDataSource(context.Context, *GetDataSourceRequest) (*DataSource, error) 2319 // Lists supported data sources and returns their settings, 2320 // which can be used for UI rendering. 2321 ListDataSources(context.Context, *ListDataSourcesRequest) (*ListDataSourcesResponse, error) 2322 // Creates a new data transfer configuration. 2323 CreateTransferConfig(context.Context, *CreateTransferConfigRequest) (*TransferConfig, error) 2324 // Updates a data transfer configuration. 2325 // All fields must be set, even if they are not updated. 2326 UpdateTransferConfig(context.Context, *UpdateTransferConfigRequest) (*TransferConfig, error) 2327 // Deletes a data transfer configuration, 2328 // including any associated transfer runs and logs. 2329 DeleteTransferConfig(context.Context, *DeleteTransferConfigRequest) (*empty.Empty, error) 2330 // Returns information about a data transfer config. 2331 GetTransferConfig(context.Context, *GetTransferConfigRequest) (*TransferConfig, error) 2332 // Returns information about all data transfers in the project. 2333 ListTransferConfigs(context.Context, *ListTransferConfigsRequest) (*ListTransferConfigsResponse, error) 2334 // Creates transfer runs for a time range [start_time, end_time]. 2335 // For each date - or whatever granularity the data source supports - in the 2336 // range, one transfer run is created. 2337 // Note that runs are created per UTC time in the time range. 2338 // DEPRECATED: use StartManualTransferRuns instead. 2339 // 2340 // Deprecated: Do not use. 2341 ScheduleTransferRuns(context.Context, *ScheduleTransferRunsRequest) (*ScheduleTransferRunsResponse, error) 2342 // Start manual transfer runs to be executed now with schedule_time equal to 2343 // current time. The transfer runs can be created for a time range where the 2344 // run_time is between start_time (inclusive) and end_time (exclusive), or for 2345 // a specific run_time. 2346 StartManualTransferRuns(context.Context, *StartManualTransferRunsRequest) (*StartManualTransferRunsResponse, error) 2347 // Returns information about the particular transfer run. 2348 GetTransferRun(context.Context, *GetTransferRunRequest) (*TransferRun, error) 2349 // Deletes the specified transfer run. 2350 DeleteTransferRun(context.Context, *DeleteTransferRunRequest) (*empty.Empty, error) 2351 // Returns information about running and completed jobs. 2352 ListTransferRuns(context.Context, *ListTransferRunsRequest) (*ListTransferRunsResponse, error) 2353 // Returns user facing log messages for the data transfer run. 2354 ListTransferLogs(context.Context, *ListTransferLogsRequest) (*ListTransferLogsResponse, error) 2355 // Returns true if valid credentials exist for the given data source and 2356 // requesting user. 2357 // Some data sources doesn't support service account, so we need to talk to 2358 // them on behalf of the end user. This API just checks whether we have OAuth 2359 // token for the particular user, which is a pre-requisite before user can 2360 // create a transfer config. 2361 CheckValidCreds(context.Context, *CheckValidCredsRequest) (*CheckValidCredsResponse, error) 2362} 2363 2364// UnimplementedDataTransferServiceServer can be embedded to have forward compatible implementations. 2365type UnimplementedDataTransferServiceServer struct { 2366} 2367 2368func (*UnimplementedDataTransferServiceServer) GetDataSource(ctx context.Context, req *GetDataSourceRequest) (*DataSource, error) { 2369 return nil, status.Errorf(codes.Unimplemented, "method GetDataSource not implemented") 2370} 2371func (*UnimplementedDataTransferServiceServer) ListDataSources(ctx context.Context, req *ListDataSourcesRequest) (*ListDataSourcesResponse, error) { 2372 return nil, status.Errorf(codes.Unimplemented, "method ListDataSources not implemented") 2373} 2374func (*UnimplementedDataTransferServiceServer) CreateTransferConfig(ctx context.Context, req *CreateTransferConfigRequest) (*TransferConfig, error) { 2375 return nil, status.Errorf(codes.Unimplemented, "method CreateTransferConfig not implemented") 2376} 2377func (*UnimplementedDataTransferServiceServer) UpdateTransferConfig(ctx context.Context, req *UpdateTransferConfigRequest) (*TransferConfig, error) { 2378 return nil, status.Errorf(codes.Unimplemented, "method UpdateTransferConfig not implemented") 2379} 2380func (*UnimplementedDataTransferServiceServer) DeleteTransferConfig(ctx context.Context, req *DeleteTransferConfigRequest) (*empty.Empty, error) { 2381 return nil, status.Errorf(codes.Unimplemented, "method DeleteTransferConfig not implemented") 2382} 2383func (*UnimplementedDataTransferServiceServer) GetTransferConfig(ctx context.Context, req *GetTransferConfigRequest) (*TransferConfig, error) { 2384 return nil, status.Errorf(codes.Unimplemented, "method GetTransferConfig not implemented") 2385} 2386func (*UnimplementedDataTransferServiceServer) ListTransferConfigs(ctx context.Context, req *ListTransferConfigsRequest) (*ListTransferConfigsResponse, error) { 2387 return nil, status.Errorf(codes.Unimplemented, "method ListTransferConfigs not implemented") 2388} 2389func (*UnimplementedDataTransferServiceServer) ScheduleTransferRuns(ctx context.Context, req *ScheduleTransferRunsRequest) (*ScheduleTransferRunsResponse, error) { 2390 return nil, status.Errorf(codes.Unimplemented, "method ScheduleTransferRuns not implemented") 2391} 2392func (*UnimplementedDataTransferServiceServer) StartManualTransferRuns(ctx context.Context, req *StartManualTransferRunsRequest) (*StartManualTransferRunsResponse, error) { 2393 return nil, status.Errorf(codes.Unimplemented, "method StartManualTransferRuns not implemented") 2394} 2395func (*UnimplementedDataTransferServiceServer) GetTransferRun(ctx context.Context, req *GetTransferRunRequest) (*TransferRun, error) { 2396 return nil, status.Errorf(codes.Unimplemented, "method GetTransferRun not implemented") 2397} 2398func (*UnimplementedDataTransferServiceServer) DeleteTransferRun(ctx context.Context, req *DeleteTransferRunRequest) (*empty.Empty, error) { 2399 return nil, status.Errorf(codes.Unimplemented, "method DeleteTransferRun not implemented") 2400} 2401func (*UnimplementedDataTransferServiceServer) ListTransferRuns(ctx context.Context, req *ListTransferRunsRequest) (*ListTransferRunsResponse, error) { 2402 return nil, status.Errorf(codes.Unimplemented, "method ListTransferRuns not implemented") 2403} 2404func (*UnimplementedDataTransferServiceServer) ListTransferLogs(ctx context.Context, req *ListTransferLogsRequest) (*ListTransferLogsResponse, error) { 2405 return nil, status.Errorf(codes.Unimplemented, "method ListTransferLogs not implemented") 2406} 2407func (*UnimplementedDataTransferServiceServer) CheckValidCreds(ctx context.Context, req *CheckValidCredsRequest) (*CheckValidCredsResponse, error) { 2408 return nil, status.Errorf(codes.Unimplemented, "method CheckValidCreds not implemented") 2409} 2410 2411func RegisterDataTransferServiceServer(s *grpc.Server, srv DataTransferServiceServer) { 2412 s.RegisterService(&_DataTransferService_serviceDesc, srv) 2413} 2414 2415func _DataTransferService_GetDataSource_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2416 in := new(GetDataSourceRequest) 2417 if err := dec(in); err != nil { 2418 return nil, err 2419 } 2420 if interceptor == nil { 2421 return srv.(DataTransferServiceServer).GetDataSource(ctx, in) 2422 } 2423 info := &grpc.UnaryServerInfo{ 2424 Server: srv, 2425 FullMethod: "/google.cloud.bigquery.datatransfer.v1.DataTransferService/GetDataSource", 2426 } 2427 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2428 return srv.(DataTransferServiceServer).GetDataSource(ctx, req.(*GetDataSourceRequest)) 2429 } 2430 return interceptor(ctx, in, info, handler) 2431} 2432 2433func _DataTransferService_ListDataSources_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2434 in := new(ListDataSourcesRequest) 2435 if err := dec(in); err != nil { 2436 return nil, err 2437 } 2438 if interceptor == nil { 2439 return srv.(DataTransferServiceServer).ListDataSources(ctx, in) 2440 } 2441 info := &grpc.UnaryServerInfo{ 2442 Server: srv, 2443 FullMethod: "/google.cloud.bigquery.datatransfer.v1.DataTransferService/ListDataSources", 2444 } 2445 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2446 return srv.(DataTransferServiceServer).ListDataSources(ctx, req.(*ListDataSourcesRequest)) 2447 } 2448 return interceptor(ctx, in, info, handler) 2449} 2450 2451func _DataTransferService_CreateTransferConfig_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2452 in := new(CreateTransferConfigRequest) 2453 if err := dec(in); err != nil { 2454 return nil, err 2455 } 2456 if interceptor == nil { 2457 return srv.(DataTransferServiceServer).CreateTransferConfig(ctx, in) 2458 } 2459 info := &grpc.UnaryServerInfo{ 2460 Server: srv, 2461 FullMethod: "/google.cloud.bigquery.datatransfer.v1.DataTransferService/CreateTransferConfig", 2462 } 2463 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2464 return srv.(DataTransferServiceServer).CreateTransferConfig(ctx, req.(*CreateTransferConfigRequest)) 2465 } 2466 return interceptor(ctx, in, info, handler) 2467} 2468 2469func _DataTransferService_UpdateTransferConfig_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2470 in := new(UpdateTransferConfigRequest) 2471 if err := dec(in); err != nil { 2472 return nil, err 2473 } 2474 if interceptor == nil { 2475 return srv.(DataTransferServiceServer).UpdateTransferConfig(ctx, in) 2476 } 2477 info := &grpc.UnaryServerInfo{ 2478 Server: srv, 2479 FullMethod: "/google.cloud.bigquery.datatransfer.v1.DataTransferService/UpdateTransferConfig", 2480 } 2481 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2482 return srv.(DataTransferServiceServer).UpdateTransferConfig(ctx, req.(*UpdateTransferConfigRequest)) 2483 } 2484 return interceptor(ctx, in, info, handler) 2485} 2486 2487func _DataTransferService_DeleteTransferConfig_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2488 in := new(DeleteTransferConfigRequest) 2489 if err := dec(in); err != nil { 2490 return nil, err 2491 } 2492 if interceptor == nil { 2493 return srv.(DataTransferServiceServer).DeleteTransferConfig(ctx, in) 2494 } 2495 info := &grpc.UnaryServerInfo{ 2496 Server: srv, 2497 FullMethod: "/google.cloud.bigquery.datatransfer.v1.DataTransferService/DeleteTransferConfig", 2498 } 2499 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2500 return srv.(DataTransferServiceServer).DeleteTransferConfig(ctx, req.(*DeleteTransferConfigRequest)) 2501 } 2502 return interceptor(ctx, in, info, handler) 2503} 2504 2505func _DataTransferService_GetTransferConfig_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2506 in := new(GetTransferConfigRequest) 2507 if err := dec(in); err != nil { 2508 return nil, err 2509 } 2510 if interceptor == nil { 2511 return srv.(DataTransferServiceServer).GetTransferConfig(ctx, in) 2512 } 2513 info := &grpc.UnaryServerInfo{ 2514 Server: srv, 2515 FullMethod: "/google.cloud.bigquery.datatransfer.v1.DataTransferService/GetTransferConfig", 2516 } 2517 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2518 return srv.(DataTransferServiceServer).GetTransferConfig(ctx, req.(*GetTransferConfigRequest)) 2519 } 2520 return interceptor(ctx, in, info, handler) 2521} 2522 2523func _DataTransferService_ListTransferConfigs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2524 in := new(ListTransferConfigsRequest) 2525 if err := dec(in); err != nil { 2526 return nil, err 2527 } 2528 if interceptor == nil { 2529 return srv.(DataTransferServiceServer).ListTransferConfigs(ctx, in) 2530 } 2531 info := &grpc.UnaryServerInfo{ 2532 Server: srv, 2533 FullMethod: "/google.cloud.bigquery.datatransfer.v1.DataTransferService/ListTransferConfigs", 2534 } 2535 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2536 return srv.(DataTransferServiceServer).ListTransferConfigs(ctx, req.(*ListTransferConfigsRequest)) 2537 } 2538 return interceptor(ctx, in, info, handler) 2539} 2540 2541func _DataTransferService_ScheduleTransferRuns_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2542 in := new(ScheduleTransferRunsRequest) 2543 if err := dec(in); err != nil { 2544 return nil, err 2545 } 2546 if interceptor == nil { 2547 return srv.(DataTransferServiceServer).ScheduleTransferRuns(ctx, in) 2548 } 2549 info := &grpc.UnaryServerInfo{ 2550 Server: srv, 2551 FullMethod: "/google.cloud.bigquery.datatransfer.v1.DataTransferService/ScheduleTransferRuns", 2552 } 2553 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2554 return srv.(DataTransferServiceServer).ScheduleTransferRuns(ctx, req.(*ScheduleTransferRunsRequest)) 2555 } 2556 return interceptor(ctx, in, info, handler) 2557} 2558 2559func _DataTransferService_StartManualTransferRuns_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2560 in := new(StartManualTransferRunsRequest) 2561 if err := dec(in); err != nil { 2562 return nil, err 2563 } 2564 if interceptor == nil { 2565 return srv.(DataTransferServiceServer).StartManualTransferRuns(ctx, in) 2566 } 2567 info := &grpc.UnaryServerInfo{ 2568 Server: srv, 2569 FullMethod: "/google.cloud.bigquery.datatransfer.v1.DataTransferService/StartManualTransferRuns", 2570 } 2571 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2572 return srv.(DataTransferServiceServer).StartManualTransferRuns(ctx, req.(*StartManualTransferRunsRequest)) 2573 } 2574 return interceptor(ctx, in, info, handler) 2575} 2576 2577func _DataTransferService_GetTransferRun_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2578 in := new(GetTransferRunRequest) 2579 if err := dec(in); err != nil { 2580 return nil, err 2581 } 2582 if interceptor == nil { 2583 return srv.(DataTransferServiceServer).GetTransferRun(ctx, in) 2584 } 2585 info := &grpc.UnaryServerInfo{ 2586 Server: srv, 2587 FullMethod: "/google.cloud.bigquery.datatransfer.v1.DataTransferService/GetTransferRun", 2588 } 2589 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2590 return srv.(DataTransferServiceServer).GetTransferRun(ctx, req.(*GetTransferRunRequest)) 2591 } 2592 return interceptor(ctx, in, info, handler) 2593} 2594 2595func _DataTransferService_DeleteTransferRun_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2596 in := new(DeleteTransferRunRequest) 2597 if err := dec(in); err != nil { 2598 return nil, err 2599 } 2600 if interceptor == nil { 2601 return srv.(DataTransferServiceServer).DeleteTransferRun(ctx, in) 2602 } 2603 info := &grpc.UnaryServerInfo{ 2604 Server: srv, 2605 FullMethod: "/google.cloud.bigquery.datatransfer.v1.DataTransferService/DeleteTransferRun", 2606 } 2607 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2608 return srv.(DataTransferServiceServer).DeleteTransferRun(ctx, req.(*DeleteTransferRunRequest)) 2609 } 2610 return interceptor(ctx, in, info, handler) 2611} 2612 2613func _DataTransferService_ListTransferRuns_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2614 in := new(ListTransferRunsRequest) 2615 if err := dec(in); err != nil { 2616 return nil, err 2617 } 2618 if interceptor == nil { 2619 return srv.(DataTransferServiceServer).ListTransferRuns(ctx, in) 2620 } 2621 info := &grpc.UnaryServerInfo{ 2622 Server: srv, 2623 FullMethod: "/google.cloud.bigquery.datatransfer.v1.DataTransferService/ListTransferRuns", 2624 } 2625 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2626 return srv.(DataTransferServiceServer).ListTransferRuns(ctx, req.(*ListTransferRunsRequest)) 2627 } 2628 return interceptor(ctx, in, info, handler) 2629} 2630 2631func _DataTransferService_ListTransferLogs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2632 in := new(ListTransferLogsRequest) 2633 if err := dec(in); err != nil { 2634 return nil, err 2635 } 2636 if interceptor == nil { 2637 return srv.(DataTransferServiceServer).ListTransferLogs(ctx, in) 2638 } 2639 info := &grpc.UnaryServerInfo{ 2640 Server: srv, 2641 FullMethod: "/google.cloud.bigquery.datatransfer.v1.DataTransferService/ListTransferLogs", 2642 } 2643 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2644 return srv.(DataTransferServiceServer).ListTransferLogs(ctx, req.(*ListTransferLogsRequest)) 2645 } 2646 return interceptor(ctx, in, info, handler) 2647} 2648 2649func _DataTransferService_CheckValidCreds_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2650 in := new(CheckValidCredsRequest) 2651 if err := dec(in); err != nil { 2652 return nil, err 2653 } 2654 if interceptor == nil { 2655 return srv.(DataTransferServiceServer).CheckValidCreds(ctx, in) 2656 } 2657 info := &grpc.UnaryServerInfo{ 2658 Server: srv, 2659 FullMethod: "/google.cloud.bigquery.datatransfer.v1.DataTransferService/CheckValidCreds", 2660 } 2661 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2662 return srv.(DataTransferServiceServer).CheckValidCreds(ctx, req.(*CheckValidCredsRequest)) 2663 } 2664 return interceptor(ctx, in, info, handler) 2665} 2666 2667var _DataTransferService_serviceDesc = grpc.ServiceDesc{ 2668 ServiceName: "google.cloud.bigquery.datatransfer.v1.DataTransferService", 2669 HandlerType: (*DataTransferServiceServer)(nil), 2670 Methods: []grpc.MethodDesc{ 2671 { 2672 MethodName: "GetDataSource", 2673 Handler: _DataTransferService_GetDataSource_Handler, 2674 }, 2675 { 2676 MethodName: "ListDataSources", 2677 Handler: _DataTransferService_ListDataSources_Handler, 2678 }, 2679 { 2680 MethodName: "CreateTransferConfig", 2681 Handler: _DataTransferService_CreateTransferConfig_Handler, 2682 }, 2683 { 2684 MethodName: "UpdateTransferConfig", 2685 Handler: _DataTransferService_UpdateTransferConfig_Handler, 2686 }, 2687 { 2688 MethodName: "DeleteTransferConfig", 2689 Handler: _DataTransferService_DeleteTransferConfig_Handler, 2690 }, 2691 { 2692 MethodName: "GetTransferConfig", 2693 Handler: _DataTransferService_GetTransferConfig_Handler, 2694 }, 2695 { 2696 MethodName: "ListTransferConfigs", 2697 Handler: _DataTransferService_ListTransferConfigs_Handler, 2698 }, 2699 { 2700 MethodName: "ScheduleTransferRuns", 2701 Handler: _DataTransferService_ScheduleTransferRuns_Handler, 2702 }, 2703 { 2704 MethodName: "StartManualTransferRuns", 2705 Handler: _DataTransferService_StartManualTransferRuns_Handler, 2706 }, 2707 { 2708 MethodName: "GetTransferRun", 2709 Handler: _DataTransferService_GetTransferRun_Handler, 2710 }, 2711 { 2712 MethodName: "DeleteTransferRun", 2713 Handler: _DataTransferService_DeleteTransferRun_Handler, 2714 }, 2715 { 2716 MethodName: "ListTransferRuns", 2717 Handler: _DataTransferService_ListTransferRuns_Handler, 2718 }, 2719 { 2720 MethodName: "ListTransferLogs", 2721 Handler: _DataTransferService_ListTransferLogs_Handler, 2722 }, 2723 { 2724 MethodName: "CheckValidCreds", 2725 Handler: _DataTransferService_CheckValidCreds_Handler, 2726 }, 2727 }, 2728 Streams: []grpc.StreamDesc{}, 2729 Metadata: "google/cloud/bigquery/datatransfer/v1/datatransfer.proto", 2730} 2731