Versions in this module Expand all Collapse all v1 v1.9.8 Jun 28, 2023 Changes in this version + type Builder interface + BuildStopVtx func(ctx context.Context, parentIDs []ids.ID) (avalanche.Vertex, error) + BuildVtx func(ctx context.Context, parentIDs []ids.ID, txs []snowstorm.Tx) (avalanche.Vertex, error) + type DAGVM interface + Linearize func(ctx context.Context, stopVertexID ids.ID) error + ParseTx func(ctx context.Context, txBytes []byte) (snowstorm.Tx, error) + PendingTxs func(ctx context.Context) []snowstorm.Tx + type Getter interface + GetTx func(ctx context.Context, txID ids.ID) (snowstorm.Tx, error) + type Heap interface + Clear func() + Contains func(ids.ID) bool + Len func() int + Pop func() avalanche.Vertex + Push func(avalanche.Vertex) bool + func NewHeap() Heap + type Manager interface + type MockDAGVM struct + func NewMockDAGVM(ctrl *gomock.Controller) *MockDAGVM + func (m *MockDAGVM) AppGossip(arg0 context.Context, arg1 ids.NodeID, arg2 []byte) error + func (m *MockDAGVM) AppRequest(arg0 context.Context, arg1 ids.NodeID, arg2 uint32, arg3 time.Time, ...) error + func (m *MockDAGVM) AppRequestFailed(arg0 context.Context, arg1 ids.NodeID, arg2 uint32) error + func (m *MockDAGVM) AppResponse(arg0 context.Context, arg1 ids.NodeID, arg2 uint32, arg3 []byte) error + func (m *MockDAGVM) BuildBlock(arg0 context.Context) (snowman.Block, error) + func (m *MockDAGVM) Connected(arg0 context.Context, arg1 ids.NodeID, arg2 *version.Application) error + func (m *MockDAGVM) CreateHandlers(arg0 context.Context) (map[string]*common.HTTPHandler, error) + func (m *MockDAGVM) CreateStaticHandlers(arg0 context.Context) (map[string]*common.HTTPHandler, error) + func (m *MockDAGVM) CrossChainAppRequest(arg0 context.Context, arg1 ids.ID, arg2 uint32, arg3 time.Time, arg4 []byte) error + func (m *MockDAGVM) CrossChainAppRequestFailed(arg0 context.Context, arg1 ids.ID, arg2 uint32) error + func (m *MockDAGVM) CrossChainAppResponse(arg0 context.Context, arg1 ids.ID, arg2 uint32, arg3 []byte) error + func (m *MockDAGVM) Disconnected(arg0 context.Context, arg1 ids.NodeID) error + func (m *MockDAGVM) EXPECT() *MockDAGVMMockRecorder + func (m *MockDAGVM) GetBlock(arg0 context.Context, arg1 ids.ID) (snowman.Block, error) + func (m *MockDAGVM) GetTx(arg0 context.Context, arg1 ids.ID) (snowstorm.Tx, error) + func (m *MockDAGVM) HealthCheck(arg0 context.Context) (interface{}, error) + func (m *MockDAGVM) Initialize(arg0 context.Context, arg1 *snow.Context, arg2 manager.Manager, ...) error + func (m *MockDAGVM) LastAccepted(arg0 context.Context) (ids.ID, error) + func (m *MockDAGVM) Linearize(arg0 context.Context, arg1 ids.ID) error + func (m *MockDAGVM) ParseBlock(arg0 context.Context, arg1 []byte) (snowman.Block, error) + func (m *MockDAGVM) ParseTx(arg0 context.Context, arg1 []byte) (snowstorm.Tx, error) + func (m *MockDAGVM) PendingTxs(arg0 context.Context) []snowstorm.Tx + func (m *MockDAGVM) SetPreference(arg0 context.Context, arg1 ids.ID) error + func (m *MockDAGVM) SetState(arg0 context.Context, arg1 snow.State) error + func (m *MockDAGVM) Shutdown(arg0 context.Context) error + func (m *MockDAGVM) Version(arg0 context.Context) (string, error) + type MockDAGVMMockRecorder struct + func (mr *MockDAGVMMockRecorder) AppGossip(arg0, arg1, arg2 interface{}) *gomock.Call + func (mr *MockDAGVMMockRecorder) AppRequest(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call + func (mr *MockDAGVMMockRecorder) AppRequestFailed(arg0, arg1, arg2 interface{}) *gomock.Call + func (mr *MockDAGVMMockRecorder) AppResponse(arg0, arg1, arg2, arg3 interface{}) *gomock.Call + func (mr *MockDAGVMMockRecorder) BuildBlock(arg0 interface{}) *gomock.Call + func (mr *MockDAGVMMockRecorder) Connected(arg0, arg1, arg2 interface{}) *gomock.Call + func (mr *MockDAGVMMockRecorder) CreateHandlers(arg0 interface{}) *gomock.Call + func (mr *MockDAGVMMockRecorder) CreateStaticHandlers(arg0 interface{}) *gomock.Call + func (mr *MockDAGVMMockRecorder) CrossChainAppRequest(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call + func (mr *MockDAGVMMockRecorder) CrossChainAppRequestFailed(arg0, arg1, arg2 interface{}) *gomock.Call + func (mr *MockDAGVMMockRecorder) CrossChainAppResponse(arg0, arg1, arg2, arg3 interface{}) *gomock.Call + func (mr *MockDAGVMMockRecorder) Disconnected(arg0, arg1 interface{}) *gomock.Call + func (mr *MockDAGVMMockRecorder) GetBlock(arg0, arg1 interface{}) *gomock.Call + func (mr *MockDAGVMMockRecorder) GetTx(arg0, arg1 interface{}) *gomock.Call + func (mr *MockDAGVMMockRecorder) HealthCheck(arg0 interface{}) *gomock.Call + func (mr *MockDAGVMMockRecorder) Initialize(arg0, arg1, arg2, arg3, arg4, arg5, arg6, arg7, arg8 interface{}) *gomock.Call + func (mr *MockDAGVMMockRecorder) LastAccepted(arg0 interface{}) *gomock.Call + func (mr *MockDAGVMMockRecorder) Linearize(arg0, arg1 interface{}) *gomock.Call + func (mr *MockDAGVMMockRecorder) ParseBlock(arg0, arg1 interface{}) *gomock.Call + func (mr *MockDAGVMMockRecorder) ParseTx(arg0, arg1 interface{}) *gomock.Call + func (mr *MockDAGVMMockRecorder) PendingTxs(arg0 interface{}) *gomock.Call + func (mr *MockDAGVMMockRecorder) SetPreference(arg0, arg1 interface{}) *gomock.Call + func (mr *MockDAGVMMockRecorder) SetState(arg0, arg1 interface{}) *gomock.Call + func (mr *MockDAGVMMockRecorder) Shutdown(arg0 interface{}) *gomock.Call + func (mr *MockDAGVMMockRecorder) Version(arg0 interface{}) *gomock.Call + type Parser interface + ParseVtx func(ctx context.Context, vertex []byte) (avalanche.Vertex, error) + type StatelessVertex interface + Bytes func() []byte + ChainID func() ids.ID + Epoch func() uint32 + Height func() uint64 + ID func() ids.ID + ParentIDs func() []ids.ID + StopVertex func() bool + Txs func() [][]byte + Version func() uint16 + func Build(chainID ids.ID, height uint64, parentIDs []ids.ID, txs [][]byte) (StatelessVertex, error) + func BuildStopVertex(chainID ids.ID, height uint64, parentIDs []ids.ID) (StatelessVertex, error) + func Parse(bytes []byte) (StatelessVertex, error) + type Storage interface + Edge func(ctx context.Context) (vtxIDs []ids.ID) + GetVtx func(ctx context.Context, vtxID ids.ID) (avalanche.Vertex, error) + StopVertexAccepted func(ctx context.Context) (bool, error) + type TestBuilder struct + BuildStopVtxF func(ctx context.Context, parentIDs []ids.ID) (avalanche.Vertex, error) + BuildVtxF func(ctx context.Context, parentIDs []ids.ID, txs []snowstorm.Tx) (avalanche.Vertex, error) + CantBuildVtx bool + T *testing.T + func (b *TestBuilder) BuildStopVtx(ctx context.Context, parentIDs []ids.ID) (avalanche.Vertex, error) + func (b *TestBuilder) BuildVtx(ctx context.Context, parentIDs []ids.ID, txs []snowstorm.Tx) (avalanche.Vertex, error) + func (b *TestBuilder) Default(cant bool) + type TestManager struct + func NewTestManager(t *testing.T) *TestManager + func (m *TestManager) Default(cant bool) + type TestParser struct + CantParseVtx bool + ParseVtxF func(context.Context, []byte) (avalanche.Vertex, error) + T *testing.T + func (p *TestParser) Default(cant bool) + func (p *TestParser) ParseVtx(ctx context.Context, b []byte) (avalanche.Vertex, error) + type TestStorage struct + CantEdge bool + CantGetVtx bool + CantStopVertexAccepted bool + EdgeF func(context.Context) []ids.ID + GetVtxF func(context.Context, ids.ID) (avalanche.Vertex, error) + StopVertexAcceptedF func(context.Context) (bool, error) + T *testing.T + func (s *TestStorage) Default(cant bool) + func (s *TestStorage) Edge(ctx context.Context) []ids.ID + func (s *TestStorage) GetVtx(ctx context.Context, vtxID ids.ID) (avalanche.Vertex, error) + func (s *TestStorage) StopVertexAccepted(ctx context.Context) (bool, error) + type TestVM struct + CantGet bool + CantLinearize bool + CantParse bool + CantPendingTxs bool + GetTxF func(context.Context, ids.ID) (snowstorm.Tx, error) + LinearizeF func(context.Context, ids.ID) error + ParseTxF func(context.Context, []byte) (snowstorm.Tx, error) + PendingTxsF func(context.Context) []snowstorm.Tx + func (vm *TestVM) Default(cant bool) + func (vm *TestVM) GetTx(ctx context.Context, txID ids.ID) (snowstorm.Tx, error) + func (vm *TestVM) Linearize(ctx context.Context, stopVertexID ids.ID) error + func (vm *TestVM) ParseTx(ctx context.Context, b []byte) (snowstorm.Tx, error) + func (vm *TestVM) PendingTxs(ctx context.Context) []snowstorm.Tx v1.9.8-rc.9 Jun 28, 2023
Go to main page