wavelet

package module

Go to main page

Versions in this module

v0

v0.2.0

Oct 3, 2019

Changes in this version

+ var ErrDepthTooLow = errors.New("transaction depth is too low")

+ var ErrOutOfSync = errors.New("Node is currently ouf of sync. Please try again later.")

+ var ErrParentDepthLimitExceeded = errors.New("transactions parents exceed depth limit")

+ var FaucetWallet = "87a6813c3b4cf534b6ae82db9b1409fa7dbd5c13dba5858970b56084c4a930eb400056ee68a7cc2695222df05ea76875bc27ec6e61e8e62317c336157019c405"

+ var ZeroPage = make([]byte, PageSize)

+ func CloneVM(vm *exec.VirtualMachine, gasPolicy compiler.GasPolicy, ...) (*exec.VirtualMachine, error)

+ func CollectVotesForFinalization(accounts *Accounts, snowball *Snowball, voteChan <-chan finalizationVote, ...)

+ func CollectVotesForSync(accounts *Accounts, snowball *Snowball, voteChan <-chan syncVote, ...)

+ func SetGenesisByNetwork(name string) error

+ type CollapseContext struct

+ VMCache *lru.LRU

+ func NewCollapseContext(tree *avl.Tree) *CollapseContext

+ func (c *CollapseContext) ApplyTransaction(round *Round, tx *Transaction) error

+ func (c *CollapseContext) Flush() error

+ func (c *CollapseContext) GetContractState(id AccountID) (*VMState, bool)

+ func (c *CollapseContext) ReadAccountBalance(id AccountID) (uint64, bool)

+ func (c *CollapseContext) ReadAccountContractCode(id TransactionID) ([]byte, bool)

+ func (c *CollapseContext) ReadAccountContractGasBalance(id TransactionID) (uint64, bool)

+ func (c *CollapseContext) ReadAccountNonce(id AccountID) (uint64, bool)

+ func (c *CollapseContext) ReadAccountReward(id AccountID) (uint64, bool)

+ func (c *CollapseContext) ReadAccountStake(id AccountID) (uint64, bool)

+ func (c *CollapseContext) ReadAccountsLen() uint64

+ func (c *CollapseContext) SetContractState(id AccountID, state *VMState)

+ func (c *CollapseContext) StoreRewardWithdrawalRequest(rw RewardWithdrawalRequest)

+ func (c *CollapseContext) WriteAccountBalance(id AccountID, balance uint64)

+ func (c *CollapseContext) WriteAccountContractCode(id TransactionID, code []byte)

+ func (c *CollapseContext) WriteAccountContractGasBalance(id TransactionID, gasBalance uint64)

+ func (c *CollapseContext) WriteAccountNonce(id AccountID, nonce uint64)

+ func (c *CollapseContext) WriteAccountReward(id AccountID, reward uint64)

+ func (c *CollapseContext) WriteAccountStake(id AccountID, stake uint64)

+ func (c *CollapseContext) WriteAccountsLen(size uint64)

+ type CollapseState struct

+ type DownloadMissingTxRequest struct

+ Ids [][]byte

+ func (*DownloadMissingTxRequest) Descriptor() ([]byte, []int)

+ func (*DownloadMissingTxRequest) ProtoMessage()

+ func (m *DownloadMissingTxRequest) GetIds() [][]byte

+ func (m *DownloadMissingTxRequest) Marshal() (dAtA []byte, err error)

+ func (m *DownloadMissingTxRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *DownloadMissingTxRequest) Reset()

+ func (m *DownloadMissingTxRequest) Size() (n int)

+ func (m *DownloadMissingTxRequest) String() string

+ func (m *DownloadMissingTxRequest) Unmarshal(dAtA []byte) error

type DownloadTxRequest

+ Depth uint64

+ SkipIds [][]byte

+ func (m *DownloadTxRequest) GetDepth() uint64

+ func (m *DownloadTxRequest) GetSkipIds() [][]byte

type Graph

+ func (g *Graph) IncompleteLen() int

+ type Identifiable interface

+ GetID func() string

type Ledger

+ func (l *Ledger) Close()

+ func (l *Ledger) Restart() error

+ func (l *Ledger) SyncStatus() string

+ func (l *Ledger) SyncTransactions()

type Option

+ func WithMaxMemoryMB(n uint64) Option

type OutOfSyncRequest

+ RoundIndex uint64

+ func (m *OutOfSyncRequest) GetRoundIndex() uint64

type OutOfSyncResponse

+ OutOfSync bool

+ func (m *OutOfSyncResponse) GetOutOfSync() bool

type Protocol

+ func (p *Protocol) DownloadMissingTx(ctx context.Context, req *DownloadMissingTxRequest) (*DownloadTxResponse, error)

type Round

+ Transactions uint32

+ func (r *Round) GetID() string

+ type StallDetector struct

