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

redcon

package module

Go to main page

Versions in this module

v2

v2.0.8

Jul 24, 2024

v2.0.7

Jun 14, 2024

v2.0.6

Jun 14, 2024

v2.0.5

Jun 14, 2024

v2.0.4

Jun 14, 2024

v2.0.3

Jun 14, 2024

v2.0.2

Jun 14, 2024

v2.0.1

Jun 14, 2024

v2.0.0

Jun 12, 2024

Changes in this version

+ const Array

+ const Bulk

+ const Error

+ const Integer

+ const String

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

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

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

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

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

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

+ func AppendBulkUint(dst []byte, x uint64) []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

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

+ func WithConnectionCount(fn func(addr string, tag string))

+ func WithConnectionLatency(fn func(addr string, tag string, latency int64))

+ 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)

+ WriteAny func(any interface{})

+ 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)

+ WriteUint64 func(num uint64)

+ type DetachedConn interface

+ Flush func() error

+ ReadCommand func() (Command, error)

+ 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 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 Marshaler interface

+ MarshalRESP func() []byte

+ 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 RESP struct

+ Count int

+ Data []byte

+ Raw []byte

+ Type Type

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

+ func (r RESP) Bytes() []byte

+ func (r RESP) Exists() bool

+ func (r RESP) Float() float64

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

+ func (r RESP) Int() int64

+ func (r RESP) Map() map[string]RESP

+ func (r RESP) MapGet(key string) RESP

+ func (r RESP) String() string

+ type Reader struct

+ func NewReader(rd io.Reader) *Reader

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

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

+ 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 Server struct

+ AcceptError func(err error)

+ 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) Listen(signal chan error) error

+ func (s *Server) ListenAndServe() error

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

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

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

+ type ServerOptions struct

+ ConnectionCount func(addr string, tag string)

+ ConnectionLatency func(addr string, tag string, latency int64)

+ type SimpleError error

+ type SimpleInt int

+ type SimpleString string

+ 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 Type byte

+ 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) WriteAny(v interface{})

+ 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)

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