temporalio.nexus.system._payload_visitor.PayloadVisitor

class documentation

class PayloadVisitor: (source)

Constructor: PayloadVisitor(skip_search_attributes, skip_headers, concurrency_limit)

View In Hierarchy

A visitor for payloads. Applies a function to every payload in a tree of messages.

Method __init__ Creates a new payload visitor.
Async Method visit Visits the given root message with the given function.
Instance Variable skip_headers Undocumented
Instance Variable skip_search_attributes Undocumented
Async Method _visit_nexus_operation_input_payload Undocumented
Async Method _visit_payload_container Undocumented
Async Method _visit_temporal_api_common_v1_Header Undocumented
Async Method _visit_temporal_api_common_v1_Memo Undocumented
Async Method _visit_temporal_api_common_v1_Payload Undocumented
Async Method _visit_temporal_api_common_v1_Payloads Undocumented
Async Method _visit_temporal_api_common_v1_SearchAttributes Undocumented
Async Method _visit_temporal_api_sdk_v1_UserMetadata Undocumented
Async Method _visit_temporal_api_workflowservice_v1_SignalWithStartWorkflowExecutionRequest Undocumented
Instance Variable _concurrency_limit Undocumented
def __init__(self, *, skip_search_attributes: bool = False, skip_headers: bool = False, concurrency_limit: int = 1): (source)

Creates a new payload visitor.

Parameters
skip_search_attributes:boolIf True, search attributes are not visited.
skip_headers:boolIf True, headers are not visited.
concurrency_limit:intMaximum number of payload visits that may run concurrently during a single call to visit(). Defaults to 1 (sequential).
async def visit(self, fs: VisitorFunctions, root: Any): (source)

Visits the given root message with the given function.

skip_headers = (source)

Undocumented

skip_search_attributes = (source)

Undocumented

async def _visit_nexus_operation_input_payload(self, fs: VisitorFunctions, service: str, operation: str, payload: Payload): (source)

Undocumented

async def _visit_payload_container(self, fs: VisitorFunctions, o: PayloadSequence): (source)

Undocumented

async def _visit_temporal_api_common_v1_Header(self, fs: VisitorFunctions, o: Any): (source)

Undocumented

async def _visit_temporal_api_common_v1_Memo(self, fs: VisitorFunctions, o: Any): (source)

Undocumented

async def _visit_temporal_api_common_v1_Payload(self, fs: VisitorFunctions, o: Payload): (source)

Undocumented

async def _visit_temporal_api_common_v1_Payloads(self, fs: VisitorFunctions, o: Any): (source)

Undocumented

async def _visit_temporal_api_common_v1_SearchAttributes(self, fs: VisitorFunctions, o: Any): (source)

Undocumented

async def _visit_temporal_api_sdk_v1_UserMetadata(self, fs: VisitorFunctions, o: Any): (source)

Undocumented

async def _visit_temporal_api_workflowservice_v1_SignalWithStartWorkflowExecutionRequest(self, fs: VisitorFunctions, o: Any): (source)

Undocumented

_concurrency_limit = (source)

Undocumented