carbon

Documentation

Index

• Constants
• func NewLoggingConfig() zapwriter.Config
• func PrintDefaultConfig() error
• type App
  • func New(configFilename string) *App
  • func (app *App) Loop()
  • func (app *App) ParseConfig() error
  • func (app *App) Reset()
  • func (app *App) Start() (err error)
  • func (app *App) Stop()
• type Collector
  • func NewCollector(app *App) *Collector
• type Config
  • func NewConfig() *Config
  • func ReadConfig(filename string) (*Config, error)
• type Point

Constants

const MetricEndpointLocal = "local"

Functions

func NewLoggingConfig

func NewLoggingConfig() zapwriter.Config

func PrintDefaultConfig

func PrintDefaultConfig() error

PrintConfig ...

Types

type App

type App struct {
	sync.RWMutex
	Config     *Config
	Writer     *writer.Writer
	Uploaders  map[string]uploader.Uploader
	UDP        receiver.Receiver
	TCP        receiver.Receiver
	Pickle     receiver.Receiver
	Grpc       receiver.Receiver
	Prometheus receiver.Receiver
	Collector  *Collector // (!!!) Should be re-created on every change config/modules

	ConfigFilename string
	// contains filtered or unexported fields
}

func New

func New(configFilename string) *App

New App instance

func (*App) Loop

func (app *App) Loop()

Loop ...

func (*App) ParseConfig

func (app *App) ParseConfig() error

ParseConfig loads config from config file

func (*App) Reset

func (app *App) Reset()

Reset cache in uploaders

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 {
	stop.Struct
	// contains filtered or unexported fields
}

func NewCollector

func NewCollector(app *App) *Collector

type Config

type Config struct {
	Common     commonConfig                `toml:"common"`
	Data       dataConfig                  `toml:"data"`
	Upload     map[string]*uploader.Config `toml:"upload"`
	Udp        udpConfig                   `toml:"udp"`
	Tcp        tcpConfig                   `toml:"tcp"`
	Pickle     pickleConfig                `toml:"pickle"`
	Grpc       grpcConfig                  `toml:"grpc"`
	Prometheus promConfig                  `toml:"prometheus"`
	Pprof      pprofConfig                 `toml:"pprof"`
	Logging    []zapwriter.Config          `toml:"logging"`
}

Config ...

func NewConfig

func NewConfig() *Config

NewConfig ...

func ReadConfig

func ReadConfig(filename string) (*Config, error)

ReadConfig ...

type Point

type Point struct {
	Metric    string
	Value     float64
	Timestamp uint32
}