handlers

Documentation

Index

• Constants
• Variables
• func CommandConnection(log *zap.Logger, sd *statsd.Client, conn net.Conn, address string, ...)
• type MessageInterceptor
• type Reservations
  • func NewReservations(maxSub, maxBlk int, sd *statsd.Client) *Reservations
  • func (r *Reservations) Close()

Constants

const (
	TransactionOpen = iota
	TransactionInner
	TransactionClose
)

Variables

var TransactionCommands = map[string]int{

	"DISCARD": TransactionClose,
	"EXEC":    TransactionClose,
	"MULTI":   TransactionOpen,
	"UNWATCH": TransactionInner,
	"WATCH":   TransactionOpen,
}

var UnsupportedCommands = map[string]bool{

	"BLPOP":      true,
	"BRPOP":      true,
	"BZPOPMAX":   true,
	"BZPOPMIN":   true,
	"XREAD":      true,
	"XREADGROUP": true,
	"WAIT":       true,

	"AUTH":   true,
	"SELECT": true,
}

Functions

func CommandConnection

func CommandConnection(log *zap.Logger, sd *statsd.Client, conn net.Conn, address string, readTimeout, writeTimeout time.Duration, id uint64, server *pool.Server, kill chan interface{}, quit chan interface{}, interceptor MessageInterceptor, reservations *Reservations)

Types

type MessageInterceptor

type MessageInterceptor func(incomingCmds []string, m []*redis.Message)

type Reservations

type Reservations struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewReservations

func NewReservations(maxSub, maxBlk int, sd *statsd.Client) *Reservations

func (*Reservations) Close

func (r *Reservations) Close()