vertex

package
v1.9.1-rc.14 Latest Latest
Warning

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

 Go to latest Published: Oct 27, 2022 License: BSD-3-Clause Imports: 24 Imported by: 36

Documentation

Overview

Package vertex is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func IsSortedAndUniqueHashOf added in v1.1.1 

func IsSortedAndUniqueHashOf(bytesSlice [][]byte) bool

func SortHashOf added in v1.1.1 

func SortHashOf(bytesSlice [][]byte)

Types

type Builder added in v1.1.1 

type Builder interface {
	// Build a new vertex from the contents of a vertex
	BuildVtx(parentIDs []ids.ID, txs []snowstorm.Tx) (avalanche.Vertex, error)
	// Build a new stop vertex from the parents
	BuildStopVtx(parentIDs []ids.ID) (avalanche.Vertex, error)
}

Builder builds a vertex given a set of parentIDs and transactions.

type DAGVM 

type DAGVM interface {
	common.VM
	Getter

	// Return any transactions that have not been sent to consensus yet
	PendingTxs() []snowstorm.Tx

	// Convert a stream of bytes to a transaction or return an error
	ParseTx(tx []byte) (snowstorm.Tx, error)
}

DAGVM defines the minimum functionality that an avalanche VM must implement

type Getter added in v1.7.14 

type Getter interface {
	// Retrieve a transaction that was submitted previously
	GetTx(ids.ID) (snowstorm.Tx, error)
}

Getter defines the functionality for fetching a tx/block by its ID.

type Heap 

type Heap interface {
	// Empty the heap.
	Clear()

	// Add the provided vertex to the heap. Vertices are de-duplicated, returns
	// true if the vertex was added, false if it was dropped.
	Push(avalanche.Vertex) bool

	// Remove the top vertex. Assumes that there is at least one element.
	Pop() avalanche.Vertex

	// Returns if a vertex with the provided ID is currently in the heap.
	Contains(ids.ID) bool

	// Returns the number of vertices in the heap.
	Len() int
}

Heap defines the functionality of a heap of vertices with unique VertexIDs ordered by height

func NewHeap 

func NewHeap() Heap

NewHeap returns an empty Heap

type Manager 

type Manager interface {
	Builder
	Parser
	Storage
}

Manager defines all the vertex related functionality that is required by the consensus engine.

type MockDAGVM added in v1.9.1 

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

MockDAGVM is a mock of DAGVM interface.

func NewMockDAGVM added in v1.9.1 

func NewMockDAGVM(ctrl *gomock.Controller) *MockDAGVM

NewMockDAGVM creates a new mock instance.

func (*MockDAGVM) AppGossip added in v1.9.1 

func (m *MockDAGVM) AppGossip(arg0 context.Context, arg1 ids.NodeID, arg2 []byte) error

AppGossip mocks base method.

func (*MockDAGVM) AppRequest added in v1.9.1 

func (m *MockDAGVM) AppRequest(arg0 context.Context, arg1 ids.NodeID, arg2 uint32, arg3 time.Time, arg4 []byte) error

AppRequest mocks base method.

func (*MockDAGVM) AppRequestFailed added in v1.9.1 

func (m *MockDAGVM) AppRequestFailed(arg0 context.Context, arg1 ids.NodeID, arg2 uint32) error

AppRequestFailed mocks base method.

func (*MockDAGVM) AppResponse added in v1.9.1 

func (m *MockDAGVM) AppResponse(arg0 context.Context, arg1 ids.NodeID, arg2 uint32, arg3 []byte) error

AppResponse mocks base method.

func (*MockDAGVM) Connected added in v1.9.1 

func (m *MockDAGVM) Connected(arg0 ids.NodeID, arg1 *version.Application) error

Connected mocks base method.

func (*MockDAGVM) CreateHandlers added in v1.9.1 

func (m *MockDAGVM) CreateHandlers() (map[string]*common.HTTPHandler, error)

CreateHandlers mocks base method.

func (*MockDAGVM) CreateStaticHandlers added in v1.9.1 

func (m *MockDAGVM) CreateStaticHandlers() (map[string]*common.HTTPHandler, error)

