database

type Database interface {
	UpdateJobExecutions(ctx context.Context) (int, error)
	RemoveFromUriQueue(ctx context.Context) (int, error)
	MoveWaitToReady() (int, error)
	MoveBusyToTimeout() (int, error)
	MoveRunningToTimeout() (int, error)
	TimeoutCrawlExecutions(ctx context.Context) (int, error)
}

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

type RethinkDbMockConnection struct {
	*RethinkDbConnection
}

type RethinkDbOptions struct {
	Username           string
	Password           string
	Database           string
	UseOpenTracing     bool
	Address            string
	QueryTimeout       time.Duration
	MaxRetries         int
	MaxOpenConnections int
}