client_pool.h

Go to the documentation of this file.

 
#ifndef KEEL_CLIENT_POOL_H
#define KEEL_CLIENT_POOL_H
 
#include <keel/allocator.h>
#include <keel/client.h>
#include <keel/error.h>
#include <keel/event_ctx.h>
#include <keel/tls.h>
#include <stdint.h>
 
/* ── Defaults ────────────────────────────────────────────────────── */
 
#define KL_CPOOL_DEFAULT_CAPACITY      32
#define KL_CPOOL_DEFAULT_MAX_PER_HOST   4
#define KL_CPOOL_DEFAULT_IDLE_MS    60000  
/* ── Types ───────────────────────────────────────────────────────── */
 
typedef struct KlClientPool KlClientPool;
 
typedef struct {
    int         capacity;       
    int         max_per_host;   
    uint64_t    idle_ms;        
} KlClientPoolConfig;
 
typedef struct {
    int    fd;       
    KlTls *tls;      
    int    reused;   
    void  *_entry;   
} KlClientPoolConn;
 
typedef struct KlClientPoolEntry {
    char     host[KL_CLIENT_HOSTNAME_MAX]; 
    int      port;
    int      is_tls;
    char     proxy_host[KL_CLIENT_HOSTNAME_MAX]; 
    int      proxy_port;                          
    int      fd;            
    KlTls   *tls;
    uint64_t idle_since_ms; 
    int64_t  timer_id;      
    struct KlClientPool *pool; 
} KlClientPoolEntry;
 
struct KlClientPool {
    KlClientPoolEntry *entries;
    int       capacity;
    int       active;       
    int       max_per_host;
    uint64_t  idle_ms;
    KlAllocator *alloc;
    KlEventCtx  *ev_ctx;   
    KlError   last_error;
};
 
/* ── Pool lifecycle ──────────────────────────────────────────────── */
 
int  kl_cpool_init(KlClientPool *pool, const KlClientPoolConfig *cfg,
                   KlAllocator *alloc, KlEventCtx *ev_ctx);
 
void kl_cpool_free(KlClientPool *pool);
 
/* ── Acquire / release ───────────────────────────────────────────── */
 
int  kl_cpool_acquire(KlClientPool *pool, const char *host, int port,
                      int is_tls, const char *proxy_host, int proxy_port,
                      KlClientPoolConn *conn);
 
int  kl_cpool_release(KlClientPool *pool, KlClientPoolConn *conn,
                      const char *host, int port, int is_tls,
                      const char *proxy_host, int proxy_port);
 
void kl_cpool_discard(KlClientPool *pool, KlClientPoolConn *conn);
 
/* ── Maintenance ─────────────────────────────────────────────────── */
 
int  kl_cpool_evict_expired(KlClientPool *pool);
 
int  kl_cpool_idle_count(const KlClientPool *pool);
 
int  kl_cpool_host_count(const KlClientPool *pool, const char *host,
                         int port, int is_tls,
                         const char *proxy_host, int proxy_port);
 
/* ── Pooled client request variants ──────────────────────────────── */
 
int kl_client_request_pooled(KlClientPool *pool,
                              KlAllocator *alloc, const KlClientConfig *cfg,
                              const char *method, const char *url,
                              const KlClientHeader *headers, int num_headers,
                              const char *body, size_t body_len,
                              KlClientResponse *resp);
 
KlClient *kl_client_start_pooled(KlClientPool *pool,
                                   KlEventCtx *ev_ctx, KlAllocator *alloc,
                                   const KlClientConfig *cfg,
                                   const char *method, const char *url,
                                   const KlClientHeader *headers, int num_headers,
                                   const char *body, size_t body_len,
                                   KlClientDoneFn on_done, void *user_data);
 
#endif /* KEEL_CLIENT_POOL_H */