iservices

package

Go to main page

Versions in this module

v1

v1.0.8

Mar 26, 2020

v1.0.7

Jan 27, 2020

v1.0.6

Jan 9, 2020

Changes in this version

type IOTrxRecord

+ Amount uint64

+ From string

+ To string

v1.0.5

Dec 13, 2019

v1.0.4

Nov 26, 2019

Changes in this version

+ const FastForwardStatus

+ const IOTrxServiceName

+ const IOTrxSplitSizeInMillion

+ const IOTrxTable

+ const MiddleStatus

+ const SyncForwardStatus

+ const ThresholdForFastConvertToSync

+ func IOTrxTableNameForBlockHeight(num uint64) string

+ type DeprecatedBlockLogProgress struct

+ BlockHeight uint64

+ FinishAt time.Time

+ ID uint64

+ func (DeprecatedBlockLogProgress) TableName() string

+ type IOTrxRecord struct

+ Account string

+ Action string

+ BlockHeight uint64

+ BlockTime time.Time

+ ID uint64

+ TrxHash string

+ func (log *IOTrxRecord) TableName() string

+ type Progress struct

+ BlockHeight uint64

+ FinishAt time.Time

+ ID uint64

+ Processor string

+ SyncStatus *int

v1.0.3

Nov 8, 2019

Changes in this version

type IP2P

+ FetchMissingBlock func(from, to comn.BlockID)

v1.0.2

Oct 14, 2019

Changes in this version

+ const BlockLogProcessServiceName

+ const BlockLogServiceName

+ const BlockLogSplitSizeInMillion

+ const BlockLogTable

+ var DailyStatisticServiceName = "dailystatservice"

+ var DbServerName = "db"

+ var DbTrunk = ""

+ var RpcServerName = "rpc"

+ var TxPoolServerName = "ctrl"

+ func BlockLogTableNameForBlockHeight(num uint64) string

+ type BlockLogRecord struct

+ BlockHeight uint64

+ BlockId string

+ BlockProducer string

+ BlockTime time.Time

+ Final bool

+ ID uint64

+ JsonLog string

+ func (log *BlockLogRecord) TableName() string

type IConsensus

+ ActiveValidators func() []string

+ CheckSyncFinished func() bool

+ EnableMockSignal func()

+ FetchBlocks func(from, to uint64) ([]common.ISignedBlock, error)

+ GetBFTCommitInfo func(num uint64) interface{}

+ GetLIB func() common.BlockID

+ GetLastBFTCommit func() (evidence interface{})

+ GetName func() string

+ GetNextBFTCheckPoint func(blockNum uint64) (evidence interface{})

+ IsCommitted func(id common.BlockID) bool

+ IsOnMainBranch func(id common.BlockID) (bool, error)

+ MaybeProduceBlock func()

+ MockMaliciousBehaviour func(b bool)

+ Push func(msg interface{}, p common.IPeer)

+ PushTransactionToPending func(trx common.ISignedTransaction) error

+ ResetProdTimer func(t time.Duration)

+ ResetTicker func(t time.Time)

+ SetHook func(key string, f func(args ...interface{}))

+ type IDailyStats interface

+ DailyStatsSince func(days int, dapp string) []*itype.Row

+ type IDatabasePatch interface

+ Apply func() error

+ NewPatch func(branchId ...string) IDatabasePatch

+ type IDatabaseRW interface

+ Delete func(key []byte) error

+ DeleteBatch func(b IDatabaseBatch)

+ Get func(key []byte) ([]byte, error)

+ Has func(key []byte) (bool, error)

+ Iterate func(start, limit []byte, reverse bool, callback func(key, value []byte) bool)

+ NewBatch func() IDatabaseBatch

+ Put func(key []byte, value []byte) error

type IDatabaseService

+ BeginTransactionWithTag func(tag string)

+ EnableReversion func(b bool) error

+ HashOfTopTransaction func() uint32

+ Lock func()

+ NewPatch func(branchId ...string) IDatabasePatch

+ RLock func()

+ RUnlock func()

+ ReversionEnabled func() bool

+ RollbackTag func(tag string) error

+ Squash func(tag string) error

+ Unlock func()

+ type IDatabaseServiceId interface

+ BranchId func() string

+ ServiceId func() uint32

+ type IGlobalPropRW interface

+ type IGlobalPropReader interface

+ GetProps func() *prototype.DynamicProperties

+ HeadBlockTime func() *prototype.TimePointSec

+ type IGlobalPropWriter interface

+ ModifyProps func(modifier func(oldProps *prototype.DynamicProperties))

+ TransferFromStakeVest func(value *prototype.Vest)

+ TransferFromVest func(value *prototype.Vest)

+ TransferToStakeVest func(value *prototype.Coin)

+ TransferToVest func(value *prototype.Coin)

+ UpdateTicketIncomeAndNum func(income *prototype.Vest, count uint64)

type IP2P

+ FetchOutOfRange func(localHeadID, targetID comn.BlockID)

+ FetchUnlinkedBlock func(prevId comn.BlockID)

+ GetMockLatency func() int

+ GetNodeNeighbours func() string

+ RandomSend func(message interface{})

+ RequestCheckpoint func(startNum, endNum uint64)

+ SendToPeer func(p *peer.Peer, message interface{})

+ SetMockLatency func(t int)

+ type ITrxPool interface

+ CalculateUserMaxStamina func(db IDatabaseRW, name string) uint64

