sqlx

package

v1.2.0 Latest Latest Go to latest Published: Jul 14, 2025 License: Apache-2.0 Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Data struct {
	Code   string `db:"code"`
	Source string `db:"source"`
	Data   []byte `db:"data"`
}

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

func NewDataKeeper(
	db connectors.DBConnector[*sqlx.DB, *sqlx.Tx],
	opts ...DataKeeperOption,
) *DataKeeper

func (dk *DataKeeper) GetData(ctx context.Context) ([]*models.Data, error)

func (dk *DataKeeper) Init(ctx context.Context) error

func (dk *DataKeeper) RemoveOldData(ctx context.Context) error

func (dk *DataKeeper) SaveData(ctx context.Context, data *models.Data) error

func (dk *DataKeeper) SetFailedData(ctx context.Context) error

func (dk *DataKeeper) UpdateFailedData(ctx context.Context, codes []string) error

func (dk *DataKeeper) UpdateLockedData(ctx context.Context) error

func (dk *DataKeeper) UpdateProcessedData(ctx context.Context, codes []string) error

type DataKeeperOption func(dk *DataKeeper)

func WithLockedTimeDataKeeperOpt(lockedTime time.Duration) DataKeeperOption

func WithMaxAttemptsDataKeeperOpt(maxAttempts int) DataKeeperOption

func WithRemoveOldDataDataKeeperOpt(removeOld time.Duration) DataKeeperOption