operatorservice

type AddOrUpdateRemoteClusterRequest struct {

	// Frontend Address is a cross cluster accessible address for gRPC traffic. This field is required.
	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 */
	// Frontend HTTP Address is a cross cluster accessible address for HTTP traffic. This field is optional. If not provided
	//
	//	on update, the existing HTTP address will be removed.
	FrontendHttpAddress string `protobuf:"bytes,3,opt,name=frontend_http_address,json=frontendHttpAddress,proto3" json:"frontend_http_address,omitempty"`
	// 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 `` /* 228-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"`
	// gRPC address.
	Address string `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"`
	// HTTP address, if one exists.
	HttpAddress string `protobuf:"bytes,7,opt,name=http_address,json=httpAddress,proto3" json:"http_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 CreateNexusEndpointRequest struct {

	// Endpoint definition to create.
	Spec *v11.EndpointSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

type CreateNexusEndpointResponse struct {

	// Data post acceptance. Can be used to issue additional updates to this record.
	Endpoint *v11.Endpoint `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,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 DeleteNexusEndpointRequest struct {

	// Server-generated unique endpoint ID.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Data version for this endpoint. Must match current version.
	Version int64 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

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

type GetNexusEndpointRequest struct {

	// Server-generated unique endpoint ID.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type GetNexusEndpointResponse struct {
	Endpoint *v11.Endpoint `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,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 ListNexusEndpointsRequest struct {
	PageSize int32 `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// To get the next page, pass in `ListNexusEndpointsResponse.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 endpoints 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"`
	// Name of the incoming endpoint to filter on - optional. Specifying this will result in zero or one results.
	// (-- api-linter: core::203::field-behavior-required=disabled
	//
	//	aip.dev/not-precedent: Not following linter rules. --)
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type ListNexusEndpointsResponse 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"`
	Endpoints     []*v11.Endpoint `protobuf:"bytes,2,rep,name=endpoints,proto3" json:"endpoints,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 `` /* 228-byte string literal not displayed */
	// Mapping between system (predefined) search attribute name to its IndexedValueType.
	SystemAttributes map[string]v1.IndexedValueType `` /* 228-byte string literal not displayed */
	// Mapping from the attribute name to the visibility storage native type.
	StorageSchema map[string]string `` /* 174-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.
	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 Nexus endpoint by ID. The returned version can be used for optimistic updates.
	GetNexusEndpoint(ctx context.Context, in *GetNexusEndpointRequest, opts ...grpc.CallOption) (*GetNexusEndpointResponse, error)
	// Create a Nexus endpoint. This will fail if an endpoint with the same name is already registered with a status of
	// ALREADY_EXISTS.
	// Returns the created endpoint with its initial version. You may use this version for subsequent updates.
	CreateNexusEndpoint(ctx context.Context, in *CreateNexusEndpointRequest, opts ...grpc.CallOption) (*CreateNexusEndpointResponse, error)
	// Optimistically update a Nexus endpoint based on provided version as obtained via the `GetNexusEndpoint` or
	// `ListNexusEndpointResponse` APIs. This will fail with a status of FAILED_PRECONDITION if the version does not
	// match.
	// Returns the updated endpoint with its updated version. You may use this version for subsequent updates. You don't
	// need to increment the version yourself. The server will increment the version for you after each update.
	UpdateNexusEndpoint(ctx context.Context, in *UpdateNexusEndpointRequest, opts ...grpc.CallOption) (*UpdateNexusEndpointResponse, error)
	// Delete an incoming Nexus service by ID.
	DeleteNexusEndpoint(ctx context.Context, in *DeleteNexusEndpointRequest, opts ...grpc.CallOption) (*DeleteNexusEndpointResponse, error)
	// List all Nexus endpoints for the cluster, sorted by ID in ascending order. Set page_token in the request to the
	// next_page_token field of the previous response to get the next page of results. An empty next_page_token
	// indicates that there are no more results. During pagination, a newly added service with an ID lexicographically
	// earlier than the previous page's last endpoint's ID may be missed.
	ListNexusEndpoints(ctx context.Context, in *ListNexusEndpointsRequest, opts ...grpc.CallOption) (*ListNexusEndpointsResponse, 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.
	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 Nexus endpoint by ID. The returned version can be used for optimistic updates.
	GetNexusEndpoint(context.Context, *GetNexusEndpointRequest) (*GetNexusEndpointResponse, error)
	// Create a Nexus endpoint. This will fail if an endpoint with the same name is already registered with a status of
	// ALREADY_EXISTS.
	// Returns the created endpoint with its initial version. You may use this version for subsequent updates.
	CreateNexusEndpoint(context.Context, *CreateNexusEndpointRequest) (*CreateNexusEndpointResponse, error)
	// Optimistically update a Nexus endpoint based on provided version as obtained via the `GetNexusEndpoint` or
	// `ListNexusEndpointResponse` APIs. This will fail with a status of FAILED_PRECONDITION if the version does not
	// match.
	// Returns the updated endpoint with its updated version. You may use this version for subsequent updates. You don't
	// need to increment the version yourself. The server will increment the version for you after each update.
	UpdateNexusEndpoint(context.Context, *UpdateNexusEndpointRequest) (*UpdateNexusEndpointResponse, error)
	// Delete an incoming Nexus service by ID.
	DeleteNexusEndpoint(context.Context, *DeleteNexusEndpointRequest) (*DeleteNexusEndpointResponse, error)
	// List all Nexus endpoints for the cluster, sorted by ID in ascending order. Set page_token in the request to the
	// next_page_token field of the previous response to get the next page of results. An empty next_page_token
	// indicates that there are no more results. During pagination, a newly added service with an ID lexicographically
	// earlier than the previous page's last endpoint's ID may be missed.
	ListNexusEndpoints(context.Context, *ListNexusEndpointsRequest) (*ListNexusEndpointsResponse, 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
}

type UpdateNexusEndpointRequest struct {

	// Server-generated unique endpoint ID.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Data version for this endpoint. Must match current version.
	Version int64             `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	Spec    *v11.EndpointSpec `protobuf:"bytes,3,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

type UpdateNexusEndpointResponse struct {

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