og

package

Go to main page

Versions in this module

v0

v0.0.9

Aug 14, 2020

v0.0.9-Bytes01

Aug 18, 2020

v0.0.9-Bytes-0.1

Aug 10, 2020

v0.0.9-Bytes

Aug 18, 2020

v0.0.8

Aug 14, 2020

v0.0.7

Aug 11, 2020

Changes in this version

+ func ErrResp(code ErrCode, format string, v ...interface{}) error

+ type ErrCode int

+ func (e ErrCode) String() string

type Hub

+ MessageUnmarshaller message_archive.typesUnmarshalManager

+ func (h *Hub) AnonymousSendMessage(messageType message_archive.BinaryMessageType, msg p2p_message.Message, ...)

type Og

+ func (og *Og) GetCurrentOgStatus() model.OgStatusData

v0.0.6

Aug 10, 2020

Changes in this version

+ var ReleaseVersion = "og/1.0.0"

type Og

+ func (og *Og) PushNodeData()

v0.0.5

Mar 17, 2020

v0.0.5-unstable

Aug 11, 2020

v0.0.4

Jan 20, 2020

Changes in this version

type DummyTxPoolMiniTx

+ func (p *DummyTxPoolMiniTx) IsBadSeq(seq *tx_types.Sequencer) error

v0.0.3

Aug 1, 2019

Changes in this version

type DummyTxPoolMiniTx

+ func (P *DummyTxPoolMiniTx) GetByNonce(addr common.Address, nonce uint64) types.Txi

type FIFOTipGenerator

+ func (f *FIFOTipGenerator) GetByNonce(addr common.Address, nonce uint64) types.Txi

+ func (f *FIFOTipGenerator) IsBadSeq(seq *tx_types.Sequencer) error

type IDag

+ GetLatestNonce func(addr common.Address) (uint64, error)

type ITxPool

+ GetByNonce func(addr common.Address, nonce uint64) types.Txi

+ IsBadSeq func(seq *tx_types.Sequencer) error

type MessageRouter

+ func (m *MessageRouter) SendToPeer(peerId string, messageType p2p_message.MessageType, msg p2p_message.Message)

type Syncer

+ SyncHashList func(seqHash common.Hash)

type TipGenerator

+ GetByNonce func(addr common.Address, nonce uint64) types.Txi

+ IsBadSeq func(seq *tx_types.Sequencer) error

type TxBuffer

+ Verifiers []Verifier

+ func (d *TxBuffer) Dump() string

+ func (d *TxBuffer) DumpKnownCache() string

type TxFormatVerifier

+ NoVerifySignatrue bool

v0.0.2

Jul 17, 2019

Changes in this version

+ func Sha256(bytes []byte) []byte

+ type ActionTxHandler interface

+ HandleActionTx func(request *p2p_message.MessageNewActionTx, perid string)

+ type ArchiveHandler interface

+ HandleArchive func(request *p2p_message.MessageNewArchive, peerId string)

type ConsensusVerifier

+ func (c *ConsensusVerifier) String() string

+ func (v *ConsensusVerifier) Independent() bool

+ type GetStateRoot interface

+ PreConfirm func(seq *tx_types.Sequencer) (hash common.Hash, err error)

type GraphVerifier

+ func (c *GraphVerifier) String() string

+ func (v *GraphVerifier) Independent() bool

type MessageRouter

+ ActionTxHandler ActionTxHandler

+ ArchiveHandler ArchiveHandler

+ func (m *MessageRouter) RouteActionTx(msg *p2PMessage)

+ func (m *MessageRouter) RouteArchive(msg *p2PMessage)

type MessageType

+ const MessageTypeActionTX

+ const MessageTypeArchive

type TxBuffer

+ TestNoVerify bool

type TxBufferConfig

+ TestNoVerify bool

type TxCreator

+ GetStateRoot GetStateRoot

+ NoVerifyMaxTxHash bool

+ NoVerifyMindHash bool

