pgx2kv

Documentation

Index

• Variables
• type QueryGenerator

Variables

var PgxAddBucketNew func(p *pgxpool.Pool) s2k.AddBucket = pgxBucketAddNew(pgBulkAddQueryGenerator)

var PgxAddLogNew func(p *pgxpool.Pool) s2k.AddLog = pgxLogAddNew(pgAddLogQueryGenerator)

var PgxBatchUpsertNew func(p *pgxpool.Pool) s2k.SetBatch = pgxBatchUpsertNew(pgBufSetQueryGenerator)

var PgxBulkSetNew func(p *pgxpool.Pool) s2k.SetMany = pgxBulkSetNew(pgSetQueryGenerator)

var PgxBulkSetSingleBuilder func(bucketName string) func(p *pgxpool.Pool) s2k.SetMany2Bucket = s2k.Compose(
	bucket2queryNew(pgSetQueryGenerator),
	pgxBulkSetSingleNew,
)

var PgxDelBucketNew func(p *pgxpool.Pool) s2k.DelBucket = pgxBucketDelNew(pgBulkDelQueryGenerator)

var PgxLogInsBuilder func(bucketName string) func(p *pgxpool.Pool) s2k.InsLog = s2k.Compose(
	bucket2queryNew(pgLogInsertQueryGenerator),
	pgxLogInsertNew,
)

var PgxPairs2BucketSingleBuilder func(bucketName string) func(p *pgxpool.Pool) s2k.Pairs2Bucket = s2k.Compose(
	bucket2queryNew(pgSetQueryGenerator),
	pgxPairs2BucketSingleNew,
)

Types

type QueryGenerator

type QueryGenerator func(bucketName string) (query string, e error)