operatorservice

package
v1.29.2 Latest Latest
Warning

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

Go to latest
Published: Mar 11, 2024 License: MIT Imports: 20 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"
	OperatorService_GetNexusIncomingService_FullMethodName            = "/temporal.api.operatorservice.v1.OperatorService/GetNexusIncomingService"
	OperatorService_CreateOrUpdateNexusIncomingService_FullMethodName = "/temporal.api.operatorservice.v1.OperatorService/CreateOrUpdateNexusIncomingService"
	OperatorService_DeleteNexusIncomingService_FullMethodName         = "/temporal.api.operatorservice.v1.OperatorService/DeleteNexusIncomingService"
	OperatorService_ListNexusIncomingServices_FullMethodName          = "/temporal.api.operatorservice.v1.OperatorService/ListNexusIncomingServices"
)

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,
		},
		{
			MethodName: "GetNexusIncomingService",
			Handler:    _OperatorService_GetNexusIncomingService_Handler,
		},
		{
			MethodName: "CreateOrUpdateNexusIncomingService",
			Handler:    _OperatorService_CreateOrUpdateNexusIncomingService_Handler,
		},
		{
			MethodName: "DeleteNexusIncomingService",
			Handler:    _OperatorService_DeleteNexusIncomingService_Handler,
		},
		{
			MethodName: "ListNexusIncomingServices",
			Handler:    _OperatorService_ListNexusIncomingServices_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 (*AddOrUpdateRemoteClusterRequest) Reset added in v1.9.0

func (*AddOrUpdateRemoteClusterRequest) Size added in v1.9.0

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

func (*AddOrUpdateRemoteClusterRequest) String added in v1.9.0

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 (*AddOrUpdateRemoteClusterResponse) Reset added in v1.9.0

func (*AddOrUpdateRemoteClusterResponse) Size added in v1.9.0

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

func (*AddOrUpdateRemoteClusterResponse) String added in v1.9.0

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 (*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 (*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 CreateOrUpdateNexusIncomingServiceRequest added in v1.27.0

type CreateOrUpdateNexusIncomingServiceRequest struct {

	// Data version for this service. Must match current version on update or set to 0 to create a new service.
	Version int64 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	// Service name, unique for this cluster.
	// The service name is used to address this service.
	// By default, when using Nexus over HTTP, the service name is matched against the base URL path.
	// E.g. the URL /api/v1/services/my-service/ would match a service named "my-service".
	// The name must match `[a-zA-Z_][a-zA-Z0-9_]*`.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Namespace to route requests to.
	TargetNamespace string `protobuf:"bytes,3,opt,name=target_namespace,json=targetNamespace,proto3" json:"target_namespace,omitempty"`
	// Task queue to route requests to.
	TargetTaskQueue string `protobuf:"bytes,4,opt,name=target_task_queue,json=targetTaskQueue,proto3" json:"target_task_queue,omitempty"`
	// Generic service metadata that is available to the server's authorizer.
	Metadata map[string]*anypb.Any `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

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

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

func (*CreateOrUpdateNexusIncomingServiceRequest) Descriptor deprecated added in v1.27.0

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

Deprecated: Use CreateOrUpdateNexusIncomingServiceRequest.ProtoReflect.Descriptor instead.

func (*CreateOrUpdateNexusIncomingServiceRequest) Equal added in v1.27.0

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

Equal returns whether two CreateOrUpdateNexusIncomingServiceRequest 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 (*CreateOrUpdateNexusIncomingServiceRequest) GetMetadata added in v1.29.1

func (*CreateOrUpdateNexusIncomingServiceRequest) GetName added in v1.29.1

func (*CreateOrUpdateNexusIncomingServiceRequest) GetTargetNamespace added in v1.29.2

func (x *CreateOrUpdateNexusIncomingServiceRequest) GetTargetNamespace() string

func (*CreateOrUpdateNexusIncomingServiceRequest) GetTargetTaskQueue added in v1.29.2

func (x *CreateOrUpdateNexusIncomingServiceRequest) GetTargetTaskQueue() string

func (*CreateOrUpdateNexusIncomingServiceRequest) GetVersion added in v1.29.1

func (*CreateOrUpdateNexusIncomingServiceRequest) Marshal added in v1.27.0

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

func (*CreateOrUpdateNexusIncomingServiceRequest) ProtoMessage added in v1.27.0

func (*CreateOrUpdateNexusIncomingServiceRequest) ProtoReflect added in v1.27.0

func (*CreateOrUpdateNexusIncomingServiceRequest) Reset added in v1.27.0

func (*CreateOrUpdateNexusIncomingServiceRequest) Size added in v1.27.0

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

func (*CreateOrUpdateNexusIncomingServiceRequest) String added in v1.27.0

func (*CreateOrUpdateNexusIncomingServiceRequest) Unmarshal added in v1.27.0

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

type CreateOrUpdateNexusIncomingServiceResponse added in v1.27.0

type CreateOrUpdateNexusIncomingServiceResponse struct {

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

func (*CreateOrUpdateNexusIncomingServiceResponse) Descriptor deprecated added in v1.27.0

Deprecated: Use CreateOrUpdateNexusIncomingServiceResponse.ProtoReflect.Descriptor instead.

func (*CreateOrUpdateNexusIncomingServiceResponse) Equal added in v1.27.0

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

Equal returns whether two CreateOrUpdateNexusIncomingServiceResponse 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 (*CreateOrUpdateNexusIncomingServiceResponse) GetService added in v1.27.0

func (*CreateOrUpdateNexusIncomingServiceResponse) Marshal added in v1.27.0

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

func (*CreateOrUpdateNexusIncomingServiceResponse) ProtoMessage added in v1.27.0

func (*CreateOrUpdateNexusIncomingServiceResponse) ProtoReflect added in v1.27.0

func (*CreateOrUpdateNexusIncomingServiceResponse) Reset added in v1.27.0

func (*CreateOrUpdateNexusIncomingServiceResponse) Size added in v1.27.0

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

func (*CreateOrUpdateNexusIncomingServiceResponse) String added in v1.27.0

func (*CreateOrUpdateNexusIncomingServiceResponse) Unmarshal added in v1.27.0

Unmarshal an object of type CreateOrUpdateNexusIncomingServiceResponse 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"`
	// 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
}

(-- 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) GetNamespaceDeleteDelay added in v1.27.0

func (x *DeleteNamespaceRequest) GetNamespaceDeleteDelay() *durationpb.Duration

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 DeleteNexusIncomingServiceRequest added in v1.27.0

type DeleteNexusIncomingServiceRequest struct {

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

func (*DeleteNexusIncomingServiceRequest) Descriptor deprecated added in v1.27.0

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

Deprecated: Use DeleteNexusIncomingServiceRequest.ProtoReflect.Descriptor instead.

func (*DeleteNexusIncomingServiceRequest) Equal added in v1.27.0

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

Equal returns whether two DeleteNexusIncomingServiceRequest 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 (*DeleteNexusIncomingServiceRequest) GetName added in v1.27.0

func (*DeleteNexusIncomingServiceRequest) Marshal added in v1.27.0

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

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

func (*DeleteNexusIncomingServiceRequest) ProtoMessage added in v1.27.0

func (*DeleteNexusIncomingServiceRequest) ProtoMessage()

func (*DeleteNexusIncomingServiceRequest) ProtoReflect added in v1.27.0

func (*DeleteNexusIncomingServiceRequest) Reset added in v1.27.0

func (*DeleteNexusIncomingServiceRequest) Size added in v1.27.0

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

func (*DeleteNexusIncomingServiceRequest) String added in v1.27.0

func (*DeleteNexusIncomingServiceRequest) Unmarshal added in v1.27.0

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

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

type DeleteNexusIncomingServiceResponse added in v1.27.0

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

func (*DeleteNexusIncomingServiceResponse) Descriptor deprecated added in v1.27.0

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

Deprecated: Use DeleteNexusIncomingServiceResponse.ProtoReflect.Descriptor instead.

func (*DeleteNexusIncomingServiceResponse) Equal added in v1.27.0

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

Equal returns whether two DeleteNexusIncomingServiceResponse 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 (*DeleteNexusIncomingServiceResponse) Marshal added in v1.27.0

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

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

func (*DeleteNexusIncomingServiceResponse) ProtoMessage added in v1.27.0

func (*DeleteNexusIncomingServiceResponse) ProtoMessage()

func (*DeleteNexusIncomingServiceResponse) ProtoReflect added in v1.27.0

func (*DeleteNexusIncomingServiceResponse) Reset added in v1.27.0

func (*DeleteNexusIncomingServiceResponse) Size added in v1.27.0

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

func (*DeleteNexusIncomingServiceResponse) String added in v1.27.0

func (*DeleteNexusIncomingServiceResponse) Unmarshal added in v1.27.0

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

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

type GetNexusIncomingServiceRequest added in v1.27.0

type GetNexusIncomingServiceRequest struct {

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

func (*GetNexusIncomingServiceRequest) Descriptor deprecated added in v1.27.0

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

Deprecated: Use GetNexusIncomingServiceRequest.ProtoReflect.Descriptor instead.

func (*GetNexusIncomingServiceRequest) Equal added in v1.27.0

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

Equal returns whether two GetNexusIncomingServiceRequest 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 (*GetNexusIncomingServiceRequest) GetName added in v1.27.0

func (*GetNexusIncomingServiceRequest) Marshal added in v1.27.0

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

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

func (*GetNexusIncomingServiceRequest) ProtoMessage added in v1.27.0

func (*GetNexusIncomingServiceRequest) ProtoMessage()

func (*GetNexusIncomingServiceRequest) ProtoReflect added in v1.27.0

func (*GetNexusIncomingServiceRequest) Reset added in v1.27.0

func (x *GetNexusIncomingServiceRequest) Reset()

func (*GetNexusIncomingServiceRequest) Size added in v1.27.0

func (val *GetNexusIncomingServiceRequest) Size() int

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

func (*GetNexusIncomingServiceRequest) String added in v1.27.0

func (*GetNexusIncomingServiceRequest) Unmarshal added in v1.27.0

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

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

type GetNexusIncomingServiceResponse added in v1.27.0

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

func (*GetNexusIncomingServiceResponse) Descriptor deprecated added in v1.27.0

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

Deprecated: Use GetNexusIncomingServiceResponse.ProtoReflect.Descriptor instead.

func (*GetNexusIncomingServiceResponse) Equal added in v1.27.0

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

Equal returns whether two GetNexusIncomingServiceResponse 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 (*GetNexusIncomingServiceResponse) GetService added in v1.27.0

func (*GetNexusIncomingServiceResponse) Marshal added in v1.27.0

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

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

func (*GetNexusIncomingServiceResponse) ProtoMessage added in v1.27.0

func (*GetNexusIncomingServiceResponse) ProtoMessage()

func (*GetNexusIncomingServiceResponse) ProtoReflect added in v1.27.0

func (*GetNexusIncomingServiceResponse) Reset added in v1.27.0

func (*GetNexusIncomingServiceResponse) Size added in v1.27.0

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

func (*GetNexusIncomingServiceResponse) String added in v1.27.0

func (*GetNexusIncomingServiceResponse) Unmarshal added in v1.27.0

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

Unmarshal an object of type GetNexusIncomingServiceResponse 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 ListNexusIncomingServicesRequest added in v1.27.0

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

func (*ListNexusIncomingServicesRequest) Descriptor deprecated added in v1.27.0

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

Deprecated: Use ListNexusIncomingServicesRequest.ProtoReflect.Descriptor instead.

func (*ListNexusIncomingServicesRequest) Equal added in v1.27.0

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

Equal returns whether two ListNexusIncomingServicesRequest 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 (*ListNexusIncomingServicesRequest) GetNextPageToken added in v1.27.0

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

func (*ListNexusIncomingServicesRequest) GetPageSize added in v1.27.0

func (x *ListNexusIncomingServicesRequest) GetPageSize() int32

func (*ListNexusIncomingServicesRequest) Marshal added in v1.27.0

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

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

func (*ListNexusIncomingServicesRequest) ProtoMessage added in v1.27.0

func (*ListNexusIncomingServicesRequest) ProtoMessage()

func (*ListNexusIncomingServicesRequest) ProtoReflect added in v1.27.0

func (*ListNexusIncomingServicesRequest) Reset added in v1.27.0

func (*ListNexusIncomingServicesRequest) Size added in v1.27.0

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

func (*ListNexusIncomingServicesRequest) String added in v1.27.0

func (*ListNexusIncomingServicesRequest) Unmarshal added in v1.27.0

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

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

type ListNexusIncomingServicesResponse added in v1.27.0

type ListNexusIncomingServicesResponse struct {

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

func (*ListNexusIncomingServicesResponse) Descriptor deprecated added in v1.27.0

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

Deprecated: Use ListNexusIncomingServicesResponse.ProtoReflect.Descriptor instead.

func (*ListNexusIncomingServicesResponse) Equal added in v1.27.0

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

Equal returns whether two ListNexusIncomingServicesResponse 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 (*ListNexusIncomingServicesResponse) GetNextPageToken added in v1.27.0

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

func (*ListNexusIncomingServicesResponse) GetServices added in v1.27.0

func (*ListNexusIncomingServicesResponse) Marshal added in v1.27.0

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

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

func (*ListNexusIncomingServicesResponse) ProtoMessage added in v1.27.0

func (*ListNexusIncomingServicesResponse) ProtoMessage()

func (*ListNexusIncomingServicesResponse) ProtoReflect added in v1.27.0

func (*ListNexusIncomingServicesResponse) Reset added in v1.27.0

func (*ListNexusIncomingServicesResponse) Size added in v1.27.0

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

func (*ListNexusIncomingServicesResponse) String added in v1.27.0

func (*ListNexusIncomingServicesResponse) Unmarshal added in v1.27.0

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

Unmarshal an object of type ListNexusIncomingServicesResponse 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 (*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 (*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 (*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)
	// Get a registered incoming Nexus service by name. The returned version can be used for optimistic updates.
	GetNexusIncomingService(ctx context.Context, in *GetNexusIncomingServiceRequest, opts ...grpc.CallOption) (*GetNexusIncomingServiceResponse, error)
	// Optimistically create or update a Nexus service based on provided version.
	// To update an existing service, get the current service record via the `GetNexusIncomingService` API, modify it
	// and submit to this API.
	// Set version to 0 to create a new service.
	// Returns the updated service with the updated version, which can be used for subsequent updates.
	CreateOrUpdateNexusIncomingService(ctx context.Context, in *CreateOrUpdateNexusIncomingServiceRequest, opts ...grpc.CallOption) (*CreateOrUpdateNexusIncomingServiceResponse, error)
	// Delete an incoming Nexus service by name.
	DeleteNexusIncomingService(ctx context.Context, in *DeleteNexusIncomingServiceRequest, opts ...grpc.CallOption) (*DeleteNexusIncomingServiceResponse, error)
	// List all Nexus incoming services in the cluster. Use next_page_token in the response for pagination.
	ListNexusIncomingServices(ctx context.Context, in *ListNexusIncomingServicesRequest, opts ...grpc.CallOption) (*ListNexusIncomingServicesResponse, 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.

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)
	// Get a registered incoming Nexus service by name. The returned version can be used for optimistic updates.
	GetNexusIncomingService(context.Context, *GetNexusIncomingServiceRequest) (*GetNexusIncomingServiceResponse, error)
	// Optimistically create or update a Nexus service based on provided version.
	// To update an existing service, get the current service record via the `GetNexusIncomingService` API, modify it
	// and submit to this API.
	// Set version to 0 to create a new service.
	// Returns the updated service with the updated version, which can be used for subsequent updates.
	CreateOrUpdateNexusIncomingService(context.Context, *CreateOrUpdateNexusIncomingServiceRequest) (*CreateOrUpdateNexusIncomingServiceResponse, error)
	// Delete an incoming Nexus service by name.
	DeleteNexusIncomingService(context.Context, *DeleteNexusIncomingServiceRequest) (*DeleteNexusIncomingServiceResponse, error)
	// List all Nexus incoming services in the cluster. Use next_page_token in the response for pagination.
	ListNexusIncomingServices(context.Context, *ListNexusIncomingServicesRequest) (*ListNexusIncomingServicesResponse, 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 (*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 (*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 (*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 (*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 (*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 (*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) AddSearchAttributes

func (UnimplementedOperatorServiceServer) CreateOrUpdateNexusIncomingService added in v1.27.0

func (UnimplementedOperatorServiceServer) DeleteNamespace

func (UnimplementedOperatorServiceServer) DeleteNexusIncomingService added in v1.27.0

func (UnimplementedOperatorServiceServer) GetNexusIncomingService added in v1.27.0

func (UnimplementedOperatorServiceServer) ListClusters added in v1.9.0

func (UnimplementedOperatorServiceServer) ListNexusIncomingServices added in v1.27.0

func (UnimplementedOperatorServiceServer) RemoveRemoteCluster added in v1.9.0

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL