go redis expired watch

gistfile1.go

const REFRESH_EXPIRED_MINUTES = 1

// somewhere (maybe in main.go) run: go WatchExpired(); go RefreshExpired();

func WatchExpired() {
	services.RClient.ConfigSet("notify-keyspace-events", "Ex")
	pub := services.RClient.PubSub()
	pub.PSubscribe("__key*__:*")
	debug, _ := conf.AppConfig.Bool("debug")

	for {
		msg, _ := pub.Receive()
    		log.Printf("[expired] %s", msg )
		//.....code......................
	}

	defer pub.Close()
}

/// refresh expired keys to produce events in time
func RefreshExpired() {
	debug, _ := conf.AppConfig.Bool("debug")
	refresh_period := conf.AppConfig.UInt("redis.refrech_expired_minutes", REFRESH_EXPIRED_MINUTES)
	refresh_duration := time.Minute * time.Duration(refresh_period)
	if debug {
		Log.Printf("[***] refreshing keys")
	}
	services.RClient.Keys(models.WATCHED_PREFIX + ":*")
	if debug {
		Log.Printf("[***] refreshing keys end")
	}
	go time.AfterFunc(refresh_duration, RefreshExpired)
}