kernel

Documentation

Index

• func Version() string
• type Kernel
  • func NewKernel(cfg *KernelConf, env *ChainEnv, land *Land) *Kernel
  • func (k *Kernel) AcceptUnpkgTxns() error
  • func (k *Kernel) CheckReplayAttack(txn *SignedTxn) bool
  • func (k *Kernel) GetReceipts(ctx *gin.Context)
  • func (k *Kernel) GetReceiptsCount(ctx *gin.Context)
  • func (k *Kernel) GetTripodInstance(name string) any
  • func (k *Kernel) GetTxn(txnHash Hash) (txn *SignedTxn, err error)
  • func (k *Kernel) HandleError(err error, ctx *context.WriteContext, block *Block, stxn *SignedTxn) *Receipt
  • func (k *Kernel) HandleEvent(ctx *context.WriteContext, block *Block, stxn *SignedTxn) *Receipt
  • func (k *Kernel) HandleHttp()
  • func (k *Kernel) HandleRead(rdCall *common.RdCall) (*context.ResponseData, error)
  • func (k *Kernel) HandleReceipt(ctx *context.WriteContext, receipt *Receipt, block *Block, stxn *SignedTxn)
  • func (k *Kernel) HandleTxn(signedWrCall *protocol.SignedWrCall) error
  • func (k *Kernel) HandleWS()
  • func (k *Kernel) InitBlockChain()
  • func (k *Kernel) LocalRun() (newBlock *Block, err error)
  • func (k *Kernel) MasterWorkerRun() error
  • func (k *Kernel) OrderedExecute(block *Block) error
  • func (k *Kernel) PostExecute(block *Block, receipts map[Hash]*Receipt) error
  • func (k *Kernel) Run()
  • func (k *Kernel) Startup()
  • func (k *Kernel) Stop()
  • func (k *Kernel) WithExecuteFn(fn ExecuteFn)

Functions

func Version

func Version() string

Types

type Kernel

type Kernel struct {
	RunMode RunMode

	*ChainEnv

	Land *Land
	// contains filtered or unexported fields
}

func NewKernel

func NewKernel(
	cfg *KernelConf,
	env *ChainEnv,
	land *Land,
) *Kernel

func (*Kernel) AcceptUnpkgTxns

func (k *Kernel) AcceptUnpkgTxns() error

func (*Kernel) CheckReplayAttack

func (k *Kernel) CheckReplayAttack(txn *SignedTxn) bool

func (*Kernel) GetReceipts

func (k *Kernel) GetReceipts(ctx *gin.Context)

func (*Kernel) GetReceiptsCount

func (k *Kernel) GetReceiptsCount(ctx *gin.Context)

func (*Kernel) GetTripodInstance

func (k *Kernel) GetTripodInstance(name string) any

func (*Kernel) GetTxn

func (k *Kernel) GetTxn(txnHash Hash) (txn *SignedTxn, err error)

func (*Kernel) HandleError

func (k *Kernel) HandleError(err error, ctx *context.WriteContext, block *Block, stxn *SignedTxn) *Receipt

func (*Kernel) HandleEvent

func (k *Kernel) HandleEvent(ctx *context.WriteContext, block *Block, stxn *SignedTxn) *Receipt

func (*Kernel) HandleHttp

func (k *Kernel) HandleHttp()

func (*Kernel) HandleRead

func (k *Kernel) HandleRead(rdCall *common.RdCall) (*context.ResponseData, error)

func (*Kernel) HandleReceipt

func (k *Kernel) HandleReceipt(ctx *context.WriteContext, receipt *Receipt, block *Block, stxn *SignedTxn)

func (*Kernel) HandleTxn

func (k *Kernel) HandleTxn(signedWrCall *protocol.SignedWrCall) error

HandleTxn handles txn from outside. You can also self-define your input by calling HandleTxn (not only by default http and ws)

func (*Kernel) HandleWS

func (k *Kernel) HandleWS()

func (*Kernel) InitBlockChain

func (k *Kernel) InitBlockChain()

func (*Kernel) LocalRun

func (k *Kernel) LocalRun() (newBlock *Block, err error)

func (*Kernel) MasterWorkerRun

func (k *Kernel) MasterWorkerRun() error

func (*Kernel) OrderedExecute

func (k *Kernel) OrderedExecute(block *Block) error

func (*Kernel) PostExecute

func (k *Kernel) PostExecute(block *Block, receipts map[Hash]*Receipt) error

func (*Kernel) Run

func (k *Kernel) Run()

func (*Kernel) Startup

func (k *Kernel) Startup()

func (*Kernel) Stop

func (k *Kernel) Stop()

func (*Kernel) WithExecuteFn

func (k *Kernel) WithExecuteFn(fn ExecuteFn)