onflow

package

v1.3.1 Latest Latest Go to latest Published: Feb 23, 2026 License: Apache-2.0 Imports: 31 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/piprate/metalocker

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func BlockFromCadence(val cadence.Value) (*model.Block, error)
func BlockRecordsFromCadence(val cadence.Value) ([][]string, error)
func CreateLedgerConnector(ctx context.Context, params ledger.Parameters, ns notification.Service, ...) (model.Ledger, error)
func InstallLedgerSchema(bc *utils.BoltClient) error
func NewInMemoryConnectorEmbedded(enableTxFees bool) (*splash.Connector, error)
func NewNetworkConnectorEmbedded(network string) (*splash.Connector, error)
func NewTemplateEngine(client *splash.Connector) (*splash.TemplateEngine, error)
func RecordFromCadence(val cadence.Value) (*model.Record, error)
func RecordToCadence(rec *model.Record, contractAddr flow.Address) cadence.Value
type Ledger
- func NewLedger(ctx context.Context, connector *splash.Connector, network string, ...) (*Ledger, error)

Constants ¶

View Source

const (
	BlocksKey       = "blocks"
	BlockRecordsKey = "block_records"
	RecordsKey      = "records"
	ControlsKey     = "controls"

	GenesisBlockHeightKey = "genesis_block_height"
	TopFlowBlockHeightKey = "top_flow_block_height"
	TopBlockNumberKey     = "top_block_number"
)

Variables ¶

This section is empty.

Functions ¶

func BlockFromCadence ¶

func BlockFromCadence(val cadence.Value) (*model.Block, error)

func BlockRecordsFromCadence ¶

func BlockRecordsFromCadence(val cadence.Value) ([][]string, error)

func CreateLedgerConnector ¶

func CreateLedgerConnector(ctx context.Context, params ledger.Parameters, ns notification.Service, resolver cmdbase.ParameterResolver) (model.Ledger, error)

func InstallLedgerSchema ¶

func InstallLedgerSchema(bc *utils.BoltClient) error

func NewInMemoryConnectorEmbedded ¶

func NewInMemoryConnectorEmbedded(enableTxFees bool) (*splash.Connector, error)

NewInMemoryConnectorEmbedded creates a new Splash Connector for in-memory emulator that uses embedded Flow configuration.

func NewNetworkConnectorEmbedded ¶

func NewNetworkConnectorEmbedded(network string) (*splash.Connector, error)

NewNetworkConnectorEmbedded creates a new Splash Connector that uses embedded Flow configuration.

func NewTemplateEngine ¶

func NewTemplateEngine(client *splash.Connector) (*splash.TemplateEngine, error)

func RecordFromCadence ¶

func RecordFromCadence(val cadence.Value) (*model.Record, error)

func RecordToCadence ¶

func RecordToCadence(rec *model.Record, contractAddr flow.Address) cadence.Value

Types ¶

type Ledger ¶

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

func NewLedger ¶

func NewLedger(ctx context.Context, connector *splash.Connector, network string, nodeAcct *accounts.Account, keyIndexList []uint32, dbFilePath string, ns notification.Service) (*Ledger, error)

func (*Ledger) Close ¶

func (l *Ledger) Close() error

func (*Ledger) GetAssetHead ¶

func (l *Ledger) GetAssetHead(ctx context.Context, headID string) (*model.Record, error)

func (*Ledger) GetBlock ¶

func (l *Ledger) GetBlock(ctx context.Context, bn uint64) (*model.Block, error)

func (*Ledger) GetBlockRecords ¶

func (l *Ledger) GetBlockRecords(ctx context.Context, bn uint64) ([][]string, error)

func (*Ledger) GetChain ¶

func (l *Ledger) GetChain(ctx context.Context, startNumber uint64, depth int) ([]*model.Block, error)

func (*Ledger) GetDataAssetState ¶

func (l *Ledger) GetDataAssetState(ctx context.Context, id string) (model.DataAssetState, error)

func (*Ledger) GetGenesisBlock ¶

func (l *Ledger) GetGenesisBlock(ctx context.Context) (*model.Block, error)

func (*Ledger) GetRecord ¶

func (l *Ledger) GetRecord(ctx context.Context, rid string) (*model.Record, error)

func (*Ledger) GetRecordState ¶

func (l *Ledger) GetRecordState(ctx context.Context, rid string) (*model.RecordState, error)

func (*Ledger) GetTopBlock ¶

func (l *Ledger) GetTopBlock(ctx context.Context) (*model.Block, error)

func (*Ledger) ImportBlock ¶

func (l *Ledger) ImportBlock(ctx context.Context, blockNumber uint64, records []*model.Record) error

func (*Ledger) StartLedgerEvents ¶

func (l *Ledger) StartLedgerEvents(ctx context.Context, syncOnStart bool, syncInterval time.Duration) error

func (*Ledger) StopContinuousSync ¶

func (l *Ledger) StopContinuousSync()

func (*Ledger) SubmitRecord ¶

func (l *Ledger) SubmitRecord(ctx context.Context, r *model.Record) error

func (*Ledger) Sync ¶

func (l *Ledger) Sync(ctx context.Context) error

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
emulator

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL