postgres

Documentation

Index

• Constants
• Variables
• func GetPostgresConnection(uri string) (*pgx.Conn, error)
• func ProcessSchema(ctx context.Context, opts daemontypes.DaemonOpts)
• func RunProxy(ctx context.Context, opts daemontypes.DaemonOpts)
• type PostgresResponseType

Constants

const (
	PostgresResponseTypeRowDescription  = 'T'
	PostgresResponseTypeDataRow         = 'D'
	PostgresResponseTypeCommandComplete = 'C'
	PostgresResponseTypeErrorResponse   = 'E'
	PostgresResponseTypeAuthentication  = 'R'
	PostgresResponseTypeParameterStatus = 'S'
	PostgresResponseTypeReadyForQuery   = 'Z'
	PostgresResponseTypeKeyData         = 'K'
)

Variables

var (
	DB *sql.DB
)

var (
	ErrNonQueryData = fmt.Errorf("non-query data")
)

var (
	Interval = 30 * time.Minute
)

Functions

func GetPostgresConnection

func GetPostgresConnection(uri string) (*pgx.Conn, error)

func ProcessSchema

func ProcessSchema(ctx context.Context, opts daemontypes.DaemonOpts)

func RunProxy

func RunProxy(ctx context.Context, opts daemontypes.DaemonOpts)

Types

type PostgresResponseType

type PostgresResponseType byte