operatorservice

package
v1.18.0 Latest Latest
Warning

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

 Go to latest Published: Feb 10, 2023 License: MIT Imports: 14 Imported by: 26

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthRequestResponse        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRequestResponse          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupRequestResponse = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterOperatorServiceServer 

func RegisterOperatorServiceServer(s *grpc.Server, srv OperatorServiceServer)

Types

type AddOrUpdateRemoteClusterRequest added in v1.9.0 

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 */
}

func (*AddOrUpdateRemoteClusterRequest) Descriptor added in v1.9.0 

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

func (*AddOrUpdateRemoteClusterRequest) Equal added in v1.9.0 

func (this *AddOrUpdateRemoteClusterRequest) Equal(that interface{}) bool

func (*AddOrUpdateRemoteClusterRequest) GetEnableRemoteClusterConnection added in v1.9.0 

func (m *AddOrUpdateRemoteClusterRequest) GetEnableRemoteClusterConnection() bool

func (*AddOrUpdateRemoteClusterRequest) GetFrontendAddress added in v1.9.0 

func (m *AddOrUpdateRemoteClusterRequest) GetFrontendAddress() string

func (*AddOrUpdateRemoteClusterRequest) GoString added in v1.9.0 

func (this *AddOrUpdateRemoteClusterRequest) GoString() string

func (*AddOrUpdateRemoteClusterRequest) Marshal added in v1.9.0 

func (m *AddOrUpdateRemoteClusterRequest) Marshal() (dAtA []byte, err error)

func (*AddOrUpdateRemoteClusterRequest) MarshalTo added in v1.9.0 

func (m *AddOrUpdateRemoteClusterRequest) MarshalTo(dAtA []byte) (int, error)

func (*AddOrUpdateRemoteClusterRequest) MarshalToSizedBuffer added in v1.9.0 

func (m *AddOrUpdateRemoteClusterRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AddOrUpdateRemoteClusterRequest) ProtoMessage added in v1.9.0 

func (*AddOrUpdateRemoteClusterRequest) ProtoMessage()

func (*AddOrUpdateRemoteClusterRequest) Reset added in v1.9.0 

func (m *AddOrUpdateRemoteClusterRequest) Reset()

func (*AddOrUpdateRemoteClusterRequest) Size added in v1.9.0 

func (m *AddOrUpdateRemoteClusterRequest) Size() (n int)

func (*AddOrUpdateRemoteClusterRequest) String added in v1.9.0 

func (this *AddOrUpdateRemoteClusterRequest) String() string

func (*AddOrUpdateRemoteClusterRequest) Unmarshal added in v1.9.0 

func (m *AddOrUpdateRemoteClusterRequest) Unmarshal(dAtA []byte) error

func (*AddOrUpdateRemoteClusterRequest) XXX_DiscardUnknown added in v1.9.0 

func (m *AddOrUpdateRemoteClusterRequest) XXX_DiscardUnknown()

func (*AddOrUpdateRemoteClusterRequest) XXX_Marshal added in v1.9.0 

func (m *AddOrUpdateRemoteClusterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AddOrUpdateRemoteClusterRequest) XXX_Merge added in v1.9.0 

func (m *AddOrUpdateRemoteClusterRequest) XXX_Merge(src proto.Message)

func (*AddOrUpdateRemoteClusterRequest) XXX_Size added in v1.9.0 

func (m *AddOrUpdateRemoteClusterRequest) XXX_Size() int

func (*AddOrUpdateRemoteClusterRequest) XXX_Unmarshal added in v1.9.0 

func (m *AddOrUpdateRemoteClusterRequest) XXX_Unmarshal(b []byte) error

type AddOrUpdateRemoteClusterResponse added in v1.9.0 

type AddOrUpdateRemoteClusterResponse struct {
}

func (*AddOrUpdateRemoteClusterResponse) Descriptor added in v1.9.0 

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

func (*AddOrUpdateRemoteClusterResponse) Equal added in v1.9.0 

func (this *AddOrUpdateRemoteClusterResponse) Equal(that interface{}) bool

func (*AddOrUpdateRemoteClusterResponse) GoString added in v1.9.0 

func (this *AddOrUpdateRemoteClusterResponse) GoString() string

func (*AddOrUpdateRemoteClusterResponse) Marshal added in v1.9.0 

func (m *AddOrUpdateRemoteClusterResponse) Marshal() (dAtA []byte, err error)

func (*AddOrUpdateRemoteClusterResponse) MarshalTo added in v1.9.0 

func (m *AddOrUpdateRemoteClusterResponse) MarshalTo(dAtA []byte) (int, error)

func (*AddOrUpdateRemoteClusterResponse) MarshalToSizedBuffer added in v1.9.0 

func (m *AddOrUpdateRemoteClusterResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AddOrUpdateRemoteClusterResponse) ProtoMessage added in v1.9.0 

func (*AddOrUpdateRemoteClusterResponse) ProtoMessage()

func (*AddOrUpdateRemoteClusterResponse) Reset added in v1.9.0 

