Versions in this module Expand all Collapse all v1 v1.11.13-rc.2 Dec 4, 2024 v1.0.0 Dec 4, 2024 Changes in this version + var ErrRemoteVMNotImplemented = errors.New("vm does not implement RemoteVM interface") + var ErrStateSyncableVMNotImplemented = errors.New("vm does not implement StateSyncableVM interface") + func BatchedParseBlock(ctx context.Context, vm Parser, blks [][]byte) ([]snowman.Block, error) + func GetAncestors(ctx context.Context, log logging.Logger, vm Getter, blkID ids.ID, ...) ([][]byte, error) + type BatchedChainVM interface + BatchedParseBlock func(ctx context.Context, blks [][]byte) ([]snowman.Block, error) + GetAncestors func(ctx context.Context, blkID ids.ID, maxBlocksNum int, maxBlocksSize int, ...) ([][]byte, error) + type BuildBlockWithContextChainVM interface + BuildBlockWithContext func(ctx context.Context, blockCtx *Context) (snowman.Block, error) + type ChainVM interface + BuildBlock func(context.Context) (snowman.Block, error) + GetBlockIDAtHeight func(ctx context.Context, height uint64) (ids.ID, error) + LastAccepted func(context.Context) (ids.ID, error) + SetPreference func(ctx context.Context, blkID ids.ID) error + type Context struct + PChainHeight uint64 + type Getter interface + GetBlock func(ctx context.Context, blkID ids.ID) (snowman.Block, error) + type MockBuildBlockWithContextChainVM struct + func NewMockBuildBlockWithContextChainVM(ctrl *gomock.Controller) *MockBuildBlockWithContextChainVM + func (m *MockBuildBlockWithContextChainVM) BuildBlockWithContext(arg0 context.Context, arg1 *Context) (snowman.Block, error) + func (m *MockBuildBlockWithContextChainVM) EXPECT() *MockBuildBlockWithContextChainVMMockRecorder + type MockBuildBlockWithContextChainVMMockRecorder struct + func (mr *MockBuildBlockWithContextChainVMMockRecorder) BuildBlockWithContext(arg0, arg1 any) *gomock.Call + type MockChainVM struct + func NewMockChainVM(ctrl *gomock.Controller) *MockChainVM + func (m *MockChainVM) AppGossip(arg0 context.Context, arg1 ids.NodeID, arg2 []byte) error + func (m *MockChainVM) AppRequest(arg0 context.Context, arg1 ids.NodeID, arg2 uint32, arg3 time.Time, ...) error + func (m *MockChainVM) AppRequestFailed(arg0 context.Context, arg1 ids.NodeID, arg2 uint32, arg3 *common.AppError) error + func (m *MockChainVM) AppResponse(arg0 context.Context, arg1 ids.NodeID, arg2 uint32, arg3 []byte) error + func (m *MockChainVM) BuildBlock(arg0 context.Context) (snowman.Block, error) + func (m *MockChainVM) Connected(arg0 context.Context, arg1 ids.NodeID, arg2 *version.Application) error + func (m *MockChainVM) CreateHandlers(arg0 context.Context) (map[string]http.Handler, error) + func (m *MockChainVM) CrossChainAppRequest(arg0 context.Context, arg1 ids.ID, arg2 uint32, arg3 time.Time, arg4 []byte) error + func (m *MockChainVM) CrossChainAppRequestFailed(arg0 context.Context, arg1 ids.ID, arg2 uint32, arg3 *common.AppError) error + func (m *MockChainVM) CrossChainAppResponse(arg0 context.Context, arg1 ids.ID, arg2 uint32, arg3 []byte) error + func (m *MockChainVM) Disconnected(arg0 context.Context, arg1 ids.NodeID) error + func (m *MockChainVM) EXPECT() *MockChainVMMockRecorder + func (m *MockChainVM) GetBlock(arg0 context.Context, arg1 ids.ID) (snowman.Block, error) + func (m *MockChainVM) GetBlockIDAtHeight(arg0 context.Context, arg1 uint64) (ids.ID, error) + func (m *MockChainVM) HealthCheck(arg0 context.Context) (any, error) + func (m *MockChainVM) Initialize(arg0 context.Context, arg1 *snow.Context, arg2 database.Database, ...) error + func (m *MockChainVM) LastAccepted(arg0 context.Context) (ids.ID, error) + func (m *MockChainVM) ParseBlock(arg0 context.Context, arg1 []byte) (snowman.Block, error) + func (m *MockChainVM) SetPreference(arg0 context.Context, arg1 ids.ID) error + func (m *MockChainVM) SetState(arg0 context.Context, arg1 snow.State) error + func (m *MockChainVM) Shutdown(arg0 context.Context) error + func (m *MockChainVM) Version(arg0 context.Context) (string, error) + type MockChainVMMockRecorder struct + func (mr *MockChainVMMockRecorder) AppGossip(arg0, arg1, arg2 any) *gomock.Call + func (mr *MockChainVMMockRecorder) AppRequest(arg0, arg1, arg2, arg3, arg4 any) *gomock.Call + func (mr *MockChainVMMockRecorder) AppRequestFailed(arg0, arg1, arg2, arg3 any) *gomock.Call + func (mr *MockChainVMMockRecorder) AppResponse(arg0, arg1, arg2, arg3 any) *gomock.Call + func (mr *MockChainVMMockRecorder) BuildBlock(arg0 any) *gomock.Call + func (mr *MockChainVMMockRecorder) Connected(arg0, arg1, arg2 any) *gomock.Call + func (mr *MockChainVMMockRecorder) CreateHandlers(arg0 any) *gomock.Call + func (mr *MockChainVMMockRecorder) CrossChainAppRequest(arg0, arg1, arg2, arg3, arg4 any) *gomock.Call + func (mr *MockChainVMMockRecorder) CrossChainAppRequestFailed(arg0, arg1, arg2, arg3 any) *gomock.Call + func (mr *MockChainVMMockRecorder) CrossChainAppResponse(arg0, arg1, arg2, arg3 any) *gomock.Call + func (mr *MockChainVMMockRecorder) Disconnected(arg0, arg1 any) *gomock.Call + func (mr *MockChainVMMockRecorder) GetBlock(arg0, arg1 any) *gomock.Call + func (mr *MockChainVMMockRecorder) GetBlockIDAtHeight(arg0, arg1 any) *gomock.Call + func (mr *MockChainVMMockRecorder) HealthCheck(arg0 any) *gomock.Call + func (mr *MockChainVMMockRecorder) Initialize(arg0, arg1, arg2, arg3, arg4, arg5, arg6, arg7, arg8 any) *gomock.Call + func (mr *MockChainVMMockRecorder) LastAccepted(arg0 any) *gomock.Call + func (mr *MockChainVMMockRecorder) ParseBlock(arg0, arg1 any) *gomock.Call + func (mr *MockChainVMMockRecorder) SetPreference(arg0, arg1 any) *gomock.Call + func (mr *MockChainVMMockRecorder) SetState(arg0, arg1 any) *gomock.Call + func (mr *MockChainVMMockRecorder) Shutdown(arg0 any) *gomock.Call + func (mr *MockChainVMMockRecorder) Version(arg0 any) *gomock.Call + type MockStateSyncableVM struct + func NewMockStateSyncableVM(ctrl *gomock.Controller) *MockStateSyncableVM + func (m *MockStateSyncableVM) EXPECT() *MockStateSyncableVMMockRecorder + func (m *MockStateSyncableVM) GetLastStateSummary(arg0 context.Context) (StateSummary, error) + func (m *MockStateSyncableVM) GetOngoingSyncStateSummary(arg0 context.Context) (StateSummary, error) + func (m *MockStateSyncableVM) GetStateSummary(arg0 context.Context, arg1 uint64) (StateSummary, error) + func (m *MockStateSyncableVM) ParseStateSummary(arg0 context.Context, arg1 []byte) (StateSummary, error) + func (m *MockStateSyncableVM) StateSyncEnabled(arg0 context.Context) (bool, error) + type MockStateSyncableVMMockRecorder struct + func (mr *MockStateSyncableVMMockRecorder) GetLastStateSummary(arg0 any) *gomock.Call + func (mr *MockStateSyncableVMMockRecorder) GetOngoingSyncStateSummary(arg0 any) *gomock.Call + func (mr *MockStateSyncableVMMockRecorder) GetStateSummary(arg0, arg1 any) *gomock.Call + func (mr *MockStateSyncableVMMockRecorder) ParseStateSummary(arg0, arg1 any) *gomock.Call + func (mr *MockStateSyncableVMMockRecorder) StateSyncEnabled(arg0 any) *gomock.Call + type MockWithVerifyContext struct + func NewMockWithVerifyContext(ctrl *gomock.Controller) *MockWithVerifyContext + func (m *MockWithVerifyContext) EXPECT() *MockWithVerifyContextMockRecorder + func (m *MockWithVerifyContext) ShouldVerifyWithContext(arg0 context.Context) (bool, error) + func (m *MockWithVerifyContext) VerifyWithContext(arg0 context.Context, arg1 *Context) error + type MockWithVerifyContextMockRecorder struct + func (mr *MockWithVerifyContextMockRecorder) ShouldVerifyWithContext(arg0 any) *gomock.Call + func (mr *MockWithVerifyContextMockRecorder) VerifyWithContext(arg0, arg1 any) *gomock.Call + type Parser interface + ParseBlock func(ctx context.Context, blockBytes []byte) (snowman.Block, error) + type StateSummary interface + Accept func(context.Context) (StateSyncMode, error) + Bytes func() []byte + Height func() uint64 + ID func() ids.ID + type StateSyncMode uint8 + const StateSyncDynamic + const StateSyncSkipped + const StateSyncStatic + func (s StateSyncMode) String() string + type StateSyncableVM interface + GetLastStateSummary func(context.Context) (StateSummary, error) + GetOngoingSyncStateSummary func(context.Context) (StateSummary, error) + GetStateSummary func(ctx context.Context, summaryHeight uint64) (StateSummary, error) + ParseStateSummary func(ctx context.Context, summaryBytes []byte) (StateSummary, error) + StateSyncEnabled func(context.Context) (bool, error) + type TestBatchedVM struct + BatchedParseBlockF func(ctx context.Context, blks [][]byte) ([]snowman.Block, error) + CantBatchParseBlock bool + CantGetAncestors bool + GetAncestorsF func(ctx context.Context, blkID ids.ID, maxBlocksNum int, maxBlocksSize int, ...) ([][]byte, error) + T *testing.T + func (vm *TestBatchedVM) BatchedParseBlock(ctx context.Context, blks [][]byte) ([]snowman.Block, error) + func (vm *TestBatchedVM) Default(cant bool) + func (vm *TestBatchedVM) GetAncestors(ctx context.Context, blkID ids.ID, maxBlocksNum int, maxBlocksSize int, ...) ([][]byte, error) + type TestStateSummary struct + AcceptF func(context.Context) (StateSyncMode, error) + BytesV []byte + CantAccept bool + HeightV uint64 + IDV ids.ID + T *testing.T + func (s *TestStateSummary) Accept(ctx context.Context) (StateSyncMode, error) + func (s *TestStateSummary) Bytes() []byte + func (s *TestStateSummary) Height() uint64 + func (s *TestStateSummary) ID() ids.ID + type TestStateSyncableVM struct + CantGetLastStateSummary bool + CantGetStateSummary bool + CantParseStateSummary bool + CantStateSyncEnabled bool + CantStateSyncGetOngoingSummary bool + GetLastStateSummaryF func(context.Context) (StateSummary, error) + GetOngoingSyncStateSummaryF func(context.Context) (StateSummary, error) + GetStateSummaryF func(ctx context.Context, summaryHeight uint64) (StateSummary, error) + ParseStateSummaryF func(ctx context.Context, summaryBytes []byte) (StateSummary, error) + StateSyncEnabledF func(context.Context) (bool, error) + T *testing.T + func (vm *TestStateSyncableVM) GetLastStateSummary(ctx context.Context) (StateSummary, error) + func (vm *TestStateSyncableVM) GetOngoingSyncStateSummary(ctx context.Context) (StateSummary, error) + func (vm *TestStateSyncableVM) GetStateSummary(ctx context.Context, summaryHeight uint64) (StateSummary, error) + func (vm *TestStateSyncableVM) ParseStateSummary(ctx context.Context, summaryBytes []byte) (StateSummary, error) + func (vm *TestStateSyncableVM) StateSyncEnabled(ctx context.Context) (bool, error) + type TestVM struct + BuildBlockF func(context.Context) (snowman.Block, error) + CantBuildBlock bool + CantGetBlock bool + CantGetBlockIDAtHeight bool + CantLastAccepted bool + CantParseBlock bool + CantSetPreference bool + GetBlockF func(context.Context, ids.ID) (snowman.Block, error) + GetBlockIDAtHeightF func(ctx context.Context, height uint64) (ids.ID, error) + LastAcceptedF func(context.Context) (ids.ID, error) + ParseBlockF func(context.Context, []byte) (snowman.Block, error) + SetPreferenceF func(context.Context, ids.ID) error + func (vm *TestVM) BuildBlock(ctx context.Context) (snowman.Block, error) + func (vm *TestVM) Default(cant bool) + func (vm *TestVM) GetBlock(ctx context.Context, id ids.ID) (snowman.Block, error) + func (vm *TestVM) GetBlockIDAtHeight(ctx context.Context, height uint64) (ids.ID, error) + func (vm *TestVM) LastAccepted(ctx context.Context) (ids.ID, error) + func (vm *TestVM) ParseBlock(ctx context.Context, b []byte) (snowman.Block, error) + func (vm *TestVM) SetPreference(ctx context.Context, id ids.ID) error + type WithVerifyContext interface + ShouldVerifyWithContext func(context.Context) (bool, error) + VerifyWithContext func(context.Context, *Context) error
Go to main page