cluster

Jan 30, 2024

Changes in this version

type SegConfig

+ Address string

+ Mode string

+ PreferredRole string

+ Status string

+ func GetSegmentConfigurationFromFile(coordinatorDataDir string) ([]SegConfig, error)

Dec 23, 2022

Changes in this version

type Scope

+ const EXCLUDE_COORDINATOR

+ const INCLUDE_COORDINATOR

Aug 19, 2022

Changes in this version

type ShellCommand

+ Completed bool

Apr 2, 2020

Changes in this version

type Cluster

+ ByContent map[int][]*SegConfig

+ ByHost map[string][]*SegConfig

+ Hostnames []string

+ func (cluster *Cluster) GenerateCommandList(scope Scope, generator interface{}) []ShellCommand

+ func (cluster *Cluster) GenerateSSHCommandList(scope Scope, generator interface{}) []ShellCommand

+ func (cluster *Cluster) GetContentsForHost(hostname string) []int

+ func (cluster *Cluster) GetDbidsForHost(hostname string) []int

+ func (cluster *Cluster) GetDirsForHost(hostname string) []string

+ func (cluster *Cluster) GetPortsForHost(hostname string) []int

type RemoteOutput

+ Commands []ShellCommand

+ FailedCommands []*ShellCommand

+ func NewRemoteOutput(scope Scope, numErrors int, commands []ShellCommand) *RemoteOutput

+ type Scope uint8

+ const EXCLUDE_MASTER

+ const EXCLUDE_MIRRORS

+ const INCLUDE_MASTER

+ const INCLUDE_MIRRORS

+ const ON_LOCAL

+ const ON_REMOTE

type SegConfig

+ Role string

+ type ShellCommand struct

+ Command *exec.Cmd

+ CommandString string

+ Content int

+ Error error

+ Host string

+ Scope Scope

+ Stderr string

+ Stdout string

+ func NewShellCommand(scope Scope, content int, host string, command []string) ShellCommand

Jan 9, 2020

Changes in this version

+ const ON_MASTER_TO_HOSTS

+ const ON_MASTER_TO_HOSTS_AND_MASTER

+ const ON_MASTER_TO_SEGMENTS

+ const ON_MASTER_TO_SEGMENTS_AND_MASTER

type Cluster

+ func (cluster *Cluster) GenerateLocalCommandMapForHosts(includeMaster bool, generateCommand func(int) string) map[int][]string

+ func (cluster *Cluster) GenerateLocalCommandMapForSegments(includeMaster bool, generateCommand func(int) string) map[int][]string

Feb 18, 2019

Changes in this version

+ const ON_HOSTS

+ const ON_HOSTS_AND_MASTER

+ const ON_SEGMENTS

+ const ON_SEGMENTS_AND_MASTER

+ func ConstructSSHCommand(host string, cmd string) []string

+ func LogFatalClusterError(errMessage string, scope int, numErrors int)

+ type Cluster struct

+ ContentIDs []int

+ Segments map[int]SegConfig

+ func NewCluster(segConfigs []SegConfig) *Cluster

+ func (cluster *Cluster) CheckClusterError(remoteOutput *RemoteOutput, finalErrMsg string, ...)

+ func (cluster *Cluster) GenerateAndExecuteCommand(verboseMsg string, execFunc func(contentID int) string, scope int) *RemoteOutput

+ func (cluster *Cluster) GenerateSSHCommandMapForHosts(includeMaster bool, generateCommand func(int) string) map[int][]string

+ func (cluster *Cluster) GenerateSSHCommandMapForSegments(includeMaster bool, generateCommand func(int) string) map[int][]string

+ func (cluster *Cluster) GenerateSegmentSSHCommand(contentID int, generateCommand func(int) string) []string

+ func (cluster *Cluster) GetContentList() []int

+ func (cluster *Cluster) GetDbidForContent(contentID int) int

+ func (cluster *Cluster) GetDirForContent(contentID int) string

+ func (cluster *Cluster) GetHostForContent(contentID int) string

+ func (cluster *Cluster) GetPortForContent(contentID int) int

+ type Executor interface

+ ExecuteClusterCommand func(scope int, commandMap map[int][]string) *RemoteOutput

+ ExecuteLocalCommand func(commandStr string) (string, error)

+ type GPDBExecutor struct

+ func (executor *GPDBExecutor) ExecuteClusterCommand(scope int, commandMap map[int][]string) *RemoteOutput

+ func (executor *GPDBExecutor) ExecuteLocalCommand(commandStr string) (string, error)

+ type RemoteOutput struct

+ CmdStrs map[int]string

+ Errors map[int]error

+ NumErrors int

+ Scope int

+ Stderrs map[int]string

+ Stdouts map[int]string

+ type SegConfig struct

+ ContentID int

+ DataDir string

+ DbID int

+ Hostname string

+ Port int

+ func GetSegmentConfiguration(connection *dbconn.DBConn) ([]SegConfig, error)

+ func MustGetSegmentConfiguration(connection *dbconn.DBConn) []SegConfig