patroni

package

v1.7.0 Latest Latest Go to latest Published: Aug 27, 2021 License: MIT Imports: 11 Imported by: 2

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/zalando/postgres-operator

Links

Open Source Insights

Documentation ¶

Index ¶

type Interface
type MemberData
type MemberDataPatroni
type Patroni
- func New(logger *logrus.Entry, client httpclient.HTTPClient) *Patroni

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Interface ¶

type Interface interface {
	Switchover(master *v1.Pod, candidate string) error
	SetPostgresParameters(server *v1.Pod, options map[string]string) error
	GetMemberData(server *v1.Pod) (MemberData, error)
	Restart(server *v1.Pod) error
	GetConfig(server *v1.Pod) (map[string]interface{}, error)
	SetConfig(server *v1.Pod, config map[string]interface{}) error
}

Interface describe patroni methods

type MemberData ¶ added in v1.6.2

type MemberData struct {
	State           string            `json:"state"`
	Role            string            `json:"role"`
	ServerVersion   int               `json:"server_version"`
	PendingRestart  bool              `json:"pending_restart"`
	ClusterUnlocked bool              `json:"cluster_unlocked"`
	Patroni         MemberDataPatroni `json:"patroni"`
}

MemberData Patroni member data from Patroni API

type MemberDataPatroni ¶ added in v1.6.2

type MemberDataPatroni struct {
	Version string `json:"version"`
	Scope   string `json:"scope"`
}

MemberDataPatroni child element

type Patroni ¶

type Patroni struct {
	// contains filtered or unexported fields
}

Patroni API client

func New ¶

func New(logger *logrus.Entry, client httpclient.HTTPClient) *Patroni

New create patroni

func (*Patroni) GetConfig ¶ added in v1.7.0

func (p *Patroni) GetConfig(server *v1.Pod) (map[string]interface{}, error)

func (*Patroni) GetConfigOrStatus ¶ added in v1.7.0

func (p *Patroni) GetConfigOrStatus(server *v1.Pod, path string) (map[string]interface{}, error)

func (*Patroni) GetMemberData ¶ added in v1.6.2

func (p *Patroni) GetMemberData(server *v1.Pod) (MemberData, error)

GetMemberData read member data from patroni API

func (*Patroni) GetStatus ¶ added in v1.7.0

func (p *Patroni) GetStatus(server *v1.Pod) (map[string]interface{}, error)

func (*Patroni) Restart ¶ added in v1.7.0

func (p *Patroni) Restart(server *v1.Pod) error

Restart method restarts instance via Patroni POST API call.

func (*Patroni) SetConfig ¶ added in v1.7.0

func (p *Patroni) SetConfig(server *v1.Pod, config map[string]interface{}) error

SetConfig sets Patroni options via Patroni patch API call.

func (*Patroni) SetPostgresParameters ¶

func (p *Patroni) SetPostgresParameters(server *v1.Pod, parameters map[string]string) error

SetPostgresParameters sets Postgres options via Patroni patch API call.

func (*Patroni) Switchover ¶

func (p *Patroni) Switchover(master *v1.Pod, candidate string) error

Switchover by calling Patroni REST API

Source Files ¶

View all Source files

patroni.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL