operatorservice

type AddOrUpdateRemoteClusterRequest struct {

	// Frontend Address is a cross cluster accessible address.
	FrontendAddress string `protobuf:"bytes,1,opt,name=frontend_address,json=frontendAddress,proto3" json:"frontend_address,omitempty"`
	// Flag to enable / disable the cross cluster connection.
	EnableRemoteClusterConnection bool `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

type AddOrUpdateRemoteClusterResponse struct {
	// contains filtered or unexported fields
}

type AddSearchAttributesRequest struct {

	// Mapping between search attribute name and its IndexedValueType.
	SearchAttributes map[string]v1.IndexedValueType `` /* 242-byte string literal not displayed */
	Namespace        string                         `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

type AddSearchAttributesResponse struct {
	// contains filtered or unexported fields
}

type ClusterMetadata struct {

	// Name of the cluster name.
	ClusterName string `protobuf:"bytes,1,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	// Id of the cluster.
	ClusterId string `protobuf:"bytes,2,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// Cluster accessible address.
	Address string `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"`
	// A unique failover version across all connected clusters.
	InitialFailoverVersion int64 `` /* 130-byte string literal not displayed */
	// History service shard number.
	HistoryShardCount int32 `protobuf:"varint,5,opt,name=history_shard_count,json=historyShardCount,proto3" json:"history_shard_count,omitempty"`
	// A flag to indicate if a connection is active.
	IsConnectionEnabled bool `protobuf:"varint,6,opt,name=is_connection_enabled,json=isConnectionEnabled,proto3" json:"is_connection_enabled,omitempty"`
	// contains filtered or unexported fields
}

type CreateOrUpdateNexusIncomingServiceRequest struct {
	Service *v11.IncomingService `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	// contains filtered or unexported fields
}

type CreateOrUpdateNexusIncomingServiceResponse struct {

	// Data post acceptance. Can be used to issue additional updates to this record.
	Service *v11.IncomingService `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	// contains filtered or unexported fields
}

type DeleteNamespaceRequest struct {

	// Only one of namespace or namespace_id must be specified to identify namespace.
	Namespace   string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	NamespaceId string `protobuf:"bytes,2,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	// If provided, the deletion of namespace info will be delayed for the given duration (0 means no delay).
	// If not provided, the default delay configured in the cluster will be used.
	NamespaceDeleteDelay *durationpb.Duration `protobuf:"bytes,3,opt,name=namespace_delete_delay,json=namespaceDeleteDelay,proto3" json:"namespace_delete_delay,omitempty"`
	// contains filtered or unexported fields
}

type DeleteNamespaceResponse struct {

	// Temporary namespace name that is used during reclaim resources step.
	DeletedNamespace string `protobuf:"bytes,1,opt,name=deleted_namespace,json=deletedNamespace,proto3" json:"deleted_namespace,omitempty"`
	// contains filtered or unexported fields
}

type DeleteNexusIncomingServiceRequest struct {

	// Name of service to delete.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type DeleteNexusIncomingServiceResponse struct {
	// contains filtered or unexported fields
}

type GetNexusIncomingServiceRequest struct {

	// Name of service to retrieve.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type GetNexusIncomingServiceResponse struct {
	Service *v11.IncomingService `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	// contains filtered or unexported fields
}

type ListClustersRequest struct {
	PageSize      int32  `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	NextPageToken []byte `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

type ListClustersResponse struct {

	// List of all cluster information
	Clusters      []*ClusterMetadata `protobuf:"bytes,1,rep,name=clusters,proto3" json:"clusters,omitempty"`
	NextPageToken []byte             `protobuf:"bytes,4,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

type ListNexusIncomingServicesRequest struct {
	PageSize int32 `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// To get the next page, pass in `ListNexusIncomingServicesResponse.next_page_token` from the previous page's
	// response, the token will be empty if there's no other page.
	// Note: the last page may be empty if the total number of services registered is a multiple of the page size.
	NextPageToken []byte `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

type ListNexusIncomingServicesResponse struct {

	// Token for getting the next page.
	NextPageToken []byte                 `protobuf:"bytes,1,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	Services      []*v11.IncomingService `protobuf:"bytes,2,rep,name=services,proto3" json:"services,omitempty"`
	// contains filtered or unexported fields
}

type ListSearchAttributesRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

type ListSearchAttributesResponse struct {

	// Mapping between custom (user-registered) search attribute name to its IndexedValueType.
	CustomAttributes map[string]v1.IndexedValueType `` /* 242-byte string literal not displayed */
	// Mapping between system (predefined) search attribute name to its IndexedValueType.
	SystemAttributes map[string]v1.IndexedValueType `` /* 242-byte string literal not displayed */
	// Mapping from the attribute name to the visibility storage native type.
	StorageSchema map[string]string `` /* 188-byte string literal not displayed */
	// contains filtered or unexported fields
}

type OperatorServiceClient interface {
	// AddSearchAttributes add custom search attributes.
	//
	// Returns ALREADY_EXISTS status code if a Search Attribute with any of the specified names already exists
	// Returns INTERNAL status code with temporal.api.errordetails.v1.SystemWorkflowFailure in Error Details if registration process fails,
	AddSearchAttributes(ctx context.Context, in *AddSearchAttributesRequest, opts ...grpc.CallOption) (*AddSearchAttributesResponse, error)
	// RemoveSearchAttributes removes custom search attributes.
	//
	// Returns NOT_FOUND status code if a Search Attribute with any of the specified names is not registered
	RemoveSearchAttributes(ctx context.Context, in *RemoveSearchAttributesRequest, opts ...grpc.CallOption) (*RemoveSearchAttributesResponse, error)
	// ListSearchAttributes returns comprehensive information about search attributes.
	ListSearchAttributes(ctx context.Context, in *ListSearchAttributesRequest, opts ...grpc.CallOption) (*ListSearchAttributesResponse, error)
	// DeleteNamespace synchronously deletes a namespace and asynchronously reclaims all namespace resources.
	// (-- api-linter: core::0135::method-signature=disabled
	//
	//	aip.dev/not-precedent: DeleteNamespace RPC doesn't follow Google API format. --)
	//
	// (-- api-linter: core::0135::response-message-name=disabled
	//
	//	aip.dev/not-precedent: DeleteNamespace RPC doesn't follow Google API format. --)
	DeleteNamespace(ctx context.Context, in *DeleteNamespaceRequest, opts ...grpc.CallOption) (*DeleteNamespaceResponse, error)
	// AddOrUpdateRemoteCluster adds or updates remote cluster.
	AddOrUpdateRemoteCluster(ctx context.Context, in *AddOrUpdateRemoteClusterRequest, opts ...grpc.CallOption) (*AddOrUpdateRemoteClusterResponse, error)
	// RemoveRemoteCluster removes remote cluster.
	RemoveRemoteCluster(ctx context.Context, in *RemoveRemoteClusterRequest, opts ...grpc.CallOption) (*RemoveRemoteClusterResponse, error)
	// ListClusters returns information about Temporal clusters.
	ListClusters(ctx context.Context, in *ListClustersRequest, opts ...grpc.CallOption) (*ListClustersResponse, error)
	// Get a registered incoming Nexus service by name. The returned version can be used for optimistic updates.
	GetNexusIncomingService(ctx context.Context, in *GetNexusIncomingServiceRequest, opts ...grpc.CallOption) (*GetNexusIncomingServiceResponse, error)
	// Optimistically create or update a Nexus service based on provided version.
	// To update an existing service, get the current service record via the `GetNexusIncomingService` API, modify it
	// and submit to this API.
	// Set version to 0 to create a new service.
	// Returns the updated service with the updated version, which can be used for subsequent updates.
	CreateOrUpdateNexusIncomingService(ctx context.Context, in *CreateOrUpdateNexusIncomingServiceRequest, opts ...grpc.CallOption) (*CreateOrUpdateNexusIncomingServiceResponse, error)
	// Delete an incoming Nexus service by name.
	DeleteNexusIncomingService(ctx context.Context, in *DeleteNexusIncomingServiceRequest, opts ...grpc.CallOption) (*DeleteNexusIncomingServiceResponse, error)
	// List all nexus incoming service names. Use next_page_token in the response for pagination.
	ListNexusIncomingServices(ctx context.Context, in *ListNexusIncomingServicesRequest, opts ...grpc.CallOption) (*ListNexusIncomingServicesResponse, error)
}

type OperatorServiceServer interface {
	// AddSearchAttributes add custom search attributes.
	//
	// Returns ALREADY_EXISTS status code if a Search Attribute with any of the specified names already exists
	// Returns INTERNAL status code with temporal.api.errordetails.v1.SystemWorkflowFailure in Error Details if registration process fails,
	AddSearchAttributes(context.Context, *AddSearchAttributesRequest) (*AddSearchAttributesResponse, error)
	// RemoveSearchAttributes removes custom search attributes.
	//
	// Returns NOT_FOUND status code if a Search Attribute with any of the specified names is not registered
	RemoveSearchAttributes(context.Context, *RemoveSearchAttributesRequest) (*RemoveSearchAttributesResponse, error)
	// ListSearchAttributes returns comprehensive information about search attributes.
	ListSearchAttributes(context.Context, *ListSearchAttributesRequest) (*ListSearchAttributesResponse, error)
	// DeleteNamespace synchronously deletes a namespace and asynchronously reclaims all namespace resources.
	// (-- api-linter: core::0135::method-signature=disabled
	//
	//	aip.dev/not-precedent: DeleteNamespace RPC doesn't follow Google API format. --)
	//
	// (-- api-linter: core::0135::response-message-name=disabled
	//
	//	aip.dev/not-precedent: DeleteNamespace RPC doesn't follow Google API format. --)
	DeleteNamespace(context.Context, *DeleteNamespaceRequest) (*DeleteNamespaceResponse, error)
	// AddOrUpdateRemoteCluster adds or updates remote cluster.
	AddOrUpdateRemoteCluster(context.Context, *AddOrUpdateRemoteClusterRequest) (*AddOrUpdateRemoteClusterResponse, error)
	// RemoveRemoteCluster removes remote cluster.
	RemoveRemoteCluster(context.Context, *RemoveRemoteClusterRequest) (*RemoveRemoteClusterResponse, error)
	// ListClusters returns information about Temporal clusters.
	ListClusters(context.Context, *ListClustersRequest) (*ListClustersResponse, error)
	// Get a registered incoming Nexus service by name. The returned version can be used for optimistic updates.
	GetNexusIncomingService(context.Context, *GetNexusIncomingServiceRequest) (*GetNexusIncomingServiceResponse, error)
	// Optimistically create or update a Nexus service based on provided version.
	// To update an existing service, get the current service record via the `GetNexusIncomingService` API, modify it
	// and submit to this API.
	// Set version to 0 to create a new service.
	// Returns the updated service with the updated version, which can be used for subsequent updates.
	CreateOrUpdateNexusIncomingService(context.Context, *CreateOrUpdateNexusIncomingServiceRequest) (*CreateOrUpdateNexusIncomingServiceResponse, error)
	// Delete an incoming Nexus service by name.
	DeleteNexusIncomingService(context.Context, *DeleteNexusIncomingServiceRequest) (*DeleteNexusIncomingServiceResponse, error)
	// List all nexus incoming service names. Use next_page_token in the response for pagination.
	ListNexusIncomingServices(context.Context, *ListNexusIncomingServicesRequest) (*ListNexusIncomingServicesResponse, error)
}

type RemoveRemoteClusterRequest struct {

	// Remote cluster name to be removed.
	ClusterName string `protobuf:"bytes,1,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	// contains filtered or unexported fields
}

type RemoveRemoteClusterResponse struct {
	// contains filtered or unexported fields
}

type RemoveSearchAttributesRequest struct {

	// Search attribute names to delete.
	SearchAttributes []string `protobuf:"bytes,1,rep,name=search_attributes,json=searchAttributes,proto3" json:"search_attributes,omitempty"`
	Namespace        string   `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

type RemoveSearchAttributesResponse struct {
	// contains filtered or unexported fields
}

type UnimplementedOperatorServiceServer struct {
}

type UnsafeOperatorServiceServer interface {
	// contains filtered or unexported methods
}