operatorservice

package
v1.26.2 Latest Latest
Warning

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

 Go to latest Published: Dec 4, 2023 License: MIT Imports: 17 Imported by: 26

Documentation

Overview

Code generated by protoc-gen-go-helpers. DO NOT EDIT.

Package operatorservice is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	OperatorService_AddSearchAttributes_FullMethodName      = "/temporal.api.operatorservice.v1.OperatorService/AddSearchAttributes"
	OperatorService_RemoveSearchAttributes_FullMethodName   = "/temporal.api.operatorservice.v1.OperatorService/RemoveSearchAttributes"
	OperatorService_ListSearchAttributes_FullMethodName     = "/temporal.api.operatorservice.v1.OperatorService/ListSearchAttributes"
	OperatorService_DeleteNamespace_FullMethodName          = "/temporal.api.operatorservice.v1.OperatorService/DeleteNamespace"
	OperatorService_AddOrUpdateRemoteCluster_FullMethodName = "/temporal.api.operatorservice.v1.OperatorService/AddOrUpdateRemoteCluster"
	OperatorService_RemoveRemoteCluster_FullMethodName      = "/temporal.api.operatorservice.v1.OperatorService/RemoveRemoteCluster"
	OperatorService_ListClusters_FullMethodName             = "/temporal.api.operatorservice.v1.OperatorService/ListClusters"
)

Variables

View Source 
var File_temporal_api_operatorservice_v1_request_response_proto protoreflect.FileDescriptor
View Source 
var File_temporal_api_operatorservice_v1_service_proto protoreflect.FileDescriptor
View Source 
var OperatorService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "temporal.api.operatorservice.v1.OperatorService",
	HandlerType: (*OperatorServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "AddSearchAttributes",
			Handler:    _OperatorService_AddSearchAttributes_Handler,
		},
		{
			MethodName: "RemoveSearchAttributes",
			Handler:    _OperatorService_RemoveSearchAttributes_Handler,
		},
		{
			MethodName: "ListSearchAttributes",
			Handler:    _OperatorService_ListSearchAttributes_Handler,
		},
		{
			MethodName: "DeleteNamespace",
			Handler:    _OperatorService_DeleteNamespace_Handler,
		},
		{
			MethodName: "AddOrUpdateRemoteCluster",
			Handler:    _OperatorService_AddOrUpdateRemoteCluster_Handler,
		},
		{
			MethodName: "RemoveRemoteCluster",
			Handler:    _OperatorService_RemoveRemoteCluster_Handler,
		},
		{
			MethodName: "ListClusters",
			Handler:    _OperatorService_ListClusters_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "temporal/api/operatorservice/v1/service.proto",
}

OperatorService_ServiceDesc is the grpc.ServiceDesc for OperatorService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterOperatorServiceHandler added in v1.25.0 

func RegisterOperatorServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterOperatorServiceHandler registers the http handlers for service OperatorService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterOperatorServiceHandlerClient added in v1.25.0 

func RegisterOperatorServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client OperatorServiceClient) error

RegisterOperatorServiceHandlerClient registers the http handlers for service OperatorService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "OperatorServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "OperatorServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "OperatorServiceClient" to call the correct interceptors.

func RegisterOperatorServiceHandlerFromEndpoint added in v1.25.0 

func RegisterOperatorServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterOperatorServiceHandlerFromEndpoint is same as RegisterOperatorServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterOperatorServiceHandlerServer added in v1.25.0 

func RegisterOperatorServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server OperatorServiceServer) error

RegisterOperatorServiceHandlerServer registers the http handlers for service OperatorService to "mux". UnaryRPC :call OperatorServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterOperatorServiceHandlerFromEndpoint instead.

func RegisterOperatorServiceServer 

func RegisterOperatorServiceServer(s grpc.ServiceRegistrar, 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 */
	// contains filtered or unexported fields
}

func (*AddOrUpdateRemoteClusterRequest) Descriptor deprecated added in v1.9.0 

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

Deprecated: Use AddOrUpdateRemoteClusterRequest.ProtoReflect.Descriptor instead.

