github
/
prometheus
mirror of https://github.com/prometheus/prometheus
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Merge pull request #207 from prometheus/julius-array-channels 

Adjust memory queue size after change to send arrays over channel.
pull/209/head
juliusv 2013-04-30 05:46:39 -07:00
parent b02debd69c 368a792dd2
commit c0cd565430
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
main.go
View File

@ -38,7 +38,7 @@ var (
ruleResultsQueueCapacity = flag.Int("ruleResultsQueueCapacity", 4096, "The size of the rule results queue.") ruleResultsQueueCapacity = flag.Int("ruleResultsQueueCapacity", 4096, "The size of the rule results queue.")
concurrentRetrievalAllowance = flag.Int("concurrentRetrievalAllowance", 15, "The number of concurrent metrics retrieval requests allowed.") concurrentRetrievalAllowance = flag.Int("concurrentRetrievalAllowance", 15, "The number of concurrent metrics retrieval requests allowed.")
diskAppendQueueCapacity = flag.Int("queue.diskAppendCapacity", 1000000, "The size of the queue for items that are pending writing to disk.") diskAppendQueueCapacity = flag.Int("queue.diskAppendCapacity", 1000000, "The size of the queue for items that are pending writing to disk.")
memoryAppendQueueCapacity = flag.Int("queue.memoryAppendCapacity", 1000000, "The size of the queue for items that are pending writing to memory.") memoryAppendQueueCapacity = flag.Int("queue.memoryAppendCapacity", 10000, "The size of the queue for items that are pending writing to memory.")
) )
type prometheus struct { type prometheus struct {

2
storage/metric/test_helper.go
View File

@ -27,7 +27,7 @@ var (
) )
const ( const (
appendQueueSize = 1000 appendQueueSize = 100
) )
func testAppendSample(p MetricPersistence, s model.Sample, t test.Tester) { func testAppendSample(p MetricPersistence, s model.Sample, t test.Tester) {