%%%------------------------------------------------------------------- %% @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).