Documentation
¶
Overview ¶
Package fasthttputil provides utility functions for fasthttp.
Index ¶
Constants ¶
This section is empty.
Variables ¶
var DefaultInMemoryListener = &Options{
MaxAcceptConn: 1024 * 10,
MaxPipeBuffer: 1024,
}
var ErrInmemoryListenerClosed = errors.New("InmemoryListener is already closed: use of closed network connection")
ErrInmemoryListenerClosed indicates that the InmemoryListener is already closed.
var (
// ErrTimeout is returned from Read() or Write() on timeout.
ErrTimeout = &timeoutError{}
)
Functions ¶
This section is empty.
Types ¶
type InmemoryListener ¶
type InmemoryListener struct {
// contains filtered or unexported fields
}
func NewInmemoryListener ¶
func NewInmemoryListener(opts *Options) *InmemoryListener
NewInmemoryListener returns new in-memory dialer<->net.Listener.
func (*InmemoryListener) Accept ¶
func (ln *InmemoryListener) Accept() (net.Conn, error)
Accept implements net.Listener's Accept.
It is safe calling Accept from concurrently running goroutines.
Accept returns new connection per each Dial call.
func (*InmemoryListener) Addr ¶
func (ln *InmemoryListener) Addr() net.Addr
Addr implements net.Listener's Addr.
func (*InmemoryListener) Close ¶
func (ln *InmemoryListener) Close() error
Close implements net.Listener's Close.
type Options ¶
InmemoryListener provides in-memory dialer<->net.Listener implementation.
It may be used either for fast in-process client<->server communications without network stack overhead or for client<->server tests.
type Pipe ¶
type Pipe struct {
*InmemoryListener
// contains filtered or unexported fields
}
func (*Pipe) SetShutdown ¶
func (p *Pipe) SetShutdown()
type PipeConns ¶
type PipeConns struct {
// contains filtered or unexported fields
}
PipeConns provides bi-directional connection pipe, which use in-process memory as a transport.
PipeConns must be created by calling NewPipeConns.
PipeConns has the following additional features comparing to connections returned from net.Pipe():
- It is faster.
- It buffers Write calls, so there is no need to have concurrent goroutine calling Read in order to unblock each Write call.
- It supports read and write deadlines.
PipeConns is NOT safe for concurrent use by multiple goroutines!
func NewPipeConns ¶
NewPipeConns returns new bi-directional connection pipe.
PipeConns is NOT safe for concurrent use by multiple goroutines!
Source Files