+ func NewStallDetector(stop <-chan struct{}, config StallDetectorConfig, ...) *StallDetector

+ func (d *StallDetector) Run(wg *sync.WaitGroup)

+ type StallDetectorConfig struct

+ MaxMemoryMB uint64

+ type StallDetectorDelegate struct

+ PrepareShutdown func(error)

type TestLedger

+ func (l *TestLedger) BalanceWithPublicKey(key AccountID) uint64

+ func (l *TestLedger) Benchmark(batchSize int) (Transaction, error)

+ func (l *TestLedger) CallContract(id [32]byte, amount uint64, gasLimit uint64, funcName string, params []byte) (Transaction, error)

+ func (l *TestLedger) Client() *skademlia.Client

+ func (l *TestLedger) DBPath() string

+ func (l *TestLedger) DepositGas(id [32]byte, gasDeposit uint64) (Transaction, error)

+ func (l *TestLedger) GasBalanceOfAddress(address [32]byte) uint64

+ func (l *TestLedger) Leave()

+ func (l *TestLedger) Ledger() *Ledger

+ func (l *TestLedger) PrivateKey() edwards25519.PrivateKey

+ func (l *TestLedger) RewardWithPublicKey(key AccountID) uint64

+ func (l *TestLedger) RoundIndex() uint64

+ func (l *TestLedger) SpawnContract(contractPath string, gasLimit uint64, params []byte) (Transaction, error)

+ func (l *TestLedger) StakeWithPublicKey(key AccountID) uint64

+ func (l *TestLedger) WaitForRound(index uint64) <-chan uint64

+ func (l *TestLedger) WaitForSync() <-chan bool

+ func (l *TestLedger) WaitUntilBalance(t testing.TB, balance uint64)

+ func (l *TestLedger) WaitUntilConsensus(t testing.TB)

+ func (l *TestLedger) WaitUntilRound(t testing.TB, round uint64)

+ func (l *TestLedger) WaitUntilStake(t testing.TB, stake uint64)

type TestLedgerConfig

+ DBPath string

+ N int

+ RemoveExistingDB bool

+ type TestLedgerOption func(cfg *TestLedgerConfig)

+ func WithDBPath(path string) TestLedgerOption

+ func WithKeepExistingDB() TestLedgerOption

+ func WithPeers(peers ...string) TestLedgerOption

+ func WithWallet(wallet string) TestLedgerOption

type TestNetwork

+ func (n *TestNetwork) Faucet() *TestLedger

+ func (n *TestNetwork) Nodes() []*TestLedger

+ func (n *TestNetwork) SetFaucet(node *TestLedger)

+ func (n *TestNetwork) WaitForRound(t testing.TB, round uint64)

+ func (n *TestNetwork) WaitForSync(t testing.TB)

+ type TestNetworkConfig struct

+ AddFaucet bool

+ type TestNetworkOption func(cfg *TestNetworkConfig)

+ func WithoutFaucet() TestNetworkOption

type Transaction

+ func (tx Transaction) ComputeSize() int

+ func (tx Transaction) Fee() uint64

+ type VMState struct

+ Globals []int64

+ Memory []byte

+ func SnapshotVMState(vm *exec.VirtualMachine) VMState

+ func (state VMState) Apply(vm *exec.VirtualMachine, gasPolicy compiler.GasPolicy, ...) (*exec.VirtualMachine, error)

type WaveletClient

+ DownloadMissingTx func(ctx context.Context, in *DownloadMissingTxRequest, opts ...grpc.CallOption) (*DownloadTxResponse, error)

type WaveletServer

+ DownloadMissingTx func(context.Context, *DownloadMissingTxRequest) (*DownloadTxResponse, error)

v0.1.1

Aug 13, 2019

Changes in this version

+ func LoadContractGlobals(snapshot *avl.Tree, id AccountID) ([]int64, bool)

+ func ReadAccountContractGlobals(tree *avl.Tree, id TransactionID) ([]byte, bool)

+ func SaveContractGlobals(snapshot *avl.Tree, id AccountID, globals []int64)

+ func TestWaitForConsensus(t testing.TB, timeout time.Duration, ledgers []*TestLedger)

+ func WriteAccountContractGlobals(tree *avl.Tree, id TransactionID, globals []byte)

type Ledger

+ func (l *Ledger) BroadcastingNop() bool

+ type Option func(cfg *config)

+ func WithGenesis(genesis *string) Option

+ func WithoutGC() Option

+ type TestLedger struct

+ func NewTestFaucet(t testing.TB) *TestLedger

+ func NewTestLedger(t testing.TB, cfg TestLedgerConfig) *TestLedger

+ func (l *TestLedger) Addr() string

+ func (l *TestLedger) Applied(tx Transaction) bool

+ func (l *TestLedger) Balance() uint64