func (*AddOrUpdateRemoteClusterRequest) Equal added in v1.9.0 

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

Equal returns whether two AddOrUpdateRemoteClusterRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*AddOrUpdateRemoteClusterRequest) GetEnableRemoteClusterConnection added in v1.9.0 

func (x *AddOrUpdateRemoteClusterRequest) GetEnableRemoteClusterConnection() bool

func (*AddOrUpdateRemoteClusterRequest) GetFrontendAddress added in v1.9.0 

func (x *AddOrUpdateRemoteClusterRequest) GetFrontendAddress() string

func (*AddOrUpdateRemoteClusterRequest) Marshal added in v1.9.0 

func (val *AddOrUpdateRemoteClusterRequest) Marshal() ([]byte, error)

Marshal an object of type AddOrUpdateRemoteClusterRequest to the protobuf v3 wire format

func (*AddOrUpdateRemoteClusterRequest) ProtoMessage added in v1.9.0 

func (*AddOrUpdateRemoteClusterRequest) ProtoMessage()

func (*AddOrUpdateRemoteClusterRequest) ProtoReflect added in v1.26.1 

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

func (*AddOrUpdateRemoteClusterRequest) Reset added in v1.9.0 

func (x *AddOrUpdateRemoteClusterRequest) Reset()

func (*AddOrUpdateRemoteClusterRequest) Size added in v1.9.0 

func (val *AddOrUpdateRemoteClusterRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*AddOrUpdateRemoteClusterRequest) String added in v1.9.0 

func (x *AddOrUpdateRemoteClusterRequest) String() string

func (*AddOrUpdateRemoteClusterRequest) Unmarshal added in v1.9.0 

func (val *AddOrUpdateRemoteClusterRequest) Unmarshal(buf []byte) error

Unmarshal an object of type AddOrUpdateRemoteClusterRequest from the protobuf v3 wire format

type AddOrUpdateRemoteClusterResponse added in v1.9.0 

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

func (*AddOrUpdateRemoteClusterResponse) Descriptor deprecated added in v1.9.0 

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

Deprecated: Use AddOrUpdateRemoteClusterResponse.ProtoReflect.Descriptor instead.

func (*AddOrUpdateRemoteClusterResponse) Equal added in v1.9.0 

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

Equal returns whether two AddOrUpdateRemoteClusterResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*AddOrUpdateRemoteClusterResponse) Marshal added in v1.9.0 

func (val *AddOrUpdateRemoteClusterResponse) Marshal() ([]byte, error)

Marshal an object of type AddOrUpdateRemoteClusterResponse to the protobuf v3 wire format

func (*AddOrUpdateRemoteClusterResponse) ProtoMessage added in v1.9.0 

func (*AddOrUpdateRemoteClusterResponse) ProtoMessage()

func (*AddOrUpdateRemoteClusterResponse) ProtoReflect added in v1.26.1 

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

func (*AddOrUpdateRemoteClusterResponse) Reset added in v1.9.0 

func (x *AddOrUpdateRemoteClusterResponse) Reset()

func (*AddOrUpdateRemoteClusterResponse) Size added in v1.9.0 

func (val *AddOrUpdateRemoteClusterResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*AddOrUpdateRemoteClusterResponse) String added in v1.9.0 

func (x *AddOrUpdateRemoteClusterResponse) String() string

func (*AddOrUpdateRemoteClusterResponse) Unmarshal added in v1.9.0 

func (val *AddOrUpdateRemoteClusterResponse) Unmarshal(buf []byte) error

Unmarshal an object of type AddOrUpdateRemoteClusterResponse from the protobuf v3 wire format

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"`
	// contains filtered or unexported fields
}

func (*AddSearchAttributesRequest) Descriptor deprecated 

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

Deprecated: Use AddSearchAttributesRequest.ProtoReflect.Descriptor instead.

func (*AddSearchAttributesRequest) Equal 

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

Equal returns whether two AddSearchAttributesRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*AddSearchAttributesRequest) GetNamespace added in v1.16.0 

func (x *AddSearchAttributesRequest) GetNamespace() string

