data

type Config struct {
	Encoding     string
	SendInterval uint
	Blackhole    bool // don't send if true
	Limits       proto.DataSpoolLimits
}

type DiskvSpooler struct {
	// contains filtered or unexported fields
}

type JsonGzipSerializer struct {
	// contains filtered or unexported fields
}

type JsonSerializer struct {
}

type Manager struct {
	// contains filtered or unexported fields
}

type Sender struct {
	// contains filtered or unexported fields
}

type SenderStats struct {
	// contains filtered or unexported fields
}

type SentInfo struct {
	Begin    time.Time
	End      time.Time
	SendTime float64
	Files    uint
	Bytes    uint64
	Errs     uint
	ApiErrs  uint
	Timeouts uint
	BadFiles uint
}

type SentReport struct {

	// --
	Begin       time.Time
	End         time.Time
	Bytes       string // humanized bytes, e.g. 443.59 kB
	Duration    string // End - Begin, humanized
	Utilization string // bytes / (End - Begin), Mbps
	Throughput  string // bytes / sendTime, Mbps
	Files       uint
	Errs        uint
	ApiErrs     uint
	Timeouts    uint
	BadFiles    uint
	// contains filtered or unexported fields
}

type Serializer interface {
	ToBytes(data interface{}) ([]byte, error)
	Encoding() string
	Concurrent() bool
}

type Spooler interface {
	Start(Serializer) error
	Stop() error
	Status() map[string]string
	Write(service string, data interface{}) error
	Files() <-chan string
	CancelFiles()
	Read(file string) ([]byte, error)
	Remove(file string) error
	Reject(file string) error
	Purge(time.Time, proto.DataSpoolLimits) (int, map[string][]string)
}