Versions in this module Expand all Collapse all v1 v1.0.0 Apr 17, 2016 Changes in this version + const CACHE_SIZE + const CONNECT_ERROR_WAIT + const DEFAULT_DATA_ENCODING + const DEFAULT_DATA_MAX_AGE + const DEFAULT_DATA_MAX_FILES + const DEFAULT_DATA_MAX_SIZE + const DEFAULT_DATA_SEND_INTERVAL + const MAX_SEND_ERRORS + const WRITE_BUFFER + var BaseReportFormat string = "%d files, %s, %s, %s net util, %s net speed" + var DebugStats = false + var ErrSpoolTimeout = errors.New("Timeout spooling data") + var ErrorReportFormat = "%d errors, %d API errors, %d timeouts, %d bad files" + func FormatSentReport(r SentReport) string + type DiskvSpooler struct + func NewDiskvSpooler(logger *pct.Logger, dataDir, trashDir, hostname string, ...) *DiskvSpooler + func (s *DiskvSpooler) CancelFiles() + func (s *DiskvSpooler) Files() <-chan string + func (s *DiskvSpooler) Purge(now time.Time, limits pc.DataSpoolLimits) (int, map[string][]string) + func (s *DiskvSpooler) PurgeChan(c chan time.Time) + func (s *DiskvSpooler) Read(file string) ([]byte, error) + func (s *DiskvSpooler) Reject(file string) error + func (s *DiskvSpooler) Remove(file string) error + func (s *DiskvSpooler) Start(sz proto.Serializer) error + func (s *DiskvSpooler) Status() map[string]string + func (s *DiskvSpooler) Stop() error + func (s *DiskvSpooler) Write(service string, data interface{}) error + type Manager struct + func NewManager(logger *pct.Logger, dataDir, trashDir, hostname string, ...) *Manager + func (m *Manager) GetConfig() ([]proto.AgentConfig, []error) + func (m *Manager) GetDefaults() map[string]interface{} + 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, timeout uint, blackhole bool) error + func (s *Sender) Status() map[string]string + func (s *Sender) Stop() error + 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 + type Spooler interface + CancelFiles func() + Files func() <-chan string + Read func(file string) ([]byte, error) + Reject func(file string) error + Remove func(file string) error + Start func(proto.Serializer) error + Status func() map[string]string + Stop func() error + Write func(service string, data interface{}) error