influxdb3

package

Go to main page

Versions in this module

v0

v0.7.0

Apr 16, 2024

Changes in this version

type Option

+ func WithHeader(key, value string) Option

type QueryOptions

+ Headers http.Header

type QueryType

+ const SQL

v0.6.0

Mar 1, 2024

Changes in this version

type Client

+ func (c *Client) QueryWithParameters(ctx context.Context, query string, parameters QueryParameters, ...) (*QueryIterator, error)

+ type Option func(o *options)

+ func WithDatabase(database string) Option

+ func WithDefaultTags(tags map[string]string) Option

+ func WithGzipThreshold(gzipThreshold int) Option

+ func WithPrecision(precision lineprotocol.Precision) Option

+ func WithQueryType(queryType QueryType) Option

+ type QueryOption = Option

+ type QueryParameters = map[string]any

+ type WriteOption = Option

type WriteOptions

+ DefaultTags map[string]string

v0.5.0

Dec 5, 2023

Changes in this version

type Point

+ func (p *Point) MarshalBinaryWithDefaultTags(precision lineprotocol.Precision, defaultTags map[string]string) ([]byte, error)

v0.4.0

Nov 3, 2023

Changes in this version

type Point

+ Values *PointValues

+ func FromValues(values *PointValues) (*Point, error)

+ func NewPointWithPointValues(values *PointValues) *Point

+ func (p *Point) Copy() *Point

+ func (p *Point) GetBooleanField(name string) *bool

+ func (p *Point) GetDoubleField(name string) *float64

+ func (p *Point) GetField(name string) interface{}

+ func (p *Point) GetFieldNames() []string

+ func (p *Point) GetIntegerField(name string) *int64

+ func (p *Point) GetMeasurement() string

+ func (p *Point) GetStringField(name string) *string

+ func (p *Point) GetTag(name string) (string, bool)

+ func (p *Point) GetTagNames() []string

+ func (p *Point) GetUIntegerField(name string) *uint64

+ func (p *Point) HasFields() bool

+ func (p *Point) RemoveField(name string) *Point

+ func (p *Point) RemoveTag(name string) *Point

+ func (p *Point) SetBooleanField(name string, value bool) *Point

+ func (p *Point) SetDoubleField(name string, value float64) *Point

+ func (p *Point) SetField(name string, value interface{}) *Point

+ func (p *Point) SetIntegerField(name string, value int64) *Point

+ func (p *Point) SetMeasurement(measurementName string) *Point

+ func (p *Point) SetStringField(name string, value string) *Point

+ func (p *Point) SetTag(name string, value string) *Point

+ func (p *Point) SetTimestampWithEpoch(timestamp int64) *Point

+ func (p *Point) SetUIntegerField(name string, value uint64) *Point

+ type PointValues struct

+ Fields map[string]interface{}

+ MeasurementName string

+ Tags map[string]string

+ Timestamp time.Time

+ func NewPointValues(measurementName string) *PointValues

+ func (pv *PointValues) AsPoint() (*Point, error)

+ func (pv *PointValues) AsPointWithMeasurement(measurement string) (*Point, error)

+ func (pv *PointValues) Copy() *PointValues

+ func (pv *PointValues) GetBooleanField(name string) *bool

+ func (pv *PointValues) GetDoubleField(name string) *float64

+ func (pv *PointValues) GetField(name string) interface{}

+ func (pv *PointValues) GetFieldNames() []string

+ func (pv *PointValues) GetIntegerField(name string) *int64

+ func (pv *PointValues) GetMeasurement() string

+ func (pv *PointValues) GetStringField(name string) *string

+ func (pv *PointValues) GetTag(name string) (string, bool)

+ func (pv *PointValues) GetTagNames() []string

+ func (pv *PointValues) GetUIntegerField(name string) *uint64

+ func (pv *PointValues) HasFields() bool

+ func (pv *PointValues) RemoveField(name string) *PointValues

+ func (pv *PointValues) RemoveTag(name string) *PointValues

+ func (pv *PointValues) SetBooleanField(name string, value bool) *PointValues

+ func (pv *PointValues) SetDoubleField(name string, value float64) *PointValues

+ func (pv *PointValues) SetField(name string, value interface{}) *PointValues

+ func (pv *PointValues) SetIntegerField(name string, value int64) *PointValues

+ func (pv *PointValues) SetMeasurement(measurementName string) *PointValues

+ func (pv *PointValues) SetStringField(name string, value string) *PointValues

+ func (pv *PointValues) SetTag(name string, value string) *PointValues

+ func (pv *PointValues) SetTimestamp(timestamp time.Time) *PointValues

+ func (pv *PointValues) SetTimestampWithEpoch(timestamp int64) *PointValues

+ func (pv *PointValues) SetUIntegerField(name string, value uint64) *PointValues

type QueryIterator

+ func (i *QueryIterator) AsPoints() *PointValues

v0.3.0

Oct 2, 2023

Changes in this version

type Client

+ func NewFromConnectionString(connectionString string) (*Client, error)

+ func NewFromEnv() (*Client, error)

v0.2.0

Aug 11, 2023

Changes in this version

+ var DefaultQueryOptions = QueryOptions

+ var DefaultWriteOptions = WriteOptions

+ func ReplaceURLProtocolWithPort(url string) (string, *bool)

+ type Client struct

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

+ func (c *Client) Close() error

+ func (c *Client) Query(ctx context.Context, query string) (*QueryIterator, error)

+ func (c *Client) QueryWithOptions(ctx context.Context, options *QueryOptions, query string) (*QueryIterator, error)

+ func (c *Client) Write(ctx context.Context, buff []byte) error

+ func (c *Client) WriteData(ctx context.Context, points ...interface{}) error

+ func (c *Client) WriteDataWithOptions(ctx context.Context, options *WriteOptions, points ...interface{}) error

+ func (c *Client) WritePoints(ctx context.Context, points ...*Point) error

+ func (c *Client) WritePointsWithOptions(ctx context.Context, options *WriteOptions, points ...*Point) error

+ func (c *Client) WriteWithOptions(ctx context.Context, options *WriteOptions, buff []byte) error

+ type ClientConfig struct

+ Database string

+ HTTPClient *http.Client

+ Headers http.Header

+ Host string

+ Organization string

+ Token string

+ WriteOptions *WriteOptions

+ type Field struct

+ Key string

+ Value lineprotocol.Value

+ type Point struct

+ Fields []Field

+ Measurement string

+ Tags []Tag

+ Timestamp time.Time

+ 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) MarshalBinary(precision lineprotocol.Precision) ([]byte, error)

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

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

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

+ type QueryIterator struct

+ func (i *QueryIterator) Done() bool

+ func (i *QueryIterator) Index() interface{}

+ func (i *QueryIterator) Next() bool

+ func (i *QueryIterator) Raw() *flight.Reader

+ func (i *QueryIterator) Value() map[string]interface{}

+ type QueryOptions struct

+ Database string

+ QueryType QueryType

+ type QueryType int

+ const FlightSQL

+ const InfluxQL

+ func (t QueryType) String() string

+ type ServerError struct

+ Code string

+ Message string

+ RetryAfter int

+ StatusCode int

+ func NewServerError(message string) *ServerError

+ func (e ServerError) Error() string

+ type Tag struct

+ Key string

+ Value string

+ type WriteOptions struct

+ Database string

+ GzipThreshold int

+ Precision lineprotocol.Precision

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL