indexer

Documentation

Index

• type Indexer
• type ListenLastTxByCycle
  • func NewListenLastTxByCycle(c config.Config, rc *cache.Redis, cr *client.Client, db *model.SuiDB) *ListenLastTxByCycle
  • func (l *ListenLastTxByCycle) ListenTx(ctx context.Context) <-chan TxDigest
• type ListenLastTxBySub
• type ListenLatestNumber
• type SuiIndexer
  • func NewSuiIndexer(c config.Config, l ListenLatestNumber, rc *cache.Redis, db *model.SuiDB) *SuiIndexer
  • func (s *SuiIndexer) ProcessDropOutMessage(ctx context.Context)
  • func (s *SuiIndexer) Scan(ctx context.Context)
  • func (s *SuiIndexer) Start(ctx context.Context)
  • func (s *SuiIndexer) WaitClose()
• type TxDigest

Types

type Indexer

type Indexer interface {
	Scan(ctx context.Context)
	WaitClose()
	Start(ctx context.Context)
}

type ListenLastTxByCycle

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

func NewListenLastTxByCycle

func NewListenLastTxByCycle(c config.Config, rc *cache.Redis, cr *client.Client, db *model.SuiDB) *ListenLastTxByCycle

func (*ListenLastTxByCycle) ListenTx

func (l *ListenLastTxByCycle) ListenTx(ctx context.Context) <-chan TxDigest

type ListenLastTxBySub

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

type ListenLatestNumber

type ListenLatestNumber interface {
	ListenTx(ctx context.Context) <-chan TxDigest
}

type SuiIndexer

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

func NewSuiIndexer

func NewSuiIndexer(c config.Config, l ListenLatestNumber, rc *cache.Redis, db *model.SuiDB) *SuiIndexer

func (*SuiIndexer) ProcessDropOutMessage

func (s *SuiIndexer) ProcessDropOutMessage(ctx context.Context)

func (*SuiIndexer) Scan

func (s *SuiIndexer) Scan(ctx context.Context)

func (*SuiIndexer) Start

func (s *SuiIndexer) Start(ctx context.Context)

func (*SuiIndexer) WaitClose

func (s *SuiIndexer) WaitClose()

type TxDigest

type TxDigest struct {
	PreDigest string
	Digest    string
}