executor

Documentation

Index

• Constants
• func DelRetrieveInfo(info *rt.RetrieveQuery, Status int64, db dbm.KVDB) (*types.KeyValue, error)
• func GetName() string
• func Init(name string, sub []byte)
• func Key(address string) (key []byte)
• func SaveRetrieveInfo(info *rt.RetrieveQuery, Status int64, db dbm.KVDB) (*types.KeyValue, error)
• type Action
  • func NewRetrieveAcction(r *Retrieve, tx *types.Transaction) *Action
  • func (action *Action) RetrieveBackup(backupRet *rt.BackupRetrieve) (*types.Receipt, error)
  • func (action *Action) RetrieveCancel(cancel *rt.CancelRetrieve) (*types.Receipt, error)
  • func (action *Action) RetrievePerform(perfRet *rt.PerformRetrieve) (*types.Receipt, error)
  • func (action *Action) RetrievePrepare(preRet *rt.PrepareRetrieve) (*types.Receipt, error)
• type DB
  • func NewDB(backupaddress string) *DB
  • func (r *DB) CheckRelation(defaultAddress string) (int, bool)
  • func (r *DB) GetKVSet() (kvset []*types.KeyValue)
  • func (r *DB) RelateDB(defaultAddress string, createTime int64, delayPeriod int64) bool
  • func (r *DB) Save(db dbm.KV)
  • func (r *DB) UnRelateDB(index int) bool
• type Retrieve
  • func (r *Retrieve) CheckReceiptExecOk() bool
  • func (r *Retrieve) CheckTx(tx *types.Transaction, index int) error
  • func (c *Retrieve) ExecDelLocal_Backup(backup *rt.BackupRetrieve, tx *types.Transaction, ...) (*types.LocalDBSet, error)
  • func (c *Retrieve) ExecDelLocal_Cancel(cancel *rt.CancelRetrieve, tx *types.Transaction, ...) (*types.LocalDBSet, error)
  • func (c *Retrieve) ExecDelLocal_Perform(perf *rt.PerformRetrieve, tx *types.Transaction, ...) (*types.LocalDBSet, error)
  • func (c *Retrieve) ExecDelLocal_Prepare(pre *rt.PrepareRetrieve, tx *types.Transaction, receiptData *types.ReceiptData, ...) (*types.LocalDBSet, error)
  • func (c *Retrieve) ExecLocal_Backup(backup *rt.BackupRetrieve, tx *types.Transaction, ...) (*types.LocalDBSet, error)
  • func (c *Retrieve) ExecLocal_Cancel(cancel *rt.CancelRetrieve, tx *types.Transaction, ...) (*types.LocalDBSet, error)
  • func (c *Retrieve) ExecLocal_Perform(perf *rt.PerformRetrieve, tx *types.Transaction, ...) (*types.LocalDBSet, error)
  • func (c *Retrieve) ExecLocal_Prepare(pre *rt.PrepareRetrieve, tx *types.Transaction, receiptData *types.ReceiptData, ...) (*types.LocalDBSet, error)
  • func (c *Retrieve) Exec_Backup(backup *rt.BackupRetrieve, tx *types.Transaction, index int) (*types.Receipt, error)
  • func (c *Retrieve) Exec_Cancel(cancel *rt.CancelRetrieve, tx *types.Transaction, index int) (*types.Receipt, error)
  • func (c *Retrieve) Exec_Perform(perf *rt.PerformRetrieve, tx *types.Transaction, index int) (*types.Receipt, error)
  • func (c *Retrieve) Exec_Prepare(pre *rt.PrepareRetrieve, tx *types.Transaction, index int) (*types.Receipt, error)
  • func (r *Retrieve) GetDriverName() string
  • func (r *Retrieve) Query_GetRetrieveInfo(in *rt.ReqRetrieveInfo) (types.Message, error)

Constants

const MaxRelation = 10

MaxRelation when backup

Functions

func DelRetrieveInfo

func DelRetrieveInfo(info *rt.RetrieveQuery, Status int64, db dbm.KVDB) (*types.KeyValue, error)

DelRetrieveInfo local

func GetName

func GetName() string

GetName method

func Init

func Init(name string, sub []byte)

Init retrieve

func Key

func Key(address string) (key []byte)

Key for retrieve

func SaveRetrieveInfo

func SaveRetrieveInfo(info *rt.RetrieveQuery, Status int64, db dbm.KVDB) (*types.KeyValue, error)

SaveRetrieveInfo local

Types

type Action

type Action struct {
	// contains filtered or unexported fields
}

Action def

func NewRetrieveAcction

func NewRetrieveAcction(r *Retrieve, tx *types.Transaction) *Action

NewRetrieveAcction gen instance

func (*Action) RetrieveBackup

func (action *Action) RetrieveBackup(backupRet *rt.BackupRetrieve) (*types.Receipt, error)

RetrieveBackup Action

func (*Action) RetrieveCancel

func (action *Action) RetrieveCancel(cancel *rt.CancelRetrieve) (*types.Receipt, error)

RetrieveCancel Action

