Skip to main content

Class: OperatorService

operatorservice.v1.OperatorService

OperatorService API defines how Temporal SDKs and other clients interact with the Temporal server to perform administrative functions like registering a search attribute or a namespace. APIs in this file could be not compatible with Temporal Cloud, hence it's usage in SDKs should be limited by designated APIs that clearly state that they shouldn't be used by the main Application (Workflows & Activities) framework.

Hierarchy​

  • Service

    ↳ OperatorService

Properties​

addOrUpdateRemoteCluster​

• addOrUpdateRemoteCluster: AddOrUpdateRemoteCluster

AddOrUpdateRemoteCluster adds or updates remote cluster.


addSearchAttributes​

• addSearchAttributes: AddSearchAttributes

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,


createNexusEndpoint​

• createNexusEndpoint: CreateNexusEndpoint

Create a Nexus endpoint. This will fail if an endpoint with the same name is already registered with a status of ALREADY_EXISTS. Returns the created endpoint with its initial version. You may use this version for subsequent updates.


deleteNamespace​

• deleteNamespace: DeleteNamespace

DeleteNamespace synchronously deletes a namespace and asynchronously reclaims all namespace resources.


deleteNexusEndpoint​

• deleteNexusEndpoint: DeleteNexusEndpoint

Delete an incoming Nexus service by ID.


getNexusEndpoint​

• getNexusEndpoint: GetNexusEndpoint

Get a registered Nexus endpoint by ID. The returned version can be used for optimistic updates.


listClusters​

• listClusters: ListClusters

ListClusters returns information about Temporal clusters.


listNexusEndpoints​

• listNexusEndpoints: ListNexusEndpoints

List all Nexus endpoints for the cluster, sorted by ID in ascending order. Set page_token in the request to the next_page_token field of the previous response to get the next page of results. An empty next_page_token indicates that there are no more results. During pagination, a newly added service with an ID lexicographically earlier than the previous page's last endpoint's ID may be missed.


listSearchAttributes​

• listSearchAttributes: ListSearchAttributes

ListSearchAttributes returns comprehensive information about search attributes.


removeRemoteCluster​

• removeRemoteCluster: RemoveRemoteCluster

RemoveRemoteCluster removes remote cluster.


removeSearchAttributes​

• removeSearchAttributes: RemoveSearchAttributes

RemoveSearchAttributes removes custom search attributes.

Returns NOT_FOUND status code if a Search Attribute with any of the specified names is not registered


requestDelimited​

• requestDelimited: boolean

Whether requests are length-delimited.

Inherited from​

$protobuf.rpc.Service.requestDelimited


responseDelimited​

• responseDelimited: boolean

Whether responses are length-delimited.

Inherited from​

$protobuf.rpc.Service.responseDelimited


rpcImpl​

• rpcImpl: null | RPCImpl

RPC implementation. Becomes null once the service is ended.

Inherited from​

$protobuf.rpc.Service.rpcImpl


updateNexusEndpoint​

• updateNexusEndpoint: UpdateNexusEndpoint

Optimistically update a Nexus endpoint based on provided version as obtained via the GetNexusEndpoint or ListNexusEndpointResponse APIs. This will fail with a status of FAILED_PRECONDITION if the version does not match. Returns the updated endpoint with its updated version. You may use this version for subsequent updates. You don't need to increment the version yourself. The server will increment the version for you after each update.

Methods​

emit​

▸ emit(evt, ...args): this

Emits an event by calling its listeners with the specified arguments.

Parameters​

NameTypeDescription
evtstringEvent name
...argsany[]Arguments

Returns​

this

this

Inherited from​

$protobuf.rpc.Service.emit


end​

▸ end(endedByRPC?): Service

Ends this service and emits the end event.

Parameters​

NameTypeDescription
endedByRPC?booleanWhether the service has been ended by the RPC implementation.

Returns​

Service

this

Inherited from​

$protobuf.rpc.Service.end


off​

▸ off(evt?, fn?): this

Removes an event listener or any matching listeners if arguments are omitted.

Parameters​

NameTypeDescription
evt?stringEvent name. Removes all listeners if omitted.
fn?EventEmitterListenerListener to remove. Removes all listeners of evt if omitted.

Returns​

this

this

Inherited from​

$protobuf.rpc.Service.off


on​

▸ on(evt, fn, ctx?): this

Registers an event listener.

Parameters​

NameTypeDescription
evtstringEvent name
fnEventEmitterListenerListener
ctx?anyListener context

Returns​

this

this

Inherited from​

$protobuf.rpc.Service.on


rpcCall​

▸ rpcCall<TReq, TRes>(method, requestCtor, responseCtor, request, callback): void

Calls a service method through rpcImpl.

Type parameters​

NameType
TReqextends Message<TReq>
TResextends Message<TRes>

Parameters​

NameTypeDescription
methodMethod | ServiceMethod<TReq, TRes>Reflected or static method
requestCtorConstructor<TReq>Request constructor
responseCtorConstructor<TRes>Response constructor
requestTReq | Properties<TReq>Request message or plain object
callbackServiceMethodCallback<TRes>Service callback

Returns​

void

Inherited from​

$protobuf.rpc.Service.rpcCall


create​

▸ create(rpcImpl, requestDelimited?, responseDelimited?): OperatorService

Creates new OperatorService service using the specified rpc implementation.

Parameters​

NameTypeDescription
rpcImplRPCImplRPC implementation
requestDelimited?booleanWhether requests are length-delimited
responseDelimited?booleanWhether responses are length-delimited

Returns​

OperatorService

RPC service. Useful where requests and/or responses are streamed.