+ CheckNetForRPC func(name string, db IDatabaseRW, sizeInBytes uint64) (bool, uint64, uint64)

+ Commit func(num uint64)

+ EstimateStamina func(trx *prototype.SignedTransaction) *prototype.TransactionReceiptWithInfo

+ GenerateAndApplyBlock func(bpName string, pre *prototype.Sha256, timestamp uint32, ...) (*prototype.SignedBlock, error)

+ GenerateBlock func(bpName string, pre *prototype.Sha256, timestamp uint32, ...) (*prototype.SignedBlock, error)

+ GetBlockProducerTopN func(n uint32) ([]string, []*prototype.PublicKeyType)

+ GetFinalizedNum func() (uint64, error)

+ GetHeadBlockNum func() (uint64, error)

+ GetShuffledBpList func() ([]string, []*prototype.PublicKeyType, uint64)

+ GetSigningPubKey func(bpName string) *prototype.PublicKeyType

+ HardFork func() uint64

+ PopBlock func(num uint64) error

+ PreShuffle func() error

+ PushBlock func(blk *prototype.SignedBlock, skip prototype.SkipFlag) error

+ PushTrx func(trx *prototype.SignedTransaction) *prototype.TransactionReceiptWithInfo

+ PushTrxToPending func(trx *prototype.SignedTransaction) error

+ SetShuffle func(s common.ShuffleFunc)

+ SetShuffledBpList func(names []string, keys []*prototype.PublicKeyType, seq uint64)

+ Sign func(priv *prototype.PrivateKeyType, digest []byte) []byte

+ ValidateAddress func(name string, pubKey *prototype.PublicKeyType) bool

+ VerifySig func(name *prototype.AccountName, digest []byte, sig []byte) bool

v0

v0.0.1

Dec 1, 2018

Changes in this version

+ var CTRL_SERVER_NAME = "ctrl"

+ var ConsensusServerName = "consensus"

+ var DB_SERVER_NAME = "db"

+ var ECO_SERVICE_NAME = "economist"

+ var P2PServerName = "p2p"

+ var RPC_SERVER_NAME = "rpc"

+ type IConsensus interface

+ ActiveProducers func() []string

+ CurrentProducer func() string

+ FetchBlock func(id common.BlockID) (common.ISignedBlock, error)

+ FetchBlocksSince func(id common.BlockID) ([]common.ISignedBlock, error)

+ GetHeadBlockId func() common.BlockID

+ GetIDs func(start, end common.BlockID) ([]common.BlockID, error)

+ HasBlock func(id common.BlockID) bool

+ PushBlock func(b common.ISignedBlock)

+ PushTransaction func(trx common.ISignedTransaction, wait bool, broadcast bool) common.ITransactionInvoice

+ SetBootstrap func(b bool)

+ type IController interface

+ AddWeightedVP func(value uint64)

+ Commit func(num uint32)

+ GenerateBlock func(witness string, pre *prototype.Sha256, timestamp uint32, ...) *prototype.SignedBlock

+ GetShuffledWitness func() []string

+ GetWitnessTopN func(n uint32) []string

+ HeadBlockTime func() *prototype.TimePointSec

+ PopBlockTo func(num uint32)

+ PushBlock func(blk *prototype.SignedBlock, skip prototype.SkipFlag) error

+ PushTrx func(trx *prototype.SignedTransaction) *prototype.TransactionInvoice

+ SetShuffledWitness func(names []string)

+ TransferFromVest func(value *prototype.Vest)

+ TransferToVest func(value *prototype.Coin)

+ type IDatabaseBatch interface

+ Delete func(key []byte) error

+ Put func(key []byte, value []byte) error

+ Reset func()

+ Write func() error

+ type IDatabaseIterator interface

+ Key func() ([]byte, error)

+ Next func() bool

+ Valid func() bool

+ Value func() ([]byte, error)

+ type IDatabaseService interface

+ BeginTransaction func()

+ Close func()

+ Delete func(key []byte) error

+ DeleteAll func() error

+ DeleteBatch func(b IDatabaseBatch)

+ DeleteIterator func(it IDatabaseIterator)

+ EndTransaction func(commit bool) error

+ Get func(key []byte) ([]byte, error)

+ GetRevision func() uint64

+ GetRevisionAndBase func() (current uint64, base uint64)

+ GetRevisionTag func(r uint64) string

+ GetTagRevision func(tag string) (uint64, error)

+ Has func(key []byte) (bool, error)

+ NewBatch func() IDatabaseBatch

+ NewIterator func(start []byte, limit []byte) IDatabaseIterator

+ NewReversedIterator func(start []byte, limit []byte) IDatabaseIterator

+ Put func(key []byte, value []byte) error

+ RebaseToRevision func(r uint64) error

+ RebaseToTag func(tag string) error

+ RevertToRevision func(r uint64) error

+ RevertToTag func(tag string) error

+ TagRevision func(r uint64, tag string) error

+ TransactionHeight func() uint

+ type IEconomist interface

+ Do func() error

+ type IP2P interface

+ Broadcast func(message interface{})

+ Send func(p *peer.Peer, msg types.Message, isConsensus bool) error

+ TriggerSync func(HeadId comn.BlockID)

+ type IPrinter interface

+ GetCurrent func() string

+ type IRPCServer interface

+ type ITimer interface

+ GetCurrent func() string

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