lake

Documentation

Index

• Constants
• Variables
• func CopyToOutput(ctx context.Context, engine storage.Engine, flags outputflags.Flags, ...) error
• func DefaultRoot() string
• func New(parent charm.Command, f *flag.FlagSet) (charm.Command, error)
• func ParseKeys(s string) (field.List, bool)
• type Command
• type CommitFlags
  • func (c *CommitFlags) CommitMessage() api.CommitMessage
  • func (c *CommitFlags) SetFlags(f *flag.FlagSet)
• type Date
  • func DefaultDate() Date
  • func ParseDate(s string) (Date, error)
  • func (d *Date) Set(s string) error
  • func (d Date) String() string
  • func (d Date) Ts() nano.Ts
• type LocalCommand
  • func (c *LocalCommand) Open(ctx context.Context) (api.Interface, error)
  • func (c *LocalCommand) Root() *root.Command
  • func (c *LocalCommand) Run(args []string) error

Constants

const RootEnv = "ZED_LAKE_ROOT"

Variables

var Cmd = &charm.Spec{
	Name:  "lake",
	Usage: "lake [options] sub-command",
	Short: "create, manage, and search Zed lakes",
	Long: `
The "zed lake" command
operates on collections of Zed data files partitioned by and organized
by a specified key and stored either on a filesystem or an S3 compatible object store.

See the zed lake README in the zed repository for more information:
https://github.com/brimdata/zed/blob/main/docs/lake/README.md
`,
	New: New,
}

Functions

func CopyToOutput

func CopyToOutput(ctx context.Context, engine storage.Engine, flags outputflags.Flags, r zio.Reader) error

func DefaultRoot

func DefaultRoot() string

func New

func New(parent charm.Command, f *flag.FlagSet) (charm.Command, error)

func ParseKeys

func ParseKeys(s string) (field.List, bool)

Types

type Command

type Command interface {
	Open(context.Context) (api.Interface, error)
	Root() *root.Command
}

type CommitFlags

type CommitFlags struct {
	User    string
	Message string
}

CommitFlags implements flags used by all "zed lake" 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 Date

type Date nano.Ts

func DefaultDate

func DefaultDate() Date

func ParseDate

func ParseDate(s string) (Date, error)

func (*Date) Set

func (d *Date) Set(s string) error

func (Date) String

func (d Date) String() string

func (Date) Ts

func (d Date) Ts() nano.Ts

type LocalCommand

type LocalCommand struct {
	*root.Command
	Path string
}

func (*LocalCommand) Open

func (c *LocalCommand) Open(ctx context.Context) (api.Interface, error)

func (*LocalCommand) Root

func (c *LocalCommand) Root() *root.Command

func (*LocalCommand) Run

func (c *LocalCommand) Run(args []string) error