cmd

Documentation

Index

• Variables
• func Execute()
• func IsMaster(db *cluster.DB) bool
• type DBLocalState
  • func (s *DBLocalState) DeepCopy() *DBLocalState
• type KeeperLocalState
• type PostgresKeeper
  • func NewPostgresKeeper(cfg *config, end chan error) (*PostgresKeeper, error)
  • func (p *PostgresKeeper) GetInSyncStandbys() ([]string, error)
  • func (p *PostgresKeeper) GetPGState(pctx context.Context) (*cluster.PostgresState, error)
  • func (p *PostgresKeeper) Start(ctx context.Context)

Variables

var CmdKeeper = &cobra.Command{
	Use:     "stolon-keeper",
	Run:     keeper,
	Version: cmd.Version,
}

Functions

func Execute

func Execute()

func IsMaster

func IsMaster(db *cluster.DB) bool

IsMaster return if the db is the cluster master db. A master is a db that: * Has a master db role or * Has a standby db role with followtype external

Types

type DBLocalState

type DBLocalState struct {
	UID        string
	Generation int64
	// Initializing registers when the db is initializing. Needed to detect
	// when the initialization has failed.
	Initializing bool
	// InitPGParameters contains the postgres parameter after the
	// initialization
	InitPGParameters common.Parameters
}

func (*DBLocalState) DeepCopy

func (s *DBLocalState) DeepCopy() *DBLocalState

type KeeperLocalState

type KeeperLocalState struct {
	UID        string
	ClusterUID string
}

type PostgresKeeper

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

func NewPostgresKeeper

func NewPostgresKeeper(cfg *config, end chan error) (*PostgresKeeper, error)

func (*PostgresKeeper) GetInSyncStandbys

func (p *PostgresKeeper) GetInSyncStandbys() ([]string, error)

func (*PostgresKeeper) GetPGState

func (p *PostgresKeeper) GetPGState(pctx context.Context) (*cluster.PostgresState, error)

func (*PostgresKeeper) Start

func (p *PostgresKeeper) Start(ctx context.Context)