1 // Copyright 2022 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 aliasgen. DO NOT EDIT. 16 17 // Package pubsublite aliases all exported identifiers in package 18 // "cloud.google.com/go/pubsublite/apiv1/pubsublitepb". 19 // 20 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb. 21 // Please read https://github.com/googleapis/google-cloud-go/blob/main/migration.md 22 // for more details. 23 package pubsublite 24 25 import ( 26 src "cloud.google.com/go/pubsublite/apiv1/pubsublitepb" 27 grpc "google.golang.org/grpc" 28 ) 29 30 // Deprecated: Please use consts in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 31 const ( 32 ExportConfig_ACTIVE = src.ExportConfig_ACTIVE 33 ExportConfig_NOT_FOUND = src.ExportConfig_NOT_FOUND 34 ExportConfig_PAUSED = src.ExportConfig_PAUSED 35 ExportConfig_PERMISSION_DENIED = src.ExportConfig_PERMISSION_DENIED 36 ExportConfig_STATE_UNSPECIFIED = src.ExportConfig_STATE_UNSPECIFIED 37 SeekRequest_COMMITTED_CURSOR = src.SeekRequest_COMMITTED_CURSOR 38 SeekRequest_HEAD = src.SeekRequest_HEAD 39 SeekRequest_NAMED_TARGET_UNSPECIFIED = src.SeekRequest_NAMED_TARGET_UNSPECIFIED 40 SeekSubscriptionRequest_HEAD = src.SeekSubscriptionRequest_HEAD 41 SeekSubscriptionRequest_NAMED_TARGET_UNSPECIFIED = src.SeekSubscriptionRequest_NAMED_TARGET_UNSPECIFIED 42 SeekSubscriptionRequest_TAIL = src.SeekSubscriptionRequest_TAIL 43 Subscription_DeliveryConfig_DELIVERY_REQUIREMENT_UNSPECIFIED = src.Subscription_DeliveryConfig_DELIVERY_REQUIREMENT_UNSPECIFIED 44 Subscription_DeliveryConfig_DELIVER_AFTER_STORED = src.Subscription_DeliveryConfig_DELIVER_AFTER_STORED 45 Subscription_DeliveryConfig_DELIVER_IMMEDIATELY = src.Subscription_DeliveryConfig_DELIVER_IMMEDIATELY 46 ) 47 48 // Deprecated: Please use vars in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 49 var ( 50 ExportConfig_State_name = src.ExportConfig_State_name 51 ExportConfig_State_value = src.ExportConfig_State_value 52 File_google_cloud_pubsublite_v1_admin_proto = src.File_google_cloud_pubsublite_v1_admin_proto 53 File_google_cloud_pubsublite_v1_common_proto = src.File_google_cloud_pubsublite_v1_common_proto 54 File_google_cloud_pubsublite_v1_cursor_proto = src.File_google_cloud_pubsublite_v1_cursor_proto 55 File_google_cloud_pubsublite_v1_publisher_proto = src.File_google_cloud_pubsublite_v1_publisher_proto 56 File_google_cloud_pubsublite_v1_subscriber_proto = src.File_google_cloud_pubsublite_v1_subscriber_proto 57 File_google_cloud_pubsublite_v1_topic_stats_proto = src.File_google_cloud_pubsublite_v1_topic_stats_proto 58 SeekRequest_NamedTarget_name = src.SeekRequest_NamedTarget_name 59 SeekRequest_NamedTarget_value = src.SeekRequest_NamedTarget_value 60 SeekSubscriptionRequest_NamedTarget_name = src.SeekSubscriptionRequest_NamedTarget_name 61 SeekSubscriptionRequest_NamedTarget_value = src.SeekSubscriptionRequest_NamedTarget_value 62 Subscription_DeliveryConfig_DeliveryRequirement_name = src.Subscription_DeliveryConfig_DeliveryRequirement_name 63 Subscription_DeliveryConfig_DeliveryRequirement_value = src.Subscription_DeliveryConfig_DeliveryRequirement_value 64 ) 65 66 // AdminServiceClient is the client API for AdminService service. For 67 // semantics around ctx use and closing/ending streaming RPCs, please refer to 68 // https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 69 // 70 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 71 type AdminServiceClient = src.AdminServiceClient 72 73 // AdminServiceServer is the server API for AdminService service. 74 // 75 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 76 type AdminServiceServer = src.AdminServiceServer 77 78 // The values associated with a key of an attribute. 79 // 80 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 81 type AttributeValues = src.AttributeValues 82 83 // Request for CommitCursor. 84 // 85 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 86 type CommitCursorRequest = src.CommitCursorRequest 87 88 // Response for CommitCursor. 89 // 90 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 91 type CommitCursorResponse = src.CommitCursorResponse 92 93 // Compute the current head cursor for a partition. 94 // 95 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 96 type ComputeHeadCursorRequest = src.ComputeHeadCursorRequest 97 98 // Response containing the head cursor for the requested topic and partition. 99 // 100 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 101 type ComputeHeadCursorResponse = src.ComputeHeadCursorResponse 102 103 // Compute statistics about a range of messages in a given topic and 104 // partition. 105 // 106 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 107 type ComputeMessageStatsRequest = src.ComputeMessageStatsRequest 108 109 // Response containing stats for messages in the requested topic and 110 // partition. 111 // 112 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 113 type ComputeMessageStatsResponse = src.ComputeMessageStatsResponse 114 115 // Compute the corresponding cursor for a publish or event time in a topic 116 // partition. 117 // 118 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 119 type ComputeTimeCursorRequest = src.ComputeTimeCursorRequest 120 121 // Response containing the cursor corresponding to a publish or event time in 122 // a topic partition. 123 // 124 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 125 type ComputeTimeCursorResponse = src.ComputeTimeCursorResponse 126 127 // Request for CreateReservation. 128 // 129 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 130 type CreateReservationRequest = src.CreateReservationRequest 131 132 // Request for CreateSubscription. 133 // 134 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 135 type CreateSubscriptionRequest = src.CreateSubscriptionRequest 136 137 // Request for CreateTopic. 138 // 139 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 140 type CreateTopicRequest = src.CreateTopicRequest 141 142 // A cursor that describes the position of a message within a topic partition. 143 // 144 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 145 type Cursor = src.Cursor 146 147 // CursorServiceClient is the client API for CursorService service. For 148 // semantics around ctx use and closing/ending streaming RPCs, please refer to 149 // https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 150 // 151 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 152 type CursorServiceClient = src.CursorServiceClient 153 154 // CursorServiceServer is the server API for CursorService service. 155 // 156 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 157 type CursorServiceServer = src.CursorServiceServer 158 type CursorService_StreamingCommitCursorClient = src.CursorService_StreamingCommitCursorClient 159 type CursorService_StreamingCommitCursorServer = src.CursorService_StreamingCommitCursorServer 160 161 // Request for DeleteReservation. 162 // 163 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 164 type DeleteReservationRequest = src.DeleteReservationRequest 165 166 // Request for DeleteSubscription. 167 // 168 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 169 type DeleteSubscriptionRequest = src.DeleteSubscriptionRequest 170 171 // Request for DeleteTopic. 172 // 173 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 174 type DeleteTopicRequest = src.DeleteTopicRequest 175 176 // Configuration for a Pub/Sub Lite subscription that writes messages to a 177 // destination. User subscriber clients must not connect to this subscription. 178 // 179 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 180 type ExportConfig = src.ExportConfig 181 182 // Configuration for exporting to a Pub/Sub topic. 183 // 184 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 185 type ExportConfig_PubSubConfig = src.ExportConfig_PubSubConfig 186 type ExportConfig_PubsubConfig = src.ExportConfig_PubsubConfig 187 188 // The desired export state. 189 // 190 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 191 type ExportConfig_State = src.ExportConfig_State 192 193 // Request to grant tokens to the server, requesting delivery of messages when 194 // they become available. 195 // 196 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 197 type FlowControlRequest = src.FlowControlRequest 198 199 // Request for GetReservation. 200 // 201 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 202 type GetReservationRequest = src.GetReservationRequest 203 204 // Request for GetSubscription. 205 // 206 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 207 type GetSubscriptionRequest = src.GetSubscriptionRequest 208 209 // Request for GetTopicPartitions. 210 // 211 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 212 type GetTopicPartitionsRequest = src.GetTopicPartitionsRequest 213 214 // Request for GetTopic. 215 // 216 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 217 type GetTopicRequest = src.GetTopicRequest 218 219 // The first streaming request that must be sent on a newly-opened stream. The 220 // client must wait for the response before sending subsequent requests on the 221 // stream. 222 // 223 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 224 type InitialCommitCursorRequest = src.InitialCommitCursorRequest 225 226 // Response to an InitialCommitCursorRequest. 227 // 228 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 229 type InitialCommitCursorResponse = src.InitialCommitCursorResponse 230 231 // The first request that must be sent on a newly-opened stream. The client 232 // must wait for the response before sending subsequent requests on the stream. 233 // 234 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 235 type InitialPartitionAssignmentRequest = src.InitialPartitionAssignmentRequest 236 237 // The first request that must be sent on a newly-opened stream. 238 // 239 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 240 type InitialPublishRequest = src.InitialPublishRequest 241 242 // Response to an InitialPublishRequest. 243 // 244 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 245 type InitialPublishResponse = src.InitialPublishResponse 246 247 // The first request that must be sent on a newly-opened stream. The client 248 // must wait for the response before sending subsequent requests on the stream. 249 // 250 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 251 type InitialSubscribeRequest = src.InitialSubscribeRequest 252 253 // Response to an InitialSubscribeRequest. 254 // 255 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 256 type InitialSubscribeResponse = src.InitialSubscribeResponse 257 258 // Request for ListPartitionCursors. 259 // 260 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 261 type ListPartitionCursorsRequest = src.ListPartitionCursorsRequest 262 263 // Response for ListPartitionCursors 264 // 265 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 266 type ListPartitionCursorsResponse = src.ListPartitionCursorsResponse 267 268 // Request for ListReservationTopics. 269 // 270 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 271 type ListReservationTopicsRequest = src.ListReservationTopicsRequest 272 273 // Response for ListReservationTopics. 274 // 275 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 276 type ListReservationTopicsResponse = src.ListReservationTopicsResponse 277 278 // Request for ListReservations. 279 // 280 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 281 type ListReservationsRequest = src.ListReservationsRequest 282 283 // Response for ListReservations. 284 // 285 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 286 type ListReservationsResponse = src.ListReservationsResponse 287 288 // Request for ListSubscriptions. 289 // 290 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 291 type ListSubscriptionsRequest = src.ListSubscriptionsRequest 292 293 // Response for ListSubscriptions. 294 // 295 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 296 type ListSubscriptionsResponse = src.ListSubscriptionsResponse 297 298 // Request for ListTopicSubscriptions. 299 // 300 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 301 type ListTopicSubscriptionsRequest = src.ListTopicSubscriptionsRequest 302 303 // Response for ListTopicSubscriptions. 304 // 305 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 306 type ListTopicSubscriptionsResponse = src.ListTopicSubscriptionsResponse 307 308 // Request for ListTopics. 309 // 310 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 311 type ListTopicsRequest = src.ListTopicsRequest 312 313 // Response for ListTopics. 314 // 315 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 316 type ListTopicsResponse = src.ListTopicsResponse 317 318 // Request to publish messages to the topic. 319 // 320 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 321 type MessagePublishRequest = src.MessagePublishRequest 322 323 // Response to a MessagePublishRequest. 324 // 325 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 326 type MessagePublishResponse = src.MessagePublishResponse 327 328 // Response containing a list of messages. Upon delivering a MessageResponse 329 // to the client, the server: - Updates the stream's delivery cursor to one 330 // greater than the cursor of the last message in the list. - Subtracts the 331 // total number of bytes and messages from the tokens available to the server. 332 // 333 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 334 type MessageResponse = src.MessageResponse 335 336 // Metadata for long running operations. 337 // 338 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 339 type OperationMetadata = src.OperationMetadata 340 341 // PartitionAssignments should not race with acknowledgements. There should be 342 // exactly one unacknowledged PartitionAssignment at a time. If not, the client 343 // must break the stream. 344 // 345 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 346 type PartitionAssignment = src.PartitionAssignment 347 348 // Acknowledge receipt and handling of the previous assignment. If not sent 349 // within a short period after receiving the assignment, partitions may remain 350 // unassigned for a period of time until the client is known to be inactive, 351 // after which time the server will break the stream. 352 // 353 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 354 type PartitionAssignmentAck = src.PartitionAssignmentAck 355 356 // A request on the PartitionAssignment stream. 357 // 358 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 359 type PartitionAssignmentRequest = src.PartitionAssignmentRequest 360 type PartitionAssignmentRequest_Ack = src.PartitionAssignmentRequest_Ack 361 type PartitionAssignmentRequest_Initial = src.PartitionAssignmentRequest_Initial 362 363 // PartitionAssignmentServiceClient is the client API for 364 // PartitionAssignmentService service. For semantics around ctx use and 365 // closing/ending streaming RPCs, please refer to 366 // https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 367 // 368 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 369 type PartitionAssignmentServiceClient = src.PartitionAssignmentServiceClient 370 371 // PartitionAssignmentServiceServer is the server API for 372 // PartitionAssignmentService service. 373 // 374 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 375 type PartitionAssignmentServiceServer = src.PartitionAssignmentServiceServer 376 type PartitionAssignmentService_AssignPartitionsClient = src.PartitionAssignmentService_AssignPartitionsClient 377 type PartitionAssignmentService_AssignPartitionsServer = src.PartitionAssignmentService_AssignPartitionsServer 378 379 // A pair of a Cursor and the partition it is for. 380 // 381 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 382 type PartitionCursor = src.PartitionCursor 383 384 // A message that is published by publishers and delivered to subscribers. 385 // 386 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 387 type PubSubMessage = src.PubSubMessage 388 389 // Request sent from the client to the server on a stream. 390 // 391 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 392 type PublishRequest = src.PublishRequest 393 type PublishRequest_InitialRequest = src.PublishRequest_InitialRequest 394 type PublishRequest_MessagePublishRequest = src.PublishRequest_MessagePublishRequest 395 396 // Response to a PublishRequest. 397 // 398 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 399 type PublishResponse = src.PublishResponse 400 type PublishResponse_InitialResponse = src.PublishResponse_InitialResponse 401 type PublishResponse_MessageResponse = src.PublishResponse_MessageResponse 402 403 // PublisherServiceClient is the client API for PublisherService service. For 404 // semantics around ctx use and closing/ending streaming RPCs, please refer to 405 // https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 406 // 407 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 408 type PublisherServiceClient = src.PublisherServiceClient 409 410 // PublisherServiceServer is the server API for PublisherService service. 411 // 412 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 413 type PublisherServiceServer = src.PublisherServiceServer 414 type PublisherService_PublishClient = src.PublisherService_PublishClient 415 type PublisherService_PublishServer = src.PublisherService_PublishServer 416 417 // Metadata about a reservation resource. 418 // 419 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 420 type Reservation = src.Reservation 421 422 // Request to update the stream's delivery cursor based on the given target. 423 // Resets the server available tokens to 0. SeekRequests past head result in 424 // stream breakage. SeekRequests may not be sent while another SeekRequest is 425 // outstanding (i.e., has not received a SeekResponse) on the same stream. 426 // 427 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 428 type SeekRequest = src.SeekRequest 429 type SeekRequest_Cursor = src.SeekRequest_Cursor 430 431 // A special target in the partition that takes no other parameters. 432 // 433 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 434 type SeekRequest_NamedTarget = src.SeekRequest_NamedTarget 435 type SeekRequest_NamedTarget_ = src.SeekRequest_NamedTarget_ 436 437 // Response to a SeekRequest. 438 // 439 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 440 type SeekResponse = src.SeekResponse 441 442 // Request for SeekSubscription. 443 // 444 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 445 type SeekSubscriptionRequest = src.SeekSubscriptionRequest 446 447 // A named position with respect to the message backlog. 448 // 449 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 450 type SeekSubscriptionRequest_NamedTarget = src.SeekSubscriptionRequest_NamedTarget 451 type SeekSubscriptionRequest_NamedTarget_ = src.SeekSubscriptionRequest_NamedTarget_ 452 type SeekSubscriptionRequest_TimeTarget = src.SeekSubscriptionRequest_TimeTarget 453 454 // Response for SeekSubscription long running operation. 455 // 456 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 457 type SeekSubscriptionResponse = src.SeekSubscriptionResponse 458 459 // Streaming request to update the committed cursor. Subsequent 460 // SequencedCommitCursorRequests override outstanding ones. 461 // 462 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 463 type SequencedCommitCursorRequest = src.SequencedCommitCursorRequest 464 465 // Response to a SequencedCommitCursorRequest. 466 // 467 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 468 type SequencedCommitCursorResponse = src.SequencedCommitCursorResponse 469 470 // A message that has been stored and sequenced by the Pub/Sub Lite system. 471 // 472 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 473 type SequencedMessage = src.SequencedMessage 474 475 // A request sent from the client to the server on a stream. 476 // 477 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 478 type StreamingCommitCursorRequest = src.StreamingCommitCursorRequest 479 type StreamingCommitCursorRequest_Commit = src.StreamingCommitCursorRequest_Commit 480 type StreamingCommitCursorRequest_Initial = src.StreamingCommitCursorRequest_Initial 481 482 // Response to a StreamingCommitCursorRequest. 483 // 484 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 485 type StreamingCommitCursorResponse = src.StreamingCommitCursorResponse 486 type StreamingCommitCursorResponse_Commit = src.StreamingCommitCursorResponse_Commit 487 type StreamingCommitCursorResponse_Initial = src.StreamingCommitCursorResponse_Initial 488 489 // A request sent from the client to the server on a stream. 490 // 491 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 492 type SubscribeRequest = src.SubscribeRequest 493 type SubscribeRequest_FlowControl = src.SubscribeRequest_FlowControl 494 type SubscribeRequest_Initial = src.SubscribeRequest_Initial 495 type SubscribeRequest_Seek = src.SubscribeRequest_Seek 496 497 // Response to SubscribeRequest. 498 // 499 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 500 type SubscribeResponse = src.SubscribeResponse 501 type SubscribeResponse_Initial = src.SubscribeResponse_Initial 502 type SubscribeResponse_Messages = src.SubscribeResponse_Messages 503 type SubscribeResponse_Seek = src.SubscribeResponse_Seek 504 505 // SubscriberServiceClient is the client API for SubscriberService service. 506 // For semantics around ctx use and closing/ending streaming RPCs, please refer 507 // to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 508 // 509 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 510 type SubscriberServiceClient = src.SubscriberServiceClient 511 512 // SubscriberServiceServer is the server API for SubscriberService service. 513 // 514 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 515 type SubscriberServiceServer = src.SubscriberServiceServer 516 type SubscriberService_SubscribeClient = src.SubscriberService_SubscribeClient 517 type SubscriberService_SubscribeServer = src.SubscriberService_SubscribeServer 518 519 // Metadata about a subscription resource. 520 // 521 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 522 type Subscription = src.Subscription 523 524 // The settings for a subscription's message delivery. 525 // 526 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 527 type Subscription_DeliveryConfig = src.Subscription_DeliveryConfig 528 529 // When this subscription should send messages to subscribers relative to 530 // messages persistence in storage. For details, see [Creating Lite 531 // subscriptions](https://cloud.google.com/pubsub/lite/docs/subscriptions#creating_lite_subscriptions). 532 // 533 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 534 type Subscription_DeliveryConfig_DeliveryRequirement = src.Subscription_DeliveryConfig_DeliveryRequirement 535 536 // A target publish or event time. Can be used for seeking to or retrieving 537 // the corresponding cursor. 538 // 539 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 540 type TimeTarget = src.TimeTarget 541 type TimeTarget_EventTime = src.TimeTarget_EventTime 542 type TimeTarget_PublishTime = src.TimeTarget_PublishTime 543 544 // Metadata about a topic resource. 545 // 546 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 547 type Topic = src.Topic 548 549 // Response for GetTopicPartitions. 550 // 551 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 552 type TopicPartitions = src.TopicPartitions 553 554 // TopicStatsServiceClient is the client API for TopicStatsService service. 555 // For semantics around ctx use and closing/ending streaming RPCs, please refer 556 // to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 557 // 558 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 559 type TopicStatsServiceClient = src.TopicStatsServiceClient 560 561 // TopicStatsServiceServer is the server API for TopicStatsService service. 562 // 563 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 564 type TopicStatsServiceServer = src.TopicStatsServiceServer 565 566 // The settings for a topic's partitions. 567 // 568 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 569 type Topic_PartitionConfig = src.Topic_PartitionConfig 570 571 // The throughput capacity configuration for each partition. 572 // 573 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 574 type Topic_PartitionConfig_Capacity = src.Topic_PartitionConfig_Capacity 575 type Topic_PartitionConfig_Capacity_ = src.Topic_PartitionConfig_Capacity_ 576 type Topic_PartitionConfig_Scale = src.Topic_PartitionConfig_Scale 577 578 // The settings for this topic's Reservation usage. 579 // 580 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 581 type Topic_ReservationConfig = src.Topic_ReservationConfig 582 583 // The settings for a topic's message retention. 584 // 585 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 586 type Topic_RetentionConfig = src.Topic_RetentionConfig 587 588 // UnimplementedAdminServiceServer can be embedded to have forward compatible 589 // implementations. 590 // 591 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 592 type UnimplementedAdminServiceServer = src.UnimplementedAdminServiceServer 593 594 // UnimplementedCursorServiceServer can be embedded to have forward compatible 595 // implementations. 596 // 597 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 598 type UnimplementedCursorServiceServer = src.UnimplementedCursorServiceServer 599 600 // UnimplementedPartitionAssignmentServiceServer can be embedded to have 601 // forward compatible implementations. 602 // 603 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 604 type UnimplementedPartitionAssignmentServiceServer = src.UnimplementedPartitionAssignmentServiceServer 605 606 // UnimplementedPublisherServiceServer can be embedded to have forward 607 // compatible implementations. 608 // 609 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 610 type UnimplementedPublisherServiceServer = src.UnimplementedPublisherServiceServer 611 612 // UnimplementedSubscriberServiceServer can be embedded to have forward 613 // compatible implementations. 614 // 615 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 616 type UnimplementedSubscriberServiceServer = src.UnimplementedSubscriberServiceServer 617 618 // UnimplementedTopicStatsServiceServer can be embedded to have forward 619 // compatible implementations. 620 // 621 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 622 type UnimplementedTopicStatsServiceServer = src.UnimplementedTopicStatsServiceServer 623 624 // Request for UpdateReservation. 625 // 626 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 627 type UpdateReservationRequest = src.UpdateReservationRequest 628 629 // Request for UpdateSubscription. 630 // 631 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 632 type UpdateSubscriptionRequest = src.UpdateSubscriptionRequest 633 634 // Request for UpdateTopic. 635 // 636 // Deprecated: Please use types in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 637 type UpdateTopicRequest = src.UpdateTopicRequest 638 639 // Deprecated: Please use funcs in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 640 func NewAdminServiceClient(cc grpc.ClientConnInterface) AdminServiceClient { 641 return src.NewAdminServiceClient(cc) 642 } 643 644 // Deprecated: Please use funcs in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 645 func NewCursorServiceClient(cc grpc.ClientConnInterface) CursorServiceClient { 646 return src.NewCursorServiceClient(cc) 647 } 648 649 // Deprecated: Please use funcs in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 650 func NewPartitionAssignmentServiceClient(cc grpc.ClientConnInterface) PartitionAssignmentServiceClient { 651 return src.NewPartitionAssignmentServiceClient(cc) 652 } 653 654 // Deprecated: Please use funcs in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 655 func NewPublisherServiceClient(cc grpc.ClientConnInterface) PublisherServiceClient { 656 return src.NewPublisherServiceClient(cc) 657 } 658 659 // Deprecated: Please use funcs in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 660 func NewSubscriberServiceClient(cc grpc.ClientConnInterface) SubscriberServiceClient { 661 return src.NewSubscriberServiceClient(cc) 662 } 663 664 // Deprecated: Please use funcs in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 665 func NewTopicStatsServiceClient(cc grpc.ClientConnInterface) TopicStatsServiceClient { 666 return src.NewTopicStatsServiceClient(cc) 667 } 668 669 // Deprecated: Please use funcs in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 670 func RegisterAdminServiceServer(s *grpc.Server, srv AdminServiceServer) { 671 src.RegisterAdminServiceServer(s, srv) 672 } 673 674 // Deprecated: Please use funcs in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 675 func RegisterCursorServiceServer(s *grpc.Server, srv CursorServiceServer) { 676 src.RegisterCursorServiceServer(s, srv) 677 } 678 679 // Deprecated: Please use funcs in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 680 func RegisterPartitionAssignmentServiceServer(s *grpc.Server, srv PartitionAssignmentServiceServer) { 681 src.RegisterPartitionAssignmentServiceServer(s, srv) 682 } 683 684 // Deprecated: Please use funcs in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 685 func RegisterPublisherServiceServer(s *grpc.Server, srv PublisherServiceServer) { 686 src.RegisterPublisherServiceServer(s, srv) 687 } 688 689 // Deprecated: Please use funcs in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 690 func RegisterSubscriberServiceServer(s *grpc.Server, srv SubscriberServiceServer) { 691 src.RegisterSubscriberServiceServer(s, srv) 692 } 693 694 // Deprecated: Please use funcs in: cloud.google.com/go/pubsublite/apiv1/pubsublitepb 695 func RegisterTopicStatsServiceServer(s *grpc.Server, srv TopicStatsServiceServer) { 696 src.RegisterTopicStatsServiceServer(s, srv) 697 } 698