dbretry

package

v0.7.0 Latest Latest Go to latest Published: Jun 17, 2019 License: Apache-2.0 Imports: 6 Imported by: 0

Details

View Source

const (
	SQLQueryRetryCounter = "sql_query_retry_count"
	SQLQueryEndCounter   = "sql_query_end_counter"
)

This section is empty.

func Metrics() []xmetrics.Metric

Metrics returns the Metrics relevant to this package

type Measures struct {
	SQLQueryRetryCount metrics.Counter
	SQLQueryEndCount   metrics.Counter
}

func NewMeasures(p provider.Provider) Measures

type Option func(r *retryConfig)

func WithInterval(interval time.Duration) Option

func WithIntervalMultiplier(mult time.Duration) Option

func WithMeasures(p provider.Provider) Option

func WithRetries(retries int) Option

func WithSleep(sleep func(time.Duration)) Option

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

func CreateRetryInsertService(inserter db.Inserter, options ...Option) RetryInsertService

func (ri RetryInsertService) InsertRecords(records ...db.Record) error

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

func CreateRetryListGService(listGetter blacklist.Updater, options ...Option) RetryListGService

func (ltg RetryListGService) GetBlacklist() (list []blacklist.BlackListedItem, err error)

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

func CreateRetryRGService(recordGetter db.RecordGetter, options ...Option) RetryRGService

func (rtg RetryRGService) GetRecords(deviceID string, limit int) ([]db.Record, error)

func (rtg RetryRGService) GetRecordsOfType(deviceID string, limit int, eventType db.EventType) ([]db.Record, error)

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

func CreateRetryUpdateService(pruner db.Pruner, options ...Option) RetryUpdateService

func (ru RetryUpdateService) GetRecordIDs(shard int, limit int, deathDate int64) ([]int, error)

func (ru RetryUpdateService) PruneRecords(records []int) error