Merge pull request #5617 from benbjohnson/influxdata

Rename influxdb/influxdb to influxdata/influxdb
pull/2887/merge
Ben Johnson 2016-02-10 13:29:46 -07:00
commit 2f1e83427b
191 changed files with 1459 additions and 1457 deletions

File diff suppressed because it is too large Load Diff

View File

@ -95,7 +95,7 @@ Setup the project structure and fetch the repo like so:
```bash
mkdir $HOME/gocodez
export GOPATH=$HOME/gocodez
go get github.com/influxdb/influxdb
go get github.com/influxdata/influxdb
```
You can add the line `export GOPATH=$HOME/gocodez` to your bash/zsh file to be set for every shell instead of having to manually run it everytime.
@ -119,7 +119,7 @@ Build and Test
Make sure you have Go installed and the project structure as shown above. To then get the dependencies for the project, execute the following commands:
```bash
cd $GOPATH/src/github.com/influxdb/influxdb
cd $GOPATH/src/github.com/influxdata/influxdb
go get -u -f -t ./...
```
@ -146,7 +146,7 @@ package.sh -h
To run the tests, execute the following command:
```bash
cd $GOPATH/src/github.com/influxdb/influxdb
cd $GOPATH/src/github.com/influxdata/influxdb
go test -v ./...
# run tests that match some pattern
@ -192,7 +192,7 @@ Pre-commit checks
We have a pre-commit hook to make sure code is formatted properly and vetted before you commit any changes. We strongly recommend using the pre-commit hook to guard against accidentally committing unformatted code. To use the pre-commit hook, run the following:
```bash
cd $GOPATH/src/github.com/influxdb/influxdb
cd $GOPATH/src/github.com/influxdata/influxdb
cp .hooks/pre-commit .git/hooks/
```
In case the commit is rejected because it's not formatted you can run

View File

@ -25,11 +25,11 @@ RUN wget https://storage.googleapis.com/golang/go${GO_VERSION}.linux-${GO_ARCH}.
rm /go${GO_VERSION}.linux-${GO_ARCH}.tar.gz
ENV PATH /usr/local/go/bin:$PATH
ENV PROJECT_DIR $GOPATH/src/github.com/influxdb/influxdb
ENV PROJECT_DIR $GOPATH/src/github.com/influxdata/influxdb
ENV PATH $GOPATH/bin:$PATH
RUN mkdir -p $PROJECT_DIR
WORKDIR $PROJECT_DIR
VOLUME $PROJECT_DIR
ENTRYPOINT [ "/root/go/src/github.com/influxdb/influxdb/build.py" ]
ENTRYPOINT [ "/root/go/src/github.com/influxdata/influxdb/build.py" ]

View File

@ -25,11 +25,11 @@ RUN wget https://storage.googleapis.com/golang/go${GO_VERSION}.linux-${GO_ARCH}.
rm /go${GO_VERSION}.linux-${GO_ARCH}.tar.gz
ENV PATH /usr/local/go/bin:$PATH
ENV PROJECT_DIR $GOPATH/src/github.com/influxdb/influxdb
ENV PROJECT_DIR $GOPATH/src/github.com/influxdata/influxdb
ENV PATH $GOPATH/bin:$PATH
RUN mkdir -p $PROJECT_DIR
WORKDIR $PROJECT_DIR
VOLUME $PROJECT_DIR
ENTRYPOINT [ "/root/go/src/github.com/influxdb/influxdb/build.py" ]
ENTRYPOINT [ "/root/go/src/github.com/influxdata/influxdb/build.py" ]

View File

@ -18,7 +18,7 @@ RUN gem install fpm
# Setup env
ENV GOPATH /root/go
ENV PROJECT_DIR $GOPATH/src/github.com/influxdb/influxdb
ENV PROJECT_DIR $GOPATH/src/github.com/influxdata/influxdb
ENV PATH $GOPATH/bin:$PATH
RUN mkdir -p $PROJECT_DIR

View File

@ -5,8 +5,8 @@ RUN add-apt-repository ppa:evarlast/golang1.4
RUN apt-get update && apt-get install -y -o Dpkg::Options::="--force-overwrite" golang-go
ENV GOPATH=/root/go
RUN mkdir -p /root/go/src/github.com/influxdb/influxdb
RUN mkdir -p /root/go/src/github.com/influxdata/influxdb
RUN mkdir -p /tmp/artifacts
VOLUME /root/go/src/github.com/influxdb/influxdb
VOLUME /root/go/src/github.com/influxdata/influxdb
VOLUME /tmp/artifacts

View File

@ -16,7 +16,7 @@ docker run --rm \
-e AWS_ACCESS_KEY_ID="$AWS_ACCESS_KEY_ID" \
-e AWS_SECRET_ACCESS_KEY="$AWS_SECRET_ACCESS_KEY" \
-v $HOME/.aws.conf:/root/.aws.conf \
-v $DIR:/root/go/src/github.com/influxdb/influxdb \
-v $DIR:/root/go/src/github.com/influxdata/influxdb \
influxdb-builder \
"$@"

View File

@ -1,12 +1,12 @@
# InfluxDB Client
[![GoDoc](https://godoc.org/github.com/influxdb/influxdb?status.svg)](http://godoc.org/github.com/influxdb/influxdb/client/v2)
[![GoDoc](https://godoc.org/github.com/influxdata/influxdb?status.svg)](http://godoc.org/github.com/influxdata/influxdb/client/v2)
## Description
**NOTE:** The Go client library now has a "v2" version, with the old version
being deprecated. The new version can be imported at
`import "github.com/influxdb/influxdb/client/v2"`. It is not backwards-compatible.
`import "github.com/influxdata/influxdb/client/v2"`. It is not backwards-compatible.
A Go client library written and maintained by the **InfluxDB** team.
This package provides convenience functions to read and write time series data.
@ -29,7 +29,7 @@ For more information please check out the
[Cluster Admin Docs](http://influxdb.com/docs/v0.9/query_language/database_administration.html).
For the impatient, you can create a new admin user _bubba_ by firing off the
[InfluxDB CLI](https://github.com/influxdb/influxdb/blob/master/cmd/influx/main.go).
[InfluxDB CLI](https://github.com/influxdata/influxdb/blob/master/cmd/influx/main.go).
```shell
influx
@ -55,7 +55,7 @@ import (
"log"
"os"
"github.com/influxdb/influxdb/client/v2"
"github.com/influxdata/influxdb/client/v2"
)
const (
@ -246,10 +246,10 @@ func WriteUDP() {
## Go Docs
Please refer to
[http://godoc.org/github.com/influxdb/influxdb/client/v2](http://godoc.org/github.com/influxdb/influxdb/client/v2)
[http://godoc.org/github.com/influxdata/influxdb/client/v2](http://godoc.org/github.com/influxdata/influxdb/client/v2)
for documentation.
## See Also
You can also examine how the client library is used by the
[InfluxDB CLI](https://github.com/influxdb/influxdb/blob/master/cmd/influx/main.go).
[InfluxDB CLI](https://github.com/influxdata/influxdb/blob/master/cmd/influx/main.go).

View File

@ -9,7 +9,7 @@ import (
"strconv"
"time"
"github.com/influxdb/influxdb/client"
"github.com/influxdata/influxdb/client"
)
func ExampleNewClient() {

View File

@ -1,4 +1,4 @@
package client
package client // import "github.com/influxdata/influxdb/client"
import (
"bytes"
@ -14,7 +14,7 @@ import (
"strings"
"time"
"github.com/influxdb/influxdb/models"
"github.com/influxdata/influxdb/models"
)
const (

View File

@ -14,7 +14,7 @@ import (
"testing"
"time"
"github.com/influxdb/influxdb/client"
"github.com/influxdata/influxdb/client"
)
func BenchmarkWrite(b *testing.B) {

View File

@ -1,4 +1,4 @@
package client
package client // import "github.com/influxdata/influxdb/client/v2"
import (
"bytes"
@ -12,7 +12,7 @@ import (
"net/url"
"time"
"github.com/influxdb/influxdb/models"
"github.com/influxdata/influxdb/models"
)
// UDPPayloadSize is a reasonable default payload size for UDP packets that

View File

@ -6,7 +6,7 @@ import (
"os"
"time"
"github.com/influxdb/influxdb/client/v2"
"github.com/influxdata/influxdb/client/v2"
)
// Create a new client

View File

@ -3,7 +3,7 @@ package cluster
import (
"math/rand"
"github.com/influxdb/influxdb/services/meta"
"github.com/influxdata/influxdb/services/meta"
)
// Balancer represents a load-balancing algorithm for a set of nodes

View File

@ -4,8 +4,8 @@ import (
"fmt"
"testing"
"github.com/influxdb/influxdb/cluster"
"github.com/influxdb/influxdb/services/meta"
"github.com/influxdata/influxdb/cluster"
"github.com/influxdata/influxdb/services/meta"
)
func NewNodes() []meta.NodeInfo {

1
cluster/cluster.go Normal file
View File

@ -0,0 +1 @@
package cluster // import "github.com/influxdata/influxdb/cluster"

View File

@ -3,7 +3,7 @@ package cluster
import (
"time"
"github.com/influxdb/influxdb/toml"
"github.com/influxdata/influxdb/toml"
)
const (

View File

@ -5,7 +5,7 @@ import (
"time"
"github.com/BurntSushi/toml"
"github.com/influxdb/influxdb/cluster"
"github.com/influxdata/influxdb/cluster"
)
func TestConfig_Parse(t *testing.T) {

View File

@ -3,8 +3,8 @@ package cluster
import (
"time"
"github.com/influxdb/influxdb/influxql"
"github.com/influxdb/influxdb/services/meta"
"github.com/influxdata/influxdb/influxql"
"github.com/influxdata/influxdb/services/meta"
)
// IteratorCreator is responsible for creating iterators for queries.

View File

@ -10,10 +10,10 @@ import (
"sync"
"time"
"github.com/influxdb/influxdb"
"github.com/influxdb/influxdb/models"
"github.com/influxdb/influxdb/services/meta"
"github.com/influxdb/influxdb/tsdb"
"github.com/influxdata/influxdb"
"github.com/influxdata/influxdb/models"
"github.com/influxdata/influxdb/services/meta"
"github.com/influxdata/influxdb/tsdb"
)
// ConsistencyLevel represent a required replication criteria before a write can

View File

@ -7,10 +7,10 @@ import (
"testing"
"time"
"github.com/influxdb/influxdb"
"github.com/influxdb/influxdb/cluster"
"github.com/influxdb/influxdb/models"
"github.com/influxdb/influxdb/services/meta"
"github.com/influxdata/influxdb"
"github.com/influxdata/influxdb/cluster"
"github.com/influxdata/influxdb/models"
"github.com/influxdata/influxdb/services/meta"
)
// Ensures the points writer maps a single point to a single shard.

View File

@ -5,8 +5,8 @@ import (
"time"
"github.com/gogo/protobuf/proto"
"github.com/influxdb/influxdb/cluster/internal"
"github.com/influxdb/influxdb/models"
"github.com/influxdata/influxdb/cluster/internal"
"github.com/influxdata/influxdb/models"
)
//go:generate protoc --gogo_out=. internal/data.proto

View File

@ -11,10 +11,10 @@ import (
"strings"
"sync"
"github.com/influxdb/influxdb"
"github.com/influxdb/influxdb/models"
"github.com/influxdb/influxdb/services/meta"
"github.com/influxdb/influxdb/tsdb"
"github.com/influxdata/influxdb"
"github.com/influxdata/influxdb/models"
"github.com/influxdata/influxdb/services/meta"
"github.com/influxdata/influxdb/tsdb"
)
// MaxMessageSize defines how large a message can be before we reject it

View File

@ -5,10 +5,10 @@ import (
"net"
"time"
"github.com/influxdb/influxdb/cluster"
"github.com/influxdb/influxdb/models"
"github.com/influxdb/influxdb/services/meta"
"github.com/influxdb/influxdb/tcp"
"github.com/influxdata/influxdb/cluster"
"github.com/influxdata/influxdb/models"
"github.com/influxdata/influxdb/services/meta"
"github.com/influxdata/influxdb/tcp"
)
type metaClient struct {

View File

@ -7,10 +7,10 @@ import (
"net"
"time"
"github.com/influxdb/influxdb"
"github.com/influxdb/influxdb/influxql"
"github.com/influxdb/influxdb/services/meta"
"github.com/influxdb/influxdb/tsdb"
"github.com/influxdata/influxdb"
"github.com/influxdata/influxdb/influxql"
"github.com/influxdata/influxdb/services/meta"
"github.com/influxdata/influxdb/tsdb"
)
// ShardMapper is responsible for providing mappers for requested shards. It is

View File

@ -9,8 +9,8 @@ import (
"net"
"testing"
"github.com/influxdb/influxdb/influxql"
"github.com/influxdb/influxdb/tsdb"
"github.com/influxdata/influxdb/influxql"
"github.com/influxdata/influxdb/tsdb"
)
// remoteShardResponder implements the remoteShardConn interface.

View File

@ -5,8 +5,8 @@ import (
"net"
"time"
"github.com/influxdb/influxdb/models"
"github.com/influxdb/influxdb/services/meta"
"github.com/influxdata/influxdb/models"
"github.com/influxdata/influxdb/services/meta"
)
const (

View File

@ -6,9 +6,9 @@ import (
"testing"
"time"
"github.com/influxdb/influxdb/cluster"
"github.com/influxdb/influxdb/models"
"github.com/influxdb/influxdb/toml"
"github.com/influxdata/influxdb/cluster"
"github.com/influxdata/influxdb/models"
"github.com/influxdata/influxdb/toml"
)
// Ensure the shard writer can successful write a single request.

View File

@ -1,4 +1,4 @@
package cli
package cli // import "github.com/influxdata/influxdb/cmd/influx/cli"
import (
"bytes"
@ -19,9 +19,9 @@ import (
"syscall"
"text/tabwriter"
"github.com/influxdb/influxdb/client"
"github.com/influxdb/influxdb/cluster"
"github.com/influxdb/influxdb/importer/v8"
"github.com/influxdata/influxdb/client"
"github.com/influxdata/influxdb/cluster"
"github.com/influxdata/influxdb/importer/v8"
"github.com/peterh/liner"
)

View File

@ -12,9 +12,9 @@ import (
"strings"
"testing"
"github.com/influxdb/influxdb/client"
"github.com/influxdb/influxdb/cmd/influx/cli"
"github.com/influxdb/influxdb/influxql"
"github.com/influxdata/influxdb/client"
"github.com/influxdata/influxdb/cmd/influx/cli"
"github.com/influxdata/influxdb/influxql"
"github.com/peterh/liner"
)

View File

@ -5,8 +5,8 @@ import (
"fmt"
"os"
"github.com/influxdb/influxdb/client"
"github.com/influxdb/influxdb/cmd/influx/cli"
"github.com/influxdata/influxdb/client"
"github.com/influxdata/influxdb/cmd/influx/cli"
)
// These variables are populated via the Go linker.

View File

@ -11,7 +11,7 @@ import (
"strings"
"text/tabwriter"
"github.com/influxdb/influxdb/tsdb"
"github.com/influxdata/influxdb/tsdb"
)
func cmdInfo(path string) {

View File

@ -5,7 +5,7 @@ import (
"fmt"
"os"
_ "github.com/influxdb/influxdb/tsdb/engine"
_ "github.com/influxdata/influxdb/tsdb/engine"
)
func usage() {

View File

@ -13,8 +13,8 @@ import (
"time"
"github.com/golang/snappy"
"github.com/influxdb/influxdb/tsdb"
"github.com/influxdb/influxdb/tsdb/engine/tsm1"
"github.com/influxdata/influxdb/tsdb"
"github.com/influxdata/influxdb/tsdb/engine/tsm1"
)
// these consts are for the old tsm format. They can be removed once we remove

View File

@ -3,7 +3,7 @@
## Ways to run
### `influx_stress`
This runs a basic stress test with the [default config](https://github.com/influxdb/influxdb/blob/master/stress/stress.toml) For more information on the configuration file please see the default. For additional questions please contact @mjdesa
This runs a basic stress test with the [default config](https://github.com/influxdata/influxdb/blob/master/stress/stress.toml) For more information on the configuration file please see the default. For additional questions please contact @mjdesa
### `influx_stress -config someConfig.toml`
This runs the stress test with a valid configuration file located at `someConfig.tom`
@ -20,7 +20,7 @@ IP address and port of database where response times will persist (e.g., localho
### `-config` string
The relative path to the stress test configuration file.
`default` = [config](https://github.com/influxdb/influxdb/blob/master/stress/stress.toml)
`default` = [config](https://github.com/influxdata/influxdb/blob/master/stress/stress.toml)
### `-cpuprofile` filename
Writes the result of Go's cpu profile to filename
@ -35,4 +35,4 @@ Name of database on `-addr` that `influx_stress` will persist write and query re
### `-tags` value
A comma separated list of tags to add to write and query response times.
`default` = ""
`default` = ""

View File

@ -6,7 +6,7 @@ import (
"os"
"runtime/pprof"
"github.com/influxdb/influxdb/stress"
"github.com/influxdata/influxdb/stress"
)
var (

View File

@ -1,4 +1,4 @@
package b1
package b1 // import "github.com/influxdata/influxdb/cmd/influx_tsm/b1"
import (
"encoding/binary"
@ -7,8 +7,8 @@ import (
"time"
"github.com/boltdb/bolt"
"github.com/influxdb/influxdb/cmd/influx_tsm/tsdb"
"github.com/influxdb/influxdb/tsdb/engine/tsm1"
"github.com/influxdata/influxdb/cmd/influx_tsm/tsdb"
"github.com/influxdata/influxdb/tsdb/engine/tsm1"
)
const DefaultChunkSize = 1000

View File

@ -1,4 +1,4 @@
package bz1
package bz1 // import "github.com/influxdata/influxdb/cmd/influx_tsm/bz1"
import (
"bytes"
@ -11,8 +11,8 @@ import (
"github.com/boltdb/bolt"
"github.com/golang/snappy"
"github.com/influxdb/influxdb/cmd/influx_tsm/tsdb"
tsm "github.com/influxdb/influxdb/tsdb/engine/tsm1"
"github.com/influxdata/influxdb/cmd/influx_tsm/tsdb"
tsm "github.com/influxdata/influxdb/tsdb/engine/tsm1"
)
const DefaultChunkSize = 1000

View File

@ -6,7 +6,7 @@ import (
"os"
"path/filepath"
"github.com/influxdb/influxdb/tsdb/engine/tsm1"
"github.com/influxdata/influxdb/tsdb/engine/tsm1"
)
type KeyIterator interface {

View File

@ -8,7 +8,7 @@ import (
"testing"
"time"
"github.com/influxdb/influxdb/tsdb/engine/tsm1"
"github.com/influxdata/influxdb/tsdb/engine/tsm1"
)
func TestScrubValues(t *testing.T) {

View File

@ -19,9 +19,9 @@ import (
"net/http"
_ "net/http/pprof"
"github.com/influxdb/influxdb/cmd/influx_tsm/b1"
"github.com/influxdb/influxdb/cmd/influx_tsm/bz1"
"github.com/influxdb/influxdb/cmd/influx_tsm/tsdb"
"github.com/influxdata/influxdb/cmd/influx_tsm/b1"
"github.com/influxdata/influxdb/cmd/influx_tsm/bz1"
"github.com/influxdata/influxdb/cmd/influx_tsm/tsdb"
)
type ShardReader interface {

View File

@ -8,9 +8,9 @@ import (
"sync/atomic"
"time"
"github.com/influxdb/influxdb/cmd/influx_tsm/b1"
"github.com/influxdb/influxdb/cmd/influx_tsm/bz1"
"github.com/influxdb/influxdb/cmd/influx_tsm/tsdb"
"github.com/influxdata/influxdb/cmd/influx_tsm/b1"
"github.com/influxdata/influxdb/cmd/influx_tsm/bz1"
"github.com/influxdata/influxdb/cmd/influx_tsm/tsdb"
)
// tracker will orchestrate and track the conversions of non-TSM shards to TSM

View File

@ -7,7 +7,7 @@ import (
"fmt"
"math"
"github.com/influxdb/influxdb/influxql"
"github.com/influxdata/influxdb/influxql"
)
const maxStringLength = 64 * 1024

View File

@ -1,4 +1,4 @@
package tsdb
package tsdb // import "github.com/influxdata/influxdb/cmd/influx_tsm/tsdb"
import (
"fmt"
@ -9,7 +9,7 @@ import (
"time"
"github.com/boltdb/bolt"
"github.com/influxdb/influxdb/pkg/slices"
"github.com/influxdata/influxdb/pkg/slices"
)
const (

View File

@ -4,8 +4,8 @@ import (
"encoding/binary"
"strings"
"github.com/influxdb/influxdb/cmd/influx_tsm/tsdb/internal"
"github.com/influxdb/influxdb/influxql"
"github.com/influxdata/influxdb/cmd/influx_tsm/tsdb/internal"
"github.com/influxdata/influxdb/influxql"
"github.com/gogo/protobuf/proto"
)

View File

@ -4,7 +4,7 @@ import (
"fmt"
"time"
tsm "github.com/influxdb/influxdb/tsdb/engine/tsm1"
tsm "github.com/influxdata/influxdb/tsdb/engine/tsm1"
)
type FloatValue struct {

View File

@ -15,8 +15,8 @@ import (
"strings"
"time"
"github.com/influxdb/influxdb/services/snapshotter"
"github.com/influxdb/influxdb/tcp"
"github.com/influxdata/influxdb/services/snapshotter"
"github.com/influxdata/influxdb/tcp"
)
const (

View File

@ -12,10 +12,10 @@ import (
"syscall"
"time"
"github.com/influxdb/influxdb/cmd/influxd/backup"
"github.com/influxdb/influxdb/cmd/influxd/help"
"github.com/influxdb/influxdb/cmd/influxd/restore"
"github.com/influxdb/influxdb/cmd/influxd/run"
"github.com/influxdata/influxdb/cmd/influxd/backup"
"github.com/influxdata/influxdb/cmd/influxd/help"
"github.com/influxdata/influxdb/cmd/influxd/restore"
"github.com/influxdata/influxdb/cmd/influxd/run"
)
// These variables are populated via the Go linker.

View File

@ -16,9 +16,9 @@ import (
"strconv"
"sync"
"github.com/influxdb/influxdb/cmd/influxd/backup"
"github.com/influxdb/influxdb/services/meta"
"github.com/influxdb/influxdb/services/snapshotter"
"github.com/influxdata/influxdb/cmd/influxd/backup"
"github.com/influxdata/influxdb/services/meta"
"github.com/influxdata/influxdb/services/snapshotter"
)
// Command represents the program execution for "influxd restore".

View File

@ -8,10 +8,10 @@ import (
"testing"
"time"
"github.com/influxdb/influxdb/cmd/influxd/backup"
"github.com/influxdb/influxdb/cmd/influxd/restore"
"github.com/influxdb/influxdb/cmd/influxd/run"
"github.com/influxdb/influxdb/services/meta"
"github.com/influxdata/influxdb/cmd/influxd/backup"
"github.com/influxdata/influxdb/cmd/influxd/restore"
"github.com/influxdata/influxdb/cmd/influxd/run"
"github.com/influxdata/influxdb/services/meta"
)
func TestServer_BackupAndRestore(t *testing.T) {

View File

@ -14,7 +14,7 @@ import (
"time"
"github.com/BurntSushi/toml"
"github.com/influxdb/influxdb"
"github.com/influxdata/influxdb"
)
const logo = `

View File

@ -11,21 +11,21 @@ import (
"strings"
"time"
"github.com/influxdb/influxdb/cluster"
"github.com/influxdb/influxdb/monitor"
"github.com/influxdb/influxdb/services/admin"
"github.com/influxdb/influxdb/services/collectd"
"github.com/influxdb/influxdb/services/continuous_querier"
"github.com/influxdb/influxdb/services/graphite"
"github.com/influxdb/influxdb/services/hh"
"github.com/influxdb/influxdb/services/httpd"
"github.com/influxdb/influxdb/services/meta"
"github.com/influxdb/influxdb/services/opentsdb"
"github.com/influxdb/influxdb/services/precreator"
"github.com/influxdb/influxdb/services/retention"
"github.com/influxdb/influxdb/services/subscriber"
"github.com/influxdb/influxdb/services/udp"
"github.com/influxdb/influxdb/tsdb"
"github.com/influxdata/influxdb/cluster"
"github.com/influxdata/influxdb/monitor"
"github.com/influxdata/influxdb/services/admin"
"github.com/influxdata/influxdb/services/collectd"
"github.com/influxdata/influxdb/services/continuous_querier"
"github.com/influxdata/influxdb/services/graphite"
"github.com/influxdata/influxdb/services/hh"
"github.com/influxdata/influxdb/services/httpd"
"github.com/influxdata/influxdb/services/meta"
"github.com/influxdata/influxdb/services/opentsdb"
"github.com/influxdata/influxdb/services/precreator"
"github.com/influxdata/influxdb/services/retention"
"github.com/influxdata/influxdb/services/subscriber"
"github.com/influxdata/influxdb/services/udp"
"github.com/influxdata/influxdb/tsdb"
)
const (

View File

@ -5,7 +5,7 @@ import (
"testing"
"github.com/BurntSushi/toml"
"github.com/influxdb/influxdb/cmd/influxd/run"
"github.com/influxdata/influxdb/cmd/influxd/run"
)
// Ensure the configuration can be parsed.

View File

@ -11,28 +11,28 @@ import (
"runtime/pprof"
"time"
"github.com/influxdb/influxdb"
"github.com/influxdb/influxdb/cluster"
"github.com/influxdb/influxdb/monitor"
"github.com/influxdb/influxdb/services/admin"
"github.com/influxdb/influxdb/services/collectd"
"github.com/influxdb/influxdb/services/continuous_querier"
"github.com/influxdb/influxdb/services/copier"
"github.com/influxdb/influxdb/services/graphite"
"github.com/influxdb/influxdb/services/hh"
"github.com/influxdb/influxdb/services/httpd"
"github.com/influxdb/influxdb/services/meta"
"github.com/influxdb/influxdb/services/opentsdb"
"github.com/influxdb/influxdb/services/precreator"
"github.com/influxdb/influxdb/services/retention"
"github.com/influxdb/influxdb/services/snapshotter"
"github.com/influxdb/influxdb/services/subscriber"
"github.com/influxdb/influxdb/services/udp"
"github.com/influxdb/influxdb/tcp"
"github.com/influxdb/influxdb/tsdb"
"github.com/influxdata/influxdb"
"github.com/influxdata/influxdb/cluster"
"github.com/influxdata/influxdb/monitor"
"github.com/influxdata/influxdb/services/admin"
"github.com/influxdata/influxdb/services/collectd"
"github.com/influxdata/influxdb/services/continuous_querier"
"github.com/influxdata/influxdb/services/copier"
"github.com/influxdata/influxdb/services/graphite"
"github.com/influxdata/influxdb/services/hh"
"github.com/influxdata/influxdb/services/httpd"
"github.com/influxdata/influxdb/services/meta"
"github.com/influxdata/influxdb/services/opentsdb"
"github.com/influxdata/influxdb/services/precreator"
"github.com/influxdata/influxdb/services/retention"
"github.com/influxdata/influxdb/services/snapshotter"
"github.com/influxdata/influxdb/services/subscriber"
"github.com/influxdata/influxdb/services/udp"
"github.com/influxdata/influxdb/tcp"
"github.com/influxdata/influxdb/tsdb"
client "github.com/influxdb/usage-client/v1"
// Initialize the engine packages
_ "github.com/influxdb/influxdb/tsdb/engine"
_ "github.com/influxdata/influxdb/tsdb/engine"
)
// BuildInfo represents the build details for the server code.

View File

@ -6,7 +6,7 @@ import (
"testing"
"time"
"github.com/influxdb/influxdb/cmd/influxd/run"
"github.com/influxdata/influxdb/cmd/influxd/run"
)
func TestCluster_CreateDatabase(t *testing.T) {

View File

@ -18,11 +18,11 @@ import (
"testing"
"time"
"github.com/influxdb/influxdb/client/v2"
"github.com/influxdb/influxdb/cmd/influxd/run"
"github.com/influxdb/influxdb/services/httpd"
"github.com/influxdb/influxdb/services/meta"
"github.com/influxdb/influxdb/toml"
"github.com/influxdata/influxdb/client/v2"
"github.com/influxdata/influxdb/cmd/influxd/run"
"github.com/influxdata/influxdb/services/httpd"
"github.com/influxdata/influxdb/services/meta"
"github.com/influxdata/influxdb/toml"
)
const emptyResults = `{"results":[{}]}`

View File

@ -9,7 +9,7 @@ import (
"testing"
"time"
"github.com/influxdb/influxdb/cluster"
"github.com/influxdata/influxdb/cluster"
)
// Ensure that HTTP responses include the InfluxDB version.
@ -5184,7 +5184,7 @@ func TestServer_ContinuousQuery(t *testing.T) {
exp: `{"results":[{"series":[{"name":"cpu","columns":["time","count","host","region","value"],"values":[["` + interval2.UTC().Format(time.RFC3339Nano) + `",3,null,null,null]]},{"name":"gpu","columns":["time","count","host","region","value"],"values":[["` + interval1.UTC().Format(time.RFC3339Nano) + `",2,null,null,null],["` + interval0.UTC().Format(time.RFC3339Nano) + `",1,null,null,null]]}]}]}`,
params: url.Values{"db": []string{"db0"}},
},
// TODO: restore this test once this is fixed: https://github.com/influxdb/influxdb/issues/3968
// TODO: restore this test once this is fixed: https://github.com/influxdata/influxdb/issues/3968
&Query{
skip: true,
name: "check results of cq2",

View File

@ -15,7 +15,7 @@ http://get.influxdb.org.s3.amazonaws.com/influxdb-0.8.9-1.x86_64.rpm
`0.8.9` exports raw data to a flat file that includes two sections, `DDL` and `DML`. You can choose to export them independently (see below).
The `DDL` section contains the sql commands to create databases and retention policies. the `DML` section is [line protocol](https://github.com/influxdb/influxdb/blob/master/tsdb/README.md) and can be directly posted to the [http endpoint](https://influxdb.com/docs/v0.9/guides/writing_data.html) in `0.9`. Remember that batching is important and we don't recommend batch sizes over 5k.
The `DDL` section contains the sql commands to create databases and retention policies. the `DML` section is [line protocol](https://github.com/influxdata/influxdb/blob/master/tsdb/README.md) and can be directly posted to the [http endpoint](https://influxdb.com/docs/v0.9/guides/writing_data.html) in `0.9`. Remember that batching is important and we don't recommend batch sizes over 5k.
You need to specify a database and shard group when you export.

View File

@ -1,4 +1,4 @@
package v8
package v8 // import "github.com/influxdata/influxdb/importer/v8"
import (
"bufio"
@ -11,7 +11,7 @@ import (
"strings"
"time"
"github.com/influxdb/influxdb/client"
"github.com/influxdata/influxdb/client"
)
const batchSize = 5000

1
influxdb.go Normal file
View File

@ -0,0 +1 @@
package influxdb // import "github.com/influxdata/influxdb"

View File

@ -10,7 +10,7 @@ import (
"strings"
"time"
"github.com/influxdb/influxdb/pkg/slices"
"github.com/influxdata/influxdb/pkg/slices"
)
// DataType represents the primitive data types available in InfluxQL.

View File

@ -7,7 +7,7 @@ import (
"testing"
"time"
"github.com/influxdb/influxdb/influxql"
"github.com/influxdata/influxdb/influxql"
)
// Ensure a value's data type can be retrieved.
@ -879,8 +879,8 @@ func TestParseString(t *testing.T) {
{
stmt: `DROP CONTINUOUS QUERY "my query" ON "my database"`,
},
// See issues https://github.com/influxdb/influxdb/issues/1647
// and https://github.com/influxdb/influxdb/issues/4404
// See issues https://github.com/influxdata/influxdb/issues/1647
// and https://github.com/influxdata/influxdb/issues/4404
//{
// stmt: `DELETE FROM "my db"."my rp"."my measurement"`,
//},

View File

@ -6,8 +6,8 @@ import (
"time"
"github.com/davecgh/go-spew/spew"
"github.com/influxdb/influxdb/influxql"
"github.com/influxdb/influxdb/pkg/deep"
"github.com/influxdata/influxdb/influxql"
"github.com/influxdata/influxdb/pkg/deep"
)
// Ensure that a float iterator can be created for a count() call.

View File

@ -4,7 +4,7 @@ import (
"fmt"
"time"
"github.com/influxdb/influxdb/models"
"github.com/influxdata/influxdb/models"
)
// Emitter groups values together by name,

View File

@ -5,9 +5,9 @@ import (
"time"
"github.com/davecgh/go-spew/spew"
"github.com/influxdb/influxdb/influxql"
"github.com/influxdb/influxdb/models"
"github.com/influxdb/influxdb/pkg/deep"
"github.com/influxdata/influxdb/influxql"
"github.com/influxdata/influxdb/models"
"github.com/influxdata/influxdb/pkg/deep"
)
// Ensure the emitter can group iterators together into rows.

View File

@ -1,4 +1,4 @@
package influxql
package influxql // import "github.com/influxdata/influxdb/influxql"
//go:generate tmpl -data=@tmpldata iterator.gen.go.tmpl
//go:generate tmpl -data=@tmpldata point.gen.go.tmpl

View File

@ -8,8 +8,8 @@ import (
"time"
"github.com/davecgh/go-spew/spew"
"github.com/influxdb/influxdb/influxql"
"github.com/influxdb/influxdb/pkg/deep"
"github.com/influxdata/influxdb/influxql"
"github.com/influxdata/influxdb/pkg/deep"
)
// Ensure that a set of iterators can be merged together, sorted by window and name/tag.

View File

@ -958,8 +958,8 @@ func (p *Parser) parseTarget(tr targetRequirement) (*Target, error) {
// This function assumes the DELETE token has already been consumed.
func (p *Parser) parseDeleteStatement() (*DeleteStatement, error) {
// TODO remove and do not skip test once we wire up DELETE FROM.
// See issues https://github.com/influxdb/influxdb/issues/1647
// and https://github.com/influxdb/influxdb/issues/4404
// See issues https://github.com/influxdata/influxdb/issues/1647
// and https://github.com/influxdata/influxdb/issues/4404
return nil, errors.New("DELETE FROM is currently not supported. Use DROP SERIES or DROP MEASUREMENT instead")
//stmt := &DeleteStatement{}

View File

@ -9,7 +9,7 @@ import (
"testing"
"time"
"github.com/influxdb/influxdb/influxql"
"github.com/influxdata/influxdb/influxql"
)
// Ensure the parser can parse a multi-statement query.
@ -644,8 +644,8 @@ func TestParser_ParseStatement(t *testing.T) {
},
},
// See issues https://github.com/influxdb/influxdb/issues/1647
// and https://github.com/influxdb/influxdb/issues/4404
// See issues https://github.com/influxdata/influxdb/issues/1647
// and https://github.com/influxdata/influxdb/issues/4404
// DELETE statement
//{
// s: `DELETE FROM myseries WHERE host = 'hosta.influxdb.org'`,
@ -1731,8 +1731,8 @@ func TestParser_ParseStatement(t *testing.T) {
{s: `SELECT value > 2 FROM cpu`, err: `invalid operator > in SELECT clause at line 1, char 8; operator is intended for WHERE clause`},
{s: `SELECT value = 2 FROM cpu`, err: `invalid operator = in SELECT clause at line 1, char 8; operator is intended for WHERE clause`},
{s: `SELECT s =~ /foo/ FROM cpu`, err: `invalid operator =~ in SELECT clause at line 1, char 8; operator is intended for WHERE clause`},
// See issues https://github.com/influxdb/influxdb/issues/1647
// and https://github.com/influxdb/influxdb/issues/4404
// See issues https://github.com/influxdata/influxdb/issues/1647
// and https://github.com/influxdata/influxdb/issues/4404
//{s: `DELETE`, err: `found EOF, expected FROM at line 1, char 8`},
//{s: `DELETE FROM`, err: `found EOF, expected identifier at line 1, char 13`},
//{s: `DELETE FROM myseries WHERE`, err: `found EOF, expected identifier, string, number, bool at line 1, char 28`},

View File

@ -5,7 +5,7 @@ package influxql
import (
"github.com/gogo/protobuf/proto"
"github.com/influxdb/influxdb/influxql/internal"
"github.com/influxdata/influxdb/influxql/internal"
)
// FloatPoint represents a point with a float64 value.

View File

@ -2,7 +2,7 @@ package influxql
import (
"github.com/gogo/protobuf/proto"
"github.com/influxdb/influxdb/influxql/internal"
"github.com/influxdata/influxdb/influxql/internal"
)
{{range .}}

View File

@ -4,7 +4,7 @@ import (
"sort"
"github.com/gogo/protobuf/proto"
"github.com/influxdb/influxdb/influxql/internal"
"github.com/influxdata/influxdb/influxql/internal"
)
// ZeroTime is the Unix nanosecond timestamp for time.Time{}.

View File

@ -6,8 +6,8 @@ import (
"testing"
"github.com/davecgh/go-spew/spew"
"github.com/influxdb/influxdb/influxql"
"github.com/influxdb/influxdb/pkg/deep"
"github.com/influxdata/influxdb/influxql"
"github.com/influxdata/influxdb/pkg/deep"
)
func TestPoint_Clone_Float(t *testing.T) {

View File

@ -4,7 +4,7 @@ import (
"encoding/json"
"errors"
"github.com/influxdb/influxdb/models"
"github.com/influxdata/influxdb/models"
)
// TagSet is a fundamental concept within the query system. It represents a composite series,

View File

@ -5,7 +5,7 @@ import (
"strings"
"testing"
"github.com/influxdb/influxdb/influxql"
"github.com/influxdata/influxdb/influxql"
)
// Ensure the scanner can scan tokens correctly.

View File

@ -6,8 +6,8 @@ import (
"time"
"github.com/davecgh/go-spew/spew"
"github.com/influxdb/influxdb/influxql"
"github.com/influxdb/influxdb/pkg/deep"
"github.com/influxdata/influxdb/influxql"
"github.com/influxdata/influxdb/pkg/deep"
)
// Second represents a helper for type converting durations.

View File

@ -1,4 +1,4 @@
package models
package models // import "github.com/influxdata/influxdb/models"
import (
"bytes"
@ -11,7 +11,7 @@ import (
"strings"
"time"
"github.com/influxdb/influxdb/pkg/escape"
"github.com/influxdata/influxdb/pkg/escape"
)
var (

View File

@ -11,7 +11,7 @@ import (
"testing"
"time"
"github.com/influxdb/influxdb/models"
"github.com/influxdata/influxdb/models"
)
var (

View File

@ -46,7 +46,7 @@ For example, if you have a component called `Service`, you can statistics like s
```
import (
"expvar"
"github.com/influxdb/influxdb"
"github.com/influxdata/influxdb"
)
.
.

View File

@ -3,7 +3,7 @@ package monitor
import (
"time"
"github.com/influxdb/influxdb/toml"
"github.com/influxdata/influxdb/toml"
)
const (

View File

@ -5,7 +5,7 @@ import (
"time"
"github.com/BurntSushi/toml"
"github.com/influxdb/influxdb/monitor"
"github.com/influxdata/influxdb/monitor"
)
func TestConfig_Parse(t *testing.T) {

View File

@ -1,4 +1,4 @@
package monitor
package monitor // import "github.com/influxdata/influxdb/monitor"
import (
"expvar"
@ -11,10 +11,10 @@ import (
"sync"
"time"
"github.com/influxdb/influxdb"
"github.com/influxdb/influxdb/cluster"
"github.com/influxdb/influxdb/models"
"github.com/influxdb/influxdb/services/meta"
"github.com/influxdata/influxdb"
"github.com/influxdata/influxdb/cluster"
"github.com/influxdata/influxdb/models"
"github.com/influxdata/influxdb/services/meta"
)
const leaderWaitTimeout = 30 * time.Second

View File

@ -4,9 +4,9 @@ import (
"strings"
"testing"
"github.com/influxdb/influxdb"
"github.com/influxdb/influxdb/influxql"
"github.com/influxdb/influxdb/services/meta"
"github.com/influxdata/influxdb"
"github.com/influxdata/influxdb/influxql"
"github.com/influxdata/influxdb/services/meta"
)
// Test that a registered stats client results in the correct SHOW STATS output.

View File

@ -4,8 +4,8 @@ import (
"fmt"
"sort"
"github.com/influxdb/influxdb/influxql"
"github.com/influxdb/influxdb/models"
"github.com/influxdata/influxdb/influxql"
"github.com/influxdata/influxdb/models"
)
// StatementExecutor translates InfluxQL queries to Monitor methods.

View File

@ -2,7 +2,7 @@
// Use of this source code is governed by a BSD-style
// license that can be found in the LICENSE file.
package deep
package deep // import "github.com/influxdata/influxdb/pkg/deep"
import (
"fmt"

View File

@ -1,4 +1,4 @@
package escape
package escape // import "github.com/influxdata/influxdb/pkg/escape"
import "bytes"

View File

@ -1,4 +1,4 @@
package slices
package slices // import "github.com/influxdata/influxdb/pkg/slices"
import "strings"

View File

@ -4,7 +4,7 @@ import (
"testing"
"github.com/BurntSushi/toml"
"github.com/influxdb/influxdb/services/admin"
"github.com/influxdata/influxdb/services/admin"
)
func TestConfig_Parse(t *testing.T) {

View File

@ -1,4 +1,4 @@
package admin
package admin // import "github.com/influxdata/influxdb/services/admin"
import (
"crypto/tls"
@ -10,7 +10,7 @@ import (
"strings"
// Register static assets via statik.
_ "github.com/influxdb/influxdb/statik"
_ "github.com/influxdata/influxdb/statik"
"github.com/rakyll/statik/fs"
)

View File

@ -5,7 +5,7 @@ import (
"net/http"
"testing"
"github.com/influxdb/influxdb/services/admin"
"github.com/influxdata/influxdb/services/admin"
)
// Ensure service can serve the root index page of the admin.

View File

@ -3,7 +3,7 @@ package collectd
import (
"time"
"github.com/influxdb/influxdb/toml"
"github.com/influxdata/influxdb/toml"
)
const (

View File

@ -4,7 +4,7 @@ import (
"testing"
"github.com/BurntSushi/toml"
"github.com/influxdb/influxdb/services/collectd"
"github.com/influxdata/influxdb/services/collectd"
)
func TestConfig_Parse(t *testing.T) {

View File

@ -1,4 +1,4 @@
package collectd
package collectd // import "github.com/influxdata/influxdb/services/collectd"
import (
"expvar"
@ -10,11 +10,11 @@ import (
"sync"
"time"
"github.com/influxdb/influxdb"
"github.com/influxdb/influxdb/cluster"
"github.com/influxdb/influxdb/models"
"github.com/influxdb/influxdb/services/meta"
"github.com/influxdb/influxdb/tsdb"
"github.com/influxdata/influxdb"
"github.com/influxdata/influxdb/cluster"
"github.com/influxdata/influxdb/models"
"github.com/influxdata/influxdb/services/meta"
"github.com/influxdata/influxdb/tsdb"
"github.com/kimor79/gollectd"
)

View File

@ -9,10 +9,10 @@ import (
"testing"
"time"
"github.com/influxdb/influxdb/cluster"
"github.com/influxdb/influxdb/models"
"github.com/influxdb/influxdb/services/meta"
"github.com/influxdb/influxdb/toml"
"github.com/influxdata/influxdb/cluster"
"github.com/influxdata/influxdb/models"
"github.com/influxdata/influxdb/services/meta"
"github.com/influxdata/influxdb/toml"
)
// Test that the service checks / creates the target database on startup.

View File

@ -3,7 +3,7 @@ package continuous_querier
import (
"time"
"github.com/influxdb/influxdb/toml"
"github.com/influxdata/influxdb/toml"
)
// Default values for aspects of interval computation.

View File

@ -5,7 +5,7 @@ import (
"time"
"github.com/BurntSushi/toml"
"github.com/influxdb/influxdb/services/continuous_querier"
"github.com/influxdata/influxdb/services/continuous_querier"
)
func TestConfig_Parse(t *testing.T) {

View File

@ -1,4 +1,4 @@
package continuous_querier
package continuous_querier // import "github.com/influxdata/influxdb/services/continuous_querier"
import (
"errors"
@ -10,10 +10,10 @@ import (
"sync"
"time"
"github.com/influxdb/influxdb"
"github.com/influxdb/influxdb/influxql"
"github.com/influxdb/influxdb/services/meta"
"github.com/influxdb/influxdb/tsdb"
"github.com/influxdata/influxdb"
"github.com/influxdata/influxdb/influxql"
"github.com/influxdata/influxdb/services/meta"
"github.com/influxdata/influxdb/tsdb"
)
const (

View File

@ -9,10 +9,10 @@ import (
"testing"
"time"
"github.com/influxdb/influxdb/cluster"
"github.com/influxdb/influxdb/influxql"
"github.com/influxdb/influxdb/models"
"github.com/influxdb/influxdb/services/meta"
"github.com/influxdata/influxdb/cluster"
"github.com/influxdata/influxdb/influxql"
"github.com/influxdata/influxdb/models"
"github.com/influxdata/influxdb/services/meta"
)
var (

View File

@ -1,4 +1,4 @@
package copier
package copier // import "github.com/influxdata/influxdb/services/copier"
import (
"encoding/binary"
@ -12,9 +12,9 @@ import (
"sync"
"github.com/gogo/protobuf/proto"
"github.com/influxdb/influxdb/services/copier/internal"
"github.com/influxdb/influxdb/tcp"
"github.com/influxdb/influxdb/tsdb"
"github.com/influxdata/influxdb/services/copier/internal"
"github.com/influxdata/influxdb/tcp"
"github.com/influxdata/influxdb/tsdb"
)
//go:generate protoc --gogo_out=. internal/internal.proto

View File

@ -11,10 +11,10 @@ import (
"path/filepath"
"testing"
"github.com/influxdb/influxdb/services/copier"
"github.com/influxdb/influxdb/tcp"
"github.com/influxdb/influxdb/tsdb"
_ "github.com/influxdb/influxdb/tsdb/engine"
"github.com/influxdata/influxdb/services/copier"
"github.com/influxdata/influxdb/tcp"
"github.com/influxdata/influxdb/tsdb"
_ "github.com/influxdata/influxdb/tsdb/engine"
)
// Ensure the service can return shard data.

Some files were not shown because too many files have changed in this diff Show More