CreateStaticHandlers mocks base method.

func (*MockDAGVM) CrossChainAppRequest added in v1.9.1 

func (m *MockDAGVM) CrossChainAppRequest(arg0 context.Context, arg1 ids.ID, arg2 uint32, arg3 time.Time, arg4 []byte) error

CrossChainAppRequest mocks base method.

func (*MockDAGVM) CrossChainAppRequestFailed added in v1.9.1 

func (m *MockDAGVM) CrossChainAppRequestFailed(arg0 context.Context, arg1 ids.ID, arg2 uint32) error

CrossChainAppRequestFailed mocks base method.

func (*MockDAGVM) CrossChainAppResponse added in v1.9.1 

func (m *MockDAGVM) CrossChainAppResponse(arg0 context.Context, arg1 ids.ID, arg2 uint32, arg3 []byte) error

CrossChainAppResponse mocks base method.

func (*MockDAGVM) Disconnected added in v1.9.1 

func (m *MockDAGVM) Disconnected(arg0 ids.NodeID) error

Disconnected mocks base method.

func (*MockDAGVM) EXPECT added in v1.9.1 

func (m *MockDAGVM) EXPECT() *MockDAGVMMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockDAGVM) GetTx added in v1.9.1 

func (m *MockDAGVM) GetTx(arg0 ids.ID) (snowstorm.Tx, error)

GetTx mocks base method.

func (*MockDAGVM) HealthCheck added in v1.9.1 

func (m *MockDAGVM) HealthCheck() (interface{}, error)

HealthCheck mocks base method.

func (*MockDAGVM) Initialize added in v1.9.1 

func (m *MockDAGVM) Initialize(arg0 *snow.Context, arg1 manager.Manager, arg2, arg3, arg4 []byte, arg5 chan<- common.Message, arg6 []*common.Fx, arg7 common.AppSender) error

Initialize mocks base method.

func (*MockDAGVM) ParseTx added in v1.9.1 

func (m *MockDAGVM) ParseTx(arg0 []byte) (snowstorm.Tx, error)

ParseTx mocks base method.

func (*MockDAGVM) PendingTxs added in v1.9.1 

func (m *MockDAGVM) PendingTxs() []snowstorm.Tx

PendingTxs mocks base method.

func (*MockDAGVM) SetState added in v1.9.1 

func (m *MockDAGVM) SetState(arg0 snow.State) error

SetState mocks base method.

func (*MockDAGVM) Shutdown added in v1.9.1 

func (m *MockDAGVM) Shutdown() error

Shutdown mocks base method.

func (*MockDAGVM) Version added in v1.9.1 

func (m *MockDAGVM) Version() (string, error)

Version mocks base method.

type MockDAGVMMockRecorder added in v1.9.1 

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

MockDAGVMMockRecorder is the mock recorder for MockDAGVM.

func (*MockDAGVMMockRecorder) AppGossip added in v1.9.1 

func (mr *MockDAGVMMockRecorder) AppGossip(arg0, arg1, arg2 interface{}) *gomock.Call

AppGossip indicates an expected call of AppGossip.

func (*MockDAGVMMockRecorder) AppRequest added in v1.9.1 

