mock

Documentation

Index

• type Lake
  • func NewLake() *Lake
  • func (l *Lake) CommitObject(_ context.Context, poolID ksuid.KSUID, branchName string) (ksuid.KSUID, error)
  • func (l *Lake) Layout(_ context.Context, src dag.Source) order.Layout
  • func (l *Lake) NewPool(poolName string) (*Pool, error)
  • func (*Lake) NewScheduler(context.Context, *zed.Context, dag.Source, extent.Span, zbuf.Filter, ...) (op.Scheduler, error)
  • func (*Lake) Open(_ context.Context, _ *zed.Context, _ string, _ zbuf.Filter) (zbuf.PullerCloser, error)
  • func (l *Lake) PoolID(_ context.Context, poolName string) (ksuid.KSUID, error)
• type Pool

Types

type Lake

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

func NewLake

func NewLake() *Lake

func (*Lake) CommitObject

func (l *Lake) CommitObject(_ context.Context, poolID ksuid.KSUID, branchName string) (ksuid.KSUID, error)

func (*Lake) Layout

func (l *Lake) Layout(_ context.Context, src dag.Source) order.Layout

func (*Lake) NewPool

func (l *Lake) NewPool(poolName string) (*Pool, error)

create a mock lake whose key layout is embedded in the mock pool name, e.g., "logs-ts:asc"

func (*Lake) NewScheduler

func (*Lake) NewScheduler(context.Context, *zed.Context, dag.Source, extent.Span, zbuf.Filter, *dag.Filter) (op.Scheduler, error)

func (*Lake) Open

func (*Lake) Open(_ context.Context, _ *zed.Context, _ string, _ zbuf.Filter) (zbuf.PullerCloser, error)

func (*Lake) PoolID

func (l *Lake) PoolID(_ context.Context, poolName string) (ksuid.KSUID, error)

type Pool

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