model

Documentation

Index

• func SetSchema(s string)
• type DataRepository
  • func (rep *DataRepository) ConcurrentFetchFromRecords(batchSize int, f func(list []entity.TransitDataRecord) bool) error
  • func (rep *DataRepository) ConcurrentFetchFromTechRecords(batchSize int, f func(list []entity.TransitDataRecord) bool) error
  • func (rep *DataRepository) CountRecords() (int, error)
  • func (rep *DataRepository) CountTechRecords() (int, error)
  • func (rep *DataRepository) GetMaxVersionFromRecords() (int, error)
  • func (rep *DataRepository) GetMaxVersionFromTechRecords() (int, error)
  • func (rep *DataRepository) GetRecordsByIdList(listId []string, techRecord bool) ([]entity.TransitDataRecord, error)
  • func (rep *DataRepository) UseRecordsCursor(batchSize int, f func(list []entity.TransitDataRecord) bool) error
  • func (rep *DataRepository) UseTechRecordsCursor(batchSize int, f func(list []entity.TransitDataRecord) bool) error

Functions

func SetSchema

func SetSchema(s string)

Types

type DataRepository

type DataRepository struct {
	DB *database.RxDbClient
}

func (*DataRepository) ConcurrentFetchFromRecords

func (rep *DataRepository) ConcurrentFetchFromRecords(batchSize int, f func(list []entity.TransitDataRecord) bool) error

func (*DataRepository) ConcurrentFetchFromTechRecords

func (rep *DataRepository) ConcurrentFetchFromTechRecords(batchSize int, f func(list []entity.TransitDataRecord) bool) error

func (*DataRepository) CountRecords

func (rep *DataRepository) CountRecords() (int, error)

can be optimized with estimate

SELECT

((reltuples/relpages) * (
  pg_relation_size('data_records') /
  (current_setting('block_size')::integer)
))::integer
FROM pg_class where relname = 'data_records';

func (*DataRepository) CountTechRecords

func (rep *DataRepository) CountTechRecords() (int, error)

func (*DataRepository) GetMaxVersionFromRecords

func (rep *DataRepository) GetMaxVersionFromRecords() (int, error)

func (*DataRepository) GetMaxVersionFromTechRecords

func (rep *DataRepository) GetMaxVersionFromTechRecords() (int, error)

func (*DataRepository) GetRecordsByIdList

func (rep *DataRepository) GetRecordsByIdList(listId []string, techRecord bool) ([]entity.TransitDataRecord, error)

func (*DataRepository) UseRecordsCursor

func (rep *DataRepository) UseRecordsCursor(batchSize int, f func(list []entity.TransitDataRecord) bool) error

func (*DataRepository) UseTechRecordsCursor

func (rep *DataRepository) UseTechRecordsCursor(batchSize int, f func(list []entity.TransitDataRecord) bool) error