Documentation
¶
Index ¶
- Constants
- Variables
- func CreateTigrisBucket(ctx context.Context, config *CreateClusterInput) error
- func ErrorStatus(err error) int
- type Client
- func (c *Client) CreateDatabase(ctx context.Context, name string) error
- func (c *Client) CreateUser(ctx context.Context, name, password string, superuser bool) error
- func (c *Client) DatabaseExists(ctx context.Context, name string) (bool, error)
- func (c Client) DeleteUser(ctx context.Context, name string) error
- func (c *Client) Do(ctx context.Context, method, path string, in, out interface{}) error
- func (c *Client) Failover(ctx context.Context) error
- func (c *Client) ListDatabases(ctx context.Context) ([]PostgresDatabase, error)
- func (c *Client) ListUsers(ctx context.Context) ([]PostgresUser, error)
- func (c *Client) NewRequest(path string, method string, in interface{}) (*http.Request, error)
- func (c *Client) SyncSettings(ctx context.Context) error
- func (c *Client) UpdateSettings(ctx context.Context, settings map[string]string) error
- func (c *Client) UserExists(ctx context.Context, name string) (bool, error)
- func (c *Client) ViewSettings(ctx context.Context, settings []string, manager string) (*PGSettings, error)
- type Command
- func (pc *Command) ListEvents(ctx context.Context, leaderIP string, flagsName []string) error
- func (pc *Command) UnregisterMember(ctx context.Context, leaderIP string, standbyNodeName string) error
- func (pc *Command) UpdateSettings(ctx context.Context, leaderIp string, config map[string]string) error
- type CommandResponse
- type CreateClusterInput
- type CreateDatabaseRequest
- type CreateUserRequest
- type DatabaseListResponse
- type DeleteDatabaseRequest
- type DeleteUserRequest
- type Error
- type FindDatabaseResponse
- type FindUserResponse
- type GrantAccessRequest
- type Launcher
- type NodeRoleResponse
- type PGSetting
- type PGSettings
- type PostgresDatabase
- type PostgresUser
- type ReadonlyResponse
- type ReplicationStat
- type ReplicationStatsResponse
- type RestartResponse
- type RevokeAccessRequest
- type SettingsViewResponse
- type StolonDBUidResponse
- type UserListResponse
Constants ¶
View Source
const (
ReplicationManager = "repmgr"
StolonManager = "stolon"
)
Variables ¶
View Source
var (
Duration10s, _ = time.ParseDuration("10s")
Duration15s, _ = time.ParseDuration("15s")
CheckPathPg = "/flycheck/pg"
CheckPathRole = "/flycheck/role"
CheckPathVm = "/flycheck/vm"
BarmanSecretName = "S3_ARCHIVE_CONFIG"
)
Functions ¶
func CreateTigrisBucket ¶ added in v0.2.89
func CreateTigrisBucket(ctx context.Context, config *CreateClusterInput) error
func ErrorStatus ¶
func ErrorStatus(err error) int
Types ¶
type Client ¶
type Client struct {
BaseURL string
// contains filtered or unexported fields
}
func NewFromInstance ¶
func NewFromInstance(address string, dialer agent.Dialer) *Client
NewFromInstance creates a new Client that targets a specific instance(address)
func (*Client) CreateDatabase ¶
func (c *Client) CreateDatabase(ctx context.Context, name string) error
func (*Client) CreateUser ¶
func (c *Client) CreateUser(ctx context.Context, name, password string, superuser bool) error
func (*Client) DatabaseExists ¶
func (c *Client) DatabaseExists(ctx context.Context, name string) (bool, error)
func (Client) DeleteUser ¶
func (c Client) DeleteUser(ctx context.Context, name string) error
func (*Client) Do ¶
func (c *Client) Do(ctx context.Context, method, path string, in, out interface{}) error
func (*Client) ListDatabases ¶
func (c *Client) ListDatabases(ctx context.Context) ([]PostgresDatabase, error)
func (*Client) NewRequest ¶
func (c *Client) NewRequest(path string, method string, in interface{}) (*http.Request, error)
func (*Client) SyncSettings ¶ added in v0.0.451
func (c *Client) SyncSettings(ctx context.Context) error
SyncSettings is specific to the repmgr/flex implementation.
func (*Client) UpdateSettings ¶ added in v0.0.438
func (c *Client) UpdateSettings(ctx context.Context, settings map[string]string) error
func (*Client) UserExists ¶
func (c *Client) UserExists(ctx context.Context, name string) (bool, error)
func (*Client) ViewSettings ¶ added in v0.0.438
func (c *Client) ViewSettings(ctx context.Context, settings []string, manager string) (*PGSettings, error)
type Command ¶ added in v0.0.367
type Command struct {
// contains filtered or unexported fields
}
func NewCommand ¶ added in v0.0.367
func NewCommand(ctx context.Context, app *fly.AppCompact) (*Command, error)
func (*Command) ListEvents ¶ added in v0.1.1
func (pc *Command) ListEvents(ctx context.Context, leaderIP string, flagsName []string) error
func (*Command) UnregisterMember ¶ added in v0.0.451
func (pc *Command) UnregisterMember(ctx context.Context, leaderIP string, standbyNodeName string) error
func (*Command) UpdateSettings ¶ added in v0.0.367
func (pc *Command) UpdateSettings(ctx context.Context, leaderIp string, config map[string]string) error
type CommandResponse ¶
type CommandResponse struct {
Result bool `json:"result"`
Error string `json:"error"`
}
type CreateClusterInput ¶ added in v0.0.367
type CreateClusterInput struct {
AppName string
ConsulURL string
ImageRef string
InitialClusterSize int
Organization *fly.Organization
Password string
Region string
VolumeSize *int
// VMSize is deprecated, specify Guest instead.
VMSize *fly.VMSize
Guest *fly.MachineGuest
SnapshotID *string
Manager string
Autostart bool
ScaleToZero bool
ForkFrom string
BackupsEnabled bool
BarmanSecret string
BarmanRemoteRestoreConfig string
RestoreTargetName string
RestoreTargetTime string
RestoreTargetInclusive bool
}
type CreateDatabaseRequest ¶
type CreateDatabaseRequest struct {
Name string `json:"name"`
}
type CreateUserRequest ¶
type CreateUserRequest struct {
Username string `json:"username"`
Password string `json:"password"`
Superuser bool `json:"superuser"`
}
type DatabaseListResponse ¶
type DatabaseListResponse struct {
Result []PostgresDatabase
}
type DeleteDatabaseRequest ¶
type DeleteDatabaseRequest struct {
Name string `json:"name"`
}
type DeleteUserRequest ¶
type DeleteUserRequest struct {
Username string `json:"username"`
}
type FindDatabaseResponse ¶
type FindDatabaseResponse struct {
Result PostgresDatabase
}
type FindUserResponse ¶
type FindUserResponse struct {
Result PostgresUser
}
type GrantAccessRequest ¶
type GrantAccessRequest struct {
Database string `json:"database"`
Username string `json:"username"`
}
type Launcher ¶ added in v0.0.367
type Launcher struct {
// contains filtered or unexported fields
}
func NewLauncher ¶ added in v0.0.367
func NewLauncher(client flyutil.Client) *Launcher
func (*Launcher) LaunchMachinesPostgres ¶ added in v0.0.367
func (l *Launcher) LaunchMachinesPostgres(ctx context.Context, config *CreateClusterInput, detach bool) error
LaunchMachinesPostgres launches a postgres cluster using the machines runtime
type NodeRoleResponse ¶
type NodeRoleResponse struct {
Result string
}
type PGSetting ¶
type PGSetting struct {
Name string `json:"name,omitempty"`
Setting string `json:"setting,omitempty"`
VarType string `json:"vartype,omitempty"`
MinVal string `json:"min_val,omitempty"`
MaxVal string `json:"max_val,omitempty"`
EnumVals []string `json:"enumvals,omitempty"`
Context string `json:"context,omitempty"`
Unit string `json:"unit,omitempty"`
Desc string `json:"short_desc,omitempty"`
PendingChange string `json:"pending_change,omitempty"`
PendingRestart bool `json:"pending_restart,omitempty"`
}
type PGSettings ¶
type PGSettings struct {
Settings []PGSetting `json:"settings,omitempty"`
}
type PostgresDatabase ¶
type PostgresDatabase struct {
Name string
Users []string
}
type PostgresUser ¶
type PostgresUser struct {
Username string
Superuser bool
Databases []string
}
type ReadonlyResponse ¶ added in v0.0.510
type ReadonlyResponse struct {
Result bool
}
type ReplicationStat ¶ added in v0.0.510
type ReplicationStat struct {
Name string `json:"name"`
Diff int `json:"diff"`
}
type ReplicationStatsResponse ¶ added in v0.0.510
type ReplicationStatsResponse struct {
Result []ReplicationStat
}
type RestartResponse ¶
type RestartResponse struct {
Result string
}
type RevokeAccessRequest ¶
type RevokeAccessRequest struct {
Database string `json:"database"`
Username string `json:"username"`
}
type SettingsViewResponse ¶
type SettingsViewResponse struct {
Result PGSettings
}
type StolonDBUidResponse ¶ added in v0.0.510
type StolonDBUidResponse struct {
Result string
}
type UserListResponse ¶
type UserListResponse struct {
Result []PostgresUser
}
Click to show internal directories.
Click to hide internal directories.