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.