pkg

type Checkpoint struct {
	Version    int64
	Timestamp  time.Time
	FileCount  int64
	FilePaths  []string
	Schema     map[string]string
	Partitions []string
}

type ColumnStats struct {
	NullCount     int64
	DistinctCount int64
	MinValue      interface{}
	MaxValue      interface{}
	AvgValue      float64
}

type Config struct {
	Server     ServerConfig     `mapstructure:"server"`
	Extensions ExtensionsConfig `mapstructure:"extensions"`
	Telemetry  TelemetryConfig  `mapstructure:"telemetry"`
}

type DeltaTable struct {
	Path            string
	Version         int64
	LastModified    time.Time
	PartitionSchema []string
	Schema          map[string]string
	Stats           *TableStats
	LogFiles        []string
	Checkpoint      *Checkpoint
}

type Extension struct {
	Name        string
	Version     string
	Description string
}

type ExtensionsConfig struct {
	Enabled []string `mapstructure:"enabled"`
	Path    string   `mapstructure:"path"`
}

type ProfileStats struct {
	ColumnName    string
	DataType      string
	TotalCount    int64
	NullCount     int64
	DistinctCount int64
	MinValue      interface{}
	MaxValue      interface{}
	AvgValue      float64
	Histogram     map[string]int64
}

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

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

type Server struct {
	Port int
	Host string
}

type ServerConfig struct {
	Host string `mapstructure:"host"`
	Port int    `mapstructure:"port"`
}

type TableProfile struct {
	TablePath     string
	TotalRows     int64
	TotalColumns  int
	LastModified  time.Time
	ColumnStats   map[string]*ProfileStats
	TableSize     int64
	PartitionInfo map[string]string
}

type TableStats struct {
	NumFiles        int64
	NumRecords      int64
	TotalSize       int64
	PartitionCounts map[string]int64
	ColumnStats     map[string]*ColumnStats
}

type TelemetryConfig struct {
	Enabled  bool   `mapstructure:"enabled"`
	Endpoint string `mapstructure:"endpoint"`
}

type TelemetryEvent struct {
	Timestamp time.Time `json:"timestamp"`
	Command   string    `json:"command"`
	Args      []string  `json:"args"`
	Success   bool      `json:"success"`
	Error     string    `json:"error,omitempty"`
	Version   string    `json:"version"`
}

type TelemetryManager struct {
	Enabled  bool
	Endpoint string
}