dbutils

package

v0.0.0-...-0d0b246 Latest Latest Go to latest Published: Apr 15, 2019 License: MIT Imports: 7 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

View Source

const (
	// OutputPlugin contains logical decoder plugin name
	OutputPlugin = "pgoutput"
)

This section is empty.

func CreateMissingPublication(conn *pgx.Conn, publicationName string) error

CreateMissingPublication creates missing publication

func QuoteLiteral(str string) string

QuoteLiteral quotes string literal

type LSN uint64

const (
	InvalidLSN LSN = 0
)

func CreateSlot(conn *pgx.Conn, ctx context.Context, slotName string) (LSN, error)

CreateSlot creates a slot

func GetSlotFlushLSN(conn *pgx.Conn, slotName, dbName string) (LSN, error)

GetSlotFlushLSN returns flush LSN of the existing replication slot

func (l LSN) Hex() string

func (l LSN) IsValid() bool

func (l LSN) MarshalYAML() (interface{}, error)

func (l *LSN) Parse(lsn string) error

func (l *LSN) ParseHex(hexStr string) error

func (l LSN) String() string

func (l *LSN) UnmarshalYAML(unmarshal func(interface{}) error) error

type OID uint32

OID describes pg oid

const InvalidOID OID = 0

InvalidOID describes invalid oid

func (o *OID) Scan(src interface{}) error

Scan implements the Scanner interface in order to allow pgx to read OID values from the DB.

func (o OID) String() string

String implements Stringer

func (o OID) Value() (driver.Value, error)

Value implements sql Valuer