carbon

Documentation

Index

• Constants
• func ParseConfig(filename string, cfg interface{}) error
• func PrintConfig(cfg interface{}) error
• func RestoreFromDir(dumpDir string, storeFunc func(*points.Points))
• func RestoreFromFile(filename string, storeFunc func(*points.Points)) error
• func RuntimeStat(send helper.StatCallback)
• func TestConfig(rootDir string) string
• type App
  • func New(configFilename string) *App
  • func (app *App) DumpStop() error
  • func (app *App) Loop()
  • func (app *App) ParseConfig() error
  • func (app *App) ReloadConfig() error
  • func (app *App) Restore(storeFunc func(*points.Points), path string, rps int)
  • func (app *App) Start() (err error)
  • func (app *App) Stop()
• type Collector
  • func NewCollector(app *App) *Collector
• type Config
  • func NewConfig() *Config
• type Duration
  • func (d *Duration) MarshalText() ([]byte, error)
  • func (d *Duration) UnmarshalText(text []byte) error
  • func (d *Duration) Value() time.Duration
• type SyncWriter
  • func (s *SyncWriter) Flush() error
  • func (s *SyncWriter) Write(p []byte) (n int, err error)

Constants

const MetricEndpointLocal = "local"

Functions

func ParseConfig

func ParseConfig(filename string, cfg interface{}) error

ParseConfig ...

func PrintConfig

func PrintConfig(cfg interface{}) error

PrintConfig ...

func RestoreFromDir

func RestoreFromDir(dumpDir string, storeFunc func(*points.Points))

RestoreFromDir cache and input dumps from disk to memory

func RestoreFromFile

func RestoreFromFile(filename string, storeFunc func(*points.Points)) error

RestoreFromFile read and parse data from single file

func RuntimeStat

func RuntimeStat(send helper.StatCallback)

func TestConfig

func TestConfig(rootDir string) string

TestConfig creates config with all files in root directory

Types

type App

type App struct {
	sync.RWMutex
	ConfigFilename string
	Config         *Config
	Cache          *cache.Cache
	UDP            receiver.Receiver
	TCP            receiver.Receiver
	Pickle         receiver.Receiver
	CarbonLink     *cache.CarbonlinkListener
	Persister      *persister.Whisper
	Carbonserver   *carbonserver.CarbonserverListener
	Collector      *Collector // (!!!) Should be re-created on every change config/modules
	// contains filtered or unexported fields
}

func New

func New(configFilename string) *App

New App instance

func (*App) DumpStop

func (app *App) DumpStop() error

DumpStop implements gracefully stop: * Start writing all new data to xlogs * Stop cache worker * Dump all cache to file * Stop listeners * Close xlogs * Exit application

func (*App) Loop

func (app *App) Loop()

Loop ...

func (*App) ParseConfig

func (app *App) ParseConfig() error

ParseConfig loads config from config file, schemas.conf, aggregation.conf

func (*App) ReloadConfig

func (app *App) ReloadConfig() error

ReloadConfig reloads some settings from config

func (*App) Restore

func (app *App) Restore(storeFunc func(*points.Points), path string, rps int)

Restore from dump.path

func (*App) Start

func (app *App) Start() (err error)

Start starts

func (*App) Stop

func (app *App) Stop()

Stop force stop all components

type Collector

type Collector struct {
	helper.Stoppable
	// contains filtered or unexported fields
}

func NewCollector

func NewCollector(app *App) *Collector

type Config

type Config struct {
	Common       commonConfig       `toml:"common"`
	Whisper      whisperConfig      `toml:"whisper"`
	Cache        cacheConfig        `toml:"cache"`
	Udp          udpConfig          `toml:"udp"`
	Tcp          tcpConfig          `toml:"tcp"`
	Pickle       pickleConfig       `toml:"pickle"`
	Carbonlink   carbonlinkConfig   `toml:"carbonlink"`
	Carbonserver carbonserverConfig `toml:"carbonserver"`
	Dump         dumpConfig         `toml:"dump"`
	Pprof        pprofConfig        `toml:"pprof"`
}

Config ...

func NewConfig

func NewConfig() *Config

NewConfig ...

type Duration

type Duration struct {
	time.Duration
}

Duration wrapper time.Duration for TOML

func (*Duration) MarshalText

func (d *Duration) MarshalText() ([]byte, error)

MarshalText encode text with TOML format

func (*Duration) UnmarshalText

func (d *Duration) UnmarshalText(text []byte) error

UnmarshalText from TOML

func (*Duration) Value

func (d *Duration) Value() time.Duration

Value return time.Duration value

type SyncWriter

type SyncWriter struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*SyncWriter) Flush

func (s *SyncWriter) Flush() error

func (*SyncWriter) Write

func (s *SyncWriter) Write(p []byte) (n int, err error)