func (m *AddOrUpdateRemoteClusterResponse) Reset()

func (*AddOrUpdateRemoteClusterResponse) Size added in v1.9.0 

func (m *AddOrUpdateRemoteClusterResponse) Size() (n int)

func (*AddOrUpdateRemoteClusterResponse) String added in v1.9.0 

func (this *AddOrUpdateRemoteClusterResponse) String() string

func (*AddOrUpdateRemoteClusterResponse) Unmarshal added in v1.9.0 

func (m *AddOrUpdateRemoteClusterResponse) Unmarshal(dAtA []byte) error

func (*AddOrUpdateRemoteClusterResponse) XXX_DiscardUnknown added in v1.9.0 

func (m *AddOrUpdateRemoteClusterResponse) XXX_DiscardUnknown()

func (*AddOrUpdateRemoteClusterResponse) XXX_Marshal added in v1.9.0 

func (m *AddOrUpdateRemoteClusterResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AddOrUpdateRemoteClusterResponse) XXX_Merge added in v1.9.0 

func (m *AddOrUpdateRemoteClusterResponse) XXX_Merge(src proto.Message)

func (*AddOrUpdateRemoteClusterResponse) XXX_Size added in v1.9.0 

func (m *AddOrUpdateRemoteClusterResponse) XXX_Size() int

func (*AddOrUpdateRemoteClusterResponse) XXX_Unmarshal added in v1.9.0 

func (m *AddOrUpdateRemoteClusterResponse) XXX_Unmarshal(b []byte) error

type AddSearchAttributesRequest 

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"`
}

func (*AddSearchAttributesRequest) Descriptor 

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

func (*AddSearchAttributesRequest) Equal 

func (this *AddSearchAttributesRequest) Equal(that interface{}) bool

func (*AddSearchAttributesRequest) GetNamespace added in v1.16.0 

func (m *AddSearchAttributesRequest) GetNamespace() string

func (*AddSearchAttributesRequest) GetSearchAttributes 

func (m *AddSearchAttributesRequest) GetSearchAttributes() map[string]v1.IndexedValueType

func (*AddSearchAttributesRequest) GoString 

func (this *AddSearchAttributesRequest) GoString() string

func (*AddSearchAttributesRequest) Marshal 

func (m *AddSearchAttributesRequest) Marshal() (dAtA []byte, err error)

func (*AddSearchAttributesRequest) MarshalTo 

func (m *AddSearchAttributesRequest) MarshalTo(dAtA []byte) (int, error)

func (*AddSearchAttributesRequest) MarshalToSizedBuffer 

func (m *AddSearchAttributesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AddSearchAttributesRequest) ProtoMessage 

func (*AddSearchAttributesRequest) ProtoMessage()

func (*AddSearchAttributesRequest) Reset 

func (m *AddSearchAttributesRequest) Reset()

func (*AddSearchAttributesRequest) Size 

func (m *AddSearchAttributesRequest) Size() (n int)

func (*AddSearchAttributesRequest) String 

func (this *AddSearchAttributesRequest) String() string

func (*AddSearchAttributesRequest) Unmarshal 

func (m *AddSearchAttributesRequest) Unmarshal(dAtA []byte) error

func (*AddSearchAttributesRequest) XXX_DiscardUnknown 

func (m *AddSearchAttributesRequest) XXX_DiscardUnknown()

func (*AddSearchAttributesRequest) XXX_Marshal 

func (m *AddSearchAttributesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AddSearchAttributesRequest) XXX_Merge 

func (m *AddSearchAttributesRequest) XXX_Merge(src proto.Message)

func (*AddSearchAttributesRequest) XXX_Size 

func (m *AddSearchAttributesRequest) XXX_Size() int

func (*AddSearchAttributesRequest) XXX_Unmarshal 

func (m *AddSearchAttributesRequest) XXX_Unmarshal(b []byte) error

type AddSearchAttributesResponse 

type AddSearchAttributesResponse struct {
}

func (*AddSearchAttributesResponse) Descriptor 

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

func (*AddSearchAttributesResponse) Equal 

func (this *AddSearchAttributesResponse) Equal(that interface{}) bool

func (*AddSearchAttributesResponse) GoString 

func (this *AddSearchAttributesResponse) GoString() string

func (*AddSearchAttributesResponse) Marshal 

func (m *AddSearchAttributesResponse) Marshal() (dAtA []byte, err error)

func (*AddSearchAttributesResponse) MarshalTo 

func (m *AddSearchAttributesResponse) MarshalTo(dAtA []byte) (int, error)

func (*AddSearchAttributesResponse) MarshalToSizedBuffer 

func (m *AddSearchAttributesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AddSearchAttributesResponse) ProtoMessage 

func (*AddSearchAttributesResponse) ProtoMessage()

func (*AddSearchAttributesResponse) Reset 

func (m *AddSearchAttributesResponse) Reset()

func (*AddSearchAttributesResponse) Size 

func (m *AddSearchAttributesResponse) Size() (n int)

