postgres

Documentation

Index

• type Postgres
  • func (p *Postgres) BatchWrite(ctx context.Context, tableName string, chunks []any) error
  • func (p *Postgres) Connection() any
  • func (p *Postgres) Open(ctx context.Context, connectionConfig database.ConnectionConfig) (database.Database, error)

Types

type Postgres

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

func (*Postgres) BatchWrite

func (p *Postgres) BatchWrite(ctx context.Context, tableName string, chunks []any) error

func (*Postgres) Connection

func (p *Postgres) Connection() any

func (*Postgres) Open

func (p *Postgres) Open(ctx context.Context, connectionConfig database.ConnectionConfig) (database.Database, error)