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")
	MetricConnectionsEstablishedL1  = metrics.AddCounter("conn_established_l1")
	MetricConnectionsEstablishedL2  = metrics.AddCounter("conn_established_l2")
	MetricCmdTotal                  = metrics.AddCounter("cmd_total")
	MetricErrAppError               = metrics.AddCounter("err_app_err")
	MetricErrUnrecoverable          = metrics.AddCounter("err_unrecoverable")

	HistSet     = metrics.AddHistogram("set", false)
	HistAdd     = metrics.AddHistogram("add", false)
	HistReplace = metrics.AddHistogram("replace", false)
	HistDelete  = metrics.AddHistogram("delete", false)
	HistTouch   = metrics.AddHistogram("touch", false)
	HistGet     = metrics.AddHistogram("get", true) // sampled
	HistGat     = metrics.AddHistogram("gat", true) // sampled

)

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
}

func (*DefaultServer) Loop

func (s *DefaultServer) Loop()

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

type ServerConst

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