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

radix

package module

Go to main page

Versions in this module

v4

v4.1.2

Jan 21, 2023

v4.1.1

Aug 13, 2022

v4.1.0

Apr 18, 2022

v4.0.0

Oct 15, 2021

Changes in this version

+ var ErrNoStreamEntries = errors.New("no stream entries")

+ func CRC16(buf []byte) uint16

+ func ClusterSlot(key []byte) uint16

+ type Action interface

+ Perform func(ctx context.Context, c Conn) error

+ Properties func() ActionProperties

+ func Cmd(rcv interface{}, cmd string, args ...string) Action

+ func FlatCmd(rcv interface{}, cmd string, args ...interface{}) Action

+ func WithConn(key string, fn func(context.Context, Conn) error) Action

+ type ActionProperties struct

+ CanPipeline bool

+ CanRetry bool

+ CanShareConn bool

+ Keys []string

+ func DefaultActionProperties(cmd string, args ...string) ActionProperties

+ type Client interface

+ Addr func() net.Addr

+ Close func() error

+ Do func(context.Context, Action) error

+ type Cluster struct

+ func (c *Cluster) Clients() (map[string]ReplicaSet, error)

+ func (c *Cluster) Close() error

+ func (c *Cluster) Do(ctx context.Context, a Action) error

+ func (c *Cluster) DoSecondary(ctx context.Context, a Action) error

+ func (c *Cluster) Sync(ctx context.Context) error

+ func (c *Cluster) Topo() ClusterTopo

+ type ClusterConfig struct

+ OnDownDelayActionsBy time.Duration

+ PoolConfig PoolConfig

+ SyncEvery time.Duration

+ Trace trace.ClusterTrace

+ func (cfg ClusterConfig) New(ctx context.Context, clusterAddrs []string) (*Cluster, error)

+ type ClusterNode struct

+ Addr string

+ ID string

+ SecondaryOfAddr string

+ SecondaryOfID string

+ Slots [][2]uint16

+ type ClusterTopo []ClusterNode

+ func (tt *ClusterTopo) UnmarshalRESP(br resp.BufferedReader, o *resp.Opts) error

+ func (tt ClusterTopo) Map() map[string]ClusterNode

+ func (tt ClusterTopo) MarshalRESP(w io.Writer, o *resp.Opts) error

+ func (tt ClusterTopo) Primaries() ClusterTopo

+ type CmdConfig struct

+ ActionProperties func(cmd string, args ...string) ActionProperties

+ func (cfg CmdConfig) Cmd(rcv interface{}, cmd string, args ...string) Action

+ func (cfg CmdConfig) FlatCmd(rcv interface{}, cmd string, args ...interface{}) Action

+ type Conn interface

+ EncodeDecode func(ctx context.Context, marshal, unmarshalInto interface{}) error

+ func Dial(ctx context.Context, network, addr string) (Conn, error)

+ func NewPubSubConnStub(remoteNetwork, remoteAddr string, ...) (Conn, chan<- PubSubMessage)

+ func NewStubConn(remoteNetwork, remoteAddr string, ...) Conn

+ type Dialer struct

+ AuthPass string

+ AuthUser string

+ CustomConn func(ctx context.Context, network, addr string) (Conn, error)

+ NetDialer interface{ ... }

+ NewRespOpts func() *resp.Opts

+ Protocol string

+ SelectDB string

+ WriteFlushInterval time.Duration

+ func (d Dialer) Dial(ctx context.Context, network, addr string) (Conn, error)

+ type EvalScript struct

+ func NewEvalScript(script string) EvalScript

+ func (es EvalScript) Cmd(rcv interface{}, keys []string, args ...string) Action

+ func (es EvalScript) FlatCmd(rcv interface{}, keys []string, args ...interface{}) Action

+ type Maybe struct

+ Empty bool

+ Null bool

+ Rcv interface{}

+ func (mb *Maybe) UnmarshalRESP(br resp.BufferedReader, o *resp.Opts) error

+ type MultiClient interface

+ Clients func() (map[string]ReplicaSet, error)

+ Close func() error

+ Do func(context.Context, Action) error

+ DoSecondary func(context.Context, Action) error

+ func NewMultiClient(rs ReplicaSet) MultiClient

+ type PersistentPubSubConnConfig struct

+ Dialer Dialer

+ PubSubConfig PubSubConfig

+ Trace trace.PersistentPubSubTrace

