Source file src/google.golang.org/genproto/googleapis/cloud/visionai/v1alpha1/streaming_service.pb.go

Documentation: google.golang.org/genproto/googleapis/cloud/visionai/v1alpha1

     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 protoc-gen-go. DO NOT EDIT.
    16  // versions:
    17  // 	protoc-gen-go v1.26.0
    18  // 	protoc        v3.21.9
    19  // source: google/cloud/visionai/v1alpha1/streaming_service.proto
    20  
    21  package visionai
    22  
    23  import (
    24  	context "context"
    25  	reflect "reflect"
    26  	sync "sync"
    27  
    28  	_ "google.golang.org/genproto/googleapis/api/annotations"
    29  	grpc "google.golang.org/grpc"
    30  	codes "google.golang.org/grpc/codes"
    31  	status "google.golang.org/grpc/status"
    32  	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
    33  	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
    34  	durationpb "google.golang.org/protobuf/types/known/durationpb"
    35  	timestamppb "google.golang.org/protobuf/types/known/timestamppb"
    36  )
    37  
    38  const (
    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 lease type.
    46  type LeaseType int32
    47  
    48  const (
    49  	// Lease type unspecified.
    50  	LeaseType_LEASE_TYPE_UNSPECIFIED LeaseType = 0
    51  	// Lease for stream reader.
    52  	LeaseType_LEASE_TYPE_READER LeaseType = 1
    53  	// Lease for stream writer.
    54  	LeaseType_LEASE_TYPE_WRITER LeaseType = 2
    55  )
    56  
    57  // Enum value maps for LeaseType.
    58  var (
    59  	LeaseType_name = map[int32]string{
    60  		0: "LEASE_TYPE_UNSPECIFIED",
    61  		1: "LEASE_TYPE_READER",
    62  		2: "LEASE_TYPE_WRITER",
    63  	}
    64  	LeaseType_value = map[string]int32{
    65  		"LEASE_TYPE_UNSPECIFIED": 0,
    66  		"LEASE_TYPE_READER":      1,
    67  		"LEASE_TYPE_WRITER":      2,
    68  	}
    69  )
    70  
    71  func (x LeaseType) Enum() *LeaseType {
    72  	p := new(LeaseType)
    73  	*p = x
    74  	return p
    75  }
    76  
    77  func (x LeaseType) String() string {
    78  	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
    79  }
    80  
    81  func (LeaseType) Descriptor() protoreflect.EnumDescriptor {
    82  	return file_google_cloud_visionai_v1alpha1_streaming_service_proto_enumTypes[0].Descriptor()
    83  }
    84  
    85  func (LeaseType) Type() protoreflect.EnumType {
    86  	return &file_google_cloud_visionai_v1alpha1_streaming_service_proto_enumTypes[0]
    87  }
    88  
    89  func (x LeaseType) Number() protoreflect.EnumNumber {
    90  	return protoreflect.EnumNumber(x)
    91  }
    92  
    93  // Deprecated: Use LeaseType.Descriptor instead.
    94  func (LeaseType) EnumDescriptor() ([]byte, []int) {
    95  	return file_google_cloud_visionai_v1alpha1_streaming_service_proto_rawDescGZIP(), []int{0}
    96  }
    97  
    98  // Request message for ReceiveEvents.
    99  type ReceiveEventsRequest struct {
   100  	state         protoimpl.MessageState
   101  	sizeCache     protoimpl.SizeCache
   102  	unknownFields protoimpl.UnknownFields
   103  
   104  	// Types that are assignable to Request:
   105  	//
   106  	//	*ReceiveEventsRequest_SetupRequest_
   107  	//	*ReceiveEventsRequest_CommitRequest
   108  	Request isReceiveEventsRequest_Request `protobuf_oneof:"request"`
   109  }
   110  
   111  func (x *ReceiveEventsRequest) Reset() {
   112  	*x = ReceiveEventsRequest{}
   113  	if protoimpl.UnsafeEnabled {
   114  		mi := &file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[0]
   115  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   116  		ms.StoreMessageInfo(mi)
   117  	}
   118  }
   119  
   120  func (x *ReceiveEventsRequest) String() string {
   121  	return protoimpl.X.MessageStringOf(x)
   122  }
   123  
   124  func (*ReceiveEventsRequest) ProtoMessage() {}
   125  
   126  func (x *ReceiveEventsRequest) ProtoReflect() protoreflect.Message {
   127  	mi := &file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[0]
   128  	if protoimpl.UnsafeEnabled && x != nil {
   129  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   130  		if ms.LoadMessageInfo() == nil {
   131  			ms.StoreMessageInfo(mi)
   132  		}
   133  		return ms
   134  	}
   135  	return mi.MessageOf(x)
   136  }
   137  
   138  // Deprecated: Use ReceiveEventsRequest.ProtoReflect.Descriptor instead.
   139  func (*ReceiveEventsRequest) Descriptor() ([]byte, []int) {
   140  	return file_google_cloud_visionai_v1alpha1_streaming_service_proto_rawDescGZIP(), []int{0}
   141  }
   142  
   143  func (m *ReceiveEventsRequest) GetRequest() isReceiveEventsRequest_Request {
   144  	if m != nil {
   145  		return m.Request
   146  	}
   147  	return nil
   148  }
   149  
   150  func (x *ReceiveEventsRequest) GetSetupRequest() *ReceiveEventsRequest_SetupRequest {
   151  	if x, ok := x.GetRequest().(*ReceiveEventsRequest_SetupRequest_); ok {
   152  		return x.SetupRequest
   153  	}
   154  	return nil
   155  }
   156  
   157  func (x *ReceiveEventsRequest) GetCommitRequest() *CommitRequest {
   158  	if x, ok := x.GetRequest().(*ReceiveEventsRequest_CommitRequest); ok {
   159  		return x.CommitRequest
   160  	}
   161  	return nil
   162  }
   163  
   164  type isReceiveEventsRequest_Request interface {
   165  	isReceiveEventsRequest_Request()
   166  }
   167  
   168  type ReceiveEventsRequest_SetupRequest_ struct {
   169  	// The setup request to setup the RPC connection.
   170  	SetupRequest *ReceiveEventsRequest_SetupRequest `protobuf:"bytes,1,opt,name=setup_request,json=setupRequest,proto3,oneof"`
   171  }
   172  
   173  type ReceiveEventsRequest_CommitRequest struct {
   174  	// This request checkpoints the consumer's read progress.
   175  	CommitRequest *CommitRequest `protobuf:"bytes,2,opt,name=commit_request,json=commitRequest,proto3,oneof"`
   176  }
   177  
   178  func (*ReceiveEventsRequest_SetupRequest_) isReceiveEventsRequest_Request() {}
   179  
   180  func (*ReceiveEventsRequest_CommitRequest) isReceiveEventsRequest_Request() {}
   181  
   182  // The event update message.
   183  type EventUpdate struct {
   184  	state         protoimpl.MessageState
   185  	sizeCache     protoimpl.SizeCache
   186  	unknownFields protoimpl.UnknownFields
   187  
   188  	// The name of the stream that the event is attached to.
   189  	Stream string `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"`
   190  	// The name of the event.
   191  	Event string `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
   192  	// The name of the series.
   193  	Series string `protobuf:"bytes,3,opt,name=series,proto3" json:"series,omitempty"`
   194  	// The timestamp when the Event update happens.
   195  	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
   196  	// The offset of the message that will be used to acknowledge of the message
   197  	// receiving.
   198  	Offset int64 `protobuf:"varint,5,opt,name=offset,proto3" json:"offset,omitempty"`
   199  }
   200  
   201  func (x *EventUpdate) Reset() {
   202  	*x = EventUpdate{}
   203  	if protoimpl.UnsafeEnabled {
   204  		mi := &file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[1]
   205  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   206  		ms.StoreMessageInfo(mi)
   207  	}
   208  }
   209  
   210  func (x *EventUpdate) String() string {
   211  	return protoimpl.X.MessageStringOf(x)
   212  }
   213  
   214  func (*EventUpdate) ProtoMessage() {}
   215  
   216  func (x *EventUpdate) ProtoReflect() protoreflect.Message {
   217  	mi := &file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[1]
   218  	if protoimpl.UnsafeEnabled && x != nil {
   219  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   220  		if ms.LoadMessageInfo() == nil {
   221  			ms.StoreMessageInfo(mi)
   222  		}
   223  		return ms
   224  	}
   225  	return mi.MessageOf(x)
   226  }
   227  
   228  // Deprecated: Use EventUpdate.ProtoReflect.Descriptor instead.
   229  func (*EventUpdate) Descriptor() ([]byte, []int) {
   230  	return file_google_cloud_visionai_v1alpha1_streaming_service_proto_rawDescGZIP(), []int{1}
   231  }
   232  
   233  func (x *EventUpdate) GetStream() string {
   234  	if x != nil {
   235  		return x.Stream
   236  	}
   237  	return ""
   238  }
   239  
   240  func (x *EventUpdate) GetEvent() string {
   241  	if x != nil {
   242  		return x.Event
   243  	}
   244  	return ""
   245  }
   246  
   247  func (x *EventUpdate) GetSeries() string {
   248  	if x != nil {
   249  		return x.Series
   250  	}
   251  	return ""
   252  }
   253  
   254  func (x *EventUpdate) GetUpdateTime() *timestamppb.Timestamp {
   255  	if x != nil {
   256  		return x.UpdateTime
   257  	}
   258  	return nil
   259  }
   260  
   261  func (x *EventUpdate) GetOffset() int64 {
   262  	if x != nil {
   263  		return x.Offset
   264  	}
   265  	return 0
   266  }
   267  
   268  // Control message for a ReceiveEventsResponse.
   269  type ReceiveEventsControlResponse struct {
   270  	state         protoimpl.MessageState
   271  	sizeCache     protoimpl.SizeCache
   272  	unknownFields protoimpl.UnknownFields
   273  
   274  	// Possible control messages.
   275  	//
   276  	// Types that are assignable to Control:
   277  	//
   278  	//	*ReceiveEventsControlResponse_Heartbeat
   279  	//	*ReceiveEventsControlResponse_WritesDoneRequest
   280  	Control isReceiveEventsControlResponse_Control `protobuf_oneof:"control"`
   281  }
   282  
   283  func (x *ReceiveEventsControlResponse) Reset() {
   284  	*x = ReceiveEventsControlResponse{}
   285  	if protoimpl.UnsafeEnabled {
   286  		mi := &file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[2]
   287  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   288  		ms.StoreMessageInfo(mi)
   289  	}
   290  }
   291  
   292  func (x *ReceiveEventsControlResponse) String() string {
   293  	return protoimpl.X.MessageStringOf(x)
   294  }
   295  
   296  func (*ReceiveEventsControlResponse) ProtoMessage() {}
   297  
   298  func (x *ReceiveEventsControlResponse) ProtoReflect() protoreflect.Message {
   299  	mi := &file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[2]
   300  	if protoimpl.UnsafeEnabled && x != nil {
   301  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   302  		if ms.LoadMessageInfo() == nil {
   303  			ms.StoreMessageInfo(mi)
   304  		}
   305  		return ms
   306  	}
   307  	return mi.MessageOf(x)
   308  }
   309  
   310  // Deprecated: Use ReceiveEventsControlResponse.ProtoReflect.Descriptor instead.
   311  func (*ReceiveEventsControlResponse) Descriptor() ([]byte, []int) {
   312  	return file_google_cloud_visionai_v1alpha1_streaming_service_proto_rawDescGZIP(), []int{2}
   313  }
   314  
   315  func (m *ReceiveEventsControlResponse) GetControl() isReceiveEventsControlResponse_Control {
   316  	if m != nil {
   317  		return m.Control
   318  	}
   319  	return nil
   320  }
   321  
   322  func (x *ReceiveEventsControlResponse) GetHeartbeat() bool {
   323  	if x, ok := x.GetControl().(*ReceiveEventsControlResponse_Heartbeat); ok {
   324  		return x.Heartbeat
   325  	}
   326  	return false
   327  }
   328  
   329  func (x *ReceiveEventsControlResponse) GetWritesDoneRequest() bool {
   330  	if x, ok := x.GetControl().(*ReceiveEventsControlResponse_WritesDoneRequest); ok {
   331  		return x.WritesDoneRequest
   332  	}
   333  	return false
   334  }
   335  
   336  type isReceiveEventsControlResponse_Control interface {
   337  	isReceiveEventsControlResponse_Control()
   338  }
   339  
   340  type ReceiveEventsControlResponse_Heartbeat struct {
   341  	// A server heartbeat.
   342  	Heartbeat bool `protobuf:"varint,1,opt,name=heartbeat,proto3,oneof"`
   343  }
   344  
   345  type ReceiveEventsControlResponse_WritesDoneRequest struct {
   346  	// A request to the receiver to complete any final writes followed by a
   347  	// `WritesDone`; e.g. issue any final `CommitRequest`s.
   348  	//
   349  	// May be ignored if `WritesDone` has already been issued at any point
   350  	// prior to receiving this message.
   351  	//
   352  	// If `WritesDone` does not get issued, then the server will forcefully
   353  	// cancel the connection, and the receiver will likely receive an
   354  	// uninformative after `Read` returns `false` and `Finish` is called.
   355  	WritesDoneRequest bool `protobuf:"varint,2,opt,name=writes_done_request,json=writesDoneRequest,proto3,oneof"`
   356  }
   357  
   358  func (*ReceiveEventsControlResponse_Heartbeat) isReceiveEventsControlResponse_Control() {}
   359  
   360  func (*ReceiveEventsControlResponse_WritesDoneRequest) isReceiveEventsControlResponse_Control() {}
   361  
   362  // Response message for the ReceiveEvents.
   363  type ReceiveEventsResponse struct {
   364  	state         protoimpl.MessageState
   365  	sizeCache     protoimpl.SizeCache
   366  	unknownFields protoimpl.UnknownFields
   367  
   368  	// Possible response types.
   369  	//
   370  	// Types that are assignable to Response:
   371  	//
   372  	//	*ReceiveEventsResponse_EventUpdate
   373  	//	*ReceiveEventsResponse_Control
   374  	Response isReceiveEventsResponse_Response `protobuf_oneof:"response"`
   375  }
   376  
   377  func (x *ReceiveEventsResponse) Reset() {
   378  	*x = ReceiveEventsResponse{}
   379  	if protoimpl.UnsafeEnabled {
   380  		mi := &file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[3]
   381  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   382  		ms.StoreMessageInfo(mi)
   383  	}
   384  }
   385  
   386  func (x *ReceiveEventsResponse) String() string {
   387  	return protoimpl.X.MessageStringOf(x)
   388  }
   389  
   390  func (*ReceiveEventsResponse) ProtoMessage() {}
   391  
   392  func (x *ReceiveEventsResponse) ProtoReflect() protoreflect.Message {
   393  	mi := &file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[3]
   394  	if protoimpl.UnsafeEnabled && x != nil {
   395  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   396  		if ms.LoadMessageInfo() == nil {
   397  			ms.StoreMessageInfo(mi)
   398  		}
   399  		return ms
   400  	}
   401  	return mi.MessageOf(x)
   402  }
   403  
   404  // Deprecated: Use ReceiveEventsResponse.ProtoReflect.Descriptor instead.
   405  func (*ReceiveEventsResponse) Descriptor() ([]byte, []int) {
   406  	return file_google_cloud_visionai_v1alpha1_streaming_service_proto_rawDescGZIP(), []int{3}
   407  }
   408  
   409  func (m *ReceiveEventsResponse) GetResponse() isReceiveEventsResponse_Response {
   410  	if m != nil {
   411  		return m.Response
   412  	}
   413  	return nil
   414  }
   415  
   416  func (x *ReceiveEventsResponse) GetEventUpdate() *EventUpdate {
   417  	if x, ok := x.GetResponse().(*ReceiveEventsResponse_EventUpdate); ok {
   418  		return x.EventUpdate
   419  	}
   420  	return nil
   421  }
   422  
   423  func (x *ReceiveEventsResponse) GetControl() *ReceiveEventsControlResponse {
   424  	if x, ok := x.GetResponse().(*ReceiveEventsResponse_Control); ok {
   425  		return x.Control
   426  	}
   427  	return nil
   428  }
   429  
   430  type isReceiveEventsResponse_Response interface {
   431  	isReceiveEventsResponse_Response()
   432  }
   433  
   434  type ReceiveEventsResponse_EventUpdate struct {
   435  	// The event update message.
   436  	EventUpdate *EventUpdate `protobuf:"bytes,1,opt,name=event_update,json=eventUpdate,proto3,oneof"`
   437  }
   438  
   439  type ReceiveEventsResponse_Control struct {
   440  	// A control message from the server.
   441  	Control *ReceiveEventsControlResponse `protobuf:"bytes,2,opt,name=control,proto3,oneof"`
   442  }
   443  
   444  func (*ReceiveEventsResponse_EventUpdate) isReceiveEventsResponse_Response() {}
   445  
   446  func (*ReceiveEventsResponse_Control) isReceiveEventsResponse_Response() {}
   447  
   448  // The lease message.
   449  type Lease struct {
   450  	state         protoimpl.MessageState
   451  	sizeCache     protoimpl.SizeCache
   452  	unknownFields protoimpl.UnknownFields
   453  
   454  	// The lease id.
   455  	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
   456  	// The series name.
   457  	Series string `protobuf:"bytes,2,opt,name=series,proto3" json:"series,omitempty"`
   458  	// The owner name.
   459  	Owner string `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"`
   460  	// The lease expire time.
   461  	ExpireTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=expire_time,json=expireTime,proto3" json:"expire_time,omitempty"`
   462  	// The lease type.
   463  	LeaseType LeaseType `protobuf:"varint,5,opt,name=lease_type,json=leaseType,proto3,enum=google.cloud.visionai.v1alpha1.LeaseType" json:"lease_type,omitempty"`
   464  }
   465  
   466  func (x *Lease) Reset() {
   467  	*x = Lease{}
   468  	if protoimpl.UnsafeEnabled {
   469  		mi := &file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[4]
   470  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   471  		ms.StoreMessageInfo(mi)
   472  	}
   473  }
   474  
   475  func (x *Lease) String() string {
   476  	return protoimpl.X.MessageStringOf(x)
   477  }
   478  
   479  func (*Lease) ProtoMessage() {}
   480  
   481  func (x *Lease) ProtoReflect() protoreflect.Message {
   482  	mi := &file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[4]
   483  	if protoimpl.UnsafeEnabled && x != nil {
   484  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   485  		if ms.LoadMessageInfo() == nil {
   486  			ms.StoreMessageInfo(mi)
   487  		}
   488  		return ms
   489  	}
   490  	return mi.MessageOf(x)
   491  }
   492  
   493  // Deprecated: Use Lease.ProtoReflect.Descriptor instead.
   494  func (*Lease) Descriptor() ([]byte, []int) {
   495  	return file_google_cloud_visionai_v1alpha1_streaming_service_proto_rawDescGZIP(), []int{4}
   496  }
   497  
   498  func (x *Lease) GetId() string {
   499  	if x != nil {
   500  		return x.Id
   501  	}
   502  	return ""
   503  }
   504  
   505  func (x *Lease) GetSeries() string {
   506  	if x != nil {
   507  		return x.Series
   508  	}
   509  	return ""
   510  }
   511  
   512  func (x *Lease) GetOwner() string {
   513  	if x != nil {
   514  		return x.Owner
   515  	}
   516  	return ""
   517  }
   518  
   519  func (x *Lease) GetExpireTime() *timestamppb.Timestamp {
   520  	if x != nil {
   521  		return x.ExpireTime
   522  	}
   523  	return nil
   524  }
   525  
   526  func (x *Lease) GetLeaseType() LeaseType {
   527  	if x != nil {
   528  		return x.LeaseType
   529  	}
   530  	return LeaseType_LEASE_TYPE_UNSPECIFIED
   531  }
   532  
   533  // Request message for acquiring a lease.
   534  type AcquireLeaseRequest struct {
   535  	state         protoimpl.MessageState
   536  	sizeCache     protoimpl.SizeCache
   537  	unknownFields protoimpl.UnknownFields
   538  
   539  	// The series name.
   540  	Series string `protobuf:"bytes,1,opt,name=series,proto3" json:"series,omitempty"`
   541  	// The owner name.
   542  	Owner string `protobuf:"bytes,2,opt,name=owner,proto3" json:"owner,omitempty"`
   543  	// The lease term.
   544  	Term *durationpb.Duration `protobuf:"bytes,3,opt,name=term,proto3" json:"term,omitempty"`
   545  	// The lease type.
   546  	LeaseType LeaseType `protobuf:"varint,4,opt,name=lease_type,json=leaseType,proto3,enum=google.cloud.visionai.v1alpha1.LeaseType" json:"lease_type,omitempty"`
   547  }
   548  
   549  func (x *AcquireLeaseRequest) Reset() {
   550  	*x = AcquireLeaseRequest{}
   551  	if protoimpl.UnsafeEnabled {
   552  		mi := &file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[5]
   553  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   554  		ms.StoreMessageInfo(mi)
   555  	}
   556  }
   557  
   558  func (x *AcquireLeaseRequest) String() string {
   559  	return protoimpl.X.MessageStringOf(x)
   560  }
   561  
   562  func (*AcquireLeaseRequest) ProtoMessage() {}
   563  
   564  func (x *AcquireLeaseRequest) ProtoReflect() protoreflect.Message {
   565  	mi := &file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[5]
   566  	if protoimpl.UnsafeEnabled && x != nil {
   567  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   568  		if ms.LoadMessageInfo() == nil {
   569  			ms.StoreMessageInfo(mi)
   570  		}
   571  		return ms
   572  	}
   573  	return mi.MessageOf(x)
   574  }
   575  
   576  // Deprecated: Use AcquireLeaseRequest.ProtoReflect.Descriptor instead.
   577  func (*AcquireLeaseRequest) Descriptor() ([]byte, []int) {
   578  	return file_google_cloud_visionai_v1alpha1_streaming_service_proto_rawDescGZIP(), []int{5}
   579  }
   580  
   581  func (x *AcquireLeaseRequest) GetSeries() string {
   582  	if x != nil {
   583  		return x.Series
   584  	}
   585  	return ""
   586  }
   587  
   588  func (x *AcquireLeaseRequest) GetOwner() string {
   589  	if x != nil {
   590  		return x.Owner
   591  	}
   592  	return ""
   593  }
   594  
   595  func (x *AcquireLeaseRequest) GetTerm() *durationpb.Duration {
   596  	if x != nil {
   597  		return x.Term
   598  	}
   599  	return nil
   600  }
   601  
   602  func (x *AcquireLeaseRequest) GetLeaseType() LeaseType {
   603  	if x != nil {
   604  		return x.LeaseType
   605  	}
   606  	return LeaseType_LEASE_TYPE_UNSPECIFIED
   607  }
   608  
   609  // Request message for renewing a lease.
   610  type RenewLeaseRequest struct {
   611  	state         protoimpl.MessageState
   612  	sizeCache     protoimpl.SizeCache
   613  	unknownFields protoimpl.UnknownFields
   614  
   615  	// Lease id.
   616  	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
   617  	// Series name.
   618  	Series string `protobuf:"bytes,2,opt,name=series,proto3" json:"series,omitempty"`
   619  	// Lease owner.
   620  	Owner string `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"`
   621  	// Lease term.
   622  	Term *durationpb.Duration `protobuf:"bytes,4,opt,name=term,proto3" json:"term,omitempty"`
   623  }
   624  
   625  func (x *RenewLeaseRequest) Reset() {
   626  	*x = RenewLeaseRequest{}
   627  	if protoimpl.UnsafeEnabled {
   628  		mi := &file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[6]
   629  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   630  		ms.StoreMessageInfo(mi)
   631  	}
   632  }
   633  
   634  func (x *RenewLeaseRequest) String() string {
   635  	return protoimpl.X.MessageStringOf(x)
   636  }
   637  
   638  func (*RenewLeaseRequest) ProtoMessage() {}
   639  
   640  func (x *RenewLeaseRequest) ProtoReflect() protoreflect.Message {
   641  	mi := &file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[6]
   642  	if protoimpl.UnsafeEnabled && x != nil {
   643  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   644  		if ms.LoadMessageInfo() == nil {
   645  			ms.StoreMessageInfo(mi)
   646  		}
   647  		return ms
   648  	}
   649  	return mi.MessageOf(x)
   650  }
   651  
   652  // Deprecated: Use RenewLeaseRequest.ProtoReflect.Descriptor instead.
   653  func (*RenewLeaseRequest) Descriptor() ([]byte, []int) {
   654  	return file_google_cloud_visionai_v1alpha1_streaming_service_proto_rawDescGZIP(), []int{6}
   655  }
   656  
   657  func (x *RenewLeaseRequest) GetId() string {
   658  	if x != nil {
   659  		return x.Id
   660  	}
   661  	return ""
   662  }
   663  
   664  func (x *RenewLeaseRequest) GetSeries() string {
   665  	if x != nil {
   666  		return x.Series
   667  	}
   668  	return ""
   669  }
   670  
   671  func (x *RenewLeaseRequest) GetOwner() string {
   672  	if x != nil {
   673  		return x.Owner
   674  	}
   675  	return ""
   676  }
   677  
   678  func (x *RenewLeaseRequest) GetTerm() *durationpb.Duration {
   679  	if x != nil {
   680  		return x.Term
   681  	}
   682  	return nil
   683  }
   684  
   685  // Request message for releasing lease.
   686  type ReleaseLeaseRequest struct {
   687  	state         protoimpl.MessageState
   688  	sizeCache     protoimpl.SizeCache
   689  	unknownFields protoimpl.UnknownFields
   690  
   691  	// Lease id.
   692  	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
   693  	// Series name.
   694  	Series string `protobuf:"bytes,2,opt,name=series,proto3" json:"series,omitempty"`
   695  	// Lease owner.
   696  	Owner string `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"`
   697  }
   698  
   699  func (x *ReleaseLeaseRequest) Reset() {
   700  	*x = ReleaseLeaseRequest{}
   701  	if protoimpl.UnsafeEnabled {
   702  		mi := &file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[7]
   703  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   704  		ms.StoreMessageInfo(mi)
   705  	}
   706  }
   707  
   708  func (x *ReleaseLeaseRequest) String() string {
   709  	return protoimpl.X.MessageStringOf(x)
   710  }
   711  
   712  func (*ReleaseLeaseRequest) ProtoMessage() {}
   713  
   714  func (x *ReleaseLeaseRequest) ProtoReflect() protoreflect.Message {
   715  	mi := &file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[7]
   716  	if protoimpl.UnsafeEnabled && x != nil {
   717  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   718  		if ms.LoadMessageInfo() == nil {
   719  			ms.StoreMessageInfo(mi)
   720  		}
   721  		return ms
   722  	}
   723  	return mi.MessageOf(x)
   724  }
   725  
   726  // Deprecated: Use ReleaseLeaseRequest.ProtoReflect.Descriptor instead.
   727  func (*ReleaseLeaseRequest) Descriptor() ([]byte, []int) {
   728  	return file_google_cloud_visionai_v1alpha1_streaming_service_proto_rawDescGZIP(), []int{7}
   729  }
   730  
   731  func (x *ReleaseLeaseRequest) GetId() string {
   732  	if x != nil {
   733  		return x.Id
   734  	}
   735  	return ""
   736  }
   737  
   738  func (x *ReleaseLeaseRequest) GetSeries() string {
   739  	if x != nil {
   740  		return x.Series
   741  	}
   742  	return ""
   743  }
   744  
   745  func (x *ReleaseLeaseRequest) GetOwner() string {
   746  	if x != nil {
   747  		return x.Owner
   748  	}
   749  	return ""
   750  }
   751  
   752  // Response message for release lease.
   753  type ReleaseLeaseResponse struct {
   754  	state         protoimpl.MessageState
   755  	sizeCache     protoimpl.SizeCache
   756  	unknownFields protoimpl.UnknownFields
   757  }
   758  
   759  func (x *ReleaseLeaseResponse) Reset() {
   760  	*x = ReleaseLeaseResponse{}
   761  	if protoimpl.UnsafeEnabled {
   762  		mi := &file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[8]
   763  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   764  		ms.StoreMessageInfo(mi)
   765  	}
   766  }
   767  
   768  func (x *ReleaseLeaseResponse) String() string {
   769  	return protoimpl.X.MessageStringOf(x)
   770  }
   771  
   772  func (*ReleaseLeaseResponse) ProtoMessage() {}
   773  
   774  func (x *ReleaseLeaseResponse) ProtoReflect() protoreflect.Message {
   775  	mi := &file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[8]
   776  	if protoimpl.UnsafeEnabled && x != nil {
   777  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   778  		if ms.LoadMessageInfo() == nil {
   779  			ms.StoreMessageInfo(mi)
   780  		}
   781  		return ms
   782  	}
   783  	return mi.MessageOf(x)
   784  }
   785  
   786  // Deprecated: Use ReleaseLeaseResponse.ProtoReflect.Descriptor instead.
   787  func (*ReleaseLeaseResponse) Descriptor() ([]byte, []int) {
   788  	return file_google_cloud_visionai_v1alpha1_streaming_service_proto_rawDescGZIP(), []int{8}
   789  }
   790  
   791  // RequestMetadata is the metadata message for the request.
   792  type RequestMetadata struct {
   793  	state         protoimpl.MessageState
   794  	sizeCache     protoimpl.SizeCache
   795  	unknownFields protoimpl.UnknownFields
   796  
   797  	// Stream name.
   798  	Stream string `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"`
   799  	// Evevt name.
   800  	Event string `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
   801  	// Series name.
   802  	Series string `protobuf:"bytes,3,opt,name=series,proto3" json:"series,omitempty"`
   803  	// Lease id.
   804  	LeaseId string `protobuf:"bytes,4,opt,name=lease_id,json=leaseId,proto3" json:"lease_id,omitempty"`
   805  	// Owner name.
   806  	Owner string `protobuf:"bytes,5,opt,name=owner,proto3" json:"owner,omitempty"`
   807  	// Lease term specifies how long the client wants the session to be maintained
   808  	// by the server after the client leaves. If the lease term is not set, the
   809  	// server will release the session immediately and the client cannot reconnect
   810  	// to the same session later.
   811  	LeaseTerm *durationpb.Duration `protobuf:"bytes,6,opt,name=lease_term,json=leaseTerm,proto3" json:"lease_term,omitempty"`
   812  }
   813  
   814  func (x *RequestMetadata) Reset() {
   815  	*x = RequestMetadata{}
   816  	if protoimpl.UnsafeEnabled {
   817  		mi := &file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[9]
   818  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   819  		ms.StoreMessageInfo(mi)
   820  	}
   821  }
   822  
   823  func (x *RequestMetadata) String() string {
   824  	return protoimpl.X.MessageStringOf(x)
   825  }
   826  
   827  func (*RequestMetadata) ProtoMessage() {}
   828  
   829  func (x *RequestMetadata) ProtoReflect() protoreflect.Message {
   830  	mi := &file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[9]
   831  	if protoimpl.UnsafeEnabled && x != nil {
   832  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   833  		if ms.LoadMessageInfo() == nil {
   834  			ms.StoreMessageInfo(mi)
   835  		}
   836  		return ms
   837  	}
   838  	return mi.MessageOf(x)
   839  }
   840  
   841  // Deprecated: Use RequestMetadata.ProtoReflect.Descriptor instead.
   842  func (*RequestMetadata) Descriptor() ([]byte, []int) {
   843  	return file_google_cloud_visionai_v1alpha1_streaming_service_proto_rawDescGZIP(), []int{9}
   844  }
   845  
   846  func (x *RequestMetadata) GetStream() string {
   847  	if x != nil {
   848  		return x.Stream
   849  	}
   850  	return ""
   851  }
   852  
   853  func (x *RequestMetadata) GetEvent() string {
   854  	if x != nil {
   855  		return x.Event
   856  	}
   857  	return ""
   858  }
   859  
   860  func (x *RequestMetadata) GetSeries() string {
   861  	if x != nil {
   862  		return x.Series
   863  	}
   864  	return ""
   865  }
   866  
   867  func (x *RequestMetadata) GetLeaseId() string {
   868  	if x != nil {
   869  		return x.LeaseId
   870  	}
   871  	return ""
   872  }
   873  
   874  func (x *RequestMetadata) GetOwner() string {
   875  	if x != nil {
   876  		return x.Owner
   877  	}
   878  	return ""
   879  }
   880  
   881  func (x *RequestMetadata) GetLeaseTerm() *durationpb.Duration {
   882  	if x != nil {
   883  		return x.LeaseTerm
   884  	}
   885  	return nil
   886  }
   887  
   888  // Request message for sending packets.
   889  type SendPacketsRequest struct {
   890  	state         protoimpl.MessageState
   891  	sizeCache     protoimpl.SizeCache
   892  	unknownFields protoimpl.UnknownFields
   893  
   894  	// Types that are assignable to Request:
   895  	//
   896  	//	*SendPacketsRequest_Packet
   897  	//	*SendPacketsRequest_Metadata
   898  	Request isSendPacketsRequest_Request `protobuf_oneof:"request"`
   899  }
   900  
   901  func (x *SendPacketsRequest) Reset() {
   902  	*x = SendPacketsRequest{}
   903  	if protoimpl.UnsafeEnabled {
   904  		mi := &file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[10]
   905  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   906  		ms.StoreMessageInfo(mi)
   907  	}
   908  }
   909  
   910  func (x *SendPacketsRequest) String() string {
   911  	return protoimpl.X.MessageStringOf(x)
   912  }
   913  
   914  func (*SendPacketsRequest) ProtoMessage() {}
   915  
   916  func (x *SendPacketsRequest) ProtoReflect() protoreflect.Message {
   917  	mi := &file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[10]
   918  	if protoimpl.UnsafeEnabled && x != nil {
   919  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   920  		if ms.LoadMessageInfo() == nil {
   921  			ms.StoreMessageInfo(mi)
   922  		}
   923  		return ms
   924  	}
   925  	return mi.MessageOf(x)
   926  }
   927  
   928  // Deprecated: Use SendPacketsRequest.ProtoReflect.Descriptor instead.
   929  func (*SendPacketsRequest) Descriptor() ([]byte, []int) {
   930  	return file_google_cloud_visionai_v1alpha1_streaming_service_proto_rawDescGZIP(), []int{10}
   931  }
   932  
   933  func (m *SendPacketsRequest) GetRequest() isSendPacketsRequest_Request {
   934  	if m != nil {
   935  		return m.Request
   936  	}
   937  	return nil
   938  }
   939  
   940  func (x *SendPacketsRequest) GetPacket() *Packet {
   941  	if x, ok := x.GetRequest().(*SendPacketsRequest_Packet); ok {
   942  		return x.Packet
   943  	}
   944  	return nil
   945  }
   946  
   947  func (x *SendPacketsRequest) GetMetadata() *RequestMetadata {
   948  	if x, ok := x.GetRequest().(*SendPacketsRequest_Metadata); ok {
   949  		return x.Metadata
   950  	}
   951  	return nil
   952  }
   953  
   954  type isSendPacketsRequest_Request interface {
   955  	isSendPacketsRequest_Request()
   956  }
   957  
   958  type SendPacketsRequest_Packet struct {
   959  	// Packets sent over the streaming rpc.
   960  	Packet *Packet `protobuf:"bytes,1,opt,name=packet,proto3,oneof"`
   961  }
   962  
   963  type SendPacketsRequest_Metadata struct {
   964  	// The first message of the streaming rpc including the request metadata.
   965  	Metadata *RequestMetadata `protobuf:"bytes,2,opt,name=metadata,proto3,oneof"`
   966  }
   967  
   968  func (*SendPacketsRequest_Packet) isSendPacketsRequest_Request() {}
   969  
   970  func (*SendPacketsRequest_Metadata) isSendPacketsRequest_Request() {}
   971  
   972  // Response message for sending packets.
   973  type SendPacketsResponse struct {
   974  	state         protoimpl.MessageState
   975  	sizeCache     protoimpl.SizeCache
   976  	unknownFields protoimpl.UnknownFields
   977  }
   978  
   979  func (x *SendPacketsResponse) Reset() {
   980  	*x = SendPacketsResponse{}
   981  	if protoimpl.UnsafeEnabled {
   982  		mi := &file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[11]
   983  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   984  		ms.StoreMessageInfo(mi)
   985  	}
   986  }
   987  
   988  func (x *SendPacketsResponse) String() string {
   989  	return protoimpl.X.MessageStringOf(x)
   990  }
   991  
   992  func (*SendPacketsResponse) ProtoMessage() {}
   993  
   994  func (x *SendPacketsResponse) ProtoReflect() protoreflect.Message {
   995  	mi := &file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[11]
   996  	if protoimpl.UnsafeEnabled && x != nil {
   997  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   998  		if ms.LoadMessageInfo() == nil {
   999  			ms.StoreMessageInfo(mi)
  1000  		}
  1001  		return ms
  1002  	}
  1003  	return mi.MessageOf(x)
  1004  }
  1005  
  1006  // Deprecated: Use SendPacketsResponse.ProtoReflect.Descriptor instead.
  1007  func (*SendPacketsResponse) Descriptor() ([]byte, []int) {
  1008  	return file_google_cloud_visionai_v1alpha1_streaming_service_proto_rawDescGZIP(), []int{11}
  1009  }
  1010  
  1011  // Request message for receiving packets.
  1012  type ReceivePacketsRequest struct {
  1013  	state         protoimpl.MessageState
  1014  	sizeCache     protoimpl.SizeCache
  1015  	unknownFields protoimpl.UnknownFields
  1016  
  1017  	// Possible request types from the client.
  1018  	//
  1019  	// Types that are assignable to Request:
  1020  	//
  1021  	//	*ReceivePacketsRequest_SetupRequest_
  1022  	//	*ReceivePacketsRequest_CommitRequest
  1023  	Request isReceivePacketsRequest_Request `protobuf_oneof:"request"`
  1024  }
  1025  
  1026  func (x *ReceivePacketsRequest) Reset() {
  1027  	*x = ReceivePacketsRequest{}
  1028  	if protoimpl.UnsafeEnabled {
  1029  		mi := &file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[12]
  1030  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1031  		ms.StoreMessageInfo(mi)
  1032  	}
  1033  }
  1034  
  1035  func (x *ReceivePacketsRequest) String() string {
  1036  	return protoimpl.X.MessageStringOf(x)
  1037  }
  1038  
  1039  func (*ReceivePacketsRequest) ProtoMessage() {}
  1040  
  1041  func (x *ReceivePacketsRequest) ProtoReflect() protoreflect.Message {
  1042  	mi := &file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[12]
  1043  	if protoimpl.UnsafeEnabled && x != nil {
  1044  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1045  		if ms.LoadMessageInfo() == nil {
  1046  			ms.StoreMessageInfo(mi)
  1047  		}
  1048  		return ms
  1049  	}
  1050  	return mi.MessageOf(x)
  1051  }
  1052  
  1053  // Deprecated: Use ReceivePacketsRequest.ProtoReflect.Descriptor instead.
  1054  func (*ReceivePacketsRequest) Descriptor() ([]byte, []int) {
  1055  	return file_google_cloud_visionai_v1alpha1_streaming_service_proto_rawDescGZIP(), []int{12}
  1056  }
  1057  
  1058  func (m *ReceivePacketsRequest) GetRequest() isReceivePacketsRequest_Request {
  1059  	if m != nil {
  1060  		return m.Request
  1061  	}
  1062  	return nil
  1063  }
  1064  
  1065  func (x *ReceivePacketsRequest) GetSetupRequest() *ReceivePacketsRequest_SetupRequest {
  1066  	if x, ok := x.GetRequest().(*ReceivePacketsRequest_SetupRequest_); ok {
  1067  		return x.SetupRequest
  1068  	}
  1069  	return nil
  1070  }
  1071  
  1072  func (x *ReceivePacketsRequest) GetCommitRequest() *CommitRequest {
  1073  	if x, ok := x.GetRequest().(*ReceivePacketsRequest_CommitRequest); ok {
  1074  		return x.CommitRequest
  1075  	}
  1076  	return nil
  1077  }
  1078  
  1079  type isReceivePacketsRequest_Request interface {
  1080  	isReceivePacketsRequest_Request()
  1081  }
  1082  
  1083  type ReceivePacketsRequest_SetupRequest_ struct {
  1084  	// The request to setup the initial state of session.
  1085  	//
  1086  	// The client must send and only send this as the first message.
  1087  	SetupRequest *ReceivePacketsRequest_SetupRequest `protobuf:"bytes,6,opt,name=setup_request,json=setupRequest,proto3,oneof"`
  1088  }
  1089  
  1090  type ReceivePacketsRequest_CommitRequest struct {
  1091  	// This request checkpoints the consumer's read progress.
  1092  	CommitRequest *CommitRequest `protobuf:"bytes,7,opt,name=commit_request,json=commitRequest,proto3,oneof"`
  1093  }
  1094  
  1095  func (*ReceivePacketsRequest_SetupRequest_) isReceivePacketsRequest_Request() {}
  1096  
  1097  func (*ReceivePacketsRequest_CommitRequest) isReceivePacketsRequest_Request() {}
  1098  
  1099  // Control message for a ReceivePacketsResponse.
  1100  type ReceivePacketsControlResponse struct {
  1101  	state         protoimpl.MessageState
  1102  	sizeCache     protoimpl.SizeCache
  1103  	unknownFields protoimpl.UnknownFields
  1104  
  1105  	// Possible control messages.
  1106  	//
  1107  	// Types that are assignable to Control:
  1108  	//
  1109  	//	*ReceivePacketsControlResponse_Heartbeat
  1110  	//	*ReceivePacketsControlResponse_WritesDoneRequest
  1111  	Control isReceivePacketsControlResponse_Control `protobuf_oneof:"control"`
  1112  }
  1113  
  1114  func (x *ReceivePacketsControlResponse) Reset() {
  1115  	*x = ReceivePacketsControlResponse{}
  1116  	if protoimpl.UnsafeEnabled {
  1117  		mi := &file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[13]
  1118  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1119  		ms.StoreMessageInfo(mi)
  1120  	}
  1121  }
  1122  
  1123  func (x *ReceivePacketsControlResponse) String() string {
  1124  	return protoimpl.X.MessageStringOf(x)
  1125  }
  1126  
  1127  func (*ReceivePacketsControlResponse) ProtoMessage() {}
  1128  
  1129  func (x *ReceivePacketsControlResponse) ProtoReflect() protoreflect.Message {
  1130  	mi := &file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[13]
  1131  	if protoimpl.UnsafeEnabled && x != nil {
  1132  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1133  		if ms.LoadMessageInfo() == nil {
  1134  			ms.StoreMessageInfo(mi)
  1135  		}
  1136  		return ms
  1137  	}
  1138  	return mi.MessageOf(x)
  1139  }
  1140  
  1141  // Deprecated: Use ReceivePacketsControlResponse.ProtoReflect.Descriptor instead.
  1142  func (*ReceivePacketsControlResponse) Descriptor() ([]byte, []int) {
  1143  	return file_google_cloud_visionai_v1alpha1_streaming_service_proto_rawDescGZIP(), []int{13}
  1144  }
  1145  
  1146  func (m *ReceivePacketsControlResponse) GetControl() isReceivePacketsControlResponse_Control {
  1147  	if m != nil {
  1148  		return m.Control
  1149  	}
  1150  	return nil
  1151  }
  1152  
  1153  func (x *ReceivePacketsControlResponse) GetHeartbeat() bool {
  1154  	if x, ok := x.GetControl().(*ReceivePacketsControlResponse_Heartbeat); ok {
  1155  		return x.Heartbeat
  1156  	}
  1157  	return false
  1158  }
  1159  
  1160  func (x *ReceivePacketsControlResponse) GetWritesDoneRequest() bool {
  1161  	if x, ok := x.GetControl().(*ReceivePacketsControlResponse_WritesDoneRequest); ok {
  1162  		return x.WritesDoneRequest
  1163  	}
  1164  	return false
  1165  }
  1166  
  1167  type isReceivePacketsControlResponse_Control interface {
  1168  	isReceivePacketsControlResponse_Control()
  1169  }
  1170  
  1171  type ReceivePacketsControlResponse_Heartbeat struct {
  1172  	// A server heartbeat.
  1173  	Heartbeat bool `protobuf:"varint,1,opt,name=heartbeat,proto3,oneof"`
  1174  }
  1175  
  1176  type ReceivePacketsControlResponse_WritesDoneRequest struct {
  1177  	// A request to the receiver to complete any final writes followed by a
  1178  	// `WritesDone`; e.g. issue any final `CommitRequest`s.
  1179  	//
  1180  	// May be ignored if `WritesDone` has already been issued at any point
  1181  	// prior to receiving this message.
  1182  	//
  1183  	// If `WritesDone` does not get issued, then the server will forcefully
  1184  	// cancel the connection, and the receiver will likely receive an
  1185  	// uninformative after `Read` returns `false` and `Finish` is called.
  1186  	WritesDoneRequest bool `protobuf:"varint,2,opt,name=writes_done_request,json=writesDoneRequest,proto3,oneof"`
  1187  }
  1188  
  1189  func (*ReceivePacketsControlResponse_Heartbeat) isReceivePacketsControlResponse_Control() {}
  1190  
  1191  func (*ReceivePacketsControlResponse_WritesDoneRequest) isReceivePacketsControlResponse_Control() {}
  1192  
  1193  // Response message from ReceivePackets.
  1194  type ReceivePacketsResponse struct {
  1195  	state         protoimpl.MessageState
  1196  	sizeCache     protoimpl.SizeCache
  1197  	unknownFields protoimpl.UnknownFields
  1198  
  1199  	// Possible response types.
  1200  	//
  1201  	// Types that are assignable to Response:
  1202  	//
  1203  	//	*ReceivePacketsResponse_Packet
  1204  	//	*ReceivePacketsResponse_Control
  1205  	Response isReceivePacketsResponse_Response `protobuf_oneof:"response"`
  1206  }
  1207  
  1208  func (x *ReceivePacketsResponse) Reset() {
  1209  	*x = ReceivePacketsResponse{}
  1210  	if protoimpl.UnsafeEnabled {
  1211  		mi := &file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[14]
  1212  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1213  		ms.StoreMessageInfo(mi)
  1214  	}
  1215  }
  1216  
  1217  func (x *ReceivePacketsResponse) String() string {
  1218  	return protoimpl.X.MessageStringOf(x)
  1219  }
  1220  
  1221  func (*ReceivePacketsResponse) ProtoMessage() {}
  1222  
  1223  func (x *ReceivePacketsResponse) ProtoReflect() protoreflect.Message {
  1224  	mi := &file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[14]
  1225  	if protoimpl.UnsafeEnabled && x != nil {
  1226  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1227  		if ms.LoadMessageInfo() == nil {
  1228  			ms.StoreMessageInfo(mi)
  1229  		}
  1230  		return ms
  1231  	}
  1232  	return mi.MessageOf(x)
  1233  }
  1234  
  1235  // Deprecated: Use ReceivePacketsResponse.ProtoReflect.Descriptor instead.
  1236  func (*ReceivePacketsResponse) Descriptor() ([]byte, []int) {
  1237  	return file_google_cloud_visionai_v1alpha1_streaming_service_proto_rawDescGZIP(), []int{14}
  1238  }
  1239  
  1240  func (m *ReceivePacketsResponse) GetResponse() isReceivePacketsResponse_Response {
  1241  	if m != nil {
  1242  		return m.Response
  1243  	}
  1244  	return nil
  1245  }
  1246  
  1247  func (x *ReceivePacketsResponse) GetPacket() *Packet {
  1248  	if x, ok := x.GetResponse().(*ReceivePacketsResponse_Packet); ok {
  1249  		return x.Packet
  1250  	}
  1251  	return nil
  1252  }
  1253  
  1254  func (x *ReceivePacketsResponse) GetControl() *ReceivePacketsControlResponse {
  1255  	if x, ok := x.GetResponse().(*ReceivePacketsResponse_Control); ok {
  1256  		return x.Control
  1257  	}
  1258  	return nil
  1259  }
  1260  
  1261  type isReceivePacketsResponse_Response interface {
  1262  	isReceivePacketsResponse_Response()
  1263  }
  1264  
  1265  type ReceivePacketsResponse_Packet struct {
  1266  	// A genuine data payload originating from the sender.
  1267  	Packet *Packet `protobuf:"bytes,1,opt,name=packet,proto3,oneof"`
  1268  }
  1269  
  1270  type ReceivePacketsResponse_Control struct {
  1271  	// A control message from the server.
  1272  	Control *ReceivePacketsControlResponse `protobuf:"bytes,3,opt,name=control,proto3,oneof"`
  1273  }
  1274  
  1275  func (*ReceivePacketsResponse_Packet) isReceivePacketsResponse_Response() {}
  1276  
  1277  func (*ReceivePacketsResponse_Control) isReceivePacketsResponse_Response() {}
  1278  
  1279  // The options for receiver under the eager mode.
  1280  type EagerMode struct {
  1281  	state         protoimpl.MessageState
  1282  	sizeCache     protoimpl.SizeCache
  1283  	unknownFields protoimpl.UnknownFields
  1284  }
  1285  
  1286  func (x *EagerMode) Reset() {
  1287  	*x = EagerMode{}
  1288  	if protoimpl.UnsafeEnabled {
  1289  		mi := &file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[15]
  1290  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1291  		ms.StoreMessageInfo(mi)
  1292  	}
  1293  }
  1294  
  1295  func (x *EagerMode) String() string {
  1296  	return protoimpl.X.MessageStringOf(x)
  1297  }
  1298  
  1299  func (*EagerMode) ProtoMessage() {}
  1300  
  1301  func (x *EagerMode) ProtoReflect() protoreflect.Message {
  1302  	mi := &file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[15]
  1303  	if protoimpl.UnsafeEnabled && x != nil {
  1304  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1305  		if ms.LoadMessageInfo() == nil {
  1306  			ms.StoreMessageInfo(mi)
  1307  		}
  1308  		return ms
  1309  	}
  1310  	return mi.MessageOf(x)
  1311  }
  1312  
  1313  // Deprecated: Use EagerMode.ProtoReflect.Descriptor instead.
  1314  func (*EagerMode) Descriptor() ([]byte, []int) {
  1315  	return file_google_cloud_visionai_v1alpha1_streaming_service_proto_rawDescGZIP(), []int{15}
  1316  }
  1317  
  1318  // The options for receiver under the controlled mode.
  1319  type ControlledMode struct {
  1320  	state         protoimpl.MessageState
  1321  	sizeCache     protoimpl.SizeCache
  1322  	unknownFields protoimpl.UnknownFields
  1323  
  1324  	// This is the offset from which to start receiveing.
  1325  	//
  1326  	// Types that are assignable to StartingOffset:
  1327  	//
  1328  	//	*ControlledMode_StartingLogicalOffset
  1329  	StartingOffset isControlledMode_StartingOffset `protobuf_oneof:"starting_offset"`
  1330  	// This is the logical starting point to fallback upon should the
  1331  	// specified starting offset be unavailable.
  1332  	//
  1333  	// This can be one of the following values:
  1334  	//
  1335  	// "begin": This will read from the earliest available message.
  1336  	//
  1337  	// "end": This will read only future messages.
  1338  	FallbackStartingOffset string `protobuf:"bytes,2,opt,name=fallback_starting_offset,json=fallbackStartingOffset,proto3" json:"fallback_starting_offset,omitempty"`
  1339  }
  1340  
  1341  func (x *ControlledMode) Reset() {
  1342  	*x = ControlledMode{}
  1343  	if protoimpl.UnsafeEnabled {
  1344  		mi := &file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[16]
  1345  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1346  		ms.StoreMessageInfo(mi)
  1347  	}
  1348  }
  1349  
  1350  func (x *ControlledMode) String() string {
  1351  	return protoimpl.X.MessageStringOf(x)
  1352  }
  1353  
  1354  func (*ControlledMode) ProtoMessage() {}
  1355  
  1356  func (x *ControlledMode) ProtoReflect() protoreflect.Message {
  1357  	mi := &file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[16]
  1358  	if protoimpl.UnsafeEnabled && x != nil {
  1359  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1360  		if ms.LoadMessageInfo() == nil {
  1361  			ms.StoreMessageInfo(mi)
  1362  		}
  1363  		return ms
  1364  	}
  1365  	return mi.MessageOf(x)
  1366  }
  1367  
  1368  // Deprecated: Use ControlledMode.ProtoReflect.Descriptor instead.
  1369  func (*ControlledMode) Descriptor() ([]byte, []int) {
  1370  	return file_google_cloud_visionai_v1alpha1_streaming_service_proto_rawDescGZIP(), []int{16}
  1371  }
  1372  
  1373  func (m *ControlledMode) GetStartingOffset() isControlledMode_StartingOffset {
  1374  	if m != nil {
  1375  		return m.StartingOffset
  1376  	}
  1377  	return nil
  1378  }
  1379  
  1380  func (x *ControlledMode) GetStartingLogicalOffset() string {
  1381  	if x, ok := x.GetStartingOffset().(*ControlledMode_StartingLogicalOffset); ok {
  1382  		return x.StartingLogicalOffset
  1383  	}
  1384  	return ""
  1385  }
  1386  
  1387  func (x *ControlledMode) GetFallbackStartingOffset() string {
  1388  	if x != nil {
  1389  		return x.FallbackStartingOffset
  1390  	}
  1391  	return ""
  1392  }
  1393  
  1394  type isControlledMode_StartingOffset interface {
  1395  	isControlledMode_StartingOffset()
  1396  }
  1397  
  1398  type ControlledMode_StartingLogicalOffset struct {
  1399  	// This can be set to the following logical starting points:
  1400  	//
  1401  	// "begin": This will read from the earliest available message.
  1402  	//
  1403  	// "most-recent": This will read from the latest available message.
  1404  	//
  1405  	// "end": This will read only future messages.
  1406  	//
  1407  	// "stored": This will resume reads one past the last committed offset.
  1408  	//
  1409  	//	It is the only option that resumes progress; all others
  1410  	//	jump unilaterally.
  1411  	StartingLogicalOffset string `protobuf:"bytes,1,opt,name=starting_logical_offset,json=startingLogicalOffset,proto3,oneof"`
  1412  }
  1413  
  1414  func (*ControlledMode_StartingLogicalOffset) isControlledMode_StartingOffset() {}
  1415  
  1416  // The message for explicitly committing the read progress.
  1417  //
  1418  // This may only be used when `ReceivePacketsControlledMode` is set in the
  1419  // initial setup request.
  1420  type CommitRequest struct {
  1421  	state         protoimpl.MessageState
  1422  	sizeCache     protoimpl.SizeCache
  1423  	unknownFields protoimpl.UnknownFields
  1424  
  1425  	// The offset to commit.
  1426  	Offset int64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
  1427  }
  1428  
  1429  func (x *CommitRequest) Reset() {
  1430  	*x = CommitRequest{}
  1431  	if protoimpl.UnsafeEnabled {
  1432  		mi := &file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[17]
  1433  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1434  		ms.StoreMessageInfo(mi)
  1435  	}
  1436  }
  1437  
  1438  func (x *CommitRequest) String() string {
  1439  	return protoimpl.X.MessageStringOf(x)
  1440  }
  1441  
  1442  func (*CommitRequest) ProtoMessage() {}
  1443  
  1444  func (x *CommitRequest) ProtoReflect() protoreflect.Message {
  1445  	mi := &file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[17]
  1446  	if protoimpl.UnsafeEnabled && x != nil {
  1447  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1448  		if ms.LoadMessageInfo() == nil {
  1449  			ms.StoreMessageInfo(mi)
  1450  		}
  1451  		return ms
  1452  	}
  1453  	return mi.MessageOf(x)
  1454  }
  1455  
  1456  // Deprecated: Use CommitRequest.ProtoReflect.Descriptor instead.
  1457  func (*CommitRequest) Descriptor() ([]byte, []int) {
  1458  	return file_google_cloud_visionai_v1alpha1_streaming_service_proto_rawDescGZIP(), []int{17}
  1459  }
  1460  
  1461  func (x *CommitRequest) GetOffset() int64 {
  1462  	if x != nil {
  1463  		return x.Offset
  1464  	}
  1465  	return 0
  1466  }
  1467  
  1468  // SetupRequest is the first message sent to the service to setup the RPC
  1469  // connection.
  1470  type ReceiveEventsRequest_SetupRequest struct {
  1471  	state         protoimpl.MessageState
  1472  	sizeCache     protoimpl.SizeCache
  1473  	unknownFields protoimpl.UnknownFields
  1474  
  1475  	// The cluster name.
  1476  	Cluster string `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
  1477  	// The stream name. The service will return the events for the given stream.
  1478  	Stream string `protobuf:"bytes,2,opt,name=stream,proto3" json:"stream,omitempty"`
  1479  	// A name for the receiver to self-identify.
  1480  	//
  1481  	// This is used to keep track of a receiver's read progress.
  1482  	Receiver string `protobuf:"bytes,3,opt,name=receiver,proto3" json:"receiver,omitempty"`
  1483  	// Controller mode configuration for receiving events from the server.
  1484  	ControlledMode *ControlledMode `protobuf:"bytes,4,opt,name=controlled_mode,json=controlledMode,proto3" json:"controlled_mode,omitempty"`
  1485  	// The maximum duration of server silence before the client determines the
  1486  	// server unreachable.
  1487  	//
  1488  	// The client must either receive an `Event` update or a heart beat message
  1489  	// before this duration expires; otherwise, the client will automatically
  1490  	// cancel the current connection and retry.
  1491  	HeartbeatInterval *durationpb.Duration `protobuf:"bytes,5,opt,name=heartbeat_interval,json=heartbeatInterval,proto3" json:"heartbeat_interval,omitempty"`
  1492  	// The grace period after which a `writes_done_request` is issued, that a
  1493  	// `WritesDone` is expected from the client.
  1494  	//
  1495  	// The server is free to cancel the RPC should this expire.
  1496  	//
  1497  	// A system default will be chosen if unset.
  1498  	WritesDoneGracePeriod *durationpb.Duration `protobuf:"bytes,6,opt,name=writes_done_grace_period,json=writesDoneGracePeriod,proto3" json:"writes_done_grace_period,omitempty"`
  1499  }
  1500  
  1501  func (x *ReceiveEventsRequest_SetupRequest) Reset() {
  1502  	*x = ReceiveEventsRequest_SetupRequest{}
  1503  	if protoimpl.UnsafeEnabled {
  1504  		mi := &file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[18]
  1505  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1506  		ms.StoreMessageInfo(mi)
  1507  	}
  1508  }
  1509  
  1510  func (x *ReceiveEventsRequest_SetupRequest) String() string {
  1511  	return protoimpl.X.MessageStringOf(x)
  1512  }
  1513  
  1514  func (*ReceiveEventsRequest_SetupRequest) ProtoMessage() {}
  1515  
  1516  func (x *ReceiveEventsRequest_SetupRequest) ProtoReflect() protoreflect.Message {
  1517  	mi := &file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[18]
  1518  	if protoimpl.UnsafeEnabled && x != nil {
  1519  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1520  		if ms.LoadMessageInfo() == nil {
  1521  			ms.StoreMessageInfo(mi)
  1522  		}
  1523  		return ms
  1524  	}
  1525  	return mi.MessageOf(x)
  1526  }
  1527  
  1528  // Deprecated: Use ReceiveEventsRequest_SetupRequest.ProtoReflect.Descriptor instead.
  1529  func (*ReceiveEventsRequest_SetupRequest) Descriptor() ([]byte, []int) {
  1530  	return file_google_cloud_visionai_v1alpha1_streaming_service_proto_rawDescGZIP(), []int{0, 0}
  1531  }
  1532  
  1533  func (x *ReceiveEventsRequest_SetupRequest) GetCluster() string {
  1534  	if x != nil {
  1535  		return x.Cluster
  1536  	}
  1537  	return ""
  1538  }
  1539  
  1540  func (x *ReceiveEventsRequest_SetupRequest) GetStream() string {
  1541  	if x != nil {
  1542  		return x.Stream
  1543  	}
  1544  	return ""
  1545  }
  1546  
  1547  func (x *ReceiveEventsRequest_SetupRequest) GetReceiver() string {
  1548  	if x != nil {
  1549  		return x.Receiver
  1550  	}
  1551  	return ""
  1552  }
  1553  
  1554  func (x *ReceiveEventsRequest_SetupRequest) GetControlledMode() *ControlledMode {
  1555  	if x != nil {
  1556  		return x.ControlledMode
  1557  	}
  1558  	return nil
  1559  }
  1560  
  1561  func (x *ReceiveEventsRequest_SetupRequest) GetHeartbeatInterval() *durationpb.Duration {
  1562  	if x != nil {
  1563  		return x.HeartbeatInterval
  1564  	}
  1565  	return nil
  1566  }
  1567  
  1568  func (x *ReceiveEventsRequest_SetupRequest) GetWritesDoneGracePeriod() *durationpb.Duration {
  1569  	if x != nil {
  1570  		return x.WritesDoneGracePeriod
  1571  	}
  1572  	return nil
  1573  }
  1574  
  1575  // The message specifying the initial settings for the ReceivePackets session.
  1576  type ReceivePacketsRequest_SetupRequest struct {
  1577  	state         protoimpl.MessageState
  1578  	sizeCache     protoimpl.SizeCache
  1579  	unknownFields protoimpl.UnknownFields
  1580  
  1581  	// The mode in which the consumer reads messages.
  1582  	//
  1583  	// Types that are assignable to ConsumerMode:
  1584  	//
  1585  	//	*ReceivePacketsRequest_SetupRequest_EagerReceiveMode
  1586  	//	*ReceivePacketsRequest_SetupRequest_ControlledReceiveMode
  1587  	ConsumerMode isReceivePacketsRequest_SetupRequest_ConsumerMode `protobuf_oneof:"consumer_mode"`
  1588  	// The configurations that specify where packets are retrieved.
  1589  	Metadata *RequestMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
  1590  	// A name for the receiver to self-identify.
  1591  	//
  1592  	// This is used to keep track of a receiver's read progress.
  1593  	Receiver string `protobuf:"bytes,2,opt,name=receiver,proto3" json:"receiver,omitempty"`
  1594  	// The maximum duration of server silence before the client determines the
  1595  	// server unreachable.
  1596  	//
  1597  	// The client must either receive a `Packet` or a heart beat message before
  1598  	// this duration expires; otherwise, the client will automatically cancel
  1599  	// the current connection and retry.
  1600  	HeartbeatInterval *durationpb.Duration `protobuf:"bytes,5,opt,name=heartbeat_interval,json=heartbeatInterval,proto3" json:"heartbeat_interval,omitempty"`
  1601  	// The grace period after which a `writes_done_request` is issued, that a
  1602  	// `WritesDone` is expected from the client.
  1603  	//
  1604  	// The server is free to cancel the RPC should this expire.
  1605  	//
  1606  	// A system default will be chosen if unset.
  1607  	WritesDoneGracePeriod *durationpb.Duration `protobuf:"bytes,6,opt,name=writes_done_grace_period,json=writesDoneGracePeriod,proto3" json:"writes_done_grace_period,omitempty"`
  1608  }
  1609  
  1610  func (x *ReceivePacketsRequest_SetupRequest) Reset() {
  1611  	*x = ReceivePacketsRequest_SetupRequest{}
  1612  	if protoimpl.UnsafeEnabled {
  1613  		mi := &file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[19]
  1614  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1615  		ms.StoreMessageInfo(mi)
  1616  	}
  1617  }
  1618  
  1619  func (x *ReceivePacketsRequest_SetupRequest) String() string {
  1620  	return protoimpl.X.MessageStringOf(x)
  1621  }
  1622  
  1623  func (*ReceivePacketsRequest_SetupRequest) ProtoMessage() {}
  1624  
  1625  func (x *ReceivePacketsRequest_SetupRequest) ProtoReflect() protoreflect.Message {
  1626  	mi := &file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[19]
  1627  	if protoimpl.UnsafeEnabled && x != nil {
  1628  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1629  		if ms.LoadMessageInfo() == nil {
  1630  			ms.StoreMessageInfo(mi)
  1631  		}
  1632  		return ms
  1633  	}
  1634  	return mi.MessageOf(x)
  1635  }
  1636  
  1637  // Deprecated: Use ReceivePacketsRequest_SetupRequest.ProtoReflect.Descriptor instead.
  1638  func (*ReceivePacketsRequest_SetupRequest) Descriptor() ([]byte, []int) {
  1639  	return file_google_cloud_visionai_v1alpha1_streaming_service_proto_rawDescGZIP(), []int{12, 0}
  1640  }
  1641  
  1642  func (m *ReceivePacketsRequest_SetupRequest) GetConsumerMode() isReceivePacketsRequest_SetupRequest_ConsumerMode {
  1643  	if m != nil {
  1644  		return m.ConsumerMode
  1645  	}
  1646  	return nil
  1647  }
  1648  
  1649  func (x *ReceivePacketsRequest_SetupRequest) GetEagerReceiveMode() *EagerMode {
  1650  	if x, ok := x.GetConsumerMode().(*ReceivePacketsRequest_SetupRequest_EagerReceiveMode); ok {
  1651  		return x.EagerReceiveMode
  1652  	}
  1653  	return nil
  1654  }
  1655  
  1656  func (x *ReceivePacketsRequest_SetupRequest) GetControlledReceiveMode() *ControlledMode {
  1657  	if x, ok := x.GetConsumerMode().(*ReceivePacketsRequest_SetupRequest_ControlledReceiveMode); ok {
  1658  		return x.ControlledReceiveMode
  1659  	}
  1660  	return nil
  1661  }
  1662  
  1663  func (x *ReceivePacketsRequest_SetupRequest) GetMetadata() *RequestMetadata {
  1664  	if x != nil {
  1665  		return x.Metadata
  1666  	}
  1667  	return nil
  1668  }
  1669  
  1670  func (x *ReceivePacketsRequest_SetupRequest) GetReceiver() string {
  1671  	if x != nil {
  1672  		return x.Receiver
  1673  	}
  1674  	return ""
  1675  }
  1676  
  1677  func (x *ReceivePacketsRequest_SetupRequest) GetHeartbeatInterval() *durationpb.Duration {
  1678  	if x != nil {
  1679  		return x.HeartbeatInterval
  1680  	}
  1681  	return nil
  1682  }
  1683  
  1684  func (x *ReceivePacketsRequest_SetupRequest) GetWritesDoneGracePeriod() *durationpb.Duration {
  1685  	if x != nil {
  1686  		return x.WritesDoneGracePeriod
  1687  	}
  1688  	return nil
  1689  }
  1690  
  1691  type isReceivePacketsRequest_SetupRequest_ConsumerMode interface {
  1692  	isReceivePacketsRequest_SetupRequest_ConsumerMode()
  1693  }
  1694  
  1695  type ReceivePacketsRequest_SetupRequest_EagerReceiveMode struct {
  1696  	// Options for configuring eager mode.
  1697  	EagerReceiveMode *EagerMode `protobuf:"bytes,3,opt,name=eager_receive_mode,json=eagerReceiveMode,proto3,oneof"`
  1698  }
  1699  
  1700  type ReceivePacketsRequest_SetupRequest_ControlledReceiveMode struct {
  1701  	// Options for configuring controlled mode.
  1702  	ControlledReceiveMode *ControlledMode `protobuf:"bytes,4,opt,name=controlled_receive_mode,json=controlledReceiveMode,proto3,oneof"`
  1703  }
  1704  
  1705  func (*ReceivePacketsRequest_SetupRequest_EagerReceiveMode) isReceivePacketsRequest_SetupRequest_ConsumerMode() {
  1706  }
  1707  
  1708  func (*ReceivePacketsRequest_SetupRequest_ControlledReceiveMode) isReceivePacketsRequest_SetupRequest_ConsumerMode() {
  1709  }
  1710  
  1711  var File_google_cloud_visionai_v1alpha1_streaming_service_proto protoreflect.FileDescriptor
  1712  
  1713  var file_google_cloud_visionai_v1alpha1_streaming_service_proto_rawDesc = []byte{
  1714  	0x0a, 0x36, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x76,
  1715  	0x69, 0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2f, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31,
  1716  	0x2f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x69, 0x6e, 0x67, 0x5f, 0x73, 0x65, 0x72, 0x76, 0x69,
  1717  	0x63, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x1e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
  1718  	0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2e,
  1719  	0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x1a, 0x1c, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
  1720  	0x2f, 0x61, 0x70, 0x69, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73,
  1721  	0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x17, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61,
  1722  	0x70, 0x69, 0x2f, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a,
  1723  	0x38, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x76, 0x69,
  1724  	0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2f, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2f,
  1725  	0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x69, 0x6e, 0x67, 0x5f, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72,
  1726  	0x63, 0x65, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1e, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
  1727  	0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x64, 0x75, 0x72, 0x61, 0x74,
  1728  	0x69, 0x6f, 0x6e, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1f, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
  1729  	0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x74, 0x69, 0x6d, 0x65, 0x73,
  1730  	0x74, 0x61, 0x6d, 0x70, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0xb9, 0x04, 0x0a, 0x14, 0x52,
  1731  	0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x73, 0x52, 0x65, 0x71, 0x75,
  1732  	0x65, 0x73, 0x74, 0x12, 0x68, 0x0a, 0x0d, 0x73, 0x65, 0x74, 0x75, 0x70, 0x5f, 0x72, 0x65, 0x71,
  1733  	0x75, 0x65, 0x73, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x41, 0x2e, 0x67, 0x6f, 0x6f,
  1734  	0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e,
  1735  	0x61, 0x69, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x52, 0x65, 0x63, 0x65,
  1736  	0x69, 0x76, 0x65, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
  1737  	0x2e, 0x53, 0x65, 0x74, 0x75, 0x70, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x48, 0x00, 0x52,
  1738  	0x0c, 0x73, 0x65, 0x74, 0x75, 0x70, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x56, 0x0a,
  1739  	0x0e, 0x63, 0x6f, 0x6d, 0x6d, 0x69, 0x74, 0x5f, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x18,
  1740  	0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63,
  1741  	0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2e, 0x76, 0x31,
  1742  	0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x43, 0x6f, 0x6d, 0x6d, 0x69, 0x74, 0x52, 0x65, 0x71,
  1743  	0x75, 0x65, 0x73, 0x74, 0x48, 0x00, 0x52, 0x0d, 0x63, 0x6f, 0x6d, 0x6d, 0x69, 0x74, 0x52, 0x65,
  1744  	0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0xd3, 0x02, 0x0a, 0x0c, 0x53, 0x65, 0x74, 0x75, 0x70, 0x52,
  1745  	0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x18, 0x0a, 0x07, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65,
  1746  	0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72,
  1747  	0x12, 0x16, 0x0a, 0x06, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09,
  1748  	0x52, 0x06, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x1a, 0x0a, 0x08, 0x72, 0x65, 0x63, 0x65,
  1749  	0x69, 0x76, 0x65, 0x72, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x72, 0x65, 0x63, 0x65,
  1750  	0x69, 0x76, 0x65, 0x72, 0x12, 0x57, 0x0a, 0x0f, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c,
  1751  	0x65, 0x64, 0x5f, 0x6d, 0x6f, 0x64, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2e, 0x2e,
  1752  	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x76, 0x69, 0x73,
  1753  	0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x43,
  1754  	0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65, 0x64, 0x4d, 0x6f, 0x64, 0x65, 0x52, 0x0e, 0x63,
  1755  	0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65, 0x64, 0x4d, 0x6f, 0x64, 0x65, 0x12, 0x48, 0x0a,
  1756  	0x12, 0x68, 0x65, 0x61, 0x72, 0x74, 0x62, 0x65, 0x61, 0x74, 0x5f, 0x69, 0x6e, 0x74, 0x65, 0x72,
  1757  	0x76, 0x61, 0x6c, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x19, 0x2e, 0x67, 0x6f, 0x6f, 0x67,
  1758  	0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x44, 0x75, 0x72, 0x61,
  1759  	0x74, 0x69, 0x6f, 0x6e, 0x52, 0x11, 0x68, 0x65, 0x61, 0x72, 0x74, 0x62, 0x65, 0x61, 0x74, 0x49,
  1760  	0x6e, 0x74, 0x65, 0x72, 0x76, 0x61, 0x6c, 0x12, 0x52, 0x0a, 0x18, 0x77, 0x72, 0x69, 0x74, 0x65,
  1761  	0x73, 0x5f, 0x64, 0x6f, 0x6e, 0x65, 0x5f, 0x67, 0x72, 0x61, 0x63, 0x65, 0x5f, 0x70, 0x65, 0x72,
  1762  	0x69, 0x6f, 0x64, 0x18, 0x06, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x19, 0x2e, 0x67, 0x6f, 0x6f, 0x67,
  1763  	0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x44, 0x75, 0x72, 0x61,
  1764  	0x74, 0x69, 0x6f, 0x6e, 0x52, 0x15, 0x77, 0x72, 0x69, 0x74, 0x65, 0x73, 0x44, 0x6f, 0x6e, 0x65,
  1765  	0x47, 0x72, 0x61, 0x63, 0x65, 0x50, 0x65, 0x72, 0x69, 0x6f, 0x64, 0x42, 0x09, 0x0a, 0x07, 0x72,
  1766  	0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x22, 0xa8, 0x01, 0x0a, 0x0b, 0x45, 0x76, 0x65, 0x6e, 0x74,
  1767  	0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d,
  1768  	0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x14,
  1769  	0x0a, 0x05, 0x65, 0x76, 0x65, 0x6e, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x65,
  1770  	0x76, 0x65, 0x6e, 0x74, 0x12, 0x16, 0x0a, 0x06, 0x73, 0x65, 0x72, 0x69, 0x65, 0x73, 0x18, 0x03,
  1771  	0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x73, 0x65, 0x72, 0x69, 0x65, 0x73, 0x12, 0x3b, 0x0a, 0x0b,
  1772  	0x75, 0x70, 0x64, 0x61, 0x74, 0x65, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28,
  1773  	0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f,
  1774  	0x62, 0x75, 0x66, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x52, 0x0a, 0x75,
  1775  	0x70, 0x64, 0x61, 0x74, 0x65, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x6f, 0x66, 0x66,
  1776  	0x73, 0x65, 0x74, 0x18, 0x05, 0x20, 0x01, 0x28, 0x03, 0x52, 0x06, 0x6f, 0x66, 0x66, 0x73, 0x65,
  1777  	0x74, 0x22, 0x7b, 0x0a, 0x1c, 0x52, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x45, 0x76, 0x65, 0x6e,
  1778  	0x74, 0x73, 0x43, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73,
  1779  	0x65, 0x12, 0x1e, 0x0a, 0x09, 0x68, 0x65, 0x61, 0x72, 0x74, 0x62, 0x65, 0x61, 0x74, 0x18, 0x01,
  1780  	0x20, 0x01, 0x28, 0x08, 0x48, 0x00, 0x52, 0x09, 0x68, 0x65, 0x61, 0x72, 0x74, 0x62, 0x65, 0x61,
  1781  	0x74, 0x12, 0x30, 0x0a, 0x13, 0x77, 0x72, 0x69, 0x74, 0x65, 0x73, 0x5f, 0x64, 0x6f, 0x6e, 0x65,
  1782  	0x5f, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x08, 0x48, 0x00,
  1783  	0x52, 0x11, 0x77, 0x72, 0x69, 0x74, 0x65, 0x73, 0x44, 0x6f, 0x6e, 0x65, 0x52, 0x65, 0x71, 0x75,
  1784  	0x65, 0x73, 0x74, 0x42, 0x09, 0x0a, 0x07, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x22, 0xcf,
  1785  	0x01, 0x0a, 0x15, 0x52, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x73,
  1786  	0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x50, 0x0a, 0x0c, 0x65, 0x76, 0x65, 0x6e,
  1787  	0x74, 0x5f, 0x75, 0x70, 0x64, 0x61, 0x74, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2b,
  1788  	0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x76, 0x69,
  1789  	0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e,
  1790  	0x45, 0x76, 0x65, 0x6e, 0x74, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x48, 0x00, 0x52, 0x0b, 0x65,
  1791  	0x76, 0x65, 0x6e, 0x74, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x12, 0x58, 0x0a, 0x07, 0x63, 0x6f,
  1792  	0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x3c, 0x2e, 0x67, 0x6f,
  1793  	0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x76, 0x69, 0x73, 0x69, 0x6f,
  1794  	0x6e, 0x61, 0x69, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x52, 0x65, 0x63,
  1795  	0x65, 0x69, 0x76, 0x65, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x73, 0x43, 0x6f, 0x6e, 0x74, 0x72, 0x6f,
  1796  	0x6c, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x48, 0x00, 0x52, 0x07, 0x63, 0x6f, 0x6e,
  1797  	0x74, 0x72, 0x6f, 0x6c, 0x42, 0x0a, 0x0a, 0x08, 0x72, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65,
  1798  	0x22, 0xcc, 0x01, 0x0a, 0x05, 0x4c, 0x65, 0x61, 0x73, 0x65, 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64,
  1799  	0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x02, 0x69, 0x64, 0x12, 0x16, 0x0a, 0x06, 0x73, 0x65,
  1800  	0x72, 0x69, 0x65, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x73, 0x65, 0x72, 0x69,
  1801  	0x65, 0x73, 0x12, 0x14, 0x0a, 0x05, 0x6f, 0x77, 0x6e, 0x65, 0x72, 0x18, 0x03, 0x20, 0x01, 0x28,
  1802  	0x09, 0x52, 0x05, 0x6f, 0x77, 0x6e, 0x65, 0x72, 0x12, 0x3b, 0x0a, 0x0b, 0x65, 0x78, 0x70, 0x69,
  1803  	0x72, 0x65, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e,
  1804  	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e,
  1805  	0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x52, 0x0a, 0x65, 0x78, 0x70, 0x69, 0x72,
  1806  	0x65, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x48, 0x0a, 0x0a, 0x6c, 0x65, 0x61, 0x73, 0x65, 0x5f, 0x74,
  1807  	0x79, 0x70, 0x65, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x29, 0x2e, 0x67, 0x6f, 0x6f, 0x67,
  1808  	0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x61,
  1809  	0x69, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x4c, 0x65, 0x61, 0x73, 0x65,
  1810  	0x54, 0x79, 0x70, 0x65, 0x52, 0x09, 0x6c, 0x65, 0x61, 0x73, 0x65, 0x54, 0x79, 0x70, 0x65, 0x22,
  1811  	0xbc, 0x01, 0x0a, 0x13, 0x41, 0x63, 0x71, 0x75, 0x69, 0x72, 0x65, 0x4c, 0x65, 0x61, 0x73, 0x65,
  1812  	0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x16, 0x0a, 0x06, 0x73, 0x65, 0x72, 0x69, 0x65,
  1813  	0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x73, 0x65, 0x72, 0x69, 0x65, 0x73, 0x12,
  1814  	0x14, 0x0a, 0x05, 0x6f, 0x77, 0x6e, 0x65, 0x72, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05,
  1815  	0x6f, 0x77, 0x6e, 0x65, 0x72, 0x12, 0x2d, 0x0a, 0x04, 0x74, 0x65, 0x72, 0x6d, 0x18, 0x03, 0x20,
  1816  	0x01, 0x28, 0x0b, 0x32, 0x19, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f,
  1817  	0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x44, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x04,
  1818  	0x74, 0x65, 0x72, 0x6d, 0x12, 0x48, 0x0a, 0x0a, 0x6c, 0x65, 0x61, 0x73, 0x65, 0x5f, 0x74, 0x79,
  1819  	0x70, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x29, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
  1820  	0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69,
  1821  	0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x4c, 0x65, 0x61, 0x73, 0x65, 0x54,
  1822  	0x79, 0x70, 0x65, 0x52, 0x09, 0x6c, 0x65, 0x61, 0x73, 0x65, 0x54, 0x79, 0x70, 0x65, 0x22, 0x80,
  1823  	0x01, 0x0a, 0x11, 0x52, 0x65, 0x6e, 0x65, 0x77, 0x4c, 0x65, 0x61, 0x73, 0x65, 0x52, 0x65, 0x71,
  1824  	0x75, 0x65, 0x73, 0x74, 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09,
  1825  	0x52, 0x02, 0x69, 0x64, 0x12, 0x16, 0x0a, 0x06, 0x73, 0x65, 0x72, 0x69, 0x65, 0x73, 0x18, 0x02,
  1826  	0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x73, 0x65, 0x72, 0x69, 0x65, 0x73, 0x12, 0x14, 0x0a, 0x05,
  1827  	0x6f, 0x77, 0x6e, 0x65, 0x72, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x6f, 0x77, 0x6e,
  1828  	0x65, 0x72, 0x12, 0x2d, 0x0a, 0x04, 0x74, 0x65, 0x72, 0x6d, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b,
  1829  	0x32, 0x19, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62,
  1830  	0x75, 0x66, 0x2e, 0x44, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x04, 0x74, 0x65, 0x72,
  1831  	0x6d, 0x22, 0x53, 0x0a, 0x13, 0x52, 0x65, 0x6c, 0x65, 0x61, 0x73, 0x65, 0x4c, 0x65, 0x61, 0x73,
  1832  	0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x01,
  1833  	0x20, 0x01, 0x28, 0x09, 0x52, 0x02, 0x69, 0x64, 0x12, 0x16, 0x0a, 0x06, 0x73, 0x65, 0x72, 0x69,
  1834  	0x65, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x73, 0x65, 0x72, 0x69, 0x65, 0x73,
  1835  	0x12, 0x14, 0x0a, 0x05, 0x6f, 0x77, 0x6e, 0x65, 0x72, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52,
  1836  	0x05, 0x6f, 0x77, 0x6e, 0x65, 0x72, 0x22, 0x16, 0x0a, 0x14, 0x52, 0x65, 0x6c, 0x65, 0x61, 0x73,
  1837  	0x65, 0x4c, 0x65, 0x61, 0x73, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0xc2,
  1838  	0x01, 0x0a, 0x0f, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61,
  1839  	0x74, 0x61, 0x12, 0x16, 0x0a, 0x06, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x18, 0x01, 0x20, 0x01,
  1840  	0x28, 0x09, 0x52, 0x06, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x14, 0x0a, 0x05, 0x65, 0x76,
  1841  	0x65, 0x6e, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x65, 0x76, 0x65, 0x6e, 0x74,
  1842  	0x12, 0x16, 0x0a, 0x06, 0x73, 0x65, 0x72, 0x69, 0x65, 0x73, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09,
  1843  	0x52, 0x06, 0x73, 0x65, 0x72, 0x69, 0x65, 0x73, 0x12, 0x19, 0x0a, 0x08, 0x6c, 0x65, 0x61, 0x73,
  1844  	0x65, 0x5f, 0x69, 0x64, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x6c, 0x65, 0x61, 0x73,
  1845  	0x65, 0x49, 0x64, 0x12, 0x14, 0x0a, 0x05, 0x6f, 0x77, 0x6e, 0x65, 0x72, 0x18, 0x05, 0x20, 0x01,
  1846  	0x28, 0x09, 0x52, 0x05, 0x6f, 0x77, 0x6e, 0x65, 0x72, 0x12, 0x38, 0x0a, 0x0a, 0x6c, 0x65, 0x61,
  1847  	0x73, 0x65, 0x5f, 0x74, 0x65, 0x72, 0x6d, 0x18, 0x06, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x19, 0x2e,
  1848  	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e,
  1849  	0x44, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x09, 0x6c, 0x65, 0x61, 0x73, 0x65, 0x54,
  1850  	0x65, 0x72, 0x6d, 0x22, 0xb0, 0x01, 0x0a, 0x12, 0x53, 0x65, 0x6e, 0x64, 0x50, 0x61, 0x63, 0x6b,
  1851  	0x65, 0x74, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x40, 0x0a, 0x06, 0x70, 0x61,
  1852  	0x63, 0x6b, 0x65, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x26, 0x2e, 0x67, 0x6f, 0x6f,
  1853  	0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e,
  1854  	0x61, 0x69, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x50, 0x61, 0x63, 0x6b,
  1855  	0x65, 0x74, 0x48, 0x00, 0x52, 0x06, 0x70, 0x61, 0x63, 0x6b, 0x65, 0x74, 0x12, 0x4d, 0x0a, 0x08,
  1856  	0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2f,
  1857  	0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x76, 0x69,
  1858  	0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e,
  1859  	0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x48,
  1860  	0x00, 0x52, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x42, 0x09, 0x0a, 0x07, 0x72,
  1861  	0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x22, 0x15, 0x0a, 0x13, 0x53, 0x65, 0x6e, 0x64, 0x50, 0x61,
  1862  	0x63, 0x6b, 0x65, 0x74, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0xd3, 0x05,
  1863  	0x0a, 0x15, 0x52, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x50, 0x61, 0x63, 0x6b, 0x65, 0x74, 0x73,
  1864  	0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x69, 0x0a, 0x0d, 0x73, 0x65, 0x74, 0x75, 0x70,
  1865  	0x5f, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x18, 0x06, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x42,
  1866  	0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x76, 0x69,
  1867  	0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e,
  1868  	0x52, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x50, 0x61, 0x63, 0x6b, 0x65, 0x74, 0x73, 0x52, 0x65,
  1869  	0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x53, 0x65, 0x74, 0x75, 0x70, 0x52, 0x65, 0x71, 0x75, 0x65,
  1870  	0x73, 0x74, 0x48, 0x00, 0x52, 0x0c, 0x73, 0x65, 0x74, 0x75, 0x70, 0x52, 0x65, 0x71, 0x75, 0x65,
  1871  	0x73, 0x74, 0x12, 0x56, 0x0a, 0x0e, 0x63, 0x6f, 0x6d, 0x6d, 0x69, 0x74, 0x5f, 0x72, 0x65, 0x71,
  1872  	0x75, 0x65, 0x73, 0x74, 0x18, 0x07, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2d, 0x2e, 0x67, 0x6f, 0x6f,
  1873  	0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e,
  1874  	0x61, 0x69, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x43, 0x6f, 0x6d, 0x6d,
  1875  	0x69, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x48, 0x00, 0x52, 0x0d, 0x63, 0x6f, 0x6d,
  1876  	0x6d, 0x69, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0xeb, 0x03, 0x0a, 0x0c, 0x53,
  1877  	0x65, 0x74, 0x75, 0x70, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x59, 0x0a, 0x12, 0x65,
  1878  	0x61, 0x67, 0x65, 0x72, 0x5f, 0x72, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x5f, 0x6d, 0x6f, 0x64,
  1879  	0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x29, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
  1880  	0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2e,
  1881  	0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x45, 0x61, 0x67, 0x65, 0x72, 0x4d, 0x6f,
  1882  	0x64, 0x65, 0x48, 0x00, 0x52, 0x10, 0x65, 0x61, 0x67, 0x65, 0x72, 0x52, 0x65, 0x63, 0x65, 0x69,
  1883  	0x76, 0x65, 0x4d, 0x6f, 0x64, 0x65, 0x12, 0x68, 0x0a, 0x17, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f,
  1884  	0x6c, 0x6c, 0x65, 0x64, 0x5f, 0x72, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x5f, 0x6d, 0x6f, 0x64,
  1885  	0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2e, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
  1886  	0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2e,
  1887  	0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x43, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c,
  1888  	0x6c, 0x65, 0x64, 0x4d, 0x6f, 0x64, 0x65, 0x48, 0x00, 0x52, 0x15, 0x63, 0x6f, 0x6e, 0x74, 0x72,
  1889  	0x6f, 0x6c, 0x6c, 0x65, 0x64, 0x52, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x4d, 0x6f, 0x64, 0x65,
  1890  	0x12, 0x4b, 0x0a, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x18, 0x01, 0x20, 0x01,
  1891  	0x28, 0x0b, 0x32, 0x2f, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75,
  1892  	0x64, 0x2e, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70,
  1893  	0x68, 0x61, 0x31, 0x2e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x4d, 0x65, 0x74, 0x61, 0x64,
  1894  	0x61, 0x74, 0x61, 0x52, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x12, 0x1a, 0x0a,
  1895  	0x08, 0x72, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x72, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52,
  1896  	0x08, 0x72, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x72, 0x12, 0x48, 0x0a, 0x12, 0x68, 0x65, 0x61,
  1897  	0x72, 0x74, 0x62, 0x65, 0x61, 0x74, 0x5f, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x76, 0x61, 0x6c, 0x18,
  1898  	0x05, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x19, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70,
  1899  	0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x44, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e,
  1900  	0x52, 0x11, 0x68, 0x65, 0x61, 0x72, 0x74, 0x62, 0x65, 0x61, 0x74, 0x49, 0x6e, 0x74, 0x65, 0x72,
  1901  	0x76, 0x61, 0x6c, 0x12, 0x52, 0x0a, 0x18, 0x77, 0x72, 0x69, 0x74, 0x65, 0x73, 0x5f, 0x64, 0x6f,
  1902  	0x6e, 0x65, 0x5f, 0x67, 0x72, 0x61, 0x63, 0x65, 0x5f, 0x70, 0x65, 0x72, 0x69, 0x6f, 0x64, 0x18,
  1903  	0x06, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x19, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70,
  1904  	0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x44, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e,
  1905  	0x52, 0x15, 0x77, 0x72, 0x69, 0x74, 0x65, 0x73, 0x44, 0x6f, 0x6e, 0x65, 0x47, 0x72, 0x61, 0x63,
  1906  	0x65, 0x50, 0x65, 0x72, 0x69, 0x6f, 0x64, 0x42, 0x0f, 0x0a, 0x0d, 0x63, 0x6f, 0x6e, 0x73, 0x75,
  1907  	0x6d, 0x65, 0x72, 0x5f, 0x6d, 0x6f, 0x64, 0x65, 0x42, 0x09, 0x0a, 0x07, 0x72, 0x65, 0x71, 0x75,
  1908  	0x65, 0x73, 0x74, 0x22, 0x7c, 0x0a, 0x1d, 0x52, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x50, 0x61,
  1909  	0x63, 0x6b, 0x65, 0x74, 0x73, 0x43, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x52, 0x65, 0x73, 0x70,
  1910  	0x6f, 0x6e, 0x73, 0x65, 0x12, 0x1e, 0x0a, 0x09, 0x68, 0x65, 0x61, 0x72, 0x74, 0x62, 0x65, 0x61,
  1911  	0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x08, 0x48, 0x00, 0x52, 0x09, 0x68, 0x65, 0x61, 0x72, 0x74,
  1912  	0x62, 0x65, 0x61, 0x74, 0x12, 0x30, 0x0a, 0x13, 0x77, 0x72, 0x69, 0x74, 0x65, 0x73, 0x5f, 0x64,
  1913  	0x6f, 0x6e, 0x65, 0x5f, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28,
  1914  	0x08, 0x48, 0x00, 0x52, 0x11, 0x77, 0x72, 0x69, 0x74, 0x65, 0x73, 0x44, 0x6f, 0x6e, 0x65, 0x52,
  1915  	0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x42, 0x09, 0x0a, 0x07, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f,
  1916  	0x6c, 0x22, 0xc1, 0x01, 0x0a, 0x16, 0x52, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x50, 0x61, 0x63,
  1917  	0x6b, 0x65, 0x74, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x40, 0x0a, 0x06,
  1918  	0x70, 0x61, 0x63, 0x6b, 0x65, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x26, 0x2e, 0x67,
  1919  	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x76, 0x69, 0x73, 0x69,
  1920  	0x6f, 0x6e, 0x61, 0x69, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x50, 0x61,
  1921  	0x63, 0x6b, 0x65, 0x74, 0x48, 0x00, 0x52, 0x06, 0x70, 0x61, 0x63, 0x6b, 0x65, 0x74, 0x12, 0x59,
  1922  	0x0a, 0x07, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32,
  1923  	0x3d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x76,
  1924  	0x69, 0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31,
  1925  	0x2e, 0x52, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x50, 0x61, 0x63, 0x6b, 0x65, 0x74, 0x73, 0x43,
  1926  	0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x48, 0x00,
  1927  	0x52, 0x07, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x42, 0x0a, 0x0a, 0x08, 0x72, 0x65, 0x73,
  1928  	0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x0b, 0x0a, 0x09, 0x45, 0x61, 0x67, 0x65, 0x72, 0x4d, 0x6f,
  1929  	0x64, 0x65, 0x22, 0x97, 0x01, 0x0a, 0x0e, 0x43, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65,
  1930  	0x64, 0x4d, 0x6f, 0x64, 0x65, 0x12, 0x38, 0x0a, 0x17, 0x73, 0x74, 0x61, 0x72, 0x74, 0x69, 0x6e,
  1931  	0x67, 0x5f, 0x6c, 0x6f, 0x67, 0x69, 0x63, 0x61, 0x6c, 0x5f, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74,
  1932  	0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x48, 0x00, 0x52, 0x15, 0x73, 0x74, 0x61, 0x72, 0x74, 0x69,
  1933  	0x6e, 0x67, 0x4c, 0x6f, 0x67, 0x69, 0x63, 0x61, 0x6c, 0x4f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x12,
  1934  	0x38, 0x0a, 0x18, 0x66, 0x61, 0x6c, 0x6c, 0x62, 0x61, 0x63, 0x6b, 0x5f, 0x73, 0x74, 0x61, 0x72,
  1935  	0x74, 0x69, 0x6e, 0x67, 0x5f, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28,
  1936  	0x09, 0x52, 0x16, 0x66, 0x61, 0x6c, 0x6c, 0x62, 0x61, 0x63, 0x6b, 0x53, 0x74, 0x61, 0x72, 0x74,
  1937  	0x69, 0x6e, 0x67, 0x4f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x42, 0x11, 0x0a, 0x0f, 0x73, 0x74, 0x61,
  1938  	0x72, 0x74, 0x69, 0x6e, 0x67, 0x5f, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x22, 0x27, 0x0a, 0x0d,
  1939  	0x43, 0x6f, 0x6d, 0x6d, 0x69, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x16, 0x0a,
  1940  	0x06, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x06, 0x6f,
  1941  	0x66, 0x66, 0x73, 0x65, 0x74, 0x2a, 0x55, 0x0a, 0x09, 0x4c, 0x65, 0x61, 0x73, 0x65, 0x54, 0x79,
  1942  	0x70, 0x65, 0x12, 0x1a, 0x0a, 0x16, 0x4c, 0x45, 0x41, 0x53, 0x45, 0x5f, 0x54, 0x59, 0x50, 0x45,
  1943  	0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45, 0x44, 0x10, 0x00, 0x12, 0x15,
  1944  	0x0a, 0x11, 0x4c, 0x45, 0x41, 0x53, 0x45, 0x5f, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x52, 0x45, 0x41,
  1945  	0x44, 0x45, 0x52, 0x10, 0x01, 0x12, 0x15, 0x0a, 0x11, 0x4c, 0x45, 0x41, 0x53, 0x45, 0x5f, 0x54,
  1946  	0x59, 0x50, 0x45, 0x5f, 0x57, 0x52, 0x49, 0x54, 0x45, 0x52, 0x10, 0x02, 0x32, 0xbf, 0x08, 0x0a,
  1947  	0x10, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x69, 0x6e, 0x67, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63,
  1948  	0x65, 0x12, 0x7c, 0x0a, 0x0b, 0x53, 0x65, 0x6e, 0x64, 0x50, 0x61, 0x63, 0x6b, 0x65, 0x74, 0x73,
  1949  	0x12, 0x32, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e,
  1950  	0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61,
  1951  	0x31, 0x2e, 0x53, 0x65, 0x6e, 0x64, 0x50, 0x61, 0x63, 0x6b, 0x65, 0x74, 0x73, 0x52, 0x65, 0x71,
  1952  	0x75, 0x65, 0x73, 0x74, 0x1a, 0x33, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c,
  1953  	0x6f, 0x75, 0x64, 0x2e, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2e, 0x76, 0x31, 0x61,
  1954  	0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x53, 0x65, 0x6e, 0x64, 0x50, 0x61, 0x63, 0x6b, 0x65, 0x74,
  1955  	0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x28, 0x01, 0x30, 0x01, 0x12,
  1956  	0x85, 0x01, 0x0a, 0x0e, 0x52, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x50, 0x61, 0x63, 0x6b, 0x65,
  1957  	0x74, 0x73, 0x12, 0x35, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75,
  1958  	0x64, 0x2e, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70,
  1959  	0x68, 0x61, 0x31, 0x2e, 0x52, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x50, 0x61, 0x63, 0x6b, 0x65,
  1960  	0x74, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x36, 0x2e, 0x67, 0x6f, 0x6f, 0x67,
  1961  	0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x61,
  1962  	0x69, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x52, 0x65, 0x63, 0x65, 0x69,
  1963  	0x76, 0x65, 0x50, 0x61, 0x63, 0x6b, 0x65, 0x74, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73,
  1964  	0x65, 0x22, 0x00, 0x28, 0x01, 0x30, 0x01, 0x12, 0x82, 0x01, 0x0a, 0x0d, 0x52, 0x65, 0x63, 0x65,
  1965  	0x69, 0x76, 0x65, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x73, 0x12, 0x34, 0x2e, 0x67, 0x6f, 0x6f, 0x67,
  1966  	0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x61,
  1967  	0x69, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x52, 0x65, 0x63, 0x65, 0x69,
  1968  	0x76, 0x65, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a,
  1969  	0x35, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x76,
  1970  	0x69, 0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31,
  1971  	0x2e, 0x52, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x73, 0x52, 0x65,
  1972  	0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x28, 0x01, 0x30, 0x01, 0x12, 0xc1, 0x01, 0x0a,
  1973  	0x0c, 0x41, 0x63, 0x71, 0x75, 0x69, 0x72, 0x65, 0x4c, 0x65, 0x61, 0x73, 0x65, 0x12, 0x33, 0x2e,
  1974  	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x76, 0x69, 0x73,
  1975  	0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x41,
  1976  	0x63, 0x71, 0x75, 0x69, 0x72, 0x65, 0x4c, 0x65, 0x61, 0x73, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65,
  1977  	0x73, 0x74, 0x1a, 0x25, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75,
  1978  	0x64, 0x2e, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70,
  1979  	0x68, 0x61, 0x31, 0x2e, 0x4c, 0x65, 0x61, 0x73, 0x65, 0x22, 0x55, 0x82, 0xd3, 0xe4, 0x93, 0x02,
  1980  	0x4f, 0x22, 0x4a, 0x2f, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2f, 0x7b, 0x73, 0x65,
  1981  	0x72, 0x69, 0x65, 0x73, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f,
  1982  	0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x63, 0x6c, 0x75, 0x73,
  1983  	0x74, 0x65, 0x72, 0x73, 0x2f, 0x2a, 0x2f, 0x73, 0x65, 0x72, 0x69, 0x65, 0x73, 0x2f, 0x2a, 0x7d,
  1984  	0x3a, 0x61, 0x63, 0x71, 0x75, 0x69, 0x72, 0x65, 0x4c, 0x65, 0x61, 0x73, 0x65, 0x3a, 0x01, 0x2a,
  1985  	0x12, 0xbb, 0x01, 0x0a, 0x0a, 0x52, 0x65, 0x6e, 0x65, 0x77, 0x4c, 0x65, 0x61, 0x73, 0x65, 0x12,
  1986  	0x31, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x76,
  1987  	0x69, 0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31,
  1988  	0x2e, 0x52, 0x65, 0x6e, 0x65, 0x77, 0x4c, 0x65, 0x61, 0x73, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65,
  1989  	0x73, 0x74, 0x1a, 0x25, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75,
  1990  	0x64, 0x2e, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70,
  1991  	0x68, 0x61, 0x31, 0x2e, 0x4c, 0x65, 0x61, 0x73, 0x65, 0x22, 0x53, 0x82, 0xd3, 0xe4, 0x93, 0x02,
  1992  	0x4d, 0x22, 0x48, 0x2f, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2f, 0x7b, 0x73, 0x65,
  1993  	0x72, 0x69, 0x65, 0x73, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f,
  1994  	0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x63, 0x6c, 0x75, 0x73,
  1995  	0x74, 0x65, 0x72, 0x73, 0x2f, 0x2a, 0x2f, 0x73, 0x65, 0x72, 0x69, 0x65, 0x73, 0x2f, 0x2a, 0x7d,
  1996  	0x3a, 0x72, 0x65, 0x6e, 0x65, 0x77, 0x4c, 0x65, 0x61, 0x73, 0x65, 0x3a, 0x01, 0x2a, 0x12, 0xd0,
  1997  	0x01, 0x0a, 0x0c, 0x52, 0x65, 0x6c, 0x65, 0x61, 0x73, 0x65, 0x4c, 0x65, 0x61, 0x73, 0x65, 0x12,
  1998  	0x33, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x76,
  1999  	0x69, 0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31,
  2000  	0x2e, 0x52, 0x65, 0x6c, 0x65, 0x61, 0x73, 0x65, 0x4c, 0x65, 0x61, 0x73, 0x65, 0x52, 0x65, 0x71,
  2001  	0x75, 0x65, 0x73, 0x74, 0x1a, 0x34, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c,
  2002  	0x6f, 0x75, 0x64, 0x2e, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2e, 0x76, 0x31, 0x61,
  2003  	0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x52, 0x65, 0x6c, 0x65, 0x61, 0x73, 0x65, 0x4c, 0x65, 0x61,
  2004  	0x73, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x55, 0x82, 0xd3, 0xe4, 0x93,
  2005  	0x02, 0x4f, 0x22, 0x4a, 0x2f, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2f, 0x7b, 0x73,
  2006  	0x65, 0x72, 0x69, 0x65, 0x73, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a,
  2007  	0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x63, 0x6c, 0x75,
  2008  	0x73, 0x74, 0x65, 0x72, 0x73, 0x2f, 0x2a, 0x2f, 0x73, 0x65, 0x72, 0x69, 0x65, 0x73, 0x2f, 0x2a,
  2009  	0x7d, 0x3a, 0x72, 0x65, 0x6c, 0x65, 0x61, 0x73, 0x65, 0x4c, 0x65, 0x61, 0x73, 0x65, 0x3a, 0x01,
  2010  	0x2a, 0x1a, 0x4b, 0xca, 0x41, 0x17, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2e, 0x67,
  2011  	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0xd2, 0x41, 0x2e,
  2012  	0x68, 0x74, 0x74, 0x70, 0x73, 0x3a, 0x2f, 0x2f, 0x77, 0x77, 0x77, 0x2e, 0x67, 0x6f, 0x6f, 0x67,
  2013  	0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x61, 0x75, 0x74, 0x68, 0x2f,
  2014  	0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2d, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x42, 0xeb,
  2015  	0x01, 0x0a, 0x22, 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c,
  2016  	0x6f, 0x75, 0x64, 0x2e, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2e, 0x76, 0x31, 0x61,
  2017  	0x6c, 0x70, 0x68, 0x61, 0x31, 0x42, 0x15, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x69, 0x6e, 0x67,
  2018  	0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x5a, 0x46,
  2019  	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x6f, 0x6c, 0x61, 0x6e, 0x67, 0x2e, 0x6f, 0x72,
  2020  	0x67, 0x2f, 0x67, 0x65, 0x6e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
  2021  	0x65, 0x61, 0x70, 0x69, 0x73, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x76, 0x69, 0x73, 0x69,
  2022  	0x6f, 0x6e, 0x61, 0x69, 0x2f, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x3b, 0x76, 0x69,
  2023  	0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69, 0xaa, 0x02, 0x1e, 0x47, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e,
  2024  	0x43, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x56, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x41, 0x49, 0x2e, 0x56,
  2025  	0x31, 0x41, 0x6c, 0x70, 0x68, 0x61, 0x31, 0xca, 0x02, 0x1e, 0x47, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
  2026  	0x5c, 0x43, 0x6c, 0x6f, 0x75, 0x64, 0x5c, 0x56, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x41, 0x49, 0x5c,
  2027  	0x56, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0xea, 0x02, 0x21, 0x47, 0x6f, 0x6f, 0x67, 0x6c,
  2028  	0x65, 0x3a, 0x3a, 0x43, 0x6c, 0x6f, 0x75, 0x64, 0x3a, 0x3a, 0x56, 0x69, 0x73, 0x69, 0x6f, 0x6e,
  2029  	0x41, 0x49, 0x3a, 0x3a, 0x56, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x62, 0x06, 0x70, 0x72,
  2030  	0x6f, 0x74, 0x6f, 0x33,
  2031  }
  2032  
  2033  var (
  2034  	file_google_cloud_visionai_v1alpha1_streaming_service_proto_rawDescOnce sync.Once
  2035  	file_google_cloud_visionai_v1alpha1_streaming_service_proto_rawDescData = file_google_cloud_visionai_v1alpha1_streaming_service_proto_rawDesc
  2036  )
  2037  
  2038  func file_google_cloud_visionai_v1alpha1_streaming_service_proto_rawDescGZIP() []byte {
  2039  	file_google_cloud_visionai_v1alpha1_streaming_service_proto_rawDescOnce.Do(func() {
  2040  		file_google_cloud_visionai_v1alpha1_streaming_service_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_cloud_visionai_v1alpha1_streaming_service_proto_rawDescData)
  2041  	})
  2042  	return file_google_cloud_visionai_v1alpha1_streaming_service_proto_rawDescData
  2043  }
  2044  
  2045  var file_google_cloud_visionai_v1alpha1_streaming_service_proto_enumTypes = make([]protoimpl.EnumInfo, 1)
  2046  var file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes = make([]protoimpl.MessageInfo, 20)
  2047  var file_google_cloud_visionai_v1alpha1_streaming_service_proto_goTypes = []interface{}{
  2048  	(LeaseType)(0),                             // 0: google.cloud.visionai.v1alpha1.LeaseType
  2049  	(*ReceiveEventsRequest)(nil),               // 1: google.cloud.visionai.v1alpha1.ReceiveEventsRequest
  2050  	(*EventUpdate)(nil),                        // 2: google.cloud.visionai.v1alpha1.EventUpdate
  2051  	(*ReceiveEventsControlResponse)(nil),       // 3: google.cloud.visionai.v1alpha1.ReceiveEventsControlResponse
  2052  	(*ReceiveEventsResponse)(nil),              // 4: google.cloud.visionai.v1alpha1.ReceiveEventsResponse
  2053  	(*Lease)(nil),                              // 5: google.cloud.visionai.v1alpha1.Lease
  2054  	(*AcquireLeaseRequest)(nil),                // 6: google.cloud.visionai.v1alpha1.AcquireLeaseRequest
  2055  	(*RenewLeaseRequest)(nil),                  // 7: google.cloud.visionai.v1alpha1.RenewLeaseRequest
  2056  	(*ReleaseLeaseRequest)(nil),                // 8: google.cloud.visionai.v1alpha1.ReleaseLeaseRequest
  2057  	(*ReleaseLeaseResponse)(nil),               // 9: google.cloud.visionai.v1alpha1.ReleaseLeaseResponse
  2058  	(*RequestMetadata)(nil),                    // 10: google.cloud.visionai.v1alpha1.RequestMetadata
  2059  	(*SendPacketsRequest)(nil),                 // 11: google.cloud.visionai.v1alpha1.SendPacketsRequest
  2060  	(*SendPacketsResponse)(nil),                // 12: google.cloud.visionai.v1alpha1.SendPacketsResponse
  2061  	(*ReceivePacketsRequest)(nil),              // 13: google.cloud.visionai.v1alpha1.ReceivePacketsRequest
  2062  	(*ReceivePacketsControlResponse)(nil),      // 14: google.cloud.visionai.v1alpha1.ReceivePacketsControlResponse
  2063  	(*ReceivePacketsResponse)(nil),             // 15: google.cloud.visionai.v1alpha1.ReceivePacketsResponse
  2064  	(*EagerMode)(nil),                          // 16: google.cloud.visionai.v1alpha1.EagerMode
  2065  	(*ControlledMode)(nil),                     // 17: google.cloud.visionai.v1alpha1.ControlledMode
  2066  	(*CommitRequest)(nil),                      // 18: google.cloud.visionai.v1alpha1.CommitRequest
  2067  	(*ReceiveEventsRequest_SetupRequest)(nil),  // 19: google.cloud.visionai.v1alpha1.ReceiveEventsRequest.SetupRequest
  2068  	(*ReceivePacketsRequest_SetupRequest)(nil), // 20: google.cloud.visionai.v1alpha1.ReceivePacketsRequest.SetupRequest
  2069  	(*timestamppb.Timestamp)(nil),              // 21: google.protobuf.Timestamp
  2070  	(*durationpb.Duration)(nil),                // 22: google.protobuf.Duration
  2071  	(*Packet)(nil),                             // 23: google.cloud.visionai.v1alpha1.Packet
  2072  }
  2073  var file_google_cloud_visionai_v1alpha1_streaming_service_proto_depIdxs = []int32{
  2074  	19, // 0: google.cloud.visionai.v1alpha1.ReceiveEventsRequest.setup_request:type_name -> google.cloud.visionai.v1alpha1.ReceiveEventsRequest.SetupRequest
  2075  	18, // 1: google.cloud.visionai.v1alpha1.ReceiveEventsRequest.commit_request:type_name -> google.cloud.visionai.v1alpha1.CommitRequest
  2076  	21, // 2: google.cloud.visionai.v1alpha1.EventUpdate.update_time:type_name -> google.protobuf.Timestamp
  2077  	2,  // 3: google.cloud.visionai.v1alpha1.ReceiveEventsResponse.event_update:type_name -> google.cloud.visionai.v1alpha1.EventUpdate
  2078  	3,  // 4: google.cloud.visionai.v1alpha1.ReceiveEventsResponse.control:type_name -> google.cloud.visionai.v1alpha1.ReceiveEventsControlResponse
  2079  	21, // 5: google.cloud.visionai.v1alpha1.Lease.expire_time:type_name -> google.protobuf.Timestamp
  2080  	0,  // 6: google.cloud.visionai.v1alpha1.Lease.lease_type:type_name -> google.cloud.visionai.v1alpha1.LeaseType
  2081  	22, // 7: google.cloud.visionai.v1alpha1.AcquireLeaseRequest.term:type_name -> google.protobuf.Duration
  2082  	0,  // 8: google.cloud.visionai.v1alpha1.AcquireLeaseRequest.lease_type:type_name -> google.cloud.visionai.v1alpha1.LeaseType
  2083  	22, // 9: google.cloud.visionai.v1alpha1.RenewLeaseRequest.term:type_name -> google.protobuf.Duration
  2084  	22, // 10: google.cloud.visionai.v1alpha1.RequestMetadata.lease_term:type_name -> google.protobuf.Duration
  2085  	23, // 11: google.cloud.visionai.v1alpha1.SendPacketsRequest.packet:type_name -> google.cloud.visionai.v1alpha1.Packet
  2086  	10, // 12: google.cloud.visionai.v1alpha1.SendPacketsRequest.metadata:type_name -> google.cloud.visionai.v1alpha1.RequestMetadata
  2087  	20, // 13: google.cloud.visionai.v1alpha1.ReceivePacketsRequest.setup_request:type_name -> google.cloud.visionai.v1alpha1.ReceivePacketsRequest.SetupRequest
  2088  	18, // 14: google.cloud.visionai.v1alpha1.ReceivePacketsRequest.commit_request:type_name -> google.cloud.visionai.v1alpha1.CommitRequest
  2089  	23, // 15: google.cloud.visionai.v1alpha1.ReceivePacketsResponse.packet:type_name -> google.cloud.visionai.v1alpha1.Packet
  2090  	14, // 16: google.cloud.visionai.v1alpha1.ReceivePacketsResponse.control:type_name -> google.cloud.visionai.v1alpha1.ReceivePacketsControlResponse
  2091  	17, // 17: google.cloud.visionai.v1alpha1.ReceiveEventsRequest.SetupRequest.controlled_mode:type_name -> google.cloud.visionai.v1alpha1.ControlledMode
  2092  	22, // 18: google.cloud.visionai.v1alpha1.ReceiveEventsRequest.SetupRequest.heartbeat_interval:type_name -> google.protobuf.Duration
  2093  	22, // 19: google.cloud.visionai.v1alpha1.ReceiveEventsRequest.SetupRequest.writes_done_grace_period:type_name -> google.protobuf.Duration
  2094  	16, // 20: google.cloud.visionai.v1alpha1.ReceivePacketsRequest.SetupRequest.eager_receive_mode:type_name -> google.cloud.visionai.v1alpha1.EagerMode
  2095  	17, // 21: google.cloud.visionai.v1alpha1.ReceivePacketsRequest.SetupRequest.controlled_receive_mode:type_name -> google.cloud.visionai.v1alpha1.ControlledMode
  2096  	10, // 22: google.cloud.visionai.v1alpha1.ReceivePacketsRequest.SetupRequest.metadata:type_name -> google.cloud.visionai.v1alpha1.RequestMetadata
  2097  	22, // 23: google.cloud.visionai.v1alpha1.ReceivePacketsRequest.SetupRequest.heartbeat_interval:type_name -> google.protobuf.Duration
  2098  	22, // 24: google.cloud.visionai.v1alpha1.ReceivePacketsRequest.SetupRequest.writes_done_grace_period:type_name -> google.protobuf.Duration
  2099  	11, // 25: google.cloud.visionai.v1alpha1.StreamingService.SendPackets:input_type -> google.cloud.visionai.v1alpha1.SendPacketsRequest
  2100  	13, // 26: google.cloud.visionai.v1alpha1.StreamingService.ReceivePackets:input_type -> google.cloud.visionai.v1alpha1.ReceivePacketsRequest
  2101  	1,  // 27: google.cloud.visionai.v1alpha1.StreamingService.ReceiveEvents:input_type -> google.cloud.visionai.v1alpha1.ReceiveEventsRequest
  2102  	6,  // 28: google.cloud.visionai.v1alpha1.StreamingService.AcquireLease:input_type -> google.cloud.visionai.v1alpha1.AcquireLeaseRequest
  2103  	7,  // 29: google.cloud.visionai.v1alpha1.StreamingService.RenewLease:input_type -> google.cloud.visionai.v1alpha1.RenewLeaseRequest
  2104  	8,  // 30: google.cloud.visionai.v1alpha1.StreamingService.ReleaseLease:input_type -> google.cloud.visionai.v1alpha1.ReleaseLeaseRequest
  2105  	12, // 31: google.cloud.visionai.v1alpha1.StreamingService.SendPackets:output_type -> google.cloud.visionai.v1alpha1.SendPacketsResponse
  2106  	15, // 32: google.cloud.visionai.v1alpha1.StreamingService.ReceivePackets:output_type -> google.cloud.visionai.v1alpha1.ReceivePacketsResponse
  2107  	4,  // 33: google.cloud.visionai.v1alpha1.StreamingService.ReceiveEvents:output_type -> google.cloud.visionai.v1alpha1.ReceiveEventsResponse
  2108  	5,  // 34: google.cloud.visionai.v1alpha1.StreamingService.AcquireLease:output_type -> google.cloud.visionai.v1alpha1.Lease
  2109  	5,  // 35: google.cloud.visionai.v1alpha1.StreamingService.RenewLease:output_type -> google.cloud.visionai.v1alpha1.Lease
  2110  	9,  // 36: google.cloud.visionai.v1alpha1.StreamingService.ReleaseLease:output_type -> google.cloud.visionai.v1alpha1.ReleaseLeaseResponse
  2111  	31, // [31:37] is the sub-list for method output_type
  2112  	25, // [25:31] is the sub-list for method input_type
  2113  	25, // [25:25] is the sub-list for extension type_name
  2114  	25, // [25:25] is the sub-list for extension extendee
  2115  	0,  // [0:25] is the sub-list for field type_name
  2116  }
  2117  
  2118  func init() { file_google_cloud_visionai_v1alpha1_streaming_service_proto_init() }
  2119  func file_google_cloud_visionai_v1alpha1_streaming_service_proto_init() {
  2120  	if File_google_cloud_visionai_v1alpha1_streaming_service_proto != nil {
  2121  		return
  2122  	}
  2123  	file_google_cloud_visionai_v1alpha1_streaming_resources_proto_init()
  2124  	if !protoimpl.UnsafeEnabled {
  2125  		file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
  2126  			switch v := v.(*ReceiveEventsRequest); i {
  2127  			case 0:
  2128  				return &v.state
  2129  			case 1:
  2130  				return &v.sizeCache
  2131  			case 2:
  2132  				return &v.unknownFields
  2133  			default:
  2134  				return nil
  2135  			}
  2136  		}
  2137  		file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
  2138  			switch v := v.(*EventUpdate); i {
  2139  			case 0:
  2140  				return &v.state
  2141  			case 1:
  2142  				return &v.sizeCache
  2143  			case 2:
  2144  				return &v.unknownFields
  2145  			default:
  2146  				return nil
  2147  			}
  2148  		}
  2149  		file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
  2150  			switch v := v.(*ReceiveEventsControlResponse); i {
  2151  			case 0:
  2152  				return &v.state
  2153  			case 1:
  2154  				return &v.sizeCache
  2155  			case 2:
  2156  				return &v.unknownFields
  2157  			default:
  2158  				return nil
  2159  			}
  2160  		}
  2161  		file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
  2162  			switch v := v.(*ReceiveEventsResponse); i {
  2163  			case 0:
  2164  				return &v.state
  2165  			case 1:
  2166  				return &v.sizeCache
  2167  			case 2:
  2168  				return &v.unknownFields
  2169  			default:
  2170  				return nil
  2171  			}
  2172  		}
  2173  		file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
  2174  			switch v := v.(*Lease); i {
  2175  			case 0:
  2176  				return &v.state
  2177  			case 1:
  2178  				return &v.sizeCache
  2179  			case 2:
  2180  				return &v.unknownFields
  2181  			default:
  2182  				return nil
  2183  			}
  2184  		}
  2185  		file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
  2186  			switch v := v.(*AcquireLeaseRequest); i {
  2187  			case 0:
  2188  				return &v.state
  2189  			case 1:
  2190  				return &v.sizeCache
  2191  			case 2:
  2192  				return &v.unknownFields
  2193  			default:
  2194  				return nil
  2195  			}
  2196  		}
  2197  		file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
  2198  			switch v := v.(*RenewLeaseRequest); i {
  2199  			case 0:
  2200  				return &v.state
  2201  			case 1:
  2202  				return &v.sizeCache
  2203  			case 2:
  2204  				return &v.unknownFields
  2205  			default:
  2206  				return nil
  2207  			}
  2208  		}
  2209  		file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
  2210  			switch v := v.(*ReleaseLeaseRequest); i {
  2211  			case 0:
  2212  				return &v.state
  2213  			case 1:
  2214  				return &v.sizeCache
  2215  			case 2:
  2216  				return &v.unknownFields
  2217  			default:
  2218  				return nil
  2219  			}
  2220  		}
  2221  		file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
  2222  			switch v := v.(*ReleaseLeaseResponse); i {
  2223  			case 0:
  2224  				return &v.state
  2225  			case 1:
  2226  				return &v.sizeCache
  2227  			case 2:
  2228  				return &v.unknownFields
  2229  			default:
  2230  				return nil
  2231  			}
  2232  		}
  2233  		file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} {
  2234  			switch v := v.(*RequestMetadata); i {
  2235  			case 0:
  2236  				return &v.state
  2237  			case 1:
  2238  				return &v.sizeCache
  2239  			case 2:
  2240  				return &v.unknownFields
  2241  			default:
  2242  				return nil
  2243  			}
  2244  		}
  2245  		file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} {
  2246  			switch v := v.(*SendPacketsRequest); i {
  2247  			case 0:
  2248  				return &v.state
  2249  			case 1:
  2250  				return &v.sizeCache
  2251  			case 2:
  2252  				return &v.unknownFields
  2253  			default:
  2254  				return nil
  2255  			}
  2256  		}
  2257  		file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} {
  2258  			switch v := v.(*SendPacketsResponse); i {
  2259  			case 0:
  2260  				return &v.state
  2261  			case 1:
  2262  				return &v.sizeCache
  2263  			case 2:
  2264  				return &v.unknownFields
  2265  			default:
  2266  				return nil
  2267  			}
  2268  		}
  2269  		file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} {
  2270  			switch v := v.(*ReceivePacketsRequest); i {
  2271  			case 0:
  2272  				return &v.state
  2273  			case 1:
  2274  				return &v.sizeCache
  2275  			case 2:
  2276  				return &v.unknownFields
  2277  			default:
  2278  				return nil
  2279  			}
  2280  		}
  2281  		file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} {
  2282  			switch v := v.(*ReceivePacketsControlResponse); i {
  2283  			case 0:
  2284  				return &v.state
  2285  			case 1:
  2286  				return &v.sizeCache
  2287  			case 2:
  2288  				return &v.unknownFields
  2289  			default:
  2290  				return nil
  2291  			}
  2292  		}
  2293  		file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} {
  2294  			switch v := v.(*ReceivePacketsResponse); i {
  2295  			case 0:
  2296  				return &v.state
  2297  			case 1:
  2298  				return &v.sizeCache
  2299  			case 2:
  2300  				return &v.unknownFields
  2301  			default:
  2302  				return nil
  2303  			}
  2304  		}
  2305  		file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[15].Exporter = func(v interface{}, i int) interface{} {
  2306  			switch v := v.(*EagerMode); i {
  2307  			case 0:
  2308  				return &v.state
  2309  			case 1:
  2310  				return &v.sizeCache
  2311  			case 2:
  2312  				return &v.unknownFields
  2313  			default:
  2314  				return nil
  2315  			}
  2316  		}
  2317  		file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[16].Exporter = func(v interface{}, i int) interface{} {
  2318  			switch v := v.(*ControlledMode); i {
  2319  			case 0:
  2320  				return &v.state
  2321  			case 1:
  2322  				return &v.sizeCache
  2323  			case 2:
  2324  				return &v.unknownFields
  2325  			default:
  2326  				return nil
  2327  			}
  2328  		}
  2329  		file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[17].Exporter = func(v interface{}, i int) interface{} {
  2330  			switch v := v.(*CommitRequest); i {
  2331  			case 0:
  2332  				return &v.state
  2333  			case 1:
  2334  				return &v.sizeCache
  2335  			case 2:
  2336  				return &v.unknownFields
  2337  			default:
  2338  				return nil
  2339  			}
  2340  		}
  2341  		file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[18].Exporter = func(v interface{}, i int) interface{} {
  2342  			switch v := v.(*ReceiveEventsRequest_SetupRequest); i {
  2343  			case 0:
  2344  				return &v.state
  2345  			case 1:
  2346  				return &v.sizeCache
  2347  			case 2:
  2348  				return &v.unknownFields
  2349  			default:
  2350  				return nil
  2351  			}
  2352  		}
  2353  		file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[19].Exporter = func(v interface{}, i int) interface{} {
  2354  			switch v := v.(*ReceivePacketsRequest_SetupRequest); i {
  2355  			case 0:
  2356  				return &v.state
  2357  			case 1:
  2358  				return &v.sizeCache
  2359  			case 2:
  2360  				return &v.unknownFields
  2361  			default:
  2362  				return nil
  2363  			}
  2364  		}
  2365  	}
  2366  	file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[0].OneofWrappers = []interface{}{
  2367  		(*ReceiveEventsRequest_SetupRequest_)(nil),
  2368  		(*ReceiveEventsRequest_CommitRequest)(nil),
  2369  	}
  2370  	file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[2].OneofWrappers = []interface{}{
  2371  		(*ReceiveEventsControlResponse_Heartbeat)(nil),
  2372  		(*ReceiveEventsControlResponse_WritesDoneRequest)(nil),
  2373  	}
  2374  	file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[3].OneofWrappers = []interface{}{
  2375  		(*ReceiveEventsResponse_EventUpdate)(nil),
  2376  		(*ReceiveEventsResponse_Control)(nil),
  2377  	}
  2378  	file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[10].OneofWrappers = []interface{}{
  2379  		(*SendPacketsRequest_Packet)(nil),
  2380  		(*SendPacketsRequest_Metadata)(nil),
  2381  	}
  2382  	file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[12].OneofWrappers = []interface{}{
  2383  		(*ReceivePacketsRequest_SetupRequest_)(nil),
  2384  		(*ReceivePacketsRequest_CommitRequest)(nil),
  2385  	}
  2386  	file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[13].OneofWrappers = []interface{}{
  2387  		(*ReceivePacketsControlResponse_Heartbeat)(nil),
  2388  		(*ReceivePacketsControlResponse_WritesDoneRequest)(nil),
  2389  	}
  2390  	file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[14].OneofWrappers = []interface{}{
  2391  		(*ReceivePacketsResponse_Packet)(nil),
  2392  		(*ReceivePacketsResponse_Control)(nil),
  2393  	}
  2394  	file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[16].OneofWrappers = []interface{}{
  2395  		(*ControlledMode_StartingLogicalOffset)(nil),
  2396  	}
  2397  	file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes[19].OneofWrappers = []interface{}{
  2398  		(*ReceivePacketsRequest_SetupRequest_EagerReceiveMode)(nil),
  2399  		(*ReceivePacketsRequest_SetupRequest_ControlledReceiveMode)(nil),
  2400  	}
  2401  	type x struct{}
  2402  	out := protoimpl.TypeBuilder{
  2403  		File: protoimpl.DescBuilder{
  2404  			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
  2405  			RawDescriptor: file_google_cloud_visionai_v1alpha1_streaming_service_proto_rawDesc,
  2406  			NumEnums:      1,
  2407  			NumMessages:   20,
  2408  			NumExtensions: 0,
  2409  			NumServices:   1,
  2410  		},
  2411  		GoTypes:           file_google_cloud_visionai_v1alpha1_streaming_service_proto_goTypes,
  2412  		DependencyIndexes: file_google_cloud_visionai_v1alpha1_streaming_service_proto_depIdxs,
  2413  		EnumInfos:         file_google_cloud_visionai_v1alpha1_streaming_service_proto_enumTypes,
  2414  		MessageInfos:      file_google_cloud_visionai_v1alpha1_streaming_service_proto_msgTypes,
  2415  	}.Build()
  2416  	File_google_cloud_visionai_v1alpha1_streaming_service_proto = out.File
  2417  	file_google_cloud_visionai_v1alpha1_streaming_service_proto_rawDesc = nil
  2418  	file_google_cloud_visionai_v1alpha1_streaming_service_proto_goTypes = nil
  2419  	file_google_cloud_visionai_v1alpha1_streaming_service_proto_depIdxs = nil
  2420  }
  2421  
  2422  // Reference imports to suppress errors if they are not otherwise used.
  2423  var _ context.Context
  2424  var _ grpc.ClientConnInterface
  2425  
  2426  // This is a compile-time assertion to ensure that this generated file
  2427  // is compatible with the grpc package it is being compiled against.
  2428  const _ = grpc.SupportPackageIsVersion6
  2429  
  2430  // StreamingServiceClient is the client API for StreamingService service.
  2431  //
  2432  // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
  2433  type StreamingServiceClient interface {
  2434  	// Send packets to the series.
  2435  	SendPackets(ctx context.Context, opts ...grpc.CallOption) (StreamingService_SendPacketsClient, error)
  2436  	// Receive packets from the series.
  2437  	ReceivePackets(ctx context.Context, opts ...grpc.CallOption) (StreamingService_ReceivePacketsClient, error)
  2438  	// Receive events given the stream name.
  2439  	ReceiveEvents(ctx context.Context, opts ...grpc.CallOption) (StreamingService_ReceiveEventsClient, error)
  2440  	// AcquireLease acquires a lease.
  2441  	AcquireLease(ctx context.Context, in *AcquireLeaseRequest, opts ...grpc.CallOption) (*Lease, error)
  2442  	// RenewLease renews a lease.
  2443  	RenewLease(ctx context.Context, in *RenewLeaseRequest, opts ...grpc.CallOption) (*Lease, error)
  2444  	// RleaseLease releases a lease.
  2445  	ReleaseLease(ctx context.Context, in *ReleaseLeaseRequest, opts ...grpc.CallOption) (*ReleaseLeaseResponse, error)
  2446  }
  2447  
  2448  type streamingServiceClient struct {
  2449  	cc grpc.ClientConnInterface
  2450  }
  2451  
  2452  func NewStreamingServiceClient(cc grpc.ClientConnInterface) StreamingServiceClient {
  2453  	return &streamingServiceClient{cc}
  2454  }
  2455  
  2456  func (c *streamingServiceClient) SendPackets(ctx context.Context, opts ...grpc.CallOption) (StreamingService_SendPacketsClient, error) {
  2457  	stream, err := c.cc.NewStream(ctx, &_StreamingService_serviceDesc.Streams[0], "/google.cloud.visionai.v1alpha1.StreamingService/SendPackets", opts...)
  2458  	if err != nil {
  2459  		return nil, err
  2460  	}
  2461  	x := &streamingServiceSendPacketsClient{stream}
  2462  	return x, nil
  2463  }
  2464  
  2465  type StreamingService_SendPacketsClient interface {
  2466  	Send(*SendPacketsRequest) error
  2467  	Recv() (*SendPacketsResponse, error)
  2468  	grpc.ClientStream
  2469  }
  2470  
  2471  type streamingServiceSendPacketsClient struct {
  2472  	grpc.ClientStream
  2473  }
  2474  
  2475  func (x *streamingServiceSendPacketsClient) Send(m *SendPacketsRequest) error {
  2476  	return x.ClientStream.SendMsg(m)
  2477  }
  2478  
  2479  func (x *streamingServiceSendPacketsClient) Recv() (*SendPacketsResponse, error) {
  2480  	m := new(SendPacketsResponse)
  2481  	if err := x.ClientStream.RecvMsg(m); err != nil {
  2482  		return nil, err
  2483  	}
  2484  	return m, nil
  2485  }
  2486  
  2487  func (c *streamingServiceClient) ReceivePackets(ctx context.Context, opts ...grpc.CallOption) (StreamingService_ReceivePacketsClient, error) {
  2488  	stream, err := c.cc.NewStream(ctx, &_StreamingService_serviceDesc.Streams[1], "/google.cloud.visionai.v1alpha1.StreamingService/ReceivePackets", opts...)
  2489  	if err != nil {
  2490  		return nil, err
  2491  	}
  2492  	x := &streamingServiceReceivePacketsClient{stream}
  2493  	return x, nil
  2494  }
  2495  
  2496  type StreamingService_ReceivePacketsClient interface {
  2497  	Send(*ReceivePacketsRequest) error
  2498  	Recv() (*ReceivePacketsResponse, error)
  2499  	grpc.ClientStream
  2500  }
  2501  
  2502  type streamingServiceReceivePacketsClient struct {
  2503  	grpc.ClientStream
  2504  }
  2505  
  2506  func (x *streamingServiceReceivePacketsClient) Send(m *ReceivePacketsRequest) error {
  2507  	return x.ClientStream.SendMsg(m)
  2508  }
  2509  
  2510  func (x *streamingServiceReceivePacketsClient) Recv() (*ReceivePacketsResponse, error) {
  2511  	m := new(ReceivePacketsResponse)
  2512  	if err := x.ClientStream.RecvMsg(m); err != nil {
  2513  		return nil, err
  2514  	}
  2515  	return m, nil
  2516  }
  2517  
  2518  func (c *streamingServiceClient) ReceiveEvents(ctx context.Context, opts ...grpc.CallOption) (StreamingService_ReceiveEventsClient, error) {
  2519  	stream, err := c.cc.NewStream(ctx, &_StreamingService_serviceDesc.Streams[2], "/google.cloud.visionai.v1alpha1.StreamingService/ReceiveEvents", opts...)
  2520  	if err != nil {
  2521  		return nil, err
  2522  	}
  2523  	x := &streamingServiceReceiveEventsClient{stream}
  2524  	return x, nil
  2525  }
  2526  
  2527  type StreamingService_ReceiveEventsClient interface {
  2528  	Send(*ReceiveEventsRequest) error
  2529  	Recv() (*ReceiveEventsResponse, error)
  2530  	grpc.ClientStream
  2531  }
  2532  
  2533  type streamingServiceReceiveEventsClient struct {
  2534  	grpc.ClientStream
  2535  }
  2536  
  2537  func (x *streamingServiceReceiveEventsClient) Send(m *ReceiveEventsRequest) error {
  2538  	return x.ClientStream.SendMsg(m)
  2539  }
  2540  
  2541  func (x *streamingServiceReceiveEventsClient) Recv() (*ReceiveEventsResponse, error) {
  2542  	m := new(ReceiveEventsResponse)
  2543  	if err := x.ClientStream.RecvMsg(m); err != nil {
  2544  		return nil, err
  2545  	}
  2546  	return m, nil
  2547  }
  2548  
  2549  func (c *streamingServiceClient) AcquireLease(ctx context.Context, in *AcquireLeaseRequest, opts ...grpc.CallOption) (*Lease, error) {
  2550  	out := new(Lease)
  2551  	err := c.cc.Invoke(ctx, "/google.cloud.visionai.v1alpha1.StreamingService/AcquireLease", in, out, opts...)
  2552  	if err != nil {
  2553  		return nil, err
  2554  	}
  2555  	return out, nil
  2556  }
  2557  
  2558  func (c *streamingServiceClient) RenewLease(ctx context.Context, in *RenewLeaseRequest, opts ...grpc.CallOption) (*Lease, error) {
  2559  	out := new(Lease)
  2560  	err := c.cc.Invoke(ctx, "/google.cloud.visionai.v1alpha1.StreamingService/RenewLease", in, out, opts...)
  2561  	if err != nil {
  2562  		return nil, err
  2563  	}
  2564  	return out, nil
  2565  }
  2566  
  2567  func (c *streamingServiceClient) ReleaseLease(ctx context.Context, in *ReleaseLeaseRequest, opts ...grpc.CallOption) (*ReleaseLeaseResponse, error) {
  2568  	out := new(ReleaseLeaseResponse)
  2569  	err := c.cc.Invoke(ctx, "/google.cloud.visionai.v1alpha1.StreamingService/ReleaseLease", in, out, opts...)
  2570  	if err != nil {
  2571  		return nil, err
  2572  	}
  2573  	return out, nil
  2574  }
  2575  
  2576  // StreamingServiceServer is the server API for StreamingService service.
  2577  type StreamingServiceServer interface {
  2578  	// Send packets to the series.
  2579  	SendPackets(StreamingService_SendPacketsServer) error
  2580  	// Receive packets from the series.
  2581  	ReceivePackets(StreamingService_ReceivePacketsServer) error
  2582  	// Receive events given the stream name.
  2583  	ReceiveEvents(StreamingService_ReceiveEventsServer) error
  2584  	// AcquireLease acquires a lease.
  2585  	AcquireLease(context.Context, *AcquireLeaseRequest) (*Lease, error)
  2586  	// RenewLease renews a lease.
  2587  	RenewLease(context.Context, *RenewLeaseRequest) (*Lease, error)
  2588  	// RleaseLease releases a lease.
  2589  	ReleaseLease(context.Context, *ReleaseLeaseRequest) (*ReleaseLeaseResponse, error)
  2590  }
  2591  
  2592  // UnimplementedStreamingServiceServer can be embedded to have forward compatible implementations.
  2593  type UnimplementedStreamingServiceServer struct {
  2594  }
  2595  
  2596  func (*UnimplementedStreamingServiceServer) SendPackets(StreamingService_SendPacketsServer) error {
  2597  	return status.Errorf(codes.Unimplemented, "method SendPackets not implemented")
  2598  }
  2599  func (*UnimplementedStreamingServiceServer) ReceivePackets(StreamingService_ReceivePacketsServer) error {
  2600  	return status.Errorf(codes.Unimplemented, "method ReceivePackets not implemented")
  2601  }
  2602  func (*UnimplementedStreamingServiceServer) ReceiveEvents(StreamingService_ReceiveEventsServer) error {
  2603  	return status.Errorf(codes.Unimplemented, "method ReceiveEvents not implemented")
  2604  }
  2605  func (*UnimplementedStreamingServiceServer) AcquireLease(context.Context, *AcquireLeaseRequest) (*Lease, error) {
  2606  	return nil, status.Errorf(codes.Unimplemented, "method AcquireLease not implemented")
  2607  }
  2608  func (*UnimplementedStreamingServiceServer) RenewLease(context.Context, *RenewLeaseRequest) (*Lease, error) {
  2609  	return nil, status.Errorf(codes.Unimplemented, "method RenewLease not implemented")
  2610  }
  2611  func (*UnimplementedStreamingServiceServer) ReleaseLease(context.Context, *ReleaseLeaseRequest) (*ReleaseLeaseResponse, error) {
  2612  	return nil, status.Errorf(codes.Unimplemented, "method ReleaseLease not implemented")
  2613  }
  2614  
  2615  func RegisterStreamingServiceServer(s *grpc.Server, srv StreamingServiceServer) {
  2616  	s.RegisterService(&_StreamingService_serviceDesc, srv)
  2617  }
  2618  
  2619  func _StreamingService_SendPackets_Handler(srv interface{}, stream grpc.ServerStream) error {
  2620  	return srv.(StreamingServiceServer).SendPackets(&streamingServiceSendPacketsServer{stream})
  2621  }
  2622  
  2623  type StreamingService_SendPacketsServer interface {
  2624  	Send(*SendPacketsResponse) error
  2625  	Recv() (*SendPacketsRequest, error)
  2626  	grpc.ServerStream
  2627  }
  2628  
  2629  type streamingServiceSendPacketsServer struct {
  2630  	grpc.ServerStream
  2631  }
  2632  
  2633  func (x *streamingServiceSendPacketsServer) Send(m *SendPacketsResponse) error {
  2634  	return x.ServerStream.SendMsg(m)
  2635  }
  2636  
  2637  func (x *streamingServiceSendPacketsServer) Recv() (*SendPacketsRequest, error) {
  2638  	m := new(SendPacketsRequest)
  2639  	if err := x.ServerStream.RecvMsg(m); err != nil {
  2640  		return nil, err
  2641  	}
  2642  	return m, nil
  2643  }
  2644  
  2645  func _StreamingService_ReceivePackets_Handler(srv interface{}, stream grpc.ServerStream) error {
  2646  	return srv.(StreamingServiceServer).ReceivePackets(&streamingServiceReceivePacketsServer{stream})
  2647  }
  2648  
  2649  type StreamingService_ReceivePacketsServer interface {
  2650  	Send(*ReceivePacketsResponse) error
  2651  	Recv() (*ReceivePacketsRequest, error)
  2652  	grpc.ServerStream
  2653  }
  2654  
  2655  type streamingServiceReceivePacketsServer struct {
  2656  	grpc.ServerStream
  2657  }
  2658  
  2659  func (x *streamingServiceReceivePacketsServer) Send(m *ReceivePacketsResponse) error {
  2660  	return x.ServerStream.SendMsg(m)
  2661  }
  2662  
  2663  func (x *streamingServiceReceivePacketsServer) Recv() (*ReceivePacketsRequest, error) {
  2664  	m := new(ReceivePacketsRequest)
  2665  	if err := x.ServerStream.RecvMsg(m); err != nil {
  2666  		return nil, err
  2667  	}
  2668  	return m, nil
  2669  }
  2670  
  2671  func _StreamingService_ReceiveEvents_Handler(srv interface{}, stream grpc.ServerStream) error {
  2672  	return srv.(StreamingServiceServer).ReceiveEvents(&streamingServiceReceiveEventsServer{stream})
  2673  }
  2674  
  2675  type StreamingService_ReceiveEventsServer interface {
  2676  	Send(*ReceiveEventsResponse) error
  2677  	Recv() (*ReceiveEventsRequest, error)
  2678  	grpc.ServerStream
  2679  }
  2680  
  2681  type streamingServiceReceiveEventsServer struct {
  2682  	grpc.ServerStream
  2683  }
  2684  
  2685  func (x *streamingServiceReceiveEventsServer) Send(m *ReceiveEventsResponse) error {
  2686  	return x.ServerStream.SendMsg(m)
  2687  }
  2688  
  2689  func (x *streamingServiceReceiveEventsServer) Recv() (*ReceiveEventsRequest, error) {
  2690  	m := new(ReceiveEventsRequest)
  2691  	if err := x.ServerStream.RecvMsg(m); err != nil {
  2692  		return nil, err
  2693  	}
  2694  	return m, nil
  2695  }
  2696  
  2697  func _StreamingService_AcquireLease_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2698  	in := new(AcquireLeaseRequest)
  2699  	if err := dec(in); err != nil {
  2700  		return nil, err
  2701  	}
  2702  	if interceptor == nil {
  2703  		return srv.(StreamingServiceServer).AcquireLease(ctx, in)
  2704  	}
  2705  	info := &grpc.UnaryServerInfo{
  2706  		Server:     srv,
  2707  		FullMethod: "/google.cloud.visionai.v1alpha1.StreamingService/AcquireLease",
  2708  	}
  2709  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2710  		return srv.(StreamingServiceServer).AcquireLease(ctx, req.(*AcquireLeaseRequest))
  2711  	}
  2712  	return interceptor(ctx, in, info, handler)
  2713  }
  2714  
  2715  func _StreamingService_RenewLease_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2716  	in := new(RenewLeaseRequest)
  2717  	if err := dec(in); err != nil {
  2718  		return nil, err
  2719  	}
  2720  	if interceptor == nil {
  2721  		return srv.(StreamingServiceServer).RenewLease(ctx, in)
  2722  	}
  2723  	info := &grpc.UnaryServerInfo{
  2724  		Server:     srv,
  2725  		FullMethod: "/google.cloud.visionai.v1alpha1.StreamingService/RenewLease",
  2726  	}
  2727  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2728  		return srv.(StreamingServiceServer).RenewLease(ctx, req.(*RenewLeaseRequest))
  2729  	}
  2730  	return interceptor(ctx, in, info, handler)
  2731  }
  2732  
  2733  func _StreamingService_ReleaseLease_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2734  	in := new(ReleaseLeaseRequest)
  2735  	if err := dec(in); err != nil {
  2736  		return nil, err
  2737  	}
  2738  	if interceptor == nil {
  2739  		return srv.(StreamingServiceServer).ReleaseLease(ctx, in)
  2740  	}
  2741  	info := &grpc.UnaryServerInfo{
  2742  		Server:     srv,
  2743  		FullMethod: "/google.cloud.visionai.v1alpha1.StreamingService/ReleaseLease",
  2744  	}
  2745  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2746  		return srv.(StreamingServiceServer).ReleaseLease(ctx, req.(*ReleaseLeaseRequest))
  2747  	}
  2748  	return interceptor(ctx, in, info, handler)
  2749  }
  2750  
  2751  var _StreamingService_serviceDesc = grpc.ServiceDesc{
  2752  	ServiceName: "google.cloud.visionai.v1alpha1.StreamingService",
  2753  	HandlerType: (*StreamingServiceServer)(nil),
  2754  	Methods: []grpc.MethodDesc{
  2755  		{
  2756  			MethodName: "AcquireLease",
  2757  			Handler:    _StreamingService_AcquireLease_Handler,
  2758  		},
  2759  		{
  2760  			MethodName: "RenewLease",
  2761  			Handler:    _StreamingService_RenewLease_Handler,
  2762  		},
  2763  		{
  2764  			MethodName: "ReleaseLease",
  2765  			Handler:    _StreamingService_ReleaseLease_Handler,
  2766  		},
  2767  	},
  2768  	Streams: []grpc.StreamDesc{
  2769  		{
  2770  			StreamName:    "SendPackets",
  2771  			Handler:       _StreamingService_SendPackets_Handler,
  2772  			ServerStreams: true,
  2773  			ClientStreams: true,
  2774  		},
  2775  		{
  2776  			StreamName:    "ReceivePackets",
  2777  			Handler:       _StreamingService_ReceivePackets_Handler,
  2778  			ServerStreams: true,
  2779  			ClientStreams: true,
  2780  		},
  2781  		{
  2782  			StreamName:    "ReceiveEvents",
  2783  			Handler:       _StreamingService_ReceiveEvents_Handler,
  2784  			ServerStreams: true,
  2785  			ClientStreams: true,
  2786  		},
  2787  	},
  2788  	Metadata: "google/cloud/visionai/v1alpha1/streaming_service.proto",
  2789  }
  2790  

View as plain text