influxdb3

package

Go to main page

Versions in this module

v0

v0.14.0

Nov 11, 2024

v0.13.0

Oct 22, 2024

v0.12.0

Oct 2, 2024

v0.11.0

Sep 27, 2024

v0.10.0

Sep 13, 2024

Changes in this version

type ServerError

+ Headers http.Header

v0.9.0

Aug 12, 2024

Changes in this version

+ var ManagementAPIURL = "https://console.influxdata.com"

+ var MaxPartitions = 7

type ClientConfig

+ AuthScheme string

+ type CloudDedicatedClient struct

+ func NewCloudDedicatedClient(client *Client) *CloudDedicatedClient

+ func (d *CloudDedicatedClient) CreateDatabase(ctx context.Context, config *CloudDedicatedClientConfig, db *Database) error

+ type CloudDedicatedClientConfig struct

+ AccountID string

+ ClusterID string

+ ManagementAPIURL *url.URL

+ ManagementToken string

+ type Database struct

+ ClusterDatabaseMaxColumnsPerTable uint64

+ ClusterDatabaseMaxTables uint64

+ ClusterDatabaseName string

+ ClusterDatabasePartitionTemplate []PartitionTemplate

+ ClusterDatabaseRetentionPeriod uint64

+ type PartitionTemplate interface

type Tag

+ Type string

+ type TagBucket struct

+ Type string

+ Value TagBucketValue

+ type TagBucketValue struct

+ NumberOfBuckets uint64

+ TagName string

v0.8.0

Jun 24, 2024

Changes in this version

+ type Bucket struct

+ Description string

+ Name string

+ OrgID string

+ RetentionRules []BucketRetentionRule

+ type BucketRetentionRule struct

+ EverySeconds int

+ ShardGroupDuration int

+ Type string

+ type ServerlessClient struct

+ func NewServerlessClient(client *Client) *ServerlessClient

+ func (c *ServerlessClient) CreateBucket(ctx context.Context, bucket *Bucket) error

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

Other modules containing this package

github.com/InfluxCommunity/influxdb3-go/v2

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