logstate

Documentation

Index

• type LogManager
  • func NewLogManager() *LogManager
  • func (m *LogManager) Ensure() error
  • func (m *LogManager) PlanChanged(pl *plan.Plan)
  • func (m *LogManager) ServiceStarted(service *plan.Service, buffer *servicelog.RingBuffer)
  • func (m *LogManager) Stop()

Types

type LogManager

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

func NewLogManager

func NewLogManager() *LogManager

func (*LogManager) Ensure

func (m *LogManager) Ensure() error

Ensure implements overlord.StateManager.

func (*LogManager) PlanChanged

func (m *LogManager) PlanChanged(pl *plan.Plan)

PlanChanged is called by the service manager when the plan changes. Based on the new plan, we will Stop old gatherers and start new ones.

func (*LogManager) ServiceStarted

func (m *LogManager) ServiceStarted(service *plan.Service, buffer *servicelog.RingBuffer)

ServiceStarted notifies the log manager that the named service has started, and provides a reference to the service's log buffer.

func (*LogManager) Stop

func (m *LogManager) Stop()

Stop implements overlord.StateStopper and stops all log forwarding.