1// Copyright 2020 Google LLC 2// 3// Licensed under the Apache License, Version 2.0 (the "License"); 4// you may not use this file except in compliance with the License. 5// You may obtain a copy of the License at 6// 7// http://www.apache.org/licenses/LICENSE-2.0 8// 9// Unless required by applicable law or agreed to in writing, software 10// distributed under the License is distributed on an "AS IS" BASIS, 11// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 12// See the License for the specific language governing permissions and 13// limitations under the License. 14 15// Code generated by protoc-gen-go. DO NOT EDIT. 16// versions: 17// protoc-gen-go v1.26.0 18// protoc v3.12.2 19// source: google/cloud/retail/v2/user_event_service.proto 20 21package retail 22 23import ( 24 context "context" 25 reflect "reflect" 26 sync "sync" 27 28 _ "google.golang.org/genproto/googleapis/api/annotations" 29 httpbody "google.golang.org/genproto/googleapis/api/httpbody" 30 longrunning "google.golang.org/genproto/googleapis/longrunning" 31 grpc "google.golang.org/grpc" 32 codes "google.golang.org/grpc/codes" 33 status "google.golang.org/grpc/status" 34 protoreflect "google.golang.org/protobuf/reflect/protoreflect" 35 protoimpl "google.golang.org/protobuf/runtime/protoimpl" 36) 37 38const ( 39 // Verify that this generated code is sufficiently up-to-date. 40 _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) 41 // Verify that runtime/protoimpl is sufficiently up-to-date. 42 _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) 43) 44 45// The scope of user events to be rejoined with the latest product catalog. 46// If the rejoining aims at reducing number of unjoined events, set 47// UserEventRejoinScope to UNJOINED_EVENTS. 48// If the rejoining aims at correcting product catalog information in joined 49// events, set UserEventRejoinScope to JOINED_EVENTS. 50// If all events needs to be rejoined, set UserEventRejoinScope to 51// USER_EVENT_REJOIN_SCOPE_UNSPECIFIED. 52type RejoinUserEventsRequest_UserEventRejoinScope int32 53 54const ( 55 // Rejoin all events with the latest product catalog, including both joined 56 // events and unjoined events. 57 RejoinUserEventsRequest_USER_EVENT_REJOIN_SCOPE_UNSPECIFIED RejoinUserEventsRequest_UserEventRejoinScope = 0 58 // Only rejoin joined events with the latest product catalog. 59 RejoinUserEventsRequest_JOINED_EVENTS RejoinUserEventsRequest_UserEventRejoinScope = 1 60 // Only rejoin unjoined events with the latest product catalog. 61 RejoinUserEventsRequest_UNJOINED_EVENTS RejoinUserEventsRequest_UserEventRejoinScope = 2 62) 63 64// Enum value maps for RejoinUserEventsRequest_UserEventRejoinScope. 65var ( 66 RejoinUserEventsRequest_UserEventRejoinScope_name = map[int32]string{ 67 0: "USER_EVENT_REJOIN_SCOPE_UNSPECIFIED", 68 1: "JOINED_EVENTS", 69 2: "UNJOINED_EVENTS", 70 } 71 RejoinUserEventsRequest_UserEventRejoinScope_value = map[string]int32{ 72 "USER_EVENT_REJOIN_SCOPE_UNSPECIFIED": 0, 73 "JOINED_EVENTS": 1, 74 "UNJOINED_EVENTS": 2, 75 } 76) 77 78func (x RejoinUserEventsRequest_UserEventRejoinScope) Enum() *RejoinUserEventsRequest_UserEventRejoinScope { 79 p := new(RejoinUserEventsRequest_UserEventRejoinScope) 80 *p = x 81 return p 82} 83 84func (x RejoinUserEventsRequest_UserEventRejoinScope) String() string { 85 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) 86} 87 88func (RejoinUserEventsRequest_UserEventRejoinScope) Descriptor() protoreflect.EnumDescriptor { 89 return file_google_cloud_retail_v2_user_event_service_proto_enumTypes[0].Descriptor() 90} 91 92func (RejoinUserEventsRequest_UserEventRejoinScope) Type() protoreflect.EnumType { 93 return &file_google_cloud_retail_v2_user_event_service_proto_enumTypes[0] 94} 95 96func (x RejoinUserEventsRequest_UserEventRejoinScope) Number() protoreflect.EnumNumber { 97 return protoreflect.EnumNumber(x) 98} 99 100// Deprecated: Use RejoinUserEventsRequest_UserEventRejoinScope.Descriptor instead. 101func (RejoinUserEventsRequest_UserEventRejoinScope) EnumDescriptor() ([]byte, []int) { 102 return file_google_cloud_retail_v2_user_event_service_proto_rawDescGZIP(), []int{2, 0} 103} 104 105// Request message for WriteUserEvent method. 106type WriteUserEventRequest struct { 107 state protoimpl.MessageState 108 sizeCache protoimpl.SizeCache 109 unknownFields protoimpl.UnknownFields 110 111 // Required. The parent catalog resource name, such as 112 // `projects/1234/locations/global/catalogs/default_catalog`. 113 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` 114 // Required. User event to write. 115 UserEvent *UserEvent `protobuf:"bytes,2,opt,name=user_event,json=userEvent,proto3" json:"user_event,omitempty"` 116} 117 118func (x *WriteUserEventRequest) Reset() { 119 *x = WriteUserEventRequest{} 120 if protoimpl.UnsafeEnabled { 121 mi := &file_google_cloud_retail_v2_user_event_service_proto_msgTypes[0] 122 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 123 ms.StoreMessageInfo(mi) 124 } 125} 126 127func (x *WriteUserEventRequest) String() string { 128 return protoimpl.X.MessageStringOf(x) 129} 130 131func (*WriteUserEventRequest) ProtoMessage() {} 132 133func (x *WriteUserEventRequest) ProtoReflect() protoreflect.Message { 134 mi := &file_google_cloud_retail_v2_user_event_service_proto_msgTypes[0] 135 if protoimpl.UnsafeEnabled && x != nil { 136 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 137 if ms.LoadMessageInfo() == nil { 138 ms.StoreMessageInfo(mi) 139 } 140 return ms 141 } 142 return mi.MessageOf(x) 143} 144 145// Deprecated: Use WriteUserEventRequest.ProtoReflect.Descriptor instead. 146func (*WriteUserEventRequest) Descriptor() ([]byte, []int) { 147 return file_google_cloud_retail_v2_user_event_service_proto_rawDescGZIP(), []int{0} 148} 149 150func (x *WriteUserEventRequest) GetParent() string { 151 if x != nil { 152 return x.Parent 153 } 154 return "" 155} 156 157func (x *WriteUserEventRequest) GetUserEvent() *UserEvent { 158 if x != nil { 159 return x.UserEvent 160 } 161 return nil 162} 163 164// Request message for CollectUserEvent method. 165type CollectUserEventRequest struct { 166 state protoimpl.MessageState 167 sizeCache protoimpl.SizeCache 168 unknownFields protoimpl.UnknownFields 169 170 // Required. The parent catalog name, such as 171 // `projects/1234/locations/global/catalogs/default_catalog`. 172 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` 173 // Required. URL encoded UserEvent proto with a length limit of 2,000,000 174 // characters. 175 UserEvent string `protobuf:"bytes,2,opt,name=user_event,json=userEvent,proto3" json:"user_event,omitempty"` 176 // The URL including cgi-parameters but excluding the hash fragment with a 177 // length limit of 5,000 characters. This is often more useful than the 178 // referer URL, because many browsers only send the domain for 3rd party 179 // requests. 180 Uri string `protobuf:"bytes,3,opt,name=uri,proto3" json:"uri,omitempty"` 181 // The event timestamp in milliseconds. This prevents browser caching of 182 // otherwise identical get requests. The name is abbreviated to reduce the 183 // payload bytes. 184 Ets int64 `protobuf:"varint,4,opt,name=ets,proto3" json:"ets,omitempty"` 185} 186 187func (x *CollectUserEventRequest) Reset() { 188 *x = CollectUserEventRequest{} 189 if protoimpl.UnsafeEnabled { 190 mi := &file_google_cloud_retail_v2_user_event_service_proto_msgTypes[1] 191 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 192 ms.StoreMessageInfo(mi) 193 } 194} 195 196func (x *CollectUserEventRequest) String() string { 197 return protoimpl.X.MessageStringOf(x) 198} 199 200func (*CollectUserEventRequest) ProtoMessage() {} 201 202func (x *CollectUserEventRequest) ProtoReflect() protoreflect.Message { 203 mi := &file_google_cloud_retail_v2_user_event_service_proto_msgTypes[1] 204 if protoimpl.UnsafeEnabled && x != nil { 205 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 206 if ms.LoadMessageInfo() == nil { 207 ms.StoreMessageInfo(mi) 208 } 209 return ms 210 } 211 return mi.MessageOf(x) 212} 213 214// Deprecated: Use CollectUserEventRequest.ProtoReflect.Descriptor instead. 215func (*CollectUserEventRequest) Descriptor() ([]byte, []int) { 216 return file_google_cloud_retail_v2_user_event_service_proto_rawDescGZIP(), []int{1} 217} 218 219func (x *CollectUserEventRequest) GetParent() string { 220 if x != nil { 221 return x.Parent 222 } 223 return "" 224} 225 226func (x *CollectUserEventRequest) GetUserEvent() string { 227 if x != nil { 228 return x.UserEvent 229 } 230 return "" 231} 232 233func (x *CollectUserEventRequest) GetUri() string { 234 if x != nil { 235 return x.Uri 236 } 237 return "" 238} 239 240func (x *CollectUserEventRequest) GetEts() int64 { 241 if x != nil { 242 return x.Ets 243 } 244 return 0 245} 246 247// Request message for RejoinUserEvents method. 248type RejoinUserEventsRequest struct { 249 state protoimpl.MessageState 250 sizeCache protoimpl.SizeCache 251 unknownFields protoimpl.UnknownFields 252 253 // Required. The parent catalog resource name, such as 254 // `projects/1234/locations/global/catalogs/default_catalog`. 255 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` 256 // The type of the user event rejoin to define the scope and range of the user 257 // events to be rejoined with the latest product catalog. Defaults to 258 // USER_EVENT_REJOIN_SCOPE_UNSPECIFIED if this field is not set, or set to an 259 // invalid integer value. 260 UserEventRejoinScope RejoinUserEventsRequest_UserEventRejoinScope `protobuf:"varint,2,opt,name=user_event_rejoin_scope,json=userEventRejoinScope,proto3,enum=google.cloud.retail.v2.RejoinUserEventsRequest_UserEventRejoinScope" json:"user_event_rejoin_scope,omitempty"` 261} 262 263func (x *RejoinUserEventsRequest) Reset() { 264 *x = RejoinUserEventsRequest{} 265 if protoimpl.UnsafeEnabled { 266 mi := &file_google_cloud_retail_v2_user_event_service_proto_msgTypes[2] 267 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 268 ms.StoreMessageInfo(mi) 269 } 270} 271 272func (x *RejoinUserEventsRequest) String() string { 273 return protoimpl.X.MessageStringOf(x) 274} 275 276func (*RejoinUserEventsRequest) ProtoMessage() {} 277 278func (x *RejoinUserEventsRequest) ProtoReflect() protoreflect.Message { 279 mi := &file_google_cloud_retail_v2_user_event_service_proto_msgTypes[2] 280 if protoimpl.UnsafeEnabled && x != nil { 281 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 282 if ms.LoadMessageInfo() == nil { 283 ms.StoreMessageInfo(mi) 284 } 285 return ms 286 } 287 return mi.MessageOf(x) 288} 289 290// Deprecated: Use RejoinUserEventsRequest.ProtoReflect.Descriptor instead. 291func (*RejoinUserEventsRequest) Descriptor() ([]byte, []int) { 292 return file_google_cloud_retail_v2_user_event_service_proto_rawDescGZIP(), []int{2} 293} 294 295func (x *RejoinUserEventsRequest) GetParent() string { 296 if x != nil { 297 return x.Parent 298 } 299 return "" 300} 301 302func (x *RejoinUserEventsRequest) GetUserEventRejoinScope() RejoinUserEventsRequest_UserEventRejoinScope { 303 if x != nil { 304 return x.UserEventRejoinScope 305 } 306 return RejoinUserEventsRequest_USER_EVENT_REJOIN_SCOPE_UNSPECIFIED 307} 308 309// Response message for RejoinUserEvents method. 310type RejoinUserEventsResponse struct { 311 state protoimpl.MessageState 312 sizeCache protoimpl.SizeCache 313 unknownFields protoimpl.UnknownFields 314 315 // Number of user events that were joined with latest product catalog. 316 RejoinedUserEventsCount int64 `protobuf:"varint,1,opt,name=rejoined_user_events_count,json=rejoinedUserEventsCount,proto3" json:"rejoined_user_events_count,omitempty"` 317} 318 319func (x *RejoinUserEventsResponse) Reset() { 320 *x = RejoinUserEventsResponse{} 321 if protoimpl.UnsafeEnabled { 322 mi := &file_google_cloud_retail_v2_user_event_service_proto_msgTypes[3] 323 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 324 ms.StoreMessageInfo(mi) 325 } 326} 327 328func (x *RejoinUserEventsResponse) String() string { 329 return protoimpl.X.MessageStringOf(x) 330} 331 332func (*RejoinUserEventsResponse) ProtoMessage() {} 333 334func (x *RejoinUserEventsResponse) ProtoReflect() protoreflect.Message { 335 mi := &file_google_cloud_retail_v2_user_event_service_proto_msgTypes[3] 336 if protoimpl.UnsafeEnabled && x != nil { 337 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 338 if ms.LoadMessageInfo() == nil { 339 ms.StoreMessageInfo(mi) 340 } 341 return ms 342 } 343 return mi.MessageOf(x) 344} 345 346// Deprecated: Use RejoinUserEventsResponse.ProtoReflect.Descriptor instead. 347func (*RejoinUserEventsResponse) Descriptor() ([]byte, []int) { 348 return file_google_cloud_retail_v2_user_event_service_proto_rawDescGZIP(), []int{3} 349} 350 351func (x *RejoinUserEventsResponse) GetRejoinedUserEventsCount() int64 { 352 if x != nil { 353 return x.RejoinedUserEventsCount 354 } 355 return 0 356} 357 358// Metadata for RejoinUserEvents method. 359type RejoinUserEventsMetadata struct { 360 state protoimpl.MessageState 361 sizeCache protoimpl.SizeCache 362 unknownFields protoimpl.UnknownFields 363} 364 365func (x *RejoinUserEventsMetadata) Reset() { 366 *x = RejoinUserEventsMetadata{} 367 if protoimpl.UnsafeEnabled { 368 mi := &file_google_cloud_retail_v2_user_event_service_proto_msgTypes[4] 369 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 370 ms.StoreMessageInfo(mi) 371 } 372} 373 374func (x *RejoinUserEventsMetadata) String() string { 375 return protoimpl.X.MessageStringOf(x) 376} 377 378func (*RejoinUserEventsMetadata) ProtoMessage() {} 379 380func (x *RejoinUserEventsMetadata) ProtoReflect() protoreflect.Message { 381 mi := &file_google_cloud_retail_v2_user_event_service_proto_msgTypes[4] 382 if protoimpl.UnsafeEnabled && x != nil { 383 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 384 if ms.LoadMessageInfo() == nil { 385 ms.StoreMessageInfo(mi) 386 } 387 return ms 388 } 389 return mi.MessageOf(x) 390} 391 392// Deprecated: Use RejoinUserEventsMetadata.ProtoReflect.Descriptor instead. 393func (*RejoinUserEventsMetadata) Descriptor() ([]byte, []int) { 394 return file_google_cloud_retail_v2_user_event_service_proto_rawDescGZIP(), []int{4} 395} 396 397var File_google_cloud_retail_v2_user_event_service_proto protoreflect.FileDescriptor 398 399var file_google_cloud_retail_v2_user_event_service_proto_rawDesc = []byte{ 400 0x0a, 0x2f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x72, 401 0x65, 0x74, 0x61, 0x69, 0x6c, 0x2f, 0x76, 0x32, 0x2f, 0x75, 0x73, 0x65, 0x72, 0x5f, 0x65, 0x76, 402 0x65, 0x6e, 0x74, 0x5f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 403 0x6f, 0x12, 0x16, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 404 0x72, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x2e, 0x76, 0x32, 0x1a, 0x1c, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 405 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 406 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x17, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 407 0x61, 0x70, 0x69, 0x2f, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 408 0x1a, 0x1f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x66, 0x69, 0x65, 409 0x6c, 0x64, 0x5f, 0x62, 0x65, 0x68, 0x61, 0x76, 0x69, 0x6f, 0x72, 0x2e, 0x70, 0x72, 0x6f, 0x74, 410 0x6f, 0x1a, 0x19, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x68, 0x74, 411 0x74, 0x70, 0x62, 0x6f, 0x64, 0x79, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x2a, 0x67, 0x6f, 412 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x72, 0x65, 0x74, 0x61, 0x69, 413 0x6c, 0x2f, 0x76, 0x32, 0x2f, 0x69, 0x6d, 0x70, 0x6f, 0x72, 0x74, 0x5f, 0x63, 0x6f, 0x6e, 0x66, 414 0x69, 0x67, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x29, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 415 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x72, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x2f, 0x76, 0x32, 416 0x2f, 0x70, 0x75, 0x72, 0x67, 0x65, 0x5f, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x2e, 0x70, 0x72, 417 0x6f, 0x74, 0x6f, 0x1a, 0x27, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 418 0x64, 0x2f, 0x72, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x2f, 0x76, 0x32, 0x2f, 0x75, 0x73, 0x65, 0x72, 419 0x5f, 0x65, 0x76, 0x65, 0x6e, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x23, 0x67, 0x6f, 420 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x6c, 0x6f, 0x6e, 0x67, 0x72, 0x75, 0x6e, 0x6e, 0x69, 0x6e, 0x67, 421 0x2f, 0x6f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 422 0x6f, 0x22, 0x7b, 0x0a, 0x15, 0x57, 0x72, 0x69, 0x74, 0x65, 0x55, 0x73, 0x65, 0x72, 0x45, 0x76, 423 0x65, 0x6e, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1b, 0x0a, 0x06, 0x70, 0x61, 424 0x72, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x03, 0xe0, 0x41, 0x02, 0x52, 425 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x45, 0x0a, 0x0a, 0x75, 0x73, 0x65, 0x72, 0x5f, 426 0x65, 0x76, 0x65, 0x6e, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x21, 0x2e, 0x67, 0x6f, 427 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x72, 0x65, 0x74, 0x61, 0x69, 428 0x6c, 0x2e, 0x76, 0x32, 0x2e, 0x55, 0x73, 0x65, 0x72, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x42, 0x03, 429 0xe0, 0x41, 0x02, 0x52, 0x09, 0x75, 0x73, 0x65, 0x72, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x22, 0x7e, 430 0x0a, 0x17, 0x43, 0x6f, 0x6c, 0x6c, 0x65, 0x63, 0x74, 0x55, 0x73, 0x65, 0x72, 0x45, 0x76, 0x65, 431 0x6e, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1b, 0x0a, 0x06, 0x70, 0x61, 0x72, 432 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x03, 0xe0, 0x41, 0x02, 0x52, 0x06, 433 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x22, 0x0a, 0x0a, 0x75, 0x73, 0x65, 0x72, 0x5f, 0x65, 434 0x76, 0x65, 0x6e, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x42, 0x03, 0xe0, 0x41, 0x02, 0x52, 435 0x09, 0x75, 0x73, 0x65, 0x72, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x12, 0x10, 0x0a, 0x03, 0x75, 0x72, 436 0x69, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x75, 0x72, 0x69, 0x12, 0x10, 0x0a, 0x03, 437 0x65, 0x74, 0x73, 0x18, 0x04, 0x20, 0x01, 0x28, 0x03, 0x52, 0x03, 0x65, 0x74, 0x73, 0x22, 0x9c, 438 0x02, 0x0a, 0x17, 0x52, 0x65, 0x6a, 0x6f, 0x69, 0x6e, 0x55, 0x73, 0x65, 0x72, 0x45, 0x76, 0x65, 439 0x6e, 0x74, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1b, 0x0a, 0x06, 0x70, 0x61, 440 0x72, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x03, 0xe0, 0x41, 0x02, 0x52, 441 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x7b, 0x0a, 0x17, 0x75, 0x73, 0x65, 0x72, 0x5f, 442 0x65, 0x76, 0x65, 0x6e, 0x74, 0x5f, 0x72, 0x65, 0x6a, 0x6f, 0x69, 0x6e, 0x5f, 0x73, 0x63, 0x6f, 443 0x70, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x44, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 444 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x72, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x2e, 0x76, 445 0x32, 0x2e, 0x52, 0x65, 0x6a, 0x6f, 0x69, 0x6e, 0x55, 0x73, 0x65, 0x72, 0x45, 0x76, 0x65, 0x6e, 446 0x74, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x55, 0x73, 0x65, 0x72, 0x45, 0x76, 447 0x65, 0x6e, 0x74, 0x52, 0x65, 0x6a, 0x6f, 0x69, 0x6e, 0x53, 0x63, 0x6f, 0x70, 0x65, 0x52, 0x14, 448 0x75, 0x73, 0x65, 0x72, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x52, 0x65, 0x6a, 0x6f, 0x69, 0x6e, 0x53, 449 0x63, 0x6f, 0x70, 0x65, 0x22, 0x67, 0x0a, 0x14, 0x55, 0x73, 0x65, 0x72, 0x45, 0x76, 0x65, 0x6e, 450 0x74, 0x52, 0x65, 0x6a, 0x6f, 0x69, 0x6e, 0x53, 0x63, 0x6f, 0x70, 0x65, 0x12, 0x27, 0x0a, 0x23, 451 0x55, 0x53, 0x45, 0x52, 0x5f, 0x45, 0x56, 0x45, 0x4e, 0x54, 0x5f, 0x52, 0x45, 0x4a, 0x4f, 0x49, 452 0x4e, 0x5f, 0x53, 0x43, 0x4f, 0x50, 0x45, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 453 0x49, 0x45, 0x44, 0x10, 0x00, 0x12, 0x11, 0x0a, 0x0d, 0x4a, 0x4f, 0x49, 0x4e, 0x45, 0x44, 0x5f, 454 0x45, 0x56, 0x45, 0x4e, 0x54, 0x53, 0x10, 0x01, 0x12, 0x13, 0x0a, 0x0f, 0x55, 0x4e, 0x4a, 0x4f, 455 0x49, 0x4e, 0x45, 0x44, 0x5f, 0x45, 0x56, 0x45, 0x4e, 0x54, 0x53, 0x10, 0x02, 0x22, 0x57, 0x0a, 456 0x18, 0x52, 0x65, 0x6a, 0x6f, 0x69, 0x6e, 0x55, 0x73, 0x65, 0x72, 0x45, 0x76, 0x65, 0x6e, 0x74, 457 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x3b, 0x0a, 0x1a, 0x72, 0x65, 0x6a, 458 0x6f, 0x69, 0x6e, 0x65, 0x64, 0x5f, 0x75, 0x73, 0x65, 0x72, 0x5f, 0x65, 0x76, 0x65, 0x6e, 0x74, 459 0x73, 0x5f, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x17, 0x72, 460 0x65, 0x6a, 0x6f, 0x69, 0x6e, 0x65, 0x64, 0x55, 0x73, 0x65, 0x72, 0x45, 0x76, 0x65, 0x6e, 0x74, 461 0x73, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x22, 0x1a, 0x0a, 0x18, 0x52, 0x65, 0x6a, 0x6f, 0x69, 0x6e, 462 0x55, 0x73, 0x65, 0x72, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x73, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 463 0x74, 0x61, 0x32, 0xbf, 0x09, 0x0a, 0x10, 0x55, 0x73, 0x65, 0x72, 0x45, 0x76, 0x65, 0x6e, 0x74, 464 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0xb7, 0x01, 0x0a, 0x0e, 0x57, 0x72, 0x69, 0x74, 465 0x65, 0x55, 0x73, 0x65, 0x72, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x12, 0x2d, 0x2e, 0x67, 0x6f, 0x6f, 466 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x72, 0x65, 0x74, 0x61, 0x69, 0x6c, 467 0x2e, 0x76, 0x32, 0x2e, 0x57, 0x72, 0x69, 0x74, 0x65, 0x55, 0x73, 0x65, 0x72, 0x45, 0x76, 0x65, 468 0x6e, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x21, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 469 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x72, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x2e, 470 0x76, 0x32, 0x2e, 0x55, 0x73, 0x65, 0x72, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x22, 0x53, 0x82, 0xd3, 471 0xe4, 0x93, 0x02, 0x4d, 0x22, 0x3f, 0x2f, 0x76, 0x32, 0x2f, 0x7b, 0x70, 0x61, 0x72, 0x65, 0x6e, 472 0x74, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 473 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x63, 0x61, 0x74, 0x61, 0x6c, 0x6f, 0x67, 474 0x73, 0x2f, 0x2a, 0x7d, 0x2f, 0x75, 0x73, 0x65, 0x72, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x73, 0x3a, 475 0x77, 0x72, 0x69, 0x74, 0x65, 0x3a, 0x0a, 0x75, 0x73, 0x65, 0x72, 0x5f, 0x65, 0x76, 0x65, 0x6e, 476 0x74, 0x12, 0xa4, 0x01, 0x0a, 0x10, 0x43, 0x6f, 0x6c, 0x6c, 0x65, 0x63, 0x74, 0x55, 0x73, 0x65, 477 0x72, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x12, 0x2f, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 478 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x72, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x2e, 0x76, 0x32, 0x2e, 479 0x43, 0x6f, 0x6c, 0x6c, 0x65, 0x63, 0x74, 0x55, 0x73, 0x65, 0x72, 0x45, 0x76, 0x65, 0x6e, 0x74, 480 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x14, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 481 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x48, 0x74, 0x74, 0x70, 0x42, 0x6f, 0x64, 0x79, 0x22, 0x49, 0x82, 482 0xd3, 0xe4, 0x93, 0x02, 0x43, 0x12, 0x41, 0x2f, 0x76, 0x32, 0x2f, 0x7b, 0x70, 0x61, 0x72, 0x65, 483 0x6e, 0x74, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 484 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x63, 0x61, 0x74, 0x61, 0x6c, 0x6f, 485 0x67, 0x73, 0x2f, 0x2a, 0x7d, 0x2f, 0x75, 0x73, 0x65, 0x72, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x73, 486 0x3a, 0x63, 0x6f, 0x6c, 0x6c, 0x65, 0x63, 0x74, 0x12, 0x86, 0x02, 0x0a, 0x0f, 0x50, 0x75, 0x72, 487 0x67, 0x65, 0x55, 0x73, 0x65, 0x72, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x73, 0x12, 0x2e, 0x2e, 0x67, 488 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x72, 0x65, 0x74, 0x61, 489 0x69, 0x6c, 0x2e, 0x76, 0x32, 0x2e, 0x50, 0x75, 0x72, 0x67, 0x65, 0x55, 0x73, 0x65, 0x72, 0x45, 490 0x76, 0x65, 0x6e, 0x74, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1d, 0x2e, 0x67, 491 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x6c, 0x6f, 0x6e, 0x67, 0x72, 0x75, 0x6e, 0x6e, 0x69, 0x6e, 492 0x67, 0x2e, 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x22, 0xa3, 0x01, 0x82, 0xd3, 493 0xe4, 0x93, 0x02, 0x44, 0x22, 0x3f, 0x2f, 0x76, 0x32, 0x2f, 0x7b, 0x70, 0x61, 0x72, 0x65, 0x6e, 494 0x74, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 495 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x63, 0x61, 0x74, 0x61, 0x6c, 0x6f, 0x67, 496 0x73, 0x2f, 0x2a, 0x7d, 0x2f, 0x75, 0x73, 0x65, 0x72, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x73, 0x3a, 497 0x70, 0x75, 0x72, 0x67, 0x65, 0x3a, 0x01, 0x2a, 0xca, 0x41, 0x56, 0x0a, 0x2e, 0x67, 0x6f, 0x6f, 498 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x72, 0x65, 0x74, 0x61, 0x69, 0x6c, 499 0x2e, 0x76, 0x32, 0x2e, 0x50, 0x75, 0x72, 0x67, 0x65, 0x55, 0x73, 0x65, 0x72, 0x45, 0x76, 0x65, 500 0x6e, 0x74, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x24, 0x67, 0x6f, 0x6f, 501 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x72, 0x65, 0x74, 0x61, 0x69, 0x6c, 502 0x2e, 0x76, 0x32, 0x2e, 0x50, 0x75, 0x72, 0x67, 0x65, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 503 0x61, 0x12, 0x8b, 0x02, 0x0a, 0x10, 0x49, 0x6d, 0x70, 0x6f, 0x72, 0x74, 0x55, 0x73, 0x65, 0x72, 504 0x45, 0x76, 0x65, 0x6e, 0x74, 0x73, 0x12, 0x2f, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 505 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x72, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x2e, 0x76, 0x32, 0x2e, 506 0x49, 0x6d, 0x70, 0x6f, 0x72, 0x74, 0x55, 0x73, 0x65, 0x72, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x73, 507 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 508 0x2e, 0x6c, 0x6f, 0x6e, 0x67, 0x72, 0x75, 0x6e, 0x6e, 0x69, 0x6e, 0x67, 0x2e, 0x4f, 0x70, 0x65, 509 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x22, 0xa6, 0x01, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x45, 0x22, 510 0x40, 0x2f, 0x76, 0x32, 0x2f, 0x7b, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x3d, 0x70, 0x72, 0x6f, 511 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 512 0x73, 0x2f, 0x2a, 0x2f, 0x63, 0x61, 0x74, 0x61, 0x6c, 0x6f, 0x67, 0x73, 0x2f, 0x2a, 0x7d, 0x2f, 513 0x75, 0x73, 0x65, 0x72, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x73, 0x3a, 0x69, 0x6d, 0x70, 0x6f, 0x72, 514 0x74, 0x3a, 0x01, 0x2a, 0xca, 0x41, 0x58, 0x0a, 0x2f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 515 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x72, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x2e, 0x76, 0x32, 0x2e, 516 0x49, 0x6d, 0x70, 0x6f, 0x72, 0x74, 0x55, 0x73, 0x65, 0x72, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x73, 517 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x25, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 518 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x72, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x2e, 0x76, 0x32, 519 0x2e, 0x49, 0x6d, 0x70, 0x6f, 0x72, 0x74, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x12, 520 0xe7, 0x01, 0x0a, 0x10, 0x52, 0x65, 0x6a, 0x6f, 0x69, 0x6e, 0x55, 0x73, 0x65, 0x72, 0x45, 0x76, 521 0x65, 0x6e, 0x74, 0x73, 0x12, 0x2f, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 522 0x6f, 0x75, 0x64, 0x2e, 0x72, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x2e, 0x76, 0x32, 0x2e, 0x52, 0x65, 523 0x6a, 0x6f, 0x69, 0x6e, 0x55, 0x73, 0x65, 0x72, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x73, 0x52, 0x65, 524 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x6c, 525 0x6f, 0x6e, 0x67, 0x72, 0x75, 0x6e, 0x6e, 0x69, 0x6e, 0x67, 0x2e, 0x4f, 0x70, 0x65, 0x72, 0x61, 526 0x74, 0x69, 0x6f, 0x6e, 0x22, 0x82, 0x01, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x45, 0x22, 0x40, 0x2f, 527 0x76, 0x32, 0x2f, 0x7b, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 528 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 529 0x2a, 0x2f, 0x63, 0x61, 0x74, 0x61, 0x6c, 0x6f, 0x67, 0x73, 0x2f, 0x2a, 0x7d, 0x2f, 0x75, 0x73, 530 0x65, 0x72, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x73, 0x3a, 0x72, 0x65, 0x6a, 0x6f, 0x69, 0x6e, 0x3a, 531 0x01, 0x2a, 0xca, 0x41, 0x34, 0x0a, 0x18, 0x52, 0x65, 0x6a, 0x6f, 0x69, 0x6e, 0x55, 0x73, 0x65, 532 0x72, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 533 0x18, 0x52, 0x65, 0x6a, 0x6f, 0x69, 0x6e, 0x55, 0x73, 0x65, 0x72, 0x45, 0x76, 0x65, 0x6e, 0x74, 534 0x73, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x1a, 0x49, 0xca, 0x41, 0x15, 0x72, 0x65, 535 0x74, 0x61, 0x69, 0x6c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 536 0x63, 0x6f, 0x6d, 0xd2, 0x41, 0x2e, 0x68, 0x74, 0x74, 0x70, 0x73, 0x3a, 0x2f, 0x2f, 0x77, 0x77, 537 0x77, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 538 0x2f, 0x61, 0x75, 0x74, 0x68, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2d, 0x70, 0x6c, 0x61, 0x74, 539 0x66, 0x6f, 0x72, 0x6d, 0x42, 0xca, 0x01, 0x0a, 0x1a, 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x6f, 0x6f, 540 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x72, 0x65, 0x74, 0x61, 0x69, 0x6c, 541 0x2e, 0x76, 0x32, 0x42, 0x15, 0x55, 0x73, 0x65, 0x72, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x53, 0x65, 542 0x72, 0x76, 0x69, 0x63, 0x65, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x5a, 0x3c, 0x67, 0x6f, 543 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x6f, 0x6c, 0x61, 0x6e, 0x67, 0x2e, 0x6f, 0x72, 0x67, 0x2f, 544 0x67, 0x65, 0x6e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 545 0x70, 0x69, 0x73, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x72, 0x65, 0x74, 0x61, 0x69, 0x6c, 546 0x2f, 0x76, 0x32, 0x3b, 0x72, 0x65, 0x74, 0x61, 0x69, 0x6c, 0xa2, 0x02, 0x06, 0x52, 0x45, 0x54, 547 0x41, 0x49, 0x4c, 0xaa, 0x02, 0x16, 0x47, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x43, 0x6c, 0x6f, 548 0x75, 0x64, 0x2e, 0x52, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x2e, 0x56, 0x32, 0xca, 0x02, 0x16, 0x47, 549 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x5c, 0x43, 0x6c, 0x6f, 0x75, 0x64, 0x5c, 0x52, 0x65, 0x74, 0x61, 550 0x69, 0x6c, 0x5c, 0x56, 0x32, 0xea, 0x02, 0x19, 0x47, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x3a, 0x3a, 551 0x43, 0x6c, 0x6f, 0x75, 0x64, 0x3a, 0x3a, 0x52, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x3a, 0x3a, 0x56, 552 0x32, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, 553} 554 555var ( 556 file_google_cloud_retail_v2_user_event_service_proto_rawDescOnce sync.Once 557 file_google_cloud_retail_v2_user_event_service_proto_rawDescData = file_google_cloud_retail_v2_user_event_service_proto_rawDesc 558) 559 560func file_google_cloud_retail_v2_user_event_service_proto_rawDescGZIP() []byte { 561 file_google_cloud_retail_v2_user_event_service_proto_rawDescOnce.Do(func() { 562 file_google_cloud_retail_v2_user_event_service_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_cloud_retail_v2_user_event_service_proto_rawDescData) 563 }) 564 return file_google_cloud_retail_v2_user_event_service_proto_rawDescData 565} 566 567var file_google_cloud_retail_v2_user_event_service_proto_enumTypes = make([]protoimpl.EnumInfo, 1) 568var file_google_cloud_retail_v2_user_event_service_proto_msgTypes = make([]protoimpl.MessageInfo, 5) 569var file_google_cloud_retail_v2_user_event_service_proto_goTypes = []interface{}{ 570 (RejoinUserEventsRequest_UserEventRejoinScope)(0), // 0: google.cloud.retail.v2.RejoinUserEventsRequest.UserEventRejoinScope 571 (*WriteUserEventRequest)(nil), // 1: google.cloud.retail.v2.WriteUserEventRequest 572 (*CollectUserEventRequest)(nil), // 2: google.cloud.retail.v2.CollectUserEventRequest 573 (*RejoinUserEventsRequest)(nil), // 3: google.cloud.retail.v2.RejoinUserEventsRequest 574 (*RejoinUserEventsResponse)(nil), // 4: google.cloud.retail.v2.RejoinUserEventsResponse 575 (*RejoinUserEventsMetadata)(nil), // 5: google.cloud.retail.v2.RejoinUserEventsMetadata 576 (*UserEvent)(nil), // 6: google.cloud.retail.v2.UserEvent 577 (*PurgeUserEventsRequest)(nil), // 7: google.cloud.retail.v2.PurgeUserEventsRequest 578 (*ImportUserEventsRequest)(nil), // 8: google.cloud.retail.v2.ImportUserEventsRequest 579 (*httpbody.HttpBody)(nil), // 9: google.api.HttpBody 580 (*longrunning.Operation)(nil), // 10: google.longrunning.Operation 581} 582var file_google_cloud_retail_v2_user_event_service_proto_depIdxs = []int32{ 583 6, // 0: google.cloud.retail.v2.WriteUserEventRequest.user_event:type_name -> google.cloud.retail.v2.UserEvent 584 0, // 1: google.cloud.retail.v2.RejoinUserEventsRequest.user_event_rejoin_scope:type_name -> google.cloud.retail.v2.RejoinUserEventsRequest.UserEventRejoinScope 585 1, // 2: google.cloud.retail.v2.UserEventService.WriteUserEvent:input_type -> google.cloud.retail.v2.WriteUserEventRequest 586 2, // 3: google.cloud.retail.v2.UserEventService.CollectUserEvent:input_type -> google.cloud.retail.v2.CollectUserEventRequest 587 7, // 4: google.cloud.retail.v2.UserEventService.PurgeUserEvents:input_type -> google.cloud.retail.v2.PurgeUserEventsRequest 588 8, // 5: google.cloud.retail.v2.UserEventService.ImportUserEvents:input_type -> google.cloud.retail.v2.ImportUserEventsRequest 589 3, // 6: google.cloud.retail.v2.UserEventService.RejoinUserEvents:input_type -> google.cloud.retail.v2.RejoinUserEventsRequest 590 6, // 7: google.cloud.retail.v2.UserEventService.WriteUserEvent:output_type -> google.cloud.retail.v2.UserEvent 591 9, // 8: google.cloud.retail.v2.UserEventService.CollectUserEvent:output_type -> google.api.HttpBody 592 10, // 9: google.cloud.retail.v2.UserEventService.PurgeUserEvents:output_type -> google.longrunning.Operation 593 10, // 10: google.cloud.retail.v2.UserEventService.ImportUserEvents:output_type -> google.longrunning.Operation 594 10, // 11: google.cloud.retail.v2.UserEventService.RejoinUserEvents:output_type -> google.longrunning.Operation 595 7, // [7:12] is the sub-list for method output_type 596 2, // [2:7] is the sub-list for method input_type 597 2, // [2:2] is the sub-list for extension type_name 598 2, // [2:2] is the sub-list for extension extendee 599 0, // [0:2] is the sub-list for field type_name 600} 601 602func init() { file_google_cloud_retail_v2_user_event_service_proto_init() } 603func file_google_cloud_retail_v2_user_event_service_proto_init() { 604 if File_google_cloud_retail_v2_user_event_service_proto != nil { 605 return 606 } 607 file_google_cloud_retail_v2_import_config_proto_init() 608 file_google_cloud_retail_v2_purge_config_proto_init() 609 file_google_cloud_retail_v2_user_event_proto_init() 610 if !protoimpl.UnsafeEnabled { 611 file_google_cloud_retail_v2_user_event_service_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { 612 switch v := v.(*WriteUserEventRequest); i { 613 case 0: 614 return &v.state 615 case 1: 616 return &v.sizeCache 617 case 2: 618 return &v.unknownFields 619 default: 620 return nil 621 } 622 } 623 file_google_cloud_retail_v2_user_event_service_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { 624 switch v := v.(*CollectUserEventRequest); i { 625 case 0: 626 return &v.state 627 case 1: 628 return &v.sizeCache 629 case 2: 630 return &v.unknownFields 631 default: 632 return nil 633 } 634 } 635 file_google_cloud_retail_v2_user_event_service_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { 636 switch v := v.(*RejoinUserEventsRequest); i { 637 case 0: 638 return &v.state 639 case 1: 640 return &v.sizeCache 641 case 2: 642 return &v.unknownFields 643 default: 644 return nil 645 } 646 } 647 file_google_cloud_retail_v2_user_event_service_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { 648 switch v := v.(*RejoinUserEventsResponse); i { 649 case 0: 650 return &v.state 651 case 1: 652 return &v.sizeCache 653 case 2: 654 return &v.unknownFields 655 default: 656 return nil 657 } 658 } 659 file_google_cloud_retail_v2_user_event_service_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { 660 switch v := v.(*RejoinUserEventsMetadata); i { 661 case 0: 662 return &v.state 663 case 1: 664 return &v.sizeCache 665 case 2: 666 return &v.unknownFields 667 default: 668 return nil 669 } 670 } 671 } 672 type x struct{} 673 out := protoimpl.TypeBuilder{ 674 File: protoimpl.DescBuilder{ 675 GoPackagePath: reflect.TypeOf(x{}).PkgPath(), 676 RawDescriptor: file_google_cloud_retail_v2_user_event_service_proto_rawDesc, 677 NumEnums: 1, 678 NumMessages: 5, 679 NumExtensions: 0, 680 NumServices: 1, 681 }, 682 GoTypes: file_google_cloud_retail_v2_user_event_service_proto_goTypes, 683 DependencyIndexes: file_google_cloud_retail_v2_user_event_service_proto_depIdxs, 684 EnumInfos: file_google_cloud_retail_v2_user_event_service_proto_enumTypes, 685 MessageInfos: file_google_cloud_retail_v2_user_event_service_proto_msgTypes, 686 }.Build() 687 File_google_cloud_retail_v2_user_event_service_proto = out.File 688 file_google_cloud_retail_v2_user_event_service_proto_rawDesc = nil 689 file_google_cloud_retail_v2_user_event_service_proto_goTypes = nil 690 file_google_cloud_retail_v2_user_event_service_proto_depIdxs = nil 691} 692 693// Reference imports to suppress errors if they are not otherwise used. 694var _ context.Context 695var _ grpc.ClientConnInterface 696 697// This is a compile-time assertion to ensure that this generated file 698// is compatible with the grpc package it is being compiled against. 699const _ = grpc.SupportPackageIsVersion6 700 701// UserEventServiceClient is the client API for UserEventService service. 702// 703// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 704type UserEventServiceClient interface { 705 // Writes a single user event. 706 WriteUserEvent(ctx context.Context, in *WriteUserEventRequest, opts ...grpc.CallOption) (*UserEvent, error) 707 // Writes a single user event from the browser. This uses a GET request to 708 // due to browser restriction of POST-ing to a 3rd party domain. 709 // 710 // This method is used only by the Retail API JavaScript pixel and Google Tag 711 // Manager. Users should not call this method directly. 712 CollectUserEvent(ctx context.Context, in *CollectUserEventRequest, opts ...grpc.CallOption) (*httpbody.HttpBody, error) 713 // Deletes permanently all user events specified by the filter provided. 714 // Depending on the number of events specified by the filter, this operation 715 // could take hours or days to complete. To test a filter, use the list 716 // command first. 717 PurgeUserEvents(ctx context.Context, in *PurgeUserEventsRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) 718 // Bulk import of User events. Request processing might be 719 // synchronous. Events that already exist are skipped. 720 // Use this method for backfilling historical user events. 721 // 722 // Operation.response is of type ImportResponse. Note that it is 723 // possible for a subset of the items to be successfully inserted. 724 // Operation.metadata is of type ImportMetadata. 725 ImportUserEvents(ctx context.Context, in *ImportUserEventsRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) 726 // Triggers a user event rejoin operation with latest product catalog. Events 727 // will not be annotated with detailed product information if product is 728 // missing from the catalog at the time the user event is ingested, and these 729 // events are stored as unjoined events with a limited usage on training and 730 // serving. This API can be used to trigger a 'join' operation on specified 731 // events with latest version of product catalog. It can also be used to 732 // correct events joined with wrong product catalog. 733 RejoinUserEvents(ctx context.Context, in *RejoinUserEventsRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) 734} 735 736type userEventServiceClient struct { 737 cc grpc.ClientConnInterface 738} 739 740func NewUserEventServiceClient(cc grpc.ClientConnInterface) UserEventServiceClient { 741 return &userEventServiceClient{cc} 742} 743 744func (c *userEventServiceClient) WriteUserEvent(ctx context.Context, in *WriteUserEventRequest, opts ...grpc.CallOption) (*UserEvent, error) { 745 out := new(UserEvent) 746 err := c.cc.Invoke(ctx, "/google.cloud.retail.v2.UserEventService/WriteUserEvent", in, out, opts...) 747 if err != nil { 748 return nil, err 749 } 750 return out, nil 751} 752 753func (c *userEventServiceClient) CollectUserEvent(ctx context.Context, in *CollectUserEventRequest, opts ...grpc.CallOption) (*httpbody.HttpBody, error) { 754 out := new(httpbody.HttpBody) 755 err := c.cc.Invoke(ctx, "/google.cloud.retail.v2.UserEventService/CollectUserEvent", in, out, opts...) 756 if err != nil { 757 return nil, err 758 } 759 return out, nil 760} 761 762func (c *userEventServiceClient) PurgeUserEvents(ctx context.Context, in *PurgeUserEventsRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) { 763 out := new(longrunning.Operation) 764 err := c.cc.Invoke(ctx, "/google.cloud.retail.v2.UserEventService/PurgeUserEvents", in, out, opts...) 765 if err != nil { 766 return nil, err 767 } 768 return out, nil 769} 770 771func (c *userEventServiceClient) ImportUserEvents(ctx context.Context, in *ImportUserEventsRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) { 772 out := new(longrunning.Operation) 773 err := c.cc.Invoke(ctx, "/google.cloud.retail.v2.UserEventService/ImportUserEvents", in, out, opts...) 774 if err != nil { 775 return nil, err 776 } 777 return out, nil 778} 779 780func (c *userEventServiceClient) RejoinUserEvents(ctx context.Context, in *RejoinUserEventsRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) { 781 out := new(longrunning.Operation) 782 err := c.cc.Invoke(ctx, "/google.cloud.retail.v2.UserEventService/RejoinUserEvents", in, out, opts...) 783 if err != nil { 784 return nil, err 785 } 786 return out, nil 787} 788 789// UserEventServiceServer is the server API for UserEventService service. 790type UserEventServiceServer interface { 791 // Writes a single user event. 792 WriteUserEvent(context.Context, *WriteUserEventRequest) (*UserEvent, error) 793 // Writes a single user event from the browser. This uses a GET request to 794 // due to browser restriction of POST-ing to a 3rd party domain. 795 // 796 // This method is used only by the Retail API JavaScript pixel and Google Tag 797 // Manager. Users should not call this method directly. 798 CollectUserEvent(context.Context, *CollectUserEventRequest) (*httpbody.HttpBody, error) 799 // Deletes permanently all user events specified by the filter provided. 800 // Depending on the number of events specified by the filter, this operation 801 // could take hours or days to complete. To test a filter, use the list 802 // command first. 803 PurgeUserEvents(context.Context, *PurgeUserEventsRequest) (*longrunning.Operation, error) 804 // Bulk import of User events. Request processing might be 805 // synchronous. Events that already exist are skipped. 806 // Use this method for backfilling historical user events. 807 // 808 // Operation.response is of type ImportResponse. Note that it is 809 // possible for a subset of the items to be successfully inserted. 810 // Operation.metadata is of type ImportMetadata. 811 ImportUserEvents(context.Context, *ImportUserEventsRequest) (*longrunning.Operation, error) 812 // Triggers a user event rejoin operation with latest product catalog. Events 813 // will not be annotated with detailed product information if product is 814 // missing from the catalog at the time the user event is ingested, and these 815 // events are stored as unjoined events with a limited usage on training and 816 // serving. This API can be used to trigger a 'join' operation on specified 817 // events with latest version of product catalog. It can also be used to 818 // correct events joined with wrong product catalog. 819 RejoinUserEvents(context.Context, *RejoinUserEventsRequest) (*longrunning.Operation, error) 820} 821 822// UnimplementedUserEventServiceServer can be embedded to have forward compatible implementations. 823type UnimplementedUserEventServiceServer struct { 824} 825 826func (*UnimplementedUserEventServiceServer) WriteUserEvent(context.Context, *WriteUserEventRequest) (*UserEvent, error) { 827 return nil, status.Errorf(codes.Unimplemented, "method WriteUserEvent not implemented") 828} 829func (*UnimplementedUserEventServiceServer) CollectUserEvent(context.Context, *CollectUserEventRequest) (*httpbody.HttpBody, error) { 830 return nil, status.Errorf(codes.Unimplemented, "method CollectUserEvent not implemented") 831} 832func (*UnimplementedUserEventServiceServer) PurgeUserEvents(context.Context, *PurgeUserEventsRequest) (*longrunning.Operation, error) { 833 return nil, status.Errorf(codes.Unimplemented, "method PurgeUserEvents not implemented") 834} 835func (*UnimplementedUserEventServiceServer) ImportUserEvents(context.Context, *ImportUserEventsRequest) (*longrunning.Operation, error) { 836 return nil, status.Errorf(codes.Unimplemented, "method ImportUserEvents not implemented") 837} 838func (*UnimplementedUserEventServiceServer) RejoinUserEvents(context.Context, *RejoinUserEventsRequest) (*longrunning.Operation, error) { 839 return nil, status.Errorf(codes.Unimplemented, "method RejoinUserEvents not implemented") 840} 841 842func RegisterUserEventServiceServer(s *grpc.Server, srv UserEventServiceServer) { 843 s.RegisterService(&_UserEventService_serviceDesc, srv) 844} 845 846func _UserEventService_WriteUserEvent_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 847 in := new(WriteUserEventRequest) 848 if err := dec(in); err != nil { 849 return nil, err 850 } 851 if interceptor == nil { 852 return srv.(UserEventServiceServer).WriteUserEvent(ctx, in) 853 } 854 info := &grpc.UnaryServerInfo{ 855 Server: srv, 856 FullMethod: "/google.cloud.retail.v2.UserEventService/WriteUserEvent", 857 } 858 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 859 return srv.(UserEventServiceServer).WriteUserEvent(ctx, req.(*WriteUserEventRequest)) 860 } 861 return interceptor(ctx, in, info, handler) 862} 863 864func _UserEventService_CollectUserEvent_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 865 in := new(CollectUserEventRequest) 866 if err := dec(in); err != nil { 867 return nil, err 868 } 869 if interceptor == nil { 870 return srv.(UserEventServiceServer).CollectUserEvent(ctx, in) 871 } 872 info := &grpc.UnaryServerInfo{ 873 Server: srv, 874 FullMethod: "/google.cloud.retail.v2.UserEventService/CollectUserEvent", 875 } 876 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 877 return srv.(UserEventServiceServer).CollectUserEvent(ctx, req.(*CollectUserEventRequest)) 878 } 879 return interceptor(ctx, in, info, handler) 880} 881 882func _UserEventService_PurgeUserEvents_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 883 in := new(PurgeUserEventsRequest) 884 if err := dec(in); err != nil { 885 return nil, err 886 } 887 if interceptor == nil { 888 return srv.(UserEventServiceServer).PurgeUserEvents(ctx, in) 889 } 890 info := &grpc.UnaryServerInfo{ 891 Server: srv, 892 FullMethod: "/google.cloud.retail.v2.UserEventService/PurgeUserEvents", 893 } 894 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 895 return srv.(UserEventServiceServer).PurgeUserEvents(ctx, req.(*PurgeUserEventsRequest)) 896 } 897 return interceptor(ctx, in, info, handler) 898} 899 900func _UserEventService_ImportUserEvents_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 901 in := new(ImportUserEventsRequest) 902 if err := dec(in); err != nil { 903 return nil, err 904 } 905 if interceptor == nil { 906 return srv.(UserEventServiceServer).ImportUserEvents(ctx, in) 907 } 908 info := &grpc.UnaryServerInfo{ 909 Server: srv, 910 FullMethod: "/google.cloud.retail.v2.UserEventService/ImportUserEvents", 911 } 912 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 913 return srv.(UserEventServiceServer).ImportUserEvents(ctx, req.(*ImportUserEventsRequest)) 914 } 915 return interceptor(ctx, in, info, handler) 916} 917 918func _UserEventService_RejoinUserEvents_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 919 in := new(RejoinUserEventsRequest) 920 if err := dec(in); err != nil { 921 return nil, err 922 } 923 if interceptor == nil { 924 return srv.(UserEventServiceServer).RejoinUserEvents(ctx, in) 925 } 926 info := &grpc.UnaryServerInfo{ 927 Server: srv, 928 FullMethod: "/google.cloud.retail.v2.UserEventService/RejoinUserEvents", 929 } 930 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 931 return srv.(UserEventServiceServer).RejoinUserEvents(ctx, req.(*RejoinUserEventsRequest)) 932 } 933 return interceptor(ctx, in, info, handler) 934} 935 936var _UserEventService_serviceDesc = grpc.ServiceDesc{ 937 ServiceName: "google.cloud.retail.v2.UserEventService", 938 HandlerType: (*UserEventServiceServer)(nil), 939 Methods: []grpc.MethodDesc{ 940 { 941 MethodName: "WriteUserEvent", 942 Handler: _UserEventService_WriteUserEvent_Handler, 943 }, 944 { 945 MethodName: "CollectUserEvent", 946 Handler: _UserEventService_CollectUserEvent_Handler, 947 }, 948 { 949 MethodName: "PurgeUserEvents", 950 Handler: _UserEventService_PurgeUserEvents_Handler, 951 }, 952 { 953 MethodName: "ImportUserEvents", 954 Handler: _UserEventService_ImportUserEvents_Handler, 955 }, 956 { 957 MethodName: "RejoinUserEvents", 958 Handler: _UserEventService_RejoinUserEvents_Handler, 959 }, 960 }, 961 Streams: []grpc.StreamDesc{}, 962 Metadata: "google/cloud/retail/v2/user_event_service.proto", 963} 964