+ TxFormatVerifier TxFormatVerifier

+ func (m *TxCreator) NewActionTxWithSeal(from common.Address, to common.Address, value *math.BigInt, action byte, ...) (tx types.Txi, err error)

+ func (m *TxCreator) NewArchiveWithSeal(data []byte) (tx types.Txi, err error)

+ func (t *TxCreator) GetArchiveNonce() uint64

type TxFormatVerifier

+ NoVerifyMaxTxHash bool

+ NoVerifyMindHash bool

+ func (c *TxFormatVerifier) String() string

+ func (t *TxFormatVerifier) SignatureValues(sig []byte) (r, s, v *big.Int, err error)

+ func (v *TxFormatVerifier) Independent() bool

type Verifier

+ Independent func() bool

+ String func() string

v0.0.1

May 31, 2019

Changes in this version

+ const DuplicateMsgPeerNum

+ const ErrDecode

+ const ErrExtraStatusMsg

+ const ErrGenesisBlockMismatch

+ const ErrInvalidMsgCode

+ const ErrMsgTooLarge

+ const ErrNetworkIdMismatch

+ const ErrNoStatusMsg

+ const ErrProtocolVersionMismatch

+ const ErrSuspendedPeer

+ const FeedBackMode

+ const NormalMode

+ const OG01

+ const OG02

+ const ProtocolMaxMsgSize

+ var ProtocolLengths = []MessageType

+ var ProtocolName = "og"

+ var ProtocolVersions = []uint

+ func CreateDB() (ogdb.Database, error)

+ func GetOldDb() (ogdb.Database, error)

+ func InitLoggers(logger *logrus.Logger, logdir string)

+ func MsgCountInit()

+ type Account struct

+ type Announcer interface

+ BroadcastNewTx func(txi types.Txi)

+ type BodiesRequestHandler interface

+ HandleBodiesRequest func(msgReq *types.MessageBodiesRequest, peerID string)

+ type BodiesResponseHandler interface

+ HandleBodiesResponse func(request *types.MessageBodiesResponse, peerId string)

+ type CampaignHandler interface

+ HandleCampaign func(request *types.MessageCampaign, peerId string)

+ type ConsensusDkgDealHandler interface

+ HandleConsensusDkgDeal func(request *types.MessageConsensusDkgDeal, peerId string)

+ type ConsensusDkgDealResponseHandler interface

+ HandleConsensusDkgDealResponse func(request *types.MessageConsensusDkgDealResponse, peerId string)

+ type ConsensusDkgGenesisPublicKeyHandler interface

+ HandleConsensusDkgGenesisPublicKey func(request *types.MessageConsensusDkgGenesisPublicKey, peerId string)

+ type ConsensusDkgSigSetsHandler interface

+ HandleConsensusDkgSigSets func(request *types.MessageConsensusDkgSigSets, peerId string)

+ type ConsensusPreCommitHandler interface

+ HandleConsensusPreCommit func(request *types.MessagePreCommit, peerId string)

+ type ConsensusPreVoteHandler interface

+ HandleConsensusPreVote func(request *types.MessagePreVote, peerId string)

+ type ConsensusProposalHandler interface

+ HandleConsensusProposal func(request *types.MessageProposal, peerId string)

+ type ConsensusVerifier struct

+ VerifyCampaign func(cp *types.Campaign) bool

+ VerifySequencer func(cp *types.Sequencer) bool

+ VerifyTermChange func(cp *types.TermChange) bool

+ func (c *ConsensusVerifier) Name() string

+ func (c *ConsensusVerifier) Verify(t types.Txi) bool

+ type ControlMsgCache struct

+ ExpireTime time.Duration

+ func (c *ControlMsgCache) Len() int

+ type ControlMsgHandler interface

+ HandleControlMsg func(msg *types.MessageControl, peerId string)

+ type DataLoader struct

+ Dag *core.Dag

+ TxPool *core.TxPool