func (*AddSearchAttributesResponse) String 

func (this *AddSearchAttributesResponse) String() string

func (*AddSearchAttributesResponse) Unmarshal 

func (m *AddSearchAttributesResponse) Unmarshal(dAtA []byte) error

func (*AddSearchAttributesResponse) XXX_DiscardUnknown 

func (m *AddSearchAttributesResponse) XXX_DiscardUnknown()

func (*AddSearchAttributesResponse) XXX_Marshal 

func (m *AddSearchAttributesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AddSearchAttributesResponse) XXX_Merge 

func (m *AddSearchAttributesResponse) XXX_Merge(src proto.Message)

func (*AddSearchAttributesResponse) XXX_Size 

func (m *AddSearchAttributesResponse) XXX_Size() int

func (*AddSearchAttributesResponse) XXX_Unmarshal 

func (m *AddSearchAttributesResponse) XXX_Unmarshal(b []byte) error

type ClusterMetadata added in v1.12.0 

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"`
}

func (*ClusterMetadata) Descriptor added in v1.12.0 

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

func (*ClusterMetadata) Equal added in v1.12.0 

func (this *ClusterMetadata) Equal(that interface{}) bool

func (*ClusterMetadata) GetAddress added in v1.12.0 

func (m *ClusterMetadata) GetAddress() string

func (*ClusterMetadata) GetClusterId added in v1.12.0 

func (m *ClusterMetadata) GetClusterId() string

func (*ClusterMetadata) GetClusterName added in v1.12.0 

func (m *ClusterMetadata) GetClusterName() string

func (*ClusterMetadata) GetHistoryShardCount added in v1.12.0 

func (m *ClusterMetadata) GetHistoryShardCount() int32

func (*ClusterMetadata) GetInitialFailoverVersion added in v1.12.0 

func (m *ClusterMetadata) GetInitialFailoverVersion() int64

func (*ClusterMetadata) GetIsConnectionEnabled added in v1.12.0 

func (m *ClusterMetadata) GetIsConnectionEnabled() bool

func (*ClusterMetadata) GoString added in v1.12.0 

func (this *ClusterMetadata) GoString() string

func (*ClusterMetadata) Marshal added in v1.12.0 

func (m *ClusterMetadata) Marshal() (dAtA []byte, err error)

func (*ClusterMetadata) MarshalTo added in v1.12.0 

func (m *ClusterMetadata) MarshalTo(dAtA []byte) (int, error)

func (*ClusterMetadata) MarshalToSizedBuffer added in v1.12.0 

func (m *ClusterMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClusterMetadata) ProtoMessage added in v1.12.0 

func (*ClusterMetadata) ProtoMessage()

func (*ClusterMetadata) Reset added in v1.12.0 

func (m *ClusterMetadata) Reset()

func (*ClusterMetadata) Size added in v1.12.0 

func (m *ClusterMetadata) Size() (n int)

func (*ClusterMetadata) String added in v1.12.0 

func (this *ClusterMetadata) String() string

func (*ClusterMetadata) Unmarshal added in v1.12.0 

func (m *ClusterMetadata) Unmarshal(dAtA []byte) error

func (*ClusterMetadata) XXX_DiscardUnknown added in v1.12.0 

func (m *ClusterMetadata) XXX_DiscardUnknown()

func (*ClusterMetadata) XXX_Marshal added in v1.12.0 

func (m *ClusterMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClusterMetadata) XXX_Merge added in v1.12.0 

func (m *ClusterMetadata) XXX_Merge(src proto.Message)

func (*ClusterMetadata) XXX_Size added in v1.12.0 

func (m *ClusterMetadata) XXX_Size() int

func (*ClusterMetadata) XXX_Unmarshal added in v1.12.0 

func (m *ClusterMetadata) XXX_Unmarshal(b []byte) error

type DeleteNamespaceRequest 

type DeleteNamespaceRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
}

