provider

package
v0.42.4-pebble.3 Latest Latest
Warning

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

 Go to latest Published: Sep 3, 2025 License: AGPL-3.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AccountProvider 

type AccountProvider interface {
	GetAccountAtBlock(ctx context.Context, address flow.Address, blockID flow.Identifier, height uint64) (*flow.Account, error)
	GetAccountBalanceAtBlock(ctx context.Context, address flow.Address, blockID flow.Identifier, height uint64) (uint64, error)
	GetAccountKeyAtBlock(ctx context.Context, address flow.Address, keyIndex uint32, blockID flow.Identifier, height uint64) (*flow.AccountPublicKey, error)
	GetAccountKeysAtBlock(ctx context.Context, address flow.Address, blockID flow.Identifier, height uint64) ([]flow.AccountPublicKey, error)
}

type ComparingAccountProvider 

type ComparingAccountProvider struct {
	FailoverAccountProvider
}

func NewComparingAccountProvider 

func NewComparingAccountProvider(
	log zerolog.Logger,
	state protocol.State,
	localRequester AccountProvider,
	execNodeRequester AccountProvider,
) *ComparingAccountProvider

func (*ComparingAccountProvider) GetAccountAtBlock 

func (c *ComparingAccountProvider) GetAccountAtBlock(
	ctx context.Context,
	address flow.Address,
	blockID flow.Identifier,
	height uint64,
) (*flow.Account, error)

type ENAccountProvider 

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

func NewENAccountProvider 

func NewENAccountProvider(
	log zerolog.Logger,
	state protocol.State,
	connFactory connection.ConnectionFactory,
	nodeCommunicator node_communicator.Communicator,
	execNodeIdentityProvider *rpc.ExecutionNodeIdentitiesProvider,
) *ENAccountProvider

func (*ENAccountProvider) GetAccountAtBlock 

func (e *ENAccountProvider) GetAccountAtBlock(
	ctx context.Context,
	address flow.Address,
	blockID flow.Identifier,
	_ uint64,
) (*flow.Account, error)

func (*ENAccountProvider) GetAccountBalanceAtBlock 

func (e *ENAccountProvider) GetAccountBalanceAtBlock(
	ctx context.Context,
	address flow.Address,
	blockID flow.Identifier,
	height uint64,
) (uint64, error)

func (*ENAccountProvider) GetAccountKeyAtBlock 

func (e *ENAccountProvider) GetAccountKeyAtBlock(
	ctx context.Context,
	address flow.Address,
	keyIndex uint32,
	blockID flow.Identifier,
	height uint64,
) (*flow.AccountPublicKey, error)

func (*ENAccountProvider) GetAccountKeysAtBlock 

func (e *ENAccountProvider) GetAccountKeysAtBlock(
	ctx context.Context,
	address flow.Address,
	blockID flow.Identifier,
	height uint64,
) ([]flow.AccountPublicKey, error)

type FailoverAccountProvider 

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

func NewFailoverAccountProvider 

func NewFailoverAccountProvider(
	log zerolog.Logger,
	state protocol.State,
	localRequester AccountProvider,
	execNodeRequester AccountProvider,
) *FailoverAccountProvider

func (*FailoverAccountProvider) GetAccountAtBlock 

func (f *FailoverAccountProvider) GetAccountAtBlock(
	ctx context.Context,
	address flow.Address,
	blockID flow.Identifier,
	height uint64,
) (*flow.Account, error)

func (*FailoverAccountProvider) GetAccountBalanceAtBlock 

func (f *FailoverAccountProvider) GetAccountBalanceAtBlock(
	ctx context.Context,
	address flow.Address,
	blockID flow.Identifier,
	height uint64,
) (uint64, error)

func (*FailoverAccountProvider) GetAccountKeyAtBlock 

func (f *FailoverAccountProvider) GetAccountKeyAtBlock(
	ctx context.Context,
	address flow.Address,
	keyIndex uint32,
	blockID flow.Identifier,
	height uint64,
) (*flow.AccountPublicKey, error)

func (*FailoverAccountProvider) GetAccountKeysAtBlock 

func (f *FailoverAccountProvider) GetAccountKeysAtBlock(
	ctx context.Context,
	address flow.Address,
	blockID flow.Identifier,
	height uint64,
) ([]flow.AccountPublicKey, error)

type LocalAccountProvider 

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

func NewLocalAccountProvider 

func NewLocalAccountProvider(
	log zerolog.Logger,
	state protocol.State,
	scriptExecutor execution.ScriptExecutor,
) *LocalAccountProvider

func (*LocalAccountProvider) GetAccountAtBlock 

func (l *LocalAccountProvider) GetAccountAtBlock(
	ctx context.Context,
	address flow.Address,
	_ flow.Identifier,
	height uint64,
) (*flow.Account, error)

func (*LocalAccountProvider) GetAccountBalanceAtBlock 

func (l *LocalAccountProvider) GetAccountBalanceAtBlock(
	ctx context.Context,
	address flow.Address,
	blockID flow.Identifier,
	height uint64,
) (uint64, error)

func (*LocalAccountProvider) GetAccountKeyAtBlock 

func (l *LocalAccountProvider) GetAccountKeyAtBlock(
	ctx context.Context,
	address flow.Address,
	keyIndex uint32,
	_ flow.Identifier,
	height uint64,
) (*flow.AccountPublicKey, error)

func (*LocalAccountProvider) GetAccountKeysAtBlock 

func (l *LocalAccountProvider) GetAccountKeysAtBlock(
	ctx context.Context,
	address flow.Address,
	_ flow.Identifier,
	height uint64,
) ([]flow.AccountPublicKey, error)

Source Files

View all Source files

Directories

Path Synopsis

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.