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
- Variables
- func RegisterOperatorServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterOperatorServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client OperatorServiceClient) error
- func RegisterOperatorServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterOperatorServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server OperatorServiceServer) error
- func RegisterOperatorServiceServer(s grpc.ServiceRegistrar, srv OperatorServiceServer)
- type AddOrUpdateRemoteClusterRequest
- func (*AddOrUpdateRemoteClusterRequest) Descriptor() ([]byte, []int)deprecated
- func (this *AddOrUpdateRemoteClusterRequest) Equal(that interface{}) bool
- func (x *AddOrUpdateRemoteClusterRequest) GetEnableRemoteClusterConnection() bool
- func (x *AddOrUpdateRemoteClusterRequest) GetFrontendAddress() string
- func (val *AddOrUpdateRemoteClusterRequest) Marshal() ([]byte, error)
- func (*AddOrUpdateRemoteClusterRequest) ProtoMessage()
- func (x *AddOrUpdateRemoteClusterRequest) ProtoReflect() protoreflect.Message
- func (x *AddOrUpdateRemoteClusterRequest) Reset()
- func (val *AddOrUpdateRemoteClusterRequest) Size() int
- func (x *AddOrUpdateRemoteClusterRequest) String() string
- func (val *AddOrUpdateRemoteClusterRequest) Unmarshal(buf []byte) error
- type AddOrUpdateRemoteClusterResponse
- func (*AddOrUpdateRemoteClusterResponse) Descriptor() ([]byte, []int)deprecated
- func (this *AddOrUpdateRemoteClusterResponse) Equal(that interface{}) bool
- func (val *AddOrUpdateRemoteClusterResponse) Marshal() ([]byte, error)
- func (*AddOrUpdateRemoteClusterResponse) ProtoMessage()
- func (x *AddOrUpdateRemoteClusterResponse) ProtoReflect() protoreflect.Message
- func (x *AddOrUpdateRemoteClusterResponse) Reset()
- func (val *AddOrUpdateRemoteClusterResponse) Size() int
- func (x *AddOrUpdateRemoteClusterResponse) String() string
- func (val *AddOrUpdateRemoteClusterResponse) Unmarshal(buf []byte) error
- type AddSearchAttributesRequest
- func (*AddSearchAttributesRequest) Descriptor() ([]byte, []int)deprecated
- func (this *AddSearchAttributesRequest) Equal(that interface{}) bool
- func (x *AddSearchAttributesRequest) GetNamespace() string
- func (x *AddSearchAttributesRequest) GetSearchAttributes() map[string]v1.IndexedValueType
- func (val *AddSearchAttributesRequest) Marshal() ([]byte, error)
- func (*AddSearchAttributesRequest) ProtoMessage()
- func (x *AddSearchAttributesRequest) ProtoReflect() protoreflect.Message
- func (x *AddSearchAttributesRequest) Reset()
- func (val *AddSearchAttributesRequest) Size() int
- func (x *AddSearchAttributesRequest) String() string
- func (val *AddSearchAttributesRequest) Unmarshal(buf []byte) error
- type AddSearchAttributesResponse
- func (*AddSearchAttributesResponse) Descriptor() ([]byte, []int)deprecated
- func (this *AddSearchAttributesResponse) Equal(that interface{}) bool
- func (val *AddSearchAttributesResponse) Marshal() ([]byte, error)
- func (*AddSearchAttributesResponse) ProtoMessage()
- func (x *AddSearchAttributesResponse) ProtoReflect() protoreflect.Message
- func (x *AddSearchAttributesResponse) Reset()
- func (val *AddSearchAttributesResponse) Size() int
- func (x *AddSearchAttributesResponse) String() string
- func (val *AddSearchAttributesResponse) Unmarshal(buf []byte) error
- type ClusterMetadata
- func (*ClusterMetadata) Descriptor() ([]byte, []int)deprecated
- func (this *ClusterMetadata) Equal(that interface{}) bool
- func (x *ClusterMetadata) GetAddress() string
- func (x *ClusterMetadata) GetClusterId() string
- func (x *ClusterMetadata) GetClusterName() string
- func (x *ClusterMetadata) GetHistoryShardCount() int32
- func (x *ClusterMetadata) GetInitialFailoverVersion() int64
- func (x *ClusterMetadata) GetIsConnectionEnabled() bool
- func (val *ClusterMetadata) Marshal() ([]byte, error)
- func (*ClusterMetadata) ProtoMessage()
- func (x *ClusterMetadata) ProtoReflect() protoreflect.Message
- func (x *ClusterMetadata) Reset()
- func (val *ClusterMetadata) Size() int
- func (x *ClusterMetadata) String() string
- func (val *ClusterMetadata) Unmarshal(buf []byte) error
- type CreateOrUpdateNexusIncomingServiceRequest
- func (*CreateOrUpdateNexusIncomingServiceRequest) Descriptor() ([]byte, []int)deprecated
- func (this *CreateOrUpdateNexusIncomingServiceRequest) Equal(that interface{}) bool
- func (x *CreateOrUpdateNexusIncomingServiceRequest) GetMetadata() map[string]*anypb.Any
- func (x *CreateOrUpdateNexusIncomingServiceRequest) GetName() string
- func (x *CreateOrUpdateNexusIncomingServiceRequest) GetTargetNamespace() string
- func (x *CreateOrUpdateNexusIncomingServiceRequest) GetTargetTaskQueue() string
- func (x *CreateOrUpdateNexusIncomingServiceRequest) GetVersion() int64
- func (val *CreateOrUpdateNexusIncomingServiceRequest) Marshal() ([]byte, error)
- func (*CreateOrUpdateNexusIncomingServiceRequest) ProtoMessage()
- func (x *CreateOrUpdateNexusIncomingServiceRequest) ProtoReflect() protoreflect.Message
- func (x *CreateOrUpdateNexusIncomingServiceRequest) Reset()
- func (val *CreateOrUpdateNexusIncomingServiceRequest) Size() int
- func (x *CreateOrUpdateNexusIncomingServiceRequest) String() string
- func (val *CreateOrUpdateNexusIncomingServiceRequest) Unmarshal(buf []byte) error
- type CreateOrUpdateNexusIncomingServiceResponse
- func (*CreateOrUpdateNexusIncomingServiceResponse) Descriptor() ([]byte, []int)deprecated
- func (this *CreateOrUpdateNexusIncomingServiceResponse) Equal(that interface{}) bool
- func (x *CreateOrUpdateNexusIncomingServiceResponse) GetService() *v11.IncomingService
- func (val *CreateOrUpdateNexusIncomingServiceResponse) Marshal() ([]byte, error)
- func (*CreateOrUpdateNexusIncomingServiceResponse) ProtoMessage()
- func (x *CreateOrUpdateNexusIncomingServiceResponse) ProtoReflect() protoreflect.Message
- func (x *CreateOrUpdateNexusIncomingServiceResponse) Reset()
- func (val *CreateOrUpdateNexusIncomingServiceResponse) Size() int
- func (x *CreateOrUpdateNexusIncomingServiceResponse) String() string
- func (val *CreateOrUpdateNexusIncomingServiceResponse) Unmarshal(buf []byte) error
- type DeleteNamespaceRequest
- func (*DeleteNamespaceRequest) Descriptor() ([]byte, []int)deprecated
- func (this *DeleteNamespaceRequest) Equal(that interface{}) bool
- func (x *DeleteNamespaceRequest) GetNamespace() string
- func (x *DeleteNamespaceRequest) GetNamespaceDeleteDelay() *durationpb.Duration
- func (x *DeleteNamespaceRequest) GetNamespaceId() string
- func (val *DeleteNamespaceRequest) Marshal() ([]byte, error)
- func (*DeleteNamespaceRequest) ProtoMessage()
- func (x *DeleteNamespaceRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteNamespaceRequest) Reset()
- func (val *DeleteNamespaceRequest) Size() int
- func (x *DeleteNamespaceRequest) String() string
- func (val *DeleteNamespaceRequest) Unmarshal(buf []byte) error
- type DeleteNamespaceResponse
- func (*DeleteNamespaceResponse) Descriptor() ([]byte, []int)deprecated
- func (this *DeleteNamespaceResponse) Equal(that interface{}) bool
- func (x *DeleteNamespaceResponse) GetDeletedNamespace() string
- func (val *DeleteNamespaceResponse) Marshal() ([]byte, error)
- func (*DeleteNamespaceResponse) ProtoMessage()
- func (x *DeleteNamespaceResponse) ProtoReflect() protoreflect.Message
- func (x *DeleteNamespaceResponse) Reset()
- func (val *DeleteNamespaceResponse) Size() int
- func (x *DeleteNamespaceResponse) String() string
- func (val *DeleteNamespaceResponse) Unmarshal(buf []byte) error
- type DeleteNexusIncomingServiceRequest
- func (*DeleteNexusIncomingServiceRequest) Descriptor() ([]byte, []int)deprecated
- func (this *DeleteNexusIncomingServiceRequest) Equal(that interface{}) bool
- func (x *DeleteNexusIncomingServiceRequest) GetName() string
- func (val *DeleteNexusIncomingServiceRequest) Marshal() ([]byte, error)
- func (*DeleteNexusIncomingServiceRequest) ProtoMessage()
- func (x *DeleteNexusIncomingServiceRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteNexusIncomingServiceRequest) Reset()
- func (val *DeleteNexusIncomingServiceRequest) Size() int
- func (x *DeleteNexusIncomingServiceRequest) String() string
- func (val *DeleteNexusIncomingServiceRequest) Unmarshal(buf []byte) error
- type DeleteNexusIncomingServiceResponse
- func (*DeleteNexusIncomingServiceResponse) Descriptor() ([]byte, []int)deprecated
- func (this *DeleteNexusIncomingServiceResponse) Equal(that interface{}) bool
- func (val *DeleteNexusIncomingServiceResponse) Marshal() ([]byte, error)
- func (*DeleteNexusIncomingServiceResponse) ProtoMessage()
- func (x *DeleteNexusIncomingServiceResponse) ProtoReflect() protoreflect.Message
- func (x *DeleteNexusIncomingServiceResponse) Reset()
- func (val *DeleteNexusIncomingServiceResponse) Size() int
- func (x *DeleteNexusIncomingServiceResponse) String() string
- func (val *DeleteNexusIncomingServiceResponse) Unmarshal(buf []byte) error
- type GetNexusIncomingServiceRequest
- func (*GetNexusIncomingServiceRequest) Descriptor() ([]byte, []int)deprecated
- func (this *GetNexusIncomingServiceRequest) Equal(that interface{}) bool
- func (x *GetNexusIncomingServiceRequest) GetName() string
- func (val *GetNexusIncomingServiceRequest) Marshal() ([]byte, error)
- func (*GetNexusIncomingServiceRequest) ProtoMessage()
- func (x *GetNexusIncomingServiceRequest) ProtoReflect() protoreflect.Message
- func (x *GetNexusIncomingServiceRequest) Reset()
- func (val *GetNexusIncomingServiceRequest) Size() int
- func (x *GetNexusIncomingServiceRequest) String() string
- func (val *GetNexusIncomingServiceRequest) Unmarshal(buf []byte) error
- type GetNexusIncomingServiceResponse
- func (*GetNexusIncomingServiceResponse) Descriptor() ([]byte, []int)deprecated
- func (this *GetNexusIncomingServiceResponse) Equal(that interface{}) bool
- func (x *GetNexusIncomingServiceResponse) GetService() *v11.IncomingService
- func (val *GetNexusIncomingServiceResponse) Marshal() ([]byte, error)
- func (*GetNexusIncomingServiceResponse) ProtoMessage()
- func (x *GetNexusIncomingServiceResponse) ProtoReflect() protoreflect.Message
- func (x *GetNexusIncomingServiceResponse) Reset()
- func (val *GetNexusIncomingServiceResponse) Size() int
- func (x *GetNexusIncomingServiceResponse) String() string
- func (val *GetNexusIncomingServiceResponse) Unmarshal(buf []byte) error
- type ListClustersRequest
- func (*ListClustersRequest) Descriptor() ([]byte, []int)deprecated
- func (this *ListClustersRequest) Equal(that interface{}) bool
- func (x *ListClustersRequest) GetNextPageToken() []byte
- func (x *ListClustersRequest) GetPageSize() int32
- func (val *ListClustersRequest) Marshal() ([]byte, error)
- func (*ListClustersRequest) ProtoMessage()
- func (x *ListClustersRequest) ProtoReflect() protoreflect.Message
- func (x *ListClustersRequest) Reset()
- func (val *ListClustersRequest) Size() int
- func (x *ListClustersRequest) String() string
- func (val *ListClustersRequest) Unmarshal(buf []byte) error
- type ListClustersResponse
- func (*ListClustersResponse) Descriptor() ([]byte, []int)deprecated
- func (this *ListClustersResponse) Equal(that interface{}) bool
- func (x *ListClustersResponse) GetClusters() []*ClusterMetadata
- func (x *ListClustersResponse) GetNextPageToken() []byte
- func (val *ListClustersResponse) Marshal() ([]byte, error)
- func (*ListClustersResponse) ProtoMessage()
- func (x *ListClustersResponse) ProtoReflect() protoreflect.Message
- func (x *ListClustersResponse) Reset()
- func (val *ListClustersResponse) Size() int
- func (x *ListClustersResponse) String() string
- func (val *ListClustersResponse) Unmarshal(buf []byte) error
- type ListNexusIncomingServicesRequest
- func (*ListNexusIncomingServicesRequest) Descriptor() ([]byte, []int)deprecated
- func (this *ListNexusIncomingServicesRequest) Equal(that interface{}) bool
- func (x *ListNexusIncomingServicesRequest) GetNextPageToken() []byte
- func (x *ListNexusIncomingServicesRequest) GetPageSize() int32
- func (val *ListNexusIncomingServicesRequest) Marshal() ([]byte, error)
- func (*ListNexusIncomingServicesRequest) ProtoMessage()
- func (x *ListNexusIncomingServicesRequest) ProtoReflect() protoreflect.Message
- func (x *ListNexusIncomingServicesRequest) Reset()
- func (val *ListNexusIncomingServicesRequest) Size() int
- func (x *ListNexusIncomingServicesRequest) String() string
- func (val *ListNexusIncomingServicesRequest) Unmarshal(buf []byte) error
- type ListNexusIncomingServicesResponse
- func (*ListNexusIncomingServicesResponse) Descriptor() ([]byte, []int)deprecated
- func (this *ListNexusIncomingServicesResponse) Equal(that interface{}) bool
- func (x *ListNexusIncomingServicesResponse) GetNextPageToken() []byte
- func (x *ListNexusIncomingServicesResponse) GetServices() []*v11.IncomingService
- func (val *ListNexusIncomingServicesResponse) Marshal() ([]byte, error)
- func (*ListNexusIncomingServicesResponse) ProtoMessage()
- func (x *ListNexusIncomingServicesResponse) ProtoReflect() protoreflect.Message
- func (x *ListNexusIncomingServicesResponse) Reset()
- func (val *ListNexusIncomingServicesResponse) Size() int
- func (x *ListNexusIncomingServicesResponse) String() string
- func (val *ListNexusIncomingServicesResponse) Unmarshal(buf []byte) error
- type ListSearchAttributesRequest
- func (*ListSearchAttributesRequest) Descriptor() ([]byte, []int)deprecated
- func (this *ListSearchAttributesRequest) Equal(that interface{}) bool
- func (x *ListSearchAttributesRequest) GetNamespace() string
- func (val *ListSearchAttributesRequest) Marshal() ([]byte, error)
- func (*ListSearchAttributesRequest) ProtoMessage()
- func (x *ListSearchAttributesRequest) ProtoReflect() protoreflect.Message
- func (x *ListSearchAttributesRequest) Reset()
- func (val *ListSearchAttributesRequest) Size() int
- func (x *ListSearchAttributesRequest) String() string
- func (val *ListSearchAttributesRequest) Unmarshal(buf []byte) error
- type ListSearchAttributesResponse
- func (*ListSearchAttributesResponse) Descriptor() ([]byte, []int)deprecated
- func (this *ListSearchAttributesResponse) Equal(that interface{}) bool
- func (x *ListSearchAttributesResponse) GetCustomAttributes() map[string]v1.IndexedValueType
- func (x *ListSearchAttributesResponse) GetStorageSchema() map[string]string
- func (x *ListSearchAttributesResponse) GetSystemAttributes() map[string]v1.IndexedValueType
- func (val *ListSearchAttributesResponse) Marshal() ([]byte, error)
- func (*ListSearchAttributesResponse) ProtoMessage()
- func (x *ListSearchAttributesResponse) ProtoReflect() protoreflect.Message
- func (x *ListSearchAttributesResponse) Reset()
- func (val *ListSearchAttributesResponse) Size() int
- func (x *ListSearchAttributesResponse) String() string
- func (val *ListSearchAttributesResponse) Unmarshal(buf []byte) error
- type OperatorServiceClient
- type OperatorServiceServer
- type RemoveRemoteClusterRequest
- func (*RemoveRemoteClusterRequest) Descriptor() ([]byte, []int)deprecated
- func (this *RemoveRemoteClusterRequest) Equal(that interface{}) bool
- func (x *RemoveRemoteClusterRequest) GetClusterName() string
- func (val *RemoveRemoteClusterRequest) Marshal() ([]byte, error)
- func (*RemoveRemoteClusterRequest) ProtoMessage()
- func (x *RemoveRemoteClusterRequest) ProtoReflect() protoreflect.Message
- func (x *RemoveRemoteClusterRequest) Reset()
- func (val *RemoveRemoteClusterRequest) Size() int
- func (x *RemoveRemoteClusterRequest) String() string
- func (val *RemoveRemoteClusterRequest) Unmarshal(buf []byte) error
- type RemoveRemoteClusterResponse
- func (*RemoveRemoteClusterResponse) Descriptor() ([]byte, []int)deprecated
- func (this *RemoveRemoteClusterResponse) Equal(that interface{}) bool
- func (val *RemoveRemoteClusterResponse) Marshal() ([]byte, error)
- func (*RemoveRemoteClusterResponse) ProtoMessage()
- func (x *RemoveRemoteClusterResponse) ProtoReflect() protoreflect.Message
- func (x *RemoveRemoteClusterResponse) Reset()
- func (val *RemoveRemoteClusterResponse) Size() int
- func (x *RemoveRemoteClusterResponse) String() string
- func (val *RemoveRemoteClusterResponse) Unmarshal(buf []byte) error
- type RemoveSearchAttributesRequest
- func (*RemoveSearchAttributesRequest) Descriptor() ([]byte, []int)deprecated
- func (this *RemoveSearchAttributesRequest) Equal(that interface{}) bool
- func (x *RemoveSearchAttributesRequest) GetNamespace() string
- func (x *RemoveSearchAttributesRequest) GetSearchAttributes() []string
- func (val *RemoveSearchAttributesRequest) Marshal() ([]byte, error)
- func (*RemoveSearchAttributesRequest) ProtoMessage()
- func (x *RemoveSearchAttributesRequest) ProtoReflect() protoreflect.Message
- func (x *RemoveSearchAttributesRequest) Reset()
- func (val *RemoveSearchAttributesRequest) Size() int
- func (x *RemoveSearchAttributesRequest) String() string
- func (val *RemoveSearchAttributesRequest) Unmarshal(buf []byte) error
- type RemoveSearchAttributesResponse
- func (*RemoveSearchAttributesResponse) Descriptor() ([]byte, []int)deprecated
- func (this *RemoveSearchAttributesResponse) Equal(that interface{}) bool
- func (val *RemoveSearchAttributesResponse) Marshal() ([]byte, error)
- func (*RemoveSearchAttributesResponse) ProtoMessage()
- func (x *RemoveSearchAttributesResponse) ProtoReflect() protoreflect.Message
- func (x *RemoveSearchAttributesResponse) Reset()
- func (val *RemoveSearchAttributesResponse) Size() int
- func (x *RemoveSearchAttributesResponse) String() string
- func (val *RemoveSearchAttributesResponse) Unmarshal(buf []byte) error
- type UnimplementedOperatorServiceServer
- func (UnimplementedOperatorServiceServer) AddOrUpdateRemoteCluster(context.Context, *AddOrUpdateRemoteClusterRequest) (*AddOrUpdateRemoteClusterResponse, error)
- func (UnimplementedOperatorServiceServer) AddSearchAttributes(context.Context, *AddSearchAttributesRequest) (*AddSearchAttributesResponse, error)
- func (UnimplementedOperatorServiceServer) CreateOrUpdateNexusIncomingService(context.Context, *CreateOrUpdateNexusIncomingServiceRequest) (*CreateOrUpdateNexusIncomingServiceResponse, error)
- func (UnimplementedOperatorServiceServer) DeleteNamespace(context.Context, *DeleteNamespaceRequest) (*DeleteNamespaceResponse, error)
- func (UnimplementedOperatorServiceServer) DeleteNexusIncomingService(context.Context, *DeleteNexusIncomingServiceRequest) (*DeleteNexusIncomingServiceResponse, error)
- func (UnimplementedOperatorServiceServer) GetNexusIncomingService(context.Context, *GetNexusIncomingServiceRequest) (*GetNexusIncomingServiceResponse, error)
- func (UnimplementedOperatorServiceServer) ListClusters(context.Context, *ListClustersRequest) (*ListClustersResponse, error)
- func (UnimplementedOperatorServiceServer) ListNexusIncomingServices(context.Context, *ListNexusIncomingServicesRequest) (*ListNexusIncomingServicesResponse, error)
- func (UnimplementedOperatorServiceServer) ListSearchAttributes(context.Context, *ListSearchAttributesRequest) (*ListSearchAttributesResponse, error)
- func (UnimplementedOperatorServiceServer) RemoveRemoteCluster(context.Context, *RemoveRemoteClusterRequest) (*RemoveRemoteClusterResponse, error)
- func (UnimplementedOperatorServiceServer) RemoveSearchAttributes(context.Context, *RemoveSearchAttributesRequest) (*RemoveSearchAttributesResponse, error)
- type UnsafeOperatorServiceServer
Constants ¶
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 ¶
var File_temporal_api_operatorservice_v1_request_response_proto protoreflect.FileDescriptor
var File_temporal_api_operatorservice_v1_service_proto protoreflect.FileDescriptor
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 (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 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 (x *CreateOrUpdateNexusIncomingServiceRequest) GetMetadata() map[string]*anypb.Any
func (*CreateOrUpdateNexusIncomingServiceRequest) GetName ¶ added in v1.29.1
func (x *CreateOrUpdateNexusIncomingServiceRequest) GetName() string
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 (x *CreateOrUpdateNexusIncomingServiceRequest) GetVersion() int64
func (*CreateOrUpdateNexusIncomingServiceRequest) Marshal ¶ added in v1.27.0
func (val *CreateOrUpdateNexusIncomingServiceRequest) Marshal() ([]byte, error)
Marshal an object of type CreateOrUpdateNexusIncomingServiceRequest to the protobuf v3 wire format
func (*CreateOrUpdateNexusIncomingServiceRequest) ProtoMessage ¶ added in v1.27.0
func (*CreateOrUpdateNexusIncomingServiceRequest) ProtoMessage()
func (*CreateOrUpdateNexusIncomingServiceRequest) ProtoReflect ¶ added in v1.27.0
func (x *CreateOrUpdateNexusIncomingServiceRequest) ProtoReflect() protoreflect.Message
func (*CreateOrUpdateNexusIncomingServiceRequest) Reset ¶ added in v1.27.0
func (x *CreateOrUpdateNexusIncomingServiceRequest) Reset()
func (*CreateOrUpdateNexusIncomingServiceRequest) Size ¶ added in v1.27.0
func (val *CreateOrUpdateNexusIncomingServiceRequest) Size() int
Size returns the size of the object, in bytes, once serialized
func (*CreateOrUpdateNexusIncomingServiceRequest) String ¶ added in v1.27.0
func (x *CreateOrUpdateNexusIncomingServiceRequest) String() string
func (*CreateOrUpdateNexusIncomingServiceRequest) Unmarshal ¶ added in v1.27.0
func (val *CreateOrUpdateNexusIncomingServiceRequest) Unmarshal(buf []byte) error
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
func (*CreateOrUpdateNexusIncomingServiceResponse) Descriptor() ([]byte, []int)
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 (x *CreateOrUpdateNexusIncomingServiceResponse) GetService() *v11.IncomingService
func (*CreateOrUpdateNexusIncomingServiceResponse) Marshal ¶ added in v1.27.0
func (val *CreateOrUpdateNexusIncomingServiceResponse) Marshal() ([]byte, error)
Marshal an object of type CreateOrUpdateNexusIncomingServiceResponse to the protobuf v3 wire format
func (*CreateOrUpdateNexusIncomingServiceResponse) ProtoMessage ¶ added in v1.27.0
func (*CreateOrUpdateNexusIncomingServiceResponse) ProtoMessage()
func (*CreateOrUpdateNexusIncomingServiceResponse) ProtoReflect ¶ added in v1.27.0
func (x *CreateOrUpdateNexusIncomingServiceResponse) ProtoReflect() protoreflect.Message
func (*CreateOrUpdateNexusIncomingServiceResponse) Reset ¶ added in v1.27.0
func (x *CreateOrUpdateNexusIncomingServiceResponse) Reset()
func (*CreateOrUpdateNexusIncomingServiceResponse) Size ¶ added in v1.27.0
func (val *CreateOrUpdateNexusIncomingServiceResponse) Size() int
Size returns the size of the object, in bytes, once serialized
func (*CreateOrUpdateNexusIncomingServiceResponse) String ¶ added in v1.27.0
func (x *CreateOrUpdateNexusIncomingServiceResponse) String() string
func (*CreateOrUpdateNexusIncomingServiceResponse) Unmarshal ¶ added in v1.27.0
func (val *CreateOrUpdateNexusIncomingServiceResponse) Unmarshal(buf []byte) error
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 (x *DeleteNexusIncomingServiceRequest) GetName() string
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 (x *DeleteNexusIncomingServiceRequest) ProtoReflect() protoreflect.Message
func (*DeleteNexusIncomingServiceRequest) Reset ¶ added in v1.27.0
func (x *DeleteNexusIncomingServiceRequest) Reset()
func (*DeleteNexusIncomingServiceRequest) Size ¶ added in v1.27.0
func (val *DeleteNexusIncomingServiceRequest) Size() int
Size returns the size of the object, in bytes, once serialized
func (*DeleteNexusIncomingServiceRequest) String ¶ added in v1.27.0
func (x *DeleteNexusIncomingServiceRequest) String() string
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 (x *DeleteNexusIncomingServiceResponse) ProtoReflect() protoreflect.Message
func (*DeleteNexusIncomingServiceResponse) Reset ¶ added in v1.27.0
func (x *DeleteNexusIncomingServiceResponse) Reset()
func (*DeleteNexusIncomingServiceResponse) Size ¶ added in v1.27.0
func (val *DeleteNexusIncomingServiceResponse) Size() int
Size returns the size of the object, in bytes, once serialized
func (*DeleteNexusIncomingServiceResponse) String ¶ added in v1.27.0
func (x *DeleteNexusIncomingServiceResponse) String() string
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 (x *GetNexusIncomingServiceRequest) GetName() string
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 (x *GetNexusIncomingServiceRequest) ProtoReflect() protoreflect.Message
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 (x *GetNexusIncomingServiceRequest) String() string
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 (x *GetNexusIncomingServiceResponse) GetService() *v11.IncomingService
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 (x *GetNexusIncomingServiceResponse) ProtoReflect() protoreflect.Message
func (*GetNexusIncomingServiceResponse) Reset ¶ added in v1.27.0
func (x *GetNexusIncomingServiceResponse) Reset()
func (*GetNexusIncomingServiceResponse) Size ¶ added in v1.27.0
func (val *GetNexusIncomingServiceResponse) Size() int
Size returns the size of the object, in bytes, once serialized
func (*GetNexusIncomingServiceResponse) String ¶ added in v1.27.0
func (x *GetNexusIncomingServiceResponse) String() string
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 (x *ListNexusIncomingServicesRequest) ProtoReflect() protoreflect.Message
func (*ListNexusIncomingServicesRequest) Reset ¶ added in v1.27.0
func (x *ListNexusIncomingServicesRequest) Reset()
func (*ListNexusIncomingServicesRequest) Size ¶ added in v1.27.0
func (val *ListNexusIncomingServicesRequest) Size() int
Size returns the size of the object, in bytes, once serialized
func (*ListNexusIncomingServicesRequest) String ¶ added in v1.27.0
func (x *ListNexusIncomingServicesRequest) String() string
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 (x *ListNexusIncomingServicesResponse) GetServices() []*v11.IncomingService
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 (x *ListNexusIncomingServicesResponse) ProtoReflect() protoreflect.Message
func (*ListNexusIncomingServicesResponse) Reset ¶ added in v1.27.0
func (x *ListNexusIncomingServicesResponse) Reset()
func (*ListNexusIncomingServicesResponse) Size ¶ added in v1.27.0
func (val *ListNexusIncomingServicesResponse) Size() int
Size returns the size of the object, in bytes, once serialized
func (*ListNexusIncomingServicesResponse) String ¶ added in v1.27.0
func (x *ListNexusIncomingServicesResponse) String() string
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 (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) // 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.
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) // 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 (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) CreateOrUpdateNexusIncomingService ¶ added in v1.27.0
func (UnimplementedOperatorServiceServer) CreateOrUpdateNexusIncomingService(context.Context, *CreateOrUpdateNexusIncomingServiceRequest) (*CreateOrUpdateNexusIncomingServiceResponse, error)
func (UnimplementedOperatorServiceServer) DeleteNamespace ¶
func (UnimplementedOperatorServiceServer) DeleteNamespace(context.Context, *DeleteNamespaceRequest) (*DeleteNamespaceResponse, error)
func (UnimplementedOperatorServiceServer) DeleteNexusIncomingService ¶ added in v1.27.0
func (UnimplementedOperatorServiceServer) DeleteNexusIncomingService(context.Context, *DeleteNexusIncomingServiceRequest) (*DeleteNexusIncomingServiceResponse, error)
func (UnimplementedOperatorServiceServer) GetNexusIncomingService ¶ added in v1.27.0
func (UnimplementedOperatorServiceServer) GetNexusIncomingService(context.Context, *GetNexusIncomingServiceRequest) (*GetNexusIncomingServiceResponse, error)
func (UnimplementedOperatorServiceServer) ListClusters ¶ added in v1.9.0
func (UnimplementedOperatorServiceServer) ListClusters(context.Context, *ListClustersRequest) (*ListClustersResponse, error)
func (UnimplementedOperatorServiceServer) ListNexusIncomingServices ¶ added in v1.27.0
func (UnimplementedOperatorServiceServer) ListNexusIncomingServices(context.Context, *ListNexusIncomingServicesRequest) (*ListNexusIncomingServicesResponse, 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.