client

Mar 6, 2018

Changes in this version

type Client

+ func (c *Client) QueryContext(ctx context.Context, q Query) (*Response, error)

type Query

+ NodeID int

Aug 4, 2017

Changes in this version

type Config

+ UnixSocket string

+ WriteConsistency string

May 11, 2016

Changes in this version

+ type Message struct

+ Level string

+ Text string

type Result

+ Messages []*Message

Apr 7, 2016

Changes in this version

+ type ChunkedResponse struct

+ func NewChunkedResponse(r io.Reader) *ChunkedResponse

+ func (r *ChunkedResponse) NextResponse() (*Response, error)

type Query

+ ChunkSize int

+ Chunked bool

Mar 22, 2016

Changes in this version

type Config

+ UnsafeSsl bool

Nov 17, 2015

Changes in this version

type Client

+ func (c *Client) SetPrecision(precision string)

type Config

+ Precision string

Aug 26, 2015

Changes in this version

+ const DefaultHost

+ const DefaultPort

+ const DefaultTimeout

+ func ParseConnectionString(path string, ssl bool) (url.URL, error)

type Client

+ func (c *Client) WriteLineProtocol(data, database, retentionPolicy, precision, writeConsistency string) (*Response, error)

type Config

+ func NewConfig() Config

Jul 2, 2015

Changes in this version

+ const ConsistencyAll

+ const ConsistencyAny

+ const ConsistencyOne

+ const ConsistencyQuorum

+ func EpochToTime(epoch int64, precision string) (time.Time, error)

+ func SetPrecision(t time.Time, precision string) time.Time

+ type BatchPoints struct

+ Database string

+ Points []Point

+ Precision string

+ RetentionPolicy string

+ Tags map[string]string

+ Time time.Time

+ WriteConsistency string

+ func (bp *BatchPoints) UnmarshalJSON(b []byte) error

type Client

+ func (c *Client) Addr() string

+ func (c *Client) Dump(db string) (io.ReadCloser, error)

+ func (c *Client) SetAuth(u, p string)

+ func (c *Client) Write(bp BatchPoints) (*Response, error)

+ type Config struct

+ Password string

+ Timeout time.Duration

+ URL url.URL

+ UserAgent string

+ Username string

+ type Point struct

+ Fields map[string]interface{}

+ Measurement string

+ Precision string

+ Raw string

+ Tags map[string]string

+ Time time.Time

+ func (p *Point) MarshalJSON() ([]byte, error)

+ func (p *Point) MarshalString() string

+ func (p *Point) UnmarshalJSON(b []byte) error

+ type Query struct

+ Command string

+ Database string

+ type Response struct

+ Err error

+ Results []Result

+ func (r *Response) MarshalJSON() ([]byte, error)

+ func (r *Response) UnmarshalJSON(b []byte) error

+ func (r Response) Error() error

+ type Result struct

+ Err error

+ Series []influxql.Row

+ func (r *Result) MarshalJSON() ([]byte, error)

+ func (r *Result) UnmarshalJSON(b []byte) error

Sep 5, 2014

Changes in this version

+ const UDPMaxMessageSize

+ type Client struct

+ func New(config *ClientConfig) (*Client, error)

+ func NewClient(config *ClientConfig) (*Client, error)

+ func (self *Client) AlterDatabasePrivilege(database, name string, isAdmin bool, permissions ...string) error

+ func (self *Client) AuthenticateClusterAdmin(username, password string) error

+ func (self *Client) AuthenticateDatabaseUser(database, username, password string) error

+ func (self *Client) ChangeClusterAdminPassword(name, newPassword string) error

+ func (self *Client) ChangeDatabaseUser(database, name, newPassword string, isAdmin bool, newPermissions ...string) error

+ func (self *Client) CreateClusterAdmin(name, password string) error

+ func (self *Client) CreateDatabase(name string) error

+ func (self *Client) CreateDatabaseUser(database, name, password string, permissions ...string) error

+ func (self *Client) CreateShardSpace(database string, space *ShardSpace) error

+ func (self *Client) DeleteClusterAdmin(name string) error

+ func (self *Client) DeleteContinuousQueries(id int) error

+ func (self *Client) DeleteDatabase(name string) error

+ func (self *Client) DeleteDatabaseUser(database, name string) error

+ func (self *Client) DisableCompression()

+ func (self *Client) DropShard(id uint32, serverIds []uint32) error

+ func (self *Client) DropShardSpace(database, name string) error

+ func (self *Client) GetClusterAdminList() ([]map[string]interface{}, error)

+ func (self *Client) GetContinuousQueries() ([]map[string]interface{}, error)

+ func (self *Client) GetDatabaseList() ([]map[string]interface{}, error)

+ func (self *Client) GetDatabaseUserList(database string) ([]map[string]interface{}, error)

+ func (self *Client) GetShardSpaces() ([]*ShardSpace, error)

+ func (self *Client) GetShards() (*LongTermShortTermShards, error)

+ func (self *Client) Ping() error

+ func (self *Client) Query(query string, precision ...TimePrecision) ([]*Series, error)

+ func (self *Client) QueryWithNumbers(query string, precision ...TimePrecision) ([]*Series, error)

+ func (self *Client) RemoveServer(id int) error

+ func (self *Client) Servers() ([]map[string]interface{}, error)

+ func (self *Client) UpdateClusterAdmin(name, password string) error

+ func (self *Client) UpdateDatabaseUser(database, name, password string) error

+ func (self *Client) UpdateDatabaseUserPermissions(database, name, readPermission, writePermissions string) error

+ func (self *Client) UpdateShardSpace(database, name string, space *ShardSpace) error

+ func (self *Client) WriteSeries(series []*Series) error

+ func (self *Client) WriteSeriesOverUDP(series []*Series) error

+ func (self *Client) WriteSeriesWithTimePrecision(series []*Series, timePrecision TimePrecision) error

+ type ClientConfig struct

+ Database string

+ Host string

+ HttpClient *http.Client

+ IsSecure bool

+ IsUDP bool

+ Password string

+ Username string

+ type LongTermShortTermShards struct

+ All []*Shard

+ LongTerm []*Shard

+ ShortTerm []*Shard

+ type Series struct

+ Columns []string

+ Name string

+ Points [][]interface{}

+ func (self *Series) GetColumns() []string

+ func (self *Series) GetName() string

+ func (self *Series) GetPoints() [][]interface{}

+ type Shard struct

+ Database string

+ EndTime int64

+ Id uint32

+ ServerIds []uint32

+ SpaceName string

+ StartTime int64

+ type ShardSpace struct

+ Database string

+ Name string

+ Regex string

+ ReplicationFactor uint32

+ RetentionPolicy string

+ ShardDuration string

+ Split uint32

+ type ShardSpaceCollection struct

+ ShardSpaces []ShardSpace

+ type TimePrecision string

+ const Microsecond

+ const Millisecond

+ const Second