repository

Documentation

Index

• type LogRepository
  • func NewLogRepository(conn *pgxpool.Pool) *LogRepository
  • func (r *LogRepository) GetAllCollectionInfoToCompact(ctx context.Context) (collectionToCompact []log.GetAllCollectionsToCompactRow, 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) *LogRepository

func (*LogRepository) GetAllCollectionInfoToCompact

func (r *LogRepository) GetAllCollectionInfoToCompact(ctx context.Context) (collectionToCompact []log.GetAllCollectionsToCompactRow, 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)