syncer

Documentation

Index

• Constants
• type Config
• type Syncer
  • func New(repo SyncerRepo, chunkRepo TreeIndexChunkRepositpry, ...) *Syncer
  • func (s *Syncer) Start(ctx context.Context)
• type SyncerRepo
• type TreeIndexChunkRepositpry

Constants

const (
	BlockNotFoundTimeout = time.Second * 15
	BlockGetErrorTimeout = time.Second * 30

	RolePatient uint8 = 0
	RoleDoctor  uint8 = 1
)

Types

type Config

type Config struct {
	Endpoint   string
	StartBlock uint64
	Contracts  []struct {
		Name    string
		Address string
	}
}

type Syncer

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

func New

func New(repo SyncerRepo, chunkRepo TreeIndexChunkRepositpry, ethClient *ethclient.Client, cfg Config) *Syncer

func (*Syncer) Start

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

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)
}