api

package
v0.33.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 17, 2021 License: BSD-3-Clause Imports: 23 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func LookupBranchByID 

func LookupBranchByID(ctx context.Context, api Interface, id ksuid.KSUID) (*lake.BranchMeta, error)

func LookupBranchByName 

func LookupBranchByName(ctx context.Context, api Interface, poolName, branchName string) (*lake.BranchMeta, error)

func LookupPoolByID 

func LookupPoolByID(ctx context.Context, api Interface, id ksuid.KSUID) (*pools.Config, error)

func LookupPoolByName 

func LookupPoolByName(ctx context.Context, api Interface, name string) (*pools.Config, error)

func ScanIndexRules 

func ScanIndexRules(ctx context.Context, api Interface, d driver.Driver) error

Types

type Interface 

type Interface interface {
	Query(ctx context.Context, d driver.Driver, head *lakeparse.Commitish, src string, srcfiles ...string) (zbuf.ScannerStats, error)
	PoolID(ctx context.Context, poolName string) (ksuid.KSUID, error)
	CommitObject(ctx context.Context, poolID ksuid.KSUID, branchName string) (ksuid.KSUID, error)
	CreatePool(context.Context, string, order.Layout, int64) (ksuid.KSUID, error)
	RemovePool(context.Context, ksuid.KSUID) error
	RenamePool(context.Context, ksuid.KSUID, string) error
	CreateBranch(ctx context.Context, pool ksuid.KSUID, name string, parent ksuid.KSUID) error
	RemoveBranch(ctx context.Context, pool ksuid.KSUID, branchName string) error
	MergeBranch(ctx context.Context, pool ksuid.KSUID, childBranch, parentBranch string, message api.CommitMessage) (ksuid.KSUID, error)
	Load(ctx context.Context, pool ksuid.KSUID, branch string, r zio.Reader, message api.CommitMessage) (ksuid.KSUID, error)
	Delete(ctx context.Context, pool ksuid.KSUID, branchName string, tags []ksuid.KSUID, message api.CommitMessage) (ksuid.KSUID, error)
	Revert(ctx context.Context, poolID ksuid.KSUID, branch string, commitID ksuid.KSUID, commit api.CommitMessage) (ksuid.KSUID, error)
	AddIndexRules(context.Context, []index.Rule) error
	DeleteIndexRules(context.Context, []ksuid.KSUID) ([]index.Rule, error)
	ApplyIndexRules(ctx context.Context, rule string, pool ksuid.KSUID, branchName string, ids []ksuid.KSUID) (ksuid.KSUID, error)
	UpdateIndex(ctx context.Context, names []string, pool ksuid.KSUID, branchName string) (ksuid.KSUID, error)
}

type LocalSession 

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

func CreateLocalLake 

func CreateLocalLake(ctx context.Context, lakePath *storage.URI) (*LocalSession, error)

func OpenLocalLake 

func OpenLocalLake(ctx context.Context, lakePath *storage.URI) (*LocalSession, error)

func (*LocalSession) AddIndexRules 

func (l *LocalSession) AddIndexRules(ctx context.Context, rules []index.Rule) error

func (*LocalSession) ApplyIndexRules 

func (l *LocalSession) ApplyIndexRules(ctx context.Context, name string, poolID ksuid.KSUID, branchName string, inTags []ksuid.KSUID) (ksuid.KSUID, error)

func (*LocalSession) CommitObject 

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

func (*LocalSession) CreateBranch 

func (l *LocalSession) CreateBranch(ctx context.Context, poolID ksuid.KSUID, name string, parent ksuid.KSUID) error

func (*LocalSession) CreatePool 

func (l *LocalSession) CreatePool(ctx context.Context, name string, layout order.Layout, thresh int64) (ksuid.KSUID, error)

func (*LocalSession) Delete 

func (l *LocalSession) Delete(ctx context.Context, poolID ksuid.KSUID, branchName string, ids []ksuid.KSUID, message api.CommitMessage) (ksuid.KSUID, error)

func (*LocalSession) DeleteIndexRules 

func (l *LocalSession) DeleteIndexRules(ctx context.Context, ids []ksuid.KSUID) ([]index.Rule, error)

func (*LocalSession) Load 

func (l *LocalSession) Load(ctx context.Context, poolID ksuid.KSUID, branchName string, r zio.Reader, message api.CommitMessage) (ksuid.KSUID, error)

func (*LocalSession) MergeBranch 

func (l *LocalSession) MergeBranch(ctx context.Context, poolID ksuid.KSUID, childBranch, parentBranch string, message api.CommitMessage) (ksuid.KSUID, error)

