carbon

package
v0.9.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 10, 2017 License: MIT Imports: 23 Imported by: 0

Documentation

Index

Constants

View Source
const MetricEndpointLocal = "local"

Variables

This section is empty.

Functions

func ParseConfig

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

ParseConfig ...

func PrintConfig

func PrintConfig(cfg interface{}) error

PrintConfig ...

func RestoreFromDir added in v0.8.0

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

RestoreFromDir cache and input dumps from disk to memory

func RestoreFromFile added in v0.8.0

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

RestoreFromFile read and parse data from single file

func RuntimeStat added in v0.9.0

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 added in v0.9.0

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 added in v0.8.0

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 added in v0.8.0

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

func NewCollector added in v0.8.0

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 added in v0.9.0

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

func (*SyncWriter) Flush added in v0.9.0

func (s *SyncWriter) Flush() error

func (*SyncWriter) Write added in v0.9.0

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL