Versions in this module Expand all Collapse all v1 v1.1.1 Oct 8, 2019 v1.1.0 Jul 3, 2019 Changes in this version + type Configuration struct + Address string + IdleTimeout time.Duration + MaxIdle int + PubSub PubSubConfiguration + type ConnHandler func(conn redis.ConnWithTimeout) error + type PubSubConfiguration struct + HealthCheckInterval time.Duration + ReadTimeout time.Duration + WriteTimeout time.Duration + type RedigoService struct + Configuration Configuration + func (service *RedigoService) ApplyConfiguration(configuration interface{}) error + func (service *RedigoService) GetConn() (redis.Conn, error) + func (service *RedigoService) LoadConfiguration() (interface{}, error) + func (service *RedigoService) Publish(ctx context.Context, channel string, data interface{}) error + func (service *RedigoService) Restart() error + func (service *RedigoService) RunWithConn(handler ConnHandler) error + func (service *RedigoService) Start() error + func (service *RedigoService) Stop() error + func (service *RedigoService) Subscribe(ctx context.Context, subscribed SubscribedHandler, ...) error + type SubscribedHandler func() error + type SubscriptionHandler func(channel string, data []byte) error
Go to main page