slot

Documentation

Index

• Variables
• type Config
  • func (c Config) Validate() error
• type Info
• type Slot
  • func NewSlot(ctx context.Context, dsn string, cfg Config, m metric.Metric) (*Slot, error)
  • func (s *Slot) Close()
  • func (s *Slot) Create(ctx context.Context) (*Info, error)
  • func (s *Slot) Info(ctx context.Context) (*Info, error)
  • func (s *Slot) Metrics(ctx context.Context)
• type Type

Variables

var (
	ErrorSlotIsNotExists = goerrors.New("slot is not exists")
)

Types

type Config

type Config struct {
	Name                        string        `json:"name" yaml:"name"`
	SlotActivityCheckerInterval time.Duration `json:"slotActivityCheckerInterval" yaml:"slotActivityCheckerInterval"`
	CreateIfNotExists           bool          `json:"createIfNotExists" yaml:"createIfNotExists"`
}

func (Config) Validate

func (c Config) Validate() error

type Info

type Info struct {
	Name              string `json:"name"`
	Type              Type   `json:"type"`
	WalStatus         string `json:"walStatus"`
	RestartLSN        pq.LSN `json:"restartLSN"`
	ConfirmedFlushLSN pq.LSN `json:"confirmedFlushLSN"`
	CurrentLSN        pq.LSN `json:"currentLSN"`
	RetainedWALSize   pq.LSN `json:"retainedWALSize"`
	Lag               pq.LSN `json:"lag"`
	ActivePID         int32  `json:"activePID"`
	Active            bool   `json:"active"`
}

type Slot

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

func NewSlot

func NewSlot(ctx context.Context, dsn string, cfg Config, m metric.Metric) (*Slot, error)

func (*Slot) Close

func (s *Slot) Close()

func (*Slot) Create

func (s *Slot) Create(ctx context.Context) (*Info, error)

func (*Slot) Info

func (s *Slot) Info(ctx context.Context) (*Info, error)

func (*Slot) Metrics

func (s *Slot) Metrics(ctx context.Context)

type Type

type Type string

const (
	Logical  Type = "logical"
	Physical Type = "physical"
)