influxdb

Jul 17, 2020

Changes in this version

type Client

+ AuthorizationsAPI func() api.AuthorizationsAPI

+ BucketsAPI func() api.BucketsAPI

+ DeleteAPI func() api.DeleteAPI

+ LabelsAPI func() api.LabelsAPI

+ OrganizationsAPI func() api.OrganizationsAPI

+ QueryAPI func(org string) api.QueryAPI

+ ServerURL func() string

+ UsersAPI func() api.UsersAPI

+ WriteAPI func(org, bucket string) api.WriteAPI

+ WriteAPIBlocking func(org, bucket string) api.WriteAPIBlocking

type Options

+ func (o *Options) HTTPOptions() *http.Options

+ func (o *Options) HTTPRequestTimeout() uint

+ func (o *Options) SetHTTPRequestTimeout(httpRequestTimeout uint) *Options

+ func (o *Options) SetTLSConfig(tlsConfig *tls.Config) *Options

+ func (o *Options) TLSConfig() *tls.Config

Jun 19, 2020

Changes in this version

type Client

+ LabelsApi func() api.LabelsApi

type Options

+ func (o *Options) AddDefaultTag(key, value string) *Options

May 15, 2020

Changes in this version

type Client

+ AuthorizationsApi func() api.AuthorizationsApi

+ BucketsApi func() api.BucketsApi

+ DeleteApi func() api.DeleteApi

+ Health func(ctx context.Context) (*domain.HealthCheck, error)

+ Options func() *Options

+ OrganizationsApi func() api.OrganizationsApi

+ QueryApi func(org string) api.QueryApi

+ Ready func(ctx context.Context) (bool, error)

+ ServerUrl func() string

+ UsersApi func() api.UsersApi

+ WriteApi func(org, bucket string) api.WriteApi

+ WriteApiBlocking func(org, bucket string) api.WriteApiBlocking

type Options

+ func (o *Options) HttpOptions() *http.Options

+ func (o *Options) WriteOptions() *write.Options

Apr 24, 2020

Changes in this version

type InfluxDBClient

+ AuthorizationsApi func() api.AuthorizationsApi

+ OrganizationsApi func() api.OrganizationsApi

+ UsersApi func() api.UsersApi

type Options

+ func (o *Options) HttpRequestTimeout() uint

+ func (o *Options) SetHttpRequestTimeout(httpRequestTimeout uint) *Options

Apr 1, 2020

Changes in this version

+ const Version

+ func DefaultDialect() *domain.Dialect

type Error

+ StatusCode int

+ func NewError(err error) *Error

+ type FluxColumn struct

+ func (f *FluxColumn) DataType() string

+ func (f *FluxColumn) DefaultValue() string

+ func (f *FluxColumn) Index() int

+ func (f *FluxColumn) IsGroup() bool

+ func (f *FluxColumn) Name() string

+ func (f *FluxColumn) SetDataType(dataType string)

+ func (f *FluxColumn) SetDefaultValue(defaultValue string)

+ func (f *FluxColumn) SetGroup(group bool)

+ func (f *FluxColumn) SetName(name string)

+ func (f *FluxColumn) String() string

+ type FluxRecord struct

+ func (r *FluxRecord) Field() string

+ func (r *FluxRecord) Measurement() string

+ func (r *FluxRecord) Start() time.Time

+ func (r *FluxRecord) Stop() time.Time

+ func (r *FluxRecord) String() string

+ func (r *FluxRecord) Table() int

+ func (r *FluxRecord) Time() time.Time

+ func (r *FluxRecord) Value() interface{}

+ func (r *FluxRecord) ValueByKey(key string) interface{}

+ func (r *FluxRecord) Values() map[string]interface{}

+ type FluxTableMetadata struct

+ func (f *FluxTableMetadata) AddColumn(column *FluxColumn) *FluxTableMetadata

+ func (f *FluxTableMetadata) Column(index int) *FluxColumn

+ func (f *FluxTableMetadata) Columns() []*FluxColumn

+ func (f *FluxTableMetadata) Position() int

+ func (f *FluxTableMetadata) String() string

+ type InfluxDBClient interface

+ Close func()

+ Options func() *Options

+ QueryApi func(org string) QueryApi

+ Ready func(ctx context.Context) (bool, error)

+ ServerUrl func() string

+ Setup func(ctx context.Context, username, password, org, bucket string, ...) (*domain.OnboardingResponse, error)

+ WriteApi func(org, bucket string) WriteApi

+ WriteApiBlocking func(org, bucket string) WriteApiBlocking

+ func NewClient(serverUrl string, authToken string) InfluxDBClient

+ func NewClientWithOptions(serverUrl string, authToken string, options *Options) InfluxDBClient

+ type Options struct

+ func DefaultOptions() *Options

+ func (o *Options) BatchSize() uint

+ func (o *Options) FlushInterval() uint

+ func (o *Options) LogLevel() uint

+ func (o *Options) MaxRetries() uint

+ func (o *Options) Precision() time.Duration

+ func (o *Options) RetryBufferLimit() uint

+ func (o *Options) RetryInterval() uint

+ func (o *Options) SetBatchSize(batchSize uint) *Options

+ func (o *Options) SetFlushInterval(flushIntervalMs uint) *Options

+ func (o *Options) SetLogLevel(logLevel uint) *Options

+ func (o *Options) SetMaxRetries(maxRetries uint) *Options

+ func (o *Options) SetPrecision(precision time.Duration) *Options

+ func (o *Options) SetRetryBufferLimit(retryBufferLimit uint) *Options

