util

Documentation

Index

• Variables
• func Prompt(ctx context.Context, prompt string) (string, error)
• func PromptYesNo(ctx context.Context, question string) (bool, error)
• type BlockWatchedPoolConn
  • func AcquireWithBlockWatcher(ctx context.Context, pool *pgxpool.Pool, maxBlockDuration time.Duration, ...) (*BlockWatchedPoolConn, error)
  • func (c *BlockWatchedPoolConn) Release()
• type BlockWatcher
  • func (w *BlockWatcher) Watch(ctx context.Context) error
• type Dumper
  • func NewDumper(pgCfg *pgx.ConnConfig, command string) (*Dumper, error)
  • func (d *Dumper) Dump(ctx context.Context, outputPath string) error

Variables

var Log io.Writer = os.Stderr

var LogColor bool = false

var LogLevel int = 0

var Logf func(int, string, ...interface{}) (int, error) = defaultLogf

Functions

func Prompt

func Prompt(ctx context.Context, prompt string) (string, error)

func PromptYesNo

func PromptYesNo(ctx context.Context, question string) (bool, error)

Types

type BlockWatchedPoolConn

type BlockWatchedPoolConn struct {
	*pgxpool.Conn
	// contains filtered or unexported fields
}

func AcquireWithBlockWatcher

func AcquireWithBlockWatcher(
	ctx context.Context,
	pool *pgxpool.Pool,
	maxBlockDuration time.Duration,
	maxBlockProcesses int,
) (
	*BlockWatchedPoolConn,
	error,
)

func (*BlockWatchedPoolConn) Release

func (c *BlockWatchedPoolConn) Release()

type BlockWatcher

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

func (*BlockWatcher) Watch

func (w *BlockWatcher) Watch(ctx context.Context) error

type Dumper

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

func NewDumper

func NewDumper(pgCfg *pgx.ConnConfig, command string) (*Dumper, error)

func (*Dumper) Dump

func (d *Dumper) Dump(ctx context.Context, outputPath string) error