chainindex

Documentation

Index

• type ChainIndex
  • func New(logger *zap.Logger, db *database.DBO) *ChainIndex
  • func (ci *ChainIndex) Init() error
  • func (ci *ChainIndex) Start(ctx context.Context, wg *sync.WaitGroup)
• type Event

Types

type ChainIndex

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

func New

func New(logger *zap.Logger, db *database.DBO) *ChainIndex

func (*ChainIndex) Init

func (ci *ChainIndex) Init() error

Init initial table and index

func (*ChainIndex) Start

func (ci *ChainIndex) Start(ctx context.Context, wg *sync.WaitGroup)

type Event

type Event struct {
	Table string
	Cols  []database.Feild
}