s3tables

type BucketReplicationConfig struct {
	TableBucketARN string            `json:"-"`
	Role           string            `json:"role"`
	VersionToken   string            `json:"versionToken"`
	Rules          []ReplicationRule `json:"rules"`
}

type CreateTableBucketOptions struct {
	Encryption   map[string]any
	Tags         map[string]string
	StorageClass string
}

type CreateTableOptions struct {
	Encryption   map[string]any
	Metadata     map[string]any
	Tags         map[string]string
	StorageClass string
}

type Handler struct {
	Backend   *InMemoryBackend
	AccountID string
	Region    string
	// contains filtered or unexported fields
}

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

type ListNamespacesParams struct {
	Prefix            string
	ContinuationToken string
	MaxNamespaces     int
}

type ListTableBucketsParams struct {
	Prefix            string
	Type              string
	ContinuationToken string
	MaxBuckets        int
}

type ListTablesParams struct {
	Prefix            string
	ContinuationToken string
	MaxTables         int
}

type MetadataWriter interface {
	WriteWarehouseObject(ctx context.Context, region, bucket, key string, body []byte) error
}

type Namespace struct {
	CreatedAt      time.Time `json:"createdAt"`
	TableBucketARN string    `json:"tableBucketARN"`
	OwnerAccountID string    `json:"ownerAccountID"`
	CreatedBy      string    `json:"createdBy"`
	Policy         string    `json:"policy"`
	NamespaceID    string    `json:"namespaceID"`
	// TableBucketID is the owning bucket's system-assigned ID (TableBucket.BucketID
	// at CreateNamespace time), the real GetNamespaceOutput/NamespaceSummary
	// "tableBucketId" member -- GetNamespaceOutput has no tableBucketARN
	// member at all (gopherstack-wla0).
	TableBucketID string   `json:"tableBucketID"`
	Namespace     []string `json:"namespace"`
}

type Provider struct{}

type ReplicationDestination struct {
	DestinationTableBucketARN string `json:"destinationTableBucketARN"`
}

type ReplicationRule struct {
	Destinations []ReplicationDestination `json:"destinations"`
}

type StorageBackend interface {
	// TableBucket operations
	TableBucketARN(name string) string
	TableARN(bucketName, namespaceName, tableName string) string
	Region() string
	AccountID() string
	CreateTableBucket(name string, opts CreateTableBucketOptions) (*TableBucket, error)
	GetTableBucket(bucketARN string) (*TableBucket, error)
	DeleteTableBucket(bucketARN string) error
	ListTableBuckets(p ListTableBucketsParams) (page.Page[*TableBucket], error)
	GetTableBucketMaintenanceConfiguration(bucketARN string) (map[string]any, error)
	PutTableBucketMaintenanceConfiguration(bucketARN, maintenanceType string, value map[string]any) error
	GetTableBucketPolicy(bucketARN string) (string, error)
	PutTableBucketPolicy(bucketARN, policy string) error
	DeleteTableBucketPolicy(bucketARN string) error

	DeleteTableBucketEncryption(bucketARN string) error

	// BucketReplication operations
	PutTableBucketReplication(
		bucketARN, role string,
		rules []ReplicationRule,
		expectedVersionToken string,
	) (*BucketReplicationConfig, error)
	GetTableBucketReplication(bucketARN string) (*BucketReplicationConfig, error)
	DeleteTableBucketReplication(bucketARN, expectedVersionToken string) error

	// TableReplication operations
	PutTableReplication(
		tableArn, role string,
		rules []ReplicationRule,
		expectedVersionToken string,
	) (*TableReplicationConfig, error)
	GetTableReplicationConfig(tableArn string) (*TableReplicationConfig, error)
	DeleteTableReplication(tableArn, versionToken string) error

	// TableRecordExpiry operations
	PutTableRecordExpirationConfiguration(tableArn string, cfg *TableRecordExpiryConfig) error
	GetTableRecordExpirationConfiguration(tableArn string) (*TableRecordExpiryConfig, error)

	// Namespace operations
	CreateNamespace(tableBucketARN string, namespace []string) (*Namespace, error)
	GetNamespace(tableBucketARN string, namespace []string) (*Namespace, error)
	DeleteNamespace(tableBucketARN string, namespace []string) error
	ListNamespaces(tableBucketARN string, p ListNamespacesParams) (page.Page[*Namespace], error)

	// Table operations
	CreateTable(tableBucketARN string, namespace []string, name, format string, opts CreateTableOptions) (*Table, error)
	GetTable(tableBucketARN string, namespace []string, name string) (*Table, error)
	GetTableByARN(tableArn string) (*Table, error)
	GetTableEncryption(tableBucketARN string, namespace []string, name string) (map[string]any, error)
	DeleteTable(tableBucketARN string, namespace []string, name, versionToken string) error
	ListTables(tableBucketARN, namespace string, p ListTablesParams) (page.Page[*Table], error)
	RenameTable(tableBucketARN string, namespace []string, name, newNamespace, newName, versionToken string) error
	UpdateTableMetadataLocation(
		tableBucketARN string,
		namespace []string,
		name, metadataLocation, versionToken string,
	) (*Table, error)
	GetTableMaintenanceConfiguration(
		tableBucketARN string,
		namespace []string,
		name string,
	) (map[string]any, string, error)
	PutTableMaintenanceConfiguration(
		tableBucketARN string,
		namespace []string,
		name, maintenanceType string,
		value map[string]any,
	) error
	GetTablePolicy(tableBucketARN string, namespace []string, name string) (string, error)
	PutTablePolicy(tableBucketARN string, namespace []string, name, policy string) error
	DeleteTablePolicy(tableBucketARN string, namespace []string, name string) error

	// Lifecycle
	Reset()
	Snapshot(ctx context.Context) []byte
	Restore(ctx context.Context, data []byte) error
}