(-- api-linter: core::0135::request-unknown-fields=disabled 

aip.dev/not-precedent: DeleteNamespace RPC doesn't follow Google API format. --)

(-- api-linter: core::0135::request-name-required=disabled 

aip.dev/not-precedent: DeleteNamespace RPC doesn't follow Google API format. --)

func (*DeleteNamespaceRequest) Descriptor 

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

func (*DeleteNamespaceRequest) Equal 

func (this *DeleteNamespaceRequest) Equal(that interface{}) bool

func (*DeleteNamespaceRequest) GetNamespace 

func (m *DeleteNamespaceRequest) GetNamespace() string

func (*DeleteNamespaceRequest) GoString 

func (this *DeleteNamespaceRequest) GoString() string

func (*DeleteNamespaceRequest) Marshal 

func (m *DeleteNamespaceRequest) Marshal() (dAtA []byte, err error)

func (*DeleteNamespaceRequest) MarshalTo 

func (m *DeleteNamespaceRequest) MarshalTo(dAtA []byte) (int, error)

func (*DeleteNamespaceRequest) MarshalToSizedBuffer 

func (m *DeleteNamespaceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeleteNamespaceRequest) ProtoMessage 

func (*DeleteNamespaceRequest) ProtoMessage()

func (*DeleteNamespaceRequest) Reset 

func (m *DeleteNamespaceRequest) Reset()

func (*DeleteNamespaceRequest) Size 

func (m *DeleteNamespaceRequest) Size() (n int)

func (*DeleteNamespaceRequest) String 

func (this *DeleteNamespaceRequest) String() string

func (*DeleteNamespaceRequest) Unmarshal 

func (m *DeleteNamespaceRequest) Unmarshal(dAtA []byte) error

func (*DeleteNamespaceRequest) XXX_DiscardUnknown 

func (m *DeleteNamespaceRequest) XXX_DiscardUnknown()

func (*DeleteNamespaceRequest) XXX_Marshal 

func (m *DeleteNamespaceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteNamespaceRequest) XXX_Merge 

func (m *DeleteNamespaceRequest) XXX_Merge(src proto.Message)

func (*DeleteNamespaceRequest) XXX_Size 

func (m *DeleteNamespaceRequest) XXX_Size() int

func (*DeleteNamespaceRequest) XXX_Unmarshal 

func (m *DeleteNamespaceRequest) XXX_Unmarshal(b []byte) error

type DeleteNamespaceResponse 

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"`
}

func (*DeleteNamespaceResponse) Descriptor 

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

func (*DeleteNamespaceResponse) Equal 

func (this *DeleteNamespaceResponse) Equal(that interface{}) bool

func (*DeleteNamespaceResponse) GetDeletedNamespace 

func (m *DeleteNamespaceResponse) GetDeletedNamespace() string

func (*DeleteNamespaceResponse) GoString 

func (this *DeleteNamespaceResponse) GoString() string

func (*DeleteNamespaceResponse) Marshal 

func (m *DeleteNamespaceResponse) Marshal() (dAtA []byte, err error)

func (*DeleteNamespaceResponse) MarshalTo 

func (m *DeleteNamespaceResponse) MarshalTo(dAtA []byte) (int, error)

func (*DeleteNamespaceResponse) MarshalToSizedBuffer 

func (m *DeleteNamespaceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeleteNamespaceResponse) ProtoMessage 

func (*DeleteNamespaceResponse) ProtoMessage()

func (*DeleteNamespaceResponse) Reset 

func (m *DeleteNamespaceResponse) Reset()

func (*DeleteNamespaceResponse) Size 

func (m *DeleteNamespaceResponse) Size() (n int)

func (*DeleteNamespaceResponse) String 

func (this *DeleteNamespaceResponse) String() string

func (*DeleteNamespaceResponse) Unmarshal 

func (m *DeleteNamespaceResponse) Unmarshal(dAtA []byte) error

func (*DeleteNamespaceResponse) XXX_DiscardUnknown 

func (m *DeleteNamespaceResponse) XXX_DiscardUnknown()

func (*DeleteNamespaceResponse) XXX_Marshal 

func (m *DeleteNamespaceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteNamespaceResponse) XXX_Merge 

func (m *DeleteNamespaceResponse) XXX_Merge(src proto.Message)

func (*DeleteNamespaceResponse) XXX_Size 

func (m *DeleteNamespaceResponse) XXX_Size() int

func (*DeleteNamespaceResponse) XXX_Unmarshal 

func (m *DeleteNamespaceResponse) XXX_Unmarshal(b []byte) error

type ListClustersRequest added in v1.9.0 

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"`
}

func (*ListClustersRequest) Descriptor added in v1.9.0 

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

func (*ListClustersRequest) Equal added in v1.9.0 

func (this *ListClustersRequest) Equal(that interface{}) bool

func (*ListClustersRequest) GetNextPageToken added in v1.9.0 

func (m *ListClustersRequest) GetNextPageToken() []byte

func (*ListClustersRequest) GetPageSize added in v1.9.0 

func (m *ListClustersRequest) GetPageSize() int32

func (*ListClustersRequest) GoString added in v1.9.0 

func (this *ListClustersRequest) GoString() string

func (*ListClustersRequest) Marshal added in v1.9.0 

func (m *ListClustersRequest) Marshal() (dAtA []byte, err error)

func (*ListClustersRequest) MarshalTo added in v1.9.0 

func (m *ListClustersRequest) MarshalTo(dAtA []byte) (int, error)

func (*ListClustersRequest) MarshalToSizedBuffer added in v1.9.0 

func (m *ListClustersRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListClustersRequest) ProtoMessage added in v1.9.0 

func (*ListClustersRequest) ProtoMessage()

func (*ListClustersRequest) Reset added in v1.9.0 

func (m *ListClustersRequest) Reset()

func (*ListClustersRequest) Size added in v1.9.0 

func (m *ListClustersRequest) Size() (n int)

func (*ListClustersRequest) String added in v1.9.0 

func (this *ListClustersRequest) String() string

func (*ListClustersRequest) Unmarshal added in v1.9.0 

