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

diam

package

Go to main page

Versions in this module

v1

v1.0.0

Jan 20, 2014

Changes in this version

+ var DefaultServeMux = NewServeMux()

+ var ErrHandlerTimeout = errors.New("diam: Handler timeout")

+ var ErrInvalidAvpHdr = errors.New("Invalid AVP header size: probably a bad dict")

+ var ErrNoParentMessage = errors.New("This AVP has no parent message")

+ func ErrorReports() chan ErrorReport

+ func Handle(cmd string, handler Handler)

+ func HandleFunc(cmd string, handler func(Conn, *Message))

+ func ListenAndServe(addr string, handler Handler, dict *dict.Parser) error

+ func ListenAndServeTLS(addr string, certFile string, keyFile string, handler Handler, ...) error

+ func Serve(l net.Listener, handler Handler) error

+ type AVP struct

+ Code uint32

+ Flags uint8

+ Length uint32

+ VendorId uint32

+ func ReadAVP(m *Message, r io.Reader) (uint32, *AVP, error)

+ func (avp *AVP) Body() Codec

+ func (avp *AVP) Data() avpdata.Generic

+ func (avp *AVP) Pack() []byte

+ func (avp *AVP) Set(data interface{}) error

+ func (avp *AVP) String() string

+ type CloseNotifier interface

+ CloseNotify func() <-chan bool

+ type Codec interface

+ Bytes func() []byte

+ Data func() avpdata.Generic

+ Length func() uint32

+ Put func([]byte)

+ String func() string

+ type Conn interface

+ Close func()

+ LocalAddr func() net.Addr

+ RemoteAddr func() net.Addr

+ TLS func() *tls.ConnectionState

+ Write func(*Message) (int, error)

+ func Dial(addr string, handler Handler, dict *dict.Parser) (Conn, error)

+ func DialTLS(addr, certFile, keyFile string, handler Handler, dict *dict.Parser) (Conn, error)

+ type ErrorReport struct

+ Error error

+ Message *Message

+ type Grouped struct

+ AVP []*AVP

+ Buffer []byte

+ Message *Message

+ func NewGroup(m *Message) *Grouped

+ func (gr *Grouped) Add(avp *AVP)

+ func (gr *Grouped) Bytes() []byte

+ func (gr *Grouped) Data() avpdata.Generic

+ func (gr *Grouped) Length() uint32

+ func (gr *Grouped) NewAVP(code interface{}, flags uint8, vendor uint32, data avpdata.Generic) (*AVP, error)

+ func (gr *Grouped) Put(d []byte)

+ func (gr *Grouped) String() string

+ type Handler interface

+ ErrorReports func() chan ErrorReport

+ ServeDiam func(Conn, *Message)

+ func TimeoutHandler(h Handler, dt time.Duration, msg string) Handler

+ type HandlerFunc func(Conn, *Message)

+ func (f HandlerFunc) ErrorReports() chan ErrorReport

+ func (f HandlerFunc) ServeDiam(c Conn, m *Message)

+ type Header struct

+ ApplicationId uint32

+ CommandFlags uint8

+ EndToEndId uint32

+ HopByHopId uint32

+ RawCommandCode [3]uint8

+ RawMessageLength [3]uint8

+ Version uint8

+ func (hdr *Header) CommandCode() uint32

+ func (hdr *Header) MessageLength() uint32

+ func (hdr *Header) SetMessageLength(length uint32)

+ type Message struct

+ AVP []*AVP

+ Dict *dict.Parser

+ Header *Header

+ func NewMessage(cmd uint32, flags uint8, appid, hopbyhop, endtoend uint32, d *dict.Parser) *Message

+ func ReadMessage(r io.Reader, d *dict.Parser) (*Message, error)

+ func (m *Message) Add(avp *AVP)

+ func (m *Message) Answer(resultCode uint32) *Message

+ func (m *Message) FindAVP(code interface{}) (*AVP, error)

+ func (m *Message) NewAVP(code interface{}, flags uint8, vendor uint32, data avpdata.Generic) (*AVP, error)

+ func (m *Message) Pack() []byte

+ func (m *Message) PrettyPrint()

+ func (m *Message) String() string

+ type ServeMux struct

+ func NewServeMux() *ServeMux

+ func (mux *ServeMux) ErrorReports() chan ErrorReport

+ func (mux *ServeMux) Handle(cmd string, handler Handler)

+ func (mux *ServeMux) HandleFunc(cmd string, handler func(Conn, *Message))

+ func (mux *ServeMux) ServeDiam(c Conn, m *Message)

+ type Server struct

+ Addr string

+ Dict *dict.Parser

+ Handler Handler

+ ReadTimeout time.Duration

+ TLSConfig *tls.Config

+ WriteTimeout time.Duration

+ func (srv *Server) ListenAndServe() error

+ func (srv *Server) ListenAndServeTLS(certFile, keyFile string) error

+ func (srv *Server) Serve(l net.Listener) error

Incompatible versions in this module

v3.0.2+incompatible

Jul 20, 2018

v3.0.1+incompatible

Feb 13, 2015

v3.0.0+incompatible

Feb 12, 2015

v2.0.4+incompatible

Feb 12, 2015

v2.0.3+incompatible

Aug 24, 2014

v2.0.2+incompatible

May 10, 2014

v2.0.1+incompatible

Apr 19, 2014

v2.0.0+incompatible

Apr 17, 2014

Other modules containing this package

github.com/ctrlzy/go-diameter/v4