deepend

type AggregatorConfig struct {
	FlushEvery time.Duration
}

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

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

type CompactorConfig struct {
	RunEvery      time.Duration
	BaseDirectory string
}

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

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

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

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

type ShardConfig struct {
	Workers          int
	AggregatorConfig *AggregatorConfig
	WriterConfig     *WriterConfig
	CompactorConfig  *CompactorConfig
}

type WriterConfig struct {
	FlushEvery    time.Duration
	BaseDirectory string
}