timescale

Documentation

Index

• func AddHistoryFunctions(ctx context.Context, conn *pgxpool.Conn) error
• type DDLManager
  • func NewDDLManager(l hclog.Logger, conn *pgxpool.Conn, cfg *history.Config, dt schema.DialectType) (*DDLManager, error)
  • func (h DDLManager) SetupHistory(ctx context.Context, conn *pgxpool.Conn) error
• type Executor
  • func New(logger hclog.Logger, dsn string, cfg *history.Config) (*Executor, error)
  • func (e Executor) Finalize(ctx context.Context) error
  • func (e Executor) Setup(ctx context.Context) (string, error)
  • func (e Executor) Validate(ctx context.Context) (bool, error)

Functions

func AddHistoryFunctions

func AddHistoryFunctions(ctx context.Context, conn *pgxpool.Conn) error

Types

type DDLManager

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

func NewDDLManager

func NewDDLManager(l hclog.Logger, conn *pgxpool.Conn, cfg *history.Config, dt schema.DialectType) (*DDLManager, error)

func (DDLManager) SetupHistory

func (h DDLManager) SetupHistory(ctx context.Context, conn *pgxpool.Conn) error

type Executor

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

func New

func New(logger hclog.Logger, dsn string, cfg *history.Config) (*Executor, error)

func (Executor) Finalize

func (e Executor) Finalize(ctx context.Context) error

func (Executor) Setup

func (e Executor) Setup(ctx context.Context) (string, error)

Setup sets all required history functions and validation checks that it can run cleanly.

func (Executor) Validate

func (e Executor) Validate(ctx context.Context) (bool, error)