bacalhau

package

v2.21.0 Latest Latest Go to latest Published: Jun 3, 2025 License: Apache-2.0 Imports: 23 Imported by: 0

Details

View Source

const MINIMUM_DISK_SPACE = 3 * 1024 * 1024 * 1024 // 3 Gb

View Source

const RESULTS_DIR = "bacalhau-results"

This section is empty.

This section is empty.

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

type BacalhauExecutor struct {
	Options BacalhauExecutorOptions
	// contains filtered or unexported fields
}

func NewBacalhauExecutor(options BacalhauExecutorOptions) (*BacalhauExecutor, error)

func (executor *BacalhauExecutor) GetMachineSpecs() ([]data.MachineSpec, error)

func (executor *BacalhauExecutor) Id() (string, error)

func (executor *BacalhauExecutor) IsAvailable() (bool, error)

Checks that Bacalhau is installed, correctly configured, and available

func (executor *BacalhauExecutor) Preflight() error

func (executor *BacalhauExecutor) RunJob(
	deal data.DealContainer,
	module data.Module,
) (*executorlib.ExecutorResults, error)

type BacalhauExecutorOptions struct {
	ApiHost               string
	ApiPort               string
	JobStatusPollInterval uint64
}