+ func (l *TestLedger) BalanceOfAccount(node *TestLedger) uint64

+ func (l *TestLedger) Cleanup()

+ func (l *TestLedger) FindTransaction(t testing.TB, id TransactionID) *Transaction

+ func (l *TestLedger) Nop() (Transaction, error)

+ func (l *TestLedger) Pay(to *TestLedger, amount uint64) (Transaction, error)

+ func (l *TestLedger) PlaceStake(amount uint64) (Transaction, error)

+ func (l *TestLedger) PublicKey() AccountID

+ func (l *TestLedger) Reward() uint64

+ func (l *TestLedger) Stake() uint64

+ func (l *TestLedger) StakeOfAccount(node *TestLedger) uint64

+ func (l *TestLedger) WaitForConsensus() <-chan bool

+ func (l *TestLedger) WithdrawReward(amount uint64) (Transaction, error)

+ func (l *TestLedger) WithdrawStake(amount uint64) (Transaction, error)

+ type TestLedgerConfig struct

+ Peers []string

+ Wallet string

+ type TestNetwork struct

+ func NewTestNetwork(t testing.TB) *TestNetwork

+ func (n *TestNetwork) AddNode(t testing.TB, startingBalance uint64) *TestLedger

+ func (n *TestNetwork) Cleanup()

+ func (n *TestNetwork) WaitForConsensus(t testing.TB)

v0.1.0

Jul 31, 2019

Changes in this version

+ const PayloadParamNameAmount

+ const PayloadParamNameContractCode

+ const PayloadParamNameFuncName

+ const PayloadParamNameFuncPayload

+ const PayloadParamNameGasDeposit

+ const PayloadParamNameGasLimit

+ const PayloadParamNameOperation

+ const PayloadParamNameRecipient

+ const SizeTransactionSeed

+ var ErrCouldNotParse = errors.New("could not parse the given payload")

+ var ErrInvalidAccountIDSize = errors.New("account ID is of an invalid size")

+ var ErrInvalidOperation = errors.New("operation is invalid")

+ var ErrInvalidTag = errors.New("tag is invalid")

+ var ErrNilField = errors.New("field is nil")

+ var ErrNoTag = errors.New("no tag specified")

+ func ApplyTransaction(round *Round, state *avl.Tree, tx *Transaction) error

+ func ParseJSON(data []byte, tag string) ([]byte, error)

+ func ReadAccountContractGasBalance(tree *avl.Tree, id TransactionID) (uint64, bool)

+ func WriteAccountContractGasBalance(tree *avl.Tree, id TransactionID, gasBalance uint64)

type Batch

+ func ParseBatch(payload []byte) (Batch, error)

+ func (b *Batch) AddContract(c Contract) error

+ func (b *Batch) AddNop() error

+ func (b *Batch) AddStake(s Stake) error

+ func (b *Batch) AddTransfer(t Transfer) error

+ func (b Batch) Marshal() []byte

type Contract

+ GasDeposit uint64

+ func ParseContract(payload []byte) (Contract, error)

+ func (c Contract) Marshal() []byte

type GraphOption

+ func WithIndexer(indexer *Indexer) GraphOption

+ type Indexer struct

+ func NewIndexer() *Indexer

+ func (m *Indexer) Find(query string, count int) []string

+ func (m *Indexer) Index(id string)

+ func (m *Indexer) Remove(id string)

type Ledger

+ func (l *Ledger) Find(query string, count int) []string

+ func (l *Ledger) PushSendQuota()

+ func (l *Ledger) TakeSendQuota() bool

type SnowballOption

+ func WithName(name string) SnowballOption

type Stake

+ func ParseStake(payload []byte) (Stake, error)

+ func (s Stake) Marshal() []byte

type Transaction

+ ParentSeeds []TransactionSeed

+ type TransactionSeed = [SizeTransactionSeed]byte

type Transfer

+ GasDeposit uint64

+ func ParseTransfer(payload []byte) (Transfer, error)

+ func (t Transfer) Marshal() []byte

v0.0.1

Jun 26, 2019

Changes in this version

+ const PageSize

+ const SizeAccountID

+ const SizeMerkleNodeID

+ const SizeRoundID

+ const SizeSignature

+ const SizeTransactionID

+ const SnowballDefaultBeta

+ var ErrAlreadyExists = errors.New("transaction already exists in the graph")

+ var ErrContractFunctionNotFound = errors.New("contract: smart contract func not found")

+ var ErrDepthLimitExceeded = errors.New("transactions parents exceed depth limit")

+ var ErrIntOverflowRpc = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthRpc = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrMissingParents = errors.New("parents for transaction are not in graph")

+ var ErrNotSmartContract = errors.New("contract: specified account ID is not a smart contract")

+ var ZeroAccountID AccountID

+ var ZeroMerkleNodeID MerkleNodeID

+ var ZeroRoundID RoundID

