class documentation
Codec for encoding/decoding to/from bytes.
Commonly used for compression or encryption.
| Async Method | decode |
Decode the given payloads. |
| Async Method | decode |
Decode payloads of a failure. |
| Async Method | decode |
decode for the temporalio.api.common.v1.Payloads wrapper. |
| Async Method | encode |
Encode the given payloads. |
| Async Method | encode |
Encode payloads of a failure. |
| Async Method | encode |
encode for the temporalio.api.common.v1.Payloads wrapper. |
| Async Method | _apply |
Undocumented |
@abstractmethod
async def decode(self, payloads:
async def decode(self, payloads:
Sequence[) -> List[:
(source)
¶
Decode the given payloads.
| Parameters | |
payloads:Sequence[ | Payloads to decode. This value should not be mutated. |
| Returns | |
List[ | Decoded payloads. Note, this does not have to be the same number as payloads given, but must be at least one and cannot be more than was given. |
@abstractmethod
async def encode(self, payloads:
async def encode(self, payloads:
Sequence[) -> List[:
(source)
¶
Encode the given payloads.
| Parameters | |
payloads:Sequence[ | Payloads to encode. This value should not be mutated. |
| Returns | |
List[ | Encoded payloads. Note, this does not have to be the same number as payloads given, but must be at least one and cannot be more than was given. |
encode for the
temporalio.api.common.v1.Payloads wrapper.
This replaces the payloads within the wrapper.
async def _apply_to_failure_payloads(self, failure:
temporalio.api.failure.v1.Failure, cb: Callable[):
(source)
¶
Undocumented