func (*AddSearchAttributesRequest) GetSearchAttributes 

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

func (*AddSearchAttributesRequest) Marshal 

func (val *AddSearchAttributesRequest) Marshal() ([]byte, error)

Marshal an object of type AddSearchAttributesRequest to the protobuf v3 wire format

func (*AddSearchAttributesRequest) ProtoMessage 

func (*AddSearchAttributesRequest) ProtoMessage()

func (*AddSearchAttributesRequest) ProtoReflect added in v1.26.1 

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

func (*AddSearchAttributesRequest) Reset 

func (x *AddSearchAttributesRequest) Reset()

func (*AddSearchAttributesRequest) Size 

func (val *AddSearchAttributesRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*AddSearchAttributesRequest) String 

func (x *AddSearchAttributesRequest) String() string

func (*AddSearchAttributesRequest) Unmarshal 

func (val *AddSearchAttributesRequest) Unmarshal(buf []byte) error

Unmarshal an object of type AddSearchAttributesRequest from the protobuf v3 wire format

type AddSearchAttributesResponse 

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

func (*AddSearchAttributesResponse) Descriptor deprecated 

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

Deprecated: Use AddSearchAttributesResponse.ProtoReflect.Descriptor instead.

func (*AddSearchAttributesResponse) Equal 

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

Equal returns whether two AddSearchAttributesResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*AddSearchAttributesResponse) Marshal 

func (val *AddSearchAttributesResponse) Marshal() ([]byte, error)

Marshal an object of type AddSearchAttributesResponse to the protobuf v3 wire format

func (*AddSearchAttributesResponse) ProtoMessage 

func (*AddSearchAttributesResponse) ProtoMessage()

func (*AddSearchAttributesResponse) ProtoReflect added in v1.26.1 

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

func (*AddSearchAttributesResponse) Reset 

func (x *AddSearchAttributesResponse) Reset()

func (*AddSearchAttributesResponse) Size 

func (val *AddSearchAttributesResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*AddSearchAttributesResponse) String 

func (x *AddSearchAttributesResponse) String() string

func (*AddSearchAttributesResponse) Unmarshal 

func (val *AddSearchAttributesResponse) Unmarshal(buf []byte) error

Unmarshal an object of type AddSearchAttributesResponse from the protobuf v3 wire format

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"`
	// contains filtered or unexported fields
}

func (*ClusterMetadata) Descriptor deprecated added in v1.12.0 

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

Deprecated: Use ClusterMetadata.ProtoReflect.Descriptor instead.

func (*ClusterMetadata) Equal added in v1.12.0 

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

Equal returns whether two ClusterMetadata values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*ClusterMetadata) GetAddress added in v1.12.0 

func (x *ClusterMetadata) GetAddress() string

func (*ClusterMetadata) GetClusterId added in v1.12.0 

func (x *ClusterMetadata) GetClusterId() string

func (*ClusterMetadata) GetClusterName added in v1.12.0 

func (x *ClusterMetadata) GetClusterName() string

func (*ClusterMetadata) GetHistoryShardCount added in v1.12.0 

func (x *ClusterMetadata) GetHistoryShardCount() int32

func (*ClusterMetadata) GetInitialFailoverVersion added in v1.12.0 

func (x *ClusterMetadata) GetInitialFailoverVersion() int64

func (*ClusterMetadata) GetIsConnectionEnabled added in v1.12.0 

func (x *ClusterMetadata) GetIsConnectionEnabled() bool

func (*ClusterMetadata) Marshal added in v1.12.0 

func (val *ClusterMetadata) Marshal() ([]byte, error)

Marshal an object of type ClusterMetadata to the protobuf v3 wire format

func (*ClusterMetadata) ProtoMessage added in v1.12.0 

func (*ClusterMetadata) ProtoMessage()

func (*ClusterMetadata) ProtoReflect added in v1.26.1 

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

func (*ClusterMetadata) Reset added in v1.12.0 

func (x *ClusterMetadata) Reset()

func (*ClusterMetadata) Size added in v1.12.0 

func (val *ClusterMetadata) Size() int

Size returns the size of the object, in bytes, once serialized

