postgres

package

v0.0.1 Latest Latest Go to latest Published: Jun 14, 2022 License: Apache-2.0 Imports: 4 Imported by: 0

Details

Package postgres implements the target storage interface backed by PostgreSQL.

This section is empty.

This section is empty.

This section is empty.

type Client struct {
	// contains filtered or unexported fields
}

Client is a PostgreSQL client.

func NewClient(connString string, l *log.Logger) (*Client, error)

NewClient creates a new PostgreSQL client.

func (c *Client) Name() string

Name returns the name of the PostgreSQL client.

func (c *Client) Query(ctx context.Context, sql string, args ...interface{}) (pgx.Rows, error)

Query submits a new query to PostgreSQL.

func (c *Client) QueryRow(ctx context.Context, sql string, args ...interface{}) pgx.Row

QueryRow submits a new query for a single row to PostgreSQL.

func (c *Client) SendBatch(ctx context.Context, batch *pgx.Batch) error

SendBatch submits a new transaction batch to PostgreSQL.

func (c *Client) Shutdown()

Shutdown shuts down the target storage client.