postgresql

Documentation

Index

• Constants
• Variables
• type Config
• type Handler
  • func NewHandler() *Handler
  • func (h *Handler) ServeHTTP(w http.ResponseWriter, req *http.Request)
• type Process
  • func NewProcess(c Config) *Process
  • func (p *Process) Info() (*client.DatabaseInfo, error)
  • func (p *Process) Ready() <-chan state.DatabaseEvent
  • func (p *Process) Reconfigure(config *state.Config) error
  • func (p *Process) Start() error
  • func (p *Process) Stop() error
  • func (p *Process) XLog() xlog.XLog
  • func (p *Process) XLogPosition() (xlog.Position, error)

Constants

const (
	IDKey = "POSTGRES_ID"
)

Variables

var ErrNoReplicationStatus = errors.New("no replication status")

Types

type Config

type Config struct {
	ID           string
	Singleton    bool
	Port         string
	BinDir       string
	DataDir      string
	Password     string
	OpTimeout    time.Duration
	ReplTimeout  time.Duration
	Logger       log15.Logger
	TimescaleDB  bool
	ExtWhitelist bool
	SHMType      string
	WaitUpstream bool
}

type Handler

type Handler struct {
	Process     *Process
	Peer        *state.Peer
	Heartbeater discoverd.Heartbeater
	Logger      log15.Logger
	// contains filtered or unexported fields
}

Handler represents an HTTP API handler for the process.

func NewHandler

func NewHandler() *Handler

NewHandler returns a new instance of Handler.

func (*Handler) ServeHTTP

func (h *Handler) ServeHTTP(w http.ResponseWriter, req *http.Request)

type Process

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

func NewProcess

func NewProcess(c Config) *Process

func (*Process) Info

func (p *Process) Info() (*client.DatabaseInfo, error)

func (*Process) Ready

func (p *Process) Ready() <-chan state.DatabaseEvent

func (*Process) Reconfigure

func (p *Process) Reconfigure(config *state.Config) error

func (*Process) Start

func (p *Process) Start() error

func (*Process) Stop

func (p *Process) Stop() error

func (*Process) XLog

func (p *Process) XLog() xlog.XLog

func (*Process) XLogPosition

func (p *Process) XLogPosition() (xlog.Position, error)