temporal_sdk_grpc_compressor behaviour (temporal_sdk v0.1.15)

View Source

gRPC compressor behaviour module.

Summary

Callbacks

compress(Cluster, Msg, RequestInfo, Opts)
decompress(Cluster, Msg, RequestInfo, Opts)

Callbacks

compress(Cluster, Msg, RequestInfo, Opts)

-callback compress(Cluster :: temporal_sdk_grpc:cluster_name(),
                   Msg :: binary(),
                   RequestInfo :: temporal_sdk_grpc:request_info(),
                   CompressOpts :: term()) ->
                      {nonempty_binary(), 0 | 1, nonempty_binary()}.

decompress(Cluster, Msg, RequestInfo, Opts)

-callback decompress(Cluster :: temporal_sdk_grpc:cluster_name(),
                     Msg :: nonempty_binary(),
                     RequestInfo :: temporal_sdk_grpc:request_info(),
                     DecompressOpts :: term()) ->
                        nonempty_binary().