pgctl

Oct 16, 2024

Changes in this version

+ func IsAdminUser(db *sql.DB) (bool, error)

+ func SanitizeDSN(dsn string) string

type Config

+ Cloud string

type Restore

+ func (x *Restore) DropSchemas() Result

type StateEnum

+ const S_MigrationInProgress

Sep 28, 2023

Changes in this version

+ const DefaultPubName

+ const DefaultSubName

+ var PGDRestoreOpts = []string

+ var PGDump = "pg_dump"

+ var PGDumpDefaultFormat = "p"

+ var PGDumpOpts = []string

+ var PSQL = "psql"

+ func Exec(name string, arg ...string) (string, error)

+ type Config struct

+ ExportFilePath string

+ Log logr.Logger

+ SourceDBAdminDsn string

+ SourceDBUserDsn string

+ TargetDBAdminDsn string

+ TargetDBUserDsn string

+ type Dump struct

+ DsnUri string

+ Format *string

+ Options []string

+ Path string

+ Verbose bool

+ func NewDump(DsnUri string) *Dump

+ func (x *Dump) EnableVerbose()

+ func (x *Dump) Exec(opts ExecOptions) Result

+ func (x *Dump) GetFileName() string

+ func (x *Dump) GetOptions() []string

+ func (x *Dump) ResetOptions()

+ func (x *Dump) SetFileName(filename string)

+ func (x *Dump) SetOptions(o []string)

+ func (x *Dump) SetPath(path string)

+ func (x *Dump) SetupFormat(f string)

+ type ExecOptions struct

+ StreamPrint bool

+ type ExportFile struct

+ Name string

+ Path string

+ type Restore struct

+ DsnUri string

+ Options []string

+ Path string

+ Schemas []string

+ Verbose bool

+ func NewRestore(DsnUri string) *Restore

+ func (x *Restore) EnableVerbose()

+ func (x *Restore) Exec(filename string, opts ExecOptions) Result

+ func (x *Restore) GetOptions() []string

+ func (x *Restore) ResetOptions()

+ func (x *Restore) SetOptions(o []string)

+ func (x *Restore) SetPath(path string)

+ func (x *Restore) SetSchemas(schemas []string)

+ type Result struct

+ Error *ResultError

+ FileName string

+ FullCommand string

+ Mine string

+ Output string

+ type ResultError struct

+ CmdOutput string

+ Err error

+ ExitCode int

+ type Results struct

+ Dump Result

+ Restore Result

+ type State interface

+ Execute func() (State, error)

+ Id func() StateEnum

+ String func() string

+ func GetReplicatorState(name string, c Config) (State, error)

+ type StateEnum int

+ const S_Completed

+ const S_CopySchema

+ const S_CreatePublication

+ const S_CreateSubscription

+ const S_CutOverReadinessCheck

+ const S_DeletePublication

+ const S_DeleteSubscription

+ const S_DisableSourceAccess

+ const S_DisableSubscription

+ const S_EnableSubscription

+ const S_Initial

+ const S_RerouteTargetSecret

+ const S_ResetTargetSequence

+ const S_Retry

+ const S_ValidateConnection

+ const S_ValidateMigrationStatus

+ const S_WaitToDisableSource

+ func GetStateEnum(name string) (StateEnum, error)

+ func (s StateEnum) String() string