data

May 15, 2015

Changes in this version

+ const DEFAULT_DATA_MAX_AGE

+ const DEFAULT_DATA_MAX_FILES

+ const DEFAULT_DATA_MAX_SIZE

type Config

+ Limits proto.DataSpoolLimits

type DiskvSpooler

+ func (s *DiskvSpooler) CancelFiles()

+ func (s *DiskvSpooler) Purge(now time.Time, limits proto.DataSpoolLimits) (int, map[string][]string)

+ func (s *DiskvSpooler) PurgeChan(c chan time.Time)

type Spooler

+ CancelFiles func()

+ Purge func(time.Time, proto.DataSpoolLimits) (int, map[string][]string)

Dec 30, 2014

Changes in this version

+ var BaseReportFormat string = "%d files, %s, %s, %s net util, %s net speed"

+ var DebugStats = false

+ var ErrorReportFormat = "%d errors, %d API errors, %d timeouts, %d bad files"

+ func FormatSentReport(r SentReport) string

+ type SenderStats struct

+ func NewSenderStats(d time.Duration) *SenderStats

+ func (s *SenderStats) Dump() []SentInfo

+ func (s *SenderStats) Report() SentReport

+ func (s *SenderStats) Sent(info SentInfo)

+ type SentInfo struct

+ ApiErrs uint

+ BadFiles uint

+ Begin time.Time

+ Bytes uint64

+ End time.Time

+ Errs uint

+ Files uint

+ SendTime float64

+ Timeouts uint

+ type SentReport struct

+ ApiErrs uint

+ BadFiles uint

+ Begin time.Time

+ Bytes string

+ Duration string

+ End time.Time

+ Errs uint

+ Files uint

+ Throughput string

+ Timeouts uint

+ Utilization string

Sep 5, 2014

Changes in this version

+ const CONNECT_ERROR_WAIT

+ const MAX_SEND_ERRORS

type DiskvSpooler

+ func (s *DiskvSpooler) Reject(file string) error

type Spooler

+ Reject func(file string) error

May 10, 2014

Changes in this version

+ const CACHE_SIZE

+ const DEFAULT_DATA_ENCODING

+ const DEFAULT_DATA_SEND_INTERVAL

+ const WRITE_BUFFER

+ var ErrSpoolTimeout = errors.New("Timeout spooling data")

+ type Config struct

+ Blackhole bool

+ Encoding string

+ SendInterval int

+ type DiskvSpooler struct

+ func NewDiskvSpooler(logger *pct.Logger, dataDir string, hostname string) *DiskvSpooler

+ func (s *DiskvSpooler) Files() <-chan string

+ func (s *DiskvSpooler) Read(file string) ([]byte, error)

+ func (s *DiskvSpooler) Remove(file string) error

+ func (s *DiskvSpooler) Start(sz Serializer) error

+ func (s *DiskvSpooler) Status() map[string]string

+ func (s *DiskvSpooler) Stop() error

+ func (s *DiskvSpooler) Write(service string, data interface{}) error

+ type JsonGzipSerializer struct

+ func NewJsonGzipSerializer() *JsonGzipSerializer

+ func (s *JsonGzipSerializer) Concurrent() bool

+ func (s *JsonGzipSerializer) Encoding() string

+ func (s *JsonGzipSerializer) ToBytes(data interface{}) ([]byte, error)

+ type JsonSerializer struct

+ func NewJsonSerializer() *JsonSerializer

+ func (j *JsonSerializer) ToBytes(data interface{}) ([]byte, error)

+ func (s *JsonSerializer) Concurrent() bool

+ func (s *JsonSerializer) Encoding() string

+ type Manager struct

+ func NewManager(logger *pct.Logger, dataDir string, hostname string, ...) *Manager

+ func (m *Manager) GetConfig() ([]proto.AgentConfig, []error)

+ func (m *Manager) Handle(cmd *proto.Cmd) *proto.Reply

+ func (m *Manager) Sender() *Sender

+ func (m *Manager) Spooler() Spooler

+ func (m *Manager) Start() error

+ func (m *Manager) Status() map[string]string

+ func (m *Manager) Stop() error

+ type Sender struct

+ func NewSender(logger *pct.Logger, client pct.WebsocketClient) *Sender

+ func (s *Sender) Start(spool Spooler, tickerChan <-chan time.Time, blackhole bool) error

+ func (s *Sender) Status() map[string]string

+ func (s *Sender) Stop() error

+ type Serializer interface

+ Concurrent func() bool

+ Encoding func() string

+ ToBytes func(data interface{}) ([]byte, error)

+ type Spooler interface

+ Files func() <-chan string

+ Read func(key string) ([]byte, error)

+ Remove func(key string) error

+ Start func(Serializer) error

+ Status func() map[string]string

+ Stop func() error

+ Write func(service string, data interface{}) error