aistreams

package
v0.0.0-...-6982302 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 2, 2025 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_google_partner_aistreams_v1alpha1_aistreams_proto protoreflect.FileDescriptor

Functions

func RegisterAIStreamsServer 

func RegisterAIStreamsServer(s *grpc.Server, srv AIStreamsServer)

Types

type AIStreamsClient 

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)
}

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.

func NewAIStreamsClient 

func NewAIStreamsClient(cc grpc.ClientConnInterface) AIStreamsClient

type AIStreamsServer 

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)
}

AIStreamsServer is the server API for AIStreams service.

type Cluster 

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 `` /* 153-byte string literal not displayed */
	// 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
}

Cluster resource.

func (*Cluster) Descriptor deprecated 

func (*Cluster) Descriptor() ([]byte, []int)

Deprecated: Use Cluster.ProtoReflect.Descriptor instead.

func (*Cluster) GetCertificate 

func (x *Cluster) GetCertificate() string

func (*Cluster) GetCreateTime 

func (x *Cluster) GetCreateTime() *timestamppb.Timestamp

func (*Cluster) GetLabels 

func (x *Cluster) GetLabels() map[string]string

func (*Cluster) GetName 

func (x *Cluster) GetName() string

func (*Cluster) GetServiceEndpoint 

func (x *Cluster) GetServiceEndpoint() string

func (*Cluster) GetUpdateTime 

func (x *Cluster) GetUpdateTime() *timestamppb.Timestamp

func (*Cluster) ProtoMessage 

func (*Cluster) ProtoMessage()

func (*Cluster) ProtoReflect 

func (x *Cluster) ProtoReflect() protoreflect.Message

func (*Cluster) Reset 

func (x *Cluster) Reset()

func (*Cluster) String 

func (x *Cluster) String() string

type CreateClusterRequest 

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
}

Request message for 'CreateCluster'.

func (*CreateClusterRequest) Descriptor deprecated 

func (*CreateClusterRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateClusterRequest.ProtoReflect.Descriptor instead.

func (*CreateClusterRequest) GetCluster 

func (x *CreateClusterRequest) GetCluster() *Cluster

func (*CreateClusterRequest) GetClusterId 

func (x *CreateClusterRequest) GetClusterId() string

func (*CreateClusterRequest) GetParent 

func (x *CreateClusterRequest) GetParent() string

func (*CreateClusterRequest) GetRequestId 

func (x *CreateClusterRequest) GetRequestId() string

func (*CreateClusterRequest) ProtoMessage 

func (*CreateClusterRequest) ProtoMessage()

func (*CreateClusterRequest) ProtoReflect 

func (x *CreateClusterRequest) ProtoReflect() protoreflect.Message

func (*CreateClusterRequest) Reset 

func (x *CreateClusterRequest) Reset()

func (*CreateClusterRequest) String 

func (x *CreateClusterRequest) String() string

type CreateStreamRequest 

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
}

Request message for 'CreateStream'.

func (*CreateStreamRequest) Descriptor deprecated 

func (*CreateStreamRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateStreamRequest.ProtoReflect.Descriptor instead.

func (*CreateStreamRequest) GetParent 

func (x *CreateStreamRequest) GetParent() string

func (*CreateStreamRequest) GetRequestId 

func (x *CreateStreamRequest) GetRequestId() string

func (*CreateStreamRequest) GetStream 

func (x *CreateStreamRequest) GetStream() *Stream

func (*CreateStreamRequest) GetStreamId 

func (x *CreateStreamRequest) GetStreamId() string

func (*CreateStreamRequest) ProtoMessage 

func (*CreateStreamRequest) ProtoMessage()

func (*CreateStreamRequest) ProtoReflect 

func (x *CreateStreamRequest) ProtoReflect() protoreflect.Message

func (*CreateStreamRequest) Reset 

func (x *CreateStreamRequest) Reset()

func (*CreateStreamRequest) String 

func (x *CreateStreamRequest) String() string

type DeleteClusterRequest 

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
}

Request message for 'DeleteCluster'.

func (*DeleteClusterRequest) Descriptor deprecated 

func (*DeleteClusterRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteClusterRequest.ProtoReflect.Descriptor instead.

func (*DeleteClusterRequest) GetName 

func (x *DeleteClusterRequest) GetName() string

func (*DeleteClusterRequest) GetRequestId 

func (x *DeleteClusterRequest) GetRequestId() string

func (*DeleteClusterRequest) ProtoMessage 

func (*DeleteClusterRequest) ProtoMessage()

func (*DeleteClusterRequest) ProtoReflect 

func (x *DeleteClusterRequest) ProtoReflect() protoreflect.Message

func (*DeleteClusterRequest) Reset 

func (x *DeleteClusterRequest) Reset()

func (*DeleteClusterRequest) String 

func (x *DeleteClusterRequest) String() string

type DeleteStreamRequest 

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
}