func (*LocalSession) PoolID 

func (l *LocalSession) PoolID(ctx context.Context, poolName string) (ksuid.KSUID, error)

func (*LocalSession) Query 

func (l *LocalSession) Query(ctx context.Context, d driver.Driver, head *lakeparse.Commitish, src string, srcfiles ...string) (zbuf.ScannerStats, error)

func (*LocalSession) RemoveBranch 

func (l *LocalSession) RemoveBranch(ctx context.Context, poolID ksuid.KSUID, branchName string) error

func (*LocalSession) RemovePool 

func (l *LocalSession) RemovePool(ctx context.Context, id ksuid.KSUID) error

func (*LocalSession) RenamePool 

func (l *LocalSession) RenamePool(ctx context.Context, id ksuid.KSUID, name string) error

func (*LocalSession) Revert 

func (l *LocalSession) Revert(ctx context.Context, poolID ksuid.KSUID, branchName string, commitID ksuid.KSUID, message api.CommitMessage) (ksuid.KSUID, error)

func (*LocalSession) UpdateIndex 

func (l *LocalSession) UpdateIndex(ctx context.Context, names []string, poolID ksuid.KSUID, branchName string) (ksuid.KSUID, error)

type RemoteSession 

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

func NewRemoteWithConnection 

func NewRemoteWithConnection(conn *client.Connection) *RemoteSession

func OpenRemoteLake 

func OpenRemoteLake(ctx context.Context, url string) (*RemoteSession, error)

func (*RemoteSession) AddIndexRules 

func (r *RemoteSession) AddIndexRules(ctx context.Context, rules []index.Rule) error

func (*RemoteSession) ApplyIndexRules 

func (r *RemoteSession) ApplyIndexRules(ctx context.Context, rule string, poolID ksuid.KSUID, branchName string, inTags []ksuid.KSUID) (ksuid.KSUID, error)

func (*RemoteSession) CommitObject 

func (r *RemoteSession) CommitObject(ctx context.Context, poolID ksuid.KSUID, branchName string) (ksuid.KSUID, error)

func (*RemoteSession) CreateBranch 

func (r *RemoteSession) CreateBranch(ctx context.Context, poolID ksuid.KSUID, name string, at ksuid.KSUID) error

func (*RemoteSession) CreatePool 

func (r *RemoteSession) CreatePool(ctx context.Context, name string, layout order.Layout, thresh int64) (ksuid.KSUID, error)

func (*RemoteSession) Delete 

func (r *RemoteSession) Delete(ctx context.Context, poolID ksuid.KSUID, branchName string, tags []ksuid.KSUID, commit api.CommitMessage) (ksuid.KSUID, error)

func (*RemoteSession) DeleteIndexRules 

func (r *RemoteSession) DeleteIndexRules(ctx context.Context, ids []ksuid.KSUID) ([]index.Rule, error)

func (*RemoteSession) Load 

func (r *RemoteSession) Load(ctx context.Context, poolID ksuid.KSUID, branchName string, reader zio.Reader, commit api.CommitMessage) (ksuid.KSUID, error)

func (*RemoteSession) MergeBranch 

func (r *RemoteSession) MergeBranch(ctx context.Context, poolID ksuid.KSUID, childBranch, parentBranch string, message api.CommitMessage) (ksuid.KSUID, error)

func (*RemoteSession) PoolID 

func (r *RemoteSession) PoolID(ctx context.Context, poolName string) (ksuid.KSUID, error)

func (*RemoteSession) Query 

func (r *RemoteSession) Query(ctx context.Context, d driver.Driver, head *lakeparse.Commitish, src string, srcfiles ...string) (zbuf.ScannerStats, error)

func (*RemoteSession) RemoveBranch 

func (r *RemoteSession) RemoveBranch(ctx context.Context, poolID ksuid.KSUID, branchName string) error

func (*RemoteSession) RemovePool 

func (r *RemoteSession) RemovePool(ctx context.Context, pool ksuid.KSUID) error

func (*RemoteSession) RenamePool 

func (r *RemoteSession) RenamePool(ctx context.Context, pool ksuid.KSUID, name string) error

func (*RemoteSession) Revert 

func (r *RemoteSession) Revert(ctx context.Context, poolID ksuid.KSUID, branchName string, commitID ksuid.KSUID, message api.CommitMessage) (ksuid.KSUID, error)

func (*RemoteSession) UpdateIndex 

func (r *RemoteSession) UpdateIndex(ctx context.Context, rules []string, poolID ksuid.KSUID, branchName string) (ksuid.KSUID, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.