func (m *ListClustersRequest) Unmarshal(dAtA []byte) error

func (*ListClustersRequest) XXX_DiscardUnknown added in v1.9.0 

func (m *ListClustersRequest) XXX_DiscardUnknown()

func (*ListClustersRequest) XXX_Marshal added in v1.9.0 

func (m *ListClustersRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListClustersRequest) XXX_Merge added in v1.9.0 

func (m *ListClustersRequest) XXX_Merge(src proto.Message)

func (*ListClustersRequest) XXX_Size added in v1.9.0 

func (m *ListClustersRequest) XXX_Size() int

func (*ListClustersRequest) XXX_Unmarshal added in v1.9.0 

func (m *ListClustersRequest) XXX_Unmarshal(b []byte) error

type ListClustersResponse added in v1.9.0 

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"`
}

func (*ListClustersResponse) Descriptor added in v1.9.0 

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

func (*ListClustersResponse) Equal added in v1.9.0 

func (this *ListClustersResponse) Equal(that interface{}) bool

func (*ListClustersResponse) GetClusters added in v1.9.0 

func (m *ListClustersResponse) GetClusters() []*ClusterMetadata

func (*ListClustersResponse) GetNextPageToken added in v1.9.0 

func (m *ListClustersResponse) GetNextPageToken() []byte

func (*ListClustersResponse) GoString added in v1.9.0 

func (this *ListClustersResponse) GoString() string

func (*ListClustersResponse) Marshal added in v1.9.0 

func (m *ListClustersResponse) Marshal() (dAtA []byte, err error)

func (*ListClustersResponse) MarshalTo added in v1.9.0 

func (m *ListClustersResponse) MarshalTo(dAtA []byte) (int, error)

func (*ListClustersResponse) MarshalToSizedBuffer added in v1.9.0 

func (m *ListClustersResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListClustersResponse) ProtoMessage added in v1.9.0 

func (*ListClustersResponse) ProtoMessage()

func (*ListClustersResponse) Reset added in v1.9.0 

func (m *ListClustersResponse) Reset()

func (*ListClustersResponse) Size added in v1.9.0 

func (m *ListClustersResponse) Size() (n int)

func (*ListClustersResponse) String added in v1.9.0 

func (this *ListClustersResponse) String() string

func (*ListClustersResponse) Unmarshal added in v1.9.0 

func (m *ListClustersResponse) Unmarshal(dAtA []byte) error

func (*ListClustersResponse) XXX_DiscardUnknown added in v1.9.0 

func (m *ListClustersResponse) XXX_DiscardUnknown()

func (*ListClustersResponse) XXX_Marshal added in v1.9.0 

func (m *ListClustersResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListClustersResponse) XXX_Merge added in v1.9.0 

func (m *ListClustersResponse) XXX_Merge(src proto.Message)

func (*ListClustersResponse) XXX_Size added in v1.9.0 

func (m *ListClustersResponse) XXX_Size() int

func (*ListClustersResponse) XXX_Unmarshal added in v1.9.0 

func (m *ListClustersResponse) XXX_Unmarshal(b []byte) error

type ListSearchAttributesRequest 

type ListSearchAttributesRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
}

func (*ListSearchAttributesRequest) Descriptor 

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

func (*ListSearchAttributesRequest) Equal 

func (this *ListSearchAttributesRequest) Equal(that interface{}) bool

func (*ListSearchAttributesRequest) GetNamespace added in v1.16.0 

func (m *ListSearchAttributesRequest) GetNamespace() string

func (*ListSearchAttributesRequest) GoString 

func (this *ListSearchAttributesRequest) GoString() string

func (*ListSearchAttributesRequest) Marshal 

func (m *ListSearchAttributesRequest) Marshal() (dAtA []byte, err error)

func (*ListSearchAttributesRequest) MarshalTo 

func (m *ListSearchAttributesRequest) MarshalTo(dAtA []byte) (int, error)

func (*ListSearchAttributesRequest) MarshalToSizedBuffer 

func (m *ListSearchAttributesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListSearchAttributesRequest) ProtoMessage 

func (*ListSearchAttributesRequest) ProtoMessage()

func (*ListSearchAttributesRequest) Reset 

func (m *ListSearchAttributesRequest) Reset()

func (*ListSearchAttributesRequest) Size 

func (m *ListSearchAttributesRequest) Size() (n int)

func (*ListSearchAttributesRequest) String 

func (this *ListSearchAttributesRequest) String() string

func (*ListSearchAttributesRequest) Unmarshal 

func (m *ListSearchAttributesRequest) Unmarshal(dAtA []byte) error

func (*ListSearchAttributesRequest) XXX_DiscardUnknown 

func (m *ListSearchAttributesRequest) XXX_DiscardUnknown()

func (*ListSearchAttributesRequest) XXX_Marshal 

func (m *ListSearchAttributesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListSearchAttributesRequest) XXX_Merge 

func (m *ListSearchAttributesRequest) XXX_Merge(src proto.Message)

func (*ListSearchAttributesRequest) XXX_Size 

