Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

influxdb3

package

Go to main page

Versions in this module

v2

v2.3.0

Feb 20, 2025

Changes in this version

+ var Done = errors.New("no more items in iterator")

type Client

+ func (c *Client) QueryPointValue(ctx context.Context, query string, options ...QueryOption) (*PointValueIterator, error)

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

+ type PointValueIterator struct

+ func (it *PointValueIterator) Index() int

+ func (it *PointValueIterator) Next() (*PointValues, error)

v2.2.0

Feb 3, 2025

v2.1.0

Jan 16, 2025

v2.0.0

Dec 13, 2024

Changes in this version

+ var DefaultQueryOptions = QueryOptions

+ var DefaultWriteOptions = WriteOptions

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

+ var MaxPartitions = 7

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

+ type Bucket struct

+ Description string

+ Name string

+ OrgID string

+ RetentionRules []BucketRetentionRule

+ type BucketRetentionRule struct

+ EverySeconds int

+ ShardGroupDuration int

+ Type string

+ type Client struct

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

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

+ func NewFromEnv() (*Client, error)

+ func (c *Client) Close() error

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

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

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

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

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

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

+ func (c *Client) WritePoints(ctx context.Context, points []*Point, options ...WriteOption) 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

+ AuthScheme string

+ Database string

+ HTTPClient *http.Client

+ Headers http.Header

+ Host string

+ Organization string

+ Token string

+ WriteOptions *WriteOptions

+ 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 Option func(o *options)

+ func WithDatabase(database string) Option

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

+ func WithGzipThreshold(gzipThreshold int) Option

+ func WithHeader(key, value string) Option

+ func WithPrecision(precision lineprotocol.Precision) Option

+ func WithQueryType(queryType QueryType) Option

+ type PartitionTemplate interface

+ type Point struct

+ Values *PointValues

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

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

+ func NewPointWithMeasurement(name string) *Point

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

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

+ 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) SetTimestamp(timestamp time.Time) *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 struct

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

+ 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 QueryOption = Option

+ type QueryOptions struct

+ Database string

+ Headers http.Header

+ QueryType QueryType

+ type QueryParameters = map[string]any

+ type QueryType int

+ const InfluxQL

+ const SQL

+ func (t QueryType) String() string

+ type ServerError struct

+ Code string

+ Headers http.Header

+ Message string

+ RetryAfter int

+ StatusCode int

+ func NewServerError(message string) *ServerError

+ func (e ServerError) Error() string

+ type ServerlessClient struct

+ func NewServerlessClient(client *Client) *ServerlessClient

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

+ type Tag struct

+ Type string

+ Value string

+ type TagBucket struct

+ Type string

+ Value TagBucketValue

+ type TagBucketValue struct

+ NumberOfBuckets uint64

+ TagName string

+ type WriteOption = Option

+ type WriteOptions struct

+ Database string

+ DefaultTags map[string]string

+ GzipThreshold int

+ Precision lineprotocol.Precision

Other modules containing this package

github.com/InfluxCommunity/influxdb3-go