aerospike

type RecordReader ¶

type RecordReader interface {
	Read(ctx context.Context) (*models.Token, error)
	Close()
}

RecordReader is an interface for reading Aerospike records. implements pipe.Reader for a token.

func NewRecordReader(
	ctx context.Context,
	client scanner,
	cfg *RecordReaderConfig,
	logger *slog.Logger,
	recordsetCloser RecordsetCloser,
) RecordReader

type RecordReaderConfig ¶

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

RecordReaderConfig represents the configuration for scanning Aerospike records.

func NewRecordReaderConfig(namespace string,
	setList []string,
	partitionFilter *a.PartitionFilter,
	scanPolicy *a.ScanPolicy,
	binList []string,
	timeBounds models.TimeBounds,
	scanLimiter *semaphore.Weighted,
	noTTLOnly bool,
	pageSize int64,
	rpsCollector *metrics.Collector,
) *RecordReaderConfig

type RecordsetCloser ¶ added in v0.6.0

type RecordsetCloser interface {
	Close(recordset *a.Recordset) a.Error
}

RecordsetCloser is an interface for closing Aerospike recordsets. It is required because scanner interacted return concrete type Recordset that is impossible to mock.

func NewRecordsetCloser() RecordsetCloser

type RecordsetCloserImpl ¶ added in v0.6.0

type RecordsetCloserImpl struct {
}

func (r *RecordsetCloserImpl) Close(recordset *a.Recordset) a.Error

type RestoreWriter ¶

type RestoreWriter[T models.TokenConstraint] struct {
	// contains filtered or unexported fields
}

RestoreWriter satisfies the DataWriter interface. It writes the types from the models package to an Aerospike client It is used to restore data from a backup.

func NewRestoreWriter[T models.TokenConstraint](
	ctx context.Context,
	asc dbWriter,
	writePolicy *a.WritePolicy,
	stats *models.RestoreStats,
	logger *slog.Logger,
	useBatchWrites bool,
	batchSize int,
	retryPolicy *models.RetryPolicy,
	rpsCollector *metrics.Collector,
	ignoreRecordError bool,
) *RestoreWriter[T]

func (rw *RestoreWriter[T]) Close() error

func (rw *RestoreWriter[T]) Write(_ context.Context, data T) (int, error)

type SindexReader ¶

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

SindexReader satisfies the DataReader interface. It reads secondary indexes from a SIndexGetter and returns them as *models.SecondaryIndex.

func NewSIndexReader(client sindexGetter, namespace string, logger *slog.Logger) *SindexReader

func (r *SindexReader) Close()

func (r *SindexReader) Read(ctx context.Context) (*models.Token, error)

type UdfReader ¶

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

UdfReader satisfies the DataReader interface. It reads UDFs from a UDFGetter and returns them as *models.UDF.

func NewUDFReader(client udfGetter, logger *slog.Logger) *UdfReader

func (r *UdfReader) Close()

func (r *UdfReader) Read(ctx context.Context) (*models.Token, error)