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

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

     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/v1/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_v1_streaming_service_proto_enumTypes[0].Descriptor()
    83  }
    84  
    85  func (LeaseType) Type() protoreflect.EnumType {
    86  	return &file_google_cloud_visionai_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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.v1.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_v1_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_v1_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_v1_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.v1.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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_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_v1_streaming_service_proto protoreflect.FileDescriptor
  1712  
  1713  var file_google_cloud_visionai_v1_streaming_service_proto_rawDesc = []byte{
  1714  	0x0a, 0x30, 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, 0x2f, 0x73, 0x74, 0x72, 0x65, 0x61,
  1716  	0x6d, 0x69, 0x6e, 0x67, 0x5f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x70, 0x72, 0x6f,
  1717  	0x74, 0x6f, 0x12, 0x18, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64,
  1718  	0x2e, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2e, 0x76, 0x31, 0x1a, 0x1c, 0x67, 0x6f,
  1719  	0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74,
  1720  	0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x17, 0x67, 0x6f, 0x6f, 0x67,
  1721  	0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x2e, 0x70, 0x72,
  1722  	0x6f, 0x74, 0x6f, 0x1a, 0x32, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75,
  1723  	0x64, 0x2f, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2f, 0x76, 0x31, 0x2f, 0x73, 0x74,
  1724  	0x72, 0x65, 0x61, 0x6d, 0x69, 0x6e, 0x67, 0x5f, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65,
  1725  	0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f,
  1726  	0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x64, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f,
  1727  	0x6e, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f,
  1728  	0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61,
  1729  	0x6d, 0x70, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0xa7, 0x04, 0x0a, 0x14, 0x52, 0x65, 0x63,
  1730  	0x65, 0x69, 0x76, 0x65, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73,
  1731  	0x74, 0x12, 0x62, 0x0a, 0x0d, 0x73, 0x65, 0x74, 0x75, 0x70, 0x5f, 0x72, 0x65, 0x71, 0x75, 0x65,
  1732  	0x73, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x3b, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
  1733  	0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69,
  1734  	0x2e, 0x76, 0x31, 0x2e, 0x52, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x45, 0x76, 0x65, 0x6e, 0x74,
  1735  	0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x53, 0x65, 0x74, 0x75, 0x70, 0x52, 0x65,
  1736  	0x71, 0x75, 0x65, 0x73, 0x74, 0x48, 0x00, 0x52, 0x0c, 0x73, 0x65, 0x74, 0x75, 0x70, 0x52, 0x65,
  1737  	0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x50, 0x0a, 0x0e, 0x63, 0x6f, 0x6d, 0x6d, 0x69, 0x74, 0x5f,
  1738  	0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x27, 0x2e,
  1739  	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x76, 0x69, 0x73,
  1740  	0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2e, 0x76, 0x31, 0x2e, 0x43, 0x6f, 0x6d, 0x6d, 0x69, 0x74, 0x52,
  1741  	0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x48, 0x00, 0x52, 0x0d, 0x63, 0x6f, 0x6d, 0x6d, 0x69, 0x74,
  1742  	0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0xcd, 0x02, 0x0a, 0x0c, 0x53, 0x65, 0x74, 0x75,
  1743  	0x70, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x18, 0x0a, 0x07, 0x63, 0x6c, 0x75, 0x73,
  1744  	0x74, 0x65, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x63, 0x6c, 0x75, 0x73, 0x74,
  1745  	0x65, 0x72, 0x12, 0x16, 0x0a, 0x06, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x18, 0x02, 0x20, 0x01,
  1746  	0x28, 0x09, 0x52, 0x06, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x1a, 0x0a, 0x08, 0x72, 0x65,
  1747  	0x63, 0x65, 0x69, 0x76, 0x65, 0x72, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x72, 0x65,
  1748  	0x63, 0x65, 0x69, 0x76, 0x65, 0x72, 0x12, 0x51, 0x0a, 0x0f, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f,
  1749  	0x6c, 0x6c, 0x65, 0x64, 0x5f, 0x6d, 0x6f, 0x64, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32,
  1750  	0x28, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x76,
  1751  	0x69, 0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2e, 0x76, 0x31, 0x2e, 0x43, 0x6f, 0x6e, 0x74, 0x72,
  1752  	0x6f, 0x6c, 0x6c, 0x65, 0x64, 0x4d, 0x6f, 0x64, 0x65, 0x52, 0x0e, 0x63, 0x6f, 0x6e, 0x74, 0x72,
  1753  	0x6f, 0x6c, 0x6c, 0x65, 0x64, 0x4d, 0x6f, 0x64, 0x65, 0x12, 0x48, 0x0a, 0x12, 0x68, 0x65, 0x61,
  1754  	0x72, 0x74, 0x62, 0x65, 0x61, 0x74, 0x5f, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x76, 0x61, 0x6c, 0x18,
  1755  	0x05, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x19, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70,
  1756  	0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x44, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e,
  1757  	0x52, 0x11, 0x68, 0x65, 0x61, 0x72, 0x74, 0x62, 0x65, 0x61, 0x74, 0x49, 0x6e, 0x74, 0x65, 0x72,
  1758  	0x76, 0x61, 0x6c, 0x12, 0x52, 0x0a, 0x18, 0x77, 0x72, 0x69, 0x74, 0x65, 0x73, 0x5f, 0x64, 0x6f,
  1759  	0x6e, 0x65, 0x5f, 0x67, 0x72, 0x61, 0x63, 0x65, 0x5f, 0x70, 0x65, 0x72, 0x69, 0x6f, 0x64, 0x18,
  1760  	0x06, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x19, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70,
  1761  	0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x44, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e,
  1762  	0x52, 0x15, 0x77, 0x72, 0x69, 0x74, 0x65, 0x73, 0x44, 0x6f, 0x6e, 0x65, 0x47, 0x72, 0x61, 0x63,
  1763  	0x65, 0x50, 0x65, 0x72, 0x69, 0x6f, 0x64, 0x42, 0x09, 0x0a, 0x07, 0x72, 0x65, 0x71, 0x75, 0x65,
  1764  	0x73, 0x74, 0x22, 0xa8, 0x01, 0x0a, 0x0b, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x55, 0x70, 0x64, 0x61,
  1765  	0x74, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x18, 0x01, 0x20, 0x01,
  1766  	0x28, 0x09, 0x52, 0x06, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x14, 0x0a, 0x05, 0x65, 0x76,
  1767  	0x65, 0x6e, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x65, 0x76, 0x65, 0x6e, 0x74,
  1768  	0x12, 0x16, 0x0a, 0x06, 0x73, 0x65, 0x72, 0x69, 0x65, 0x73, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09,
  1769  	0x52, 0x06, 0x73, 0x65, 0x72, 0x69, 0x65, 0x73, 0x12, 0x3b, 0x0a, 0x0b, 0x75, 0x70, 0x64, 0x61,
  1770  	0x74, 0x65, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e,
  1771  	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e,
  1772  	0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x52, 0x0a, 0x75, 0x70, 0x64, 0x61, 0x74,
  1773  	0x65, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x18,
  1774  	0x05, 0x20, 0x01, 0x28, 0x03, 0x52, 0x06, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x22, 0x7b, 0x0a,
  1775  	0x1c, 0x52, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x73, 0x43, 0x6f,
  1776  	0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x1e, 0x0a,
  1777  	0x09, 0x68, 0x65, 0x61, 0x72, 0x74, 0x62, 0x65, 0x61, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x08,
  1778  	0x48, 0x00, 0x52, 0x09, 0x68, 0x65, 0x61, 0x72, 0x74, 0x62, 0x65, 0x61, 0x74, 0x12, 0x30, 0x0a,
  1779  	0x13, 0x77, 0x72, 0x69, 0x74, 0x65, 0x73, 0x5f, 0x64, 0x6f, 0x6e, 0x65, 0x5f, 0x72, 0x65, 0x71,
  1780  	0x75, 0x65, 0x73, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x08, 0x48, 0x00, 0x52, 0x11, 0x77, 0x72,
  1781  	0x69, 0x74, 0x65, 0x73, 0x44, 0x6f, 0x6e, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x42,
  1782  	0x09, 0x0a, 0x07, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x22, 0xc3, 0x01, 0x0a, 0x15, 0x52,
  1783  	0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x73, 0x52, 0x65, 0x73, 0x70,
  1784  	0x6f, 0x6e, 0x73, 0x65, 0x12, 0x4a, 0x0a, 0x0c, 0x65, 0x76, 0x65, 0x6e, 0x74, 0x5f, 0x75, 0x70,
  1785  	0x64, 0x61, 0x74, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x25, 0x2e, 0x67, 0x6f, 0x6f,
  1786  	0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e,
  1787  	0x61, 0x69, 0x2e, 0x76, 0x31, 0x2e, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x55, 0x70, 0x64, 0x61, 0x74,
  1788  	0x65, 0x48, 0x00, 0x52, 0x0b, 0x65, 0x76, 0x65, 0x6e, 0x74, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65,
  1789  	0x12, 0x52, 0x0a, 0x07, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x18, 0x02, 0x20, 0x01, 0x28,
  1790  	0x0b, 0x32, 0x36, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64,
  1791  	0x2e, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2e, 0x76, 0x31, 0x2e, 0x52, 0x65, 0x63,
  1792  	0x65, 0x69, 0x76, 0x65, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x73, 0x43, 0x6f, 0x6e, 0x74, 0x72, 0x6f,
  1793  	0x6c, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x48, 0x00, 0x52, 0x07, 0x63, 0x6f, 0x6e,
  1794  	0x74, 0x72, 0x6f, 0x6c, 0x42, 0x0a, 0x0a, 0x08, 0x72, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65,
  1795  	0x22, 0xc6, 0x01, 0x0a, 0x05, 0x4c, 0x65, 0x61, 0x73, 0x65, 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64,
  1796  	0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x02, 0x69, 0x64, 0x12, 0x16, 0x0a, 0x06, 0x73, 0x65,
  1797  	0x72, 0x69, 0x65, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x73, 0x65, 0x72, 0x69,
  1798  	0x65, 0x73, 0x12, 0x14, 0x0a, 0x05, 0x6f, 0x77, 0x6e, 0x65, 0x72, 0x18, 0x03, 0x20, 0x01, 0x28,
  1799  	0x09, 0x52, 0x05, 0x6f, 0x77, 0x6e, 0x65, 0x72, 0x12, 0x3b, 0x0a, 0x0b, 0x65, 0x78, 0x70, 0x69,
  1800  	0x72, 0x65, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e,
  1801  	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e,
  1802  	0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x52, 0x0a, 0x65, 0x78, 0x70, 0x69, 0x72,
  1803  	0x65, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x42, 0x0a, 0x0a, 0x6c, 0x65, 0x61, 0x73, 0x65, 0x5f, 0x74,
  1804  	0x79, 0x70, 0x65, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x23, 0x2e, 0x67, 0x6f, 0x6f, 0x67,
  1805  	0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x61,
  1806  	0x69, 0x2e, 0x76, 0x31, 0x2e, 0x4c, 0x65, 0x61, 0x73, 0x65, 0x54, 0x79, 0x70, 0x65, 0x52, 0x09,
  1807  	0x6c, 0x65, 0x61, 0x73, 0x65, 0x54, 0x79, 0x70, 0x65, 0x22, 0xb6, 0x01, 0x0a, 0x13, 0x41, 0x63,
  1808  	0x71, 0x75, 0x69, 0x72, 0x65, 0x4c, 0x65, 0x61, 0x73, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73,
  1809  	0x74, 0x12, 0x16, 0x0a, 0x06, 0x73, 0x65, 0x72, 0x69, 0x65, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28,
  1810  	0x09, 0x52, 0x06, 0x73, 0x65, 0x72, 0x69, 0x65, 0x73, 0x12, 0x14, 0x0a, 0x05, 0x6f, 0x77, 0x6e,
  1811  	0x65, 0x72, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x6f, 0x77, 0x6e, 0x65, 0x72, 0x12,
  1812  	0x2d, 0x0a, 0x04, 0x74, 0x65, 0x72, 0x6d, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x19, 0x2e,
  1813  	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e,
  1814  	0x44, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x04, 0x74, 0x65, 0x72, 0x6d, 0x12, 0x42,
  1815  	0x0a, 0x0a, 0x6c, 0x65, 0x61, 0x73, 0x65, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x18, 0x04, 0x20, 0x01,
  1816  	0x28, 0x0e, 0x32, 0x23, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75,
  1817  	0x64, 0x2e, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2e, 0x76, 0x31, 0x2e, 0x4c, 0x65,
  1818  	0x61, 0x73, 0x65, 0x54, 0x79, 0x70, 0x65, 0x52, 0x09, 0x6c, 0x65, 0x61, 0x73, 0x65, 0x54, 0x79,
  1819  	0x70, 0x65, 0x22, 0x80, 0x01, 0x0a, 0x11, 0x52, 0x65, 0x6e, 0x65, 0x77, 0x4c, 0x65, 0x61, 0x73,
  1820  	0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x01,
  1821  	0x20, 0x01, 0x28, 0x09, 0x52, 0x02, 0x69, 0x64, 0x12, 0x16, 0x0a, 0x06, 0x73, 0x65, 0x72, 0x69,
  1822  	0x65, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x73, 0x65, 0x72, 0x69, 0x65, 0x73,
  1823  	0x12, 0x14, 0x0a, 0x05, 0x6f, 0x77, 0x6e, 0x65, 0x72, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52,
  1824  	0x05, 0x6f, 0x77, 0x6e, 0x65, 0x72, 0x12, 0x2d, 0x0a, 0x04, 0x74, 0x65, 0x72, 0x6d, 0x18, 0x04,
  1825  	0x20, 0x01, 0x28, 0x0b, 0x32, 0x19, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72,
  1826  	0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x44, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52,
  1827  	0x04, 0x74, 0x65, 0x72, 0x6d, 0x22, 0x53, 0x0a, 0x13, 0x52, 0x65, 0x6c, 0x65, 0x61, 0x73, 0x65,
  1828  	0x4c, 0x65, 0x61, 0x73, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x0e, 0x0a, 0x02,
  1829  	0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x02, 0x69, 0x64, 0x12, 0x16, 0x0a, 0x06,
  1830  	0x73, 0x65, 0x72, 0x69, 0x65, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x73, 0x65,
  1831  	0x72, 0x69, 0x65, 0x73, 0x12, 0x14, 0x0a, 0x05, 0x6f, 0x77, 0x6e, 0x65, 0x72, 0x18, 0x03, 0x20,
  1832  	0x01, 0x28, 0x09, 0x52, 0x05, 0x6f, 0x77, 0x6e, 0x65, 0x72, 0x22, 0x16, 0x0a, 0x14, 0x52, 0x65,
  1833  	0x6c, 0x65, 0x61, 0x73, 0x65, 0x4c, 0x65, 0x61, 0x73, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e,
  1834  	0x73, 0x65, 0x22, 0xc2, 0x01, 0x0a, 0x0f, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x4d, 0x65,
  1835  	0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x12, 0x16, 0x0a, 0x06, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d,
  1836  	0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x14,
  1837  	0x0a, 0x05, 0x65, 0x76, 0x65, 0x6e, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x65,
  1838  	0x76, 0x65, 0x6e, 0x74, 0x12, 0x16, 0x0a, 0x06, 0x73, 0x65, 0x72, 0x69, 0x65, 0x73, 0x18, 0x03,
  1839  	0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x73, 0x65, 0x72, 0x69, 0x65, 0x73, 0x12, 0x19, 0x0a, 0x08,
  1840  	0x6c, 0x65, 0x61, 0x73, 0x65, 0x5f, 0x69, 0x64, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07,
  1841  	0x6c, 0x65, 0x61, 0x73, 0x65, 0x49, 0x64, 0x12, 0x14, 0x0a, 0x05, 0x6f, 0x77, 0x6e, 0x65, 0x72,
  1842  	0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x6f, 0x77, 0x6e, 0x65, 0x72, 0x12, 0x38, 0x0a,
  1843  	0x0a, 0x6c, 0x65, 0x61, 0x73, 0x65, 0x5f, 0x74, 0x65, 0x72, 0x6d, 0x18, 0x06, 0x20, 0x01, 0x28,
  1844  	0x0b, 0x32, 0x19, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f,
  1845  	0x62, 0x75, 0x66, 0x2e, 0x44, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x09, 0x6c, 0x65,
  1846  	0x61, 0x73, 0x65, 0x54, 0x65, 0x72, 0x6d, 0x22, 0xa4, 0x01, 0x0a, 0x12, 0x53, 0x65, 0x6e, 0x64,
  1847  	0x50, 0x61, 0x63, 0x6b, 0x65, 0x74, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x3a,
  1848  	0x0a, 0x06, 0x70, 0x61, 0x63, 0x6b, 0x65, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x20,
  1849  	0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x76, 0x69,
  1850  	0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2e, 0x76, 0x31, 0x2e, 0x50, 0x61, 0x63, 0x6b, 0x65, 0x74,
  1851  	0x48, 0x00, 0x52, 0x06, 0x70, 0x61, 0x63, 0x6b, 0x65, 0x74, 0x12, 0x47, 0x0a, 0x08, 0x6d, 0x65,
  1852  	0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x29, 0x2e, 0x67,
  1853  	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x76, 0x69, 0x73, 0x69,
  1854  	0x6f, 0x6e, 0x61, 0x69, 0x2e, 0x76, 0x31, 0x2e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x4d,
  1855  	0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x48, 0x00, 0x52, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64,
  1856  	0x61, 0x74, 0x61, 0x42, 0x09, 0x0a, 0x07, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x22, 0x15,
  1857  	0x0a, 0x13, 0x53, 0x65, 0x6e, 0x64, 0x50, 0x61, 0x63, 0x6b, 0x65, 0x74, 0x73, 0x52, 0x65, 0x73,
  1858  	0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0xb5, 0x05, 0x0a, 0x15, 0x52, 0x65, 0x63, 0x65, 0x69, 0x76,
  1859  	0x65, 0x50, 0x61, 0x63, 0x6b, 0x65, 0x74, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12,
  1860  	0x63, 0x0a, 0x0d, 0x73, 0x65, 0x74, 0x75, 0x70, 0x5f, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
  1861  	0x18, 0x06, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x3c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e,
  1862  	0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2e, 0x76,
  1863  	0x31, 0x2e, 0x52, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x50, 0x61, 0x63, 0x6b, 0x65, 0x74, 0x73,
  1864  	0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x53, 0x65, 0x74, 0x75, 0x70, 0x52, 0x65, 0x71,
  1865  	0x75, 0x65, 0x73, 0x74, 0x48, 0x00, 0x52, 0x0c, 0x73, 0x65, 0x74, 0x75, 0x70, 0x52, 0x65, 0x71,
  1866  	0x75, 0x65, 0x73, 0x74, 0x12, 0x50, 0x0a, 0x0e, 0x63, 0x6f, 0x6d, 0x6d, 0x69, 0x74, 0x5f, 0x72,
  1867  	0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x18, 0x07, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x27, 0x2e, 0x67,
  1868  	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x76, 0x69, 0x73, 0x69,
  1869  	0x6f, 0x6e, 0x61, 0x69, 0x2e, 0x76, 0x31, 0x2e, 0x43, 0x6f, 0x6d, 0x6d, 0x69, 0x74, 0x52, 0x65,
  1870  	0x71, 0x75, 0x65, 0x73, 0x74, 0x48, 0x00, 0x52, 0x0d, 0x63, 0x6f, 0x6d, 0x6d, 0x69, 0x74, 0x52,
  1871  	0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0xd9, 0x03, 0x0a, 0x0c, 0x53, 0x65, 0x74, 0x75, 0x70,
  1872  	0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x53, 0x0a, 0x12, 0x65, 0x61, 0x67, 0x65, 0x72,
  1873  	0x5f, 0x72, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x5f, 0x6d, 0x6f, 0x64, 0x65, 0x18, 0x03, 0x20,
  1874  	0x01, 0x28, 0x0b, 0x32, 0x23, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f,
  1875  	0x75, 0x64, 0x2e, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2e, 0x76, 0x31, 0x2e, 0x45,
  1876  	0x61, 0x67, 0x65, 0x72, 0x4d, 0x6f, 0x64, 0x65, 0x48, 0x00, 0x52, 0x10, 0x65, 0x61, 0x67, 0x65,
  1877  	0x72, 0x52, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x4d, 0x6f, 0x64, 0x65, 0x12, 0x62, 0x0a, 0x17,
  1878  	0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65, 0x64, 0x5f, 0x72, 0x65, 0x63, 0x65, 0x69,
  1879  	0x76, 0x65, 0x5f, 0x6d, 0x6f, 0x64, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x28, 0x2e,
  1880  	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x76, 0x69, 0x73,
  1881  	0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2e, 0x76, 0x31, 0x2e, 0x43, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c,
  1882  	0x6c, 0x65, 0x64, 0x4d, 0x6f, 0x64, 0x65, 0x48, 0x00, 0x52, 0x15, 0x63, 0x6f, 0x6e, 0x74, 0x72,
  1883  	0x6f, 0x6c, 0x6c, 0x65, 0x64, 0x52, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x4d, 0x6f, 0x64, 0x65,
  1884  	0x12, 0x45, 0x0a, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x18, 0x01, 0x20, 0x01,
  1885  	0x28, 0x0b, 0x32, 0x29, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75,
  1886  	0x64, 0x2e, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2e, 0x76, 0x31, 0x2e, 0x52, 0x65,
  1887  	0x71, 0x75, 0x65, 0x73, 0x74, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x52, 0x08, 0x6d,
  1888  	0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x12, 0x1a, 0x0a, 0x08, 0x72, 0x65, 0x63, 0x65, 0x69,
  1889  	0x76, 0x65, 0x72, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x72, 0x65, 0x63, 0x65, 0x69,
  1890  	0x76, 0x65, 0x72, 0x12, 0x48, 0x0a, 0x12, 0x68, 0x65, 0x61, 0x72, 0x74, 0x62, 0x65, 0x61, 0x74,
  1891  	0x5f, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x76, 0x61, 0x6c, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0b, 0x32,
  1892  	0x19, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75,
  1893  	0x66, 0x2e, 0x44, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x11, 0x68, 0x65, 0x61, 0x72,
  1894  	0x74, 0x62, 0x65, 0x61, 0x74, 0x49, 0x6e, 0x74, 0x65, 0x72, 0x76, 0x61, 0x6c, 0x12, 0x52, 0x0a,
  1895  	0x18, 0x77, 0x72, 0x69, 0x74, 0x65, 0x73, 0x5f, 0x64, 0x6f, 0x6e, 0x65, 0x5f, 0x67, 0x72, 0x61,
  1896  	0x63, 0x65, 0x5f, 0x70, 0x65, 0x72, 0x69, 0x6f, 0x64, 0x18, 0x06, 0x20, 0x01, 0x28, 0x0b, 0x32,
  1897  	0x19, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75,
  1898  	0x66, 0x2e, 0x44, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x15, 0x77, 0x72, 0x69, 0x74,
  1899  	0x65, 0x73, 0x44, 0x6f, 0x6e, 0x65, 0x47, 0x72, 0x61, 0x63, 0x65, 0x50, 0x65, 0x72, 0x69, 0x6f,
  1900  	0x64, 0x42, 0x0f, 0x0a, 0x0d, 0x63, 0x6f, 0x6e, 0x73, 0x75, 0x6d, 0x65, 0x72, 0x5f, 0x6d, 0x6f,
  1901  	0x64, 0x65, 0x42, 0x09, 0x0a, 0x07, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x22, 0x7c, 0x0a,
  1902  	0x1d, 0x52, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x50, 0x61, 0x63, 0x6b, 0x65, 0x74, 0x73, 0x43,
  1903  	0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x1e,
  1904  	0x0a, 0x09, 0x68, 0x65, 0x61, 0x72, 0x74, 0x62, 0x65, 0x61, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28,
  1905  	0x08, 0x48, 0x00, 0x52, 0x09, 0x68, 0x65, 0x61, 0x72, 0x74, 0x62, 0x65, 0x61, 0x74, 0x12, 0x30,
  1906  	0x0a, 0x13, 0x77, 0x72, 0x69, 0x74, 0x65, 0x73, 0x5f, 0x64, 0x6f, 0x6e, 0x65, 0x5f, 0x72, 0x65,
  1907  	0x71, 0x75, 0x65, 0x73, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x08, 0x48, 0x00, 0x52, 0x11, 0x77,
  1908  	0x72, 0x69, 0x74, 0x65, 0x73, 0x44, 0x6f, 0x6e, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
  1909  	0x42, 0x09, 0x0a, 0x07, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x22, 0xb5, 0x01, 0x0a, 0x16,
  1910  	0x52, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x50, 0x61, 0x63, 0x6b, 0x65, 0x74, 0x73, 0x52, 0x65,
  1911  	0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x3a, 0x0a, 0x06, 0x70, 0x61, 0x63, 0x6b, 0x65, 0x74,
  1912  	0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x20, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e,
  1913  	0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2e, 0x76,
  1914  	0x31, 0x2e, 0x50, 0x61, 0x63, 0x6b, 0x65, 0x74, 0x48, 0x00, 0x52, 0x06, 0x70, 0x61, 0x63, 0x6b,
  1915  	0x65, 0x74, 0x12, 0x53, 0x0a, 0x07, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x18, 0x03, 0x20,
  1916  	0x01, 0x28, 0x0b, 0x32, 0x37, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f,
  1917  	0x75, 0x64, 0x2e, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2e, 0x76, 0x31, 0x2e, 0x52,
  1918  	0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x50, 0x61, 0x63, 0x6b, 0x65, 0x74, 0x73, 0x43, 0x6f, 0x6e,
  1919  	0x74, 0x72, 0x6f, 0x6c, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x48, 0x00, 0x52, 0x07,
  1920  	0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x42, 0x0a, 0x0a, 0x08, 0x72, 0x65, 0x73, 0x70, 0x6f,
  1921  	0x6e, 0x73, 0x65, 0x22, 0x0b, 0x0a, 0x09, 0x45, 0x61, 0x67, 0x65, 0x72, 0x4d, 0x6f, 0x64, 0x65,
  1922  	0x22, 0x97, 0x01, 0x0a, 0x0e, 0x43, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65, 0x64, 0x4d,
  1923  	0x6f, 0x64, 0x65, 0x12, 0x38, 0x0a, 0x17, 0x73, 0x74, 0x61, 0x72, 0x74, 0x69, 0x6e, 0x67, 0x5f,
  1924  	0x6c, 0x6f, 0x67, 0x69, 0x63, 0x61, 0x6c, 0x5f, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x18, 0x01,
  1925  	0x20, 0x01, 0x28, 0x09, 0x48, 0x00, 0x52, 0x15, 0x73, 0x74, 0x61, 0x72, 0x74, 0x69, 0x6e, 0x67,
  1926  	0x4c, 0x6f, 0x67, 0x69, 0x63, 0x61, 0x6c, 0x4f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x12, 0x38, 0x0a,
  1927  	0x18, 0x66, 0x61, 0x6c, 0x6c, 0x62, 0x61, 0x63, 0x6b, 0x5f, 0x73, 0x74, 0x61, 0x72, 0x74, 0x69,
  1928  	0x6e, 0x67, 0x5f, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52,
  1929  	0x16, 0x66, 0x61, 0x6c, 0x6c, 0x62, 0x61, 0x63, 0x6b, 0x53, 0x74, 0x61, 0x72, 0x74, 0x69, 0x6e,
  1930  	0x67, 0x4f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x42, 0x11, 0x0a, 0x0f, 0x73, 0x74, 0x61, 0x72, 0x74,
  1931  	0x69, 0x6e, 0x67, 0x5f, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x22, 0x27, 0x0a, 0x0d, 0x43, 0x6f,
  1932  	0x6d, 0x6d, 0x69, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x16, 0x0a, 0x06, 0x6f,
  1933  	0x66, 0x66, 0x73, 0x65, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x06, 0x6f, 0x66, 0x66,
  1934  	0x73, 0x65, 0x74, 0x2a, 0x55, 0x0a, 0x09, 0x4c, 0x65, 0x61, 0x73, 0x65, 0x54, 0x79, 0x70, 0x65,
  1935  	0x12, 0x1a, 0x0a, 0x16, 0x4c, 0x45, 0x41, 0x53, 0x45, 0x5f, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x55,
  1936  	0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45, 0x44, 0x10, 0x00, 0x12, 0x15, 0x0a, 0x11,
  1937  	0x4c, 0x45, 0x41, 0x53, 0x45, 0x5f, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x52, 0x45, 0x41, 0x44, 0x45,
  1938  	0x52, 0x10, 0x01, 0x12, 0x15, 0x0a, 0x11, 0x4c, 0x45, 0x41, 0x53, 0x45, 0x5f, 0x54, 0x59, 0x50,
  1939  	0x45, 0x5f, 0x57, 0x52, 0x49, 0x54, 0x45, 0x52, 0x10, 0x02, 0x32, 0xe3, 0x07, 0x0a, 0x10, 0x53,
  1940  	0x74, 0x72, 0x65, 0x61, 0x6d, 0x69, 0x6e, 0x67, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12,
  1941  	0x70, 0x0a, 0x0b, 0x53, 0x65, 0x6e, 0x64, 0x50, 0x61, 0x63, 0x6b, 0x65, 0x74, 0x73, 0x12, 0x2c,
  1942  	0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x76, 0x69,
  1943  	0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x65, 0x6e, 0x64, 0x50, 0x61,
  1944  	0x63, 0x6b, 0x65, 0x74, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x2d, 0x2e, 0x67,
  1945  	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x76, 0x69, 0x73, 0x69,
  1946  	0x6f, 0x6e, 0x61, 0x69, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x65, 0x6e, 0x64, 0x50, 0x61, 0x63, 0x6b,
  1947  	0x65, 0x74, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x28, 0x01, 0x30,
  1948  	0x01, 0x12, 0x79, 0x0a, 0x0e, 0x52, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x50, 0x61, 0x63, 0x6b,
  1949  	0x65, 0x74, 0x73, 0x12, 0x2f, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f,
  1950  	0x75, 0x64, 0x2e, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2e, 0x76, 0x31, 0x2e, 0x52,
  1951  	0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x50, 0x61, 0x63, 0x6b, 0x65, 0x74, 0x73, 0x52, 0x65, 0x71,
  1952  	0x75, 0x65, 0x73, 0x74, 0x1a, 0x30, 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, 0x2e,
  1954  	0x52, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x50, 0x61, 0x63, 0x6b, 0x65, 0x74, 0x73, 0x52, 0x65,
  1955  	0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x28, 0x01, 0x30, 0x01, 0x12, 0x76, 0x0a, 0x0d,
  1956  	0x52, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x73, 0x12, 0x2e, 0x2e,
  1957  	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x76, 0x69, 0x73,
  1958  	0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2e, 0x76, 0x31, 0x2e, 0x52, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65,
  1959  	0x45, 0x76, 0x65, 0x6e, 0x74, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x2f, 0x2e,
  1960  	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x76, 0x69, 0x73,
  1961  	0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2e, 0x76, 0x31, 0x2e, 0x52, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65,
  1962  	0x45, 0x76, 0x65, 0x6e, 0x74, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00,
  1963  	0x28, 0x01, 0x30, 0x01, 0x12, 0xaf, 0x01, 0x0a, 0x0c, 0x41, 0x63, 0x71, 0x75, 0x69, 0x72, 0x65,
  1964  	0x4c, 0x65, 0x61, 0x73, 0x65, 0x12, 0x2d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63,
  1965  	0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2e, 0x76, 0x31,
  1966  	0x2e, 0x41, 0x63, 0x71, 0x75, 0x69, 0x72, 0x65, 0x4c, 0x65, 0x61, 0x73, 0x65, 0x52, 0x65, 0x71,
  1967  	0x75, 0x65, 0x73, 0x74, 0x1a, 0x1f, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c,
  1968  	0x6f, 0x75, 0x64, 0x2e, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2e, 0x76, 0x31, 0x2e,
  1969  	0x4c, 0x65, 0x61, 0x73, 0x65, 0x22, 0x4f, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x49, 0x22, 0x44, 0x2f,
  1970  	0x76, 0x31, 0x2f, 0x7b, 0x73, 0x65, 0x72, 0x69, 0x65, 0x73, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65,
  1971  	0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f,
  1972  	0x2a, 0x2f, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x73, 0x2f, 0x2a, 0x2f, 0x73, 0x65, 0x72,
  1973  	0x69, 0x65, 0x73, 0x2f, 0x2a, 0x7d, 0x3a, 0x61, 0x63, 0x71, 0x75, 0x69, 0x72, 0x65, 0x4c, 0x65,
  1974  	0x61, 0x73, 0x65, 0x3a, 0x01, 0x2a, 0x12, 0xa9, 0x01, 0x0a, 0x0a, 0x52, 0x65, 0x6e, 0x65, 0x77,
  1975  	0x4c, 0x65, 0x61, 0x73, 0x65, 0x12, 0x2b, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63,
  1976  	0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2e, 0x76, 0x31,
  1977  	0x2e, 0x52, 0x65, 0x6e, 0x65, 0x77, 0x4c, 0x65, 0x61, 0x73, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65,
  1978  	0x73, 0x74, 0x1a, 0x1f, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75,
  1979  	0x64, 0x2e, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2e, 0x76, 0x31, 0x2e, 0x4c, 0x65,
  1980  	0x61, 0x73, 0x65, 0x22, 0x4d, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x47, 0x22, 0x42, 0x2f, 0x76, 0x31,
  1981  	0x2f, 0x7b, 0x73, 0x65, 0x72, 0x69, 0x65, 0x73, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74,
  1982  	0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f,
  1983  	0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x73, 0x2f, 0x2a, 0x2f, 0x73, 0x65, 0x72, 0x69, 0x65,
  1984  	0x73, 0x2f, 0x2a, 0x7d, 0x3a, 0x72, 0x65, 0x6e, 0x65, 0x77, 0x4c, 0x65, 0x61, 0x73, 0x65, 0x3a,
  1985  	0x01, 0x2a, 0x12, 0xbe, 0x01, 0x0a, 0x0c, 0x52, 0x65, 0x6c, 0x65, 0x61, 0x73, 0x65, 0x4c, 0x65,
  1986  	0x61, 0x73, 0x65, 0x12, 0x2d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f,
  1987  	0x75, 0x64, 0x2e, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2e, 0x76, 0x31, 0x2e, 0x52,
  1988  	0x65, 0x6c, 0x65, 0x61, 0x73, 0x65, 0x4c, 0x65, 0x61, 0x73, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65,
  1989  	0x73, 0x74, 0x1a, 0x2e, 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, 0x2e, 0x52, 0x65,
  1991  	0x6c, 0x65, 0x61, 0x73, 0x65, 0x4c, 0x65, 0x61, 0x73, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e,
  1992  	0x73, 0x65, 0x22, 0x4f, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x49, 0x22, 0x44, 0x2f, 0x76, 0x31, 0x2f,
  1993  	0x7b, 0x73, 0x65, 0x72, 0x69, 0x65, 0x73, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73,
  1994  	0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x63,
  1995  	0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x73, 0x2f, 0x2a, 0x2f, 0x73, 0x65, 0x72, 0x69, 0x65, 0x73,
  1996  	0x2f, 0x2a, 0x7d, 0x3a, 0x72, 0x65, 0x6c, 0x65, 0x61, 0x73, 0x65, 0x4c, 0x65, 0x61, 0x73, 0x65,
  1997  	0x3a, 0x01, 0x2a, 0x1a, 0x4b, 0xca, 0x41, 0x17, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69,
  1998  	0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0xd2,
  1999  	0x41, 0x2e, 0x68, 0x74, 0x74, 0x70, 0x73, 0x3a, 0x2f, 0x2f, 0x77, 0x77, 0x77, 0x2e, 0x67, 0x6f,
  2000  	0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x61, 0x75, 0x74,
  2001  	0x68, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2d, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d,
  2002  	0x42, 0xcd, 0x01, 0x0a, 0x1c, 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e,
  2003  	0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69, 0x2e, 0x76,
  2004  	0x31, 0x42, 0x15, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x69, 0x6e, 0x67, 0x53, 0x65, 0x72, 0x76,
  2005  	0x69, 0x63, 0x65, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x5a, 0x40, 0x67, 0x6f, 0x6f, 0x67,
  2006  	0x6c, 0x65, 0x2e, 0x67, 0x6f, 0x6c, 0x61, 0x6e, 0x67, 0x2e, 0x6f, 0x72, 0x67, 0x2f, 0x67, 0x65,
  2007  	0x6e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69,
  2008  	0x73, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69,
  2009  	0x2f, 0x76, 0x31, 0x3b, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x61, 0x69, 0xaa, 0x02, 0x18, 0x47,
  2010  	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x43, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x56, 0x69, 0x73, 0x69,
  2011  	0x6f, 0x6e, 0x41, 0x49, 0x2e, 0x56, 0x31, 0xca, 0x02, 0x18, 0x47, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
  2012  	0x5c, 0x43, 0x6c, 0x6f, 0x75, 0x64, 0x5c, 0x56, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x41, 0x49, 0x5c,
  2013  	0x56, 0x31, 0xea, 0x02, 0x1b, 0x47, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x3a, 0x3a, 0x43, 0x6c, 0x6f,
  2014  	0x75, 0x64, 0x3a, 0x3a, 0x56, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x41, 0x49, 0x3a, 0x3a, 0x56, 0x31,
  2015  	0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
  2016  }
  2017  
  2018  var (
  2019  	file_google_cloud_visionai_v1_streaming_service_proto_rawDescOnce sync.Once
  2020  	file_google_cloud_visionai_v1_streaming_service_proto_rawDescData = file_google_cloud_visionai_v1_streaming_service_proto_rawDesc
  2021  )
  2022  
  2023  func file_google_cloud_visionai_v1_streaming_service_proto_rawDescGZIP() []byte {
  2024  	file_google_cloud_visionai_v1_streaming_service_proto_rawDescOnce.Do(func() {
  2025  		file_google_cloud_visionai_v1_streaming_service_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_cloud_visionai_v1_streaming_service_proto_rawDescData)
  2026  	})
  2027  	return file_google_cloud_visionai_v1_streaming_service_proto_rawDescData
  2028  }
  2029  
  2030  var file_google_cloud_visionai_v1_streaming_service_proto_enumTypes = make([]protoimpl.EnumInfo, 1)
  2031  var file_google_cloud_visionai_v1_streaming_service_proto_msgTypes = make([]protoimpl.MessageInfo, 20)
  2032  var file_google_cloud_visionai_v1_streaming_service_proto_goTypes = []interface{}{
  2033  	(LeaseType)(0),                             // 0: google.cloud.visionai.v1.LeaseType
  2034  	(*ReceiveEventsRequest)(nil),               // 1: google.cloud.visionai.v1.ReceiveEventsRequest
  2035  	(*EventUpdate)(nil),                        // 2: google.cloud.visionai.v1.EventUpdate
  2036  	(*ReceiveEventsControlResponse)(nil),       // 3: google.cloud.visionai.v1.ReceiveEventsControlResponse
  2037  	(*ReceiveEventsResponse)(nil),              // 4: google.cloud.visionai.v1.ReceiveEventsResponse
  2038  	(*Lease)(nil),                              // 5: google.cloud.visionai.v1.Lease
  2039  	(*AcquireLeaseRequest)(nil),                // 6: google.cloud.visionai.v1.AcquireLeaseRequest
  2040  	(*RenewLeaseRequest)(nil),                  // 7: google.cloud.visionai.v1.RenewLeaseRequest
  2041  	(*ReleaseLeaseRequest)(nil),                // 8: google.cloud.visionai.v1.ReleaseLeaseRequest
  2042  	(*ReleaseLeaseResponse)(nil),               // 9: google.cloud.visionai.v1.ReleaseLeaseResponse
  2043  	(*RequestMetadata)(nil),                    // 10: google.cloud.visionai.v1.RequestMetadata
  2044  	(*SendPacketsRequest)(nil),                 // 11: google.cloud.visionai.v1.SendPacketsRequest
  2045  	(*SendPacketsResponse)(nil),                // 12: google.cloud.visionai.v1.SendPacketsResponse
  2046  	(*ReceivePacketsRequest)(nil),              // 13: google.cloud.visionai.v1.ReceivePacketsRequest
  2047  	(*ReceivePacketsControlResponse)(nil),      // 14: google.cloud.visionai.v1.ReceivePacketsControlResponse
  2048  	(*ReceivePacketsResponse)(nil),             // 15: google.cloud.visionai.v1.ReceivePacketsResponse
  2049  	(*EagerMode)(nil),                          // 16: google.cloud.visionai.v1.EagerMode
  2050  	(*ControlledMode)(nil),                     // 17: google.cloud.visionai.v1.ControlledMode
  2051  	(*CommitRequest)(nil),                      // 18: google.cloud.visionai.v1.CommitRequest
  2052  	(*ReceiveEventsRequest_SetupRequest)(nil),  // 19: google.cloud.visionai.v1.ReceiveEventsRequest.SetupRequest
  2053  	(*ReceivePacketsRequest_SetupRequest)(nil), // 20: google.cloud.visionai.v1.ReceivePacketsRequest.SetupRequest
  2054  	(*timestamppb.Timestamp)(nil),              // 21: google.protobuf.Timestamp
  2055  	(*durationpb.Duration)(nil),                // 22: google.protobuf.Duration
  2056  	(*Packet)(nil),                             // 23: google.cloud.visionai.v1.Packet
  2057  }
  2058  var file_google_cloud_visionai_v1_streaming_service_proto_depIdxs = []int32{
  2059  	19, // 0: google.cloud.visionai.v1.ReceiveEventsRequest.setup_request:type_name -> google.cloud.visionai.v1.ReceiveEventsRequest.SetupRequest
  2060  	18, // 1: google.cloud.visionai.v1.ReceiveEventsRequest.commit_request:type_name -> google.cloud.visionai.v1.CommitRequest
  2061  	21, // 2: google.cloud.visionai.v1.EventUpdate.update_time:type_name -> google.protobuf.Timestamp
  2062  	2,  // 3: google.cloud.visionai.v1.ReceiveEventsResponse.event_update:type_name -> google.cloud.visionai.v1.EventUpdate
  2063  	3,  // 4: google.cloud.visionai.v1.ReceiveEventsResponse.control:type_name -> google.cloud.visionai.v1.ReceiveEventsControlResponse
  2064  	21, // 5: google.cloud.visionai.v1.Lease.expire_time:type_name -> google.protobuf.Timestamp
  2065  	0,  // 6: google.cloud.visionai.v1.Lease.lease_type:type_name -> google.cloud.visionai.v1.LeaseType
  2066  	22, // 7: google.cloud.visionai.v1.AcquireLeaseRequest.term:type_name -> google.protobuf.Duration
  2067  	0,  // 8: google.cloud.visionai.v1.AcquireLeaseRequest.lease_type:type_name -> google.cloud.visionai.v1.LeaseType
  2068  	22, // 9: google.cloud.visionai.v1.RenewLeaseRequest.term:type_name -> google.protobuf.Duration
  2069  	22, // 10: google.cloud.visionai.v1.RequestMetadata.lease_term:type_name -> google.protobuf.Duration
  2070  	23, // 11: google.cloud.visionai.v1.SendPacketsRequest.packet:type_name -> google.cloud.visionai.v1.Packet
  2071  	10, // 12: google.cloud.visionai.v1.SendPacketsRequest.metadata:type_name -> google.cloud.visionai.v1.RequestMetadata
  2072  	20, // 13: google.cloud.visionai.v1.ReceivePacketsRequest.setup_request:type_name -> google.cloud.visionai.v1.ReceivePacketsRequest.SetupRequest
  2073  	18, // 14: google.cloud.visionai.v1.ReceivePacketsRequest.commit_request:type_name -> google.cloud.visionai.v1.CommitRequest
  2074  	23, // 15: google.cloud.visionai.v1.ReceivePacketsResponse.packet:type_name -> google.cloud.visionai.v1.Packet
  2075  	14, // 16: google.cloud.visionai.v1.ReceivePacketsResponse.control:type_name -> google.cloud.visionai.v1.ReceivePacketsControlResponse
  2076  	17, // 17: google.cloud.visionai.v1.ReceiveEventsRequest.SetupRequest.controlled_mode:type_name -> google.cloud.visionai.v1.ControlledMode
  2077  	22, // 18: google.cloud.visionai.v1.ReceiveEventsRequest.SetupRequest.heartbeat_interval:type_name -> google.protobuf.Duration
  2078  	22, // 19: google.cloud.visionai.v1.ReceiveEventsRequest.SetupRequest.writes_done_grace_period:type_name -> google.protobuf.Duration
  2079  	16, // 20: google.cloud.visionai.v1.ReceivePacketsRequest.SetupRequest.eager_receive_mode:type_name -> google.cloud.visionai.v1.EagerMode
  2080  	17, // 21: google.cloud.visionai.v1.ReceivePacketsRequest.SetupRequest.controlled_receive_mode:type_name -> google.cloud.visionai.v1.ControlledMode
  2081  	10, // 22: google.cloud.visionai.v1.ReceivePacketsRequest.SetupRequest.metadata:type_name -> google.cloud.visionai.v1.RequestMetadata
  2082  	22, // 23: google.cloud.visionai.v1.ReceivePacketsRequest.SetupRequest.heartbeat_interval:type_name -> google.protobuf.Duration
  2083  	22, // 24: google.cloud.visionai.v1.ReceivePacketsRequest.SetupRequest.writes_done_grace_period:type_name -> google.protobuf.Duration
  2084  	11, // 25: google.cloud.visionai.v1.StreamingService.SendPackets:input_type -> google.cloud.visionai.v1.SendPacketsRequest
  2085  	13, // 26: google.cloud.visionai.v1.StreamingService.ReceivePackets:input_type -> google.cloud.visionai.v1.ReceivePacketsRequest
  2086  	1,  // 27: google.cloud.visionai.v1.StreamingService.ReceiveEvents:input_type -> google.cloud.visionai.v1.ReceiveEventsRequest
  2087  	6,  // 28: google.cloud.visionai.v1.StreamingService.AcquireLease:input_type -> google.cloud.visionai.v1.AcquireLeaseRequest
  2088  	7,  // 29: google.cloud.visionai.v1.StreamingService.RenewLease:input_type -> google.cloud.visionai.v1.RenewLeaseRequest
  2089  	8,  // 30: google.cloud.visionai.v1.StreamingService.ReleaseLease:input_type -> google.cloud.visionai.v1.ReleaseLeaseRequest
  2090  	12, // 31: google.cloud.visionai.v1.StreamingService.SendPackets:output_type -> google.cloud.visionai.v1.SendPacketsResponse
  2091  	15, // 32: google.cloud.visionai.v1.StreamingService.ReceivePackets:output_type -> google.cloud.visionai.v1.ReceivePacketsResponse
  2092  	4,  // 33: google.cloud.visionai.v1.StreamingService.ReceiveEvents:output_type -> google.cloud.visionai.v1.ReceiveEventsResponse
  2093  	5,  // 34: google.cloud.visionai.v1.StreamingService.AcquireLease:output_type -> google.cloud.visionai.v1.Lease
  2094  	5,  // 35: google.cloud.visionai.v1.StreamingService.RenewLease:output_type -> google.cloud.visionai.v1.Lease
  2095  	9,  // 36: google.cloud.visionai.v1.StreamingService.ReleaseLease:output_type -> google.cloud.visionai.v1.ReleaseLeaseResponse
  2096  	31, // [31:37] is the sub-list for method output_type
  2097  	25, // [25:31] is the sub-list for method input_type
  2098  	25, // [25:25] is the sub-list for extension type_name
  2099  	25, // [25:25] is the sub-list for extension extendee
  2100  	0,  // [0:25] is the sub-list for field type_name
  2101  }
  2102  
  2103  func init() { file_google_cloud_visionai_v1_streaming_service_proto_init() }
  2104  func file_google_cloud_visionai_v1_streaming_service_proto_init() {
  2105  	if File_google_cloud_visionai_v1_streaming_service_proto != nil {
  2106  		return
  2107  	}
  2108  	file_google_cloud_visionai_v1_streaming_resources_proto_init()
  2109  	if !protoimpl.UnsafeEnabled {
  2110  		file_google_cloud_visionai_v1_streaming_service_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
  2111  			switch v := v.(*ReceiveEventsRequest); i {
  2112  			case 0:
  2113  				return &v.state
  2114  			case 1:
  2115  				return &v.sizeCache
  2116  			case 2:
  2117  				return &v.unknownFields
  2118  			default:
  2119  				return nil
  2120  			}
  2121  		}
  2122  		file_google_cloud_visionai_v1_streaming_service_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
  2123  			switch v := v.(*EventUpdate); i {
  2124  			case 0:
  2125  				return &v.state
  2126  			case 1:
  2127  				return &v.sizeCache
  2128  			case 2:
  2129  				return &v.unknownFields
  2130  			default:
  2131  				return nil
  2132  			}
  2133  		}
  2134  		file_google_cloud_visionai_v1_streaming_service_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
  2135  			switch v := v.(*ReceiveEventsControlResponse); i {
  2136  			case 0:
  2137  				return &v.state
  2138  			case 1:
  2139  				return &v.sizeCache
  2140  			case 2:
  2141  				return &v.unknownFields
  2142  			default:
  2143  				return nil
  2144  			}
  2145  		}
  2146  		file_google_cloud_visionai_v1_streaming_service_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
  2147  			switch v := v.(*ReceiveEventsResponse); i {
  2148  			case 0:
  2149  				return &v.state
  2150  			case 1:
  2151  				return &v.sizeCache
  2152  			case 2:
  2153  				return &v.unknownFields
  2154  			default:
  2155  				return nil
  2156  			}
  2157  		}
  2158  		file_google_cloud_visionai_v1_streaming_service_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
  2159  			switch v := v.(*Lease); i {
  2160  			case 0:
  2161  				return &v.state
  2162  			case 1:
  2163  				return &v.sizeCache
  2164  			case 2:
  2165  				return &v.unknownFields
  2166  			default:
  2167  				return nil
  2168  			}
  2169  		}
  2170  		file_google_cloud_visionai_v1_streaming_service_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
  2171  			switch v := v.(*AcquireLeaseRequest); i {
  2172  			case 0:
  2173  				return &v.state
  2174  			case 1:
  2175  				return &v.sizeCache
  2176  			case 2:
  2177  				return &v.unknownFields
  2178  			default:
  2179  				return nil
  2180  			}
  2181  		}
  2182  		file_google_cloud_visionai_v1_streaming_service_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
  2183  			switch v := v.(*RenewLeaseRequest); i {
  2184  			case 0:
  2185  				return &v.state
  2186  			case 1:
  2187  				return &v.sizeCache
  2188  			case 2:
  2189  				return &v.unknownFields
  2190  			default:
  2191  				return nil
  2192  			}
  2193  		}
  2194  		file_google_cloud_visionai_v1_streaming_service_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
  2195  			switch v := v.(*ReleaseLeaseRequest); i {
  2196  			case 0:
  2197  				return &v.state
  2198  			case 1:
  2199  				return &v.sizeCache
  2200  			case 2:
  2201  				return &v.unknownFields
  2202  			default:
  2203  				return nil
  2204  			}
  2205  		}
  2206  		file_google_cloud_visionai_v1_streaming_service_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
  2207  			switch v := v.(*ReleaseLeaseResponse); i {
  2208  			case 0:
  2209  				return &v.state
  2210  			case 1:
  2211  				return &v.sizeCache
  2212  			case 2:
  2213  				return &v.unknownFields
  2214  			default:
  2215  				return nil
  2216  			}
  2217  		}
  2218  		file_google_cloud_visionai_v1_streaming_service_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} {
  2219  			switch v := v.(*RequestMetadata); i {
  2220  			case 0:
  2221  				return &v.state
  2222  			case 1:
  2223  				return &v.sizeCache
  2224  			case 2:
  2225  				return &v.unknownFields
  2226  			default:
  2227  				return nil
  2228  			}
  2229  		}
  2230  		file_google_cloud_visionai_v1_streaming_service_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} {
  2231  			switch v := v.(*SendPacketsRequest); i {
  2232  			case 0:
  2233  				return &v.state
  2234  			case 1:
  2235  				return &v.sizeCache
  2236  			case 2:
  2237  				return &v.unknownFields
  2238  			default:
  2239  				return nil
  2240  			}
  2241  		}
  2242  		file_google_cloud_visionai_v1_streaming_service_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} {
  2243  			switch v := v.(*SendPacketsResponse); i {
  2244  			case 0:
  2245  				return &v.state
  2246  			case 1:
  2247  				return &v.sizeCache
  2248  			case 2:
  2249  				return &v.unknownFields
  2250  			default:
  2251  				return nil
  2252  			}
  2253  		}
  2254  		file_google_cloud_visionai_v1_streaming_service_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} {
  2255  			switch v := v.(*ReceivePacketsRequest); i {
  2256  			case 0:
  2257  				return &v.state
  2258  			case 1:
  2259  				return &v.sizeCache
  2260  			case 2:
  2261  				return &v.unknownFields
  2262  			default:
  2263  				return nil
  2264  			}
  2265  		}
  2266  		file_google_cloud_visionai_v1_streaming_service_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} {
  2267  			switch v := v.(*ReceivePacketsControlResponse); i {
  2268  			case 0:
  2269  				return &v.state
  2270  			case 1:
  2271  				return &v.sizeCache
  2272  			case 2:
  2273  				return &v.unknownFields
  2274  			default:
  2275  				return nil
  2276  			}
  2277  		}
  2278  		file_google_cloud_visionai_v1_streaming_service_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} {
  2279  			switch v := v.(*ReceivePacketsResponse); i {
  2280  			case 0:
  2281  				return &v.state
  2282  			case 1:
  2283  				return &v.sizeCache
  2284  			case 2:
  2285  				return &v.unknownFields
  2286  			default:
  2287  				return nil
  2288  			}
  2289  		}
  2290  		file_google_cloud_visionai_v1_streaming_service_proto_msgTypes[15].Exporter = func(v interface{}, i int) interface{} {
  2291  			switch v := v.(*EagerMode); i {
  2292  			case 0:
  2293  				return &v.state
  2294  			case 1:
  2295  				return &v.sizeCache
  2296  			case 2:
  2297  				return &v.unknownFields
  2298  			default:
  2299  				return nil
  2300  			}
  2301  		}
  2302  		file_google_cloud_visionai_v1_streaming_service_proto_msgTypes[16].Exporter = func(v interface{}, i int) interface{} {
  2303  			switch v := v.(*ControlledMode); i {
  2304  			case 0:
  2305  				return &v.state
  2306  			case 1:
  2307  				return &v.sizeCache
  2308  			case 2:
  2309  				return &v.unknownFields
  2310  			default:
  2311  				return nil
  2312  			}
  2313  		}
  2314  		file_google_cloud_visionai_v1_streaming_service_proto_msgTypes[17].Exporter = func(v interface{}, i int) interface{} {
  2315  			switch v := v.(*CommitRequest); i {
  2316  			case 0:
  2317  				return &v.state
  2318  			case 1:
  2319  				return &v.sizeCache
  2320  			case 2:
  2321  				return &v.unknownFields
  2322  			default:
  2323  				return nil
  2324  			}
  2325  		}
  2326  		file_google_cloud_visionai_v1_streaming_service_proto_msgTypes[18].Exporter = func(v interface{}, i int) interface{} {
  2327  			switch v := v.(*ReceiveEventsRequest_SetupRequest); i {
  2328  			case 0:
  2329  				return &v.state
  2330  			case 1:
  2331  				return &v.sizeCache
  2332  			case 2:
  2333  				return &v.unknownFields
  2334  			default:
  2335  				return nil
  2336  			}
  2337  		}
  2338  		file_google_cloud_visionai_v1_streaming_service_proto_msgTypes[19].Exporter = func(v interface{}, i int) interface{} {
  2339  			switch v := v.(*ReceivePacketsRequest_SetupRequest); i {
  2340  			case 0:
  2341  				return &v.state
  2342  			case 1:
  2343  				return &v.sizeCache
  2344  			case 2:
  2345  				return &v.unknownFields
  2346  			default:
  2347  				return nil
  2348  			}
  2349  		}
  2350  	}
  2351  	file_google_cloud_visionai_v1_streaming_service_proto_msgTypes[0].OneofWrappers = []interface{}{
  2352  		(*ReceiveEventsRequest_SetupRequest_)(nil),
  2353  		(*ReceiveEventsRequest_CommitRequest)(nil),
  2354  	}
  2355  	file_google_cloud_visionai_v1_streaming_service_proto_msgTypes[2].OneofWrappers = []interface{}{
  2356  		(*ReceiveEventsControlResponse_Heartbeat)(nil),
  2357  		(*ReceiveEventsControlResponse_WritesDoneRequest)(nil),
  2358  	}
  2359  	file_google_cloud_visionai_v1_streaming_service_proto_msgTypes[3].OneofWrappers = []interface{}{
  2360  		(*ReceiveEventsResponse_EventUpdate)(nil),
  2361  		(*ReceiveEventsResponse_Control)(nil),
  2362  	}
  2363  	file_google_cloud_visionai_v1_streaming_service_proto_msgTypes[10].OneofWrappers = []interface{}{
  2364  		(*SendPacketsRequest_Packet)(nil),
  2365  		(*SendPacketsRequest_Metadata)(nil),
  2366  	}
  2367  	file_google_cloud_visionai_v1_streaming_service_proto_msgTypes[12].OneofWrappers = []interface{}{
  2368  		(*ReceivePacketsRequest_SetupRequest_)(nil),
  2369  		(*ReceivePacketsRequest_CommitRequest)(nil),
  2370  	}
  2371  	file_google_cloud_visionai_v1_streaming_service_proto_msgTypes[13].OneofWrappers = []interface{}{
  2372  		(*ReceivePacketsControlResponse_Heartbeat)(nil),
  2373  		(*ReceivePacketsControlResponse_WritesDoneRequest)(nil),
  2374  	}
  2375  	file_google_cloud_visionai_v1_streaming_service_proto_msgTypes[14].OneofWrappers = []interface{}{
  2376  		(*ReceivePacketsResponse_Packet)(nil),
  2377  		(*ReceivePacketsResponse_Control)(nil),
  2378  	}
  2379  	file_google_cloud_visionai_v1_streaming_service_proto_msgTypes[16].OneofWrappers = []interface{}{
  2380  		(*ControlledMode_StartingLogicalOffset)(nil),
  2381  	}
  2382  	file_google_cloud_visionai_v1_streaming_service_proto_msgTypes[19].OneofWrappers = []interface{}{
  2383  		(*ReceivePacketsRequest_SetupRequest_EagerReceiveMode)(nil),
  2384  		(*ReceivePacketsRequest_SetupRequest_ControlledReceiveMode)(nil),
  2385  	}
  2386  	type x struct{}
  2387  	out := protoimpl.TypeBuilder{
  2388  		File: protoimpl.DescBuilder{
  2389  			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
  2390  			RawDescriptor: file_google_cloud_visionai_v1_streaming_service_proto_rawDesc,
  2391  			NumEnums:      1,
  2392  			NumMessages:   20,
  2393  			NumExtensions: 0,
  2394  			NumServices:   1,
  2395  		},
  2396  		GoTypes:           file_google_cloud_visionai_v1_streaming_service_proto_goTypes,
  2397  		DependencyIndexes: file_google_cloud_visionai_v1_streaming_service_proto_depIdxs,
  2398  		EnumInfos:         file_google_cloud_visionai_v1_streaming_service_proto_enumTypes,
  2399  		MessageInfos:      file_google_cloud_visionai_v1_streaming_service_proto_msgTypes,
  2400  	}.Build()
  2401  	File_google_cloud_visionai_v1_streaming_service_proto = out.File
  2402  	file_google_cloud_visionai_v1_streaming_service_proto_rawDesc = nil
  2403  	file_google_cloud_visionai_v1_streaming_service_proto_goTypes = nil
  2404  	file_google_cloud_visionai_v1_streaming_service_proto_depIdxs = nil
  2405  }
  2406  
  2407  // Reference imports to suppress errors if they are not otherwise used.
  2408  var _ context.Context
  2409  var _ grpc.ClientConnInterface
  2410  
  2411  // This is a compile-time assertion to ensure that this generated file
  2412  // is compatible with the grpc package it is being compiled against.
  2413  const _ = grpc.SupportPackageIsVersion6
  2414  
  2415  // StreamingServiceClient is the client API for StreamingService service.
  2416  //
  2417  // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
  2418  type StreamingServiceClient interface {
  2419  	// Send packets to the series.
  2420  	SendPackets(ctx context.Context, opts ...grpc.CallOption) (StreamingService_SendPacketsClient, error)
  2421  	// Receive packets from the series.
  2422  	ReceivePackets(ctx context.Context, opts ...grpc.CallOption) (StreamingService_ReceivePacketsClient, error)
  2423  	// Receive events given the stream name.
  2424  	ReceiveEvents(ctx context.Context, opts ...grpc.CallOption) (StreamingService_ReceiveEventsClient, error)
  2425  	// AcquireLease acquires a lease.
  2426  	AcquireLease(ctx context.Context, in *AcquireLeaseRequest, opts ...grpc.CallOption) (*Lease, error)
  2427  	// RenewLease renews a lease.
  2428  	RenewLease(ctx context.Context, in *RenewLeaseRequest, opts ...grpc.CallOption) (*Lease, error)
  2429  	// RleaseLease releases a lease.
  2430  	ReleaseLease(ctx context.Context, in *ReleaseLeaseRequest, opts ...grpc.CallOption) (*ReleaseLeaseResponse, error)
  2431  }
  2432  
  2433  type streamingServiceClient struct {
  2434  	cc grpc.ClientConnInterface
  2435  }
  2436  
  2437  func NewStreamingServiceClient(cc grpc.ClientConnInterface) StreamingServiceClient {
  2438  	return &streamingServiceClient{cc}
  2439  }
  2440  
  2441  func (c *streamingServiceClient) SendPackets(ctx context.Context, opts ...grpc.CallOption) (StreamingService_SendPacketsClient, error) {
  2442  	stream, err := c.cc.NewStream(ctx, &_StreamingService_serviceDesc.Streams[0], "/google.cloud.visionai.v1.StreamingService/SendPackets", opts...)
  2443  	if err != nil {
  2444  		return nil, err
  2445  	}
  2446  	x := &streamingServiceSendPacketsClient{stream}
  2447  	return x, nil
  2448  }
  2449  
  2450  type StreamingService_SendPacketsClient interface {
  2451  	Send(*SendPacketsRequest) error
  2452  	Recv() (*SendPacketsResponse, error)
  2453  	grpc.ClientStream
  2454  }
  2455  
  2456  type streamingServiceSendPacketsClient struct {
  2457  	grpc.ClientStream
  2458  }
  2459  
  2460  func (x *streamingServiceSendPacketsClient) Send(m *SendPacketsRequest) error {
  2461  	return x.ClientStream.SendMsg(m)
  2462  }
  2463  
  2464  func (x *streamingServiceSendPacketsClient) Recv() (*SendPacketsResponse, error) {
  2465  	m := new(SendPacketsResponse)
  2466  	if err := x.ClientStream.RecvMsg(m); err != nil {
  2467  		return nil, err
  2468  	}
  2469  	return m, nil
  2470  }
  2471  
  2472  func (c *streamingServiceClient) ReceivePackets(ctx context.Context, opts ...grpc.CallOption) (StreamingService_ReceivePacketsClient, error) {
  2473  	stream, err := c.cc.NewStream(ctx, &_StreamingService_serviceDesc.Streams[1], "/google.cloud.visionai.v1.StreamingService/ReceivePackets", opts...)
  2474  	if err != nil {
  2475  		return nil, err
  2476  	}
  2477  	x := &streamingServiceReceivePacketsClient{stream}
  2478  	return x, nil
  2479  }
  2480  
  2481  type StreamingService_ReceivePacketsClient interface {
  2482  	Send(*ReceivePacketsRequest) error
  2483  	Recv() (*ReceivePacketsResponse, error)
  2484  	grpc.ClientStream
  2485  }
  2486  
  2487  type streamingServiceReceivePacketsClient struct {
  2488  	grpc.ClientStream
  2489  }
  2490  
  2491  func (x *streamingServiceReceivePacketsClient) Send(m *ReceivePacketsRequest) error {
  2492  	return x.ClientStream.SendMsg(m)
  2493  }
  2494  
  2495  func (x *streamingServiceReceivePacketsClient) Recv() (*ReceivePacketsResponse, error) {
  2496  	m := new(ReceivePacketsResponse)
  2497  	if err := x.ClientStream.RecvMsg(m); err != nil {
  2498  		return nil, err
  2499  	}
  2500  	return m, nil
  2501  }
  2502  
  2503  func (c *streamingServiceClient) ReceiveEvents(ctx context.Context, opts ...grpc.CallOption) (StreamingService_ReceiveEventsClient, error) {
  2504  	stream, err := c.cc.NewStream(ctx, &_StreamingService_serviceDesc.Streams[2], "/google.cloud.visionai.v1.StreamingService/ReceiveEvents", opts...)
  2505  	if err != nil {
  2506  		return nil, err
  2507  	}
  2508  	x := &streamingServiceReceiveEventsClient{stream}
  2509  	return x, nil
  2510  }
  2511  
  2512  type StreamingService_ReceiveEventsClient interface {
  2513  	Send(*ReceiveEventsRequest) error
  2514  	Recv() (*ReceiveEventsResponse, error)
  2515  	grpc.ClientStream
  2516  }
  2517  
  2518  type streamingServiceReceiveEventsClient struct {
  2519  	grpc.ClientStream
  2520  }
  2521  
  2522  func (x *streamingServiceReceiveEventsClient) Send(m *ReceiveEventsRequest) error {
  2523  	return x.ClientStream.SendMsg(m)
  2524  }
  2525  
  2526  func (x *streamingServiceReceiveEventsClient) Recv() (*ReceiveEventsResponse, error) {
  2527  	m := new(ReceiveEventsResponse)
  2528  	if err := x.ClientStream.RecvMsg(m); err != nil {
  2529  		return nil, err
  2530  	}
  2531  	return m, nil
  2532  }
  2533  
  2534  func (c *streamingServiceClient) AcquireLease(ctx context.Context, in *AcquireLeaseRequest, opts ...grpc.CallOption) (*Lease, error) {
  2535  	out := new(Lease)
  2536  	err := c.cc.Invoke(ctx, "/google.cloud.visionai.v1.StreamingService/AcquireLease", in, out, opts...)
  2537  	if err != nil {
  2538  		return nil, err
  2539  	}
  2540  	return out, nil
  2541  }
  2542  
  2543  func (c *streamingServiceClient) RenewLease(ctx context.Context, in *RenewLeaseRequest, opts ...grpc.CallOption) (*Lease, error) {
  2544  	out := new(Lease)
  2545  	err := c.cc.Invoke(ctx, "/google.cloud.visionai.v1.StreamingService/RenewLease", in, out, opts...)
  2546  	if err != nil {
  2547  		return nil, err
  2548  	}
  2549  	return out, nil
  2550  }
  2551  
  2552  func (c *streamingServiceClient) ReleaseLease(ctx context.Context, in *ReleaseLeaseRequest, opts ...grpc.CallOption) (*ReleaseLeaseResponse, error) {
  2553  	out := new(ReleaseLeaseResponse)
  2554  	err := c.cc.Invoke(ctx, "/google.cloud.visionai.v1.StreamingService/ReleaseLease", in, out, opts...)
  2555  	if err != nil {
  2556  		return nil, err
  2557  	}
  2558  	return out, nil
  2559  }
  2560  
  2561  // StreamingServiceServer is the server API for StreamingService service.
  2562  type StreamingServiceServer interface {
  2563  	// Send packets to the series.
  2564  	SendPackets(StreamingService_SendPacketsServer) error
  2565  	// Receive packets from the series.
  2566  	ReceivePackets(StreamingService_ReceivePacketsServer) error
  2567  	// Receive events given the stream name.
  2568  	ReceiveEvents(StreamingService_ReceiveEventsServer) error
  2569  	// AcquireLease acquires a lease.
  2570  	AcquireLease(context.Context, *AcquireLeaseRequest) (*Lease, error)
  2571  	// RenewLease renews a lease.
  2572  	RenewLease(context.Context, *RenewLeaseRequest) (*Lease, error)
  2573  	// RleaseLease releases a lease.
  2574  	ReleaseLease(context.Context, *ReleaseLeaseRequest) (*ReleaseLeaseResponse, error)
  2575  }
  2576  
  2577  // UnimplementedStreamingServiceServer can be embedded to have forward compatible implementations.
  2578  type UnimplementedStreamingServiceServer struct {
  2579  }
  2580  
  2581  func (*UnimplementedStreamingServiceServer) SendPackets(StreamingService_SendPacketsServer) error {
  2582  	return status.Errorf(codes.Unimplemented, "method SendPackets not implemented")
  2583  }
  2584  func (*UnimplementedStreamingServiceServer) ReceivePackets(StreamingService_ReceivePacketsServer) error {
  2585  	return status.Errorf(codes.Unimplemented, "method ReceivePackets not implemented")
  2586  }
  2587  func (*UnimplementedStreamingServiceServer) ReceiveEvents(StreamingService_ReceiveEventsServer) error {
  2588  	return status.Errorf(codes.Unimplemented, "method ReceiveEvents not implemented")
  2589  }
  2590  func (*UnimplementedStreamingServiceServer) AcquireLease(context.Context, *AcquireLeaseRequest) (*Lease, error) {
  2591  	return nil, status.Errorf(codes.Unimplemented, "method AcquireLease not implemented")
  2592  }
  2593  func (*UnimplementedStreamingServiceServer) RenewLease(context.Context, *RenewLeaseRequest) (*Lease, error) {
  2594  	return nil, status.Errorf(codes.Unimplemented, "method RenewLease not implemented")
  2595  }
  2596  func (*UnimplementedStreamingServiceServer) ReleaseLease(context.Context, *ReleaseLeaseRequest) (*ReleaseLeaseResponse, error) {
  2597  	return nil, status.Errorf(codes.Unimplemented, "method ReleaseLease not implemented")
  2598  }
  2599  
  2600  func RegisterStreamingServiceServer(s *grpc.Server, srv StreamingServiceServer) {
  2601  	s.RegisterService(&_StreamingService_serviceDesc, srv)
  2602  }
  2603  
  2604  func _StreamingService_SendPackets_Handler(srv interface{}, stream grpc.ServerStream) error {
  2605  	return srv.(StreamingServiceServer).SendPackets(&streamingServiceSendPacketsServer{stream})
  2606  }
  2607  
  2608  type StreamingService_SendPacketsServer interface {
  2609  	Send(*SendPacketsResponse) error
  2610  	Recv() (*SendPacketsRequest, error)
  2611  	grpc.ServerStream
  2612  }
  2613  
  2614  type streamingServiceSendPacketsServer struct {
  2615  	grpc.ServerStream
  2616  }
  2617  
  2618  func (x *streamingServiceSendPacketsServer) Send(m *SendPacketsResponse) error {
  2619  	return x.ServerStream.SendMsg(m)
  2620  }
  2621  
  2622  func (x *streamingServiceSendPacketsServer) Recv() (*SendPacketsRequest, error) {
  2623  	m := new(SendPacketsRequest)
  2624  	if err := x.ServerStream.RecvMsg(m); err != nil {
  2625  		return nil, err
  2626  	}
  2627  	return m, nil
  2628  }
  2629  
  2630  func _StreamingService_ReceivePackets_Handler(srv interface{}, stream grpc.ServerStream) error {
  2631  	return srv.(StreamingServiceServer).ReceivePackets(&streamingServiceReceivePacketsServer{stream})
  2632  }
  2633  
  2634  type StreamingService_ReceivePacketsServer interface {
  2635  	Send(*ReceivePacketsResponse) error
  2636  	Recv() (*ReceivePacketsRequest, error)
  2637  	grpc.ServerStream
  2638  }
  2639  
  2640  type streamingServiceReceivePacketsServer struct {
  2641  	grpc.ServerStream
  2642  }
  2643  
  2644  func (x *streamingServiceReceivePacketsServer) Send(m *ReceivePacketsResponse) error {
  2645  	return x.ServerStream.SendMsg(m)
  2646  }
  2647  
  2648  func (x *streamingServiceReceivePacketsServer) Recv() (*ReceivePacketsRequest, error) {
  2649  	m := new(ReceivePacketsRequest)
  2650  	if err := x.ServerStream.RecvMsg(m); err != nil {
  2651  		return nil, err
  2652  	}
  2653  	return m, nil
  2654  }
  2655  
  2656  func _StreamingService_ReceiveEvents_Handler(srv interface{}, stream grpc.ServerStream) error {
  2657  	return srv.(StreamingServiceServer).ReceiveEvents(&streamingServiceReceiveEventsServer{stream})
  2658  }
  2659  
  2660  type StreamingService_ReceiveEventsServer interface {
  2661  	Send(*ReceiveEventsResponse) error
  2662  	Recv() (*ReceiveEventsRequest, error)
  2663  	grpc.ServerStream
  2664  }
  2665  
  2666  type streamingServiceReceiveEventsServer struct {
  2667  	grpc.ServerStream
  2668  }
  2669  
  2670  func (x *streamingServiceReceiveEventsServer) Send(m *ReceiveEventsResponse) error {
  2671  	return x.ServerStream.SendMsg(m)
  2672  }
  2673  
  2674  func (x *streamingServiceReceiveEventsServer) Recv() (*ReceiveEventsRequest, error) {
  2675  	m := new(ReceiveEventsRequest)
  2676  	if err := x.ServerStream.RecvMsg(m); err != nil {
  2677  		return nil, err
  2678  	}
  2679  	return m, nil
  2680  }
  2681  
  2682  func _StreamingService_AcquireLease_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2683  	in := new(AcquireLeaseRequest)
  2684  	if err := dec(in); err != nil {
  2685  		return nil, err
  2686  	}
  2687  	if interceptor == nil {
  2688  		return srv.(StreamingServiceServer).AcquireLease(ctx, in)
  2689  	}
  2690  	info := &grpc.UnaryServerInfo{
  2691  		Server:     srv,
  2692  		FullMethod: "/google.cloud.visionai.v1.StreamingService/AcquireLease",
  2693  	}
  2694  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2695  		return srv.(StreamingServiceServer).AcquireLease(ctx, req.(*AcquireLeaseRequest))
  2696  	}
  2697  	return interceptor(ctx, in, info, handler)
  2698  }
  2699  
  2700  func _StreamingService_RenewLease_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2701  	in := new(RenewLeaseRequest)
  2702  	if err := dec(in); err != nil {
  2703  		return nil, err
  2704  	}
  2705  	if interceptor == nil {
  2706  		return srv.(StreamingServiceServer).RenewLease(ctx, in)
  2707  	}
  2708  	info := &grpc.UnaryServerInfo{
  2709  		Server:     srv,
  2710  		FullMethod: "/google.cloud.visionai.v1.StreamingService/RenewLease",
  2711  	}
  2712  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2713  		return srv.(StreamingServiceServer).RenewLease(ctx, req.(*RenewLeaseRequest))
  2714  	}
  2715  	return interceptor(ctx, in, info, handler)
  2716  }
  2717  
  2718  func _StreamingService_ReleaseLease_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2719  	in := new(ReleaseLeaseRequest)
  2720  	if err := dec(in); err != nil {
  2721  		return nil, err
  2722  	}
  2723  	if interceptor == nil {
  2724  		return srv.(StreamingServiceServer).ReleaseLease(ctx, in)
  2725  	}
  2726  	info := &grpc.UnaryServerInfo{
  2727  		Server:     srv,
  2728  		FullMethod: "/google.cloud.visionai.v1.StreamingService/ReleaseLease",
  2729  	}
  2730  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2731  		return srv.(StreamingServiceServer).ReleaseLease(ctx, req.(*ReleaseLeaseRequest))
  2732  	}
  2733  	return interceptor(ctx, in, info, handler)
  2734  }
  2735  
  2736  var _StreamingService_serviceDesc = grpc.ServiceDesc{
  2737  	ServiceName: "google.cloud.visionai.v1.StreamingService",
  2738  	HandlerType: (*StreamingServiceServer)(nil),
  2739  	Methods: []grpc.MethodDesc{
  2740  		{
  2741  			MethodName: "AcquireLease",
  2742  			Handler:    _StreamingService_AcquireLease_Handler,
  2743  		},
  2744  		{
  2745  			MethodName: "RenewLease",
  2746  			Handler:    _StreamingService_RenewLease_Handler,
  2747  		},
  2748  		{
  2749  			MethodName: "ReleaseLease",
  2750  			Handler:    _StreamingService_ReleaseLease_Handler,
  2751  		},
  2752  	},
  2753  	Streams: []grpc.StreamDesc{
  2754  		{
  2755  			StreamName:    "SendPackets",
  2756  			Handler:       _StreamingService_SendPackets_Handler,
  2757  			ServerStreams: true,
  2758  			ClientStreams: true,
  2759  		},
  2760  		{
  2761  			StreamName:    "ReceivePackets",
  2762  			Handler:       _StreamingService_ReceivePackets_Handler,
  2763  			ServerStreams: true,
  2764  			ClientStreams: true,
  2765  		},
  2766  		{
  2767  			StreamName:    "ReceiveEvents",
  2768  			Handler:       _StreamingService_ReceiveEvents_Handler,
  2769  			ServerStreams: true,
  2770  			ClientStreams: true,
  2771  		},
  2772  	},
  2773  	Metadata: "google/cloud/visionai/v1/streaming_service.proto",
  2774  }
  2775  

View as plain text