+ func (d *DataLoader) GenerateGenesis() *types.Sequencer

+ func (d *DataLoader) LoadLocalData()

+ func (d *DataLoader) Name() string

+ func (d *DataLoader) Start()

+ func (d *DataLoader) Stop()

+ func (loader *DataLoader) GenerateGenesisBalance() map[types.Address]*math.BigInt

+ type DummyTxPoolMiniTx struct

+ func (d *DummyTxPoolMiniTx) Init()

+ func (p *DummyTxPoolMiniTx) Add(v types.Txi)

+ func (p *DummyTxPoolMiniTx) GetRandomTips(n int) (v []types.Txi)

+ type EncryptionLayer interface

+ SetEncryptionKey func(priv *crypto.PrivateKey)

+ type FIFOTipGenerator struct

+ func NewFIFOTIpGenerator(upstream TipGenerator, maxCacheSize int) *FIFOTipGenerator

+ func (f *FIFOTipGenerator) GetRandomTips(n int) (v []types.Txi)

+ type FetchByHashHandlerRequest interface

+ HandleFetchByHashRequest func(req *types.MessageSyncRequest, sourceID string)

+ type FetchByHashResponseHandler interface

+ HandleFetchByHashResponse func(resp *types.MessageSyncResponse, sourceID string)

+ type GetMsgHandler interface

+ HandleGetMsg func(msg *types.MessageGetMsg, peerId string)

+ type GetNodeDataMsgHandler interface

+ HandleGetNodeDataMsg func(peerId string)

+ type GetReceiptsMsgHandler interface

+ HandleGetReceiptsMsg func(peerId string)

+ type GraphVerifier struct

+ Dag IDag

+ TxPool ITxPool

+ func (v *GraphVerifier) Name() string

+ func (v *GraphVerifier) Verify(txi types.Txi) (ok bool)

+ type HeaderRequestHandler interface

+ HandleHeaderRequest func(request *types.MessageHeaderRequest, peerID string)

+ type HeaderResponseHandler interface

+ HandleHeaderResponse func(headerMsg *types.MessageHeaderResponse, peerID string)

+ type Hub struct

+ CallbackRegistry map[MessageType]func(*p2PMessage)

+ CallbackRegistryOG02 map[MessageType]func(*p2PMessage)

+ Downloader *downloader.Downloader

+ Fetcher *fetcher.Fetcher

+ IsReceivedHash func(hash types.Hash) bool

+ NodeInfo func() *p2p.NodeInfo

+ OnNewPeerConnected []chan string

+ StatusDataProvider NodeStatusDataProvider

+ SubProtocols []p2p.Protocol

+ func NewHub(config *HubConfig) *Hub

+ func (h *Hub) BestPeerId() (peerId string, err error)

+ func (h *Hub) BestPeerInfo() (peerId string, hash types.Hash, seqId uint64, err error)

+ func (h *Hub) BroadcastMessage(messageType MessageType, msg types.Message)

+ func (h *Hub) BroadcastMessageWithFilter(messageType MessageType, msg types.Message)

+ func (h *Hub) BroadcastMessageWithLink(messageType MessageType, msg types.Message)

+ func (h *Hub) GetBenchmarks() map[string]interface{}

+ func (h *Hub) GetPeerHead(peerId string) (hash types.Hash, seqId uint64, err error)

+ func (h *Hub) Init(config *HubConfig)

+ func (h *Hub) MulticastMessage(messageType MessageType, msg types.Message)

+ func (h *Hub) MulticastToSource(messageType MessageType, msg types.Message, sourceMsgHash *types.Hash)

+ func (h *Hub) Name() string

+ func (h *Hub) NodeStatus() *NodeStatus

+ func (h *Hub) PeersInfo() []*PeerInfo

+ func (h *Hub) RelayMessage(msgOut *p2PMessage)

+ func (h *Hub) RemovePeer(id string)

