integration_test

package
v2.4.0 Latest Latest
Warning

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

 Go to latest Published: Aug 14, 2024 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewUniqueAddressGenerator added in v2.4.0 

func NewUniqueAddressGenerator() uniqueAddressGenerator

Types

type GetLatestBlockDataWrapper added in v2.4.0 

type GetLatestBlockDataWrapper func(rpcprovider.ReliabilityManagerInf, int64, int64, int64) (int64, []*chaintracker.BlockStore, time.Time, error)

type MockChainFetcher 

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

func NewMockChainFetcher 

func NewMockChainFetcher(startBlock, blocksToSave int64, callback func()) *MockChainFetcher

func (*MockChainFetcher) AdvanceBlock 

func (mcf *MockChainFetcher) AdvanceBlock() int64

func (*MockChainFetcher) FetchBlockHashByNum 

func (mcf *MockChainFetcher) FetchBlockHashByNum(ctx context.Context, blockNum int64) (string, error)

func (*MockChainFetcher) FetchChainID 

func (mcf *MockChainFetcher) FetchChainID(ctx context.Context) (string, string, error)

func (*MockChainFetcher) FetchEndpoint 

func (mcf *MockChainFetcher) FetchEndpoint() lavasession.RPCProviderEndpoint

func (*MockChainFetcher) FetchLatestBlockNum 

func (mcf *MockChainFetcher) FetchLatestBlockNum(ctx context.Context) (int64, error)

func (*MockChainFetcher) Fork 

func (mcf *MockChainFetcher) Fork(fork string)

func (*MockChainFetcher) IsCorrectHash 

func (mcf *MockChainFetcher) IsCorrectHash(hash string, hashBlock int64) bool

func (*MockChainFetcher) SetBlock 

func (mcf *MockChainFetcher) SetBlock(latestBlock int64)

func (*MockChainFetcher) Shrink 

func (mcf *MockChainFetcher) Shrink(newSize int)

type MockReliabilityManager added in v2.4.0 

type MockReliabilityManager struct {
	ReliabilityManager rpcprovider.ReliabilityManagerInf
	// contains filtered or unexported fields
}

func NewMockReliabilityManager added in v2.4.0 

func NewMockReliabilityManager(reliabilityManager rpcprovider.ReliabilityManagerInf) *MockReliabilityManager

func (*MockReliabilityManager) GetLatestBlockData added in v2.4.0 

func (mrm *MockReliabilityManager) GetLatestBlockData(fromBlock, toBlock, specificBlock int64) (latestBlock int64, requestedHashes []*chaintracker.BlockStore, changeTime time.Time, err error)

func (*MockReliabilityManager) GetLatestBlockNum added in v2.4.0 

func (mrm *MockReliabilityManager) GetLatestBlockNum() (int64, time.Time)

func (*MockReliabilityManager) SetGetLatestBlockDataWrapper added in v2.4.0 

func (mrm *MockReliabilityManager) SetGetLatestBlockDataWrapper(wrapper GetLatestBlockDataWrapper)

type ReplySetter 

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

type TxConflictDetectionMock added in v2.4.0 

type TxConflictDetectionMock func(context.Context, *conflicttypes.FinalizationConflict, *conflicttypes.ResponseConflict, common.ConflictHandlerInterface) error

Source Files

View all Source files

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.