node

package
v0.5.0 Latest Latest
Warning

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

 Go to latest Published: Apr 3, 2020 License: MIT Imports: 23 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var TimeoutErr = errors.New("timeout")

Functions

func MaybeEnableExtendedApi added in v0.5.0 

func MaybeEnableExtendedApi(state state.State, time types.Time) error

func NewMockPeerManagerWithDefaultPeer 

func NewMockPeerManagerWithDefaultPeer() (*mockPeerManager, *mock.Peer)

func PreloadBlockIds added in v0.5.0 

func PreloadBlockIds(ctx context.Context, out chan nullable.BlockID, p sendMessage, lastBlockIds *BlockIds, subscribe types.Subscribe, wg *sync.WaitGroup) error

Types

type BlockIds added in v0.5.0 

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

func LastBlockIds added in v0.5.0 

func LastBlockIds(state state.State) (*BlockIds, error)

func NewBlockIds added in v0.5.0 

func NewBlockIds(ids ...proto.BlockID) *BlockIds

func (*BlockIds) Exists added in v0.5.0 

func (a *BlockIds) Exists(id proto.BlockID) bool

func (*BlockIds) Ids added in v0.5.0 

func (a *BlockIds) Ids() []proto.BlockID

func (*BlockIds) Revert added in v0.5.0 

func (a *BlockIds) Revert() *BlockIds

type BlocksApplier added in v0.5.0 

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

func NewBlocksApplier added in v0.5.0 

func NewBlocksApplier(state state.State, tm types.Time) *BlocksApplier

func (*BlocksApplier) Apply added in v0.5.0 

func (a *BlocksApplier) Apply(blocks []*proto.Block) error

1) notify peers about score 2) reshedule

type Config 

type Config struct {
	AppName  string
	NodeName string
	Listen   string
	DeclAddr string
}

type HistoryBlockApplier added in v0.5.0 

type HistoryBlockApplier interface {
	Apply(blocks []*proto.Block) error
}

type HistoryBlockApplierImpl added in v0.5.0 

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

func NewHistoryBlockApplier added in v0.5.0 

func NewHistoryBlockApplier(applier types.BlocksApplier, services services.Services, scoreSender types.ScoreSender) *HistoryBlockApplierImpl

func (*HistoryBlockApplierImpl) Apply added in v0.5.0 

func (a *HistoryBlockApplierImpl) Apply(blocks []*proto.Block) error

type MockStateManager 

type MockStateManager struct {
	Peers_ []proto.TCPAddr
	// contains filtered or unexported fields
}

func NewMockStateManager 

func NewMockStateManager(blocks ...*proto.Block) (*MockStateManager, error)

func (*MockStateManager) AccountBalance 

func (a *MockStateManager) AccountBalance(account proto.Recipient, asset []byte) (uint64, error)

func (*MockStateManager) ActivationHeight 

func (a *MockStateManager) ActivationHeight(featureID int16) (uint64, error)

func (*MockStateManager) AddBlock 

func (a *MockStateManager) AddBlock([]byte) (*proto.Block, error)

func (*MockStateManager) AddBlocks 

func (a *MockStateManager) AddBlocks(blocks [][]byte, initialisation bool) error

func (*MockStateManager) AddDeserializedBlock 

func (a *MockStateManager) AddDeserializedBlock(block *proto.Block) (*proto.Block, error)

func (*MockStateManager) AddNewBlocks 

func (a *MockStateManager) AddNewBlocks(blocks [][]byte) error

func (*MockStateManager) AddNewDeserializedBlocks 

func (a *MockStateManager) AddNewDeserializedBlocks(blocks []*proto.Block) (*proto.Block, error)

func (*MockStateManager) AddOldBlocks 

func (a *MockStateManager) AddOldBlocks(blocks [][]byte) error

func (*MockStateManager) AddOldDeserializedBlocks 

func (a *MockStateManager) AddOldDeserializedBlocks([]*proto.Block) error

func (*MockStateManager) AddingBlockHeight 

func (a *MockStateManager) AddingBlockHeight() (proto.Height, error)

func (*MockStateManager) AddrByAlias 

func (a *MockStateManager) AddrByAlias(alias proto.Alias) (proto.Address, error)

func (*MockStateManager) AddressesNumber 

func (a *MockStateManager) AddressesNumber(wavesonly bool) (uint64, error)

func (*MockStateManager) AllFeatures added in v0.5.0 

func (a *MockStateManager) AllFeatures() ([]int16, error)

func (*MockStateManager) ApprovalHeight 

func (a *MockStateManager) ApprovalHeight(featureID int16) (uint64, error)

func (*MockStateManager) AssetInfo 

func (a *MockStateManager) AssetInfo(assetID crypto.Digest) (*proto.AssetInfo, error)

func (*MockStateManager) AssetIsSponsored 

func (a *MockStateManager) AssetIsSponsored(assetID crypto.Digest) (bool, error)

func (*MockStateManager) Block 

func (a *MockStateManager) Block(blockID proto.BlockID) (*proto.Block, error)