+ var ZeroRoundPtr = &Round

+ var ZeroSignature Signature

+ var ZeroTransactionID TransactionID

+ func AcquireQueue() *queue.Queue

+ func ApplyBatchTransaction(snapshot *avl.Tree, round *Round, tx *Transaction) (*avl.Tree, error)

+ func ApplyContractTransaction(snapshot *avl.Tree, round *Round, tx *Transaction, ...) (*avl.Tree, error)

+ func ApplyStakeTransaction(snapshot *avl.Tree, round *Round, tx *Transaction) (*avl.Tree, error)

+ func ApplyTransferTransaction(snapshot *avl.Tree, round *Round, tx *Transaction, ...) (*avl.Tree, error)

+ func CollectVotes(accounts *Accounts, snowball *Snowball, voteChan <-chan vote, ...)

+ func ExportGraphDOT(round *Round, graph *Graph)

+ func LoadContractMemorySnapshot(snapshot *avl.Tree, id AccountID) []byte

+ func ReadAccountBalance(tree *avl.Tree, id AccountID) (uint64, bool)

+ func ReadAccountContractCode(tree *avl.Tree, id TransactionID) ([]byte, bool)

+ func ReadAccountContractNumPages(tree *avl.Tree, id TransactionID) (uint64, bool)

+ func ReadAccountContractPage(tree *avl.Tree, id TransactionID, idx uint64) ([]byte, bool)

+ func ReadAccountNonce(tree *avl.Tree, id AccountID) (uint64, bool)

+ func ReadAccountReward(tree *avl.Tree, id AccountID) (uint64, bool)

+ func ReadAccountStake(tree *avl.Tree, id AccountID) (uint64, bool)

+ func ReadAccountsLen(tree *avl.Tree) uint64

+ func RegisterWaveletServer(s *grpc.Server, srv WaveletServer)

+ func ReleaseQueue(q *queue.Queue)

+ func SaveContractMemorySnapshot(snapshot *avl.Tree, id AccountID, mem []byte)

+ func SelectPeers(peers []*grpc.ClientConn, amount int) ([]*grpc.ClientConn, error)

+ func StoreRewardWithdrawalRequest(tree *avl.Tree, rw RewardWithdrawalRequest)

+ func StoreRound(kv store.KV, round Round, currentIx, oldestIx uint32, storedCount uint8) error

+ func WriteAccountBalance(tree *avl.Tree, id AccountID, balance uint64)

+ func WriteAccountContractCode(tree *avl.Tree, id TransactionID, code []byte)

+ func WriteAccountContractNumPages(tree *avl.Tree, id TransactionID, numPages uint64)

+ func WriteAccountContractPage(tree *avl.Tree, id TransactionID, idx uint64, page []byte)

+ func WriteAccountNonce(tree *avl.Tree, id AccountID, nonce uint64)

+ func WriteAccountReward(tree *avl.Tree, id AccountID, reward uint64)

+ func WriteAccountStake(tree *avl.Tree, id AccountID, stake uint64)

+ func WriteAccountsLen(tree *avl.Tree, size uint64)

+ type AccountID = [SizeAccountID]byte

+ type Accounts struct

+ func NewAccounts(kv store.KV) *Accounts

+ func (a *Accounts) Commit(new *avl.Tree) error

+ func (a *Accounts) GC(ctx context.Context)

+ func (a *Accounts) Snapshot() *avl.Tree

+ type Batch struct

+ Payloads [][]byte

+ Size uint8

+ Tags []uint8

+ func ParseBatchTransaction(payload []byte) (Batch, error)

+ type CollapseResults struct

+ type Contract struct

+ Code []byte

+ GasLimit uint64

+ Params []byte

+ func ParseContractTransaction(payload []byte) (Contract, error)

+ type ContractExecutor struct

+ Error []byte

+ Gas uint64

+ GasLimitExceeded bool

+ ID AccountID

+ Payload []byte

+ Queue []*Transaction

+ Snapshot *avl.Tree

+ func (e *ContractExecutor) Execute(snapshot *avl.Tree, id AccountID, round *Round, tx *Transaction, ...) error

+ func (e *ContractExecutor) GetCost(key string) int64

+ func (e *ContractExecutor) ResolveFunc(module, field string) exec.FunctionImport

+ func (e *ContractExecutor) ResolveGlobal(module, field string) int64

+ type ContractExecutorState struct

+ GasLimit uint64

+ Sender AccountID

+ type DownloadTxRequest struct

+ Ids [][]byte

+ func (*DownloadTxRequest) Descriptor() ([]byte, []int)

+ func (*DownloadTxRequest) ProtoMessage()

+ func (m *DownloadTxRequest) GetIds() [][]byte

+ func (m *DownloadTxRequest) Marshal() (dAtA []byte, err error)

+ func (m *DownloadTxRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *DownloadTxRequest) Reset()

