node

Aug 11, 2020

Changes in this version

type Delegate

+ func (c *Delegate) JudgeNonce(me *account.Account) uint64

+ type Node2 struct

+ PhysicalCommunicator community.LibP2pPhysicalCommunicator

+ PrivateInfoProvider account.PrivateInfoProvider

+ func (n *Node2) InitDefault()

+ func (n *Node2) Setup()

+ type PhysicalCommunicator interface

+ ClosePeer func(id string)

+ GetIncomingChannel func() chan *WireMessage

+ GetNeighbour func(id string) (neighbour *Neighbour, err error)

+ Start func()

+ Stop func()

Aug 10, 2020

Changes in this version

+ func GetHostName() string

Jul 17, 2019

Changes in this version

type AutoClient

+ ArchiveInterValUs int

+ AutoArchiveEnabled bool

+ TestDagPush bool

+ TestInsertPool bool

+ TestSeal bool

+ TestSigNature bool

+ TestSyncBuffer bool

+ TpsTest bool

+ TpsTestInit bool

+ type BootstrapInfoRequest struct

+ NetworkId int64

+ ONode string

+ PublicKey string

+ type BootstrapInfoResponse struct

+ BootstrapNode bool

+ BootstrapNodes string

+ GenesisPk string

+ Message string

+ Partners int

+ Status string

type Delegate

+ InsertSyncBuffer insertTxsFn

+ ReceivedNewTxChan chan types.Txi

+ ReceivedNewTxsChan chan []types.Txi

+ func (c *Delegate) GenerateArchive(data []byte) (tx types.Txi, err error)

+ func (d *Delegate) GetTxNum() uint32

+ func (d *Delegate) TooMoreTx() bool

type TxRequest

+ TokenId int32

May 31, 2019

Changes in this version

+ const IntervalModeConstantInterval

+ const IntervalModeRandom

+ func NewP2PServer(privKey *ecdsa.PrivateKey, bootNode bool) *p2p.Server

+ func SetupCallbacks(m *og.MessageRouter, hub *og.Hub)

+ func SetupCallbacksOG32(m *og.MessageRouterOG02, hub *og.Hub)

+ func StringArrayToIntArray(arr []string) []int

+ type AutoClient struct

+ AutoSequencerEnabled bool

+ AutoTxEnabled bool

+ CampainEnable bool

+ Delegate *Delegate

+ IntervalMode string

+ ManualChan chan types.TxBaseType

+ MyAccount *account.SampleAccount

+ MyIndex int

+ NewRawTx chan types.Txi

+ NonceSelfDiscipline bool

+ SampleAccounts []*account.SampleAccount

+ SequencerIntervalUs int

+ TxIntervalUs int

+ func (c *AutoClient) Init()

+ func (c *AutoClient) Pause()

+ func (c *AutoClient) Resume()

+ func (c *AutoClient) SetTxIntervalUs(i int)

+ func (c *AutoClient) Start()

+ func (c *AutoClient) Stop()

+ type AutoClientManager struct

+ Clients []*AutoClient

+ NodeStatusDataProvider og.NodeStatusDataProvider

+ RegisterReceiver func(c chan types.Txi)

+ SampleAccounts []*account.SampleAccount

+ UpToDateEventListener chan bool

+ func (a *AutoClientManager) JudgeNonce(me *account.SampleAccount) uint64

+ func (m *AutoClientManager) Init(accountIndices []int, delegate *Delegate, ...)

+ func (m *AutoClientManager) Name() string

+ func (m *AutoClientManager) SetTxIntervalUs(interval int)

+ func (m *AutoClientManager) Start()

+ func (m *AutoClientManager) Stop()

+ type Component interface

+ Name func() string

+ Start func()

+ Stop func()

+ type Delegate struct

+ Dag *core.Dag

+ OnNewTxiGenerated []chan types.Txi

+ TxBuffer *og.TxBuffer

+ TxCreator *og.TxCreator

+ TxPool *core.TxPool

+ func (c *Delegate) Announce(txi types.Txi)

+ func (c *Delegate) GenerateSequencer(r SeqRequest) (seq types.Txi, err error)

+ func (c *Delegate) GenerateTx(r TxRequest) (tx types.Txi, err error)

+ func (c *Delegate) GetLatestAccountNonce(addr types.Address) (uint64, error)

+ func (c *Delegate) GetLatestDagSequencer() *types.Sequencer

+ type Node struct

+ Components []Component

+ func NewNode() *Node

+ func (n *Node) Start()

+ func (n *Node) Stop()

+ type SeqRequest struct

+ Height uint64

+ Issuer types.Address

+ Nonce uint64

+ PrivateKey crypto.PrivateKey

+ type TxRequest struct

+ AddrFrom types.Address

+ AddrTo types.Address

+ Nonce uint64

+ PrivateKey crypto.PrivateKey

+ Value *math.BigInt