+ func (h *Hub) RequestBodies(peerId string, hashs types.Hashes) error

+ func (h *Hub) RequestOneHeader(peerId string, hash types.Hash) error

+ func (h *Hub) SendBytesToPeer(peerId string, messageType MessageType, msg []byte) error

+ func (h *Hub) SendGetMsg(peerId string, msg *types.MessageGetMsg) error

+ func (h *Hub) SendToAnynomous(messageType MessageType, msg types.Message, anyNomousPubKey *crypto.PublicKey)

+ func (h *Hub) SendToPeer(peerId string, messageType MessageType, msg types.Message) error

+ func (h *Hub) SetEncryptionKey(priv *crypto.PrivateKey)

+ func (h *Hub) SetPeerHead(peerId string, hash types.Hash, number uint64) error

+ func (h *Hub) Start()

+ func (h *Hub) Stop()

+ type HubConfig struct

+ BroadCastMode uint8

+ DisableEncryptGossip bool

+ IncomingBufferSize int

+ MaxPeers int

+ MessageCacheExpirationSeconds int

+ MessageCacheMaxSize int

+ OutgoingBufferSize int

+ func DefaultHubConfig() HubConfig

+ type IDag interface

+ Genesis func() *types.Sequencer

+ GetBalance func(addr types.Address) *math.BigInt

+ GetHeight func() uint64

+ GetSequencer func(hash types.Hash, id uint64) *types.Sequencer

+ GetSequencerByHash func(hash types.Hash) *types.Sequencer

+ GetSequencerByHeight func(id uint64) *types.Sequencer

+ GetTx func(hash types.Hash) types.Txi

+ GetTxByNonce func(addr types.Address, nonce uint64) types.Txi

+ GetTxisByNumber func(id uint64) types.Txis

+ LatestSequencer func() *types.Sequencer

+ type ITxPool interface

+ AddRemoteTx func(tx types.Txi, noFeedBack bool) error

+ Get func(hash types.Hash) types.Txi

+ GetLatestNonce func(addr types.Address) (uint64, error)

+ GetMaxWeight func() uint64

+ IsLocalHash func(hash types.Hash) bool

+ RegisterOnNewTxReceived func(c chan types.Txi, name string, allTx bool)

+ type IncomingMessageHandler struct

+ Hub *Hub

+ Og *Og

+ TxEnable func() bool

+ func NewIncomingMessageHandler(og *Og, hub *Hub, cacheSize int, expireTime time.Duration) *IncomingMessageHandler

+ func (h *IncomingMessageHandler) HandleBodiesRequest(msgReq *types.MessageBodiesRequest, peerId string)

+ func (h *IncomingMessageHandler) HandleBodiesResponse(request *types.MessageBodiesResponse, peerId string)

+ func (h *IncomingMessageHandler) HandleControlMsg(req *types.MessageControl, sourceId string)

+ func (h *IncomingMessageHandler) HandleFetchByHashRequest(syncRequest *types.MessageSyncRequest, peerId string)

+ func (h *IncomingMessageHandler) HandleGetMsg(msg *types.MessageGetMsg, sourcePeerId string)

+ func (h *IncomingMessageHandler) HandleHeaderRequest(query *types.MessageHeaderRequest, peerId string)

+ func (h *IncomingMessageHandler) HandleHeaderResponse(headerMsg *types.MessageHeaderResponse, peerId string)

+ func (h *IncomingMessageHandler) HandlePing(peerId string)

+ func (h *IncomingMessageHandler) HandlePong()

+ func (h *IncomingMessageHandler) HandleSequencerHeader(msgHeader *types.MessageSequencerHeader, peerId string)

+ func (h *IncomingMessageHandler) HandleTxsRequest(msgReq *types.MessageTxsRequest, peerId string)

+ func (h *IncomingMessageHandler) HandleTxsResponse(request *types.MessageTxsResponse)

+ func (h *IncomingMessageHandler) RemoveControlMsgFromCache(hash types.Hash)

