collector

type Collector interface {
	// Type return the types of collector
	Type() string

	// Add append result to statistic
	Add(*fcom.Result)

	// Serialize generate serialized data to pass through network in remote mode
	Serialize() []byte

	// Merge merge serialized data
	Merge([]byte) error

	// MergeC try to merge a Collector, if it can not do this, just raise a error
	MergeC(Collector) error

	// Get get current statistic data group by label
	Get() *fcom.Data

	// Reset reset data should reset the time window and clean data
	Reset()
}

type Details struct {
	Label          string
	Num            int
	SendLatency    *TDigest
	ConfirmLatency *TDigest
	WriteLatency   *TDigest
	Status         map[fcom.Status]int
	Tps            *TDigest
	Bps            *TDigest
}

type TDigest struct {
	*tdigest.TDigest
}

type TDigestDetailsCollector struct {
	Data map[string]*Details
	Time int64
}

type TDigestSummaryCollector struct {
	Data *Details
	Time int64
}