questdb

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

type HttpError struct {
	Code    string `json:"code"`
	Message string `json:"message"`
	Line    int    `json:"line,omitempty"`
	ErrorId string `json:"errorId"`
	// contains filtered or unexported fields
}

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

type LineSender interface {
	// Table sets the table name (metric) for a new ILP message. Should be
	// called before any Symbol or Column method.
	//
	// Table name cannot contain any of the following characters:
	// '\n', '\r', '?', ',', ”', '"', '\', '/', ':', ')', '(', '+', '*',
	// '%', '~', starting '.', trailing '.', or a non-printable char.
	Table(name string) LineSender

	// Symbol adds a symbol column value to the ILP message. Should be called
	// before any Column method.
	//
	// Symbol name cannot contain any of the following characters:
	// '\n', '\r', '?', '.', ',', ”', '"', '\\', '/', ':', ')', '(', '+',
	// '-', '*' '%%', '~', or a non-printable char.
	Symbol(name, val string) LineSender

	// Int64Column adds a 64-bit integer (long) column value to the ILP
	// message.
	//
	// Column name cannot contain any of the following characters:
	// '\n', '\r', '?', '.', ',', ”', '"', '\\', '/', ':', ')', '(', '+',
	// '-', '*' '%%', '~', or a non-printable char.
	Int64Column(name string, val int64) LineSender

	// Long256Column adds a 256-bit unsigned integer (long256) column
	// value to the ILP message.
	//
	// Only non-negative numbers that fit into 256-bit unsigned integer are
	// supported and any other input value would lead to an error.
	//
	// Column name cannot contain any of the following characters:
	// '\n', '\r', '?', '.', ',', ”', '"', '\\', '/', ':', ')', '(', '+',
	// '-', '*' '%%', '~', or a non-printable char.
	Long256Column(name string, val *big.Int) LineSender

	// TimestampColumn adds a timestamp column value to the ILP
	// message.
	//
	// Should be used only for non-designated timestamp column.
	// Designated timestamp column values should be passed to At/AtNow.
	//
	// Column name cannot contain any of the following characters:
	// '\n', '\r', '?', '.', ',', ”', '"', '\\', '/', ':', ')', '(', '+',
	// '-', '*' '%%', '~', or a non-printable char.
	TimestampColumn(name string, ts time.Time) LineSender

	// Float64Column adds a 64-bit float (double) column value to the ILP
	// message.
	//
	// Column name cannot contain any of the following characters:
	// '\n', '\r', '?', '.', ',', ”', '"', '\', '/', ':', ')', '(', '+',
	// '-', '*' '%%', '~', or a non-printable char.
	Float64Column(name string, val float64) LineSender

	// DecimalColumnFromString adds a decimal column value to the ILP message.
	//
	// Serializes the decimal value using the text representation.
	//
	// Column name cannot contain any of the following characters:
	// '\n', '\r', '?', '.', ',', ”', '"', '\', '/', ':', ')', '(', '+',
	// '-', '*' '%%', '~', or a non-printable char.
	DecimalColumnFromString(name string, val string) LineSender

	// DecimalColumn adds a decimal column value to the ILP message.
	//
	// Serializes the decimal value using the binary representation.
	//
	// Column name cannot contain any of the following characters:
	// '\n', '\r', '?', '.', ',', ”', '"', '\', '/', ':', ')', '(', '+',
	// '-', '*' '%%', '~', or a non-printable char.
	DecimalColumn(name string, val Decimal) LineSender

	// DecimalColumnShopspring adds a decimal column value to the ILP message.
	//
	// Serializes the decimal value using the binary representation.
	//
	// Column name cannot contain any of the following characters:
	// '\n', '\r', '?', '.', ',', ”', '"', '\', '/', ':', ')', '(', '+',
	// '-', '*' '%%', '~', or a non-printable char.
	DecimalColumnShopspring(name string, val ShopspringDecimal) LineSender

	// StringColumn adds a string column value to the ILP message.
	//
	// Column name cannot contain any of the following characters:
	// '\n', '\r', '?', '.', ',', ”', '"', '\', '/', ':', ')', '(', '+',
	// '-', '*' '%%', '~', or a non-printable char.
	StringColumn(name, val string) LineSender

	// BoolColumn adds a boolean column value to the ILP message.
	//
	// Column name cannot contain any of the following characters:
	// '\n', '\r', '?', '.', ',', ”', '"', '\', '/', ':', ')', '(', '+',
	// '-', '*' '%%', '~', or a non-printable char.
	BoolColumn(name string, val bool) LineSender

	// Float64Array1DColumn adds an array of 64-bit floats (double array) to the ILP message.
	//
	// Column name cannot contain any of the following characters:
	// '\n', '\r', '?', '.', ',', "', '"', '\', '/', ':', ')', '(', '+',
	// '-', '*' '%%', '~', or a non-printable char.
	Float64Array1DColumn(name string, values []float64) LineSender

	// Float64Array2DColumn adds a 2D array of 64-bit floats (double 2D array) to the ILP message.
	//
	// The values parameter must have a regular (rectangular) shape - all rows must have
	// exactly the same length. If the array has irregular shape, this method returns an error.
	//
	// Example of valid input:
	//   values := [][]float64{{1.0, 2.0}, {3.0, 4.0}, {5.0, 6.0}}  // 3x2 regular shape
	//
	// Example of invalid input:
	//   values := [][]float64{{1.0, 2.0}, {3.0}, {4.0, 5.0, 6.0}}   // irregular shape - returns error
	//
	// Column name cannot contain any of the following characters:
	// '\n', '\r', '?', '.', ',', "', '"', '\', '/', ':', ')', '(', '+',
	// '-', '*' '%%', '~', or a non-printable char.
	Float64Array2DColumn(name string, values [][]float64) LineSender

	// Float64Array3DColumn adds a 3D array of 64-bit floats (double 3D array) to the ILP message.
	//
	// The values parameter must have a regular (cuboid) shape - all dimensions must have
	// consistent sizes throughout. If the array has irregular shape, this method returns an error.
	//
	// Example of valid input:
	//   values := [][][]float64{
	//     {{1.0, 2.0}, {3.0, 4.0}},    // 2x2 matrix
	//     {{5.0, 6.0}, {7.0, 8.0}},    // 2x2 matrix (same shape)
	//   }  // 2x2x2 regular shape
	//
	// Example of invalid input:
	//   values := [][][]float64{
	//     {{1.0, 2.0}, {3.0, 4.0}},    // 2x2 matrix
	//     {{5.0}, {6.0, 7.0, 8.0}},    // irregular matrix - returns error
	//   }
	//
	// Column name cannot contain any of the following characters:
	// '\n', '\r', '?', '.', ',', "', '"', '\', '/', ':', ')', '(', '+',
	// '-', '*' '%%', '~', or a non-printable char.
	Float64Array3DColumn(name string, values [][][]float64) LineSender

	// Float64ArrayNDColumn adds an n-dimensional array of 64-bit floats (double n-D array) to the ILP message.
	//
	// Example usage:
	//   // Create a 2x3x4 array
	//   arr, _ := questdb.NewNDArray[float64](2, 3, 4)
	//   arr.Fill(1.5)
	//   sender.Float64ArrayNDColumn("ndarray_col", arr)
	//
	// Column name cannot contain any of the following characters:
	// '\n', '\r', '?', '.', ',', "', '"', '\', '/', ':', ')', '(', '+',
	// '-', '*' '%%', '~', or a non-printable char.
	Float64ArrayNDColumn(name string, values *NdArray[float64]) LineSender

	// At sets the designated timestamp value and finalizes the ILP
	// message.
	//
	// If the underlying buffer reaches configured capacity or the
	// number of buffered messages exceeds the auto-flush trigger, this
	// method also sends the accumulated messages.
	//
	// If ts.IsZero(), no timestamp is sent to the server.
	At(ctx context.Context, ts time.Time) error

	// AtNow omits designated timestamp value and finalizes the ILP
	// message. The server will insert each message using the system
	// clock as the row timestamp.
	//
	// If the underlying buffer reaches configured capacity or the
	// number of buffered messages exceeds the auto-flush trigger, this
	// method also sends the accumulated messages.
	AtNow(ctx context.Context) error

	// Flush sends the accumulated messages via the underlying
	// connection. Should be called periodically to make sure that
	// all messages are sent to the server.
	//
	// For optimal performance, this method should not be called after
	// each ILP message. Instead, the messages should be written in
	// batches followed by a Flush call. The optimal batch size may
	// vary from one thousand to few thousand messages depending on
	// the message size.
	Flush(ctx context.Context) error

	// Close closes the underlying HTTP client.
	//
	// If auto-flush is enabled, the client will flush any remaining buffered
	// messages before closing itself.
	Close(ctx context.Context) error
}