+ func (m *IncomingMessageHandler) GetBenchmarks() map[string]interface{}

+ func (m *IncomingMessageHandler) Name() string

+ func (m *IncomingMessageHandler) Start()

+ func (m *IncomingMessageHandler) Stop()

+ type IncomingMessageHandlerOG02 struct

+ Hub *Hub

+ Og *Og

+ func (h *IncomingMessageHandlerOG02) HandleGetNodeDataMsg(peerId string)

+ func (h *IncomingMessageHandlerOG02) HandleGetReceiptsMsg(peerId string)

+ func (h *IncomingMessageHandlerOG02) HandleNodeDataMsg(peerId string)

+ type ManagerConfig struct

+ AcquireTxQueueSize uint

+ BatchAcquireSize uint

+ type MessageCounter struct

+ var MsgCounter *MessageCounter

+ func (m *MessageCounter) Get() uint32

+ func (z *MessageCounter) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *MessageCounter) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z MessageCounter) EncodeMsg(en *msgp.Writer) (err error)

+ func (z MessageCounter) MarshalMsg(b []byte) (o []byte, err error)

+ func (z MessageCounter) Msgsize() (s int)

+ type MessageRouter struct

+ BodiesRequestHandler BodiesRequestHandler

+ BodiesResponseHandler BodiesResponseHandler

+ CampaignHandler CampaignHandler

+ ConsensusDkgDealHandler ConsensusDkgDealHandler

+ ConsensusDkgDealResponseHandler ConsensusDkgDealResponseHandler

+ ConsensusDkgGenesisPublicKeyHandler ConsensusDkgGenesisPublicKeyHandler

+ ConsensusDkgSigSetsHandler ConsensusDkgSigSetsHandler

+ ConsensusPreCommitHandler ConsensusPreCommitHandler

+ ConsensusPreVoteHandler ConsensusPreVoteHandler

+ ConsensusProposalHandler ConsensusProposalHandler

+ ControlMsgHandler ControlMsgHandler

+ FetchByHashRequestHandler FetchByHashHandlerRequest

+ FetchByHashResponseHandler FetchByHashResponseHandler

+ GetMsgHandler GetMsgHandler

+ HeaderRequestHandler HeaderRequestHandler

+ HeaderResponseHandler HeaderResponseHandler

+ Hub *Hub

+ NewSequencerHandler NewSequencerHandler

+ NewTxHandler NewTxHandler

+ NewTxsHandler NewTxsHandler

+ PingHandler PingHandler

+ PongHandler PongHandler

+ SequencerHeaderHandler SequencerHeaderHandler

+ TermChangeHandler TermChangeHandler

+ TermChangeRequestHandler TermChangeRequestHandler

+ TermChangeResponseHandler TermChangeResponseHandler

+ TxsRequestHandler TxsRequestHandler

+ TxsResponseHandler TxsResponseHandler

+ func (m *MessageRouter) BroadcastMessage(messageType MessageType, message types.Message)

+ func (m *MessageRouter) BroadcastMessageWithLink(messageType MessageType, message types.Message)

+ func (m *MessageRouter) MulticastMessage(messageType MessageType, message types.Message)

+ func (m *MessageRouter) MulticastToSource(messageType MessageType, message types.Message, sourceMsgHash *types.Hash)

+ func (m *MessageRouter) Name() string

+ func (m *MessageRouter) RouteBodiesRequest(msg *p2PMessage)

+ func (m *MessageRouter) RouteBodiesResponse(msg *p2PMessage)

+ func (m *MessageRouter) RouteCampaign(msg *p2PMessage)

+ func (m *MessageRouter) RouteConsensusDkgDeal(msg *p2PMessage)

+ func (m *MessageRouter) RouteConsensusDkgDealResponse(msg *p2PMessage)

+ func (m *MessageRouter) RouteConsensusDkgGenesisPublicKey(msg *p2PMessage)

