Packages

grpcbox

0.17.1
0.18.0 0.17.1 0.17.0 0.16.0 0.15.0 0.14.0 0.13.1 0.13.0 0.12.0 0.11.0 0.10.0 0.9.1 0.9.0 0.8.0 0.7.0 0.6.1 0.6.0 0.5.0 0.4.0 0.3.0 0.1.1 0.1.0

Erlang grpc library based on chatterbox

Current section

Files

Jump to
Readme
22 Versions
4 Dependencies
4 Dependants
Files
Activity
grpcbox src grpcbox_health_client.erl
Raw

src/grpcbox_health_client.erl 

%%%-------------------------------------------------------------------

%% @doc Client module for grpc service grpc.health.v1.Health.

%% @end

%%%-------------------------------------------------------------------



%% this module was generated and should not be modified manually



-module(grpcbox_health_client).



-compile(export_all).

-compile(nowarn_export_all).



-include_lib("grpcbox/include/grpcbox.hrl").



-define(is_ctx(Ctx), is_tuple(Ctx) andalso element(1, Ctx) =:= ctx).



-define(SERVICE, 'grpc.health.v1.Health').

-define(PROTO_MODULE, 'grpcbox_health_pb').

-define(MARSHAL_FUN(T), fun(I) -> ?PROTO_MODULE:encode_msg(I, T) end).

-define(UNMARSHAL_FUN(T), fun(I) -> ?PROTO_MODULE:decode_msg(I, T) end).

-define(DEF(Input, Output, MessageType), #grpcbox_def{service=?SERVICE,

                                                      message_type=MessageType,

                                                      marshal_fun=?MARSHAL_FUN(Input),

                                                      unmarshal_fun=?UNMARSHAL_FUN(Output)}).



%% @doc Unary RPC

-spec check(grpcbox_health_pb:health_check_request()) ->

    {ok, grpcbox_health_pb:health_check_response(), grpcbox:metadata()} | grpcbox_stream:grpc_error_response() | {error, any()}.

check(Input) ->

    check(ctx:new(), Input, #{}).



-spec check(ctx:t() | grpcbox_health_pb:health_check_request(), grpcbox_health_pb:health_check_request() | grpcbox_client:options()) ->

    {ok, grpcbox_health_pb:health_check_response(), grpcbox:metadata()} | grpcbox_stream:grpc_error_response() | {error, any()}.

check(Ctx, Input) when ?is_ctx(Ctx) ->

    check(Ctx, Input, #{});

check(Input, Options) ->

    check(ctx:new(), Input, Options).



-spec check(ctx:t(), grpcbox_health_pb:health_check_request(), grpcbox_client:options()) ->

    {ok, grpcbox_health_pb:health_check_response(), grpcbox:metadata()} | grpcbox_stream:grpc_error_response() | {error, any()}.

check(Ctx, Input, Options) ->

    grpcbox_client:unary(Ctx, <<"/grpc.health.v1.Health/Check">>, Input, ?DEF(health_check_request, health_check_response, <<"grpc.health.v1.HealthCheckRequest">>), Options).



%% @doc 

-spec watch(grpcbox_health_pb:health_check_request()) ->

    {ok, grpcbox_client:stream()} | grpcbox_stream:grpc_error_response() | {error, any()}.

watch(Input) ->

    watch(ctx:new(), Input, #{}).



-spec watch(ctx:t() | grpcbox_health_pb:health_check_request(), grpcbox_health_pb:health_check_request() | grpcbox_client:options()) ->

    {ok, grpcbox_client:stream()} | grpcbox_stream:grpc_error_response() | {error, any()}.

watch(Ctx, Input) when ?is_ctx(Ctx) ->

    watch(Ctx, Input, #{});

watch(Input, Options) ->

    watch(ctx:new(), Input, Options).



-spec watch(ctx:t(), grpcbox_health_pb:health_check_request(), grpcbox_client:options()) ->

    {ok, grpcbox_client:stream()} | grpcbox_stream:grpc_error_response() | {error, any()}.

watch(Ctx, Input, Options) ->

    grpcbox_client:stream(Ctx, <<"/grpc.health.v1.Health/Watch">>, Input, ?DEF(health_check_request, health_check_response, <<"grpc.health.v1.HealthCheckRequest">>), Options).