computation

package
v0.24.4-one-receipt Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 14, 2022 License: AGPL-3.0 Imports: 23 Imported by: 6

Documentation

Index

Constants

View Source 
const DefaultProgramsCacheSize = 1000
View Source 
const MaxScriptErrorMessageSize = 1000 // 1000 chars

Variables

View Source 
var DefaultScriptLogThreshold = 1 * time.Second

Functions

This section is empty.

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,
	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(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 added in v0.14.6 

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

func NewProgramsCache added in v0.14.6 

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

func (*ProgramsCache) Get added in v0.14.6 

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

func (*ProgramsCache) Set added in v0.14.6 

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)
}

Source Files

View all Source files

Directories

Path Synopsis
mock
uploader

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.