cacheinv

type Client interface {
	// GetServerIDs ...
	GetServerIDs() []int64

	// GetServerName ...
	GetServerName(serverID int64) string

	// DeleteCacheKeys ...
	DeleteCacheKeys(ctx context.Context, serverID int64, keys []string) error
}

type InvalidateEvent struct {
	ID   int64         `db:"id"`
	Seq  sql.NullInt64 `db:"seq"`
	Data string        `db:"data"`
}

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

type Option func(conf *jobConfig)

type Repository interface {
	eventx.Repository[InvalidateEvent]

	// GetMinSequence returns the min sequence number of all events (except events with null sequence numbers)
	// returns null if no events with sequence number existed
	GetMinSequence(ctx context.Context) (sql.NullInt64, error)

	// DeleteEventsBefore deletes events with sequence number < *beforeSeq*
	DeleteEventsBefore(ctx context.Context, beforeSeq uint64) error

	// GetLastSequence get from invalidate_offsets table
	GetLastSequence(ctx context.Context, serverName string) (sql.NullInt64, error)
	// SetLastSequence upsert into invalidate_offsets table
	SetLastSequence(ctx context.Context, serverName string, seq int64) error
}