repo

Documentation

Index

• Constants
• type FsRepo
  • func NewFS(path string) (*FsRepo, error)
  • func (fsr *FsRepo) Exists() (bool, error)
  • func (fsr *FsRepo) Init() error
  • func (fsr *FsRepo) InitExecutionStore(ctx context.Context, prefix string) (store.ExecutionStore, error)
  • func (fsr *FsRepo) InitJobStore(ctx context.Context, prefix string) (jobstore.Store, error)
  • func (fsr *FsRepo) Open() error
  • func (fsr *FsRepo) Path() (string, error)
  • func (fsr *FsRepo) WriteRunInfo(ctx context.Context, summaryShellVariablesString string) (string, error)
• type RepoVersion

Constants

const (
	// repo versioning
	RepoVersion1    = 1
	RepoVersionFile = "repo.version"

	// user key files
	Libp2pPrivateKeyFileName = "libp2p_private_key"
	UserPrivateKeyFileName   = "user_id.pem"

	// compute paths
	ComputeStoragesPath = "executor_storages"
	PluginsPath         = "plugins"

	// requester paths
	AutoCertCachePath = "autocert-cache"

	// update check paths
	UpdateCheckStatePath = "update.json"
)

Types

type FsRepo

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

func NewFS

func NewFS(path string) (*FsRepo, error)

func (*FsRepo) Exists

func (fsr *FsRepo) Exists() (bool, error)

func (*FsRepo) Init

func (fsr *FsRepo) Init() error

func (*FsRepo) InitExecutionStore

func (fsr *FsRepo) InitExecutionStore(ctx context.Context, prefix string) (store.ExecutionStore, error)

InitExecutionStore must be called after Init and uses the configuration to create a new ExecutionStore. Where BoltDB is chosen, and no path is specified, then the database will be created in the repo in a folder labeledafter the node ID. For example: `~/.bacalhau/Qmd1BEyR4RsLdYTEym1YxxaeXFdwWCMANYN7XCcpPYbTRs-compute/executions.db`

func (*FsRepo) InitJobStore

func (fsr *FsRepo) InitJobStore(ctx context.Context, prefix string) (jobstore.Store, error)

InitJobStore must be called after Init and uses the configuration to create a new JobStore for the requester node. Where BoltDB is chosen, and no path is specified, then the database will be created in the repo in a folder labeledafter the node ID. For example: `~/.bacalhau/Qmd1BEyR4RsLdYTEym1YxxaeXFdwWCMANYN7XCcpPYbTRs-requester/jobs.db`

func (*FsRepo) Open

func (fsr *FsRepo) Open() error

func (*FsRepo) Path

func (fsr *FsRepo) Path() (string, error)

func (*FsRepo) WriteRunInfo

func (fsr *FsRepo) WriteRunInfo(ctx context.Context, summaryShellVariablesString string) (string, error)

type RepoVersion

type RepoVersion struct {
	Version int
}