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

proxy

package

Go to main page

Versions in this module

v1

v1.1.2

Dec 6, 2024

v1.1.1

Dec 6, 2024

v1.1.0

Dec 6, 2024

Changes in this version

+ type BackendServerPool struct

+ func NewBackendServerPool(redisConn *RedisConn) *BackendServerPool

+ func (b *BackendServerPool) Get(server string) (*BackendServer, error)

+ func (b *BackendServerPool) Init(server string) (*connpool.Pool, error)

+ func (b *BackendServerPool) Put(server *BackendServer) error

+ func (b *BackendServerPool) Reload(servers map[string]bool)

type Session

+ func (s *Session) Reset(conn net.Conn)

v1.0.23

Aug 23, 2024

v1.0.22

Aug 22, 2024

v1.0.21

Aug 22, 2024

v1.0.20

Aug 22, 2024

v1.0.19

Jun 19, 2024

Changes in this version

+ const CLUSTER_NODES_FIELD_NUM_FLAGS

+ const CLUSTER_NODES_FIELD_NUM_IP_PORT

+ const CLUSTER_NODES_FIELD_SPLIT_NUM

+ const CLUSTER_SLOTS_END

+ const CLUSTER_SLOTS_SERVER_START

+ const CLUSTER_SLOTS_START

+ const CMD_FLAG_GENERAL

+ const CMD_FLAG_PROXY

+ const CMD_FLAG_READ

+ const CMD_FLAG_READ_ALL

+ const CMD_FLAG_UNKNOWN

+ const NumSlots

+ const READ_PREFER_MASTER

+ const READ_PREFER_SLAVE

+ const READ_PREFER_SLAVE_IDC

+ var ARGUMENTS_ERR = []byte("ERR wrong number of arguments")

+ var ASK = []byte("-ASK")

+ var ASK_CMD_BYTES = []byte("+ASKING\r\n")

+ var AUTH_CMD_ERR = []byte("ERR invalid password")

+ var MOVED = []byte("-MOVED")

+ var NOAUTH_ERR = []byte("NOAUTH Authentication required.")

+ var OK = []byte("OK")

+ var OK_DATA = &resp.Data

+ var REDIS_CMD_CLUSTER_NODES *resp.Command

+ var REDIS_CMD_CLUSTER_SLOTS *resp.Command

+ var REDIS_CMD_READ_ONLY *resp.Command

+ var UNKNOWN_CMD_ERR = []byte("ERR unknown command")

+ func CRC16(buf []byte) uint16

+ func CmdAuthRequired(cmd *resp.Command) bool

+ func CmdFlag(cmd *resp.Command) int

+ func CmdReadAll(cmd *resp.Command) bool

+ func CmdReadOnly(cmd *resp.Command) bool

+ func CmdUnknown(cmd *resp.Command) bool

+ func IsMultiCmd(cmd *resp.Command) (multiKey bool, numKeys int)

+ func Key2Slot(key string) int

+ func LocalIP() string

+ func ParseRedirectInfo(msg string) (slot int, server string)

+ type BackendServer struct

+ func NewBackendServer(server string, redisConn *RedisConn) *BackendServer

+ func (tr *BackendServer) Close()

+ func (tr *BackendServer) Request(req *PipelineRequest) (*PipelineResponse, error)

+ type Dispatcher struct

+ func NewDispatcher(startupNodes []string, slotReloadInterval time.Duration, redisConn *RedisConn, ...) *Dispatcher

+ func (d *Dispatcher) AddEvent(session *Session)

+ func (d *Dispatcher) InitSlotTable() error

+ func (d *Dispatcher) RemoveEvent(session *Session)

+ func (d *Dispatcher) Run()

+ func (d *Dispatcher) TriggerReloadSlots()

+ type MultiCmd struct

+ func NewMultiCmd(session *Session, cmd *resp.Command, numSubCmds int) *MultiCmd

+ func (mc *MultiCmd) CoalesceRsp() *PipelineResponse

+ func (mc *MultiCmd) Finished() bool

+ func (mc *MultiCmd) OnSubCmdFinished(rsp *PipelineResponse)

+ func (mc *MultiCmd) SubCmd(index, size int) (*resp.Command, error)

+ type MultiCmdExec struct

+ func NewMultiCmdExec(session *Session) *MultiCmdExec

+ func (m *MultiCmdExec) Exec() (*resp.Data, error)

+ type PipelineRequest struct

+ type PipelineResponse struct

+ type PipelineResponseHeap []*PipelineResponse

+ func (h *PipelineResponseHeap) Pop() interface{}

+ func (h *PipelineResponseHeap) Push(x interface{})

+ func (h PipelineResponseHeap) Len() int

+ func (h PipelineResponseHeap) Less(i, j int) bool

+ func (h PipelineResponseHeap) Swap(i, j int)

+ func (h PipelineResponseHeap) Top() *PipelineResponse

+ type Proxy struct

+ func NewProxy(addr string, dispatcher *Dispatcher, redisConn *RedisConn) *Proxy

+ func (p *Proxy) Exit()

+ func (p *Proxy) Run()

+ type RedisConn struct

+ func NewRedisConn(maxIdle int, connTimeout time.Duration, password string, sendReadOnly bool) *RedisConn

+ func (cp *RedisConn) Auth(password string) bool

+ func (cp *RedisConn) Conn(server string) (net.Conn, error)

+ func (cp *RedisConn) Request(command *resp.Command, conn net.Conn) (*resp.Data, error)

+ type ServerGroup struct

+ type Session struct

+ func (s *Session) Close()

+ func (s *Session) Read(p []byte) (int, error)

+ func (s *Session) ReadingLoop()

+ func (s *Session) Reload(servers map[string]bool)

+ func (s *Session) Run()

+ func (s *Session) Schedule(req *PipelineRequest)

+ func (s *Session) WritingLoop()

+ type SlotInfo struct

+ func NewSlotInfo(data *resp.Data) *SlotInfo

+ type SlotTable struct

+ func NewSlotTable() *SlotTable

+ func (st *SlotTable) ReadServer(slot int) string

+ func (st *SlotTable) ServerSlots() []int

+ func (st *SlotTable) SetSlotInfo(si *SlotInfo)

+ func (st *SlotTable) WriteServer(slot int) string