Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

lakehouse

package

Go to main page

Versions in this module

v0

v0.3.1

Apr 22, 2026

v0.3.0

Mar 29, 2026

Changes in this version

+ func LakehouseModuleSchemas() []sdk.ModuleSchemaData

+ func NewCatalogModule(name string, config map[string]any) (sdk.ModuleInstance, error)

+ func NewCompactStep(name string, _ map[string]any) (sdk.StepInstance, error)

+ func NewCreateTableStep(name string, _ map[string]any) (sdk.StepInstance, error)

+ func NewEvolveSchemaStep(name string, _ map[string]any) (sdk.StepInstance, error)

+ func NewExpireSnapshotsStep(name string, _ map[string]any) (sdk.StepInstance, error)

+ func NewQueryStep(name string, _ map[string]any) (sdk.StepInstance, error)

+ func NewSnapshotStep(name string, _ map[string]any) (sdk.StepInstance, error)

+ func NewTableModule(name string, config map[string]any) (sdk.ModuleInstance, error)

+ func NewWriteStep(name string, _ map[string]any) (sdk.StepInstance, error)

+ func RegisterCatalog(name string, client IcebergCatalogClient) error

+ func UnregisterCatalog(name string)

+ type CatalogConfig struct

+ Defaults map[string]string

+ Overrides map[string]string

+ type CatalogModule struct

+ func (m *CatalogModule) Client() IcebergCatalogClient

+ func (m *CatalogModule) Init() error

+ func (m *CatalogModule) Start(ctx context.Context) error

+ func (m *CatalogModule) Stop(_ context.Context) error

+ type CreateTableRequest struct

+ Location string

+ Name string

+ PartitionSpec *PartitionSpec

+ Properties map[string]string

+ Schema Schema

+ WriteOrder *SortOrder

+ type IcebergCatalogClient interface

+ CreateNamespace func(ctx context.Context, ns Namespace, properties map[string]string) error

+ CreateTable func(ctx context.Context, ns Namespace, req CreateTableRequest) (*TableMetadata, error)

+ DropNamespace func(ctx context.Context, ns Namespace) error

+ DropTable func(ctx context.Context, id TableIdentifier, purge bool) error

+ GetConfig func(ctx context.Context) (*CatalogConfig, error)

+ ListNamespaces func(ctx context.Context, parent string) ([]Namespace, error)

+ ListSnapshots func(ctx context.Context, id TableIdentifier) ([]Snapshot, error)

+ ListTables func(ctx context.Context, ns Namespace) ([]TableIdentifier, error)

+ LoadNamespace func(ctx context.Context, ns Namespace) (*NamespaceInfo, error)

+ LoadTable func(ctx context.Context, id TableIdentifier) (*TableMetadata, error)

+ TableExists func(ctx context.Context, id TableIdentifier) (bool, error)

+ UpdateNamespaceProperties func(ctx context.Context, ns Namespace, updates, removals map[string]string) error

+ UpdateTable func(ctx context.Context, id TableIdentifier, updates []TableUpdate, ...) (*TableMetadata, error)

+ func LookupCatalog(name string) (IcebergCatalogClient, error)

+ func NewIcebergCatalogClient(cfg IcebergClientConfig) (IcebergCatalogClient, error)

+ type IcebergClientConfig struct

+ Endpoint string

+ HTTPTimeout time.Duration

+ Token string

+ type Namespace []string

+ type NamespaceInfo struct

+ Namespace Namespace

+ Properties map[string]string

+ type PartitionField struct

+ FieldID int

+ Name string

+ SourceID int

+ Transform string

+ type PartitionSpec struct

+ Fields []PartitionField

+ SpecID int

+ type Schema struct

+ Fields []SchemaField

+ SchemaID int

+ Type string

+ type SchemaField struct

+ Doc string

+ ID int

+ Name string

+ Required bool

+ Type string

+ type Snapshot struct

+ ManifestList string

+ SnapshotID int64

+ Summary map[string]string

+ Timestamp int64

+ type SortField struct

+ Direction string

+ NullOrder string

+ SourceID int

+ Transform string

+ type SortOrder struct

+ Fields []SortField

+ OrderID int

+ type TableConfig struct

+ Catalog string

+ Namespace Namespace

+ Schema TableSchemaConfig

+ Table string

+ type TableFieldConfig struct

+ Doc string

+ Name string

+ Required bool

+ Type string

+ type TableIdentifier struct

+ Name string

+ Namespace Namespace

+ type TableMetadata struct

+ CurrentSchemaID int

+ CurrentSnapshotID *int64

+ FormatVersion int

+ Location string

+ Properties map[string]string

+ Schemas []Schema

+ Snapshots []Snapshot

+ TableUUID string

+ type TableModule struct

+ func (m *TableModule) Init() error

+ func (m *TableModule) Start(ctx context.Context) error

+ func (m *TableModule) Stop(_ context.Context) error

+ type TableRequirement struct

+ Fields map[string]any

+ Type string

+ type TableSchemaConfig struct

+ Fields []TableFieldConfig

+ type TableUpdate struct

+ Action string

+ Fields map[string]any

v0.1.2

Mar 29, 2026

v0.1.1

Mar 29, 2026

v0.1.0

Mar 29, 2026