Request message for 'DeleteStream'.

func (*DeleteStreamRequest) Descriptor deprecated 

func (*DeleteStreamRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteStreamRequest.ProtoReflect.Descriptor instead.

func (*DeleteStreamRequest) GetName 

func (x *DeleteStreamRequest) GetName() string

func (*DeleteStreamRequest) GetRequestId 

func (x *DeleteStreamRequest) GetRequestId() string

func (*DeleteStreamRequest) ProtoMessage 

func (*DeleteStreamRequest) ProtoMessage()

func (*DeleteStreamRequest) ProtoReflect 

func (x *DeleteStreamRequest) ProtoReflect() protoreflect.Message

func (*DeleteStreamRequest) Reset 

func (x *DeleteStreamRequest) Reset()

func (*DeleteStreamRequest) String 

func (x *DeleteStreamRequest) String() string

type GetClusterRequest 

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
}

Request message for 'GetCluster'.

func (*GetClusterRequest) Descriptor deprecated 

func (*GetClusterRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetClusterRequest.ProtoReflect.Descriptor instead.

func (*GetClusterRequest) GetName 

func (x *GetClusterRequest) GetName() string

func (*GetClusterRequest) ProtoMessage 

func (*GetClusterRequest) ProtoMessage()

func (*GetClusterRequest) ProtoReflect 

func (x *GetClusterRequest) ProtoReflect() protoreflect.Message

func (*GetClusterRequest) Reset 

func (x *GetClusterRequest) Reset()

func (*GetClusterRequest) String 

func (x *GetClusterRequest) String() string

type GetStreamRequest 

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
}

Request message for 'GetStream'.

func (*GetStreamRequest) Descriptor deprecated 

func (*GetStreamRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetStreamRequest.ProtoReflect.Descriptor instead.

func (*GetStreamRequest) GetName 

func (x *GetStreamRequest) GetName() string

func (*GetStreamRequest) ProtoMessage 

func (*GetStreamRequest) ProtoMessage()

func (*GetStreamRequest) ProtoReflect 

func (x *GetStreamRequest) ProtoReflect() protoreflect.Message

func (*GetStreamRequest) Reset 

func (x *GetStreamRequest) Reset()

func (*GetStreamRequest) String 

func (x *GetStreamRequest) String() string

type ListClustersRequest 

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
}

Request message for 'ListClusters'.

func (*ListClustersRequest) Descriptor deprecated 

func (*ListClustersRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListClustersRequest.ProtoReflect.Descriptor instead.

func (*ListClustersRequest) GetFilter 

func (x *ListClustersRequest) GetFilter() string

func (*ListClustersRequest) GetOrderBy 

func (x *ListClustersRequest) GetOrderBy() string

func (*ListClustersRequest) GetPageSize 

func (x *ListClustersRequest) GetPageSize() int32

func (*ListClustersRequest) GetPageToken 

func (x *ListClustersRequest) GetPageToken() string

func (*ListClustersRequest) GetParent 

func (x *ListClustersRequest) GetParent() string

func (*ListClustersRequest) ProtoMessage 

func (*ListClustersRequest) ProtoMessage()

func (*ListClustersRequest) ProtoReflect 

func (x *ListClustersRequest) ProtoReflect() protoreflect.Message

func (*ListClustersRequest) Reset 

func (x *ListClustersRequest) Reset()

func (*ListClustersRequest) String 

func (x *ListClustersRequest) String() string

type ListClustersResponse 

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
}

Response message from 'ListClusters'.

func (*ListClustersResponse) Descriptor deprecated 

func (*ListClustersResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListClustersResponse.ProtoReflect.Descriptor instead.

func (*ListClustersResponse) GetClusters 

func (x *ListClustersResponse) GetClusters() []*Cluster

func (*ListClustersResponse) GetNextPageToken 

func (x *ListClustersResponse) GetNextPageToken() string

func (*ListClustersResponse) GetUnreachable 

func (x *ListClustersResponse) GetUnreachable() []string

func (*ListClustersResponse) ProtoMessage 

func (*ListClustersResponse) ProtoMessage()

func (*ListClustersResponse) ProtoReflect 

func (x *ListClustersResponse) ProtoReflect() protoreflect.Message

func (*ListClustersResponse) Reset 

func (x *ListClustersResponse) Reset()

func (*ListClustersResponse) String 

func (x *ListClustersResponse) String() string

type ListStreamsRequest 

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
}

