Documentation ¶
Index ¶
- Constants
- type FsRepo
- 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" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FsRepo ¶
type FsRepo struct {
// contains filtered or unexported fields
}
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 ¶
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`
type RepoVersion ¶
type RepoVersion struct {
Version int
}