server

Documentation

Index

• Variables
• func ListenAndServe(l ListenArgs, s ServerConst, o orcas.OrcaConst, h1, h2 handlers.HandlerConst)
• type DefaultServer
  • func (s *DefaultServer) Loop()
• type ListenArgs
• type ListenType
• type Server
  • func Default(conns []io.Closer, rp common.RequestParser, o orcas.Orca) Server
• type ServerConst

Variables

var (
	MetricConnectionsEstablishedExt = metrics.AddCounter("conn_established_ext", nil)
	MetricConnectionsEstablishedL1  = metrics.AddCounter("conn_established_l1", nil)
	MetricConnectionsEstablishedL2  = metrics.AddCounter("conn_established_l2", nil)
	MetricCmdTotal                  = metrics.AddCounter("cmd_total", nil)
	MetricErrAppError               = metrics.AddCounter("err_app_err", nil)
	MetricErrUnrecoverable          = metrics.AddCounter("err_unrecoverable", nil)

	MetricCmdGet     = metrics.AddCounter("cmd_get", nil)
	MetricCmdGetE    = metrics.AddCounter("cmd_gete", nil)
	MetricCmdSet     = metrics.AddCounter("cmd_set", nil)
	MetricCmdAdd     = metrics.AddCounter("cmd_add", nil)
	MetricCmdReplace = metrics.AddCounter("cmd_replace", nil)
	MetricCmdAppend  = metrics.AddCounter("cmd_append", nil)
	MetricCmdPrepend = metrics.AddCounter("cmd_prepend", nil)
	MetricCmdDelete  = metrics.AddCounter("cmd_delete", nil)
	MetricCmdTouch   = metrics.AddCounter("cmd_touch", nil)
	MetricCmdGat     = metrics.AddCounter("cmd_gat", nil)
	MetricCmdUnknown = metrics.AddCounter("cmd_unknown", nil)
	MetricCmdNoop    = metrics.AddCounter("cmd_noop", nil)
	MetricCmdQuit    = metrics.AddCounter("cmd_quit", nil)
	MetricCmdVersion = metrics.AddCounter("cmd_version", nil)

	HistSet     = metrics.AddHistogram("set", false, nil)
	HistAdd     = metrics.AddHistogram("add", false, nil)
	HistReplace = metrics.AddHistogram("replace", false, nil)
	HistAppend  = metrics.AddHistogram("append", false, nil)
	HistPrepend = metrics.AddHistogram("prepend", false, nil)
	HistDelete  = metrics.AddHistogram("delete", false, nil)
	HistTouch   = metrics.AddHistogram("touch", false, nil)
	HistGet     = metrics.AddHistogram("get", false, nil)  // not sampled until configurable
	HistGetE    = metrics.AddHistogram("gete", false, nil) // not sampled until configurable
	HistGat     = metrics.AddHistogram("gat", false, nil)  // not sampled until configurable

)

Functions

func ListenAndServe

func ListenAndServe(l ListenArgs, s ServerConst, o orcas.OrcaConst, h1, h2 handlers.HandlerConst)

Types

type DefaultServer

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

DefaultServer is the default server implementation that implements a server REPL for a single external connection.

func (*DefaultServer) Loop

func (s *DefaultServer) Loop()

Loop acts as a master loop for the connection that it is given. Requests are read using the given common.RequestParser and performed by the given orcas.Orca. The connections will all be closed upon an unrecoverable error.

type ListenArgs

type ListenArgs struct {
	// The type of the connection. "tcp" or "unix" only.
	Type ListenType
	// TCP port to listen on, if applicable
	Port int
	// Unix domain socket path to listen on, if applicable
	Path string
}

type ListenType

type ListenType int

const (
	ListenTCP ListenType = iota
	ListenUnix
)

type Server

type Server interface {
	Loop()
}

func Default

func Default(conns []io.Closer, rp common.RequestParser, o orcas.Orca) Server

Default creates a new *DefaultServer instance with the given connections, request parser, and request orchestrator.

type ServerConst

type ServerConst func(conns []io.Closer, rp common.RequestParser, o orcas.Orca) Server