Versions in this module Expand all Collapse all v1 v1.0.0 Oct 19, 2018 Changes in this version + const DefaultPortHTTP + const PRECISION_DAY + const PRECISION_DEFAULT + const PRECISION_HOUR + const PRECISION_MICRO + const PRECISION_MICRO2 + const PRECISION_MILLI + const PRECISION_MINUTE + const PRECISION_NANO + const PRECISION_SECOND + const PRECISION_WEEK + var ErrAlreadyExists = errors.New("Already Exists") + var ErrBadParameter = errors.New("Bad Parameter") + var ErrEmptyResponse = errors.New("Empty response from server") + var ErrNotConnected = errors.New("Not connected") + var ErrNotFound = errors.New("Not Found") + var ErrNotSupported = errors.New("Not supported") + var ErrUnexpectedResponse = errors.New("Unexpected response from server") + func Quote(value string) string + func QuoteString(value string) string + type Client interface + CreateDatabase func(name string, policy *RetentionPolicy) error + CreateRetentionPolicy func(name string, policy *RetentionPolicy) error + Database func() string + Do func(query Query) (Results, error) + DropDatabase func(name string) error + DropRetentionPolicy func(name string) error + NewDataset func(name string, tags, fields []string) (Dataset, error) + Precision func() string + RetentionPolicies func() (map[string]*RetentionPolicy, error) + SetDatabase func(value string) error + SetPrecision func(value string) error + Version func() string + Write func(Dataset) error + type Dataset interface + AddValues func(values ...Value) error + AddValuesForTimestamp func(ts time.Time, values ...Value) error + Fields func() []string + Len func() uint + Name func() string + Partial func() bool + SetTag func(key, value string) + Tag func(key string) string + Tags func() []string + ValuesAtIndex func(uint) (time.Time, []Value) + type Measurement struct + Database string + Name string + Policy string + func (m Measurement) String() string + type Predicate interface + String func() string + func TagEquals(name string, value ...string) Predicate + func TagMatches(name, regexp string) Predicate + func TagNotEquals(name, value string) Predicate + type Query interface + Database func(value string) Query + Default func(value bool) Query + Filter func(values ...Predicate) Query + Measurement func(values ...*Measurement) Query + OffsetLimit func(offset uint, limit uint) Query + RetentionPolicy func(value *RetentionPolicy) Query + String func() string + func AlterRetentionPolicy(database string, name string, policy *RetentionPolicy) Query + func CreateDatabase(name string) Query + func CreateRetentionPolicy(database string, name string, policy *RetentionPolicy) Query + func DropDatabase(name string) Query + func DropRetentionPolicy(database string, name string) Query + func Select(measurements ...*Measurement) Query + func ShowDatabases() Query + func ShowMeasurements() Query + func ShowRetentionPolicies() Query + func ShowSeries() Query + type Result struct + Columns []string + Name string + Partial bool + Result int + Series int + Tags map[string]string + Values [][]interface{} + func (r *Result) ParseRetentionPolicies() (map[string]*RetentionPolicy, error) + func (r *Result) String() string + type Results []*Result + func (r Results) Column(result int, series string, column string) ([]Value, error) + func (r Results) String() string + type RetentionPolicy struct + Default bool + Duration time.Duration + ReplicationFactor int + ShardGroupDuration time.Duration + func (this *RetentionPolicy) String() string + type Value interface