Skip to content

Instantly share code, notes, and snippets.

@jwilder
jwilder / gist:e46cdb9e7f9cb902d80e
Created April 11, 2015 04:20
DQ remote_mapper.go
diff --git a/remote_mapper.go b/remote_mapper.go
index ee03e8a..3b520fb 100644
--- a/remote_mapper.go
+++ b/remote_mapper.go
@@ -4,13 +4,14 @@ import (
"bytes"
"encoding/json"
"errors"
+ "io"
"net/http"
This file has been truncated, but you can view the full file.
influxdb:influxdb jason$ cpulimit -l 10 -i go test -v -run Test5 ./cmd/influxd/
System Info: CPU=8 GOMAXPROCS=1
=== RUN Test5NodeClusterPartiallyReplicated
2015/04/22 15:59:13 influxdb started, version 0.9, commit
2015/04/22 15:59:13 Cluster server listening on [::]:62064
2015/04/22 15:59:13 broker opened at /var/folders/lj/vlbynqp52pxdxxlxx64j6bk80000gn/T/influxdb-541380742/broker-integration-test/0
[raft] 2015/04/22 15:59:13 Open: fsm: index=0
[raft] 2015/04/22 15:59:13 log pending: waiting for initialization or join
[raft] 2015/04/22 15:59:13 changing term: 0 => 1
[raft] 2015/04/22 15:59:13 log state change: stopped => leader (term=1)
@jwilder
jwilder / main.go
Created June 26, 2015 16:04
Load Test
package main
import (
crand "crypto/rand"
"encoding/base64"
"fmt"
"math/rand"
"net/url"
"os"
"strings"
@jwilder
jwilder / functions.diff
Created August 26, 2015 03:16
Deterministic First/Last
diff --git a/influxql/functions.go b/influxql/functions.go
index 3d75c5a..918f241 100644
--- a/influxql/functions.go
+++ b/influxql/functions.go
@@ -949,6 +949,8 @@ func MapFirst(itr Iterator) interface{} {
if k < out.Time {
out.Time = k
out.Val = v
+ } else if k == out.Time && greaterThan(v, out.Val) {
+ out.Val = v
@jwilder
jwilder / tsmdump.txt
Created October 10, 2015 04:53
Sample output from tsm dump
Summary:
File: /Users/jason/.influxdb/data/stress/default/2/0000001.tsm1
Time Range: 1974-07-30T19:40:14.048274791Z - 1974-07-30T19:40:14.248274792Z
Duration: 200.000001ms Series: 20 File Size: 1385
Index:
Pos ID Ofs Key Field
0 1457934444615313758 4 cpu,host=server-49999 value
1 1530265636438342380 61 cpu,host=server-69999 value
2 1674605844894586950 115 cpu,host=server-74999 value
[monitor] 2015/10/23 14:00:08 failed to store statistics: timeout
^\SIGQUIT: quit
PC=0x6347b m=0
goroutine 0 [idle]:
runtime.mach_semaphore_wait(0xe03, 0x0, 0x33401, 0xc820124180, 0xc989a0, 0xc989a0, 0x55c59, 0xffffffffffffffff, 0x0, 0x7fff5fbff8ec, ...)
/usr/local/go/src/runtime/sys_darwin_amd64.s:407 +0xb
runtime.semasleep1(0xffffffffffffffff, 0x0)
/usr/local/go/src/runtime/os1_darwin.go:385 +0xe5
runtime.semasleep.func1()
diff --git a/coordinator/query_executor.go b/coordinator/query_executor.go
index 34ec5a4..a93680c 100644
--- a/coordinator/query_executor.go
+++ b/coordinator/query_executor.go
@@ -1076,22 +1076,6 @@ func (d *NodeDialer) DialNode(nodeID uint64) (net.Conn, error) {
return conn, nil
}
-// TSDBStore is an interface for accessing the time series data store.
-type TSDBStore interface {
func BenchmarkWAL_Write_1(b *testing.B) {
benchmarkWALWrite(b, 1)
}
// func BenchmarkWAL_Write_10(b *testing.B) {
// benchmarkWALWrite(b, 10)
// }
func benchmarkWALWrite(b *testing.B, concurrency int) {
points := map[string][]tsm1.Value{}
package merge
import (
"sort"
"testing"
"time"
"github.com/influxdata/influxdb/tsdb/engine/tsm1"
)