Class InternalNexusOperationContext

java.lang.Object

io.temporal.internal.nexus.InternalNexusOperationContext

public class InternalNexusOperationContext
extends Object

Constructor Summary

Constructors

Constructor	Description
InternalNexusOperationContext(String namespace, String taskQueue, String endpoint, com.uber.m3.tally.Scope metricScope, WorkflowClient client)

Method Summary

Modifier and Type	Method	Description
void	addResponseLink(io.temporal.api.common.v1.Link link)	Append a response link returned by an outbound RPC the operation handler issued (e.g.
String	getEndpoint()
com.uber.m3.tally.Scope	getMetricsScope()
String	getNamespace()
List<io.temporal.api.common.v1.Link>	getRequestLinks()	Links from the inbound Nexus task; empty if none.
List<io.temporal.api.common.v1.Link>	getResponseLinks()	Response links from every outbound RPC the handler issued.
io.temporal.api.common.v1.Link	getStartWorkflowResponseLink()
String	getTaskQueue()
NexusOperationContext	getUserFacingContext()
WorkflowClient	getWorkflowClient()
void	setOutboundInterceptor(NexusOperationOutboundCallsInterceptor outboundCalls)
void	setRequestLinks(List<io.temporal.api.common.v1.Link> links)	Set the common.v1.Links extracted from the inbound Nexus task so they can be attached to RPCs issued by the operation handler.
void	setStartWorkflowResponseLink(io.temporal.api.common.v1.Link link)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

InternalNexusOperationContext

public InternalNexusOperationContext(String namespace,
 String taskQueue,
 String endpoint,
 com.uber.m3.tally.Scope metricScope,
 WorkflowClient client)

Method Details

getMetricsScope

public com.uber.m3.tally.Scope getMetricsScope()

getWorkflowClient

public WorkflowClient getWorkflowClient()

getTaskQueue

public String getTaskQueue()

getNamespace

public String getNamespace()

getEndpoint

public String getEndpoint()

setOutboundInterceptor

public void setOutboundInterceptor(NexusOperationOutboundCallsInterceptor outboundCalls)

getUserFacingContext

public NexusOperationContext getUserFacingContext()

setRequestLinks

public void setRequestLinks(List<io.temporal.api.common.v1.Link> links)

Set the common.v1.Links extracted from the inbound Nexus task so they can be attached to RPCs issued by the operation handler.

getRequestLinks

@Nonnull
public List<io.temporal.api.common.v1.Link> getRequestLinks()

Links from the inbound Nexus task; empty if none.

setStartWorkflowResponseLink

public void setStartWorkflowResponseLink(io.temporal.api.common.v1.Link link)

getStartWorkflowResponseLink

public io.temporal.api.common.v1.Link getStartWorkflowResponseLink()

addResponseLink

public void addResponseLink(io.temporal.api.common.v1.Link link)

Append a response link returned by an outbound RPC the operation handler issued (e.g. signal, signalWithStart, etc). The task handler drains the list when building the operation's StartOperationResponse.

getResponseLinks

@Nonnull
public List<io.temporal.api.common.v1.Link> getResponseLinks()

Response links from every outbound RPC the handler issued. Returned as an unmodifiable view; callers must not attempt to mutate. Entries are accumulated while the operation handler runs (the call that flows through NexusOperationInboundCallsInterceptor.startOperation(io.temporal.common.interceptors.NexusOperationInboundCallsInterceptor.StartOperationInput)) and are drained afterward by the task handler when building the StartOperationResponse.