+ func (m *DownloadTxRequest) Size() (n int)

+ func (m *DownloadTxRequest) String() string

+ func (m *DownloadTxRequest) Unmarshal(dAtA []byte) error

+ func (m *DownloadTxRequest) XXX_DiscardUnknown()

+ func (m *DownloadTxRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DownloadTxRequest) XXX_Merge(src proto.Message)

+ func (m *DownloadTxRequest) XXX_Size() int

+ func (m *DownloadTxRequest) XXX_Unmarshal(b []byte) error

+ type DownloadTxResponse struct

+ Transactions [][]byte

+ func (*DownloadTxResponse) Descriptor() ([]byte, []int)

+ func (*DownloadTxResponse) ProtoMessage()

+ func (m *DownloadTxResponse) GetTransactions() [][]byte

+ func (m *DownloadTxResponse) Marshal() (dAtA []byte, err error)

+ func (m *DownloadTxResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *DownloadTxResponse) Reset()

+ func (m *DownloadTxResponse) Size() (n int)

+ func (m *DownloadTxResponse) String() string

+ func (m *DownloadTxResponse) Unmarshal(dAtA []byte) error

+ func (m *DownloadTxResponse) XXX_DiscardUnknown()

+ func (m *DownloadTxResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DownloadTxResponse) XXX_Merge(src proto.Message)

+ func (m *DownloadTxResponse) XXX_Size() int

+ func (m *DownloadTxResponse) XXX_Unmarshal(b []byte) error

+ type Empty struct

+ func (*Empty) Descriptor() ([]byte, []int)

+ func (*Empty) ProtoMessage()

+ func (m *Empty) Marshal() (dAtA []byte, err error)

+ func (m *Empty) MarshalTo(dAtA []byte) (int, error)

+ func (m *Empty) Reset()

+ func (m *Empty) Size() (n int)

+ func (m *Empty) String() string

+ func (m *Empty) Unmarshal(dAtA []byte) error

+ func (m *Empty) XXX_DiscardUnknown()

+ func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Empty) XXX_Merge(src proto.Message)

+ func (m *Empty) XXX_Size() int

+ func (m *Empty) XXX_Unmarshal(b []byte) error

+ type Gossiper struct

+ func NewGossiper(ctx context.Context, client *skademlia.Client, metrics *Metrics) *Gossiper

+ func (g *Gossiper) Gossip(transactions [][]byte)

+ func (g *Gossiper) Push(tx Transaction)

+ type Graph struct

+ func NewGraph(opts ...GraphOption) *Graph

+ func (g *Graph) AddTransaction(tx Transaction) error

+ func (g *Graph) DepthLen(start *uint64, end *uint64) int

+ func (g *Graph) FindEligibleCritical(difficulty byte) *Transaction

+ func (g *Graph) FindEligibleParents() []*Transaction

+ func (g *Graph) FindTransaction(id TransactionID) *Transaction

+ func (g *Graph) GetTransactionsByDepth(start *uint64, end *uint64) []*Transaction

+ func (g *Graph) Height() uint64

+ func (g *Graph) Len() int

+ func (g *Graph) ListTransactions(offset, limit uint64, sender, creator AccountID) (transactions []*Transaction)

+ func (g *Graph) MarkTransactionAsMissing(id TransactionID, depth uint64)

+ func (g *Graph) Missing() []TransactionID

+ func (g *Graph) MissingLen() int

+ func (g *Graph) PruneBelowDepth(targetDepth uint64) int

+ func (g *Graph) RootDepth() uint64

+ func (g *Graph) UpdateRoot(root Transaction)

+ func (g *Graph) UpdateRootDepth(rootDepth uint64)

+ type GraphOption func(*Graph)

+ func VerifySignatures() GraphOption

+ func WithMetrics(metrics *Metrics) GraphOption

+ func WithRoot(root Transaction) GraphOption

+ type LRU struct

+ func NewLRU(size int) *LRU

+ type Ledger struct

+ func NewLedger(kv store.KV, client *skademlia.Client, genesis *string) *Ledger

+ func (l *Ledger) AddTransaction(tx Transaction) error

+ func (l *Ledger) ApplyTransactionToSnapshot(snapshot *avl.Tree, tx *Transaction) error

+ func (l *Ledger) BroadcastNop() *Transaction

+ func (l *Ledger) CollapseTransactions(round uint64, root Transaction, end Transaction, logging bool) (*CollapseResults, error)

+ func (l *Ledger) FeedSendTokenIntoBucket()

+ func (l *Ledger) FinalizeRounds()

+ func (l *Ledger) Finalizer() *Snowball

+ func (l *Ledger) Graph() *Graph

+ func (l *Ledger) LogChanges(snapshot *avl.Tree, lastRound uint64)

+ func (l *Ledger) PerformConsensus()

