repository

Documentation

Index

• Constants
• type IndexStorage
  • func NewIndexStorage(db *sqlx.DB) *IndexStorage
  • func (store *IndexStorage) AddNewIndexObject(ctx context.Context, chunk models.IndexChunk) error
  • func (store *IndexStorage) GetAllIndexObjects(ctx context.Context) ([]models.IndexChunk, error)
• type StatsStorage
  • func NetStatsSotrage(db *sqlx.DB) *StatsStorage
  • func (repo *StatsStorage) StatDocumentsCountGet(ctx context.Context, start, end int64) (uint64, error)
  • func (repo *StatsStorage) StatDocumentsCountIncrement(ctx context.Context, timestamp time.Time) error
  • func (repo *StatsStorage) StatPatientsCountGet(ctx context.Context, start, end int64) (uint64, error)
  • func (repo *StatsStorage) StatPatientsCountIncrement(ctx context.Context, timestamp time.Time) error
  • func (repo *StatsStorage) SyncLastBlockGet(ctx context.Context) (uint64, error)
  • func (repo *StatsStorage) SyncLastBlockSet(ctx context.Context, lastSyncedBlock uint64) error

Constants

const (
	TableNamePatients  = "stat_patients"
	TableNameDocuments = "stat_documents"
)

Types

type IndexStorage

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

func NewIndexStorage

func NewIndexStorage(db *sqlx.DB) *IndexStorage

func (*IndexStorage) AddNewIndexObject

func (store *IndexStorage) AddNewIndexObject(ctx context.Context, chunk models.IndexChunk) error

func (*IndexStorage) GetAllIndexObjects

func (store *IndexStorage) GetAllIndexObjects(ctx context.Context) ([]models.IndexChunk, error)

type StatsStorage

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

func NetStatsSotrage

func NetStatsSotrage(db *sqlx.DB) *StatsStorage

func (*StatsStorage) StatDocumentsCountGet

func (repo *StatsStorage) StatDocumentsCountGet(ctx context.Context, start, end int64) (uint64, error)

func (*StatsStorage) StatDocumentsCountIncrement

func (repo *StatsStorage) StatDocumentsCountIncrement(ctx context.Context, timestamp time.Time) error

func (*StatsStorage) StatPatientsCountGet

func (repo *StatsStorage) StatPatientsCountGet(ctx context.Context, start, end int64) (uint64, error)

func (*StatsStorage) StatPatientsCountIncrement

func (repo *StatsStorage) StatPatientsCountIncrement(ctx context.Context, timestamp time.Time) error

func (*StatsStorage) SyncLastBlockGet

func (repo *StatsStorage) SyncLastBlockGet(ctx context.Context) (uint64, error)

func (*StatsStorage) SyncLastBlockSet

func (repo *StatsStorage) SyncLastBlockSet(ctx context.Context, lastSyncedBlock uint64) error