Versions in this module Expand all Collapse all v1 v1.0.8 Apr 23, 2023 Changes in this version + const VarScopeProcess + const VarScopeRequest + const VarScopeResponse + const VarScopeSession + const VarScopeTransaction + func DecodeHeaders(headers []byte) (http.Header, error) + type Action interface + type ActionSetVar struct + Name string + Scope varScope + Value interface{} + type ActionUnsetVar struct + Name string + Scope varScope + type Agent struct + Handler Handler + func New(h Handler) *Agent + func NewWithConfig(h Handler, cfg Config) *Agent + func (a *Agent) ListenAndServe(addr string) error + func (a *Agent) Serve(lis net.Listener) error + type Arg struct + Name string + Value interface{} + type ArgIterator struct + Arg Arg + func (i *ArgIterator) Count() int + func (i *ArgIterator) Map() map[string]interface{} + func (i *ArgIterator) Next() bool + type Config struct + IdleTimeout time.Duration + MaxConnections int + ReadTimeout time.Duration + WriteTimeout time.Duration + type EngKey struct + Conn net.Conn + Engine string + FrameSize int + type Engine struct + type Frame struct + type Handler func(msgs *MessageIterator) ([]Action, error) + type Message struct + Args *ArgIterator + Name string + type MessageIterator struct + Message Message + func (i *MessageIterator) Error() error + func (i *MessageIterator) Next() bool