func (*ClusterMetadata) String added in v1.12.0 

func (x *ClusterMetadata) String() string

func (*ClusterMetadata) Unmarshal added in v1.12.0 

func (val *ClusterMetadata) Unmarshal(buf []byte) error

Unmarshal an object of type ClusterMetadata from the protobuf v3 wire format

type DeleteNamespaceRequest 

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"`
	// contains filtered or unexported fields
}

(-- 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 deprecated 

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

Deprecated: Use DeleteNamespaceRequest.ProtoReflect.Descriptor instead.

func (*DeleteNamespaceRequest) Equal 

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

Equal returns whether two DeleteNamespaceRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*DeleteNamespaceRequest) GetNamespace 

func (x *DeleteNamespaceRequest) GetNamespace() string

func (*DeleteNamespaceRequest) GetNamespaceId added in v1.25.0 

func (x *DeleteNamespaceRequest) GetNamespaceId() string

func (*DeleteNamespaceRequest) Marshal 

func (val *DeleteNamespaceRequest) Marshal() ([]byte, error)

Marshal an object of type DeleteNamespaceRequest to the protobuf v3 wire format

func (*DeleteNamespaceRequest) ProtoMessage 

func (*DeleteNamespaceRequest) ProtoMessage()

func (*DeleteNamespaceRequest) ProtoReflect added in v1.26.1 

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

func (*DeleteNamespaceRequest) Reset 

func (x *DeleteNamespaceRequest) Reset()

func (*DeleteNamespaceRequest) Size 

func (val *DeleteNamespaceRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*DeleteNamespaceRequest) String 

func (x *DeleteNamespaceRequest) String() string

func (*DeleteNamespaceRequest) Unmarshal 

func (val *DeleteNamespaceRequest) Unmarshal(buf []byte) error

Unmarshal an object of type DeleteNamespaceRequest from the protobuf v3 wire format

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"`
	// contains filtered or unexported fields
}

func (*DeleteNamespaceResponse) Descriptor deprecated 

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

Deprecated: Use DeleteNamespaceResponse.ProtoReflect.Descriptor instead.

func (*DeleteNamespaceResponse) Equal 

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

Equal returns whether two DeleteNamespaceResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*DeleteNamespaceResponse) GetDeletedNamespace 

func (x *DeleteNamespaceResponse) GetDeletedNamespace() string

func (*DeleteNamespaceResponse) Marshal 

func (val *DeleteNamespaceResponse) Marshal() ([]byte, error)

Marshal an object of type DeleteNamespaceResponse to the protobuf v3 wire format

func (*DeleteNamespaceResponse) ProtoMessage 

func (*DeleteNamespaceResponse) ProtoMessage()

func (*DeleteNamespaceResponse) ProtoReflect added in v1.26.1 

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

func (*DeleteNamespaceResponse) Reset 

func (x *DeleteNamespaceResponse) Reset()

func (*DeleteNamespaceResponse) Size 

func (val *DeleteNamespaceResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*DeleteNamespaceResponse) String 

func (x *DeleteNamespaceResponse) String() string

func (*DeleteNamespaceResponse) Unmarshal 

func (val *DeleteNamespaceResponse) Unmarshal(buf []byte) error

Unmarshal an object of type DeleteNamespaceResponse from the protobuf v3 wire format

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"`
	// contains filtered or unexported fields
}

func (*ListClustersRequest) Descriptor deprecated added in v1.9.0 

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

Deprecated: Use ListClustersRequest.ProtoReflect.Descriptor instead.

func (*ListClustersRequest) Equal added in v1.9.0 

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

Equal returns whether two ListClustersRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*ListClustersRequest) GetNextPageToken added in v1.9.0 

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

func (*ListClustersRequest) GetPageSize added in v1.9.0 

func (x *ListClustersRequest) GetPageSize() int32

func (*ListClustersRequest) Marshal added in v1.9.0 

func (val *ListClustersRequest) Marshal() ([]byte, error)

Marshal an object of type ListClustersRequest to the protobuf v3 wire format

func (*ListClustersRequest) ProtoMessage added in v1.9.0 

