check

Documentation

Index

• type Check
• type Framework
• type Manager
  • func NewCheckManager(name string, fw Framework) (*Manager, error)
  • func (c *Manager) Check() *Check
  • func (c *Manager) Instance() interface{}
  • func (c *Manager) Set(check *Check) error
  • func (c *Manager) Start(ctx context.Context, wg *sync.WaitGroup) error
  • func (c *Manager) Stop(rm bool)
  • func (c *Manager) Update(u interface{})
  • func (c *Manager) WriteMachine() error

Types

type Check

type Check struct {
	Name              string        `json:"name"`
	Plugin            string        `json:"plugin"`
	Builtin           string        `json:"builtin"`
	Arguments         string        `json:"arguments"`
	PluginTimeout     time.Duration `json:"plugin_timeout"`
	CheckInterval     time.Duration `json:"check_interval"`
	RemediateCommand  string        `json:"remediate_command"`
	RemediateInterval time.Duration `json:"remediate_interval"`
}

type Framework

type Framework interface {
	NATSConn() *nats.Conn
	Logger(string) *logrus.Entry
	MachineSourceDir() string
}

type Manager

type Manager struct {
	logger.Logrus
	updatenotifier.Notifier
	sync.Mutex
	// contains filtered or unexported fields
}

func NewCheckManager

func NewCheckManager(name string, fw Framework) (*Manager, error)

func (*Manager) Check

func (c *Manager) Check() *Check

func (*Manager) Instance

func (c *Manager) Instance() interface{}

Instance implements stream.updatable

func (*Manager) Set

func (c *Manager) Set(check *Check) error

func (*Manager) Start

func (c *Manager) Start(ctx context.Context, wg *sync.WaitGroup) error

func (*Manager) Stop

func (c *Manager) Stop(rm bool)

func (*Manager) Update

func (c *Manager) Update(u interface{})

Update implements stream.updatable

func (*Manager) WriteMachine

func (c *Manager) WriteMachine() error