timescale

Documentation

Index

• type DDLManager
  • func NewDDLManager(l hclog.Logger, pool *pgxpool.Pool, cfg *history.Config, dt schema.DialectType) (*DDLManager, error)
  • func (d *DDLManager) AddHistoryFunctions(ctx context.Context) error
  • func (d *DDLManager) Close()
  • func (d *DDLManager) DropViews(ctx context.Context) error
  • func (d *DDLManager) SetupHistory(ctx context.Context) error
• type Executor
  • func New(logger hclog.Logger, dsn string, cfg *history.Config) (*Executor, error)
  • func (e Executor) Finalize(ctx context.Context, retErr error) error
  • func (e Executor) Prepare(ctx context.Context) error
  • func (e *Executor) Setup(ctx context.Context) (string, error)
  • func (e Executor) Validate(ctx context.Context) (bool, error)

Types

type DDLManager

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

func NewDDLManager

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

func (*DDLManager) AddHistoryFunctions

func (d *DDLManager) AddHistoryFunctions(ctx context.Context) error

func (*DDLManager) Close

func (d *DDLManager) Close()

func (*DDLManager) DropViews

func (d *DDLManager) DropViews(ctx context.Context) error

DropViews drops all hypertable related views. This must be called before any migrations can be run.

func (*DDLManager) SetupHistory

func (d *DDLManager) SetupHistory(ctx context.Context) error

SetupHistory is run after any migrations, finalizing history setup

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, retErr error) error

func (Executor) Prepare

func (e Executor) Prepare(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)