var File_google_partner_aistreams_v1alpha1_aistreams_proto protoreflect.FileDescriptor
func RegisterAIStreamsServer(s *grpc.Server, srv AIStreamsServer)
AIStreamsClient is the client API for AIStreams service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
type AIStreamsClient interface {
// Lists Clusters in a given project and location.
ListClusters(ctx context.Context, in *ListClustersRequest, opts ...grpc.CallOption) (*ListClustersResponse, error)
// Gets details of a single Cluster.
GetCluster(ctx context.Context, in *GetClusterRequest, opts ...grpc.CallOption) (*Cluster, error)
// Creates a new Cluster in a given project and location.
CreateCluster(ctx context.Context, in *CreateClusterRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
// Updates the parameters of a single Cluster.
UpdateCluster(ctx context.Context, in *UpdateClusterRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
// Deletes a single Cluster.
DeleteCluster(ctx context.Context, in *DeleteClusterRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
// Lists Streams in a given project, location and cluster.
ListStreams(ctx context.Context, in *ListStreamsRequest, opts ...grpc.CallOption) (*ListStreamsResponse, error)
// Gets details of a single Stream.
GetStream(ctx context.Context, in *GetStreamRequest, opts ...grpc.CallOption) (*Stream, error)
// Creates a new Stream in a given project and location.
CreateStream(ctx context.Context, in *CreateStreamRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
// Updates the parameters of a single Stream.
UpdateStream(ctx context.Context, in *UpdateStreamRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
// Deletes a single Stream.
DeleteStream(ctx context.Context, in *DeleteStreamRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
}
func NewAIStreamsClient(cc grpc.ClientConnInterface) AIStreamsClient
AIStreamsServer is the server API for AIStreams service.
type AIStreamsServer interface {
// Lists Clusters in a given project and location.
ListClusters(context.Context, *ListClustersRequest) (*ListClustersResponse, error)
// Gets details of a single Cluster.
GetCluster(context.Context, *GetClusterRequest) (*Cluster, error)
// Creates a new Cluster in a given project and location.
CreateCluster(context.Context, *CreateClusterRequest) (*longrunningpb.Operation, error)
// Updates the parameters of a single Cluster.
UpdateCluster(context.Context, *UpdateClusterRequest) (*longrunningpb.Operation, error)
// Deletes a single Cluster.
DeleteCluster(context.Context, *DeleteClusterRequest) (*longrunningpb.Operation, error)
// Lists Streams in a given project, location and cluster.
ListStreams(context.Context, *ListStreamsRequest) (*ListStreamsResponse, error)
// Gets details of a single Stream.
GetStream(context.Context, *GetStreamRequest) (*Stream, error)
// Creates a new Stream in a given project and location.
CreateStream(context.Context, *CreateStreamRequest) (*longrunningpb.Operation, error)
// Updates the parameters of a single Stream.
UpdateStream(context.Context, *UpdateStreamRequest) (*longrunningpb.Operation, error)
// Deletes a single Stream.
DeleteStream(context.Context, *DeleteStreamRequest) (*longrunningpb.Operation, error)
}
Cluster resource.
type Cluster struct {
// The name of the cluster. The format of cluster is:
// projects/<projectid>/locations/<locationid>/clusters/<clusterid>.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// Output only. The time at which this cluster was created.
CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
// Output only. The time at which this cluster was updated.
UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
// Labels with user-defined metadata.
Labels map[string]string `protobuf:"bytes,4,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
// Output only. The certificate for creating the secure connection between the
// client and the AI Streams data plane.
Certificate string `protobuf:"bytes,5,opt,name=certificate,proto3" json:"certificate,omitempty"`
// Output only. The endpoint of the data plane cluster.
ServiceEndpoint string `protobuf:"bytes,6,opt,name=service_endpoint,json=serviceEndpoint,proto3" json:"service_endpoint,omitempty"`
// contains filtered or unexported fields
}
func (*Cluster) Descriptor() ([]byte, []int)
Deprecated: Use Cluster.ProtoReflect.Descriptor instead.
func (x *Cluster) GetCertificate() string
func (x *Cluster) GetCreateTime() *timestamppb.Timestamp
func (x *Cluster) GetLabels() map[string]string
func (x *Cluster) GetName() string
func (x *Cluster) GetServiceEndpoint() string
func (x *Cluster) GetUpdateTime() *timestamppb.Timestamp
func (*Cluster) ProtoMessage()
func (x *Cluster) ProtoReflect() protoreflect.Message
func (x *Cluster) Reset()
func (x *Cluster) String() string
Request message for 'CreateCluster'.
type CreateClusterRequest struct {
// Required. The parent that owns the collection of Clusters.
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// Required. The cluster identifier.
ClusterId string `protobuf:"bytes,2,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
// Required. The cluster resource to create.
Cluster *Cluster `protobuf:"bytes,3,opt,name=cluster,proto3" json:"cluster,omitempty"`
// Optional. An optional request ID to identify requests. Specify a unique
// request ID so that if you must retry your request, the server will know to
// ignore the request if it has already been completed. The server will
// guarantee that for at least 60 minutes since the first request.
//
// For example, consider a situation where you make an initial request and the
// request times out. If you make the request again with the same request ID,
// the server can check if original operation with the same request ID was
// received, and if so, will ignore the second request. This prevents clients
// from accidentally creating duplicate commitments.
//
// The request ID must be a valid UUID with the exception that zero UUID is
// not supported (00000000-0000-0000-0000-000000000000).
RequestId string `protobuf:"bytes,4,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
// contains filtered or unexported fields
}
func (*CreateClusterRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateClusterRequest.ProtoReflect.Descriptor instead.
func (x *CreateClusterRequest) GetCluster() *Cluster
func (x *CreateClusterRequest) GetClusterId() string
func (x *CreateClusterRequest) GetParent() string
func (x *CreateClusterRequest) GetRequestId() string
func (*CreateClusterRequest) ProtoMessage()
func (x *CreateClusterRequest) ProtoReflect() protoreflect.Message
func (x *CreateClusterRequest) Reset()
func (x *CreateClusterRequest) String() string
Request message for 'CreateStream'.
type CreateStreamRequest struct {
// Required. The parent that owns the collection of streams.
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// Required. The stream identifier.
StreamId string `protobuf:"bytes,2,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
// Required. The stream to create.
Stream *Stream `protobuf:"bytes,3,opt,name=stream,proto3" json:"stream,omitempty"`
// Optional. An optional request ID to identify requests. Specify a unique
// request ID so that if you must retry your request, the server will know to
// ignore the request if it has already been completed. The server will
// guarantee that for at least 60 minutes since the first request.
//
// For example, consider a situation where you make an initial request and t
// he request times out. If you make the request again with the same request
// ID, the server can check if original operation with the same request ID
// was received, and if so, will ignore the second request. This prevents
// clients from accidentally creating duplicate commitments.
//
// The request ID must be a valid UUID with the exception that zero UUID is
// not supported (00000000-0000-0000-0000-000000000000).
RequestId string `protobuf:"bytes,4,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
// contains filtered or unexported fields
}
func (*CreateStreamRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateStreamRequest.ProtoReflect.Descriptor instead.
func (x *CreateStreamRequest) GetParent() string
func (x *CreateStreamRequest) GetRequestId() string
func (x *CreateStreamRequest) GetStream() *Stream
func (x *CreateStreamRequest) GetStreamId() string
func (*CreateStreamRequest) ProtoMessage()
func (x *CreateStreamRequest) ProtoReflect() protoreflect.Message
func (x *CreateStreamRequest) Reset()
func (x *CreateStreamRequest) String() string
Request message for 'DeleteCluster'.
type DeleteClusterRequest struct {
// Required. The name of cluster to delete.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// Optional. An optional request ID to identify requests. Specify a unique
// request ID so that if you must retry your request, the server will know to
// ignore the request if it has already been completed. The server will
// guarantee that for at least 60 minutes after the first request.
//
// For example, consider a situation where you make an initial request and the
// request times out. If you make the request again with the same request ID,
// the server can check if original operation with the same request ID was
// received, and if so, will ignore the second request. This prevents clients
// from accidentally creating duplicate commitments.
//
// The request ID must be a valid UUID with the exception that zero UUID is
// not supported (00000000-0000-0000-0000-000000000000).
RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
// contains filtered or unexported fields
}
func (*DeleteClusterRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteClusterRequest.ProtoReflect.Descriptor instead.
func (x *DeleteClusterRequest) GetName() string
func (x *DeleteClusterRequest) GetRequestId() string
func (*DeleteClusterRequest) ProtoMessage()
func (x *DeleteClusterRequest) ProtoReflect() protoreflect.Message
func (x *DeleteClusterRequest) Reset()
func (x *DeleteClusterRequest) String() string
Request message for 'DeleteStream'.
type DeleteStreamRequest struct {
// Required. The name of the stream.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// Optional. An optional request ID to identify requests. Specify a unique
// request ID so that if you must retry your request, the server will know to
// ignore the request if it has already been completed. The server will
// guarantee that for at least 60 minutes after the first request.
//
// For example, consider a situation where you make an initial request and t
// he request times out. If you make the request again with the same request
// ID, the server can check if original operation with the same request ID
// was received, and if so, will ignore the second request. This prevents
// clients from accidentally creating duplicate commitments.
//
// The request ID must be a valid UUID with the exception that zero UUID is
// not supported (00000000-0000-0000-0000-000000000000).
RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
// contains filtered or unexported fields
}
func (*DeleteStreamRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteStreamRequest.ProtoReflect.Descriptor instead.
func (x *DeleteStreamRequest) GetName() string
func (x *DeleteStreamRequest) GetRequestId() string
func (*DeleteStreamRequest) ProtoMessage()
func (x *DeleteStreamRequest) ProtoReflect() protoreflect.Message
func (x *DeleteStreamRequest) Reset()
func (x *DeleteStreamRequest) String() string
Request message for 'GetCluster'.
type GetClusterRequest struct {
// Required. The name of the Cluster resource to get.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*GetClusterRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetClusterRequest.ProtoReflect.Descriptor instead.
func (x *GetClusterRequest) GetName() string
func (*GetClusterRequest) ProtoMessage()
func (x *GetClusterRequest) ProtoReflect() protoreflect.Message
func (x *GetClusterRequest) Reset()
func (x *GetClusterRequest) String() string
Request message for 'GetStream'.
type GetStreamRequest struct {
// Required. The name of the stream.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*GetStreamRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetStreamRequest.ProtoReflect.Descriptor instead.
func (x *GetStreamRequest) GetName() string
func (*GetStreamRequest) ProtoMessage()
func (x *GetStreamRequest) ProtoReflect() protoreflect.Message
func (x *GetStreamRequest) Reset()
func (x *GetStreamRequest) String() string
Request message for 'ListClusters'.
type ListClustersRequest struct {
// Required. The parent that owns the collection of Clusters.
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// Maximum number of Clusters to return.
PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
// Page token received from a previous `ListClusters` call. Provide this to
// retrieve the subsequent page. When paginating, all other parameters
// provided to `ListClusters` must match the call that provided the page
// token.
PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
// Filter request.
Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
// Order by fields for the result.
OrderBy string `protobuf:"bytes,5,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
// contains filtered or unexported fields
}
func (*ListClustersRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListClustersRequest.ProtoReflect.Descriptor instead.
func (x *ListClustersRequest) GetFilter() string
func (x *ListClustersRequest) GetOrderBy() string
func (x *ListClustersRequest) GetPageSize() int32
func (x *ListClustersRequest) GetPageToken() string
func (x *ListClustersRequest) GetParent() string
func (*ListClustersRequest) ProtoMessage()
func (x *ListClustersRequest) ProtoReflect() protoreflect.Message
func (x *ListClustersRequest) Reset()
func (x *ListClustersRequest) String() string
Response message from 'ListClusters'.
type ListClustersResponse struct {
// List of clusters.
Clusters []*Cluster `protobuf:"bytes,1,rep,name=clusters,proto3" json:"clusters,omitempty"`
// A token, which can be sent as `page_token` to retrieve the next page.
// If this field is omitted, there are no subsequent pages.
NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
// Locations that could not be reached.
Unreachable []string `protobuf:"bytes,3,rep,name=unreachable,proto3" json:"unreachable,omitempty"`
// contains filtered or unexported fields
}
func (*ListClustersResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListClustersResponse.ProtoReflect.Descriptor instead.
func (x *ListClustersResponse) GetClusters() []*Cluster
func (x *ListClustersResponse) GetNextPageToken() string
func (x *ListClustersResponse) GetUnreachable() []string
func (*ListClustersResponse) ProtoMessage()
func (x *ListClustersResponse) ProtoReflect() protoreflect.Message
func (x *ListClustersResponse) Reset()
func (x *ListClustersResponse) String() string
Request message for 'ListStreams'.
type ListStreamsRequest struct {
// Required. The parent that owns the collection of the Streams.
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// Maximum number of Streams to return.
PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
// Page token received from a previous `ListStreams` call. Provide this to
// retrieve the subsequent page. When paginating, all other parameters
// provided to `ListClusters` must match the call that provided the page
// token.
PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
// Filter request.
Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
// Order by fields for the result.
OrderBy string `protobuf:"bytes,5,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
// contains filtered or unexported fields
}
func (*ListStreamsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListStreamsRequest.ProtoReflect.Descriptor instead.
func (x *ListStreamsRequest) GetFilter() string
func (x *ListStreamsRequest) GetOrderBy() string
func (x *ListStreamsRequest) GetPageSize() int32
func (x *ListStreamsRequest) GetPageToken() string
func (x *ListStreamsRequest) GetParent() string
func (*ListStreamsRequest) ProtoMessage()
func (x *ListStreamsRequest) ProtoReflect() protoreflect.Message
func (x *ListStreamsRequest) Reset()
func (x *ListStreamsRequest) String() string
Response message from 'ListStreams'.
type ListStreamsResponse struct {
// List of the streams.
Streams []*Stream `protobuf:"bytes,1,rep,name=streams,proto3" json:"streams,omitempty"`
// A token, which can be sent as `page_token` to retrieve the next page.
// If this field is omitted, there are no subsequent pages.
NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
// Locations that could not be reached.
Unreachable []string `protobuf:"bytes,3,rep,name=unreachable,proto3" json:"unreachable,omitempty"`
// contains filtered or unexported fields
}
func (*ListStreamsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListStreamsResponse.ProtoReflect.Descriptor instead.
func (x *ListStreamsResponse) GetNextPageToken() string
func (x *ListStreamsResponse) GetStreams() []*Stream
func (x *ListStreamsResponse) GetUnreachable() []string
func (*ListStreamsResponse) ProtoMessage()
func (x *ListStreamsResponse) ProtoReflect() protoreflect.Message
func (x *ListStreamsResponse) Reset()
func (x *ListStreamsResponse) String() string
Represents the metadata of the long-running operation.
type OperationMetadata struct {
// Output only. The time the operation was created.
CreateTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
// Output only. The time the operation finished running.
EndTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
// Output only. Server-defined resource path for the target of the operation.
Target string `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
// Output only. Name of the verb executed by the operation.
Verb string `protobuf:"bytes,4,opt,name=verb,proto3" json:"verb,omitempty"`
// Output only. Human-readable status of the operation, if any.
StatusMessage string `protobuf:"bytes,5,opt,name=status_message,json=statusMessage,proto3" json:"status_message,omitempty"`
// Output only. Identifies whether the user has requested cancellation
// of the operation. Operations that have successfully been cancelled
// have [Operation.error][] value with a
// [google.rpc.Status.code][google.rpc.Status.code] of 1, corresponding to
// `Code.CANCELLED`.
RequestedCancellation bool `protobuf:"varint,6,opt,name=requested_cancellation,json=requestedCancellation,proto3" json:"requested_cancellation,omitempty"`
// Output only. API version used to start the operation.
ApiVersion string `protobuf:"bytes,7,opt,name=api_version,json=apiVersion,proto3" json:"api_version,omitempty"`
// contains filtered or unexported fields
}
func (*OperationMetadata) Descriptor() ([]byte, []int)
Deprecated: Use OperationMetadata.ProtoReflect.Descriptor instead.
func (x *OperationMetadata) GetApiVersion() string
func (x *OperationMetadata) GetCreateTime() *timestamppb.Timestamp
func (x *OperationMetadata) GetEndTime() *timestamppb.Timestamp
func (x *OperationMetadata) GetRequestedCancellation() bool
func (x *OperationMetadata) GetStatusMessage() string
func (x *OperationMetadata) GetTarget() string
func (x *OperationMetadata) GetVerb() string
func (*OperationMetadata) ProtoMessage()
func (x *OperationMetadata) ProtoReflect() protoreflect.Message
func (x *OperationMetadata) Reset()
func (x *OperationMetadata) String() string
Stream resource.
type Stream struct {
// The name of the stream. The format for the full name is:
// projects/<projectid>/location/<locationid>/clusters/<clusterid>/streams/<streamid>.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// Output only. The time at which this Stream was created.
CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
// Output only. The time at which this Stream was updated.
UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
// The labels of the stream.
Labels map[string]string `protobuf:"bytes,4,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
// contains filtered or unexported fields
}
func (*Stream) Descriptor() ([]byte, []int)
Deprecated: Use Stream.ProtoReflect.Descriptor instead.
func (x *Stream) GetCreateTime() *timestamppb.Timestamp
func (x *Stream) GetLabels() map[string]string
func (x *Stream) GetName() string
func (x *Stream) GetUpdateTime() *timestamppb.Timestamp
func (*Stream) ProtoMessage()
func (x *Stream) ProtoReflect() protoreflect.Message
func (x *Stream) Reset()
func (x *Stream) String() string
UnimplementedAIStreamsServer can be embedded to have forward compatible implementations.
type UnimplementedAIStreamsServer struct {
}
func (*UnimplementedAIStreamsServer) CreateCluster(context.Context, *CreateClusterRequest) (*longrunningpb.Operation, error)
func (*UnimplementedAIStreamsServer) CreateStream(context.Context, *CreateStreamRequest) (*longrunningpb.Operation, error)
func (*UnimplementedAIStreamsServer) DeleteCluster(context.Context, *DeleteClusterRequest) (*longrunningpb.Operation, error)
func (*UnimplementedAIStreamsServer) DeleteStream(context.Context, *DeleteStreamRequest) (*longrunningpb.Operation, error)
func (*UnimplementedAIStreamsServer) GetCluster(context.Context, *GetClusterRequest) (*Cluster, error)
func (*UnimplementedAIStreamsServer) GetStream(context.Context, *GetStreamRequest) (*Stream, error)
func (*UnimplementedAIStreamsServer) ListClusters(context.Context, *ListClustersRequest) (*ListClustersResponse, error)
func (*UnimplementedAIStreamsServer) ListStreams(context.Context, *ListStreamsRequest) (*ListStreamsResponse, error)
func (*UnimplementedAIStreamsServer) UpdateCluster(context.Context, *UpdateClusterRequest) (*longrunningpb.Operation, error)
func (*UnimplementedAIStreamsServer) UpdateStream(context.Context, *UpdateStreamRequest) (*longrunningpb.Operation, error)
Request message for 'UpdateCluster'.
type UpdateClusterRequest struct {
// Required. Field mask is used to specify the fields to be overwritten in the
// Cluster resource by the update.
// The fields specified in the update_mask are relative to the resource, not
// the full request. A field will be overwritten if it is in the mask. If the
// user does not provide a mask then all fields will be overwritten.
UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,1,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
// Required. The Cluster resource to update.
Cluster *Cluster `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
// Optional. An optional request ID to identify requests. Specify a unique
// request ID so that if you must retry your request, the server will know to
// ignore the request if it has already been completed. The server will
// guarantee that for at least 60 minutes since the first request.
//
// For example, consider a situation where you make an initial request and the
// request times out. If you make the request again with the same request ID,
// the server can check if original operation with the same request ID was
// received, and if so, will ignore the second request. This prevents clients
// from accidentally creating duplicate commitments.
//
// The request ID must be a valid UUID with the exception that zero UUID is
// not supported (00000000-0000-0000-0000-000000000000).
RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
// contains filtered or unexported fields
}
func (*UpdateClusterRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateClusterRequest.ProtoReflect.Descriptor instead.
func (x *UpdateClusterRequest) GetCluster() *Cluster
func (x *UpdateClusterRequest) GetRequestId() string
func (x *UpdateClusterRequest) GetUpdateMask() *fieldmaskpb.FieldMask
func (*UpdateClusterRequest) ProtoMessage()
func (x *UpdateClusterRequest) ProtoReflect() protoreflect.Message
func (x *UpdateClusterRequest) Reset()
func (x *UpdateClusterRequest) String() string
Request message for 'UpdateStream'.
type UpdateStreamRequest struct {
// Required. Field mask is used to specify the fields to be overwritten in the
// Stream resource by the update.
// The fields specified in the update_mask are relative to the resource, not
// the full request. A field will be overwritten if it is in the mask. If the
// user does not provide a mask then all fields will be overwritten.
UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,1,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
// Required. The stream resource to update.
Stream *Stream `protobuf:"bytes,2,opt,name=stream,proto3" json:"stream,omitempty"`
// Optional. An optional request ID to identify requests. Specify a unique
// request ID so that if you must retry your request, the server will know to
// ignore the request if it has already been completed. The server will
// guarantee that for at least 60 minutes since the first request.
//
// For example, consider a situation where you make an initial request and t
// he request times out. If you make the request again with the same request
// ID, the server can check if original operation with the same request ID
// was received, and if so, will ignore the second request. This prevents
// clients from accidentally creating duplicate commitments.
//
// The request ID must be a valid UUID with the exception that zero UUID is
// not supported (00000000-0000-0000-0000-000000000000).
RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
// contains filtered or unexported fields
}
func (*UpdateStreamRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateStreamRequest.ProtoReflect.Descriptor instead.
func (x *UpdateStreamRequest) GetRequestId() string
func (x *UpdateStreamRequest) GetStream() *Stream
func (x *UpdateStreamRequest) GetUpdateMask() *fieldmaskpb.FieldMask
func (*UpdateStreamRequest) ProtoMessage()
func (x *UpdateStreamRequest) ProtoReflect() protoreflect.Message
func (x *UpdateStreamRequest) Reset()
func (x *UpdateStreamRequest) String() string