computation

Documentation

Index

• Constants
• Variables
• func SetUploaderEnabled(enabled bool)
• 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(ctx context.Context, code []byte, arguments [][]byte, blockHeader *flow.Header, ...) ([]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

const MaxScriptErrorMessageSize = 1000 // 1000 chars

Variables

var DefaultScriptExecutionTimeLimit = 10 * time.Second

var DefaultScriptLogThreshold = 1 * time.Second

Functions

func SetUploaderEnabled

func SetUploaderEnabled(enabled bool)

Types

type ComputationManager

type ComputationManager interface {
	ExecuteScript(context.Context, []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,
	scriptExecutionTimeLimit time.Duration,
	uploaders []uploader.Uploader,
	eds state_synchronization.ExecutionDataService,
	edCache state_synchronization.ExecutionDataCIDCache,
) (*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(
	ctx context.Context,
	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)
}