convert

Documentation

Index

• Variables
• func InitConfig(cfg *proto.ConfigNew)
• func InitContract(cfg *proto.ConfigNew)
• func InitDB(cfg *proto.ConfigNew)
• func InitSeqNum(cfg *proto.ConfigNew)
• func InitSeqStore(cfg *proto.ConfigNew)
• func InitWriteDB(writeDB *proto.ESDB, version int32)
• type App
  • func NewApp(cfg *proto.ConfigNew) *App
  • func (a *App) ConvertBlock(blockSeq *block.Seq, detail *types.BlockDetail) ([]db.Record, error)
  • func (a *App) ConvertTx(env *db.TxEnv, op int) ([]db.Record, error)
  • func (a *App) RecoverStats(client escli.ESClient, lastSeq int64) error
• type Service
  • func NewConvertService(cfg *proto.ConfigNew) *Service
  • func (s *Service) Start()

Variables

var (
	EsWrite     escli.ESClient
	SeqNumStore store.SeqNumStore
	SeqStore    store.SeqStore
)

Functions

func InitConfig

func InitConfig(cfg *proto.ConfigNew)

func InitContract

func InitContract(cfg *proto.ConfigNew)

func InitDB

func InitDB(cfg *proto.ConfigNew)

func InitSeqNum

func InitSeqNum(cfg *proto.ConfigNew)

func InitSeqStore

func InitSeqStore(cfg *proto.ConfigNew)

func InitWriteDB

func InitWriteDB(writeDB *proto.ESDB, version int32)

InitWriteDB 设置存储数据的配置

Types

type App

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

func NewApp

func NewApp(cfg *proto.ConfigNew) *App

func (*App) ConvertBlock

func (a *App) ConvertBlock(blockSeq *block.Seq, detail *types.BlockDetail) ([]db.Record, error)

func (*App) ConvertTx

func (a *App) ConvertTx(env *db.TxEnv, op int) ([]db.Record, error)

func (*App) RecoverStats

func (a *App) RecoverStats(client escli.ESClient, lastSeq int64) error

type Service

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

func NewConvertService

func NewConvertService(cfg *proto.ConfigNew) *Service

func (*Service) Start

func (s *Service) Start()

Start 启动convert服务