Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var DefaultConfig = func() Config { opts := Config{ Common: config.NewCommon[*client.Conn](), CreateInactivityMonitor: func() client.InactivityMonitor { maxRetries := uint32(2) timeout := time.Second * 16 onInactive := func(cc *client.Conn) { _ = cc.Close() } keepalive := inactivity.NewKeepAlive(maxRetries, onInactive, func(cc *client.Conn, receivePong func()) (func(), error) { return cc.AsyncPing(receivePong) }) return inactivity.New(timeout/time.Duration(maxRetries+1), keepalive.OnInactive) }, OnNewConn: func(cc *client.Conn) { }, ConnectionCacheSize: 2 * 1024, } opts.Handler = func(w *responsewriter.ResponseWriter[*client.Conn], r *pool.Message) { if err := w.SetResponse(codes.NotFound, message.TextPlain, nil); err != nil { opts.Errors(fmt.Errorf("server handler: cannot set response: %w", err)) } } return opts }()
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
config.Common[*client.Conn]
CreateInactivityMonitor client.CreateInactivityMonitorFunc
Handler HandlerFunc
OnNewConn OnNewConnFunc
ConnectionCacheSize uint16
DisablePeerTCPSignalMessageCSMs bool
DisableTCPSignalMessageCSM bool
}
type GoPoolFunc ¶
type GoPoolFunc = func(func()) error
type HandlerFunc ¶
type HandlerFunc = func(*responsewriter.ResponseWriter[*client.Conn], *pool.Message)
The HandlerFunc type is an adapter to allow the use of ordinary functions as COAP handlers.
type OnNewConnFunc ¶
OnNewConnFunc is the callback for new connections.
Click to show internal directories.
Click to hide internal directories.