Request message for 'ListStreams'.

func (*ListStreamsRequest) Descriptor deprecated 

func (*ListStreamsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListStreamsRequest.ProtoReflect.Descriptor instead.

func (*ListStreamsRequest) GetFilter 

func (x *ListStreamsRequest) GetFilter() string

func (*ListStreamsRequest) GetOrderBy 

func (x *ListStreamsRequest) GetOrderBy() string

func (*ListStreamsRequest) GetPageSize 

func (x *ListStreamsRequest) GetPageSize() int32

func (*ListStreamsRequest) GetPageToken 

func (x *ListStreamsRequest) GetPageToken() string

func (*ListStreamsRequest) GetParent 

func (x *ListStreamsRequest) GetParent() string

func (*ListStreamsRequest) ProtoMessage 

func (*ListStreamsRequest) ProtoMessage()

func (*ListStreamsRequest) ProtoReflect 

func (x *ListStreamsRequest) ProtoReflect() protoreflect.Message

func (*ListStreamsRequest) Reset 

func (x *ListStreamsRequest) Reset()

func (*ListStreamsRequest) String 

func (x *ListStreamsRequest) String() string

type ListStreamsResponse 

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
}

Response message from 'ListStreams'.

func (*ListStreamsResponse) Descriptor deprecated 

func (*ListStreamsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListStreamsResponse.ProtoReflect.Descriptor instead.

func (*ListStreamsResponse) GetNextPageToken 

func (x *ListStreamsResponse) GetNextPageToken() string

func (*ListStreamsResponse) GetStreams 

func (x *ListStreamsResponse) GetStreams() []*Stream

func (*ListStreamsResponse) GetUnreachable 

func (x *ListStreamsResponse) GetUnreachable() []string

func (*ListStreamsResponse) ProtoMessage 

func (*ListStreamsResponse) ProtoMessage()

func (*ListStreamsResponse) ProtoReflect 

func (x *ListStreamsResponse) ProtoReflect() protoreflect.Message

func (*ListStreamsResponse) Reset 

func (x *ListStreamsResponse) Reset()

func (*ListStreamsResponse) String 

func (x *ListStreamsResponse) String() string

type OperationMetadata 

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
}

Represents the metadata of the long-running operation.

func (*OperationMetadata) Descriptor deprecated 

func (*OperationMetadata) Descriptor() ([]byte, []int)

Deprecated: Use OperationMetadata.ProtoReflect.Descriptor instead.

func (*OperationMetadata) GetApiVersion 

func (x *OperationMetadata) GetApiVersion() string

func (*OperationMetadata) GetCreateTime 

func (x *OperationMetadata) GetCreateTime() *timestamppb.Timestamp

func (*OperationMetadata) GetEndTime 

func (x *OperationMetadata) GetEndTime() *timestamppb.Timestamp

func (*OperationMetadata) GetRequestedCancellation 

func (x *OperationMetadata) GetRequestedCancellation() bool

func (*OperationMetadata) GetStatusMessage 

func (x *OperationMetadata) GetStatusMessage() string

func (*OperationMetadata) GetTarget 

func (x *OperationMetadata) GetTarget() string

func (*OperationMetadata) GetVerb 

func (x *OperationMetadata) GetVerb() string

func (*OperationMetadata) ProtoMessage 

func (*OperationMetadata) ProtoMessage()

func (*OperationMetadata) ProtoReflect 

func (x *OperationMetadata) ProtoReflect() protoreflect.Message

func (*OperationMetadata) Reset 

func (x *OperationMetadata) Reset()

func (*OperationMetadata) String 

func (x *OperationMetadata) String() string

