commanders

package

v0.0.0-...-9ba49b0 Latest Latest Go to latest Published: Apr 4, 2024 License: Apache-2.0 Imports: 32 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/greenplum-db/gpupgrade

Documentation ¶

Index ¶

Variables
func ApplyDataMigrationScriptSubDir(gphome string, port int, scriptDirFS fs.FS, scriptDir string, bar *mpb.Bar) ([]byte, error)
func ApplyDataMigrationScripts(streams step.OutStreams, nonInteractive bool, gphome string, port int, ...) error
func ApplyDataMigrationScriptsPrompt(nonInteractive bool, reader *bufio.Reader, currentScriptDir string, ...) ([]string, error)
func ApplySQLFile(gphome string, port int, database string, path string, args ...string) ([]byte, error)
func ArchiveDataMigrationScriptsPrompt(streams step.OutStreams, nonInteractive bool, reader *bufio.Reader, ...) error
func CreateStateDir() (err error)
func Execute(client idl.CliToHubClient, request *idl.ExecuteRequest, verbose bool) (*idl.ExecuteResponse, error)
func Finalize(client idl.CliToHubClient, verbose bool) (*idl.FinalizeResponse, error)
func Format(description string, status idl.Status) string
func FormatStatus(status *idl.SubstepStatus) string
func GenerateDataMigrationScripts(streams step.OutStreams, nonInteractive bool, gphome string, port int, ...) error
func GenerateScriptsPerDatabase(streams step.OutStreams, database DatabaseInfo, gphome string, port int, ...) error
func GenerateScriptsPerPhase(phase idl.Step, database DatabaseInfo, gphome string, port int, seedDir string, ...) error
func Initialize(client idl.CliToHubClient, request *idl.InitializeRequest, verbose bool) (err error)
func InitializeCreateCluster(client idl.CliToHubClient, request *idl.InitializeCreateClusterRequest, ...) (*idl.InitializeResponse, error)
func IsHubRunning() (bool, error)
func ResetBashCommand()
func ResetBootstrapConnectionFunction()
func ResetPsqlCommand()
func ResetPsqlFileCommand()
func Revert(client idl.CliToHubClient, verbose bool) (*idl.RevertResponse, error)
func SelectDataMigrationScriptsPrompt(reader *bufio.Reader, currentScriptDir string, currentScriptDirFS fs.FS, ...) ([]string, error)
func SetBashCommand(command exectest.Command)
func SetBootstrapConnectionFunction(...)
func SetPsqlCommand(command exectest.Command)
func SetPsqlFileCommand(command exectest.Command)
func StartHub(streams step.OutStreams) (err error)
func UILoop(stream receiver, verbose bool) (*idl.Response, error)
type DatabaseInfo
- func GetDatabases(db *sql.DB, seedDirFS fs.FS) ([]DatabaseInfo, error)
type Script
type Scripts
- func ParseSelection(input string, allScripts Scripts) (Scripts, error)
- func (scripts Scripts) Description() string
- func (scripts Scripts) Find(num uint64) Script
- func (scripts Scripts) Len() int
- func (scripts Scripts) Less(i, j int) bool
- func (scripts Scripts) Names() []string
- func (scripts Scripts) String() string
- func (scripts Scripts) Swap(i, j int)

Constants ¶

This section is empty.

Variables ¶

View Source

var MigrationScriptPhases = []idl.Step{idl.Step_initialize, idl.Step_finalize, idl.Step_revert, idl.Step_stats}

Functions ¶

func ApplyDataMigrationScriptSubDir ¶

func ApplyDataMigrationScriptSubDir(gphome string, port int, scriptDirFS fs.FS, scriptDir string, bar *mpb.Bar) ([]byte, error)

func ApplyDataMigrationScripts ¶

func ApplyDataMigrationScripts(streams step.OutStreams, nonInteractive bool, gphome string, port int, logDir string, currentScriptDirFS fs.FS, currentScriptDir string, phase idl.Step) error

func ApplyDataMigrationScriptsPrompt ¶

func ApplyDataMigrationScriptsPrompt(nonInteractive bool, reader *bufio.Reader, currentScriptDir string, currentScriptDirFS fs.FS, phase idl.Step) ([]string, error)

func ApplySQLFile ¶

func ApplySQLFile(gphome string, port int, database string, path string, args ...string) ([]byte, error)

func ArchiveDataMigrationScriptsPrompt ¶

