gotrepo

package
v0.0.1 Latest Latest
Warning

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

 Go to latest Published: Dec 20, 2021 License: GPL-3.0 Imports: 39 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	MaxBlobSize = gotfs.DefaultMaxBlobSize
)

default bucket

Variables

This section is empty.

Functions

func ConfigureRepo 

func ConfigureRepo(repoPath string, fn func(x Config) Config) error

ConfigureRepo applies fn to the config of the repo at repoPath

func Init 

func Init(p string) error

func LoadPrivateKey 

func LoadPrivateKey(fsx posixfs.FS, p string) (p2p.PrivateKey, error)

func MarshalIAMPolicy 

func MarshalIAMPolicy(p gotiam.Policy) []byte

func MarshalIAMRule 

func MarshalIAMRule(r gotiam.Rule) []byte

func ParsePolicy 

func ParsePolicy(data []byte) (*gotiam.Policy, error)

func ParseRule 

func ParseRule(data []byte) (*gotiam.Rule, error)

func SaveConfig 

func SaveConfig(fsx posixfs.FS, p string, c Config) error

func SavePrivateKey 

func SavePrivateKey(fsx posixfs.FS, p string, privateKey p2p.PrivateKey) error

Types

type BlobcacheStoreSpec 

type BlobcacheStoreSpec struct {
	Addr string `json:"addr"`
}

type Branch 

type Branch = branches.Branch

type BranchSpec 

type BranchSpec struct {
	Volume    VolumeSpec  `json:"volume"`
	Salt      []byte      `json:"salt"`
	CreatedAt tai64.TAI64 `json:"created_at"`
}

type Cell 

type Cell = cells.Cell

type CellID 

type CellID uint64

type CellSpec 

type CellSpec struct {
	Local     *LocalCellSpec     `json:"local,omitempty"`
	HTTP      *HTTPCellSpec      `json:"http,omitempty"`
	Encrypted *EncryptedCellSpec `json:"encrypted,omitempty"`
	Signed    *SignedCellSpec    `json:"signed,omitempty"`
}

func ParseCellSpec 

func ParseCellSpec(data []byte) (*CellSpec, error)

type Config 

type Config struct {
	Spaces []SpaceLayerSpec `json:"spaces"`
}

func DefaultConfig 

func DefaultConfig() Config

func LoadConfig 

func LoadConfig(fsx posixfs.FS, p string) (*Config, error)

type EncryptedCellSpec 

type EncryptedCellSpec struct {
	Inner  CellSpec `json:"inner"`
	Secret []byte   `json:"secret"`
}

type FS 

type FS = posixfs.FS

type FileOperation 

type FileOperation struct {
	Create   *Root
	Modify   *Root
	Delete   bool
	MoveFrom *string
}

type HTTPCellSpec 

type HTTPCellSpec = httpcell.Spec

type LocalCellSpec 

type LocalCellSpec = CellID

type LocalStoreSpec 

type LocalStoreSpec = StoreID

type MultiSpaceSpec 

type MultiSpaceSpec []SpaceLayerSpec

type PeerCellSpec 

type PeerCellSpec struct {
	ID   p2p.PeerID `json:"id"`
	Name string     `json:"name"`
}

type PeerID 

type PeerID = inet256.Addr

type PrivateKey 

type PrivateKey = inet256.PrivateKey

type Ref 

type Ref = gotkv.Ref

type Repo 

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

func Open 

func Open(p string) (*Repo, error)

func (*Repo) Add 

func (r *Repo) Add(ctx context.Context, paths ...string) error

Add adds paths from the working directory to the staging area. Directories are traversed, and only paths are added. Adding a directory will update any existing paths and add new ones, it will not remove paths from version control

func (*Repo) Cat 

func (r *Repo) Cat(ctx context.Context, p string, w io.Writer) error

func (*Repo) Check 

func (r *Repo) Check(ctx context.Context) error

func (*Repo) Cleanup 

func (r *Repo) Cleanup(ctx context.Context) error

func (*Repo) CleanupBranch 

func (r *Repo) CleanupBranch(ctx context.Context, name string) error

func (Repo) Clear 

func (r Repo) Clear(ctx context.Context) error

func (*Repo) Close 

func (r *Repo) Close() error

func (*Repo) Commit 

func (r *Repo) Commit(ctx context.Context, snapInfo gotvc.SnapInfo) error

func (*Repo) CreateBranch 

func (r *Repo) CreateBranch(ctx context.Context, name string, params branches.Params) (*Branch, error)

CreateBranch creates a branch using the default spec.

func (*Repo) CreateBranchWithSpec 

func (r *Repo) CreateBranchWithSpec(name string, spec BranchSpec) (*Branch, error)

CreateBranchWithSpec creates a branch using spec

func (*Repo) DebugDB 

func (r *Repo) DebugDB(ctx context.Context, w io.Writer) error

func (*Repo) DebugFS 

func (r *Repo) DebugFS(ctx context.Context, w io.Writer) error

func (*Repo) DebugKV 

func (r *Repo) DebugKV(ctx context.Context, w io.Writer) error

func (*Repo) DeleteBranch 

func (r *Repo) DeleteBranch(ctx context.Context, name string) error

DeleteBranch deletes a branch

func (*Repo) Discard 

func (r *Repo) Discard(ctx context.Context, paths ...string) error

Discard removes any staged changes for a path

