Home
last modified time | relevance | path

Searched refs:PgDatabase (Results 1 – 14 of 14) sorted by relevance

/dports/databases/pgbouncer/pgbouncer-1.16.0/include/
H A Dobjects.h32 PgDatabase *find_database(const char *name);
34 PgPool *get_pool(PgDatabase *, PgUser *);
36 bool evict_connection(PgDatabase *db) _MUSTCHECK;
47 PgDatabase * add_database(const char *name) _MUSTCHECK;
48 PgDatabase *register_auto_database(const char *name);
50 PgUser * add_db_user(PgDatabase *db, const char *name, const char *passwd) _MUSTCHECK;
51 PgUser * force_user(PgDatabase *db, const char *username, const char *passwd) _MUSTCHECK;
82 void tag_database_dirty(PgDatabase *db);
H A Dbouncer.h96 typedef struct PgDatabase PgDatabase; typedef
269 PgDatabase *db; /* corresponding database */
344 struct PgDatabase { struct
434 PgDatabase *db; /* cache db while doing auth query */
H A Djanitor.h25 void kill_database(PgDatabase *db);
H A Dserver.h25 int database_max_connections(PgDatabase *db) _MUSTCHECK;
/dports/net/cloudquery/cloudquery-0.16.0/vendor/github.com/cloudquery/cq-provider-sdk/provider/schema/
H A Ddatabase.go45 type PgDatabase struct { struct
50 func NewPgDatabase(ctx context.Context, logger hclog.Logger, dsn string) (*PgDatabase, error) {
59 return &PgDatabase{pool: pool, log: logger}, nil
63 func (p PgDatabase) Insert(ctx context.Context, t *Table, resources Resources) error { argument
104 func (p PgDatabase) CopyFrom(ctx context.Context, resources Resources, shouldCascade bool, cascadeD… argument
145 func (p PgDatabase) Exec(ctx context.Context, query string, args ...interface{}) error { argument
151 func (p PgDatabase) Query(ctx context.Context, query string, args ...interface{}) (pgx.Rows, error)… argument
157 func (p PgDatabase) QueryOne(ctx context.Context, query string, args ...interface{}) pgx.Row { argument
162 func (p PgDatabase) Delete(ctx context.Context, t *Table, kvFilters []interface{}) error { argument
181 func (p PgDatabase) RemoveStaleData(ctx context.Context, t *Table, executionStart time.Time, kvFilt… argument
[all …]
/dports/databases/pgbouncer/pgbouncer-1.16.0/src/
H A Dobjects.c297 PgDatabase *db1 = container_of(i1, PgDatabase, head); in cmp_database()
298 PgDatabase *db2 = container_of(i2, PgDatabase, head); in cmp_database()
322 PgDatabase *add_database(const char *name) in add_database()
324 PgDatabase *db = find_database(name); in add_database()
348 PgDatabase *db; in register_auto_database()
459 PgDatabase *db; in find_database()
1102 bool evict_connection(PgDatabase *db) in evict_connection()
1409 PgDatabase *db = find_database(dbname); in use_client_socket()
1650 void tag_database_dirty(PgDatabase *db) in tag_database_dirty()
1665 PgDatabase *db; in tag_autodb_dirty()
[all …]
H A Dadmin.c115 PgDatabase *db; in count_paused_databases()
406 PgDatabase *db = find_database(name); in find_or_register_database()
486 PgDatabase *db; in admin_show_databases()
1086 PgDatabase *db; in admin_cmd_pause()
1121 PgDatabase *db; in admin_cmd_reconnect()
1138 PgDatabase *db; in admin_cmd_disable()
1160 PgDatabase *db; in admin_cmd_enable()
1183 PgDatabase *db; in admin_cmd_kill()
1225 PgDatabase *db; in admin_cmd_wait_close()
1237 PgDatabase *db; in admin_cmd_wait_close()
[all …]
H A Djanitor.c593 PgDatabase *db; in cleanup_inactive_autodatabases()
602 db = container_of(item, PgDatabase, head); in cleanup_inactive_autodatabases()
619 PgDatabase *db; in do_full_maint()
646 db = container_of(item, PgDatabase, head); in do_full_maint()
703 void kill_database(PgDatabase *db) in kill_database()
737 PgDatabase *db; in config_postprocess()
740 db = container_of(item, PgDatabase, head); in config_postprocess()
H A Dstats.c95 PgDatabase *cur_db = NULL; in admin_database_stats()
166 PgDatabase *cur_db = NULL; in admin_database_stats_totals()
233 PgDatabase *cur_db = NULL; in admin_database_stats_averages()
H A Dmain.c368 PgDatabase *db; in set_dbs_dead()
371 db = container_of(item, PgDatabase, head); in set_dbs_dead()
682 PgDatabase *db; in check_limits()
698 db = container_of(item, PgDatabase, head); in check_limits()
H A Dloader.c130 static void set_connect_query(PgDatabase *db, const char *new) in set_connect_query()
180 PgDatabase *db; in parse_database()
H A Dproto.c261 PgDatabase *db = server->pool->db; in get_srv_psw()
537 PgDatabase *db = server->pool->db; in send_startup_packet()
H A Dtakeover.c361 PgDatabase *db = find_database("pgbouncer"); in takeover_init()
H A Dserver.c228 int database_max_connections(PgDatabase *db) in database_max_connections()