func (*MockStateManager) BlockByHeight 

func (a *MockStateManager) BlockByHeight(height proto.Height) (*proto.Block, error)

func (*MockStateManager) BlockBytes 

func (a *MockStateManager) BlockBytes(blockID proto.BlockID) ([]byte, error)

func (*MockStateManager) BlockBytesByHeight 

func (a *MockStateManager) BlockBytesByHeight(height proto.Height) ([]byte, error)

func (*MockStateManager) BlockIDToHeight 

func (a *MockStateManager) BlockIDToHeight(blockID proto.BlockID) (uint64, error)

func (*MockStateManager) BlockVRF added in v0.5.0 

func (a *MockStateManager) BlockVRF(header *proto.BlockHeader, height proto.Height) ([]byte, error)

func (*MockStateManager) BlockchainSettings 

func (a *MockStateManager) BlockchainSettings() (*settings.BlockchainSettings, error)

func (*MockStateManager) Close 

func (a *MockStateManager) Close() error

func (*MockStateManager) CurrentScore 

func (a *MockStateManager) CurrentScore() (*big.Int, error)

func (*MockStateManager) EffectiveBalanceStable added in v0.5.0 

func (a *MockStateManager) EffectiveBalanceStable(account proto.Recipient, startHeight, endHeight uint64) (uint64, error)

func (*MockStateManager) FullAssetInfo added in v0.5.0 

func (a *MockStateManager) FullAssetInfo(assetID crypto.Digest) (*proto.FullAssetInfo, error)

func (*MockStateManager) FullWavesBalance added in v0.5.0 

func (a *MockStateManager) FullWavesBalance(account proto.Recipient) (*proto.FullWavesBalance, error)

func (*MockStateManager) Header 

func (a *MockStateManager) Header(block proto.BlockID) (*proto.BlockHeader, error)

func (*MockStateManager) HeaderByHeight 

func (a *MockStateManager) HeaderByHeight(height uint64) (*proto.BlockHeader, error)

func (*MockStateManager) HeaderBytes 

func (a *MockStateManager) HeaderBytes(blockID proto.BlockID) ([]byte, error)

func (*MockStateManager) HeaderBytesByHeight 

func (a *MockStateManager) HeaderBytesByHeight(height uint64) ([]byte, error)

func (*MockStateManager) Height 

func (a *MockStateManager) Height() (proto.Height, error)

func (*MockStateManager) HeightToBlockID 

func (a *MockStateManager) HeightToBlockID(height uint64) (proto.BlockID, error)

func (*MockStateManager) HitSourceAtHeight added in v0.5.0 

func (a *MockStateManager) HitSourceAtHeight(height proto.Height) ([]byte, error)

func (*MockStateManager) InvokeResultByID added in v0.5.0 

func (a *MockStateManager) InvokeResultByID(invokeID crypto.Digest) (*proto.ScriptResult, error)

func (*MockStateManager) IsActivated 

func (a *MockStateManager) IsActivated(featureID int16) (bool, error)

func (*MockStateManager) IsActiveAtHeight added in v0.5.0 

func (a *MockStateManager) IsActiveAtHeight(featureID int16, height proto.Height) (bool, error)

func (*MockStateManager) IsActiveLeasing added in v0.5.0 

func (a *MockStateManager) IsActiveLeasing(leaseID crypto.Digest) (bool, error)

func (*MockStateManager) IsApproved 

func (a *MockStateManager) IsApproved(featureID int16) (bool, error)

func (*MockStateManager) IsApprovedAtHeight added in v0.5.0 

func (a *MockStateManager) IsApprovedAtHeight(featureID int16, height uint64) (bool, error)

func (*MockStateManager) IsNotFound 

func (a *MockStateManager) IsNotFound(err error) bool

func (*MockStateManager) Mutex 

func (a *MockStateManager) Mutex() *lock.RwMutex

func (*MockStateManager) NewAddrTransactionsIterator added in v0.5.0 

func (a *MockStateManager) NewAddrTransactionsIterator(addr proto.Address) (state.TransactionIterator, error)

func (*MockStateManager) Peers 

func (a *MockStateManager) Peers() ([]proto.TCPAddr, error)

func (*MockStateManager) ProvidesExtendedApi added in v0.5.0 

func (a *MockStateManager) ProvidesExtendedApi() (bool, error)

func (*MockStateManager) ResetValidationList 

func (a *MockStateManager) ResetValidationList()

func (*MockStateManager) RetrieveBinaryEntry 

func (a *MockStateManager) RetrieveBinaryEntry(account proto.Recipient, key string) (*proto.BinaryDataEntry, error)

func (*MockStateManager) RetrieveBooleanEntry 

func (a *MockStateManager) RetrieveBooleanEntry(account proto.Recipient, key string) (*proto.BooleanDataEntry, error)

func (*MockStateManager) RetrieveEntries added in v0.5.0 

func (a *MockStateManager) RetrieveEntries(account proto.Recipient) ([]proto.DataEntry, error)