func (m *ListSearchAttributesRequest) XXX_Size() int

func (*ListSearchAttributesRequest) XXX_Unmarshal 

func (m *ListSearchAttributesRequest) XXX_Unmarshal(b []byte) error

type ListSearchAttributesResponse 

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 */
}

func (*ListSearchAttributesResponse) Descriptor 

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

func (*ListSearchAttributesResponse) Equal 

func (this *ListSearchAttributesResponse) Equal(that interface{}) bool

func (*ListSearchAttributesResponse) GetCustomAttributes 

func (m *ListSearchAttributesResponse) GetCustomAttributes() map[string]v1.IndexedValueType

func (*ListSearchAttributesResponse) GetStorageSchema 

func (m *ListSearchAttributesResponse) GetStorageSchema() map[string]string

func (*ListSearchAttributesResponse) GetSystemAttributes 

func (m *ListSearchAttributesResponse) GetSystemAttributes() map[string]v1.IndexedValueType

func (*ListSearchAttributesResponse) GoString 

func (this *ListSearchAttributesResponse) GoString() string

func (*ListSearchAttributesResponse) Marshal 

func (m *ListSearchAttributesResponse) Marshal() (dAtA []byte, err error)

func (*ListSearchAttributesResponse) MarshalTo 

func (m *ListSearchAttributesResponse) MarshalTo(dAtA []byte) (int, error)

func (*ListSearchAttributesResponse) MarshalToSizedBuffer 

func (m *ListSearchAttributesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListSearchAttributesResponse) ProtoMessage 

func (*ListSearchAttributesResponse) ProtoMessage()

func (*ListSearchAttributesResponse) Reset 

func (m *ListSearchAttributesResponse) Reset()

func (*ListSearchAttributesResponse) Size 

func (m *ListSearchAttributesResponse) Size() (n int)

func (*ListSearchAttributesResponse) String 

func (this *ListSearchAttributesResponse) String() string

func (*ListSearchAttributesResponse) Unmarshal 

func (m *ListSearchAttributesResponse) Unmarshal(dAtA []byte) error

func (*ListSearchAttributesResponse) XXX_DiscardUnknown 

func (m *ListSearchAttributesResponse) XXX_DiscardUnknown()

func (*ListSearchAttributesResponse) XXX_Marshal 

func (m *ListSearchAttributesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListSearchAttributesResponse) XXX_Merge 

func (m *ListSearchAttributesResponse) XXX_Merge(src proto.Message)

func (*ListSearchAttributesResponse) XXX_Size 

func (m *ListSearchAttributesResponse) XXX_Size() int

func (*ListSearchAttributesResponse) XXX_Unmarshal 

func (m *ListSearchAttributesResponse) XXX_Unmarshal(b []byte) error

type OperatorServiceClient 

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

OperatorServiceClient is the client API for OperatorService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewOperatorServiceClient 

func NewOperatorServiceClient(cc grpc.ClientConnInterface) OperatorServiceClient

type OperatorServiceServer 

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

OperatorServiceServer is the server API for OperatorService service.

type RemoveRemoteClusterRequest added in v1.9.0 

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"`
}

func (*RemoveRemoteClusterRequest) Descriptor added in v1.9.0 

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

func (*RemoveRemoteClusterRequest) Equal added in v1.9.0 

func (this *RemoveRemoteClusterRequest) Equal(that interface{}) bool

func (*RemoveRemoteClusterRequest) GetClusterName added in v1.9.0 

func (m *RemoveRemoteClusterRequest) GetClusterName() string

func (*RemoveRemoteClusterRequest) GoString added in v1.9.0 

func (this *RemoveRemoteClusterRequest) GoString() string

func (*RemoveRemoteClusterRequest) Marshal added in v1.9.0 

func (m *RemoveRemoteClusterRequest) Marshal() (dAtA []byte, err error)

func (*RemoveRemoteClusterRequest) MarshalTo added in v1.9.0 

func (m *RemoveRemoteClusterRequest) MarshalTo(dAtA []byte) (int, error)

func (*RemoveRemoteClusterRequest) MarshalToSizedBuffer added in v1.9.0 

func (m *RemoveRemoteClusterRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RemoveRemoteClusterRequest) ProtoMessage added in v1.9.0 

func (*RemoveRemoteClusterRequest) ProtoMessage()

func (*RemoveRemoteClusterRequest) Reset added in v1.9.0 

func (m *RemoveRemoteClusterRequest) Reset()

func (*RemoveRemoteClusterRequest) Size added in v1.9.0 

func (m *RemoveRemoteClusterRequest) Size() (n int)

func (*RemoveRemoteClusterRequest) String added in v1.9.0 

func (this *RemoveRemoteClusterRequest) String() string

func (*RemoveRemoteClusterRequest) Unmarshal added in v1.9.0 

func (m *RemoveRemoteClusterRequest) Unmarshal(dAtA []byte) error

func (*RemoveRemoteClusterRequest) XXX_DiscardUnknown added in v1.9.0 

