timeseries

type ArchiveResult struct {
	RowsArchived   int64  `json:"rowsArchived"`
	BytesWritten   int64  `json:"bytesWritten"`
	Destination    string `json:"destination"`
	DeletedFromHot bool   `json:"deletedFromHot"`
}

type ClickHouseConfig struct {
	Endpoints    []string      `json:"endpoints"    yaml:"endpoints"`
	Database     string        `json:"database"     yaml:"database"`
	Username     string        `json:"username"     yaml:"username"`
	Password     string        `json:"password"     yaml:"password"`
	MaxOpenConns int           `json:"maxOpenConns" yaml:"maxOpenConns"`
	MaxIdleConns int           `json:"maxIdleConns" yaml:"maxIdleConns"`
	Compression  string        `json:"compression"  yaml:"compression"`
	Secure       bool          `json:"secure"       yaml:"secure"`
	DialTimeout  time.Duration `json:"dialTimeout"  yaml:"dialTimeout"`
}

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

type CompactionConfig struct {
	TargetCompactionSizeBytes int64  `json:"targetCompactionSizeBytes,omitempty" yaml:"targetCompactionSizeBytes,omitempty"`
	SkipOffsetFromLatest      string `json:"skipOffsetFromLatest,omitempty"      yaml:"skipOffsetFromLatest,omitempty"`
}

type CompactionStatus struct {
	DataSource string `json:"dataSource"`
	State      string `json:"state"`
}

type DatasourceInfo struct {
	Name       string         `json:"name"`
	Properties map[string]any `json:"properties,omitempty"`
}

type DruidClient interface {
	GetStatus(ctx context.Context) (*DruidStatus, error)
	SQLQuery(ctx context.Context, query string, params []any) (*QueryResult, error)
	NativeQuery(ctx context.Context, query map[string]any) (*QueryResult, error)
	SubmitSupervisor(ctx context.Context, spec map[string]any) (*SupervisorStatus, error)
	GetSupervisorStatus(ctx context.Context, id string) (*SupervisorStatus, error)
	SuspendSupervisor(ctx context.Context, id string) error
	ResumeSupervisor(ctx context.Context, id string) error
	TerminateSupervisor(ctx context.Context, id string) error
	ListDatasources(ctx context.Context) ([]string, error)
	GetDatasource(ctx context.Context, name string) (*DatasourceInfo, error)
	DisableDatasource(ctx context.Context, name string) error
	SubmitCompaction(ctx context.Context, datasource string, config CompactionConfig) error
	GetCompactionStatus(ctx context.Context, datasource string) (*CompactionStatus, error)
}

type DruidConfig struct {
	RouterURL   string        `json:"routerUrl"    yaml:"routerUrl"`
	Username    string        `json:"username"     yaml:"username"`
	Password    string        `json:"password"     yaml:"password"`
	HTTPTimeout time.Duration `json:"httpTimeout"  yaml:"httpTimeout"`
}

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

type DruidStatus struct {
	Version string `json:"version"`
	Loading bool   `json:"loading"`
}

type HypertableConfig struct {
	Table         string `json:"table"         yaml:"table"`
	TimeColumn    string `json:"timeColumn"    yaml:"timeColumn"`
	ChunkInterval string `json:"chunkInterval" yaml:"chunkInterval"`
}

type InfluxConfig struct {
	URL           string        `json:"url"           yaml:"url"`
	Token         string        `json:"token"         yaml:"token"`
	Org           string        `json:"org"           yaml:"org"`
	Bucket        string        `json:"bucket"        yaml:"bucket"`
	BatchSize     uint          `json:"batchSize"     yaml:"batchSize"`
	FlushInterval time.Duration `json:"flushInterval" yaml:"flushInterval"`
	Precision     string        `json:"precision"     yaml:"precision"`
}

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

type Point struct {
	Measurement string            `json:"measurement" yaml:"measurement"`
	Tags        map[string]string `json:"tags"        yaml:"tags"`
	Fields      map[string]any    `json:"fields"      yaml:"fields"`
	Timestamp   time.Time         `json:"timestamp"   yaml:"timestamp"`
}

type QueryResult struct {
	Rows []map[string]any
}

type QuestDBConfig struct {
	ILPEndpoint   string        `json:"ilpEndpoint"   yaml:"ilpEndpoint"`
	HTTPEndpoint  string        `json:"httpEndpoint"  yaml:"httpEndpoint"`
	AuthToken     string        `json:"authToken"     yaml:"authToken"`
	TLSEnabled    bool          `json:"tlsEnabled"    yaml:"tlsEnabled"`
	AutoFlush     bool          `json:"autoFlush"     yaml:"autoFlush"`
	FlushInterval time.Duration `json:"flushInterval" yaml:"flushInterval"`
}

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

type SenderFactory func(ctx context.Context, cfg QuestDBConfig) (qdb.LineSender, error)

type SupervisorStatus struct {
	ID      string `json:"id"`
	State   string `json:"state"`
	Healthy bool   `json:"healthy"`
}

type TierManager interface {
	Archive(ctx context.Context, olderThan time.Duration, dest, format string, deleteAfter bool) (*ArchiveResult, error)
	Status(ctx context.Context, measurement string) (*TierStatus, error)
}

type TierStatus struct {
	HotRows             int64      `json:"hotRows"`
	HotOldestTimestamp  *time.Time `json:"hotOldestTimestamp,omitempty"`
	ColdFiles           int        `json:"coldFiles"`
	ColdOldestTimestamp *time.Time `json:"coldOldestTimestamp,omitempty"`
	TotalBytes          int64      `json:"totalBytes"`
}

type TimeSeriesWriter interface {
	WritePoint(ctx context.Context, measurement string, tags map[string]string, fields map[string]any, timestamp time.Time) error
	WriteBatch(ctx context.Context, points []Point) error
	Query(ctx context.Context, query string, args ...any) ([]map[string]any, error)
}

type TimescaleConfig struct {
	Connection   string             `json:"connection"    yaml:"connection"`
	MaxOpenConns int                `json:"maxOpenConns"  yaml:"maxOpenConns"`
	MaxIdleConns int                `json:"maxIdleConns"  yaml:"maxIdleConns"`
	Hypertables  []HypertableConfig `json:"hypertables"   yaml:"hypertables"`
}

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