nastra commented on code in PR #58:
URL: https://github.com/apache/iceberg-go/pull/58#discussion_r1489129979
##########
catalog/catalog.go:
##########
@@ -37,29 +40,148 @@ const (
var (
// ErrNoSuchTable is returned when a table does not exist in the
catalog.
- ErrNoSuchTable = errors.New("table does not exist")
+ ErrNoSuchTable = errors.New("table does not exist")
+ ErrNoSuchNamespace = errors.New("namespace does not exist")
+ ErrNamespaceAlreadyExists = errors.New("namespace already exists")
)
// WithAwsConfig sets the AWS configuration for the catalog.
-func WithAwsConfig(cfg aws.Config) Option {
+func WithAwsConfig(cfg aws.Config) Option[GlueCatalog] {
return func(o *options) {
o.awsConfig = cfg
}
}
-type Option func(*options)
+func WithCredential(cred string) Option[RestCatalog] {
+ return func(o *options) {
+ o.credential = cred
+ }
+}
+
+func WithOAuthToken(token string) Option[RestCatalog] {
+ return func(o *options) {
+ o.oauthToken = token
+ }
+}
+
+func WithTLSConfig(config *tls.Config) Option[RestCatalog] {
+ return func(o *options) {
+ o.tlsConfig = config
+ }
+}
+
+func WithWarehouseLocation(loc string) Option[RestCatalog] {
+ return func(o *options) {
+ o.warehouseLocation = loc
+ }
+}
+
+func WithMetadataLocation(loc string) Option[RestCatalog] {
+ return func(o *options) {
+ o.metadataLocation = loc
+ }
+}
+
+func WithSigV4() Option[RestCatalog] {
+ return func(o *options) {
+ o.enableSigv4 = true
+ o.sigv4Service = "execute-api"
+ }
+}
+
+func WithSigV4RegionSvc(region, service string) Option[RestCatalog] {
+ return func(o *options) {
+ o.enableSigv4 = true
+ o.sigv4Region = region
+
+ if service == "" {
+ o.sigv4Service = "execute-api"
+ } else {
+ o.sigv4Service = service
+ }
+ }
+}
+
+func WithAuthURI(uri *url.URL) Option[RestCatalog] {
+ return func(o *options) {
+ o.authUri = uri
+ }
+}
+
+func WithPrefix(prefix string) Option[RestCatalog] {
+ return func(o *options) {
+ o.prefix = prefix
+ }
+}
+
+type Option[T GlueCatalog | RestCatalog] func(*options)
type options struct {
awsConfig aws.Config
+
+ tlsConfig *tls.Config
+ credential string
+ oauthToken string
+ warehouseLocation string
+ metadataLocation string
+ enableSigv4 bool
+ sigv4Region string
+ sigv4Service string
+ prefix string
+ authUri *url.URL
+}
+
+type PropertiesUpdateSummary struct {
+ Removed []string `json:"removed"`
+ Updated []string `json:"updated"`
+ Missing []string `json:"missing"`
}
// Catalog for iceberg table operations like create, drop, load, list and
others.
type Catalog interface {
+ // CatalogType returns the type of the catalog.
+ CatalogType() CatalogType
+
// ListTables returns a list of table identifiers in the catalog, with
the returned
// identifiers containing the information required to load the table
via that catalog.
ListTables(ctx context.Context, namespace table.Identifier)
([]table.Identifier, error)
// LoadTable loads a table from the catalog and returns a Table with
the metadata.
- LoadTable(ctx context.Context, identifier table.Identifier, props
map[string]string) (*table.Table, error)
- // CatalogType returns the type of the catalog.
- CatalogType() CatalogType
+ LoadTable(ctx context.Context, identifier table.Identifier, props
iceberg.Properties) (*table.Table, error)
+ // DropTable tells the catalog to drop the table entirely
+ DropTable(ctx context.Context, identifier table.Identifier) error
+ // RenameTable tells the catalog to rename a given table by the
identifiers
+ // provided, and then loads and returns the destination table
+ RenameTable(ctx context.Context, from, to table.Identifier)
(*table.Table, error)
+ // ListNamespaces returns the list of available namespaces, optionally
filtering by a
+ // parent namespace
+ ListNamespaces(ctx context.Context, parent table.Identifier)
([]table.Identifier, error)
+ // CreateNamespace tells the catalog to create a new namespace with the
given properties
+ CreateNamespace(ctx context.Context, namespace table.Identifier, props
iceberg.Properties) error
+ // DropNamespace tells the catalog to drop the namespace and all tables
in that namespace
+ DropNamespace(ctx context.Context, namespace table.Identifier) error
+ // LoadNamespaceProperties returns the current properties in the
catalog for
+ // a given namespace
+ LoadNamespaceProperties(ctx context.Context, namespace
table.Identifier) (iceberg.Properties, error)
+ // UpdateNamespaceProperties allows removing, adding, and/or updating
properties of a namespace
+ UpdateNamespaceProperties(ctx context.Context, namespace
table.Identifier,
+ removals []string, updates iceberg.Properties)
(PropertiesUpdateSummary, error)
+}
+
+const (
+ keyToken = "token"
Review Comment:
nit: I would probably rename this to `keyOauthToken` and `keyCredential` to
`keyOAuthCredential` to make it clearer that these are for OAuth. No need to
update in this PR, so feel free to update this in the next one
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