func ArchiveDataMigrationScriptsPrompt(streams step.OutStreams, nonInteractive bool, reader *bufio.Reader, outputDirFS fs.FS, outputDir string) error

func CreateStateDir ¶

func CreateStateDir() (err error)

CreateStateDir creates the state directory in the cli to ensure that at most one gpupgrade is occurring at the same time.

func Execute ¶

func Execute(client idl.CliToHubClient, request *idl.ExecuteRequest, verbose bool) (*idl.ExecuteResponse, error)

func Finalize ¶

func Finalize(client idl.CliToHubClient, verbose bool) (*idl.FinalizeResponse, error)

func Format ¶

func Format(description string, status idl.Status) string

Format is also exported for ease of testing (see FormatStatus). Use NewSubstep instead.

func FormatStatus ¶

func FormatStatus(status *idl.SubstepStatus) string

FormatStatus returns a status string based on the upgrade status message. It's exported for ease of testing.

FormatStatus panics if it doesn't have a string representation for a given protobuf code.

func GenerateDataMigrationScripts ¶

func GenerateDataMigrationScripts(streams step.OutStreams, nonInteractive bool, gphome string, port int, seedDir string, outputDir string, outputDirFS fs.FS) error

func GenerateScriptsPerDatabase ¶

func GenerateScriptsPerDatabase(streams step.OutStreams, database DatabaseInfo, gphome string, port int, seedDir string, outputDir string, bar *mpb.Bar) error

func GenerateScriptsPerPhase ¶

func GenerateScriptsPerPhase(phase idl.Step, database DatabaseInfo, gphome string, port int, seedDir string, seedDirFS fs.FS, outputDir string, bar *mpb.Bar) error

func Initialize ¶

func Initialize(client idl.CliToHubClient, request *idl.InitializeRequest, verbose bool) (err error)

func InitializeCreateCluster ¶

func InitializeCreateCluster(client idl.CliToHubClient, request *idl.InitializeCreateClusterRequest, verbose bool) (*idl.InitializeResponse, error)

func IsHubRunning ¶

func IsHubRunning() (bool, error)

func ResetBashCommand ¶

func ResetBashCommand()

func ResetBootstrapConnectionFunction ¶

func ResetBootstrapConnectionFunction()

XXX: for internal testing only

func ResetPsqlCommand ¶

func ResetPsqlCommand()

func ResetPsqlFileCommand ¶

func ResetPsqlFileCommand()

func Revert ¶

func Revert(client idl.CliToHubClient, verbose bool) (*idl.RevertResponse, error)

func SelectDataMigrationScriptsPrompt ¶

func SelectDataMigrationScriptsPrompt(reader *bufio.Reader, currentScriptDir string, currentScriptDirFS fs.FS, phase idl.Step) ([]string, error)

func SetBashCommand ¶

func SetBashCommand(command exectest.Command)

func SetBootstrapConnectionFunction ¶

func SetBootstrapConnectionFunction(connectionFunc func(destination idl.ClusterDestination, gphome string, port int) (*sql.DB, error))

XXX: for internal testing only

func SetPsqlCommand ¶

func SetPsqlCommand(command exectest.Command)

func SetPsqlFileCommand ¶

func SetPsqlFileCommand(command exectest.Command)

func StartHub ¶

func StartHub(streams step.OutStreams) (err error)

func UILoop ¶

func UILoop(stream receiver, verbose bool) (*idl.Response, error)

Types ¶

type DatabaseInfo ¶

type DatabaseInfo struct {
	Datname        string
	QuotedDatname  string
	NumSeedScripts int
}

func GetDatabases ¶

func GetDatabases(db *sql.DB, seedDirFS fs.FS) ([]DatabaseInfo, error)

type Script ¶

type Script struct {
	Num  uint64
	Name string
}

type Scripts ¶

type Scripts []Script

func ParseSelection ¶

func ParseSelection(input string, allScripts Scripts) (Scripts, error)

func (Scripts) Description ¶

func (scripts Scripts) Description() string

func (Scripts) Find ¶

func (scripts Scripts) Find(num uint64) Script

func (Scripts) Len ¶

func (scripts Scripts) Len() int

func (Scripts) Less ¶

func (scripts Scripts) Less(i, j int) bool

func (Scripts) Names ¶

func (scripts Scripts) Names() []string

func (Scripts) String ¶

func (scripts Scripts) String() string

func (Scripts) Swap ¶

func (scripts Scripts) Swap(i, j int)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL