describe

Documentation

Index

• type Channel
• type Info
  • func Analyze(ctx context.Context, query string, src *data.Source, head *lakeparse.Commitish) (*Info, error)
  • func AnalyzeDAG(ctx context.Context, entry dag.Seq, src *data.Source, ...) (*Info, error)
• type LakeMeta
  • func (*LakeMeta) Source()
• type Path
  • func (*Path) Source()
• type Pool
  • func (*Pool) Source()
• type Source

Types

type Channel

type Channel struct {
	Name            string         `json:"name"`
	AggregationKeys field.List     `json:"aggregation_keys"`
	Sort            order.SortKeys `json:"sort"`
}

type Info

type Info struct {
	Sources  []Source  `json:"sources"`
	Channels []Channel `json:"channels"`
}

func Analyze

func Analyze(ctx context.Context, query string, src *data.Source, head *lakeparse.Commitish) (*Info, error)

func AnalyzeDAG

func AnalyzeDAG(ctx context.Context, entry dag.Seq, src *data.Source, head *lakeparse.Commitish) (*Info, error)

type LakeMeta

type LakeMeta struct {
	Kind string `json:"kind"`
	Meta string `json:"meta"`
}

func (*LakeMeta) Source

func (*LakeMeta) Source()

type Path

type Path struct {
	Kind     string `json:"kind"`
	URI      string `json:"uri"`
	Inferred bool   `json:"inferred"`
}

func (*Path) Source

func (*Path) Source()

type Pool

type Pool struct {
	Kind     string      `json:"kind"`
	Name     string      `json:"name"`
	ID       ksuid.KSUID `json:"id"`
	Inferred bool        `json:"inferred"`
}

func (*Pool) Source

func (*Pool) Source()

type Source

type Source interface {
	Source()
}