appdata

Documentation

Index

• Constants
• func GetOnChainTrxQueue() *deque.Deque[*OnChainTrxEvent]
• type AppDb
  • func CreateAppDb(path string) (*AppDb, error)
  • func NewAppDb() *AppDb
  • func (appdb *AppDb) AddMetaByTrx(blockId uint64, groupid string, trxs []*quorumpb.Trx) error
  • func (appdb *AppDb) Close()
  • func (appdb *AppDb) DelGroupSeed(groupID string) error
  • func (appdb *AppDb) GetAllGroupSeeds() (map[string]*quorumpb.GroupSeed, error)
  • func (appdb *AppDb) GetGroupContentBySenders(groupid string, senders []string, starttrx string, num int, reverse bool, ...) (trxidList []string, err error)
  • func (appdb *AppDb) GetGroupSeed(groupID string) (*quorumpb.GroupSeed, error)
  • func (appdb *AppDb) GetGroupStatus(groupid string, name string) (string, error)
  • func (appdb *AppDb) GetSeqId(seqkey string) (uint64, error)
  • func (appdb *AppDb) Rebuild(vertag string, chainDb storage.QuorumStorage) error
  • func (appdb *AppDb) Release() error
  • func (appdb *AppDb) SetGroupSeed(seed *quorumpb.GroupSeed) error
• type AppSync
  • func NewAppSyncAgent(apiroot string, nodename string, appdb *AppDb, dbmgr *storage.DbMgr) *AppSync
  • func (appsync *AppSync) GetGroups() []*quorumpb.GroupItem
  • func (appsync *AppSync) ParseBlockTrxs(groupid string, block *quorumpb.Block) error
  • func (appsync *AppSync) RunSync(groupid string, lastSyncBlock uint64, highestBlock uint64)
  • func (appsync *AppSync) Start(interval int)
• type OnChainTrxEvent

Constants

const CNT_PREFIX string = "cnt_"

const GRP_PREFIX string = "grp_"

const SDR_PREFIX string = "sdr_"

const SED_PREFIX string = "sed_"

const SEQ_PREFIX string = "seq_"

const STATUS_PREFIX string = "stu_"

const TRX_PREFIX string = "trx_"

Functions

func GetOnChainTrxQueue

func GetOnChainTrxQueue() *deque.Deque[*OnChainTrxEvent]

Types

type AppDb

type AppDb struct {
	Db storage.QuorumStorage

	DataPath string
	// contains filtered or unexported fields
}

func CreateAppDb

func CreateAppDb(path string) (*AppDb, error)

func NewAppDb

func NewAppDb() *AppDb

func (*AppDb) AddMetaByTrx

func (appdb *AppDb) AddMetaByTrx(blockId uint64, groupid string, trxs []*quorumpb.Trx) error

func (*AppDb) Close

func (appdb *AppDb) Close()

func (*AppDb) DelGroupSeed

func (appdb *AppDb) DelGroupSeed(groupID string) error

func (*AppDb) GetAllGroupSeeds

func (appdb *AppDb) GetAllGroupSeeds() (map[string]*quorumpb.GroupSeed, error)

func (*AppDb) GetGroupContentBySenders

func (appdb *AppDb) GetGroupContentBySenders(groupid string, senders []string, starttrx string, num int, reverse bool, starttrxinclude bool) (trxidList []string, err error)

func (*AppDb) GetGroupSeed

func (appdb *AppDb) GetGroupSeed(groupID string) (*quorumpb.GroupSeed, error)

func (*AppDb) GetGroupStatus

func (appdb *AppDb) GetGroupStatus(groupid string, name string) (string, error)

func (*AppDb) GetSeqId

func (appdb *AppDb) GetSeqId(seqkey string) (uint64, error)

func (*AppDb) Rebuild

func (appdb *AppDb) Rebuild(vertag string, chainDb storage.QuorumStorage) error

func (*AppDb) Release

func (appdb *AppDb) Release() error

func (*AppDb) SetGroupSeed

func (appdb *AppDb) SetGroupSeed(seed *quorumpb.GroupSeed) error

type AppSync

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

func NewAppSyncAgent

func NewAppSyncAgent(apiroot string, nodename string, appdb *AppDb, dbmgr *storage.DbMgr) *AppSync

func (*AppSync) GetGroups

func (appsync *AppSync) GetGroups() []*quorumpb.GroupItem

func (*AppSync) ParseBlockTrxs

func (appsync *AppSync) ParseBlockTrxs(groupid string, block *quorumpb.Block) error

func (*AppSync) RunSync

func (appsync *AppSync) RunSync(groupid string, lastSyncBlock uint64, highestBlock uint64)

func (*AppSync) Start

func (appsync *AppSync) Start(interval int)

type OnChainTrxEvent

type OnChainTrxEvent struct {
	GroupId string `json:"group_id"`
	TrxId   string `json:"trx_id"`
}