+ func (m *MessageRouter) RouteConsensusDkgSigSets(msg *p2PMessage)

+ func (m *MessageRouter) RouteConsensusPreCommit(msg *p2PMessage)

+ func (m *MessageRouter) RouteConsensusPreVote(msg *p2PMessage)

+ func (m *MessageRouter) RouteConsensusProposal(msg *p2PMessage)

+ func (m *MessageRouter) RouteControlMsg(msg *p2PMessage)

+ func (m *MessageRouter) RouteFetchByHashRequest(msg *p2PMessage)

+ func (m *MessageRouter) RouteFetchByHashResponse(msg *p2PMessage)

+ func (m *MessageRouter) RouteGetMsg(msg *p2PMessage)

+ func (m *MessageRouter) RouteHeaderRequest(msg *p2PMessage)

+ func (m *MessageRouter) RouteHeaderResponse(msg *p2PMessage)

+ func (m *MessageRouter) RouteNewSequencer(msg *p2PMessage)

+ func (m *MessageRouter) RouteNewTx(msg *p2PMessage)

+ func (m *MessageRouter) RouteNewTxs(msg *p2PMessage)

+ func (m *MessageRouter) RoutePing(msg *p2PMessage)

+ func (m *MessageRouter) RoutePong(*p2PMessage)

+ func (m *MessageRouter) RouteSequencerHeader(msg *p2PMessage)

+ func (m *MessageRouter) RouteTermChange(msg *p2PMessage)

+ func (m *MessageRouter) RouteTermChangeRequest(msg *p2PMessage)

+ func (m *MessageRouter) RouteTermChangeResponse(msg *p2PMessage)

+ func (m *MessageRouter) RouteTxsRequest(msg *p2PMessage)

+ func (m *MessageRouter) RouteTxsResponse(msg *p2PMessage)

+ func (m *MessageRouter) Start()

+ func (m *MessageRouter) Stop()

+ type MessageRouterOG02 struct

+ GetNodeDataMsgHandler GetNodeDataMsgHandler

+ GetReceiptsMsgHandler GetReceiptsMsgHandler

+ NodeDataMsgHandler NodeDataMsgHandler

+ func (m *MessageRouterOG02) Name() string

+ func (m *MessageRouterOG02) RouteGetNodeDataMsg(msg *p2PMessage)

+ func (m *MessageRouterOG02) RouteGetReceiptsMsg(msg *p2PMessage)

+ func (m *MessageRouterOG02) RouteNodeDataMsg(msg *p2PMessage)

+ func (m *MessageRouterOG02) Start()

+ func (m *MessageRouterOG02) Stop()

+ type MessageType uint16

+ const GetNodeDataMsg

+ const GetReceiptsMsg

+ const MessageTypeBodiesRequest

+ const MessageTypeBodiesResponse

+ const MessageTypeCampaign

+ const MessageTypeConsensusDkgDeal

+ const MessageTypeConsensusDkgDealResponse

+ const MessageTypeConsensusDkgGenesisPublicKey

+ const MessageTypeConsensusDkgSigSets

+ const MessageTypeControl

+ const MessageTypeDuplicate

+ const MessageTypeFetchByHashRequest

+ const MessageTypeFetchByHashResponse

+ const MessageTypeGetMsg

+ const MessageTypeHeaderRequest

+ const MessageTypeHeaderResponse

+ const MessageTypeNewSequencer

+ const MessageTypeNewTx

+ const MessageTypeNewTxs

+ const MessageTypeOg01Length

+ const MessageTypeOg02Length

+ const MessageTypePing

+ const MessageTypePong

+ const MessageTypePreCommit

+ const MessageTypePreVote

+ const MessageTypeProposal

+ const MessageTypeSecret

+ const MessageTypeSequencerHeader

+ const MessageTypeTermChange

+ const MessageTypeTermChangeRequest

+ const MessageTypeTermChangeResponse

+ const MessageTypeTxsRequest

