resourceprovider

Documentation

Index

• Constants
• Variables
• func AddResourceProviderCliFlags(cmd *cobra.Command, options *ResourceProviderOptions)
• func AddResourceProviderOfferCliFlags(cmd *cobra.Command, offerOptions *ResourceProviderOfferOptions)
• func CheckResourceProviderOfferOptions(options ResourceProviderOfferOptions) error
• func CheckResourceProviderOptions(options ResourceProviderOptions) error
• type ResourceProvider
  • func NewResourceProvider(options ResourceProviderOptions, web3SDK *web3.Web3SDK, ...) (*ResourceProvider, error)
  • func (resourceProvider *ResourceProvider) Start(ctx context.Context, cm *system.CleanupManager) chan error
• type ResourceProviderController
  • func NewResourceProviderController(options ResourceProviderOptions, web3SDK *web3.Web3SDK, ...) (*ResourceProviderController, error)
  • func (controller *ResourceProviderController) Start(ctx context.Context, cm *system.CleanupManager) chan error
• type ResourceProviderOfferOptions
  • func GetDefaultResourceProviderOfferOptions() ResourceProviderOfferOptions
  • func ProcessResourceProviderOfferOptions(options ResourceProviderOfferOptions) (ResourceProviderOfferOptions, error)
• type ResourceProviderOptions
  • func NewResourceProviderOptions() ResourceProviderOptions
  • func ProcessResourceProviderOptions(options ResourceProviderOptions) (ResourceProviderOptions, error)

Constants

const CONTROL_LOOP_INTERVAL = 10 * time.Second

the background "even if we have not heard of an event" loop i.e. things will not wait 10 seconds - the control loop reacts to events in the system - this 10 second background loop is just for in case we miss any events

Variables

var Module = fx.Options(
	fx.Provide(
		newServices,
	),
)

Functions

func AddResourceProviderCliFlags

func AddResourceProviderCliFlags(cmd *cobra.Command, options *ResourceProviderOptions)

func AddResourceProviderOfferCliFlags

func AddResourceProviderOfferCliFlags(cmd *cobra.Command, offerOptions *ResourceProviderOfferOptions)

func CheckResourceProviderOfferOptions

func CheckResourceProviderOfferOptions(options ResourceProviderOfferOptions) error

func CheckResourceProviderOptions

func CheckResourceProviderOptions(options ResourceProviderOptions) error

Types

type ResourceProvider

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

func NewResourceProvider

func NewResourceProvider(
	options ResourceProviderOptions,
	web3SDK *web3.Web3SDK,
	executor executor.Executor,
	dealMakerService *dealmaker.Service,
) (*ResourceProvider, error)

func (*ResourceProvider) Start

func (resourceProvider *ResourceProvider) Start(ctx context.Context, cm *system.CleanupManager) chan error

type ResourceProviderController

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

func NewResourceProviderController

func NewResourceProviderController(
	options ResourceProviderOptions,
	web3SDK *web3.Web3SDK,
	executor executor.Executor,
	dealmakerService *dealmaker.Service,
) (*ResourceProviderController, error)

func (*ResourceProviderController) Start

func (controller *ResourceProviderController) Start(ctx context.Context, cm *system.CleanupManager) chan error

type ResourceProviderOfferOptions

type ResourceProviderOfferOptions struct {
	// if we are configuring a single machine then
	// these values are populated by the flags
	OfferSpec dto.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 []dto.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 dto.PricingMode

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

	// allow different pricing for different modules
	ModulePricing  map[string]dto.DealPricing
	ModuleTimeouts map[string]dto.DealTimeouts

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

this configures the resource offers we will keep track of

func GetDefaultResourceProviderOfferOptions

func GetDefaultResourceProviderOfferOptions() ResourceProviderOfferOptions

func ProcessResourceProviderOfferOptions

func ProcessResourceProviderOfferOptions(options ResourceProviderOfferOptions) (ResourceProviderOfferOptions, error)

type ResourceProviderOptions

type ResourceProviderOptions struct {
	Bacalhau bacalhau.BacalhauExecutorOptions
	Offers   ResourceProviderOfferOptions
	Web3     web3.Web3Options
	Dealer   string
}

func NewResourceProviderOptions

func NewResourceProviderOptions() ResourceProviderOptions

func ProcessResourceProviderOptions

func ProcessResourceProviderOptions(options ResourceProviderOptions) (ResourceProviderOptions, error)