s3tables

type BucketReplicationConfig struct {
	// TableBucketARN is the store.Table primary-key qualifier for the
	// bucketReplication table (see store_setup.go). BucketReplicationConfig
	// carries no identity of its own -- it was previously keyed externally
	// by the map key alone -- so this field was added to give the live
	// store.Table a key to derive. It is tagged json:"-" because it is
	// never part of the S3 Tables wire API (handleGetTableBucketReplication
	// builds its own response map from Destinations only); persistence.go's
	// arnDTO wrapper carries the ARN explicitly for Snapshot/Restore since a
	// plain json.Marshal of this type drops any json:"-" field.
	TableBucketARN string                   `json:"-"`
	Destinations   []ReplicationDestination `json:"destinations"`
}

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

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

type Handler struct {
	Backend   *InMemoryBackend
	AccountID string
	Region    string
}

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 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"`
	Namespace      []string  `json:"namespace"`
}

type Provider struct{}

type ReplicationDestination struct {
	DestinationBucketARN string `json:"destinationBucketARN"`
}

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 string, cfg *BucketReplicationConfig) error
	GetTableBucketReplication(bucketARN string) (*BucketReplicationConfig, error)
	DeleteTableBucketReplication(bucketARN string) error

	// TableReplication operations
	PutTableReplication(tableArn string) error
	DeleteTableReplication(tableArn 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 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"`
	TableBucketARN    string         `json:"tableBucketARN"`
	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"`
	// 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 is the store.Table primary-key qualifier for the
	// tableRecordExpiry table (see store_setup.go) -- see
	// BucketReplicationConfig.TableBucketARN's doc comment for why this
	// field exists and is tagged json:"-".
	TableARN string `json:"-"`
}