func (*Repo) ForEachBranch 

func (r *Repo) ForEachBranch(ctx context.Context, fn func(string) error) error

ForEachBranch calls fn once for each branch, or until an error is returned from fn

func (*Repo) ForEachStaging 

func (r *Repo) ForEachStaging(ctx context.Context, fn func(p string, op FileOperation) error) error

func (*Repo) ForEachUntracked 

func (r *Repo) ForEachUntracked(ctx context.Context, fn func(p string) error) error

ForEachUntracked lists all the files which are not in either:

  1. the staging area
  2. the active branch head

func (*Repo) Fork 

func (r *Repo) Fork(ctx context.Context, base, next string) error

Fork creates a new branch called next and sets its head to match base's

func (*Repo) GetActiveBranch 

func (r *Repo) GetActiveBranch(ctx context.Context) (string, *Branch, error)

GetActiveBranch returns the name of the active branch, and the branch

func (*Repo) GetBranch 

func (r *Repo) GetBranch(ctx context.Context, name string) (*Branch, error)

GetBranch returns the branch with the specified name

func (*Repo) GetBranchHead 

func (r *Repo) GetBranchHead(ctx context.Context, name string) (*Snap, error)

func (*Repo) GetIAMPolicy 

func (r *Repo) GetIAMPolicy() gotiam.Policy

func (*Repo) GetID 

func (r *Repo) GetID() inet256.Addr

func (*Repo) GetPrivateKey 

func (r *Repo) GetPrivateKey() p2p.PrivateKey

func (*Repo) GetSpace 

func (r *Repo) GetSpace() Space

func (*Repo) GotNetClient 

func (r *Repo) GotNetClient() (*gotnet.Service, error)

func (*Repo) History 

func (r *Repo) History(ctx context.Context, name string, fn func(ref Ref, s Snap) error) error

func (*Repo) Ls 

func (r *Repo) Ls(ctx context.Context, p string, fn func(gotfs.DirEnt) error) error

func (*Repo) MakeCell 

func (r *Repo) MakeCell(spec CellSpec) (Cell, error)

func (*Repo) MakeSpace 

func (r *Repo) MakeSpace(spec SpaceSpec) (Space, error)

func (*Repo) MakeStore 

func (r *Repo) MakeStore(spec StoreSpec) (Store, error)

func (*Repo) MakeVolume 

func (r *Repo) MakeVolume(spec VolumeSpec) (*Volume, error)

func (*Repo) Put 

func (r *Repo) Put(ctx context.Context, paths ...string) error

Put replaces a path (file or directory) with whatever is in the working directory Adding a file updates the file. Adding a directory will delete paths not in the working directory, and add paths in the working directory.

func (*Repo) Rm 

func (r *Repo) Rm(ctx context.Context, paths ...string) error

Rm deletes a path known to version control.

func (*Repo) Serve 

func (r *Repo) Serve(ctx context.Context) error

Server serves cells, and blobs to the network.

func (*Repo) SetActiveBranch 

func (r *Repo) SetActiveBranch(ctx context.Context, name string) error

SetActiveBranch sets the active branch to name

func (*Repo) SetBranchHead 

func (r *Repo) SetBranchHead(ctx context.Context, name string, snap Snap) error

SetBranchHead

func (*Repo) StagingStore 

func (r *Repo) StagingStore() cadata.Store

func (*Repo) Stat 

func (r *Repo) Stat(ctx context.Context, p string) (*gotfs.Metadata, error)

func (*Repo) Sync 

func (r *Repo) Sync(ctx context.Context, dst, src string, force bool) error

Sync synces 2 branches by name.

func (*Repo) UnionStore 

func (r *Repo) UnionStore() cadata.Store

func (*Repo) UpdateIAMPolicy 

func (r *Repo) UpdateIAMPolicy(fn func(gotiam.Policy) gotiam.Policy) error

func (*Repo) WorkingDir 

func (r *Repo) WorkingDir() FS

type Root 

type Root = gotfs.Root

type SignedCellSpec 

type SignedCellSpec struct {
	Inner          CellSpec `json:"inner"`
	PublicKeyX509  []byte   `json:"public_key"`
	PrivateKeyX509 []byte   `json:"private_key"`
}

type Snap 

type Snap = gotvc.Snap

type Space 

type Space = branches.Space

type SpaceLayerSpec 

type SpaceLayerSpec struct {
	Prefix string    `json:"prefix"`
	Target SpaceSpec `json:"target"`
}

type SpaceSpec 

type SpaceSpec struct {
	Peer *inet256.ID `json:"peer,omitempty"`
}

type Store 

type Store = cadata.Store

type StoreID 

type StoreID = uint64

type StoreSpec 

type StoreSpec struct {
	Local     *LocalStoreSpec     `json:"local,omitempty"`
	Blobcache *BlobcacheStoreSpec `json:"blobcache,omitempty"`
}

func DefaultBlobcacheSpec 

func DefaultBlobcacheSpec() StoreSpec

type Volume 

type Volume = branches.Volume

type VolumeSpec 

type VolumeSpec struct {
	Cell     CellSpec  `json:"cell"`
	VCStore  StoreSpec `json:"vc_store"`
	FSStore  StoreSpec `json:"fs_store"`
	RawStore StoreSpec `json:"raw_store"`
}

func ParseVolumeSpec 

func ParseVolumeSpec(data []byte) (*VolumeSpec, 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.