type Stream 

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 `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

Stream resource.

func (*Stream) Descriptor deprecated 

func (*Stream) Descriptor() ([]byte, []int)

Deprecated: Use Stream.ProtoReflect.Descriptor instead.

func (*Stream) GetCreateTime 

func (x *Stream) GetCreateTime() *timestamppb.Timestamp

func (*Stream) GetLabels 

func (x *Stream) GetLabels() map[string]string

func (*Stream) GetName 

func (x *Stream) GetName() string

func (*Stream) GetUpdateTime 

func (x *Stream) GetUpdateTime() *timestamppb.Timestamp

func (*Stream) ProtoMessage 

func (*Stream) ProtoMessage()

func (*Stream) ProtoReflect 

func (x *Stream) ProtoReflect() protoreflect.Message

func (*Stream) Reset 

func (x *Stream) Reset()

func (*Stream) String 

func (x *Stream) String() string

type UnimplementedAIStreamsServer 

type UnimplementedAIStreamsServer struct {
}

UnimplementedAIStreamsServer can be embedded to have forward compatible implementations.

func (*UnimplementedAIStreamsServer) CreateCluster 

func (*UnimplementedAIStreamsServer) CreateCluster(context.Context, *CreateClusterRequest) (*longrunningpb.Operation, error)

func (*UnimplementedAIStreamsServer) CreateStream 

func (*UnimplementedAIStreamsServer) CreateStream(context.Context, *CreateStreamRequest) (*longrunningpb.Operation, error)

func (*UnimplementedAIStreamsServer) DeleteCluster 

func (*UnimplementedAIStreamsServer) DeleteCluster(context.Context, *DeleteClusterRequest) (*longrunningpb.Operation, error)

func (*UnimplementedAIStreamsServer) DeleteStream 

func (*UnimplementedAIStreamsServer) DeleteStream(context.Context, *DeleteStreamRequest) (*longrunningpb.Operation, error)

func (*UnimplementedAIStreamsServer) GetCluster 

func (*UnimplementedAIStreamsServer) GetCluster(context.Context, *GetClusterRequest) (*Cluster, error)

func (*UnimplementedAIStreamsServer) GetStream 

func (*UnimplementedAIStreamsServer) GetStream(context.Context, *GetStreamRequest) (*Stream, error)

func (*UnimplementedAIStreamsServer) ListClusters 

func (*UnimplementedAIStreamsServer) ListClusters(context.Context, *ListClustersRequest) (*ListClustersResponse, error)

func (*UnimplementedAIStreamsServer) ListStreams 

func (*UnimplementedAIStreamsServer) ListStreams(context.Context, *ListStreamsRequest) (*ListStreamsResponse, error)

func (*UnimplementedAIStreamsServer) UpdateCluster 

func (*UnimplementedAIStreamsServer) UpdateCluster(context.Context, *UpdateClusterRequest) (*longrunningpb.Operation, error)

func (*UnimplementedAIStreamsServer) UpdateStream 

func (*UnimplementedAIStreamsServer) UpdateStream(context.Context, *UpdateStreamRequest) (*longrunningpb.Operation, error)

type UpdateClusterRequest 

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
}

Request message for 'UpdateCluster'.

func (*UpdateClusterRequest) Descriptor deprecated 

func (*UpdateClusterRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateClusterRequest.ProtoReflect.Descriptor instead.

func (*UpdateClusterRequest) GetCluster 

func (x *UpdateClusterRequest) GetCluster() *Cluster

func (*UpdateClusterRequest) GetRequestId 

func (x *UpdateClusterRequest) GetRequestId() string

func (*UpdateClusterRequest) GetUpdateMask 

func (x *UpdateClusterRequest) GetUpdateMask() *fieldmaskpb.FieldMask

func (*UpdateClusterRequest) ProtoMessage 

func (*UpdateClusterRequest) ProtoMessage()

func (*UpdateClusterRequest) ProtoReflect 

func (x *UpdateClusterRequest) ProtoReflect() protoreflect.Message

func (*UpdateClusterRequest) Reset 

func (x *UpdateClusterRequest) Reset()

func (*UpdateClusterRequest) String 

func (x *UpdateClusterRequest) String() string

type UpdateStreamRequest 

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
}

Request message for 'UpdateStream'.

func (*UpdateStreamRequest) Descriptor deprecated 

func (*UpdateStreamRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateStreamRequest.ProtoReflect.Descriptor instead.

func (*UpdateStreamRequest) GetRequestId 

func (x *UpdateStreamRequest) GetRequestId() string

func (*UpdateStreamRequest) GetStream 

func (x *UpdateStreamRequest) GetStream() *Stream

func (*UpdateStreamRequest) GetUpdateMask 

func (x *UpdateStreamRequest) GetUpdateMask() *fieldmaskpb.FieldMask

func (*UpdateStreamRequest) ProtoMessage 

func (*UpdateStreamRequest) ProtoMessage()

func (*UpdateStreamRequest) ProtoReflect 

func (x *UpdateStreamRequest) ProtoReflect() protoreflect.Message

func (*UpdateStreamRequest) Reset 

func (x *UpdateStreamRequest) Reset()

func (*UpdateStreamRequest) String 

func (x *UpdateStreamRequest) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.