redis

Documentation

Index

• type RedisConfig
• type RedisPlugin
  • func NewRedisPlugin() *RedisPlugin
  • func (p *RedisPlugin) CanHotReload() bool
  • func (p *RedisPlugin) Delete(key string) error
  • func (p *RedisPlugin) Get(key string) (string, error)
  • func (p *RedisPlugin) GetClient() *redis.Client
  • func (p *RedisPlugin) GetDefaultConfig() map[string]interface{}
  • func (p *RedisPlugin) GetEventSubscriptions() map[string]gorgo.EventHandler
  • func (p *RedisPlugin) GetMiddleware() []gorgo.MiddlewareFunc
  • func (p *RedisPlugin) GetServices() map[string]interface{}
  • func (p *RedisPlugin) Initialize(container *container.Container, config map[string]interface{}) error
  • func (p *RedisPlugin) OnHotReload(newConfig map[string]interface{}) error
  • func (p *RedisPlugin) SessionMiddleware(sessionName string) gorgo.MiddlewareFunc
  • func (p *RedisPlugin) Set(key string, value interface{}, expiration time.Duration) error
  • func (p *RedisPlugin) Start(ctx context.Context) error
  • func (p *RedisPlugin) Stop(ctx context.Context) error
  • func (p *RedisPlugin) ValidateConfig(config map[string]interface{}) error

Types

type RedisConfig

type RedisConfig struct {
	Host     string `toml:"host"`
	Port     int    `toml:"port"`
	Password string `toml:"password"`
	DB       int    `toml:"db"`
	PoolSize int    `toml:"pool_size"`
}

type RedisPlugin

type RedisPlugin struct {
	gorgo.BasePlugin
	// contains filtered or unexported fields
}

func NewRedisPlugin

func NewRedisPlugin() *RedisPlugin

func (*RedisPlugin) CanHotReload

func (p *RedisPlugin) CanHotReload() bool

HotReloadable implementation

func (*RedisPlugin) Delete

func (p *RedisPlugin) Delete(key string) error

func (*RedisPlugin) Get

func (p *RedisPlugin) Get(key string) (string, error)

func (*RedisPlugin) GetClient

func (p *RedisPlugin) GetClient() *redis.Client

Additional methods

func (*RedisPlugin) GetDefaultConfig

func (p *RedisPlugin) GetDefaultConfig() map[string]interface{}

func (*RedisPlugin) GetEventSubscriptions

func (p *RedisPlugin) GetEventSubscriptions() map[string]gorgo.EventHandler

EventSubscriber implementation

func (*RedisPlugin) GetMiddleware

func (p *RedisPlugin) GetMiddleware() []gorgo.MiddlewareFunc

MiddlewareProvider implementation

func (*RedisPlugin) GetServices

func (p *RedisPlugin) GetServices() map[string]interface{}

ServiceProvider implementation

func (*RedisPlugin) Initialize

func (p *RedisPlugin) Initialize(container *container.Container, config map[string]interface{}) error

Main plugin methods

func (*RedisPlugin) OnHotReload

func (p *RedisPlugin) OnHotReload(newConfig map[string]interface{}) error

func (*RedisPlugin) SessionMiddleware

func (p *RedisPlugin) SessionMiddleware(sessionName string) gorgo.MiddlewareFunc

Session middleware

func (*RedisPlugin) Set

func (p *RedisPlugin) Set(key string, value interface{}, expiration time.Duration) error

func (*RedisPlugin) Start

func (p *RedisPlugin) Start(ctx context.Context) error

func (*RedisPlugin) Stop

func (p *RedisPlugin) Stop(ctx context.Context) error

func (*RedisPlugin) ValidateConfig

func (p *RedisPlugin) ValidateConfig(config map[string]interface{}) error

ConfigurablePlugin implementation