repository

Documentation

Index

• type LogRepository
  • func NewLogRepository(conn *pgxpool.Pool, sysDb sysdb.ISysDB) *LogRepository
  • func (r *LogRepository) GarbageCollection(ctx context.Context) error
  • func (r *LogRepository) GetAllCollectionInfoToCompact(ctx context.Context, minCompactionSize uint64) (collectionToCompact []log.GetAllCollectionsToCompactRow, err error)
  • func (r *LogRepository) GetLastCompactedOffsetForCollection(ctx context.Context, collectionId string) (compacted_offset int64, err error)
  • func (r *LogRepository) GetTotalUncompactedRecordsCount(ctx context.Context) (totalUncompactedDepth int64, err error)
  • func (r *LogRepository) InsertRecords(ctx context.Context, collectionId string, records [][]byte) (insertCount int64, err error)
  • func (r *LogRepository) PullRecords(ctx context.Context, collectionId string, offset int64, batchSize int, ...) (records []log.RecordLog, err error)
  • func (r *LogRepository) PurgeRecords(ctx context.Context) (err error)
  • func (r *LogRepository) UpdateCollectionCompactionOffsetPosition(ctx context.Context, collectionId string, offsetPosition int64) (err error)

Types

type LogRepository

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

func NewLogRepository

func NewLogRepository(conn *pgxpool.Pool, sysDb sysdb.ISysDB) *LogRepository

func (*LogRepository) GarbageCollection

func (r *LogRepository) GarbageCollection(ctx context.Context) error

func (*LogRepository) GetAllCollectionInfoToCompact

func (r *LogRepository) GetAllCollectionInfoToCompact(ctx context.Context, minCompactionSize uint64) (collectionToCompact []log.GetAllCollectionsToCompactRow, err error)

func (*LogRepository) GetLastCompactedOffsetForCollection

func (r *LogRepository) GetLastCompactedOffsetForCollection(ctx context.Context, collectionId string) (compacted_offset int64, err error)

func (*LogRepository) GetTotalUncompactedRecordsCount

func (r *LogRepository) GetTotalUncompactedRecordsCount(ctx context.Context) (totalUncompactedDepth int64, err error)

func (*LogRepository) InsertRecords

func (r *LogRepository) InsertRecords(ctx context.Context, collectionId string, records [][]byte) (insertCount int64, err error)

func (*LogRepository) PullRecords

func (r *LogRepository) PullRecords(ctx context.Context, collectionId string, offset int64, batchSize int, timestamp int64) (records []log.RecordLog, err error)

func (*LogRepository) PurgeRecords

func (r *LogRepository) PurgeRecords(ctx context.Context) (err error)

func (*LogRepository) UpdateCollectionCompactionOffsetPosition

func (r *LogRepository) UpdateCollectionCompactionOffsetPosition(ctx context.Context, collectionId string, offsetPosition int64) (err error)