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.