1// Code generated by protoc-gen-go. DO NOT EDIT. 2// source: google/cloud/recommendationengine/v1beta1/import.proto 3 4package recommendationengine 5 6import ( 7 fmt "fmt" 8 math "math" 9 10 proto "github.com/golang/protobuf/proto" 11 timestamp "github.com/golang/protobuf/ptypes/timestamp" 12 _ "google.golang.org/genproto/googleapis/api/annotations" 13 status "google.golang.org/genproto/googleapis/rpc/status" 14) 15 16// Reference imports to suppress errors if they are not otherwise used. 17var _ = proto.Marshal 18var _ = fmt.Errorf 19var _ = math.Inf 20 21// This is a compile-time assertion to ensure that this generated file 22// is compatible with the proto package it is being compiled against. 23// A compilation error at this line likely means your copy of the 24// proto package needs to be updated. 25const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package 26 27// Google Cloud Storage location for input content. 28// format. 29type GcsSource struct { 30 // Required. Google Cloud Storage URIs to input files. URI can be up to 31 // 2000 characters long. URIs can match the full object path (for example, 32 // gs://bucket/directory/object.json) or a pattern matching one or more 33 // files, such as gs://bucket/directory/*.json. A request can 34 // contain at most 100 files, and each file can be up to 2 GB. See 35 // [Importing catalog information](/recommendations-ai/docs/upload-catalog) 36 // for the expected file format and setup instructions. 37 InputUris []string `protobuf:"bytes,1,rep,name=input_uris,json=inputUris,proto3" json:"input_uris,omitempty"` 38 XXX_NoUnkeyedLiteral struct{} `json:"-"` 39 XXX_unrecognized []byte `json:"-"` 40 XXX_sizecache int32 `json:"-"` 41} 42 43func (m *GcsSource) Reset() { *m = GcsSource{} } 44func (m *GcsSource) String() string { return proto.CompactTextString(m) } 45func (*GcsSource) ProtoMessage() {} 46func (*GcsSource) Descriptor() ([]byte, []int) { 47 return fileDescriptor_152d6e7da409eb0d, []int{0} 48} 49 50func (m *GcsSource) XXX_Unmarshal(b []byte) error { 51 return xxx_messageInfo_GcsSource.Unmarshal(m, b) 52} 53func (m *GcsSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 54 return xxx_messageInfo_GcsSource.Marshal(b, m, deterministic) 55} 56func (m *GcsSource) XXX_Merge(src proto.Message) { 57 xxx_messageInfo_GcsSource.Merge(m, src) 58} 59func (m *GcsSource) XXX_Size() int { 60 return xxx_messageInfo_GcsSource.Size(m) 61} 62func (m *GcsSource) XXX_DiscardUnknown() { 63 xxx_messageInfo_GcsSource.DiscardUnknown(m) 64} 65 66var xxx_messageInfo_GcsSource proto.InternalMessageInfo 67 68func (m *GcsSource) GetInputUris() []string { 69 if m != nil { 70 return m.InputUris 71 } 72 return nil 73} 74 75// The inline source for the input config for ImportCatalogItems method. 76type CatalogInlineSource struct { 77 // Optional. A list of catalog items to update/create. Recommended max of 10k 78 // items. 79 CatalogItems []*CatalogItem `protobuf:"bytes,1,rep,name=catalog_items,json=catalogItems,proto3" json:"catalog_items,omitempty"` 80 XXX_NoUnkeyedLiteral struct{} `json:"-"` 81 XXX_unrecognized []byte `json:"-"` 82 XXX_sizecache int32 `json:"-"` 83} 84 85func (m *CatalogInlineSource) Reset() { *m = CatalogInlineSource{} } 86func (m *CatalogInlineSource) String() string { return proto.CompactTextString(m) } 87func (*CatalogInlineSource) ProtoMessage() {} 88func (*CatalogInlineSource) Descriptor() ([]byte, []int) { 89 return fileDescriptor_152d6e7da409eb0d, []int{1} 90} 91 92func (m *CatalogInlineSource) XXX_Unmarshal(b []byte) error { 93 return xxx_messageInfo_CatalogInlineSource.Unmarshal(m, b) 94} 95func (m *CatalogInlineSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 96 return xxx_messageInfo_CatalogInlineSource.Marshal(b, m, deterministic) 97} 98func (m *CatalogInlineSource) XXX_Merge(src proto.Message) { 99 xxx_messageInfo_CatalogInlineSource.Merge(m, src) 100} 101func (m *CatalogInlineSource) XXX_Size() int { 102 return xxx_messageInfo_CatalogInlineSource.Size(m) 103} 104func (m *CatalogInlineSource) XXX_DiscardUnknown() { 105 xxx_messageInfo_CatalogInlineSource.DiscardUnknown(m) 106} 107 108var xxx_messageInfo_CatalogInlineSource proto.InternalMessageInfo 109 110func (m *CatalogInlineSource) GetCatalogItems() []*CatalogItem { 111 if m != nil { 112 return m.CatalogItems 113 } 114 return nil 115} 116 117// The inline source for the input config for ImportUserEvents method. 118type UserEventInlineSource struct { 119 // Optional. A list of user events to import. Recommended max of 10k items. 120 UserEvents []*UserEvent `protobuf:"bytes,1,rep,name=user_events,json=userEvents,proto3" json:"user_events,omitempty"` 121 XXX_NoUnkeyedLiteral struct{} `json:"-"` 122 XXX_unrecognized []byte `json:"-"` 123 XXX_sizecache int32 `json:"-"` 124} 125 126func (m *UserEventInlineSource) Reset() { *m = UserEventInlineSource{} } 127func (m *UserEventInlineSource) String() string { return proto.CompactTextString(m) } 128func (*UserEventInlineSource) ProtoMessage() {} 129func (*UserEventInlineSource) Descriptor() ([]byte, []int) { 130 return fileDescriptor_152d6e7da409eb0d, []int{2} 131} 132 133func (m *UserEventInlineSource) XXX_Unmarshal(b []byte) error { 134 return xxx_messageInfo_UserEventInlineSource.Unmarshal(m, b) 135} 136func (m *UserEventInlineSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 137 return xxx_messageInfo_UserEventInlineSource.Marshal(b, m, deterministic) 138} 139func (m *UserEventInlineSource) XXX_Merge(src proto.Message) { 140 xxx_messageInfo_UserEventInlineSource.Merge(m, src) 141} 142func (m *UserEventInlineSource) XXX_Size() int { 143 return xxx_messageInfo_UserEventInlineSource.Size(m) 144} 145func (m *UserEventInlineSource) XXX_DiscardUnknown() { 146 xxx_messageInfo_UserEventInlineSource.DiscardUnknown(m) 147} 148 149var xxx_messageInfo_UserEventInlineSource proto.InternalMessageInfo 150 151func (m *UserEventInlineSource) GetUserEvents() []*UserEvent { 152 if m != nil { 153 return m.UserEvents 154 } 155 return nil 156} 157 158// Configuration of destination for Import related errors. 159type ImportErrorsConfig struct { 160 // Required. Errors destination. 161 // 162 // Types that are valid to be assigned to Destination: 163 // *ImportErrorsConfig_GcsPrefix 164 Destination isImportErrorsConfig_Destination `protobuf_oneof:"destination"` 165 XXX_NoUnkeyedLiteral struct{} `json:"-"` 166 XXX_unrecognized []byte `json:"-"` 167 XXX_sizecache int32 `json:"-"` 168} 169 170func (m *ImportErrorsConfig) Reset() { *m = ImportErrorsConfig{} } 171func (m *ImportErrorsConfig) String() string { return proto.CompactTextString(m) } 172func (*ImportErrorsConfig) ProtoMessage() {} 173func (*ImportErrorsConfig) Descriptor() ([]byte, []int) { 174 return fileDescriptor_152d6e7da409eb0d, []int{3} 175} 176 177func (m *ImportErrorsConfig) XXX_Unmarshal(b []byte) error { 178 return xxx_messageInfo_ImportErrorsConfig.Unmarshal(m, b) 179} 180func (m *ImportErrorsConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 181 return xxx_messageInfo_ImportErrorsConfig.Marshal(b, m, deterministic) 182} 183func (m *ImportErrorsConfig) XXX_Merge(src proto.Message) { 184 xxx_messageInfo_ImportErrorsConfig.Merge(m, src) 185} 186func (m *ImportErrorsConfig) XXX_Size() int { 187 return xxx_messageInfo_ImportErrorsConfig.Size(m) 188} 189func (m *ImportErrorsConfig) XXX_DiscardUnknown() { 190 xxx_messageInfo_ImportErrorsConfig.DiscardUnknown(m) 191} 192 193var xxx_messageInfo_ImportErrorsConfig proto.InternalMessageInfo 194 195type isImportErrorsConfig_Destination interface { 196 isImportErrorsConfig_Destination() 197} 198 199type ImportErrorsConfig_GcsPrefix struct { 200 GcsPrefix string `protobuf:"bytes,1,opt,name=gcs_prefix,json=gcsPrefix,proto3,oneof"` 201} 202 203func (*ImportErrorsConfig_GcsPrefix) isImportErrorsConfig_Destination() {} 204 205func (m *ImportErrorsConfig) GetDestination() isImportErrorsConfig_Destination { 206 if m != nil { 207 return m.Destination 208 } 209 return nil 210} 211 212func (m *ImportErrorsConfig) GetGcsPrefix() string { 213 if x, ok := m.GetDestination().(*ImportErrorsConfig_GcsPrefix); ok { 214 return x.GcsPrefix 215 } 216 return "" 217} 218 219// XXX_OneofWrappers is for the internal use of the proto package. 220func (*ImportErrorsConfig) XXX_OneofWrappers() []interface{} { 221 return []interface{}{ 222 (*ImportErrorsConfig_GcsPrefix)(nil), 223 } 224} 225 226// Request message for Import methods. 227type ImportCatalogItemsRequest struct { 228 // Required. "projects/1234/locations/global/catalogs/default_catalog" 229 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` 230 // Optional. Unique identifier provided by client, within the ancestor 231 // dataset scope. Ensures idempotency and used for request deduplication. 232 // Server-generated if unspecified. Up to 128 characters long. This is 233 // returned as google.longrunning.Operation.name in the response. 234 RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` 235 // Required. The desired input location of the data. 236 InputConfig *InputConfig `protobuf:"bytes,3,opt,name=input_config,json=inputConfig,proto3" json:"input_config,omitempty"` 237 // Optional. The desired location of errors incurred during the Import. 238 ErrorsConfig *ImportErrorsConfig `protobuf:"bytes,4,opt,name=errors_config,json=errorsConfig,proto3" json:"errors_config,omitempty"` 239 XXX_NoUnkeyedLiteral struct{} `json:"-"` 240 XXX_unrecognized []byte `json:"-"` 241 XXX_sizecache int32 `json:"-"` 242} 243 244func (m *ImportCatalogItemsRequest) Reset() { *m = ImportCatalogItemsRequest{} } 245func (m *ImportCatalogItemsRequest) String() string { return proto.CompactTextString(m) } 246func (*ImportCatalogItemsRequest) ProtoMessage() {} 247func (*ImportCatalogItemsRequest) Descriptor() ([]byte, []int) { 248 return fileDescriptor_152d6e7da409eb0d, []int{4} 249} 250 251func (m *ImportCatalogItemsRequest) XXX_Unmarshal(b []byte) error { 252 return xxx_messageInfo_ImportCatalogItemsRequest.Unmarshal(m, b) 253} 254func (m *ImportCatalogItemsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 255 return xxx_messageInfo_ImportCatalogItemsRequest.Marshal(b, m, deterministic) 256} 257func (m *ImportCatalogItemsRequest) XXX_Merge(src proto.Message) { 258 xxx_messageInfo_ImportCatalogItemsRequest.Merge(m, src) 259} 260func (m *ImportCatalogItemsRequest) XXX_Size() int { 261 return xxx_messageInfo_ImportCatalogItemsRequest.Size(m) 262} 263func (m *ImportCatalogItemsRequest) XXX_DiscardUnknown() { 264 xxx_messageInfo_ImportCatalogItemsRequest.DiscardUnknown(m) 265} 266 267var xxx_messageInfo_ImportCatalogItemsRequest proto.InternalMessageInfo 268 269func (m *ImportCatalogItemsRequest) GetParent() string { 270 if m != nil { 271 return m.Parent 272 } 273 return "" 274} 275 276func (m *ImportCatalogItemsRequest) GetRequestId() string { 277 if m != nil { 278 return m.RequestId 279 } 280 return "" 281} 282 283func (m *ImportCatalogItemsRequest) GetInputConfig() *InputConfig { 284 if m != nil { 285 return m.InputConfig 286 } 287 return nil 288} 289 290func (m *ImportCatalogItemsRequest) GetErrorsConfig() *ImportErrorsConfig { 291 if m != nil { 292 return m.ErrorsConfig 293 } 294 return nil 295} 296 297// Request message for the ImportUserEvents request. 298type ImportUserEventsRequest struct { 299 // Required. "projects/1234/locations/global/catalogs/default_catalog/eventStores/default_event_store" 300 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` 301 // Optional. Unique identifier provided by client, within the ancestor 302 // dataset scope. Ensures idempotency for expensive long running operations. 303 // Server-generated if unspecified. Up to 128 characters long. This is 304 // returned as google.longrunning.Operation.name in the response. Note that 305 // this field must not be set if the desired input config is 306 // catalog_inline_source. 307 RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` 308 // Required. The desired input location of the data. 309 InputConfig *InputConfig `protobuf:"bytes,3,opt,name=input_config,json=inputConfig,proto3" json:"input_config,omitempty"` 310 // Optional. The desired location of errors incurred during the Import. 311 ErrorsConfig *ImportErrorsConfig `protobuf:"bytes,4,opt,name=errors_config,json=errorsConfig,proto3" json:"errors_config,omitempty"` 312 XXX_NoUnkeyedLiteral struct{} `json:"-"` 313 XXX_unrecognized []byte `json:"-"` 314 XXX_sizecache int32 `json:"-"` 315} 316 317func (m *ImportUserEventsRequest) Reset() { *m = ImportUserEventsRequest{} } 318func (m *ImportUserEventsRequest) String() string { return proto.CompactTextString(m) } 319func (*ImportUserEventsRequest) ProtoMessage() {} 320func (*ImportUserEventsRequest) Descriptor() ([]byte, []int) { 321 return fileDescriptor_152d6e7da409eb0d, []int{5} 322} 323 324func (m *ImportUserEventsRequest) XXX_Unmarshal(b []byte) error { 325 return xxx_messageInfo_ImportUserEventsRequest.Unmarshal(m, b) 326} 327func (m *ImportUserEventsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 328 return xxx_messageInfo_ImportUserEventsRequest.Marshal(b, m, deterministic) 329} 330func (m *ImportUserEventsRequest) XXX_Merge(src proto.Message) { 331 xxx_messageInfo_ImportUserEventsRequest.Merge(m, src) 332} 333func (m *ImportUserEventsRequest) XXX_Size() int { 334 return xxx_messageInfo_ImportUserEventsRequest.Size(m) 335} 336func (m *ImportUserEventsRequest) XXX_DiscardUnknown() { 337 xxx_messageInfo_ImportUserEventsRequest.DiscardUnknown(m) 338} 339 340var xxx_messageInfo_ImportUserEventsRequest proto.InternalMessageInfo 341 342func (m *ImportUserEventsRequest) GetParent() string { 343 if m != nil { 344 return m.Parent 345 } 346 return "" 347} 348 349func (m *ImportUserEventsRequest) GetRequestId() string { 350 if m != nil { 351 return m.RequestId 352 } 353 return "" 354} 355 356func (m *ImportUserEventsRequest) GetInputConfig() *InputConfig { 357 if m != nil { 358 return m.InputConfig 359 } 360 return nil 361} 362 363func (m *ImportUserEventsRequest) GetErrorsConfig() *ImportErrorsConfig { 364 if m != nil { 365 return m.ErrorsConfig 366 } 367 return nil 368} 369 370// The input config source. 371type InputConfig struct { 372 // Required. The source of the input. 373 // 374 // Types that are valid to be assigned to Source: 375 // *InputConfig_CatalogInlineSource 376 // *InputConfig_GcsSource 377 // *InputConfig_UserEventInlineSource 378 Source isInputConfig_Source `protobuf_oneof:"source"` 379 XXX_NoUnkeyedLiteral struct{} `json:"-"` 380 XXX_unrecognized []byte `json:"-"` 381 XXX_sizecache int32 `json:"-"` 382} 383 384func (m *InputConfig) Reset() { *m = InputConfig{} } 385func (m *InputConfig) String() string { return proto.CompactTextString(m) } 386func (*InputConfig) ProtoMessage() {} 387func (*InputConfig) Descriptor() ([]byte, []int) { 388 return fileDescriptor_152d6e7da409eb0d, []int{6} 389} 390 391func (m *InputConfig) XXX_Unmarshal(b []byte) error { 392 return xxx_messageInfo_InputConfig.Unmarshal(m, b) 393} 394func (m *InputConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 395 return xxx_messageInfo_InputConfig.Marshal(b, m, deterministic) 396} 397func (m *InputConfig) XXX_Merge(src proto.Message) { 398 xxx_messageInfo_InputConfig.Merge(m, src) 399} 400func (m *InputConfig) XXX_Size() int { 401 return xxx_messageInfo_InputConfig.Size(m) 402} 403func (m *InputConfig) XXX_DiscardUnknown() { 404 xxx_messageInfo_InputConfig.DiscardUnknown(m) 405} 406 407var xxx_messageInfo_InputConfig proto.InternalMessageInfo 408 409type isInputConfig_Source interface { 410 isInputConfig_Source() 411} 412 413type InputConfig_CatalogInlineSource struct { 414 CatalogInlineSource *CatalogInlineSource `protobuf:"bytes,1,opt,name=catalog_inline_source,json=catalogInlineSource,proto3,oneof"` 415} 416 417type InputConfig_GcsSource struct { 418 GcsSource *GcsSource `protobuf:"bytes,2,opt,name=gcs_source,json=gcsSource,proto3,oneof"` 419} 420 421type InputConfig_UserEventInlineSource struct { 422 UserEventInlineSource *UserEventInlineSource `protobuf:"bytes,3,opt,name=user_event_inline_source,json=userEventInlineSource,proto3,oneof"` 423} 424 425func (*InputConfig_CatalogInlineSource) isInputConfig_Source() {} 426 427func (*InputConfig_GcsSource) isInputConfig_Source() {} 428 429func (*InputConfig_UserEventInlineSource) isInputConfig_Source() {} 430 431func (m *InputConfig) GetSource() isInputConfig_Source { 432 if m != nil { 433 return m.Source 434 } 435 return nil 436} 437 438func (m *InputConfig) GetCatalogInlineSource() *CatalogInlineSource { 439 if x, ok := m.GetSource().(*InputConfig_CatalogInlineSource); ok { 440 return x.CatalogInlineSource 441 } 442 return nil 443} 444 445func (m *InputConfig) GetGcsSource() *GcsSource { 446 if x, ok := m.GetSource().(*InputConfig_GcsSource); ok { 447 return x.GcsSource 448 } 449 return nil 450} 451 452func (m *InputConfig) GetUserEventInlineSource() *UserEventInlineSource { 453 if x, ok := m.GetSource().(*InputConfig_UserEventInlineSource); ok { 454 return x.UserEventInlineSource 455 } 456 return nil 457} 458 459// XXX_OneofWrappers is for the internal use of the proto package. 460func (*InputConfig) XXX_OneofWrappers() []interface{} { 461 return []interface{}{ 462 (*InputConfig_CatalogInlineSource)(nil), 463 (*InputConfig_GcsSource)(nil), 464 (*InputConfig_UserEventInlineSource)(nil), 465 } 466} 467 468// Metadata related to the progress of the Import operation. This will be 469// returned by the google.longrunning.Operation.metadata field. 470type ImportMetadata struct { 471 // Name of the operation. 472 OperationName string `protobuf:"bytes,5,opt,name=operation_name,json=operationName,proto3" json:"operation_name,omitempty"` 473 // Id of the request / operation. This is parroting back the requestId that 474 // was passed in the request. 475 RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` 476 // Operation create time. 477 CreateTime *timestamp.Timestamp `protobuf:"bytes,4,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"` 478 // Count of entries that were processed successfully. 479 SuccessCount int64 `protobuf:"varint,1,opt,name=success_count,json=successCount,proto3" json:"success_count,omitempty"` 480 // Count of entries that encountered errors while processing. 481 FailureCount int64 `protobuf:"varint,2,opt,name=failure_count,json=failureCount,proto3" json:"failure_count,omitempty"` 482 // Operation last update time. If the operation is done, this is also the 483 // finish time. 484 UpdateTime *timestamp.Timestamp `protobuf:"bytes,6,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"` 485 XXX_NoUnkeyedLiteral struct{} `json:"-"` 486 XXX_unrecognized []byte `json:"-"` 487 XXX_sizecache int32 `json:"-"` 488} 489 490func (m *ImportMetadata) Reset() { *m = ImportMetadata{} } 491func (m *ImportMetadata) String() string { return proto.CompactTextString(m) } 492func (*ImportMetadata) ProtoMessage() {} 493func (*ImportMetadata) Descriptor() ([]byte, []int) { 494 return fileDescriptor_152d6e7da409eb0d, []int{7} 495} 496 497func (m *ImportMetadata) XXX_Unmarshal(b []byte) error { 498 return xxx_messageInfo_ImportMetadata.Unmarshal(m, b) 499} 500func (m *ImportMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 501 return xxx_messageInfo_ImportMetadata.Marshal(b, m, deterministic) 502} 503func (m *ImportMetadata) XXX_Merge(src proto.Message) { 504 xxx_messageInfo_ImportMetadata.Merge(m, src) 505} 506func (m *ImportMetadata) XXX_Size() int { 507 return xxx_messageInfo_ImportMetadata.Size(m) 508} 509func (m *ImportMetadata) XXX_DiscardUnknown() { 510 xxx_messageInfo_ImportMetadata.DiscardUnknown(m) 511} 512 513var xxx_messageInfo_ImportMetadata proto.InternalMessageInfo 514 515func (m *ImportMetadata) GetOperationName() string { 516 if m != nil { 517 return m.OperationName 518 } 519 return "" 520} 521 522func (m *ImportMetadata) GetRequestId() string { 523 if m != nil { 524 return m.RequestId 525 } 526 return "" 527} 528 529func (m *ImportMetadata) GetCreateTime() *timestamp.Timestamp { 530 if m != nil { 531 return m.CreateTime 532 } 533 return nil 534} 535 536func (m *ImportMetadata) GetSuccessCount() int64 { 537 if m != nil { 538 return m.SuccessCount 539 } 540 return 0 541} 542 543func (m *ImportMetadata) GetFailureCount() int64 { 544 if m != nil { 545 return m.FailureCount 546 } 547 return 0 548} 549 550func (m *ImportMetadata) GetUpdateTime() *timestamp.Timestamp { 551 if m != nil { 552 return m.UpdateTime 553 } 554 return nil 555} 556 557// Response of the ImportCatalogItemsRequest. If the long running 558// operation is done, then this message is returned by the 559// google.longrunning.Operations.response field if the operation was successful. 560type ImportCatalogItemsResponse struct { 561 // A sample of errors encountered while processing the request. 562 ErrorSamples []*status.Status `protobuf:"bytes,1,rep,name=error_samples,json=errorSamples,proto3" json:"error_samples,omitempty"` 563 // Echoes the destination for the complete errors in the request if set. 564 ErrorsConfig *ImportErrorsConfig `protobuf:"bytes,2,opt,name=errors_config,json=errorsConfig,proto3" json:"errors_config,omitempty"` 565 XXX_NoUnkeyedLiteral struct{} `json:"-"` 566 XXX_unrecognized []byte `json:"-"` 567 XXX_sizecache int32 `json:"-"` 568} 569 570func (m *ImportCatalogItemsResponse) Reset() { *m = ImportCatalogItemsResponse{} } 571func (m *ImportCatalogItemsResponse) String() string { return proto.CompactTextString(m) } 572func (*ImportCatalogItemsResponse) ProtoMessage() {} 573func (*ImportCatalogItemsResponse) Descriptor() ([]byte, []int) { 574 return fileDescriptor_152d6e7da409eb0d, []int{8} 575} 576 577func (m *ImportCatalogItemsResponse) XXX_Unmarshal(b []byte) error { 578 return xxx_messageInfo_ImportCatalogItemsResponse.Unmarshal(m, b) 579} 580func (m *ImportCatalogItemsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 581 return xxx_messageInfo_ImportCatalogItemsResponse.Marshal(b, m, deterministic) 582} 583func (m *ImportCatalogItemsResponse) XXX_Merge(src proto.Message) { 584 xxx_messageInfo_ImportCatalogItemsResponse.Merge(m, src) 585} 586func (m *ImportCatalogItemsResponse) XXX_Size() int { 587 return xxx_messageInfo_ImportCatalogItemsResponse.Size(m) 588} 589func (m *ImportCatalogItemsResponse) XXX_DiscardUnknown() { 590 xxx_messageInfo_ImportCatalogItemsResponse.DiscardUnknown(m) 591} 592 593var xxx_messageInfo_ImportCatalogItemsResponse proto.InternalMessageInfo 594 595func (m *ImportCatalogItemsResponse) GetErrorSamples() []*status.Status { 596 if m != nil { 597 return m.ErrorSamples 598 } 599 return nil 600} 601 602func (m *ImportCatalogItemsResponse) GetErrorsConfig() *ImportErrorsConfig { 603 if m != nil { 604 return m.ErrorsConfig 605 } 606 return nil 607} 608 609// Response of the ImportUserEventsRequest. If the long running 610// operation was successful, then this message is returned by the 611// google.longrunning.Operations.response field if the operation was successful. 612type ImportUserEventsResponse struct { 613 // A sample of errors encountered while processing the request. 614 ErrorSamples []*status.Status `protobuf:"bytes,1,rep,name=error_samples,json=errorSamples,proto3" json:"error_samples,omitempty"` 615 // Echoes the destination for the complete errors if this field was set in 616 // the request. 617 ErrorsConfig *ImportErrorsConfig `protobuf:"bytes,2,opt,name=errors_config,json=errorsConfig,proto3" json:"errors_config,omitempty"` 618 // Aggregated statistics of user event import status. 619 ImportSummary *UserEventImportSummary `protobuf:"bytes,3,opt,name=import_summary,json=importSummary,proto3" json:"import_summary,omitempty"` 620 XXX_NoUnkeyedLiteral struct{} `json:"-"` 621 XXX_unrecognized []byte `json:"-"` 622 XXX_sizecache int32 `json:"-"` 623} 624 625func (m *ImportUserEventsResponse) Reset() { *m = ImportUserEventsResponse{} } 626func (m *ImportUserEventsResponse) String() string { return proto.CompactTextString(m) } 627func (*ImportUserEventsResponse) ProtoMessage() {} 628func (*ImportUserEventsResponse) Descriptor() ([]byte, []int) { 629 return fileDescriptor_152d6e7da409eb0d, []int{9} 630} 631 632func (m *ImportUserEventsResponse) XXX_Unmarshal(b []byte) error { 633 return xxx_messageInfo_ImportUserEventsResponse.Unmarshal(m, b) 634} 635func (m *ImportUserEventsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 636 return xxx_messageInfo_ImportUserEventsResponse.Marshal(b, m, deterministic) 637} 638func (m *ImportUserEventsResponse) XXX_Merge(src proto.Message) { 639 xxx_messageInfo_ImportUserEventsResponse.Merge(m, src) 640} 641func (m *ImportUserEventsResponse) XXX_Size() int { 642 return xxx_messageInfo_ImportUserEventsResponse.Size(m) 643} 644func (m *ImportUserEventsResponse) XXX_DiscardUnknown() { 645 xxx_messageInfo_ImportUserEventsResponse.DiscardUnknown(m) 646} 647 648var xxx_messageInfo_ImportUserEventsResponse proto.InternalMessageInfo 649 650func (m *ImportUserEventsResponse) GetErrorSamples() []*status.Status { 651 if m != nil { 652 return m.ErrorSamples 653 } 654 return nil 655} 656 657func (m *ImportUserEventsResponse) GetErrorsConfig() *ImportErrorsConfig { 658 if m != nil { 659 return m.ErrorsConfig 660 } 661 return nil 662} 663 664func (m *ImportUserEventsResponse) GetImportSummary() *UserEventImportSummary { 665 if m != nil { 666 return m.ImportSummary 667 } 668 return nil 669} 670 671// A summary of import result. The UserEventImportSummary summarizes 672// the import status for user events. 673type UserEventImportSummary struct { 674 // Count of user events imported with complete existing catalog information. 675 JoinedEventsCount int64 `protobuf:"varint,1,opt,name=joined_events_count,json=joinedEventsCount,proto3" json:"joined_events_count,omitempty"` 676 // Count of user events imported, but with catalog information not found 677 // in the imported catalog. 678 UnjoinedEventsCount int64 `protobuf:"varint,2,opt,name=unjoined_events_count,json=unjoinedEventsCount,proto3" json:"unjoined_events_count,omitempty"` 679 XXX_NoUnkeyedLiteral struct{} `json:"-"` 680 XXX_unrecognized []byte `json:"-"` 681 XXX_sizecache int32 `json:"-"` 682} 683 684func (m *UserEventImportSummary) Reset() { *m = UserEventImportSummary{} } 685func (m *UserEventImportSummary) String() string { return proto.CompactTextString(m) } 686func (*UserEventImportSummary) ProtoMessage() {} 687func (*UserEventImportSummary) Descriptor() ([]byte, []int) { 688 return fileDescriptor_152d6e7da409eb0d, []int{10} 689} 690 691func (m *UserEventImportSummary) XXX_Unmarshal(b []byte) error { 692 return xxx_messageInfo_UserEventImportSummary.Unmarshal(m, b) 693} 694func (m *UserEventImportSummary) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 695 return xxx_messageInfo_UserEventImportSummary.Marshal(b, m, deterministic) 696} 697func (m *UserEventImportSummary) XXX_Merge(src proto.Message) { 698 xxx_messageInfo_UserEventImportSummary.Merge(m, src) 699} 700func (m *UserEventImportSummary) XXX_Size() int { 701 return xxx_messageInfo_UserEventImportSummary.Size(m) 702} 703func (m *UserEventImportSummary) XXX_DiscardUnknown() { 704 xxx_messageInfo_UserEventImportSummary.DiscardUnknown(m) 705} 706 707var xxx_messageInfo_UserEventImportSummary proto.InternalMessageInfo 708 709func (m *UserEventImportSummary) GetJoinedEventsCount() int64 { 710 if m != nil { 711 return m.JoinedEventsCount 712 } 713 return 0 714} 715 716func (m *UserEventImportSummary) GetUnjoinedEventsCount() int64 { 717 if m != nil { 718 return m.UnjoinedEventsCount 719 } 720 return 0 721} 722 723func init() { 724 proto.RegisterType((*GcsSource)(nil), "google.cloud.recommendationengine.v1beta1.GcsSource") 725 proto.RegisterType((*CatalogInlineSource)(nil), "google.cloud.recommendationengine.v1beta1.CatalogInlineSource") 726 proto.RegisterType((*UserEventInlineSource)(nil), "google.cloud.recommendationengine.v1beta1.UserEventInlineSource") 727 proto.RegisterType((*ImportErrorsConfig)(nil), "google.cloud.recommendationengine.v1beta1.ImportErrorsConfig") 728 proto.RegisterType((*ImportCatalogItemsRequest)(nil), "google.cloud.recommendationengine.v1beta1.ImportCatalogItemsRequest") 729 proto.RegisterType((*ImportUserEventsRequest)(nil), "google.cloud.recommendationengine.v1beta1.ImportUserEventsRequest") 730 proto.RegisterType((*InputConfig)(nil), "google.cloud.recommendationengine.v1beta1.InputConfig") 731 proto.RegisterType((*ImportMetadata)(nil), "google.cloud.recommendationengine.v1beta1.ImportMetadata") 732 proto.RegisterType((*ImportCatalogItemsResponse)(nil), "google.cloud.recommendationengine.v1beta1.ImportCatalogItemsResponse") 733 proto.RegisterType((*ImportUserEventsResponse)(nil), "google.cloud.recommendationengine.v1beta1.ImportUserEventsResponse") 734 proto.RegisterType((*UserEventImportSummary)(nil), "google.cloud.recommendationengine.v1beta1.UserEventImportSummary") 735} 736 737func init() { 738 proto.RegisterFile("google/cloud/recommendationengine/v1beta1/import.proto", fileDescriptor_152d6e7da409eb0d) 739} 740 741var fileDescriptor_152d6e7da409eb0d = []byte{ 742 // 890 bytes of a gzipped FileDescriptorProto 743 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xec, 0x56, 0x51, 0x6f, 0xe3, 0x44, 744 0x10, 0xbe, 0xb8, 0x5c, 0x45, 0x26, 0x4d, 0x25, 0x5c, 0x95, 0x0b, 0x05, 0x74, 0x95, 0x11, 0xd2, 745 0x9d, 0x04, 0xb6, 0x5a, 0xd0, 0x9d, 0x94, 0x0a, 0x44, 0x13, 0xaa, 0xbb, 0x3c, 0x80, 0x4e, 0x2e, 746 0xbd, 0x87, 0x53, 0xc1, 0x6c, 0xec, 0x89, 0x6f, 0x51, 0xbc, 0x6b, 0x76, 0xd7, 0x05, 0x04, 0xbf, 747 0x84, 0x17, 0x04, 0x88, 0x17, 0xfe, 0x01, 0x7f, 0x81, 0x5f, 0x01, 0xaf, 0xfc, 0x0a, 0xe4, 0x9d, 748 0x75, 0x9a, 0xb6, 0x96, 0x48, 0x2b, 0x5e, 0x90, 0x78, 0xf4, 0xcc, 0x37, 0xf3, 0xcd, 0xcc, 0xce, 749 0x37, 0x09, 0x3c, 0xc8, 0xa5, 0xcc, 0xe7, 0x18, 0xa5, 0x73, 0x59, 0x65, 0x91, 0xc2, 0x54, 0x16, 750 0x05, 0x8a, 0x8c, 0x19, 0x2e, 0x05, 0x8a, 0x9c, 0x0b, 0x8c, 0xce, 0xf6, 0xa6, 0x68, 0xd8, 0x5e, 751 0xc4, 0x8b, 0x52, 0x2a, 0x13, 0x96, 0x4a, 0x1a, 0xe9, 0xdf, 0xa7, 0xb8, 0xd0, 0xc6, 0x85, 0x6d, 752 0x71, 0xa1, 0x8b, 0xdb, 0xb9, 0xeb, 0x28, 0x58, 0xc9, 0xa3, 0x19, 0xc7, 0x79, 0x96, 0x4c, 0xf1, 753 0x39, 0x3b, 0xe3, 0x52, 0x51, 0xae, 0x9d, 0x87, 0xab, 0xd7, 0x90, 0x32, 0xc3, 0xe6, 0x32, 0x77, 754 0x81, 0xc3, 0xd5, 0x03, 0x2b, 0x8d, 0x2a, 0xc1, 0x33, 0x14, 0xae, 0x81, 0x45, 0x55, 0xf6, 0x6b, 755 0x5a, 0xcd, 0x22, 0xc3, 0x0b, 0xd4, 0x86, 0x15, 0xa5, 0x03, 0xdc, 0x71, 0x00, 0x55, 0xa6, 0x91, 756 0x36, 0xcc, 0x54, 0xda, 0x39, 0x5e, 0x5b, 0xea, 0x87, 0x09, 0x21, 0x8d, 0xe5, 0x73, 0xde, 0x20, 757 0x82, 0xee, 0xa3, 0x54, 0x1f, 0xcb, 0x4a, 0xa5, 0xe8, 0x07, 0x00, 0x5c, 0x94, 0x95, 0x49, 0x2a, 758 0xc5, 0xf5, 0xa0, 0xb3, 0xbb, 0x76, 0xaf, 0x3b, 0x5a, 0xfb, 0xe3, 0xd0, 0x8b, 0xbb, 0xd6, 0x7c, 759 0xa2, 0xb8, 0x0e, 0xbe, 0x82, 0xad, 0x31, 0x75, 0x35, 0x11, 0x73, 0x2e, 0xd0, 0x85, 0x7e, 0x0e, 760 0x7d, 0xd7, 0x6c, 0xc2, 0x0d, 0x16, 0x14, 0xdd, 0xdb, 0x7f, 0x10, 0xae, 0x3c, 0xf8, 0xb0, 0x49, 761 0x6b, 0xb0, 0xa8, 0x59, 0x3b, 0xf1, 0x46, 0x7a, 0x6e, 0xd1, 0x81, 0x86, 0xed, 0x13, 0x8d, 0xea, 762 0xa8, 0x1e, 0xca, 0x05, 0xea, 0x67, 0xd0, 0x3b, 0x1f, 0x57, 0x43, 0xfc, 0xee, 0x35, 0x88, 0x17, 763 0x69, 0x89, 0x16, 0xaa, 0xe6, 0x5b, 0x07, 0x1f, 0x82, 0x3f, 0xb1, 0x7b, 0x74, 0xa4, 0x94, 0x54, 764 0x7a, 0x2c, 0xc5, 0x8c, 0xe7, 0xfe, 0x5d, 0x80, 0x3c, 0xd5, 0x49, 0xa9, 0x70, 0xc6, 0xbf, 0x1e, 765 0x74, 0x76, 0x3b, 0xf7, 0xba, 0x8f, 0x6f, 0xc5, 0xdd, 0x3c, 0xd5, 0x4f, 0xac, 0x69, 0xd4, 0x87, 766 0x5e, 0x86, 0xda, 0x70, 0x61, 0xe9, 0x82, 0x5f, 0x3c, 0x78, 0x85, 0xd2, 0x2c, 0xf5, 0xa8, 0x63, 767 0xfc, 0xb2, 0x42, 0x6d, 0xfc, 0x57, 0x61, 0xbd, 0x64, 0x0a, 0x85, 0xa1, 0x4c, 0x34, 0x71, 0x67, 768 0xaa, 0x9f, 0x44, 0x11, 0x2e, 0xe1, 0xd9, 0xc0, 0x6b, 0x00, 0x9d, 0xb8, 0xeb, 0xcc, 0x93, 0xcc, 769 0xff, 0x0c, 0x36, 0xe8, 0xd9, 0x52, 0x5b, 0xde, 0x60, 0x6d, 0xb7, 0x73, 0xcd, 0xd1, 0x4f, 0xea, 770 0x70, 0x6a, 0x8e, 0xe8, 0x7b, 0xfc, 0xdc, 0xe2, 0xe7, 0xd0, 0x47, 0xdb, 0x7e, 0x43, 0xf0, 0x82, 771 0x25, 0x78, 0xef, 0x3a, 0x04, 0x57, 0x86, 0xe8, 0x9e, 0x18, 0x97, 0x4c, 0xc1, 0xcf, 0x1e, 0xdc, 772 0x21, 0xe4, 0xe2, 0x49, 0xfe, 0x9f, 0xd2, 0x95, 0x29, 0xfd, 0xe9, 0x41, 0x6f, 0xa9, 0x14, 0xdf, 773 0xc0, 0xf6, 0x42, 0x7a, 0x56, 0x17, 0x89, 0xb6, 0xc2, 0xb0, 0x83, 0xea, 0xed, 0xbf, 0x7f, 0x03, 774 0x09, 0x2e, 0xc9, 0xeb, 0xf1, 0xad, 0x78, 0x2b, 0x6d, 0x11, 0xfc, 0x09, 0x69, 0xc0, 0x51, 0x79, 775 0x96, 0xea, 0x3a, 0xa2, 0x5b, 0x5c, 0x1d, 0xa7, 0x1c, 0x97, 0xf6, 0x5b, 0x18, 0x9c, 0x8b, 0xf9, 776 0x52, 0x3f, 0xf4, 0x62, 0x1f, 0xdc, 0x44, 0xd9, 0x97, 0x3a, 0xda, 0xae, 0xda, 0x1c, 0xa3, 0x17, 777 0x61, 0x9d, 0xa8, 0x82, 0xef, 0x3d, 0xd8, 0xa4, 0xd7, 0xf8, 0x08, 0x0d, 0xcb, 0x98, 0x61, 0xfe, 778 0x9b, 0xb0, 0x29, 0x4b, 0x54, 0x96, 0x26, 0x11, 0xac, 0xc0, 0xc1, 0xed, 0x7a, 0xcf, 0xe2, 0xfe, 779 0xc2, 0xfa, 0x31, 0x2b, 0xd0, 0x7f, 0xfd, 0xc2, 0x2a, 0xae, 0x59, 0xc8, 0xd2, 0x16, 0x1e, 0x40, 780 0x2f, 0x55, 0xc8, 0x0c, 0x26, 0xf5, 0x01, 0x77, 0x3b, 0xb2, 0xd3, 0xb4, 0xd4, 0x5c, 0xf7, 0xf0, 781 0x93, 0xe6, 0xba, 0xc7, 0x40, 0xf0, 0xda, 0xe0, 0xbf, 0x01, 0x7d, 0x5d, 0xa5, 0x29, 0xea, 0x7a, 782 0xc7, 0x2a, 0x27, 0x85, 0xb5, 0x78, 0xc3, 0x19, 0xc7, 0xb5, 0xad, 0x06, 0xcd, 0x18, 0x9f, 0x57, 783 0x0a, 0x1d, 0xc8, 0x23, 0x90, 0x33, 0x12, 0xe8, 0x00, 0x7a, 0x55, 0x99, 0x2d, 0xca, 0x58, 0xff, 784 0xe7, 0x32, 0x08, 0x5e, 0x1b, 0x82, 0xdf, 0x3a, 0xb0, 0xd3, 0x76, 0xce, 0x74, 0x29, 0x85, 0x46, 785 0xff, 0xa1, 0x13, 0x42, 0xa2, 0x59, 0x51, 0xce, 0xb1, 0xb9, 0xc8, 0x7e, 0x93, 0x5d, 0x95, 0x69, 786 0x78, 0x6c, 0x7f, 0xa1, 0xdc, 0x62, 0x1f, 0x13, 0xce, 0x9f, 0x5e, 0x56, 0x90, 0xf7, 0x2f, 0x28, 787 0xe8, 0x92, 0x78, 0x7e, 0xf4, 0x60, 0x70, 0xf5, 0xc4, 0xfc, 0x07, 0x2a, 0xf7, 0x9f, 0xc3, 0x26, 788 0xfd, 0xa5, 0x49, 0x74, 0x55, 0x14, 0x4c, 0x7d, 0xe3, 0xf4, 0x70, 0x78, 0x23, 0x3d, 0xd8, 0x4c, 789 0xc7, 0x94, 0x28, 0xee, 0xf3, 0xe5, 0xcf, 0xe0, 0x3b, 0x78, 0xb9, 0x1d, 0xe8, 0x87, 0xb0, 0xf5, 790 0x85, 0xe4, 0x02, 0x33, 0xf7, 0x63, 0x7b, 0x61, 0x0d, 0x5f, 0x22, 0x17, 0xcd, 0x94, 0xd6, 0x6c, 791 0x1f, 0xb6, 0x2b, 0xd1, 0x16, 0x41, 0x3b, 0xb9, 0xd5, 0x38, 0x97, 0x62, 0x46, 0x3f, 0x78, 0xf0, 792 0x76, 0x2a, 0x8b, 0xd5, 0xbb, 0x7a, 0xd2, 0x79, 0xf6, 0xa9, 0x03, 0xe7, 0x72, 0xce, 0x44, 0x1e, 793 0x4a, 0x95, 0x47, 0x39, 0x0a, 0xbb, 0xc6, 0x11, 0xb9, 0x58, 0xc9, 0xf5, 0x0a, 0x7f, 0xbc, 0x0e, 794 0xda, 0x9c, 0x3f, 0x79, 0xb7, 0xe3, 0xa3, 0xf1, 0xe1, 0xe4, 0x57, 0xef, 0xfe, 0x23, 0xe2, 0x19, 795 0xdb, 0xa2, 0xe2, 0x0b, 0xd8, 0x23, 0x2a, 0xea, 0xe9, 0xde, 0xa8, 0x4e, 0xf4, 0x7b, 0x83, 0x3d, 796 0xb5, 0xd8, 0xd3, 0x36, 0xec, 0xe9, 0x53, 0x22, 0xfd, 0xcb, 0x7b, 0x8b, 0xb0, 0xc3, 0xa1, 0x05, 797 0x0f, 0x87, 0x6d, 0xe8, 0xe1, 0xd0, 0xc1, 0xa7, 0xeb, 0xb6, 0xb1, 0x77, 0xfe, 0x0e, 0x00, 0x00, 798 0xff, 0xff, 0xf7, 0x5e, 0x91, 0xbd, 0x0d, 0x0b, 0x00, 0x00, 799} 800