func (m *RemoveRemoteClusterRequest) XXX_DiscardUnknown()

func (*RemoveRemoteClusterRequest) XXX_Marshal added in v1.9.0 

func (m *RemoveRemoteClusterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RemoveRemoteClusterRequest) XXX_Merge added in v1.9.0 

func (m *RemoveRemoteClusterRequest) XXX_Merge(src proto.Message)

func (*RemoveRemoteClusterRequest) XXX_Size added in v1.9.0 

func (m *RemoveRemoteClusterRequest) XXX_Size() int

func (*RemoveRemoteClusterRequest) XXX_Unmarshal added in v1.9.0 

func (m *RemoveRemoteClusterRequest) XXX_Unmarshal(b []byte) error

type RemoveRemoteClusterResponse added in v1.9.0 

type RemoveRemoteClusterResponse struct {
}

func (*RemoveRemoteClusterResponse) Descriptor added in v1.9.0 

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

func (*RemoveRemoteClusterResponse) Equal added in v1.9.0 

func (this *RemoveRemoteClusterResponse) Equal(that interface{}) bool

func (*RemoveRemoteClusterResponse) GoString added in v1.9.0 

func (this *RemoveRemoteClusterResponse) GoString() string

func (*RemoveRemoteClusterResponse) Marshal added in v1.9.0 

func (m *RemoveRemoteClusterResponse) Marshal() (dAtA []byte, err error)

func (*RemoveRemoteClusterResponse) MarshalTo added in v1.9.0 

func (m *RemoveRemoteClusterResponse) MarshalTo(dAtA []byte) (int, error)

func (*RemoveRemoteClusterResponse) MarshalToSizedBuffer added in v1.9.0 

func (m *RemoveRemoteClusterResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RemoveRemoteClusterResponse) ProtoMessage added in v1.9.0 

func (*RemoveRemoteClusterResponse) ProtoMessage()

func (*RemoveRemoteClusterResponse) Reset added in v1.9.0 

func (m *RemoveRemoteClusterResponse) Reset()

func (*RemoveRemoteClusterResponse) Size added in v1.9.0 

func (m *RemoveRemoteClusterResponse) Size() (n int)

func (*RemoveRemoteClusterResponse) String added in v1.9.0 

func (this *RemoveRemoteClusterResponse) String() string

func (*RemoveRemoteClusterResponse) Unmarshal added in v1.9.0 

func (m *RemoveRemoteClusterResponse) Unmarshal(dAtA []byte) error

func (*RemoveRemoteClusterResponse) XXX_DiscardUnknown added in v1.9.0 

func (m *RemoveRemoteClusterResponse) XXX_DiscardUnknown()

func (*RemoveRemoteClusterResponse) XXX_Marshal added in v1.9.0 

func (m *RemoveRemoteClusterResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RemoveRemoteClusterResponse) XXX_Merge added in v1.9.0 

func (m *RemoveRemoteClusterResponse) XXX_Merge(src proto.Message)

func (*RemoveRemoteClusterResponse) XXX_Size added in v1.9.0 

func (m *RemoveRemoteClusterResponse) XXX_Size() int

func (*RemoveRemoteClusterResponse) XXX_Unmarshal added in v1.9.0 

func (m *RemoveRemoteClusterResponse) XXX_Unmarshal(b []byte) error

type RemoveSearchAttributesRequest 

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"`
}

func (*RemoveSearchAttributesRequest) Descriptor 

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

func (*RemoveSearchAttributesRequest) Equal 

func (this *RemoveSearchAttributesRequest) Equal(that interface{}) bool

func (*RemoveSearchAttributesRequest) GetNamespace added in v1.16.0 

func (m *RemoveSearchAttributesRequest) GetNamespace() string

func (*RemoveSearchAttributesRequest) GetSearchAttributes 

func (m *RemoveSearchAttributesRequest) GetSearchAttributes() []string

func (*RemoveSearchAttributesRequest) GoString 

func (this *RemoveSearchAttributesRequest) GoString() string

func (*RemoveSearchAttributesRequest) Marshal 

func (m *RemoveSearchAttributesRequest) Marshal() (dAtA []byte, err error)

func (*RemoveSearchAttributesRequest) MarshalTo 

func (m *RemoveSearchAttributesRequest) MarshalTo(dAtA []byte) (int, error)

func (*RemoveSearchAttributesRequest) MarshalToSizedBuffer 

func (m *RemoveSearchAttributesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RemoveSearchAttributesRequest) ProtoMessage 

func (*RemoveSearchAttributesRequest) ProtoMessage()

func (*RemoveSearchAttributesRequest) Reset 

func (m *RemoveSearchAttributesRequest) Reset()

func (*RemoveSearchAttributesRequest) Size 

func (m *RemoveSearchAttributesRequest) Size() (n int)

func (*RemoveSearchAttributesRequest) String 

func (this *RemoveSearchAttributesRequest) String() string

func (*RemoveSearchAttributesRequest) Unmarshal 