func (*ListClustersRequest) ProtoMessage()

func (*ListClustersRequest) ProtoReflect added in v1.26.1 

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

func (*ListClustersRequest) Reset added in v1.9.0 

func (x *ListClustersRequest) Reset()

func (*ListClustersRequest) Size added in v1.9.0 

func (val *ListClustersRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*ListClustersRequest) String added in v1.9.0 

func (x *ListClustersRequest) String() string

func (*ListClustersRequest) Unmarshal added in v1.9.0 

func (val *ListClustersRequest) Unmarshal(buf []byte) error

Unmarshal an object of type ListClustersRequest from the protobuf v3 wire format

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"`
	// contains filtered or unexported fields
}

func (*ListClustersResponse) Descriptor deprecated added in v1.9.0 

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

Deprecated: Use ListClustersResponse.ProtoReflect.Descriptor instead.

func (*ListClustersResponse) Equal added in v1.9.0 

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

Equal returns whether two ListClustersResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*ListClustersResponse) GetClusters added in v1.9.0 

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

func (*ListClustersResponse) GetNextPageToken added in v1.9.0 

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

func (*ListClustersResponse) Marshal added in v1.9.0 

func (val *ListClustersResponse) Marshal() ([]byte, error)

Marshal an object of type ListClustersResponse to the protobuf v3 wire format

func (*ListClustersResponse) ProtoMessage added in v1.9.0 

func (*ListClustersResponse) ProtoMessage()

func (*ListClustersResponse) ProtoReflect added in v1.26.1 

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

func (*ListClustersResponse) Reset added in v1.9.0 

func (x *ListClustersResponse) Reset()

func (*ListClustersResponse) Size added in v1.9.0 

func (val *ListClustersResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*ListClustersResponse) String added in v1.9.0 

func (x *ListClustersResponse) String() string

func (*ListClustersResponse) Unmarshal added in v1.9.0 

func (val *ListClustersResponse) Unmarshal(buf []byte) error

Unmarshal an object of type ListClustersResponse from the protobuf v3 wire format

type ListSearchAttributesRequest 

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

func (*ListSearchAttributesRequest) Descriptor deprecated 

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

Deprecated: Use ListSearchAttributesRequest.ProtoReflect.Descriptor instead.

func (*ListSearchAttributesRequest) Equal 

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

Equal returns whether two ListSearchAttributesRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*ListSearchAttributesRequest) GetNamespace added in v1.16.0 

func (x *ListSearchAttributesRequest) GetNamespace() string

func (*ListSearchAttributesRequest) Marshal 

func (val *ListSearchAttributesRequest) Marshal() ([]byte, error)

Marshal an object of type ListSearchAttributesRequest to the protobuf v3 wire format

func (*ListSearchAttributesRequest) ProtoMessage 

func (*ListSearchAttributesRequest) ProtoMessage()

func (*ListSearchAttributesRequest) ProtoReflect added in v1.26.1 

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

func (*ListSearchAttributesRequest) Reset 

func (x *ListSearchAttributesRequest) Reset()

func (*ListSearchAttributesRequest) Size 

func (val *ListSearchAttributesRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*ListSearchAttributesRequest) String 

func (x *ListSearchAttributesRequest) String() string

func (*ListSearchAttributesRequest) Unmarshal 

func (val *ListSearchAttributesRequest) Unmarshal(buf []byte) error

Unmarshal an object of type ListSearchAttributesRequest from the protobuf v3 wire format

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 */
	// contains filtered or unexported fields
}

func (*ListSearchAttributesResponse) Descriptor deprecated 

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

Deprecated: Use ListSearchAttributesResponse.ProtoReflect.Descriptor instead.

func (*ListSearchAttributesResponse) Equal 

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

Equal returns whether two ListSearchAttributesResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*ListSearchAttributesResponse) GetCustomAttributes 

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

func (*ListSearchAttributesResponse) GetStorageSchema 

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

func (*ListSearchAttributesResponse) GetSystemAttributes 

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

func (*ListSearchAttributesResponse) Marshal 

func (val *ListSearchAttributesResponse) Marshal() ([]byte, error)