+ func (l *Ledger) Protocol() *Protocol

+ func (l *Ledger) PullMissingTransactions()

+ func (l *Ledger) RewardValidators(snapshot *avl.Tree, root Transaction, tx *Transaction, logging bool) error

+ func (l *Ledger) Rounds() *Rounds

+ func (l *Ledger) Snapshot() *avl.Tree

+ func (l *Ledger) SyncToLatestRound()

+ func (l *Ledger) TakeSendToken() bool

+ type MerkleNodeID = [SizeMerkleNodeID]byte

+ type Metrics struct

+ func NewMetrics(ctx context.Context) *Metrics

+ func (m *Metrics) Stop()

+ type OutOfSyncRequest struct

+ func (*OutOfSyncRequest) Descriptor() ([]byte, []int)

+ func (*OutOfSyncRequest) ProtoMessage()

+ func (m *OutOfSyncRequest) Marshal() (dAtA []byte, err error)

+ func (m *OutOfSyncRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *OutOfSyncRequest) Reset()

+ func (m *OutOfSyncRequest) Size() (n int)

+ func (m *OutOfSyncRequest) String() string

+ func (m *OutOfSyncRequest) Unmarshal(dAtA []byte) error

+ func (m *OutOfSyncRequest) XXX_DiscardUnknown()

+ func (m *OutOfSyncRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *OutOfSyncRequest) XXX_Merge(src proto.Message)

+ func (m *OutOfSyncRequest) XXX_Size() int

+ func (m *OutOfSyncRequest) XXX_Unmarshal(b []byte) error

+ type OutOfSyncResponse struct

+ Round []byte

+ func (*OutOfSyncResponse) Descriptor() ([]byte, []int)

+ func (*OutOfSyncResponse) ProtoMessage()

+ func (m *OutOfSyncResponse) GetRound() []byte

+ func (m *OutOfSyncResponse) Marshal() (dAtA []byte, err error)

+ func (m *OutOfSyncResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *OutOfSyncResponse) Reset()

+ func (m *OutOfSyncResponse) Size() (n int)

+ func (m *OutOfSyncResponse) String() string

+ func (m *OutOfSyncResponse) Unmarshal(dAtA []byte) error

+ func (m *OutOfSyncResponse) XXX_DiscardUnknown()

+ func (m *OutOfSyncResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *OutOfSyncResponse) XXX_Merge(src proto.Message)

+ func (m *OutOfSyncResponse) XXX_Size() int

+ func (m *OutOfSyncResponse) XXX_Unmarshal(b []byte) error

+ type Protocol struct

+ func (p *Protocol) CheckOutOfSync(context.Context, *OutOfSyncRequest) (*OutOfSyncResponse, error)

+ func (p *Protocol) DownloadTx(ctx context.Context, req *DownloadTxRequest) (*DownloadTxResponse, error)

+ func (p *Protocol) Gossip(stream Wavelet_GossipServer) error

+ func (p *Protocol) Query(ctx context.Context, req *QueryRequest) (*QueryResponse, error)

+ func (p *Protocol) Sync(stream Wavelet_SyncServer) error

+ type QueryRequest struct

+ RoundIndex uint64

+ func (*QueryRequest) Descriptor() ([]byte, []int)

+ func (*QueryRequest) ProtoMessage()

+ func (m *QueryRequest) GetRoundIndex() uint64

+ func (m *QueryRequest) Marshal() (dAtA []byte, err error)

+ func (m *QueryRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *QueryRequest) Reset()

+ func (m *QueryRequest) Size() (n int)

+ func (m *QueryRequest) String() string

+ func (m *QueryRequest) Unmarshal(dAtA []byte) error

+ func (m *QueryRequest) XXX_DiscardUnknown()

+ func (m *QueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *QueryRequest) XXX_Merge(src proto.Message)

+ func (m *QueryRequest) XXX_Size() int

+ func (m *QueryRequest) XXX_Unmarshal(b []byte) error

+ type QueryResponse struct

+ Round []byte

+ func (*QueryResponse) Descriptor() ([]byte, []int)

+ func (*QueryResponse) ProtoMessage()

+ func (m *QueryResponse) GetRound() []byte

+ func (m *QueryResponse) Marshal() (dAtA []byte, err error)

+ func (m *QueryResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *QueryResponse) Reset()

+ func (m *QueryResponse) Size() (n int)

+ func (m *QueryResponse) String() string

+ func (m *QueryResponse) Unmarshal(dAtA []byte) error

+ func (m *QueryResponse) XXX_DiscardUnknown()

+ func (m *QueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *QueryResponse) XXX_Merge(src proto.Message)

+ func (m *QueryResponse) XXX_Size() int

+ func (m *QueryResponse) XXX_Unmarshal(b []byte) error

+ type RewardWithdrawalRequest struct

