pass connection options to postgresql client

Signed-off-by: Turkalp Burak Kayrancıoğlu <[email protected]>

plugins/out_pgsql/pgsql.c

@@ -92,6 +92,9 @@ static int cb_pgsql_init(struct flb_output_instance *ins,
         ctx->db_table = flb_sds_create(FLB_PGSQL_TABLE);
     }
 
+    /* connection options */
+    ctx->conn_options = flb_output_get_property("connection_options", ins);
+
     if (!ctx->db_table) {
         flb_errno();
         pgsql_conf_destroy(ctx);

plugins/out_pgsql/pgsql.h

@@ -67,6 +67,9 @@ struct flb_pgsql_config {
     /* instance reference */
     struct flb_output_instance *ins;
 
+    /* connections */
+    const char *conn_options;
+
     /* connections pool */
     struct mk_list conn_queue;
     struct mk_list _head;

plugins/out_pgsql/pgsql_connections.c

@@ -54,9 +54,12 @@ void *pgsql_create_connection(struct flb_pgsql_config *ctx)
         flb_errno();
         return NULL;
     }
+
+    flb_plg_debug(ctx->ins, "connection_options: %s", ctx->conn_options);
     conn->conn = PQsetdbLogin(ctx->db_hostname,
                               ctx->db_port,
-                              NULL, NULL,
+                              ctx->conn_options,
+                              NULL,
                               ctx->db_name,
                               ctx->db_user,
                               ctx->db_passwd);