patroni

Documentation

Index

• type Interface
• type MemberData
• type MemberDataPatroni
• type Patroni
  • func New(logger *logrus.Entry, client httpclient.HTTPClient) *Patroni
  • func (p *Patroni) GetConfig(server *v1.Pod) (acidv1.Patroni, map[string]string, error)
  • func (p *Patroni) GetMemberData(server *v1.Pod) (MemberData, error)
  • func (p *Patroni) Restart(server *v1.Pod) error
  • func (p *Patroni) SetConfig(server *v1.Pod, config map[string]interface{}) error
  • func (p *Patroni) SetPostgresParameters(server *v1.Pod, parameters map[string]string) error
  • func (p *Patroni) Switchover(master *v1.Pod, candidate string) error

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) (acidv1.Patroni, map[string]string, error)
	SetConfig(server *v1.Pod, config map[string]interface{}) error
}

Interface describe patroni methods

type MemberData

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

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

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

func (*Patroni) GetMemberData

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

GetMemberData read member data from patroni API

func (*Patroni) Restart

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

Restart method restarts instance via Patroni POST API call.

func (*Patroni) SetConfig

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