Documentation ¶
Index ¶
Constants ¶
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Syncer ¶
type Syncer struct {
// contains filtered or unexported fields
}
func New ¶
func New(repo SyncerRepo, chunkRepo TreeIndexChunkRepositpry, ethClient *ethclient.Client, cfg Config) *Syncer
type SyncerRepo ¶
type SyncerRepo interface { SyncLastBlockGet(ctx context.Context) (uint64, error) SyncLastBlockSet(ctx context.Context, lastSyncedBlock uint64) error StatPatientsCountIncrement(ctx context.Context, timestamp time.Time) error StatDocumentsCountIncrement(ctx context.Context, timestamp time.Time) error }
type TreeIndexChunkRepositpry ¶
type TreeIndexChunkRepositpry interface { AddNewIndexObject(ctx context.Context, chunk models.IndexChunk) error GetAllIndexObjects(ctx context.Context) ([]models.IndexChunk, error) }
Click to show internal directories.
Click to hide internal directories.