func (m *RemoveSearchAttributesRequest) Unmarshal(dAtA []byte) error

func (*RemoveSearchAttributesRequest) XXX_DiscardUnknown 

func (m *RemoveSearchAttributesRequest) XXX_DiscardUnknown()

func (*RemoveSearchAttributesRequest) XXX_Marshal 

func (m *RemoveSearchAttributesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RemoveSearchAttributesRequest) XXX_Merge 

func (m *RemoveSearchAttributesRequest) XXX_Merge(src proto.Message)

func (*RemoveSearchAttributesRequest) XXX_Size 

func (m *RemoveSearchAttributesRequest) XXX_Size() int

func (*RemoveSearchAttributesRequest) XXX_Unmarshal 

func (m *RemoveSearchAttributesRequest) XXX_Unmarshal(b []byte) error

type RemoveSearchAttributesResponse 

type RemoveSearchAttributesResponse struct {
}

func (*RemoveSearchAttributesResponse) Descriptor 

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

func (*RemoveSearchAttributesResponse) Equal 

func (this *RemoveSearchAttributesResponse) Equal(that interface{}) bool

func (*RemoveSearchAttributesResponse) GoString 

func (this *RemoveSearchAttributesResponse) GoString() string

func (*RemoveSearchAttributesResponse) Marshal 

func (m *RemoveSearchAttributesResponse) Marshal() (dAtA []byte, err error)

func (*RemoveSearchAttributesResponse) MarshalTo 

func (m *RemoveSearchAttributesResponse) MarshalTo(dAtA []byte) (int, error)

func (*RemoveSearchAttributesResponse) MarshalToSizedBuffer 

func (m *RemoveSearchAttributesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RemoveSearchAttributesResponse) ProtoMessage 

func (*RemoveSearchAttributesResponse) ProtoMessage()

func (*RemoveSearchAttributesResponse) Reset 

func (m *RemoveSearchAttributesResponse) Reset()

func (*RemoveSearchAttributesResponse) Size 

func (m *RemoveSearchAttributesResponse) Size() (n int)

func (*RemoveSearchAttributesResponse) String 

func (this *RemoveSearchAttributesResponse) String() string

func (*RemoveSearchAttributesResponse) Unmarshal 

func (m *RemoveSearchAttributesResponse) Unmarshal(dAtA []byte) error

func (*RemoveSearchAttributesResponse) XXX_DiscardUnknown 

func (m *RemoveSearchAttributesResponse) XXX_DiscardUnknown()

func (*RemoveSearchAttributesResponse) XXX_Marshal 

func (m *RemoveSearchAttributesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RemoveSearchAttributesResponse) XXX_Merge 

func (m *RemoveSearchAttributesResponse) XXX_Merge(src proto.Message)

func (*RemoveSearchAttributesResponse) XXX_Size 

func (m *RemoveSearchAttributesResponse) XXX_Size() int

func (*RemoveSearchAttributesResponse) XXX_Unmarshal 

func (m *RemoveSearchAttributesResponse) XXX_Unmarshal(b []byte) error

type UnimplementedOperatorServiceServer 

type UnimplementedOperatorServiceServer struct {
}

UnimplementedOperatorServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedOperatorServiceServer) AddOrUpdateRemoteCluster added in v1.9.0 

func (*UnimplementedOperatorServiceServer) AddOrUpdateRemoteCluster(ctx context.Context, req *AddOrUpdateRemoteClusterRequest) (*AddOrUpdateRemoteClusterResponse, error)

func (*UnimplementedOperatorServiceServer) AddSearchAttributes 

func (*UnimplementedOperatorServiceServer) AddSearchAttributes(ctx context.Context, req *AddSearchAttributesRequest) (*AddSearchAttributesResponse, error)

func (*UnimplementedOperatorServiceServer) DeleteNamespace 

func (*UnimplementedOperatorServiceServer) DeleteNamespace(ctx context.Context, req *DeleteNamespaceRequest) (*DeleteNamespaceResponse, error)

func (*UnimplementedOperatorServiceServer) ListClusters added in v1.9.0 

func (*UnimplementedOperatorServiceServer) ListClusters(ctx context.Context, req *ListClustersRequest) (*ListClustersResponse, error)

func (*UnimplementedOperatorServiceServer) ListSearchAttributes 

func (*UnimplementedOperatorServiceServer) ListSearchAttributes(ctx context.Context, req *ListSearchAttributesRequest) (*ListSearchAttributesResponse, error)

func (*UnimplementedOperatorServiceServer) RemoveRemoteCluster added in v1.9.0 

func (*UnimplementedOperatorServiceServer) RemoveRemoteCluster(ctx context.Context, req *RemoveRemoteClusterRequest) (*RemoveRemoteClusterResponse, error)

func (*UnimplementedOperatorServiceServer) RemoveSearchAttributes 

func (*UnimplementedOperatorServiceServer) RemoveSearchAttributes(ctx context.Context, req *RemoveSearchAttributesRequest) (*RemoveSearchAttributesResponse, error)

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.