mediator

Documentation

Index

• Constants
• type Mediator
  • func NewMediator(options MediatorOptions, web3SDK *web3.Web3SDK, executor executor.Executor) (*Mediator, error)
  • func (mediator *Mediator) Start(ctx context.Context, cm *system.CleanupManager) chan error
• type MediatorController
  • func NewMediatorController(options MediatorOptions, web3SDK *web3.Web3SDK, executor executor.Executor) (*MediatorController, error)
  • func (controller *MediatorController) Start(ctx context.Context, cm *system.CleanupManager) chan error
• type MediatorOptions

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

Types

type Mediator

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

func NewMediator

func NewMediator(
	options MediatorOptions,
	web3SDK *web3.Web3SDK,
	executor executor.Executor,
) (*Mediator, error)

func (*Mediator) Start

func (mediator *Mediator) Start(ctx context.Context, cm *system.CleanupManager) chan error

type MediatorController

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

func NewMediatorController

func NewMediatorController(
	options MediatorOptions,
	web3SDK *web3.Web3SDK,
	executor executor.Executor,
) (*MediatorController, error)

func (*MediatorController) Start

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

type MediatorOptions

type MediatorOptions struct {
	Bacalhau bacalhau.BacalhauExecutorOptions
	Services data.ServiceConfig
	Web3     web3.Web3Options
}