types

Documentation

Index

• type BaseTarget
• type BlocksApplier
• type EmbeddedWallet
• type Handler
• type ID
• type InvRequester
• type MessageSender
• type Miner
• type MinerConsensus
• type Scheduler
• type ScoreSender
• type SmartState
• type StateHistorySynchronizer
• type StateSync
• type Subscribe
• type Time
• type TransactionWithBytes
• type UtxPool

Types

type BaseTarget

type BaseTarget = uint64

type BlocksApplier

type BlocksApplier interface {
	Apply(block []*proto.Block) error
}

type EmbeddedWallet

type EmbeddedWallet interface {
	SignTransactionWith(pk crypto.PublicKey, tx proto.Transaction) error
	Load(password []byte) error
	Seeds() [][]byte
}

type Handler

type Handler interface {
	Handle()
}

Abstract handler that called when event happens

type ID

type ID interface {
	ID() string
}

type InvRequester

type InvRequester interface {
	Request(MessageSender, proto.BlockID)
}

type MessageSender

type MessageSender interface {
	SendMessage(proto.Message)
}

type Miner

type Miner interface {
	Mine(ctx context.Context, t proto.Timestamp, k proto.KeyPair, parent proto.BlockID, baseTarget BaseTarget, gs []byte, vrf []byte)
}

type MinerConsensus

type MinerConsensus interface {
	IsMiningAllowed() bool
}

type Scheduler

type Scheduler interface {
	Reschedule()
}

type ScoreSender

type ScoreSender interface {
	Priority()
	NonPriority()
}

type SmartState

type SmartState interface {
	AddingBlockHeight() (uint64, error)
	NewestTransactionByID([]byte) (proto.Transaction, error)
	NewestTransactionHeightByID([]byte) (uint64, error)

	// NewestAccountBalance retrieves balance of address in specific currency, asset is asset's ID.
	// nil asset = Waves.
	NewestAccountBalance(account proto.Recipient, asset []byte) (uint64, error)
	NewestAddrByAlias(alias proto.Alias) (proto.Address, error)
	RetrieveNewestIntegerEntry(account proto.Recipient, key string) (*proto.IntegerDataEntry, error)
	RetrieveNewestBooleanEntry(account proto.Recipient, key string) (*proto.BooleanDataEntry, error)
	RetrieveNewestStringEntry(account proto.Recipient, key string) (*proto.StringDataEntry, error)
	RetrieveNewestBinaryEntry(account proto.Recipient, key string) (*proto.BinaryDataEntry, error)
	NewestAssetIsSponsored(assetID crypto.Digest) (bool, error)
	NewestAssetInfo(assetID crypto.Digest) (*proto.AssetInfo, error)
	NewestHeaderByHeight(height proto.Height) (*proto.BlockHeader, error)

	IsNotFound(err error) bool
	BlockVRF(blockHeader *proto.BlockHeader, height proto.Height) ([]byte, error)
}

state for smart contracts

type StateHistorySynchronizer

type StateHistorySynchronizer interface {
	Sync()
}

notify state that it must run synchronization

type StateSync

type StateSync interface {
	Sync()
	SetEnabled(enabled bool)
	Close()
	Run(ctx context.Context)
}

type Subscribe

type Subscribe interface {
	Subscribe(p ID, responseMessage proto.Message) (chan proto.Message, func(), error)
	Receive(p ID, responseMessage proto.Message) bool
}

type Time

type Time interface {
	Now() time.Time
}

type TransactionWithBytes

type TransactionWithBytes struct {
	T proto.Transaction
	B []byte
}

type UtxPool

type UtxPool interface {
	AddWithBytes(t proto.Transaction, b []byte) error
	Exists(t proto.Transaction) bool
	Pop() *TransactionWithBytes
	AllTransactions() []*TransactionWithBytes
	Count() int
	ExistsByID(id []byte) bool
}

UtxPool storage interface