lakehouse

type CatalogConfig struct {
	Defaults  map[string]string `json:"defaults"`
	Overrides map[string]string `json:"overrides"`
}

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

type CreateTableRequest struct {
	Name          string            `json:"name"`
	Schema        Schema            `json:"schema"`
	PartitionSpec *PartitionSpec    `json:"partition-spec,omitempty"`
	WriteOrder    *SortOrder        `json:"write-order,omitempty"`
	Properties    map[string]string `json:"properties,omitempty"`
	Location      string            `json:"location,omitempty"`
}

type IcebergCatalogClient interface {
	// GetConfig retrieves catalog-level configuration.
	GetConfig(ctx context.Context) (*CatalogConfig, error)

	// ListNamespaces lists namespaces, optionally filtered by parent.
	ListNamespaces(ctx context.Context, parent string) ([]Namespace, error)

	// CreateNamespace creates a new namespace with optional properties.
	CreateNamespace(ctx context.Context, ns Namespace, properties map[string]string) error

	// LoadNamespace retrieves namespace info and properties.
	LoadNamespace(ctx context.Context, ns Namespace) (*NamespaceInfo, error)

	// DropNamespace removes a namespace.
	DropNamespace(ctx context.Context, ns Namespace) error

	// UpdateNamespaceProperties sets or removes namespace properties.
	UpdateNamespaceProperties(ctx context.Context, ns Namespace, updates, removals map[string]string) error

	// ListTables lists all tables within a namespace.
	ListTables(ctx context.Context, ns Namespace) ([]TableIdentifier, error)

	// CreateTable creates a new table in the given namespace.
	CreateTable(ctx context.Context, ns Namespace, req CreateTableRequest) (*TableMetadata, error)

	// LoadTable retrieves table metadata by identifier.
	LoadTable(ctx context.Context, id TableIdentifier) (*TableMetadata, error)

	// UpdateTable applies schema or metadata updates to a table.
	UpdateTable(ctx context.Context, id TableIdentifier, updates []TableUpdate, requirements []TableRequirement) (*TableMetadata, error)

	// DropTable removes a table; if purge is true, data files are also deleted.
	DropTable(ctx context.Context, id TableIdentifier, purge bool) error

	// TableExists returns true if the table exists.
	TableExists(ctx context.Context, id TableIdentifier) (bool, error)

	// ListSnapshots returns all snapshots for a table.
	ListSnapshots(ctx context.Context, id TableIdentifier) ([]Snapshot, error)
}

type IcebergClientConfig struct {
	// Endpoint is the base URL of the REST catalog (e.g. "https://catalog.example.com/v1").
	Endpoint string `json:"endpoint" yaml:"endpoint"`
	// Token is a static Bearer token for authentication.
	Token string `json:"credential" yaml:"credential"`
	// HTTPTimeout is the HTTP client timeout (default 30s).
	HTTPTimeout time.Duration `json:"httpTimeout" yaml:"httpTimeout"`
}

type Namespace []string

type NamespaceInfo struct {
	Namespace  Namespace         `json:"namespace"`
	Properties map[string]string `json:"properties"`
}

type PartitionField struct {
	SourceID  int    `json:"source-id"`
	FieldID   int    `json:"field-id"`
	Name      string `json:"name"`
	Transform string `json:"transform"`
}

type PartitionSpec struct {
	SpecID int              `json:"spec-id"`
	Fields []PartitionField `json:"fields"`
}

type Schema struct {
	SchemaID int           `json:"schema-id"`
	Type     string        `json:"type"`
	Fields   []SchemaField `json:"fields"`
}

type SchemaField struct {
	ID       int    `json:"id"`
	Name     string `json:"name"`
	Type     string `json:"type"`
	Required bool   `json:"required"`
	Doc      string `json:"doc,omitempty"`
}

type Snapshot struct {
	SnapshotID   int64             `json:"snapshot-id"`
	Timestamp    int64             `json:"timestamp-ms"`
	Summary      map[string]string `json:"summary"`
	ManifestList string            `json:"manifest-list"`
}

type SortField struct {
	SourceID  int    `json:"source-id"`
	Transform string `json:"transform"`
	Direction string `json:"direction"`
	NullOrder string `json:"null-order"`
}

type SortOrder struct {
	OrderID int         `json:"order-id"`
	Fields  []SortField `json:"fields"`
}

type TableConfig struct {
	Catalog   string            `json:"catalog"    yaml:"catalog"`
	Namespace Namespace         `json:"namespace"  yaml:"namespace"`
	Table     string            `json:"table"      yaml:"table"`
	Schema    TableSchemaConfig `json:"schema"     yaml:"schema"`
}

type TableFieldConfig struct {
	Name     string `json:"name"     yaml:"name"`
	Type     string `json:"type"     yaml:"type"`
	Required bool   `json:"required" yaml:"required"`
	Doc      string `json:"doc"      yaml:"doc"`
}

type TableIdentifier struct {
	Namespace Namespace
	Name      string
}

type TableMetadata struct {
	FormatVersion     int               `json:"format-version"`
	TableUUID         string            `json:"table-uuid"`
	Location          string            `json:"location"`
	CurrentSchemaID   int               `json:"current-schema-id"`
	Schemas           []Schema          `json:"schemas"`
	CurrentSnapshotID *int64            `json:"current-snapshot-id,omitempty"`
	Snapshots         []Snapshot        `json:"snapshots"`
	Properties        map[string]string `json:"properties"`
}

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

type TableRequirement struct {
	Type   string         `json:"type"`
	Fields map[string]any `json:"fields,omitempty"`
}

type TableSchemaConfig struct {
	Fields []TableFieldConfig `json:"fields" yaml:"fields"`
}

type TableUpdate struct {
	Action string         `json:"action"`
	Fields map[string]any `json:"fields,omitempty"`
}