supervisord

Documentation

Overview

Package supervisord provides facilities for working with Supervisord.

Index

• type Logs
  • func NewLogs(pmmVersion string) *Logs
  • func (l *Logs) Zip(ctx context.Context, w io.Writer) error
• type Service
  • func New() *Service
  • func (s *Service) PMMUpdateRunning() bool
  • func (s *Service) Run(ctx context.Context)
  • func (s *Service) StartPMMUpdate() error

Types

type Logs

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

Logs is responsible for interactions with logs.

func NewLogs

func NewLogs(pmmVersion string) *Logs

NewLogs creates a new Logs service. n is a number of last lines of log to read.

func (*Logs) Zip

func (l *Logs) Zip(ctx context.Context, w io.Writer) error

Zip creates .zip archive with all logs.

type Service

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

Service is responsible for interactions with Supervisord via supervisorctl.

func New

func New() *Service

New creates new service.

func (*Service) PMMUpdateRunning

func (s *Service) PMMUpdateRunning() bool

PMMUpdateRunning returns true if pmm-update-perform supervisord program is running or being restarted, false if it is not running / failed.

func (*Service) Run

func (s *Service) Run(ctx context.Context)

Run reads supervisord's log (maintail) and sends events to subscribers.

func (*Service) StartPMMUpdate

func (s *Service) StartPMMUpdate() error

StartPMMUpdate starts pmm-update-perform supervisord program with some preparations.