integration_test

Documentation

Index

• func NewUniqueAddressGenerator() uniqueAddressGenerator
• type GetLatestBlockDataWrapper
• type MockChainFetcher
  • func NewMockChainFetcher(startBlock, blocksToSave int64, callback func()) *MockChainFetcher
  • func (mcf *MockChainFetcher) AdvanceBlock() int64
  • func (mcf *MockChainFetcher) FetchBlockHashByNum(ctx context.Context, blockNum int64) (string, error)
  • func (mcf *MockChainFetcher) FetchChainID(ctx context.Context) (string, string, error)
  • func (mcf *MockChainFetcher) FetchEndpoint() lavasession.RPCProviderEndpoint
  • func (mcf *MockChainFetcher) FetchLatestBlockNum(ctx context.Context) (int64, error)
  • func (mcf *MockChainFetcher) Fork(fork string)
  • func (mcf *MockChainFetcher) IsCorrectHash(hash string, hashBlock int64) bool
  • func (mcf *MockChainFetcher) SetBlock(latestBlock int64)
  • func (mcf *MockChainFetcher) Shrink(newSize int)
• type MockReliabilityManager
  • func NewMockReliabilityManager(reliabilityManager rpcprovider.ReliabilityManagerInf) *MockReliabilityManager
  • func (mrm *MockReliabilityManager) GetLatestBlockData(fromBlock, toBlock, specificBlock int64) (latestBlock int64, requestedHashes []*chaintracker.BlockStore, ...)
  • func (mrm *MockReliabilityManager) GetLatestBlockNum() (int64, time.Time)
  • func (mrm *MockReliabilityManager) SetGetLatestBlockDataWrapper(wrapper GetLatestBlockDataWrapper)
• type ReplySetter
• type TxConflictDetectionMock

Functions

func NewUniqueAddressGenerator

func NewUniqueAddressGenerator() uniqueAddressGenerator

Types

type GetLatestBlockDataWrapper

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

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

func NewMockReliabilityManager

func NewMockReliabilityManager(reliabilityManager rpcprovider.ReliabilityManagerInf) *MockReliabilityManager

func (*MockReliabilityManager) GetLatestBlockData

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

func (*MockReliabilityManager) GetLatestBlockNum

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

func (*MockReliabilityManager) SetGetLatestBlockDataWrapper

func (mrm *MockReliabilityManager) SetGetLatestBlockDataWrapper(wrapper GetLatestBlockDataWrapper)

type ReplySetter

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

type TxConflictDetectionMock

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