repo

Documentation

Index

• Constants
• type LocalRepo
• type LocalWorkingCopy
• type RemoteServeType
  • func (t *RemoteServeType) Set(v string) (err error)
  • func (i RemoteServeType) String() string
• type RemoteTransferOptions
  • func (options *RemoteTransferOptions) SetFlagSet(f *flag.FlagSet)
  • func (options RemoteTransferOptions) WithPrintCopies(value bool) RemoteTransferOptions
• type RemoteType
  • func GetAllRemoteTypes() []RemoteType
  • func (t *RemoteType) Set(v string) (err error)
  • func (i RemoteType) String() string
• type Repo
• type UnixSocket
• type WorkingCopy

Constants

const (
	RemoteServeTypeUnspecified = RemoteServeType(iota)
	RemoteServeTypeSocketUnix
	RemoteServeTypePortHTTP
	RemoteServeTypeStdioLocal
)

const (
	RemoteTypeUnspecified = RemoteType(iota)
	RemoteTypeNativeDotenvXDG
	RemoteTypeSocketUnix
	RemoteTypeUrl
	RemoteTypeStdioLocal
	RemoteTypeStdioSSH
)

Types

type LocalRepo

type LocalRepo interface {
	Repo
	GetEnvRepo() env_repo.Env // TODO rename to GetEnvRepo
	GetImmutableConfigPrivate() config_immutable_io.ConfigLoadedPrivate
	Lock() error
	Unlock() error
}

type LocalWorkingCopy

type LocalWorkingCopy interface {
	WorkingCopy
	LocalRepo
	GetEnvWorkspace() env_workspace.Env
}

type RemoteServeType

type RemoteServeType int

func (*RemoteServeType) Set

func (t *RemoteServeType) Set(v string) (err error)

func (RemoteServeType) String

func (i RemoteServeType) String() string

type RemoteTransferOptions

type RemoteTransferOptions struct {
	PrintCopies         bool
	BlobGenres          ids.Genre
	IncludeObjects      bool
	IncludeBlobs        bool
	AllowMergeConflicts bool
}

TODO add HTTP header options for these flags

func (*RemoteTransferOptions) SetFlagSet

func (options *RemoteTransferOptions) SetFlagSet(f *flag.FlagSet)

func (RemoteTransferOptions) WithPrintCopies

func (options RemoteTransferOptions) WithPrintCopies(
	value bool,
) RemoteTransferOptions

type RemoteType

type RemoteType int

func GetAllRemoteTypes

func GetAllRemoteTypes() []RemoteType

func (*RemoteType) Set

func (t *RemoteType) Set(v string) (err error)

func (RemoteType) String

func (i RemoteType) String() string

type Repo

type Repo interface {
	GetEnv() env_ui.Env
	GetImmutableConfigPublic() config_immutable_io.ConfigLoadedPublic
	GetBlobStore() interfaces.BlobStore
	GetObjectStore() sku.ObjectStore
	GetTypedInventoryListBlobStore() typed_blob_store.InventoryList
	GetInventoryListStore() sku.InventoryListStore

	MakeImporter(
		options sku.ImporterOptions,
		storeOptions sku.StoreOptions,
	) sku.Importer

	// TODO switch to seq
	ImportList(
		list *sku.List,
		i sku.Importer,
	) (err error)
}

TODO explore permissions for who can read / write from the inventory list store

type UnixSocket

type UnixSocket struct {
	net.Listener
	Path string
}

type WorkingCopy

type WorkingCopy interface {
	Repo

	MakeExternalQueryGroup(
		builderOptions query.BuilderOption,
		externalQueryOptions sku.ExternalQueryOptions,
		args ...string,
	) (qg *query.Query, err error)

	MakeInventoryList(
		qg *query.Query,
	) (list *sku.List, err error)

	PullQueryGroupFromRemote(
		remote Repo,
		qg *query.Query,
		options RemoteTransferOptions,
	) (err error)

	ReadObjectHistory(
		oid *ids.ObjectId,
	) (skus []*sku.Transacted, err error)
}