Marshal an object of type ListSearchAttributesResponse to the protobuf v3 wire format

func (*ListSearchAttributesResponse) ProtoMessage 

func (*ListSearchAttributesResponse) ProtoMessage()

func (*ListSearchAttributesResponse) ProtoReflect added in v1.26.1 

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

func (*ListSearchAttributesResponse) Reset 

func (x *ListSearchAttributesResponse) Reset()

func (*ListSearchAttributesResponse) Size 

func (val *ListSearchAttributesResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*ListSearchAttributesResponse) String 

func (x *ListSearchAttributesResponse) String() string

func (*ListSearchAttributesResponse) Unmarshal 

func (val *ListSearchAttributesResponse) Unmarshal(buf []byte) error

Unmarshal an object of type ListSearchAttributesResponse from the protobuf v3 wire format

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://pkg.go.dev/google.golang.org/grpc/?tab=doc#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)
	// contains filtered or unexported methods
}

OperatorServiceServer is the server API for OperatorService service. All implementations must embed UnimplementedOperatorServiceServer for forward compatibility

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"`
	// contains filtered or unexported fields
}

func (*RemoveRemoteClusterRequest) Descriptor deprecated added in v1.9.0 

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

Deprecated: Use RemoveRemoteClusterRequest.ProtoReflect.Descriptor instead.

func (*RemoveRemoteClusterRequest) Equal added in v1.9.0 

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

Equal returns whether two RemoveRemoteClusterRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*RemoveRemoteClusterRequest) GetClusterName added in v1.9.0 

func (x *RemoveRemoteClusterRequest) GetClusterName() string

func (*RemoveRemoteClusterRequest) Marshal added in v1.9.0 

func (val *RemoveRemoteClusterRequest) Marshal() ([]byte, error)

Marshal an object of type RemoveRemoteClusterRequest to the protobuf v3 wire format

func (*RemoveRemoteClusterRequest) ProtoMessage added in v1.9.0 

func (*RemoveRemoteClusterRequest) ProtoMessage()

func (*RemoveRemoteClusterRequest) ProtoReflect added in v1.26.1 

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

func (*RemoveRemoteClusterRequest) Reset added in v1.9.0 

func (x *RemoveRemoteClusterRequest) Reset()

func (*RemoveRemoteClusterRequest) Size added in v1.9.0 

func (val *RemoveRemoteClusterRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*RemoveRemoteClusterRequest) String added in v1.9.0 

func (x *RemoveRemoteClusterRequest) String() string

func (*RemoveRemoteClusterRequest) Unmarshal added in v1.9.0 

func (val *RemoveRemoteClusterRequest) Unmarshal(buf []byte) error

Unmarshal an object of type RemoveRemoteClusterRequest from the protobuf v3 wire format

type RemoveRemoteClusterResponse added in v1.9.0 

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

func (*RemoveRemoteClusterResponse) Descriptor deprecated added in v1.9.0 

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

Deprecated: Use RemoveRemoteClusterResponse.ProtoReflect.Descriptor instead.

func (*RemoveRemoteClusterResponse) Equal added in v1.9.0 

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

Equal returns whether two RemoveRemoteClusterResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*RemoveRemoteClusterResponse) Marshal added in v1.9.0 

func (val *RemoveRemoteClusterResponse) Marshal() ([]byte, error)

Marshal an object of type RemoveRemoteClusterResponse to the protobuf v3 wire format

func (*RemoveRemoteClusterResponse) ProtoMessage added in v1.9.0 

func (*RemoveRemoteClusterResponse) ProtoMessage()

func (*RemoveRemoteClusterResponse) ProtoReflect added in v1.26.1 

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

func (*RemoveRemoteClusterResponse) Reset added in v1.9.0 

func (x *RemoveRemoteClusterResponse) Reset()

func (*RemoveRemoteClusterResponse) Size added in v1.9.0 

func (val *RemoveRemoteClusterResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*RemoveRemoteClusterResponse) String added in v1.9.0 

func (x *RemoveRemoteClusterResponse) String() string