+ func (o *Options) SetRetryInterval(retryIntervalMs uint) *Options

+ func (o *Options) SetTlsConfig(tlsConfig *tls.Config) *Options

+ func (o *Options) SetUseGZip(useGZip bool) *Options

+ func (o *Options) TlsConfig() *tls.Config

+ func (o *Options) UseGZip() bool

+ type Point struct

+ func NewPoint(measurement string, tags map[string]string, fields map[string]interface{}, ...) *Point

+ func NewPointWithMeasurement(measurement string) *Point

+ func (m *Point) AddField(k string, v interface{}) *Point

+ func (m *Point) AddTag(k, v string) *Point

+ func (m *Point) FieldList() []*lp.Field

+ func (m *Point) Name() string

+ func (m *Point) SetTime(timestamp time.Time) *Point

+ func (m *Point) SortFields() *Point

+ func (m *Point) SortTags() *Point

+ func (m *Point) TagList() []*lp.Tag

+ func (m *Point) Time() time.Time

+ type QueryApi interface

+ Query func(ctx context.Context, query string) (*QueryTableResult, error)

+ QueryRaw func(ctx context.Context, query string, dialect *domain.Dialect) (string, error)

+ type QueryTableResult struct

+ func (q *QueryTableResult) Err() error

+ func (q *QueryTableResult) Next() bool

+ func (q *QueryTableResult) Record() *FluxRecord

+ func (q *QueryTableResult) TableChanged() bool

+ func (q *QueryTableResult) TableMetadata() *FluxTableMetadata

+ func (q *QueryTableResult) TablePosition() int

+ type RequestCallback func(req *http.Request)

+ type ResponseCallback func(req *http.Response) error

+ type WriteApi interface

+ Close func()

+ Errors func() <-chan error

+ Flush func()

+ WritePoint func(point *Point)

+ WriteRecord func(line string)

+ type WriteApiBlocking interface

+ WritePoint func(ctx context.Context, point ...*Point) error

+ WriteRecord func(ctx context.Context, line ...string) error

Feb 6, 2020

Changes in this version

+ func NewWriteGzipRequest(url *url.URL, userAgent, token, bucket, org string, compressionLevel int, ...) (*http.Request, error)

+ func NewWriteRequest(url *url.URL, userAgent, token, bucket, org string, body io.Reader) (*http.Request, error)

Sep 19, 2019

Changes in this version

+ const EConflict

+ const EEmptyValue

+ const EForbidden

+ const EInternal

+ const EInvalid

+ const EMethodNotAllowed

+ const ENotFound

+ const ETooManyRequests

+ const EUnauthorized

+ const EUnavailable

+ const EUnprocessableEntity

+ var ErrUnimplemented = errors.New("unimplemented")

+ func HTTPClientWithTLSConfig(conf *tls.Config) *http.Client

+ type Client struct

+ func New(connection string, token string, options ...Option) (*Client, error)

+ func (c *Client) Close() error

+ func (c *Client) Ping(ctx context.Context) error

+ func (c *Client) QueryCSV(ctx context.Context, flux string, org string, extern ...interface{}) (*QueryCSVResult, error)

+ func (c *Client) Setup(ctx context.Context, bucket, org string, retentionPeriodHrs int) (*SetupResult, error)

+ func (c *Client) Write(ctx context.Context, bucket, org string, m ...Metric) (n int, err error)

+ type Error struct

+ Code string

+ Err string

+ Line *int32

+ MaxLength *int32

+ Message string

+ Op string

+ RetryAfter *int32

+ func (e *Error) Error() string

+ type Field = lp.Field

+ type HTTPConfig struct

+ Addr string

+ HTTPClient *http.Client

+ InsecureSkipVerify bool

+ Password string

+ Proxy func(req *http.Request) (*url.URL, error)

+ TLSConfig *tls.Config

+ Timeout time.Duration

+ UserAgent string

+ Username string

+ type Metric = lp.Metric

+ type Option struct

+ func WithGZIP(n int) Option

+ func WithHTTPClient(h *http.Client) Option

+ func WithMaxLineBytes(n int) Option

+ func WithNoCompression() Option

+ func WithUserAgent(ua string) Option

+ func WithUserAndPass(username, password string) Option

+ func WithV1Config(conf *HTTPConfig) Option

+ type QueryCSVResult struct

+ ColNames []string

+ Err error

+ Row []string

+ func (q *QueryCSVResult) Next() bool

+ func (q *QueryCSVResult) Unmarshal(x interface{}) error

+ type RowMetric struct

+ Fields []*lp.Field

+ NameStr string

+ TS time.Time

+ Tags []*lp.Tag

+ func NewRowMetric(fields map[string]interface{}, name string, tags map[string]string, ...) *RowMetric

+ func (m *RowMetric) AddField(k string, v interface{})

+ func (m *RowMetric) AddTag(k, v string)

+ func (m *RowMetric) FieldList() []*lp.Field

+ func (m *RowMetric) Name() string

+ func (m *RowMetric) SortFields()

+ func (m *RowMetric) SortTags()

+ func (m *RowMetric) TagList() []*lp.Tag

+ func (m *RowMetric) Time() time.Time

+ type SetupRequest struct

+ Bucket string

+ Org string

+ Password string

+ RetentionPeriodHrs int

+ Username string

+ type SetupResult struct

+ Auth struct{ ... }

+ Bucket struct{ ... }

+ Code string

+ Message string

+ Org struct{ ... }

+ User struct{ ... }

+ type Tag = lp.Tag