type LineSenderOption func(*lineSenderConfig)

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

type LineSenderPoolOption func(*LineSenderPool)

type NdArray[T NdArrayElementType] struct {
	// contains filtered or unexported fields
}

type NdArrayElementType interface {
	~float64
}

type QwpError struct {
	// Status is the status code from the ACK response.
	Status qwpStatusCode

	// Sequence is the cumulative sequence number from the ACK, used
	// to correlate responses with requests in async mode.
	Sequence int64

	// Message is the server's error description, or empty if
	// no error message was included in the response.
	Message string
}

type QwpSender interface {
	LineSender

	// ByteColumn adds a BYTE (int8) column value.
	ByteColumn(name string, val int8) QwpSender

	// ShortColumn adds a SHORT (int16) column value.
	ShortColumn(name string, val int16) QwpSender

	// Int32Column adds an INT (int32) column value.
	Int32Column(name string, val int32) QwpSender

	// Float32Column adds a FLOAT (float32) column value.
	Float32Column(name string, val float32) QwpSender

	// CharColumn adds a CHAR column value stored as a UTF-16 code unit.
	CharColumn(name string, val rune) QwpSender

	// DateColumn adds a DATE column value (milliseconds since epoch).
	DateColumn(name string, val time.Time) QwpSender

	// TimestampNanosColumn adds a TIMESTAMP column value (nanoseconds since epoch).
	TimestampNanosColumn(name string, val time.Time) QwpSender

	// UuidColumn adds a UUID column value from high and low 64-bit parts.
	UuidColumn(name string, hi, lo uint64) QwpSender

	// GeohashColumn adds a GEOHASH column value with the given bit precision.
	GeohashColumn(name string, hash uint64, precision int) QwpSender

	// Int64Array1DColumn adds a 1-dimensional LONG array column.
	Int64Array1DColumn(name string, values []int64) QwpSender

	// Int64Array2DColumn adds a 2-dimensional LONG array column.
	Int64Array2DColumn(name string, values [][]int64) QwpSender

	// Int64Array3DColumn adds a 3-dimensional LONG array column.
	Int64Array3DColumn(name string, values [][][]int64) QwpSender

	// Decimal64Column adds a DECIMAL64 column value (8 bytes on the wire,
	// 18 digits of precision). Returns an error on the next At/AtNow/Flush
	// if the value's unscaled coefficient does not fit in 64 bits.
	Decimal64Column(name string, val Decimal) QwpSender

	// Decimal128Column adds a DECIMAL128 column value (16 bytes on the wire,
	// 38 digits of precision). Returns an error on the next At/AtNow/Flush
	// if the value's unscaled coefficient does not fit in 128 bits.
	Decimal128Column(name string, val Decimal) QwpSender

	// Decimal256Column adds a DECIMAL256 column value (32 bytes on the wire,
	// 77 digits of precision). Equivalent to DecimalColumn.
	Decimal256Column(name string, val Decimal) QwpSender

	// AtNano closes the current row with a nanosecond-resolution
	// designated timestamp (TYPE_TIMESTAMP_NANO on the wire). It is
	// the nanosecond counterpart of LineSender.At, which uses
	// microseconds.
	//
	// A table's designated timestamp resolution is fixed by its first
	// row: mixing At and AtNano on rows of the same table within one
	// flush returns a type-conflict error.
	AtNano(ctx context.Context, ts time.Time) error
}

type RetryTimeoutError struct {
	LastErr error
	Timeout time.Duration
}

type ShopspringDecimal interface {
	Coefficient() *big.Int
	Exponent() int32
}