type Table struct {
	CreatedAt                time.Time      `json:"createdAt"`
	ModifiedAt               time.Time      `json:"modifiedAt"`
	MaintenanceConfiguration map[string]any `json:"maintenanceConfiguration"`
	// Encryption is the table-level encryption override set at CreateTable
	// time. When nil, the table has no override and GetTableEncryption
	// falls back to the owning bucket's configuration, then to the AWS
	// default (SSE-S3/AES256) -- see GetTableEncryption. There is no
	// separate PutTableEncryption SDK operation; this can only be set at
	// creation.
	Encryption map[string]any `json:"encryption"`
	// Metadata is the Iceberg metadata supplied at CreateTable time (schema, partition spec,
	// write order, properties).
	Metadata       map[string]any `json:"metadata,omitempty"`
	TableBucketARN string         `json:"tableBucketARN"`
	// TableBucketID is the owning bucket's system-assigned ID (TableBucket.BucketID
	// at CreateTable time), the real GetTableOutput/TableSummary "tableBucketId"
	// member -- neither shape has a tableBucketARN member (gopherstack-wla0).
	TableBucketID     string   `json:"tableBucketID"`
	Format            string   `json:"format"`
	VersionToken      string   `json:"versionToken"`
	MetadataLocation  string   `json:"metadataLocation"`
	WarehouseLocation string   `json:"warehouseLocation"`
	ARN               string   `json:"arn"`
	OwnerAccountID    string   `json:"ownerAccountID"`
	Policy            string   `json:"policy"`
	Name              string   `json:"name"`
	StorageClass      string   `json:"storageClass"`
	Namespace         []string `json:"namespace"`
}

type TableBucket struct {
	CreatedAt                time.Time      `json:"createdAt"`
	MaintenanceConfiguration map[string]any `json:"maintenanceConfiguration"`
	Encryption               map[string]any `json:"encryption"`
	ARN                      string         `json:"arn"`
	Name                     string         `json:"name"`
	OwnerAccountID           string         `json:"ownerAccountID"`
	Policy                   string         `json:"policy"`
	StorageClass             string         `json:"storageClass"`
	// BucketID is the system-assigned unique identifier AWS returns as
	// "tableBucketId" on GetTableBucket/ListTableBuckets and, transitively,
	// on every Namespace/Table nested under this bucket (see
	// Namespace.TableBucketID/Table.TableBucketID) -- distinct from ARN,
	// confirmed via GetTableBucketOutput.TableBucketId in
	// aws-sdk-go-v2/service/s3tables (gopherstack-wla0).
	BucketID string `json:"bucketID"`
	// MetricsConfigurationID is the unique identifier AWS assigns to a table
	// bucket's metrics configuration once PutTableBucketMetricsConfiguration
	// has been called. It is cleared by DeleteTableBucketMetricsConfiguration.
	MetricsConfigurationID string `json:"metricsConfigurationID,omitempty"`
	MetricsEnabled         bool   `json:"metricsEnabled"`
}

type TableRecordExpiryConfig struct {
	Status   string `json:"status"`
	TableARN string `json:"-"`
	Days     int    `json:"days,omitempty"`
}

type TableReplicationConfig struct {
	TableARN     string            `json:"-"`
	Role         string            `json:"role"`
	VersionToken string            `json:"versionToken"`
	Rules        []ReplicationRule `json:"rules"`
}

type TaggedEntry struct {
	Tags map[string]string
	ARN  string
}