mediator

Documentation

Index

• Constants
• Variables
• func AddMediatorCliFlags(cmd *cobra.Command, options *MediatorOptions)
• func CheckMediatorOptions(options MediatorOptions) error
• 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
  • func NewMediatorOptions() MediatorOptions
  • func ProcessMediatorOptions(options MediatorOptions) (MediatorOptions, 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 AddMediatorCliFlags

func AddMediatorCliFlags(cmd *cobra.Command, options *MediatorOptions)

func CheckMediatorOptions

func CheckMediatorOptions(options MediatorOptions) error

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 dto.ServiceConfig
	Web3     web3.Web3Options
}

func NewMediatorOptions

func NewMediatorOptions() MediatorOptions

func ProcessMediatorOptions

func ProcessMediatorOptions(options MediatorOptions) (MediatorOptions, error)