proxy

Documentation

Index

• func RedisHost() string
• func SetupClusterClient(t *testing.T, address string, readonly bool, id int) *redis.ClusterClient
• func SetupProxy(t *testing.T, upstreamPort string, db int) func()
• func SetupProxyAdvancedConfig(t *testing.T, upstreamPort string, db int, maxPoolSize int, id int, ...) func()
• func SetupStandaloneClient(t *testing.T, address string) *redis.Client
• type Proxy
  • func NewProxy(log *zap.Logger, sd *statsd.Client, config *config.Config, upstreamIndex int) (*Proxy, error)
  • func (p *Proxy) Kill()
  • func (p *Proxy) Run() error
  • func (p *Proxy) Shutdown()
• type StatsdBackgroundGaugeCallback

Functions

func RedisHost

func RedisHost() string

func SetupClusterClient

func SetupClusterClient(t *testing.T, address string, readonly bool, id int) *redis.ClusterClient

func SetupProxy

func SetupProxy(t *testing.T, upstreamPort string, db int) func()

func SetupProxyAdvancedConfig

func SetupProxyAdvancedConfig(t *testing.T, upstreamPort string, db int, maxPoolSize int, id int, readonly bool) func()

func SetupStandaloneClient

func SetupStandaloneClient(t *testing.T, address string) *redis.Client

Types

type Proxy

type Proxy struct {
	// contains filtered or unexported fields
}

func NewProxy

func NewProxy(log *zap.Logger, sd *statsd.Client, config *config.Config, upstreamIndex int) (*Proxy, error)

func (*Proxy) Kill

func (p *Proxy) Kill()

func (*Proxy) Run

func (p *Proxy) Run() error

func (*Proxy) Shutdown

func (p *Proxy) Shutdown()

type StatsdBackgroundGaugeCallback

type StatsdBackgroundGaugeCallback func(name string, tags []string)