Documentation
      ¶
    
    
  
    
  
    Index ¶
- Constants
 - Variables
 - func PGPort() string
 - type Config
 - type Credentials
 - type KeeperState
 - type Node
 - func (n *Node) GetStolonClusterData() (s stolon.ClusterData, err error)
 - func (n *Node) IsPrimaryRegion() bool
 - func (n *Node) NewLeaderConnection(ctx context.Context) (*pgx.Conn, error)
 - func (n *Node) NewLocalConnection(ctx context.Context) (*pgx.Conn, error)
 - func (n *Node) NewProxyConnection(ctx context.Context) (*pgx.Conn, error)
 
- type Setting
 - type Settings
 
Constants ¶
      View Source
      
  
    const ( BackendStoreConsul = "consul" BackendStoreEtcd = "etcdv3" BackendStoreUnspecified = "" )
      View Source
      
  
    const InitModeExisting = "existing"
    
      View Source
      
  
const InitModeNew = "new"
    Variables ¶
      View Source
      
  
var ErrClusterNotInitialized = errors.New("cluster not initialized")
    Functions ¶
Types ¶
type Config ¶
type Config struct {
	InitMode                  string            `json:"initMode"`
	ExistingConfig            map[string]string `json:"existingConfig"`
	PGParameters              map[string]string `json:"pgParameters"`
	MaxStandbysPerSender      int               `json:"maxStandbysPerSender"`
	DeadKeeperRemovalInterval string            `json:"deadKeeperRemovalInterval"`
}
    func InitConfig ¶
type Credentials ¶
type KeeperState ¶
type Node ¶
type Node struct {
	AppName       string
	PrivateIP     net.IP
	Region        string
	PrimaryRegion string
	DataDir       string
	SUCredentials       Credentials
	ReplCredentials     Credentials
	OperatorCredentials Credentials
	BackendStore    string
	BackendStoreURL *url.URL
	KeeperUID string
	StoreNode string
	PGPort      int
	PGProxyPort int
}
    func (*Node) GetStolonClusterData ¶
func (n *Node) GetStolonClusterData() (s stolon.ClusterData, err error)
func (*Node) IsPrimaryRegion ¶
func (*Node) NewLeaderConnection ¶
func (*Node) NewLocalConnection ¶
type Setting ¶ added in v0.0.20
type Setting struct {
	Name           *string   `json:"name,omitempty"`
	Setting        *string   `json:"setting,omitempty"`
	Context        *string   `json:"context,omitempty"`
	VarType        *string   `json:"vartype,omitempty"`
	MinVal         *string   `json:"min_val,omitempty"`
	MaxVal         *string   `json:"max_val,omitempty"`
	EnumVals       []*string `json:"enumvals,omitempty"`
	Unit           *string   `json:"unit,omitempty"`
	ShortDesc      *string   `json:"short_desc,omitempty"`
	PendingChange  *string   `json:"pending_change,omitempty"`
	PendingRestart bool      `json:"pending_restart,omitempty"`
}
     Click to show internal directories. 
   Click to hide internal directories.