Merge pull request #6875 from bkayranci/master

out_pgsql: pass connection options to postgresql client

This new option `connection_options` allows to pass the `pgoptions` argument
to PQsetdbLogin() function that are passed to the PostgreSQL backend.

When this option it's set, the backend will accept the options with the format of
`-c option_name=value`.

Author: sxd

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 options */
+    const char *conn_options;
+
     /* connections pool */
     struct mk_list conn_queue;
     struct mk_list _head;

plugins/out_pgsql/pgsql_connections.c

@@ -54,9 +54,11 @@ void *pgsql_create_connection(struct flb_pgsql_config *ctx)
         flb_errno();
         return NULL;
     }
+
     conn->conn = PQsetdbLogin(ctx->db_hostname,
                               ctx->db_port,
-                              NULL, NULL,
+                              ctx->conn_options,
+                              NULL,
                               ctx->db_name,
                               ctx->db_user,
                               ctx->db_passwd);