+ const MessageTypeTxsResponse

+ const NodeDataMsg

+ const StatusMsg

+ func (mt MessageType) Code() p2p.MsgCodeType

+ func (mt MessageType) String() string

+ func (z *MessageType) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *MessageType) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z MessageType) EncodeMsg(en *msgp.Writer) (err error)

+ func (z MessageType) MarshalMsg(b []byte) (o []byte, err error)

+ func (z MessageType) Msgsize() (s int)

+ type NewSequencerHandler interface

+ HandleNewSequencer func(msg *types.MessageNewSequencer, peerId string)

+ type NewTxHandler interface

+ HandleNewTx func(msg *types.MessageNewTx, peerId string)

+ type NewTxsHandler interface

+ HandleNewTxs func(newTxs *types.MessageNewTxs, peerId string)

+ type NodeDataMsgHandler interface

+ HandleNodeDataMsg func(peerId string)

+ type NodeStatus struct

+ Difficulty *big.Int

+ Genesis types.Hash

+ Head types.Hash

+ Network uint64

+ type NodeStatusDataProvider interface

+ GetCurrentNodeStatus func() StatusData

+ GetHeight func() uint64

+ type OGConfig struct

+ CryptoType crypto.CryptoType

+ GenesisPath string

+ NetworkId uint64

+ func DefaultOGConfig() OGConfig

+ type Og struct

+ CryptoType crypto.CryptoType

+ Dag *core.Dag

+ Manager *MessageRouter

+ NetworkId uint64

+ NewLatestSequencerCh chan bool

+ TxBuffer *TxBuffer

+ TxPool *core.TxPool

+ func NewOg(config OGConfig) (*Og, error)

+ func (og *Og) BroadcastLatestSequencer()

+ func (og *Og) GetCurrentNodeStatus() StatusData

+ func (og *Og) GetHeight() uint64

+ func (og *Og) GetSequencerByHash(hash types.Hash) *types.Sequencer

+ func (og *Og) Name() string

+ func (og *Og) Start()

+ func (og *Og) Stop()

+ type PeerInfo struct

+ Addrs string

+ Head string

+ InBound bool

+ Link bool

+ SequencerId uint64

+ ShortId string

+ Version int

+ type PeerProvider interface

+ BestPeerInfo func() (peerId string, hash types.Hash, seqId uint64, err error)

+ GetPeerHead func(peerId string) (hash types.Hash, seqId uint64, err error)

+ type PingHandler interface

+ HandlePing func(peerId string)

+ type PongHandler interface

+ HandlePong func()

+ type RequestCache struct

+ type SendingType uint8

+ func (z *SendingType) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *SendingType) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z SendingType) EncodeMsg(en *msgp.Writer) (err error)

+ func (z SendingType) MarshalMsg(b []byte) (o []byte, err error)

+ func (z SendingType) Msgsize() (s int)

+ type SequencerHeaderHandler interface

+ HandleSequencerHeader func(msgHeader *types.MessageSequencerHeader, peerId string)

+ type StatusData struct

+ CurrentBlock types.Hash

+ CurrentId uint64

+ GenesisBlock types.Hash

+ NetworkId uint64

+ ProtocolVersion uint32

+ func (s *StatusData) String() string

+ func (z *StatusData) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *StatusData) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *StatusData) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *StatusData) Msgsize() (s int)

+ func (z *StatusData) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type Syncer interface

+ ClearQueue func()

+ Enqueue func(hash *types.Hash, childHash types.Hash, sendBloomFilter bool)

+ IsCachedHash func(hash types.Hash) bool

+ type TermChangeHandler interface

+ HandleTermChange func(request *types.MessageTermChange, peerId string)

+ type TermChangeRequestHandler interface

+ HandleTermChangeRequest func(request *types.MessageTermChangeRequest, peerId string)

+ type TermChangeResponseHandler interface

+ HandleTermChangeResponse func(request *types.MessageTermChangeResponse, peerId string)

