generic

type AdmissionControlPolicy interface {
	// Admit checks whether the query should be admitted.
	// If the query is not admitted, a non-nil error is returned with the reason why the query was denied.
	// If the query is admitted, then the error will be nil and a callback function is returned to the caller.
	// The caller must execute it after finishing the query
	Admit(ctx context.Context, txName string) (callOnFinish func(), err error)
}

type ErrCode func(error) string

type ErrRetry func(error) bool

type Generic struct {
	sync.Mutex

	LockWrites     bool
	LastInsertID   bool
	DB             *sql.DB
	GetCurrentSQL  string
	GetRevisionSQL string

	RevisionSQL          string
	ListRevisionStartSQL string
	GetRevisionAfterSQL  string
	CountCurrentSQL      string

	CountRevisionSQL string

	AfterSQLPrefix string

	AfterSQL  string
	DeleteSQL string

	UpdateCompactSQL string

	InsertSQL string

	FillSQL string

	InsertLastInsertIDSQL string

	GetSizeSQL string

	Retry        ErrRetry
	TranslateErr TranslateErr
	ErrCode      ErrCode

	AdmissionControlPolicy AdmissionControlPolicy

	// CompactInterval is interval between database compactions performed by kine.
	CompactInterval time.Duration
	// PollInterval is the event poll interval used by kine.
	PollInterval time.Duration
	// contains filtered or unexported fields
}

type Stripped string

type TranslateErr func(error) error