worker

Documentation

Index

• type ExpirationResult
  • func (r *ExpirationResult) String() string
• type ExpirationWorker
  • func GetExpirationWorker(configPath string) (*ExpirationWorker, error)
  • func NewExpirationWorker(host string, port int, password string, db int, connectionTimeout int, ...) (*ExpirationWorker, error)
  • func (w *ExpirationWorker) Run(resultsChan chan<- []*ExpirationResult, errChan chan<- error)
  • 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

func (*ExpirationResult) String

func (r *ExpirationResult) String() string

type ExpirationWorker

type ExpirationWorker struct {
	RedisClient             *extredis.Client
	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) (*ExpirationWorker, error)

GetExpirationWorker returns a new scores expirer worker

func NewExpirationWorker

func NewExpirationWorker(host string, port int, password string, db int, connectionTimeout int,
	expirationCheckInterval time.Duration, expirationLimitPerRun int) (*ExpirationWorker, error)

NewExpirationWorker returns a new scores expirer worker with already loaded configuration.

func (*ExpirationWorker) Run

func (w *ExpirationWorker) Run(resultsChan chan<- []*ExpirationResult, errChan chan<- error)

Run starts the worker -- this method blocks

func (*ExpirationWorker) Stop

func (w *ExpirationWorker) Stop()

Stop stops