Versions in this module Expand all Collapse all v0 v0.3.0 Dec 20, 2023 v0.2.0 Dec 20, 2023 v0.1.0 Dec 19, 2023 Changes in this version + type Client interface + DeleteCacheKeys func(ctx context.Context, serverID int64, keys []string) error + GetServerIDs func() []int64 + GetServerName func(serverID int64) string + type InvalidateEvent struct + Data string + ID int64 + Seq sql.NullInt64 + func (e InvalidateEvent) GetID() uint64 + func (e InvalidateEvent) GetSequence() uint64 + func (e InvalidateEvent) GetSize() uint64 + type InvalidatorJob struct + func NewInvalidatorJob(repo Repository, client Client, options ...Option) *InvalidatorJob + func (j *InvalidatorJob) Notify() + func (j *InvalidatorJob) Run() + func (j *InvalidatorJob) Shutdown() + type Option func(conf *jobConfig) + func WithRetentionOptions(options ...eventx.RetentionOption) Option + func WithRetryConsumerOptions(options ...eventx.RetryConsumerOption) Option + func WithRunnerOptions(options ...eventx.Option) Option + type Repository interface + DeleteEventsBefore func(ctx context.Context, beforeSeq uint64) error + GetLastSequence func(ctx context.Context, serverName string) (sql.NullInt64, error) + GetMinSequence func(ctx context.Context) (sql.NullInt64, error) + SetLastSequence func(ctx context.Context, serverName string, seq int64) error