func (*MockStateManager) RetrieveEntry 

func (a *MockStateManager) RetrieveEntry(account proto.Recipient, key string) (proto.DataEntry, error)

func (*MockStateManager) RetrieveIntegerEntry 

func (a *MockStateManager) RetrieveIntegerEntry(account proto.Recipient, key string) (*proto.IntegerDataEntry, error)

func (*MockStateManager) RetrieveStringEntry 

func (a *MockStateManager) RetrieveStringEntry(account proto.Recipient, key string) (*proto.StringDataEntry, error)

func (*MockStateManager) RollbackTo 

func (a *MockStateManager) RollbackTo(removalEdge proto.BlockID) error

func (*MockStateManager) RollbackToHeight 

func (a *MockStateManager) RollbackToHeight(height uint64) error

func (*MockStateManager) SavePeers 

func (a *MockStateManager) SavePeers([]proto.TCPAddr) error

func (*MockStateManager) ScoreAtHeight 

func (a *MockStateManager) ScoreAtHeight(height uint64) (*big.Int, error)

func (*MockStateManager) ScriptInfoByAccount added in v0.5.0 

func (a *MockStateManager) ScriptInfoByAccount(account proto.Recipient) (*proto.ScriptInfo, error)

func (*MockStateManager) ScriptInfoByAsset added in v0.5.0 

func (a *MockStateManager) ScriptInfoByAsset(assetID crypto.Digest) (*proto.ScriptInfo, error)

func (*MockStateManager) StartProvidingExtendedApi added in v0.5.0 

func (a *MockStateManager) StartProvidingExtendedApi() error

func (*MockStateManager) TopBlock added in v0.5.0 

func (a *MockStateManager) TopBlock() *proto.Block

func (*MockStateManager) TransactionByID 

func (a *MockStateManager) TransactionByID(id []byte) (proto.Transaction, error)

func (*MockStateManager) TransactionHeightByID 

func (a *MockStateManager) TransactionHeightByID(id []byte) (proto.Height, error)

func (*MockStateManager) ValidateNextTx 

func (a *MockStateManager) ValidateNextTx(tx proto.Transaction, currentTimestamp, parentTimestamp uint64, version proto.BlockVersion, vrf []byte) error

func (*MockStateManager) VotesNum added in v0.5.0 

func (a *MockStateManager) VotesNum(featureID int16) (uint64, error)

func (*MockStateManager) VotesNumAtHeight added in v0.5.0 

func (a *MockStateManager) VotesNumAtHeight(featureID int16, height proto.Height) (uint64, error)

func (*MockStateManager) WavesAddressesNumber 

func (a *MockStateManager) WavesAddressesNumber() (uint64, error)

type Node 

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

func NewNode 

func NewNode(services services.Services, declAddr proto.TCPAddr, bindAddr proto.TCPAddr, ng *ng.RuntimeImpl, sync types.StateSync) *Node

func (*Node) AskPeers 

func (a *Node) AskPeers()

func (*Node) Close 

func (a *Node) Close()

func (*Node) HandleInfoMessage 

func (a *Node) HandleInfoMessage(m peer.InfoMessage)

func (*Node) HandleProtoMessage 

func (a *Node) HandleProtoMessage(mess peer.ProtoMessage)

func (*Node) PeerManager 

func (a *Node) PeerManager() peer_manager.PeerManager

func (*Node) Run added in v0.5.0 

func (n *Node) Run(ctx context.Context, p peer.Parent)

func (*Node) Serve 

func (a *Node) Serve(ctx context.Context) error

func (*Node) SpawnOutgoingConnection 

func (a *Node) SpawnOutgoingConnection(ctx context.Context, addr proto.TCPAddr) error

func (*Node) SpawnOutgoingConnections 

func (a *Node) SpawnOutgoingConnections(ctx context.Context)

func (*Node) State 

func (a *Node) State() state.State

type StateSync 

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

func NewStateSync 

func NewStateSync(services services.Services, scoreSender types.ScoreSender, applier types.BlocksApplier) *StateSync

func (*StateSync) Close 

func (a *StateSync) Close()

func (*StateSync) Run 

func (a *StateSync) Run(ctx context.Context)

func (*StateSync) SetEnabled added in v0.5.0 

func (a *StateSync) SetEnabled(enabled bool)

func (*StateSync) Sync 

func (a *StateSync) Sync()

type Subscribe 

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

func NewSubscribeService 

func NewSubscribeService() *Subscribe

func (*Subscribe) Exists 

func (a *Subscribe) Exists(id string, responseMessage proto.Message) bool

func (*Subscribe) Receive 

func (a *Subscribe) Receive(p types.ID, responseMessage proto.Message) bool

Receive tries to apply block to any listener, if no one accepted return `false`, otherwise `true`

func (*Subscribe) Subscribe 

func (a *Subscribe) Subscribe(p types.ID, responseMessage proto.Message) (chan proto.Message, func(), error)

Source Files

View all Source files

Directories

Path Synopsis

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.