+ func GetRewardWithdrawalRequests(tree *avl.Tree, roundLimit uint64) []RewardWithdrawalRequest

+ func UnmarshalRewardWithdrawalRequest(r io.Reader) (RewardWithdrawalRequest, error)

+ func (rw RewardWithdrawalRequest) Key() []byte

+ func (rw RewardWithdrawalRequest) Marshal() []byte

+ type Round struct

+ Applied uint64

+ End Transaction

+ ID RoundID

+ Index uint64

+ Merkle MerkleNodeID

+ Start Transaction

+ func LoadRounds(kv store.KV) ([]*Round, uint32, uint32, error)

+ func NewRound(index uint64, merkle MerkleNodeID, applied uint64, start, end Transaction) Round

+ func UnmarshalRound(r io.Reader) (round Round, err error)

+ func (r Round) ExpectedDifficulty(min byte, scale float64) byte

+ func (r Round) Marshal() []byte

+ type RoundID = [SizeRoundID]byte

+ type Rounds struct

+ func NewRounds(store store.KV, limit uint8) (*Rounds, error)

+ func (r *Rounds) Count() uint64

+ func (r *Rounds) GetByIndex(ix uint64) (*Round, error)

+ func (r *Rounds) Latest() *Round

+ func (r *Rounds) Oldest() *Round

+ func (r *Rounds) Save(round *Round) (*Round, error)

+ type Signature = [SizeSignature]byte

+ type Snowball struct

+ func NewSnowball(opts ...SnowballOption) *Snowball

+ func (s *Snowball) Decided() bool

+ func (s *Snowball) Prefer(round *Round)

+ func (s *Snowball) Preferred() *Round

+ func (s *Snowball) Progress() int

+ func (s *Snowball) Reset()

+ func (s *Snowball) Tick(round *Round)

+ type SnowballOption func(*Snowball)

+ func WithBeta(beta int) SnowballOption

+ type Stake struct

+ Amount uint64

+ Opcode byte

+ func ParseStakeTransaction(payload []byte) (Stake, error)

+ type SyncInfo struct

+ Checksums [][]byte

+ LatestRound []byte

+ func (*SyncInfo) Descriptor() ([]byte, []int)

+ func (*SyncInfo) ProtoMessage()

+ func (m *SyncInfo) GetChecksums() [][]byte

+ func (m *SyncInfo) GetLatestRound() []byte

+ func (m *SyncInfo) Marshal() (dAtA []byte, err error)

+ func (m *SyncInfo) MarshalTo(dAtA []byte) (int, error)

+ func (m *SyncInfo) Reset()

+ func (m *SyncInfo) Size() (n int)

+ func (m *SyncInfo) String() string

+ func (m *SyncInfo) Unmarshal(dAtA []byte) error

+ func (m *SyncInfo) XXX_DiscardUnknown()

+ func (m *SyncInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SyncInfo) XXX_Merge(src proto.Message)

+ func (m *SyncInfo) XXX_Size() int

+ func (m *SyncInfo) XXX_Unmarshal(b []byte) error

+ type SyncRequest struct

+ Data isSyncRequest_Data

+ func (*SyncRequest) Descriptor() ([]byte, []int)

+ func (*SyncRequest) ProtoMessage()

+ func (*SyncRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *SyncRequest) GetChecksum() []byte

+ func (m *SyncRequest) GetData() isSyncRequest_Data

+ func (m *SyncRequest) GetRoundId() uint64

+ func (m *SyncRequest) Marshal() (dAtA []byte, err error)

+ func (m *SyncRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *SyncRequest) Reset()

+ func (m *SyncRequest) Size() (n int)

+ func (m *SyncRequest) String() string

+ func (m *SyncRequest) Unmarshal(dAtA []byte) error

+ func (m *SyncRequest) XXX_DiscardUnknown()

+ func (m *SyncRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SyncRequest) XXX_Merge(src proto.Message)

+ func (m *SyncRequest) XXX_Size() int

+ func (m *SyncRequest) XXX_Unmarshal(b []byte) error

+ type SyncRequest_Checksum struct

+ Checksum []byte

+ func (m *SyncRequest_Checksum) MarshalTo(dAtA []byte) (int, error)

+ func (m *SyncRequest_Checksum) Size() (n int)

+ type SyncRequest_RoundId struct

+ RoundId uint64

+ func (m *SyncRequest_RoundId) MarshalTo(dAtA []byte) (int, error)

+ func (m *SyncRequest_RoundId) Size() (n int)

+ type SyncResponse struct

+ Data isSyncResponse_Data

+ func (*SyncResponse) Descriptor() ([]byte, []int)

+ func (*SyncResponse) ProtoMessage()

+ func (*SyncResponse) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *SyncResponse) GetChunk() []byte

+ func (m *SyncResponse) GetData() isSyncResponse_Data

