redcon

Oct 26, 2021

Changes in this version

+ type PubSub struct

+ func (ps *PubSub) Psubscribe(conn Conn, channel string)

+ func (ps *PubSub) Publish(channel, message string) int

+ func (ps *PubSub) Subscribe(conn Conn, channel string)

type Reader

+ func (rd *Reader) ReadCommands() ([]Command, error)

type Server

+ func (s *Server) SetIdleClose(dur time.Duration)

Oct 30, 2020

Changes in this version

+ type Marshaler interface

+ MarshalRESP func() []byte

Mar 6, 2020

Changes in this version

+ type SimpleInt int

+ type SimpleString string

Mar 3, 2020

Changes in this version

+ func AppendAny(b []byte, v interface{}) []byte

type Conn

+ WriteAny func(any interface{})

type Writer

+ func (w *Writer) WriteAny(v interface{})

Jan 27, 2020

Changes in this version

+ const Array

+ const Bulk

+ const Error

+ const Integer

+ const String

+ type RESP struct

+ Count int

+ Data []byte

+ Raw []byte

+ Type Type

+ func ReadNextRESP(b []byte) (n int, resp RESP)

+ func (r *RESP) ForEach(iter func(resp RESP) bool)

+ type Type byte

Jan 20, 2020

Changes in this version

type Server

+ AcceptError func(err error)

Jan 20, 2020

Changes in this version

+ func AppendBulkFloat(b []byte, f float64) []byte

+ func AppendBulkInt(b []byte, x int64) []byte

+ func AppendBulkUint(b []byte, x uint64) []byte

Dec 19, 2019

Changes in this version

type Conn

+ WriteUint64 func(num uint64)

+ type Handler interface

+ ServeRESP func(conn Conn, cmd Command)

+ type HandlerFunc func(conn Conn, cmd Command)

+ func (f HandlerFunc) ServeRESP(conn Conn, cmd Command)

+ type ServeMux struct

+ func NewServeMux() *ServeMux

+ func (m *ServeMux) Handle(command string, handler Handler)

+ func (m *ServeMux) HandleFunc(command string, handler func(conn Conn, cmd Command))

+ func (m *ServeMux) ServeRESP(conn Conn, cmd Command)

type Writer

+ func (w *Writer) WriteUint64(num uint64)

Mar 21, 2019

Changes in this version

+ func Serve(ln net.Listener, handler func(conn Conn, cmd Command), ...) error

type Server

+ func (s *Server) Serve(ln net.Listener) error

Feb 28, 2018

Changes in this version

+ func AppendArray(b []byte, n int) []byte

+ func AppendBulk(b []byte, bulk []byte) []byte

+ func AppendBulkString(b []byte, bulk string) []byte

+ func AppendError(b []byte, s string) []byte

+ func AppendInt(b []byte, n int64) []byte

+ func AppendNull(b []byte) []byte

+ func AppendOK(b []byte) []byte

+ func AppendString(b []byte, s string) []byte

+ func AppendTile38(b []byte, data []byte) []byte

+ func AppendUint(b []byte, n uint64) []byte

+ func ListenAndServe(addr string, handler func(conn Conn, cmd Command), accept func(conn Conn) bool, ...) error

+ func ListenAndServeNetwork(net, laddr string, handler func(conn Conn, cmd Command), ...) error

+ func ListenAndServeNetworkTLS(net, laddr string, handler func(conn Conn, cmd Command), ...) error

+ func ListenAndServeTLS(addr string, handler func(conn Conn, cmd Command), accept func(conn Conn) bool, ...) error

+ type Command struct

+ Args [][]byte

+ Raw []byte

+ func Parse(raw []byte) (Command, error)

+ type Conn interface

+ Close func() error

+ Context func() interface{}

+ Detach func() DetachedConn

+ NetConn func() net.Conn

+ PeekPipeline func() []Command

+ ReadPipeline func() []Command

+ RemoteAddr func() string

+ SetContext func(v interface{})

+ SetReadBuffer func(bytes int)

+ WriteArray func(count int)

+ WriteBulk func(bulk []byte)

+ WriteBulkString func(bulk string)

+ WriteError func(msg string)

+ WriteInt func(num int)

+ WriteInt64 func(num int64)

+ WriteNull func()

+ WriteRaw func(data []byte)

+ WriteString func(str string)

+ type DetachedConn interface

+ Flush func() error

+ ReadCommand func() (Command, error)

+ type Kind int

+ const Redis

+ const Telnet

+ const Tile38

+ func ReadNextCommand(packet []byte, argsbuf [][]byte) (complete bool, args [][]byte, kind Kind, leftover []byte, err error)

+ type Reader struct

+ func NewReader(rd io.Reader) *Reader

+ func (rd *Reader) ReadCommand() (Command, error)

+ type Server struct

+ func NewServer(addr string, handler func(conn Conn, cmd Command), accept func(conn Conn) bool, ...) *Server

+ func NewServerNetwork(net, laddr string, handler func(conn Conn, cmd Command), ...) *Server

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

+ func (s *Server) Close() error

+ func (s *Server) ListenAndServe() error

+ func (s *Server) ListenServeAndSignal(signal chan error) error

+ type TLSServer struct

+ func NewServerNetworkTLS(net, laddr string, handler func(conn Conn, cmd Command), ...) *TLSServer

+ func NewServerTLS(addr string, handler func(conn Conn, cmd Command), accept func(conn Conn) bool, ...) *TLSServer

+ func (s *TLSServer) Close() error

+ func (s *TLSServer) ListenAndServe() error

+ func (s *TLSServer) ListenServeAndSignal(signal chan error) error

+ type Writer struct

+ func BaseWriter(c Conn) *Writer

+ func NewWriter(wr io.Writer) *Writer

+ func (w *Writer) Buffer() []byte

+ func (w *Writer) Flush() error

+ func (w *Writer) SetBuffer(raw []byte)

+ func (w *Writer) WriteArray(count int)

+ func (w *Writer) WriteBulk(bulk []byte)

+ func (w *Writer) WriteBulkString(bulk string)

+ func (w *Writer) WriteError(msg string)

+ func (w *Writer) WriteInt(num int)

+ func (w *Writer) WriteInt64(num int64)

+ func (w *Writer) WriteNull()

+ func (w *Writer) WriteRaw(data []byte)

+ func (w *Writer) WriteString(msg string)