func (mr *MockDAGVMMockRecorder) AppRequest(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call

AppRequest indicates an expected call of AppRequest.

func (*MockDAGVMMockRecorder) AppRequestFailed added in v1.9.1 

func (mr *MockDAGVMMockRecorder) AppRequestFailed(arg0, arg1, arg2 interface{}) *gomock.Call

AppRequestFailed indicates an expected call of AppRequestFailed.

func (*MockDAGVMMockRecorder) AppResponse added in v1.9.1 

func (mr *MockDAGVMMockRecorder) AppResponse(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

AppResponse indicates an expected call of AppResponse.

func (*MockDAGVMMockRecorder) Connected added in v1.9.1 

func (mr *MockDAGVMMockRecorder) Connected(arg0, arg1 interface{}) *gomock.Call

Connected indicates an expected call of Connected.

func (*MockDAGVMMockRecorder) CreateHandlers added in v1.9.1 

func (mr *MockDAGVMMockRecorder) CreateHandlers() *gomock.Call

CreateHandlers indicates an expected call of CreateHandlers.

func (*MockDAGVMMockRecorder) CreateStaticHandlers added in v1.9.1 

func (mr *MockDAGVMMockRecorder) CreateStaticHandlers() *gomock.Call

CreateStaticHandlers indicates an expected call of CreateStaticHandlers.

func (*MockDAGVMMockRecorder) CrossChainAppRequest added in v1.9.1 

func (mr *MockDAGVMMockRecorder) CrossChainAppRequest(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call

CrossChainAppRequest indicates an expected call of CrossChainAppRequest.

func (*MockDAGVMMockRecorder) CrossChainAppRequestFailed added in v1.9.1 

func (mr *MockDAGVMMockRecorder) CrossChainAppRequestFailed(arg0, arg1, arg2 interface{}) *gomock.Call

CrossChainAppRequestFailed indicates an expected call of CrossChainAppRequestFailed.

func (*MockDAGVMMockRecorder) CrossChainAppResponse added in v1.9.1 

func (mr *MockDAGVMMockRecorder) CrossChainAppResponse(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

CrossChainAppResponse indicates an expected call of CrossChainAppResponse.

func (*MockDAGVMMockRecorder) Disconnected added in v1.9.1 

func (mr *MockDAGVMMockRecorder) Disconnected(arg0 interface{}) *gomock.Call

Disconnected indicates an expected call of Disconnected.

func (*MockDAGVMMockRecorder) GetTx added in v1.9.1 

func (mr *MockDAGVMMockRecorder) GetTx(arg0 interface{}) *gomock.Call

GetTx indicates an expected call of GetTx.

func (*MockDAGVMMockRecorder) HealthCheck added in v1.9.1 

func (mr *MockDAGVMMockRecorder) HealthCheck() *gomock.Call

HealthCheck indicates an expected call of HealthCheck.

func (*MockDAGVMMockRecorder) Initialize added in v1.9.1 

func (mr *MockDAGVMMockRecorder) Initialize(arg0, arg1, arg2, arg3, arg4, arg5, arg6, arg7 interface{}) *gomock.Call

Initialize indicates an expected call of Initialize.

func (*MockDAGVMMockRecorder) ParseTx added in v1.9.1 

func (mr *MockDAGVMMockRecorder) ParseTx(arg0 interface{}) *gomock.Call

ParseTx indicates an expected call of ParseTx.

func (*MockDAGVMMockRecorder) PendingTxs added in v1.9.1 

func (mr *MockDAGVMMockRecorder) PendingTxs() *gomock.Call

PendingTxs indicates an expected call of PendingTxs.

func (*MockDAGVMMockRecorder) SetState added in v1.9.1 

func (mr *MockDAGVMMockRecorder) SetState(arg0 interface{}) *gomock.Call

SetState indicates an expected call of SetState.

func (*MockDAGVMMockRecorder) Shutdown added in v1.9.1 

func (mr *MockDAGVMMockRecorder) Shutdown() *gomock.Call

Shutdown indicates an expected call of Shutdown.

func (*MockDAGVMMockRecorder) Version added in v1.9.1 

func (mr *MockDAGVMMockRecorder) Version() *gomock.Call

Version indicates an expected call of Version.

type Parser added in v1.1.1 

type Parser interface {
	// Parse a vertex from a slice of bytes
	ParseVtx(vertex []byte) (avalanche.Vertex, error)
}

Parser parses bytes into a vertex.

type StatelessVertex added in v1.1.1 

type StatelessVertex interface {
	verify.Verifiable
	ID() ids.ID
	Bytes() []byte
	Version() uint16
	ChainID() ids.ID
	StopVertex() bool
	Height() uint64
	Epoch() uint32
	ParentIDs() []ids.ID
	Txs() [][]byte
}

func Build added in v1.1.1 

func Build(
	chainID ids.ID,
	height uint64,
	parentIDs []ids.ID,
	txs [][]byte,
) (StatelessVertex, error)

Build a new stateless vertex from the contents of a vertex

func BuildStopVertex added in v1.7.4 

func BuildStopVertex(chainID ids.ID, height uint64, parentIDs []ids.ID) (StatelessVertex, error)

Build a new stateless vertex from the contents of a vertex

func Parse added in v1.1.1 

func Parse(bytes []byte) (StatelessVertex, error)

Parse parses the provided vertex bytes into a stateless vertex

type Storage added in v1.1.1 

type Storage interface {
	// Get a vertex by its hash from storage.
	GetVtx(vtxID ids.ID) (avalanche.Vertex, error)
	// Edge returns a list of accepted vertex IDs with no accepted children.
	Edge() (vtxIDs []ids.ID)
	// Returns "true" if accepted frontier ("Edge") is stop vertex.
	StopVertexAccepted() (bool, error)
}

Storage defines the persistent storage that is required by the consensus engine.

type TestBuilder added in v1.1.1 

type TestBuilder struct {
	T             *testing.T
	CantBuildVtx  bool
	BuildVtxF     func(parentIDs []ids.ID, txs []snowstorm.Tx) (avalanche.Vertex, error)
	BuildStopVtxF func(parentIDs []ids.ID) (avalanche.Vertex, error)
}

func (*TestBuilder) BuildStopVtx added in v1.7.4 

func (b *TestBuilder) BuildStopVtx(parentIDs []ids.ID) (avalanche.Vertex, error)

func (*TestBuilder) BuildVtx added in v1.3.2 

func (b *TestBuilder) BuildVtx(parentIDs []ids.ID, txs []snowstorm.Tx) (avalanche.Vertex, error)

func (*TestBuilder) Default added in v1.1.1 

func (b *TestBuilder) Default(cant bool)

type TestManager 

type TestManager struct {
	TestBuilder
	TestParser
	TestStorage
}

func NewTestManager added in v1.1.1 

func NewTestManager(t *testing.T) *TestManager

func (*TestManager) Default 

func (m *TestManager) Default(cant bool)

type TestParser added in v1.1.1 

type TestParser struct {
	T            *testing.T
	CantParseVtx bool
	ParseVtxF    func([]byte) (avalanche.Vertex, error)
}

func (*TestParser) Default added in v1.1.1 

func (p *TestParser) Default(cant bool)

func (*TestParser) ParseVtx added in v1.3.2 

func (p *TestParser) ParseVtx(b []byte) (avalanche.Vertex, error)

type TestStorage added in v1.1.1 

type TestStorage struct {
	T                                            *testing.T
	CantGetVtx, CantEdge, CantStopVertexAccepted bool
	GetVtxF                                      func(ids.ID) (avalanche.Vertex, error)
	EdgeF                                        func() []ids.ID
	StopVertexAcceptedF                          func() (bool, error)
}

func (*TestStorage) Default added in v1.1.1 

func (s *TestStorage) Default(cant bool)

func (*TestStorage) Edge added in v1.1.1 

func (s *TestStorage) Edge() []ids.ID

func (*TestStorage) GetVtx added in v1.3.2 

func (s *TestStorage) GetVtx(id ids.ID) (avalanche.Vertex, error)

func (*TestStorage) StopVertexAccepted added in v1.7.14 

func (s *TestStorage) StopVertexAccepted() (bool, error)

type TestVM 

type TestVM struct {
	common.TestVM

	CantPendingTxs, CantParse, CantGet bool

	PendingTxsF func() []snowstorm.Tx
	ParseTxF    func([]byte) (snowstorm.Tx, error)
	GetTxF      func(ids.ID) (snowstorm.Tx, error)
}

func (*TestVM) Default 

func (vm *TestVM) Default(cant bool)

func (*TestVM) GetTx 

func (vm *TestVM) GetTx(txID ids.ID) (snowstorm.Tx, error)

func (*TestVM) ParseTx 

func (vm *TestVM) ParseTx(b []byte) (snowstorm.Tx, error)

func (*TestVM) PendingTxs 

func (vm *TestVM) PendingTxs() []snowstorm.Tx

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.