+ func (cfg PersistentPubSubConnConfig) New(ctx context.Context, cb func() (network, addr string, err error)) (PubSubConn, error)

+ type Pipeline struct

+ func NewPipeline() *Pipeline

+ func (p *Pipeline) Append(a Action)

+ func (p *Pipeline) Perform(ctx context.Context, c Conn) error

+ func (p *Pipeline) Properties() ActionProperties

+ func (p *Pipeline) Reset()

+ type PoolConfig struct

+ CustomPool func(ctx context.Context, network, addr string) (Client, error)

+ Dialer Dialer

+ MaxReconnectInterval time.Duration

+ MinReconnectInterval time.Duration

+ PingInterval time.Duration

+ Size int

+ Trace trace.PoolTrace

+ func (cfg PoolConfig) New(ctx context.Context, network, addr string) (Client, error)

+ type PubSubConfig struct

+ PingInterval time.Duration

+ func (cfg PubSubConfig) New(conn Conn) PubSubConn

+ type PubSubConn interface

+ Close func() error

+ Next func(ctx context.Context) (PubSubMessage, error)

+ PSubscribe func(ctx context.Context, patterns ...string) error

+ PUnsubscribe func(ctx context.Context, patterns ...string) error

+ Ping func(ctx context.Context) error

+ Subscribe func(ctx context.Context, channels ...string) error

+ Unsubscribe func(ctx context.Context, channels ...string) error

+ type PubSubMessage struct

+ Channel string

+ Message []byte

+ Pattern string

+ Type string

+ func (m *PubSubMessage) UnmarshalRESP(br resp.BufferedReader, o *resp.Opts) error

+ func (m PubSubMessage) MarshalRESP(w io.Writer, o *resp.Opts) error

+ type ReplicaSet struct

+ Primary Client

+ Secondaries []Client

+ type Scanner interface

+ Close func() error

+ Next func(context.Context, *string) bool

+ type ScannerConfig struct

+ Command string

+ Count int

+ Key string

+ Pattern string

+ Type string

+ func (cfg ScannerConfig) New(c Client) Scanner

+ func (cfg ScannerConfig) NewMulti(mc MultiClient) Scanner

+ type Sentinel struct

+ func (sc *Sentinel) Clients() (map[string]ReplicaSet, error)

+ func (sc *Sentinel) Close() error

+ func (sc *Sentinel) Do(ctx context.Context, a Action) error

+ func (sc *Sentinel) DoSecondary(ctx context.Context, a Action) error

+ func (sc *Sentinel) SentinelAddrs() ([]string, error)

+ type SentinelConfig struct

+ PoolConfig PoolConfig

+ SentinelDialer Dialer

+ Trace trace.SentinelTrace

+ func (cfg SentinelConfig) New(ctx context.Context, primaryName string, sentinelAddrs []string) (*Sentinel, error)

+ type StreamConfig struct

+ After StreamEntryID

+ Latest bool

+ PendingThenLatest bool

+ type StreamEntries struct

+ Entries []StreamEntry

+ Stream string

+ func (s *StreamEntries) UnmarshalRESP(br resp.BufferedReader, o *resp.Opts) error

+ type StreamEntry struct

+ Fields [][2]string

+ ID StreamEntryID

+ func (s *StreamEntry) UnmarshalRESP(br resp.BufferedReader, o *resp.Opts) error

+ type StreamEntryID struct

+ Seq uint64

+ Time uint64

+ func (s *StreamEntryID) MarshalRESP(w io.Writer, o *resp.Opts) error

+ func (s *StreamEntryID) UnmarshalRESP(br resp.BufferedReader, o *resp.Opts) error

+ func (s StreamEntryID) Before(o StreamEntryID) bool

+ func (s StreamEntryID) Next() StreamEntryID

+ func (s StreamEntryID) Prev() StreamEntryID

+ func (s StreamEntryID) String() string

+ type StreamReader interface

+ Next func(context.Context) (stream string, entry StreamEntry, err error)

+ type StreamReaderConfig struct

+ Consumer string

+ Count int

+ Group string

+ NoAck bool

+ NoBlock bool

+ func (cfg StreamReaderConfig) New(c Client, streamCfgs map[string]StreamConfig) StreamReader

+ type Tuple []interface

+ func (t Tuple) UnmarshalRESP(br resp.BufferedReader, o *resp.Opts) error

v4.0.0-beta.1

Dec 29, 2020

v4.0.0-beta.0

Oct 4, 2020

Other modules containing this package

github.com/mediocregopher/radix/v3