temporal_sdk_grpc_adapter behaviour (temporal_sdk v0.2.11)

gRPC HTTP/2 adapter behaviour module.

Summary

Types

headers()

Callbacks

init_adapter(Cluster, AdapterConfig)

pools_status(Cluster)

request(Cluster, Method, Path, Headers, Body, Opts)

Types

headers()

-type headers() :: #{nonempty_binary() | string() | atom() => iodata()}.

Callbacks

init_adapter(Cluster, AdapterConfig)

-callback init_adapter(Cluster :: temporal_sdk_grpc:cluster_name(), AdapterConfig :: term()) ->
                          ok | {error, term()}.

pools_status(Cluster)

-callback pools_status(Cluster :: temporal_sdk_grpc:cluster_name()) -> term().

request(Cluster, Method, Path, Headers, Body, Opts)

-callback request(Cluster :: temporal_sdk_grpc:cluster_name(),
                  Method :: iodata(),
                  Path :: iodata(),
                  Headers :: temporal_sdk_grpc:headers(),
                  Body :: iodata(),
                  Timeout :: timeout()) ->
                     {ok, Endpoint :: term(), Response :: binary(), RHeaders :: headers()} |
                     {request_error,
                      Endpoint :: term(),
                      ErrorDetails ::
                          #{grpc_response_status => non_neg_integer(),
                            grpc_response_headers => headers(),
                            grpc_response_trailers => headers()} |
                          term()}.