data

Documentation

Index

• type Source
  • func NewSource(engine storage.Engine, lake *lake.Root) *Source
  • func (s *Source) CommitObject(ctx context.Context, id ksuid.KSUID, name string) (ksuid.KSUID, error)
  • func (s *Source) IsLake() bool
  • func (s *Source) Lake() *lake.Root
  • func (s *Source) Layout(ctx context.Context, src dag.Source) order.Layout
  • func (s *Source) Open(ctx context.Context, zctx *zed.Context, path, format string, ...) (zbuf.Puller, error)
  • func (s *Source) PoolID(ctx context.Context, id string) (ksuid.KSUID, error)

Types

type Source

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

func NewSource

func NewSource(engine storage.Engine, lake *lake.Root) *Source

func (*Source) CommitObject

func (s *Source) CommitObject(ctx context.Context, id ksuid.KSUID, name string) (ksuid.KSUID, error)

func (*Source) IsLake

func (s *Source) IsLake() bool

func (*Source) Lake

func (s *Source) Lake() *lake.Root

func (*Source) Layout

func (s *Source) Layout(ctx context.Context, src dag.Source) order.Layout

func (*Source) Open

func (s *Source) Open(ctx context.Context, zctx *zed.Context, path, format string, pushdown zbuf.Filter) (zbuf.Puller, error)

func (*Source) PoolID

func (s *Source) PoolID(ctx context.Context, id string) (ksuid.KSUID, error)