resourceprovider

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

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

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

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

type ResourceProviderOfferOptions struct {
	// if we are configuring a single machine then
	// these values are populated by the flags
	OfferSpec data.MachineSpec
	// we can dupliate the single spec to create a list of specs
	OfferCount int
	// this represents how many machines we will keep
	// offering to the network
	// we can configure this with a config file
	// to start with we will just add --cpu --gpu and --ram flags
	// to the resource provider CLI which constrains them to a single machine
	Specs []data.MachineSpec
	// the list of modules we are willing to run
	// an empty list means anything
	Modules []string

	// this will normally be FixedPrice for RP's
	Mode data.PricingMode

	// the default pricing for this resource provider
	// for all modules that don't have a specific price
	DefaultPricing data.DealPricing

	// allow different pricing for different modules
	ModulePricing map[string]data.DealPricing

	// which mediators and directories this RP will trust
	Services data.ServiceConfig
}

type ResourceProviderOptions struct {
	Bacalhau  bacalhau.BacalhauExecutorOptions
	Offers    ResourceProviderOfferOptions
	Web3      web3.Web3Options
	Pow       ResourceProviderPowOptions
	IPFS      ipfs.IPFSOptions
	Telemetry system.TelemetryOptions
}

type ResourceProviderPowOptions struct {
	DisablePow         bool
	NumWorkers         int
	CudaGridSize       int
	CudaBlockSize      int
	CudaHashsPerThread int
}

type SubmitWork func(nonce *big.Int, hashrate float64)

type Task struct {
	Id         uuid.UUID
	Challenge  [32]byte
	Difficulty *uint256.Int
	From       *uint256.Int
	End        *uint256.Int
}

type TaskResult struct {
	Id    uuid.UUID
	Nonce *uint256.Int
}

type Worker interface {
	FindSolution(ctx context.Context, task *Task)
	Stop()
}

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