grpc_client.h

Go to the documentation of this file.

 
#ifndef __CWIST_GRPC_CLIENT_H__
#define __CWIST_GRPC_CLIENT_H__
 
#include <cwist/net/grpc/grpc.h>
 
#ifdef __cplusplus
extern "C" {
#endif
 
typedef struct cwist_grpc_client cwist_grpc_client;
typedef struct cwist_grpc_call cwist_grpc_call;
 
typedef struct cwist_grpc_client_options {
    const char *authority;        /* :authority header; defaults to host:port */
    int use_tls;                  /* 0 = h2c cleartext, 1 = TLS (ALPN "h2") */
    int verify_peer;              /* TLS only: verify server certificate (default 1) */
    uint64_t connect_timeout_ms;  /* 0 = 10000 */
    const char *tls_server_name;  /* TLS only: SNI hostname; defaults to the
                                  * connect host (channels set this to the
                                  * original dns name, not the resolved IP) */
} cwist_grpc_client_options;
 
cwist_grpc_client *cwist_grpc_client_connect(const char *host, uint16_t port,
                                             const cwist_grpc_client_options *options);
 
void cwist_grpc_client_close(cwist_grpc_client *client);
 
cwist_grpc_call *cwist_grpc_call_start(cwist_grpc_client *client, const char *method,
                                       const void *request, size_t request_len,
                                       uint64_t timeout_ms);
 
cwist_grpc_call *cwist_grpc_call_start_ex(cwist_grpc_client *client, const char *method,
                                          const void *request, size_t request_len,
                                          uint64_t timeout_ms, uint32_t previous_attempts);
 
int cwist_grpc_call_await_headers(cwist_grpc_call *call);
 
int cwist_grpc_call_committed(const cwist_grpc_call *call);
 
int cwist_grpc_call_refused(const cwist_grpc_call *call);
 
int cwist_grpc_call_retry_pushback_ms(const cwist_grpc_call *call, int32_t *out_ms);
 
int cwist_grpc_client_dead(cwist_grpc_client *client);
 
cwist_grpc_status_t cwist_grpc_call_status(const cwist_grpc_call *call);
 
int cwist_grpc_call_recv(cwist_grpc_call *call, cwist_grpc_message *out);
 
cwist_grpc_status_t cwist_grpc_call_finish(cwist_grpc_call *call, const char **message);
 
void cwist_grpc_call_cancel(cwist_grpc_call *call);
 
void cwist_grpc_call_destroy(cwist_grpc_call *call);
 
#ifdef __cplusplus
}
#endif
 
#endif