+ func (m *SyncResponse) GetHeader() *SyncInfo

+ func (m *SyncResponse) Marshal() (dAtA []byte, err error)

+ func (m *SyncResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *SyncResponse) Reset()

+ func (m *SyncResponse) Size() (n int)

+ func (m *SyncResponse) String() string

+ func (m *SyncResponse) Unmarshal(dAtA []byte) error

+ func (m *SyncResponse) XXX_DiscardUnknown()

+ func (m *SyncResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SyncResponse) XXX_Merge(src proto.Message)

+ func (m *SyncResponse) XXX_Size() int

+ func (m *SyncResponse) XXX_Unmarshal(b []byte) error

+ type SyncResponse_Chunk struct

+ Chunk []byte

+ func (m *SyncResponse_Chunk) MarshalTo(dAtA []byte) (int, error)

+ func (m *SyncResponse_Chunk) Size() (n int)

+ type SyncResponse_Header struct

+ Header *SyncInfo

+ func (m *SyncResponse_Header) MarshalTo(dAtA []byte) (int, error)

+ func (m *SyncResponse_Header) Size() (n int)

+ type Transaction struct

+ Creator AccountID

+ CreatorSignature Signature

+ Depth uint64

+ ID TransactionID

+ Nonce uint64

+ ParentIDs []TransactionID

+ Payload []byte

+ Seed [blake2b.Size256]byte

+ SeedLen byte

+ Sender AccountID

+ SenderSignature Signature

+ Tag byte

+ func AttachSenderToTransaction(sender *skademlia.Keypair, tx Transaction, parents ...*Transaction) Transaction

+ func NewBatchTransaction(creator *skademlia.Keypair, tags []byte, payloads [][]byte) Transaction

+ func NewTransaction(creator *skademlia.Keypair, tag byte, payload []byte) Transaction

+ func UnmarshalTransaction(r io.Reader) (t Transaction, err error)

+ func (t Transaction) Marshal() []byte

+ func (tx Transaction) IsCritical(difficulty byte) bool

+ func (tx Transaction) LogicalUnits() int

+ func (tx Transaction) String() string

+ type TransactionID = [SizeTransactionID]byte

+ type Transactions struct

+ Transactions [][]byte

+ func (*Transactions) Descriptor() ([]byte, []int)

+ func (*Transactions) ProtoMessage()

+ func (m *Transactions) GetTransactions() [][]byte

+ func (m *Transactions) Marshal() (dAtA []byte, err error)

+ func (m *Transactions) MarshalTo(dAtA []byte) (int, error)

+ func (m *Transactions) Reset()

+ func (m *Transactions) Size() (n int)

+ func (m *Transactions) String() string

+ func (m *Transactions) Unmarshal(dAtA []byte) error

+ func (m *Transactions) XXX_DiscardUnknown()

+ func (m *Transactions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Transactions) XXX_Merge(src proto.Message)

+ func (m *Transactions) XXX_Size() int

+ func (m *Transactions) XXX_Unmarshal(b []byte) error

+ type Transfer struct

+ Amount uint64

+ FuncName []byte

+ FuncParams []byte

+ GasLimit uint64

+ Recipient AccountID

+ func ParseTransferTransaction(payload []byte) (Transfer, error)

+ type WaveletClient interface

+ CheckOutOfSync func(ctx context.Context, in *OutOfSyncRequest, opts ...grpc.CallOption) (*OutOfSyncResponse, error)

+ DownloadTx func(ctx context.Context, in *DownloadTxRequest, opts ...grpc.CallOption) (*DownloadTxResponse, error)

+ Gossip func(ctx context.Context, opts ...grpc.CallOption) (Wavelet_GossipClient, error)

+ Query func(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResponse, error)

+ Sync func(ctx context.Context, opts ...grpc.CallOption) (Wavelet_SyncClient, error)

+ func NewWaveletClient(cc *grpc.ClientConn) WaveletClient

+ type WaveletServer interface

+ CheckOutOfSync func(context.Context, *OutOfSyncRequest) (*OutOfSyncResponse, error)

+ DownloadTx func(context.Context, *DownloadTxRequest) (*DownloadTxResponse, error)

+ Gossip func(Wavelet_GossipServer) error

+ Query func(context.Context, *QueryRequest) (*QueryResponse, error)

+ Sync func(Wavelet_SyncServer) error

+ type Wavelet_GossipClient interface

+ CloseAndRecv func() (*Empty, error)

+ Send func(*Transactions) error

+ type Wavelet_GossipServer interface

+ Recv func() (*Transactions, error)

+ SendAndClose func(*Empty) error

+ type Wavelet_SyncClient interface

+ Recv func() (*SyncResponse, error)

+ Send func(*SyncRequest) error

+ type Wavelet_SyncServer interface

+ Recv func() (*SyncRequest, error)

+ Send func(*SyncResponse) error

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