+ type TipGenerator interface

+ GetRandomTips func(n int) (v []types.Txi)

+ type TxBuffer struct

+ Announcer Announcer

+ OnProposalSeqCh chan types.Hash

+ ReceivedNewTxChan chan types.Txi

+ ReceivedNewTxsChan chan []types.Txi

+ SelfGeneratedNewTxChan chan types.Txi

+ Syncer Syncer

+ func NewTxBuffer(config TxBufferConfig) *TxBuffer

+ func (b *TxBuffer) GetBenchmarks() map[string]interface{}

+ func (b *TxBuffer) GetFromAllKnownSource(hash types.Hash) types.Txi

+ func (b *TxBuffer) GetFromBuffer(hash types.Hash) types.Txi

+ func (b *TxBuffer) GetFromProviders(hash types.Hash) types.Txi

+ func (b *TxBuffer) IsCachedHash(hash types.Hash) bool

+ func (b *TxBuffer) IsKnownHash(hash types.Hash) bool

+ func (b *TxBuffer) IsReceivedHash(hash types.Hash) bool

+ func (b *TxBuffer) Name() string

+ func (b *TxBuffer) Start()

+ func (b *TxBuffer) Stop()

+ type TxBufferConfig struct

+ AddedToPoolQueueSize int

+ Dag IDag

+ DependencyCacheExpirationSeconds int

+ DependencyCacheMaxSize int

+ KnownCacheExpirationSeconds int

+ KnownCacheMaxSize int

+ NewTxQueueSize int

+ Syncer Syncer

+ TxAnnouncer Announcer

+ TxPool ITxPool

+ Verifiers []Verifier

+ type TxCreator struct

+ DebugNodeId int

+ GraphVerifier Verifier

+ MaxConnectingTries int

+ MaxMinedHash types.Hash

+ MaxTxHash types.Hash

+ Miner miner.Miner

+ Signer crypto.Signer

+ TipGenerator TipGenerator

+ func (m *TxCreator) GenerateSequencer(issuer types.Address, Height uint64, accountNonce uint64, ...) (seq *types.Sequencer)

+ func (m *TxCreator) NewSignedSequencer(issuer types.Address, height uint64, accountNonce uint64, ...) types.Txi

+ func (m *TxCreator) NewSignedTx(from types.Address, to types.Address, value *math.BigInt, accountNonce uint64, ...) types.Txi

+ func (m *TxCreator) NewTxWithSeal(from types.Address, to types.Address, value *math.BigInt, data []byte, ...) (tx types.Txi, err error)

+ func (m *TxCreator) NewUnsignedSequencer(issuer types.Address, Height uint64, accountNonce uint64) *types.Sequencer

+ func (m *TxCreator) NewUnsignedTx(from types.Address, to types.Address, value *math.BigInt, accountNonce uint64) types.Txi

+ func (m *TxCreator) SealTx(tx types.Txi, priveKey *crypto.PrivateKey) (ok bool)

+ func (t *TxCreator) Stop()

+ type TxFormatVerifier struct

+ CryptoType crypto.CryptoType

+ MaxMinedHash types.Hash

+ MaxTxHash types.Hash

+ Signer crypto.Signer

+ func (v *TxFormatVerifier) Name() string

+ func (v *TxFormatVerifier) Verify(t types.Txi) bool

+ func (v *TxFormatVerifier) VerifyHash(t types.Txi) bool

+ func (v *TxFormatVerifier) VerifySignature(t types.Txi) bool

+ func (v *TxFormatVerifier) VerifySourceAddress(t types.Txi) bool

+ type TxsRequestHandler interface

+ HandleTxsRequest func(msgReq *types.MessageTxsRequest, peerID string)

+ type TxsResponseHandler interface

+ HandleTxsResponse func(request *types.MessageTxsResponse)

+ type Verifier interface

+ Name func() string

+ Verify func(t types.Txi) bool

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL