server

Documentation

Index

• Variables
• type Cmd
• type DisconnectHandler
• type Peer
  • func (c *Peer) Block(f func(*Writer))
  • func (c *Peer) Close()
  • func (c *Peer) Flush()
  • func (c *Peer) OnDisconnect(f func())
  • func (c *Peer) WriteBulk(s string)
  • func (c *Peer) WriteError(e string)
  • func (c *Peer) WriteInline(s string)
  • func (c *Peer) WriteInt(i int)
  • func (c *Peer) WriteLen(n int)
  • func (c *Peer) WriteNull()
  • func (c *Peer) WriteOK()
• type Server
  • func NewServer(addr string) (*Server, error)
  • func (s *Server) Addr() *net.TCPAddr
  • func (s *Server) ClientsLen() int
  • func (s *Server) Close()
  • func (s *Server) Register(cmd string, f Cmd) error
  • func (s *Server) ServeConn(conn net.Conn)
  • func (s *Server) TotalCommands() int
  • func (s *Server) TotalConnections() int
• type Writer
  • func (w *Writer) Flush()
  • func (w *Writer) WriteBulk(s string)
  • func (w *Writer) WriteError(e string)
  • func (w *Writer) WriteInline(s string)
  • func (w *Writer) WriteInt(i int)
  • func (w *Writer) WriteLen(n int)
  • func (w *Writer) WriteNull()

Variables

var ErrProtocol = errors.New("invalid request")

ErrProtocol is the general error for unexpected input

Types

type Cmd

type Cmd func(c *Peer, cmd string, args []string)

Cmd is what Register expects

type DisconnectHandler

type DisconnectHandler func(c *Peer)

type Peer

type Peer struct {
	Ctx interface{} // anything goes, server won't touch this
	// contains filtered or unexported fields
}

Peer is a client connected to the server

func (*Peer) Block

func (c *Peer) Block(f func(*Writer))

issue multiple calls, guarded with a mutex

func (*Peer) Close

func (c *Peer) Close()

Close the client connection after the current command is done.

func (*Peer) Flush

func (c *Peer) Flush()

Flush the write buffer. Called automatically after every redis command

func (*Peer) OnDisconnect

func (c *Peer) OnDisconnect(f func())

Register a function to execute on disconnect. There can be multiple functions registered.

func (*Peer) WriteBulk

func (c *Peer) WriteBulk(s string)

WriteBulk writes a bulk string

func (*Peer) WriteError

func (c *Peer) WriteError(e string)

WriteError writes a redis 'Error'

func (*Peer) WriteInline

func (c *Peer) WriteInline(s string)

WriteInline writes a redis inline string

func (*Peer) WriteInt

func (c *Peer) WriteInt(i int)

WriteInt writes an integer

func (*Peer) WriteLen

func (c *Peer) WriteLen(n int)

WriteLen starts an array with the given length

func (*Peer) WriteNull

func (c *Peer) WriteNull()

WriteNull writes a redis Null element

func (*Peer) WriteOK

func (c *Peer) WriteOK()

WriteOK write the inline string `OK`

type Server

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

Server is a simple redis server

func NewServer

func NewServer(addr string) (*Server, error)

NewServer makes a server listening on addr. Close with .Close().

func (*Server) Addr

func (s *Server) Addr() *net.TCPAddr

Addr has the net.Addr struct

func (*Server) ClientsLen

func (s *Server) ClientsLen() int

ClientsLen gives the number of connected clients right now

func (*Server) Close

func (s *Server) Close()

Close a server started with NewServer. It will wait until all clients are closed.

func (*Server) Register

func (s *Server) Register(cmd string, f Cmd) error

Register a command. It can't have been registered before. Safe to call on a running server.

func (*Server) ServeConn

func (s *Server) ServeConn(conn net.Conn)

ServeConn handles a net.Conn. Nice with net.Pipe()

func (*Server) TotalCommands

func (s *Server) TotalCommands() int

TotalCommands is total (known) commands since this the server started

func (*Server) TotalConnections

func (s *Server) TotalConnections() int

TotalConnections give the number of clients connected since the server started, including the currently connected ones

type Writer

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

A Writer is given to the callback in Block()

func (*Writer) Flush

func (w *Writer) Flush()

func (*Writer) WriteBulk

func (w *Writer) WriteBulk(s string)

WriteBulk writes a bulk string

func (*Writer) WriteError

func (w *Writer) WriteError(e string)

WriteError writes a redis 'Error'

func (*Writer) WriteInline

func (w *Writer) WriteInline(s string)

WriteInline writes a redis inline string

func (*Writer) WriteInt

func (w *Writer) WriteInt(i int)

WriteInt writes an integer

func (*Writer) WriteLen

func (w *Writer) WriteLen(n int)

func (*Writer) WriteNull

func (w *Writer) WriteNull()

WriteNull writes a redis Null element