db

type AggregateInfo struct {
	Name          string
	ArgumentTypes []string
	StateFunc     string
	StateType     string
	FinalFunc     string
	InitCond      string
	ReturnType    string
}

type AggregateListInfo struct {
	Name          string
	ArgumentTypes []string
	StateType     string
	ReturnType    string
}

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

type CQLTypeHandler struct {
	// Configuration options
	TimeFormat      string // Format for time display (default RFC3339)
	HexPrefix       string // Prefix for hex values (default "0x")
	NullString      string // String to display for null values (default "null")
	CollectionLimit int    // Max items to display in collections (0 = unlimited)
	TruncateStrings int    // Max length for strings (0 = no truncation)
}

type CQLTypeInfo struct {
	BaseType   string         // "text", "int", "list", "map", "udt", etc.
	Frozen     bool           // Whether the type is frozen
	Parameters []*CQLTypeInfo // For collections/tuples - element types
	UDTName    string         // For UDT types - the name of the UDT
	Keyspace   string         // For UDT types - optional keyspace qualifier
}

type CachedTableInfo struct {
	TableInfo
	RowCount    int64 // Optional: cached approximate count
	LastUpdated time.Time
}

type ClusterInfo struct {
	ClusterName string
	Partitioner string
	Version     string
}

type ColumnInfo struct {
	Name     string
	DataType string
	Kind     string
	Position int
}

type ColumnSchema struct {
	Name     string
	Type     string
	Kind     string // 'partition_key', 'clustering', 'regular', 'static'
	Position int    // Position for partition/clustering keys
}

type FunctionDetails struct {
	Name          string
	ArgumentTypes []string
	ArgumentNames []string
	ReturnType    string
	Language      string
	Body          string
	CalledOnNull  bool
}

type IndexInfo struct {
	TableName string
	IndexName string
	Kind      string
	Options   map[string]string
}

type KeyColumnInfo struct {
	Kind     string // "partition_key" or "clustering"
	Position int
}

type KeyspaceInfo struct {
	Name          string
	DurableWrites bool
	Replication   map[string]string
}

type KeyspaceListInfo struct {
	Name        string
	Replication map[string]string
}

type KeyspaceSchema struct {
	Name   string
	Tables map[string]*TableSchema
}

type MaterializedViewInfo struct {
	Name                    string
	BaseTable               string
	WhereClause             string
	BloomFilterFpChance     float64
	Caching                 string
	Comment                 string
	Compaction              map[string]string
	Compression             map[string]string
	CrcCheckChance          float64
	DclocalReadRepairChance float64
	DefaultTTL              int
	GcGrace                 int
	MaxIndexInterval        int
	MemtableFlushPeriod     int
	MinIndexInterval        int
	ReadRepairChance        float64
	SpeculativeRetry        string
	PartitionKeys           []string
	ClusteringKeys          []string
}

type PermissionInfo struct {
	Role        string
	Resource    string
	Permissions []string
}

type QueryResult struct {
	Data            [][]string               // Formatted strings for display
	RawData         []map[string]interface{} // Raw values for JSON export (preserves types)
	Duration        time.Duration
	RowCount        int
	ColumnTypes     []string         // Data types of each column
	ColumnTypeInfos []gocql.TypeInfo // TypeInfo objects for each column (for UDT support)
	Headers         []string         // Column names without PK/C indicators
}

type RawBytes []byte

type RoleInfo struct {
	Role        string
	CanLogin    bool
	IsSuperuser bool
	MemberOf    []string
	SaltedHash  string
}

type SchemaCache struct {
	Keyspaces   []string
	Tables      map[string][]CachedTableInfo       // keyspace -> tables
	Columns     map[string]map[string][]ColumnInfo // keyspace -> table -> columns
	SearchIndex *SearchIndex                       // Pre-computed fuzzy search index
	LastRefresh time.Time
	Mu          sync.RWMutex
	// contains filtered or unexported fields
}

type SchemaCatalog struct {
	Keyspaces map[string]*KeyspaceSchema
}

type SearchIndex struct {
	TableTokens map[string][]string // table -> tokens for fuzzy matching
}

type Session struct {
	*gocql.Session
	// contains filtered or unexported fields
}

type SessionOptions struct {
	Host           string
	Port           int
	Keyspace       string
	Username       string
	Password       string
	Consistency    string // Default consistency level (e.g., "LOCAL_ONE", "QUORUM")
	SSL            *config.SSLConfig
	BatchMode      bool   // Skip schema caching for batch mode
	ConnectTimeout int    // Connection timeout in seconds (0 = use default)
	RequestTimeout int    // Request timeout in seconds (0 = use default)
	ConfigFile     string // Path to custom config file
}

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

type StreamingQueryResult struct {
	Headers         []string         // Column headers (with PK/C indicators)
	ColumnNames     []string         // Original column names (for data lookup)
	ColumnTypes     []string         // Data types of each column
	ColumnTypeInfos []gocql.TypeInfo // TypeInfo objects for each column (for UDT support)
	Iterator        *gocql.Iter      // Iterator for fetching more rows
	StartTime       time.Time        // Query start time for duration calculation
	Keyspace        string           // Keyspace extracted from query or session
}

type StreamingResult struct {
	Headers     []string
	Rows        [][]string
	HasMore     bool
	LoadMore    func(ctx context.Context, count int) ([][]string, bool, error)
	Close       func() error
	ElapsedTime time.Duration
}

type TableInfo struct {
	KeyspaceName   string
	TableName      string
	TableProps     map[string]interface{}
	Columns        []ColumnInfo
	PartitionKeys  []string
	ClusteringKeys []string
}

type TableListInfo struct {
	Name           string
	GcGrace        int
	Compaction     map[string]string
	Compression    map[string]string
	PartitionKeys  []string
	ClusteringKeys []string
}

type TableSchema struct {
	Keyspace       string
	TableName      string
	Columns        []ColumnSchema
	PartitionKeys  []string
	ClusteringKeys []string
}

type TraceInfo struct {
	Coordinator string
	Duration    int
}

type TypeInfo struct {
	Name       string
	FieldNames []string
	FieldTypes []string
}

type TypeListInfo struct {
	Name string
}

type UDTDefinition struct {
	Keyspace string
	Name     string
	Fields   []UDTField
}

type UDTField struct {
	Name     string
	TypeStr  string
	TypeInfo *CQLTypeInfo // Parsed type information
}

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