cli

Documentation

Index

• Variables
• func FileExists(path string) bool
• type FileAdaptor
  • func NewFileAdaptor(engine storage.Engine) *FileAdaptor
  • func (*FileAdaptor) CommitObject(context.Context, ksuid.KSUID, string) (ksuid.KSUID, error)
  • func (*FileAdaptor) Layout(context.Context, dag.Source) order.Layout
  • func (*FileAdaptor) NewScheduler(context.Context, *zed.Context, dag.Source, extent.Span, zbuf.Filter) (proc.Scheduler, error)
  • func (f *FileAdaptor) Open(ctx context.Context, zctx *zed.Context, path string, pushdown zbuf.Filter) (zbuf.PullerCloser, error)
  • func (*FileAdaptor) PoolID(context.Context, string) (ksuid.KSUID, error)
• type Flags
  • func (f *Flags) Cleanup()
  • func (f *Flags) Init(all ...Initializer) error
  • func (f *Flags) SetFlags(fs *flag.FlagSet)
• type Initializer

Variables

var Version = "unknown"

Version is set via the Go linker. See Makefile.

Functions

func FileExists

func FileExists(path string) bool

Types

type FileAdaptor

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

func NewFileAdaptor

func NewFileAdaptor(engine storage.Engine) *FileAdaptor

func (*FileAdaptor) CommitObject

func (*FileAdaptor) CommitObject(context.Context, ksuid.KSUID, string) (ksuid.KSUID, error)

func (*FileAdaptor) Layout

func (*FileAdaptor) Layout(context.Context, dag.Source) order.Layout

func (*FileAdaptor) NewScheduler

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

func (*FileAdaptor) Open

func (f *FileAdaptor) Open(ctx context.Context, zctx *zed.Context, path string, pushdown zbuf.Filter) (zbuf.PullerCloser, error)

func (*FileAdaptor) PoolID

func (*FileAdaptor) PoolID(context.Context, string) (ksuid.KSUID, error)

type Flags

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

func (*Flags) Cleanup

func (f *Flags) Cleanup()

func (*Flags) Init

func (f *Flags) Init(all ...Initializer) error

func (*Flags) SetFlags

func (f *Flags) SetFlags(fs *flag.FlagSet)

type Initializer

type Initializer interface {
	Init() error
}