nodemanager

Documentation

Index

• type App
  • func New(config *Config, modules *Modules, zlogger *zap.Logger) *App
  • func (a *App) IsReady() bool
  • func (a *App) Run() error
• type Config
• type Modules

Types

type App

type App struct {
	*shutter.Shutter
	// contains filtered or unexported fields
}

func New

func New(config *Config, modules *Modules, zlogger *zap.Logger) *App

func (*App) IsReady

func (a *App) IsReady() bool

func (*App) Run

func (a *App) Run() error

type Config

type Config struct {
	GRPCAddr string
	HTTPAddr string

	// Backup Flags
	AutoBackupModulo        int
	AutoBackupPeriod        time.Duration
	AutoBackupHostnameMatch string // If non-empty, will only apply autobackup if we have that hostname

	// Snapshot Flags
	AutoSnapshotModulo        int
	AutoSnapshotPeriod        time.Duration
	AutoSnapshotHostnameMatch string // If non-empty, will only apply autosnapshot if we have that hostname

	// Volume Snapshot Flags
	AutoVolumeSnapshotModulo         int
	AutoVolumeSnapshotPeriod         time.Duration
	AutoVolumeSnapshotSpecificBlocks []uint64

	StartupDelay       time.Duration
	ConnectionWatchdog bool
}

type Modules

type Modules struct {
	Operator                     *operator.Operator
	MetricsAndReadinessManager   *nodeManager.MetricsAndReadinessManager
	LaunchConnectionWatchdogFunc func(terminating <-chan struct{})
	MindreaderPlugin             *mindreader.MindReaderPlugin
	RegisterGRPCService          func(server *grpc.Server) error
	StartFailureHandlerFunc      func()
}