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) Open(ctx context.Context, zctx *zed.Context, path, format string, ...) (zbuf.Puller, error)
  • func (s *Source) OpenHTTP(ctx context.Context, zctx *zed.Context, url, format, method string, ...) (zbuf.Puller, error)
  • func (s *Source) PoolID(ctx context.Context, name string) (ksuid.KSUID, error)
  • func (s *Source) SortKey(ctx context.Context, src dag.Op) order.SortKey

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) Open

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

func (*Source) OpenHTTP

func (s *Source) OpenHTTP(ctx context.Context, zctx *zed.Context, url, format, method string, headers http.Header, body io.Reader, demandOut demand.Demand) (zbuf.Puller, error)

func (*Source) PoolID

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

func (*Source) SortKey

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