influxdb

type AuthenticationMethod int

type BatchPoints interface {
	// AddPoint adds the given point to the Batch of points
	AddPoint(p Point)
	// AddPoints adds the given points to the Batch of points
	AddPoints(ps []Point)
	// Points lists the points in the Batch
	Points() []Point

	// Precision returns the currently set precision of this Batch
	Precision() string
	// SetPrecision sets the precision of this batch.
	SetPrecision(s string) error

	// Database returns the currently set database of this Batch
	Database() string
	// SetDatabase sets the database of this Batch
	SetDatabase(s string)

	// WriteConsistency returns the currently set write consistency of this Batch
	WriteConsistency() string
	// SetWriteConsistency sets the write consistency of this Batch
	SetWriteConsistency(s string)

	// RetentionPolicy returns the currently set retention policy of this Batch
	RetentionPolicy() string
	// SetRetentionPolicy sets the retention policy of this Batch
	SetRetentionPolicy(s string)
}

type BatchPointsConfig struct {
	// Precision is the write precision of the points, defaults to "ns"
	Precision string

	// Database is the database to write points to
	Database string

	// RetentionPolicy is the retention policy of the points
	RetentionPolicy string

	// Write consistency is the number of servers required to confirm write
	WriteConsistency string
}

type Client interface {
	// Ping checks that status of cluster
	// The provided context can be used to cancel the request.
	Ping(ctx context.Context) (time.Duration, string, error)

	// Write takes a BatchPoints object and writes all Points to InfluxDB.
	Write(bp BatchPoints) error

	// WriteV2 takes a FluxWrite object and writes all Points to InfluxDB using the V2 interface.
	WriteV2(w FluxWrite) error

	// Query makes an InfluxDB Query on the database.
	// The response is checked for an error and the is returned
	// if it exists
	Query(q Query) (*Response, error)

	// QueryFlux is for querying Influxdb with the Flux language
	// The response is checked for an error and the is returned
	// if it exists
	QueryFlux(q FluxQuery) (flux.ResultIterator, error)

	// QueryFlux is for querying Influxdb with the Flux language
	// The response is checked for an error and the is returned
	// if it exists.  Unlike QueryFlux, this returns a *Response
	// object.
	QueryFluxResponse(q FluxQuery) (*Response, error)

	// CreateBucketV2 uses the 2.x /api/v2/bucket api to create a bucket.
	// Note that 1.x does not support this API
	CreateBucketV2(bucket string, org string, orgID string) error
}

type ClientCreator struct{}

type ClientUpdater interface {
	Client
	Update(new Config) error
	Close() error
}

type Config struct {
	// The URL of the InfluxDB server.
	URLs []string

	// Optional credentials for authenticating with the server.
	Credentials Credentials

	// UserAgent is the http User Agent, defaults to "KapacitorInfluxDBClient"
	UserAgent string

	// Timeout for requests, defaults to no timeout.
	Timeout time.Duration

	// Transport is the HTTP transport to use for requests
	// If nil, a default transport will be used.
	Transport *http.Transport

	// Which compression should we use for writing to influxdb, defaults to "gzip".
	Compression string
}

type Credentials struct {
	Method AuthenticationMethod

	// UserAuthentication fields
	Username string
	Password string

	// TokenAuthentication fields
	Token string

	// BearerAuthentication fields
	HttpSharedSecret bool
}

type Diagnostic interface {
	Error(msg string, err error, ctx ...keyvalue.T)
}

type FluxCSVEventHandler interface {
	// Error event represents a ',error' table in the flux result, which is special
	Error(err string)

	// GroupStart gives the metadata for a new group of tables
	GroupStart(names []string, types []string, groups []bool)

	// TableStart marks the start of a table
	TableStart(meta FluxTableMetaData, firstRow []string)

	// DataRow is called for each regular data row
	DataRow(meta FluxTableMetaData, row []string)

	// TableEnd marks the end of a table
	TableEnd()
}

type FluxCSVEventParser struct {
	// contains filtered or unexported fields
}

type FluxQuery struct {
	Org   string
	OrgID string
	Query string
	Now   time.Time
}

type FluxTableMetaData struct {
	TableNumber string
	DataTypes   []string
	ColumnNames []string
	Groups      []bool
}

type FluxWrite struct {
	Bucket string
	Org    string
	OrgID  string
	Points models.Points
}

type HTTPClient struct {
	// contains filtered or unexported fields
}

type Message struct {
	Level string
	Text  string
}

type Point struct {
	Name   string
	Tags   map[string]string
	Fields map[string]interface{}
	Time   time.Time
}

type Query struct {
	Command   string
	Database  string
	Precision string
}

type Response struct {
	Results []Result
	Err     string `json:"error,omitempty"`
}

type Result struct {
	Series   []imodels.Row
	Messages []*Message
	Err      string `json:"error,omitempty"`
}

type TokenClientCreator struct {
	// contains filtered or unexported fields
}