Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

redisconn

package

Go to main page

Versions in this module

v0

v0.9.4

Apr 3, 2020

v0.9.3

Apr 1, 2020

v0.9.2

Feb 14, 2020

Changes in this version

+ const PingLatencyGranularity

+ const PingMaxLatency

type Connection

+ func (conn *Connection) PingLatency() time.Duration

v0.9.0

Dec 19, 2018

Changes in this version

+ const DoAsking

+ const DoTransaction

+ var EKConnection = errorx.RegisterProperty("connection")

+ var EKDb = errorx.RegisterPrintableProperty("db")

+ var ErrAuth = ErrConnection.NewType("count_not_auth", ErrTraitInitPermanent)

+ var ErrConnSetup = ErrConnection.NewType("initialization_temp_error")

+ var ErrConnection = redis.Errors.NewSubNamespace("connection", redis.ErrTraitNotSent, redis.ErrTraitConnectivity)

+ var ErrDial = ErrConnection.NewType("could_not_connect")

+ var ErrInit = ErrConnection.NewType("initialization_error", ErrTraitInitPermanent)

+ var ErrNotConnected = ErrConnection.NewType("not_connected")

+ var ErrTraitInitPermanent = errorx.RegisterTrait("init_permanent")

+ type Connection struct

+ func Connect(ctx context.Context, addr string, opts Opts) (conn *Connection, err error)

+ func (c *Connection) EachShard(cb func(redis.Sender, error) bool)

+ func (c *Connection) Scanner(opts redis.ScanOpts) redis.Scanner

+ func (conn *Connection) Addr() string

+ func (conn *Connection) Close()

+ func (conn *Connection) ConnectedNow() bool

+ func (conn *Connection) Ctx() context.Context

+ func (conn *Connection) Handle() interface{}

+ func (conn *Connection) LocalAddr() string

+ func (conn *Connection) MayBeConnected() bool

+ func (conn *Connection) Ping() error

+ func (conn *Connection) RemoteAddr() string

+ func (conn *Connection) Send(req Request, cb Future, n uint64)

+ func (conn *Connection) SendAsk(req Request, cb Future, n uint64, asking bool)

+ func (conn *Connection) SendBatch(requests []Request, cb Future, start uint64)

+ func (conn *Connection) SendBatchFlags(requests []Request, cb Future, start uint64, flags int)

+ func (conn *Connection) SendMany(requests []Request, cb Future, start uint64)

+ func (conn *Connection) SendTransaction(reqs []Request, cb Future, off uint64)

+ func (conn *Connection) String() string

+ type DefaultLogger struct

+ func (d DefaultLogger) Report(conn *Connection, event LogEvent)

+ func (d DefaultLogger) ReqStat(conn *Connection, req Request, res interface{}, nanos int64)

+ type Future = redis.Future

+ type LogConnectFailed struct

+ Error error

+ type LogConnected struct

+ LocalAddr string

+ RemoteAddr string

+ type LogConnecting struct

+ type LogContextClosed struct

+ Error error

+ type LogDisconnected struct

+ Error error

+ LocalAddr string

+ RemoteAddr string

+ type LogEvent interface

+ type Logger interface

+ Report func(conn *Connection, event LogEvent)

+ ReqStat func(conn *Connection, req Request, res interface{}, nanos int64)

+ type NoopLogger struct

+ func (d NoopLogger) Report(*Connection, LogEvent)

+ func (d NoopLogger) ReqStat(conn *Connection, req Request, res interface{}, nanos int64)

+ type Opts struct

+ AsyncDial bool

+ DB int

+ DialTimeout time.Duration

+ Handle interface{}

+ IOTimeout time.Duration

+ Logger Logger

+ Password string

+ ReconnectPause time.Duration

+ ScriptMode bool

+ TCPKeepAlive time.Duration

+ WritePause time.Duration

+ type Request = redis.Request

+ type Scanner struct

+ func (s *Scanner) Next(cb redis.Future)