func (*Action) RetrievePerform

func (action *Action) RetrievePerform(perfRet *rt.PerformRetrieve) (*types.Receipt, error)

RetrievePerform Action

func (*Action) RetrievePrepare

func (action *Action) RetrievePrepare(preRet *rt.PrepareRetrieve) (*types.Receipt, error)

RetrievePrepare Action

type DB

type DB struct {
	rt.Retrieve
}

DB def

func NewDB

func NewDB(backupaddress string) *DB

NewDB instance

func (*DB) CheckRelation

func (r *DB) CheckRelation(defaultAddress string) (int, bool)

CheckRelation on retrieve action

func (*DB) GetKVSet

func (r *DB) GetKVSet() (kvset []*types.KeyValue)

GetKVSet for retrieve

func (*DB) RelateDB

func (r *DB) RelateDB(defaultAddress string, createTime int64, delayPeriod int64) bool

RelateDB on retrieve action

func (*DB) Save

func (r *DB) Save(db dbm.KV)

Save KV

func (*DB) UnRelateDB

func (r *DB) UnRelateDB(index int) bool

UnRelateDB on retrieve action

type Retrieve

type Retrieve struct {
	drivers.DriverBase
}

Retrieve def

func (*Retrieve) CheckReceiptExecOk

func (r *Retrieve) CheckReceiptExecOk() bool

CheckReceiptExecOk return true to check if receipt ty is ok

func (*Retrieve) CheckTx

func (r *Retrieve) CheckTx(tx *types.Transaction, index int) error

CheckTx nil

func (*Retrieve) ExecDelLocal_Backup

func (c *Retrieve) ExecDelLocal_Backup(backup *rt.BackupRetrieve, tx *types.Transaction, receiptData *types.ReceiptData, index int) (*types.LocalDBSet, error)

ExecDelLocal_Backup Action

func (*Retrieve) ExecDelLocal_Cancel

func (c *Retrieve) ExecDelLocal_Cancel(cancel *rt.CancelRetrieve, tx *types.Transaction, receiptData *types.ReceiptData, index int) (*types.LocalDBSet, error)

ExecDelLocal_Cancel Action

func (*Retrieve) ExecDelLocal_Perform

func (c *Retrieve) ExecDelLocal_Perform(perf *rt.PerformRetrieve, tx *types.Transaction, receiptData *types.ReceiptData, index int) (*types.LocalDBSet, error)

ExecDelLocal_Perform Action

func (*Retrieve) ExecDelLocal_Prepare

func (c *Retrieve) ExecDelLocal_Prepare(pre *rt.PrepareRetrieve, tx *types.Transaction, receiptData *types.ReceiptData, index int) (*types.LocalDBSet, error)

ExecDelLocal_Prepare Action

func (*Retrieve) ExecLocal_Backup

func (c *Retrieve) ExecLocal_Backup(backup *rt.BackupRetrieve, tx *types.Transaction, receiptData *types.ReceiptData, index int) (*types.LocalDBSet, error)

ExecLocal_Backup Action

func (*Retrieve) ExecLocal_Cancel

func (c *Retrieve) ExecLocal_Cancel(cancel *rt.CancelRetrieve, tx *types.Transaction, receiptData *types.ReceiptData, index int) (*types.LocalDBSet, error)

ExecLocal_Cancel Action

func (*Retrieve) ExecLocal_Perform

func (c *Retrieve) ExecLocal_Perform(perf *rt.PerformRetrieve, tx *types.Transaction, receiptData *types.ReceiptData, index int) (*types.LocalDBSet, error)

ExecLocal_Perform Action

func (*Retrieve) ExecLocal_Prepare

func (c *Retrieve) ExecLocal_Prepare(pre *rt.PrepareRetrieve, tx *types.Transaction, receiptData *types.ReceiptData, index int) (*types.LocalDBSet, error)

ExecLocal_Prepare Action

func (*Retrieve) Exec_Backup

func (c *Retrieve) Exec_Backup(backup *rt.BackupRetrieve, tx *types.Transaction, index int) (*types.Receipt, error)

Exec_Backup Action

func (*Retrieve) Exec_Cancel

func (c *Retrieve) Exec_Cancel(cancel *rt.CancelRetrieve, tx *types.Transaction, index int) (*types.Receipt, error)

Exec_Cancel Action

func (*Retrieve) Exec_Perform

func (c *Retrieve) Exec_Perform(perf *rt.PerformRetrieve, tx *types.Transaction, index int) (*types.Receipt, error)

Exec_Perform Action

func (*Retrieve) Exec_Prepare

func (c *Retrieve) Exec_Prepare(pre *rt.PrepareRetrieve, tx *types.Transaction, index int) (*types.Receipt, error)

Exec_Prepare Action

func (*Retrieve) GetDriverName

func (r *Retrieve) GetDriverName() string

GetDriverName method

func (*Retrieve) Query_GetRetrieveInfo

func (r *Retrieve) Query_GetRetrieveInfo(in *rt.ReqRetrieveInfo) (types.Message, error)

Query_GetRetrieveInfo get retrieve state