cli

Documentation

Index

• Variables
• func FileExists(path string) bool
• type CommitFlags
  • func (c *CommitFlags) CommitMessage() api.CommitMessage
  • func (c *CommitFlags) SetFlags(f *flag.FlagSet)
• 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, ...) (op.Scheduler, error)
  • func (f *FileAdaptor) Open(ctx context.Context, zctx *zed.Context, path string, pushdown zbuf.Filter) (zbuf.Puller, 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
• type LakeFlags
  • func (l *LakeFlags) AuthStore() *auth0.Store
  • func (l *LakeFlags) Connection() (*client.Connection, error)
  • func (l *LakeFlags) Open(ctx context.Context) (api.Interface, error)
  • func (l *LakeFlags) SetFlags(fs *flag.FlagSet)
  • func (l *LakeFlags) SetFlagsWithDefaultLake(fs *flag.FlagSet, lake string)
  • func (l *LakeFlags) URI() (*storage.URI, error)

Variables

var Version = "unknown"

Version is set via the Go linker. See Makefile.

Functions

func FileExists

func FileExists(path string) bool

Types

type CommitFlags

type CommitFlags struct {
	User    string
	Message string
	Meta    string
}

CommitFlags implements flags used by all "zed" commands that need commit info.

func (*CommitFlags) CommitMessage

func (c *CommitFlags) CommitMessage() api.CommitMessage

func (*CommitFlags) SetFlags

func (c *CommitFlags) SetFlags(f *flag.FlagSet)

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, *dag.Filter) (op.Scheduler, error)

func (*FileAdaptor) Open

func (f *FileAdaptor) Open(ctx context.Context, zctx *zed.Context, path string, pushdown zbuf.Filter) (zbuf.Puller, 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
}

type LakeFlags

type LakeFlags struct {
	ConfigDir string
	Lake      string
}

func (*LakeFlags) AuthStore

func (l *LakeFlags) AuthStore() *auth0.Store

func (*LakeFlags) Connection

func (l *LakeFlags) Connection() (*client.Connection, error)

func (*LakeFlags) Open

func (l *LakeFlags) Open(ctx context.Context) (api.Interface, error)

func (*LakeFlags) SetFlags

func (l *LakeFlags) SetFlags(fs *flag.FlagSet)

func (*LakeFlags) SetFlagsWithDefaultLake

func (l *LakeFlags) SetFlagsWithDefaultLake(fs *flag.FlagSet, lake string)

func (*LakeFlags) URI

func (l *LakeFlags) URI() (*storage.URI, error)