func (*RemoveRemoteClusterResponse) Unmarshal added in v1.9.0 

func (val *RemoveRemoteClusterResponse) Unmarshal(buf []byte) error

Unmarshal an object of type RemoveRemoteClusterResponse from the protobuf v3 wire format

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"`
	// contains filtered or unexported fields
}

func (*RemoveSearchAttributesRequest) Descriptor deprecated 

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

Deprecated: Use RemoveSearchAttributesRequest.ProtoReflect.Descriptor instead.

func (*RemoveSearchAttributesRequest) Equal 

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

Equal returns whether two RemoveSearchAttributesRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*RemoveSearchAttributesRequest) GetNamespace added in v1.16.0 

func (x *RemoveSearchAttributesRequest) GetNamespace() string

func (*RemoveSearchAttributesRequest) GetSearchAttributes 

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

func (*RemoveSearchAttributesRequest) Marshal 

func (val *RemoveSearchAttributesRequest) Marshal() ([]byte, error)

Marshal an object of type RemoveSearchAttributesRequest to the protobuf v3 wire format

func (*RemoveSearchAttributesRequest) ProtoMessage 

func (*RemoveSearchAttributesRequest) ProtoMessage()

func (*RemoveSearchAttributesRequest) ProtoReflect added in v1.26.1 

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

func (*RemoveSearchAttributesRequest) Reset 

func (x *RemoveSearchAttributesRequest) Reset()

func (*RemoveSearchAttributesRequest) Size 

func (val *RemoveSearchAttributesRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*RemoveSearchAttributesRequest) String 

func (x *RemoveSearchAttributesRequest) String() string

func (*RemoveSearchAttributesRequest) Unmarshal 

func (val *RemoveSearchAttributesRequest) Unmarshal(buf []byte) error

Unmarshal an object of type RemoveSearchAttributesRequest from the protobuf v3 wire format

type RemoveSearchAttributesResponse 

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

func (*RemoveSearchAttributesResponse) Descriptor deprecated 

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

Deprecated: Use RemoveSearchAttributesResponse.ProtoReflect.Descriptor instead.

func (*RemoveSearchAttributesResponse) Equal 

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

Equal returns whether two RemoveSearchAttributesResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*RemoveSearchAttributesResponse) Marshal 

func (val *RemoveSearchAttributesResponse) Marshal() ([]byte, error)

Marshal an object of type RemoveSearchAttributesResponse to the protobuf v3 wire format

func (*RemoveSearchAttributesResponse) ProtoMessage 

func (*RemoveSearchAttributesResponse) ProtoMessage()

func (*RemoveSearchAttributesResponse) ProtoReflect added in v1.26.1 

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

func (*RemoveSearchAttributesResponse) Reset 

func (x *RemoveSearchAttributesResponse) Reset()

func (*RemoveSearchAttributesResponse) Size 

func (val *RemoveSearchAttributesResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*RemoveSearchAttributesResponse) String 

func (x *RemoveSearchAttributesResponse) String() string

func (*RemoveSearchAttributesResponse) Unmarshal 

func (val *RemoveSearchAttributesResponse) Unmarshal(buf []byte) error

Unmarshal an object of type RemoveSearchAttributesResponse from the protobuf v3 wire format

type UnimplementedOperatorServiceServer 

type UnimplementedOperatorServiceServer struct {
}

UnimplementedOperatorServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedOperatorServiceServer) AddOrUpdateRemoteCluster added in v1.9.0 

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

func (UnimplementedOperatorServiceServer) AddSearchAttributes 

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

func (UnimplementedOperatorServiceServer) DeleteNamespace 

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

func (UnimplementedOperatorServiceServer) ListClusters added in v1.9.0 

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

func (UnimplementedOperatorServiceServer) ListSearchAttributes 

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

func (UnimplementedOperatorServiceServer) RemoveRemoteCluster added in v1.9.0 

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

func (UnimplementedOperatorServiceServer) RemoveSearchAttributes 

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

type UnsafeOperatorServiceServer added in v1.26.1 

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

UnsafeOperatorServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to OperatorServiceServer will result in compilation errors.

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.