reloader

Documentation

Index

• Constants
• func DiffPipelineConfigs(ignoreFunc control.FileIgnore) (newCfg *control.PipelineConfig, diffPipes []string, ...)
• func Setup(stopCh <-chan struct{}, controller *control.Controller, config *ReloadConfig)
• type ReloadConfig

Constants

const HandleReadPipelineConfigPath = "/api/v1/reload/config"

Functions

func DiffPipelineConfigs

func DiffPipelineConfigs(ignoreFunc control.FileIgnore) (newCfg *control.PipelineConfig, diffPipes []string, stopComponentList []pipeline.Config, startComponentList []pipeline.Config)

func Setup

func Setup(stopCh <-chan struct{}, controller *control.Controller, config *ReloadConfig)

Types

type ReloadConfig

type ReloadConfig struct {
	Enabled      bool          `yaml:"enabled"`
	ConfigPath   string        `yaml:"-"`
	ReloadPeriod time.Duration `yaml:"period" default:"10s"`
}