driver

type ConNode struct {
	NodeName *string // Node name for exact match
	NodeID   *string // Node ID for exact match
}

type ConTimeRange struct {
	StartAt *uint64 // Start timestamp in UNIX format (inclusive, closed interval)
	EndAt   *uint64 // End timestamp in UNIX format (inclusive, closed interval)
}

type ConValRange struct {
	Key      string   // Target key name for filtering
	StartVal *float64 // Minimum value pointer (inclusive, nil means no lower bound)
	EndVal   *float64 // Maximum value pointer (inclusive, nil means no upper bound)
}

type ConditionOption func(driver *QueryCondition)

type IDriver interface {
	GetDriverName() string
	// SetTableName Set write/reader table name
	SetTableName(tableName string)
	// GetNewDriver Get a new writer/reader driver
	GetNewDriver(tableName string) IDriver
	// CreateColumnsWithType Create columns with type: key is column name, value is column type
	CreateColumnsWithType(map[string]string) error
	// SetBatchWriteTxnSize Set batch write transaction size: it should be 1<= size <=100.(default is 1)
	//  if size = 0,it will return currentSize,nil
	//  if size > 100,or size < 1,it will return 0,and error
	SetBatchWriteTxnSize(size int) (int, error)
	// Migrate auto migrate table
	Migrate(map[string]string) error
	IWriter
	IReader
}

type IReader interface {
	GetData(conditions ...ConditionOption) map[string][]any
}

type IWriter interface {
	// Insert insert data: key is column name, value is column value
	Insert(map[string]any) error
	// Writer will auto conversion data []byte to json-key-value, and write to table.
	io.Writer
}

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

type QueryCondition struct {
	*ConTimeRange               // Embedded time range condition (optional)
	*ConNode                    // Embedded node condition (optional)
	ValRange      []ConValRange // Slice of value range conditions
}

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