computation

Documentation

Index

• Constants
• Variables
• type ComputationManager
• type Manager
  • func New(logger zerolog.Logger, metrics module.ExecutionMetrics, tracer module.Tracer, ...) (*Manager, error)
  • func (e *Manager) ComputeBlock(ctx context.Context, block *entity.ExecutableBlock, view state.View) (*execution.ComputationResult, error)
  • func (e *Manager) ExecuteScript(code []byte, arguments [][]byte, blockHeader *flow.Header, view state.View) ([]byte, error)
  • func (e *Manager) GetAccount(address flow.Address, blockHeader *flow.Header, view state.View) (*flow.Account, error)
• type ProgramsCache
  • func NewProgramsCache(size uint) (*ProgramsCache, error)
  • func (pc *ProgramsCache) Get(blockID flow.Identifier) *programs.Programs
  • func (pc *ProgramsCache) Set(blockId flow.Identifier, programs *programs.Programs)
• type VirtualMachine

Constants

const DefaultProgramsCacheSize = 1000

Variables

var DefaultScriptLogThreshold = 1 * time.Second

Types

type ComputationManager

type ComputationManager interface {
	ExecuteScript([]byte, [][]byte, *flow.Header, state.View) ([]byte, error)
	ComputeBlock(
		ctx context.Context,
		block *entity.ExecutableBlock,
		view state.View,
	) (*execution.ComputationResult, error)
	GetAccount(addr flow.Address, header *flow.Header, view state.View) (*flow.Account, error)
}

type Manager

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

Manager manages computation and execution

func New

func New(
	logger zerolog.Logger,
	metrics module.ExecutionMetrics,
	tracer module.Tracer,
	me module.Local,
	protoState protocol.State,
	vm VirtualMachine,
	vmCtx fvm.Context,
	programsCacheSize uint,
	committer computer.ViewCommitter,
	scriptLogThreshold time.Duration,
	uploader uploader.Uploader,
) (*Manager, error)

func (*Manager) ComputeBlock

func (e *Manager) ComputeBlock(
	ctx context.Context,
	block *entity.ExecutableBlock,
	view state.View,
) (*execution.ComputationResult, error)

func (*Manager) ExecuteScript

func (e *Manager) ExecuteScript(code []byte, arguments [][]byte, blockHeader *flow.Header, view state.View) ([]byte, error)

func (*Manager) GetAccount

func (e *Manager) GetAccount(address flow.Address, blockHeader *flow.Header, view state.View) (*flow.Account, error)

type ProgramsCache

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

func NewProgramsCache

func NewProgramsCache(size uint) (*ProgramsCache, error)

func (*ProgramsCache) Get

func (pc *ProgramsCache) Get(blockID flow.Identifier) *programs.Programs

func (*ProgramsCache) Set

func (pc *ProgramsCache) Set(blockId flow.Identifier, programs *programs.Programs)

type VirtualMachine

type VirtualMachine interface {
	Run(fvm.Context, fvm.Procedure, state.View, *programs.Programs) error
	GetAccount(fvm.Context, flow.Address, state.View, *programs.Programs) (*flow.Account, error)
}