timer

package

v1.0.2 Latest Latest Go to latest Published: Jan 27, 2022 License: Apache-2.0 Imports: 10 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type KernMethod struct {
	BcName string
}

func NewKernContractMethod(bcName string) *KernMethod

func (t *KernMethod) Add(ctx contract.KContext) (*contract.Response, error)

func (t *KernMethod) Do(ctx contract.KContext) (*contract.Response, error)

func (t *KernMethod) Trigger(ctx contract.KContext, triggerBuf []byte)

type LedgerRely interface {
	// 获取状态机最新确认快照
	GetTipXMSnapshotReader() (ledger.XMSnapshotReader, error)
}

type Manager struct {
	Ctx *TimerCtx
}

Manager manages all timer releated data, providing read/write interface

func (mgr *Manager) GetObjectBySnapshot(bucket string, object []byte) ([]byte, error)

func (mgr *Manager) GetTimerTasks(blockHeight int64) (uint64, error)

GetTimerTasks get timer tasks

type TimerCtx struct {
	// 基础上下文
	xcontext.BaseCtx
	BcName   string
	Ledger   LedgerRely
	Contract contract.Manager
}

func NewTimerTaskCtx(bcName string, leg LedgerRely, contract contract.Manager) (*TimerCtx, error)

type TimerManager interface {
	GetTimerTasks(blockHeight int64) (uint64, error)
}

func NewTimerTaskManager(ctx *TimerCtx) (TimerManager, error)

NewTimerTaskManager create instance of TimerManager