type github.com/polarsignals/frostdb.DataSource (interface)

Method Implmentations

Prefixes(ctx context.Context, prefix string) ([]string, error) DataSinkSource.Prefixes (*DefaultObjstoreBucket).Prefixes *github.com/polarsignals/frostdb/index.LSM.Prefixes *github.com/polarsignals/frostdb/storage.Iceberg.Prefixes
Scan(ctx context.Context, prefix string, schema *dynparquet.Schema, filter logicalplan.Expr, lastBlockTimestamp uint64, callback func(context.Context, any) error) error DataSinkSource.Scan (*DefaultObjstoreBucket).Scan *github.com/polarsignals/frostdb/index.LSM.Scan *github.com/polarsignals/frostdb/storage.Iceberg.Scan
String() string DataSinkSource.String (*DefaultObjstoreBucket).String *github.com/polarsignals/frostdb/index.LSM.String *github.com/polarsignals/frostdb/storage.Iceberg.String