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)
 
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"`
}
    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 ¶
 Click to show internal directories. 
   Click to hide internal directories.