Documentation ¶
Index ¶
- type ComponentsCfg
- type Config
- type Indexer
- func (i *Indexer) BuildWorkers(c int)
- func (i *Indexer) EnqueueJob(work WorkQueue.Job)
- func (i *Indexer) SetGetMissingHeightsFn(fn MissingJobsFn)
- func (i *Indexer) SetSyncCB(cb db_buffer.SyncCB)
- func (i *Indexer) SetWorkerConstructor(w WorkQueue.WorkerConstructor)
- func (i *Indexer) StartIndexing()
- func (i *Indexer) StopIndexing()
- type MissingJobsFn
- type StatusServer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ComponentsCfg ¶
type ComponentsCfg struct { DBBufferCfg db_buffer.Config DispatcherCfg WorkQueue.DispatcherConfig DataStoreCfg data_store.DataStoreConfig }
type Config ¶
type Config struct { EnableBuffer bool ComponentsCfg }
type Indexer ¶
type Indexer struct { Id string DbConn *gorm.DB DBBuffer *db_buffer.Buffer Config Config // contains filtered or unexported fields }
func (*Indexer) BuildWorkers ¶
func (*Indexer) EnqueueJob ¶ added in v1.2.0
func (i *Indexer) EnqueueJob(work WorkQueue.Job)
func (*Indexer) SetGetMissingHeightsFn ¶
func (i *Indexer) SetGetMissingHeightsFn(fn MissingJobsFn)
func (*Indexer) SetWorkerConstructor ¶
func (i *Indexer) SetWorkerConstructor(w WorkQueue.WorkerConstructor)
func (*Indexer) StartIndexing ¶
func (i *Indexer) StartIndexing()
func (*Indexer) StopIndexing ¶
func (i *Indexer) StopIndexing()
type MissingJobsFn ¶ added in v1.2.0
type MissingJobsFn func() ([]WorkQueue.Job, error)
type StatusServer ¶ added in v1.1.0
type StatusServer struct {
// contains filtered or unexported fields
}
func NewStatusServer ¶ added in v1.1.0
func NewStatusServer(i *Indexer) *StatusServer
func (*StatusServer) Start ¶ added in v1.1.0
func (s *StatusServer) Start()
func (*StatusServer) Stop ¶ added in v1.1.0
func (s *StatusServer) Stop()
Click to show internal directories.
Click to hide internal directories.