worker

Documentation

Index

• type ExpirationResult
• type ExpirationWorker
  • func GetExpirationWorker(configPath string, logger zap.Logger) (*ExpirationWorker, error)
  • func (w *ExpirationWorker) Run()
  • func (w *ExpirationWorker) Stop()

Types

type ExpirationResult

type ExpirationResult struct {
	DeletedMembers int
	DeletedSet     bool
	Set            string
}

ExpirationResult is the struct that represents the result of an expiration job

type ExpirationWorker

type ExpirationWorker struct {
	RedisClient             *extredis.Client
	Logger                  zap.Logger
	Config                  *viper.Viper
	ConfigPath              string
	ExpirationCheckInterval time.Duration
	ExpirationLimitPerRun   int
	// contains filtered or unexported fields
}

ExpirationWorker is the struct that represents the scores expirer worker

func GetExpirationWorker

func GetExpirationWorker(configPath string, logger zap.Logger) (*ExpirationWorker, error)

GetExpirationWorker returns a new scores expirer worker

func (*ExpirationWorker) Run

func (w *ExpirationWorker) Run()

Run starts the worker -- this method blocks

func (*ExpirationWorker) Stop

func (w *ExpirationWorker) Stop()

Stop stops