idletiming

README

idletiming   

Provides mechanisms for adding idle timeouts to net.Conn and net.Listener.

GoDoc

Documentation

Overview

package idletiming provides mechanisms for adding idle timeouts to net.Conn and net.Listener.

Index

• func Listener(listener net.Listener, idleTimeout time.Duration, onIdle func(conn net.Conn)) net.Listener
• type IdleTimingConn
  • func Conn(conn net.Conn, idleTimeout time.Duration, onIdle func()) *IdleTimingConn
  • func (c *IdleTimingConn) Close() error
  • func (c *IdleTimingConn) LocalAddr() net.Addr
  • func (c *IdleTimingConn) Read(b []byte) (int, error)
  • func (c *IdleTimingConn) RemoteAddr() net.Addr
  • func (c *IdleTimingConn) SetDeadline(t time.Time) error
  • func (c *IdleTimingConn) SetReadDeadline(t time.Time) error
  • func (c *IdleTimingConn) SetWriteDeadline(t time.Time) error
  • func (c *IdleTimingConn) TimesOutAt() time.Time
  • func (c *IdleTimingConn) TimesOutIn() time.Duration
  • func (c *IdleTimingConn) Write(b []byte) (int, error)

Examples

• Conn
• Listener

Functions

func Listener

func Listener(listener net.Listener, idleTimeout time.Duration, onIdle func(conn net.Conn)) net.Listener

Listener creates a net.Listener that wraps the connections obtained from an original net.Listener with idle timing connections that time out after the specified duration.

idleTimeout specifies how long to wait for inactivity before considering connection idle. Note - the actual timeout may be up to twice idleTimeout, depending on timing.

onIdle is a required function that's called if a connection idles. idletiming.Conn does not close the underlying connection on idle, you have to do that in your onIdle callback.

Example

l, err := net.Listen("tcp", "127.0.0.1:8080")
if err != nil {
	log.Fatalf("Unable to listen %s", err)
}

il := Listener(l, 5*time.Second, func(conn net.Conn) {
	log.Debugf("Connection was idled")
})

if _, err := il.Accept(); err != nil {
	log.Fatalf("Unable to accept connections: %v", err)
}

Types

type IdleTimingConn

type IdleTimingConn struct {
	// contains filtered or unexported fields
}

IdleTimingConn is a net.Conn that wraps another net.Conn and that times out if idle for more than idleTimeout.

func Conn

func Conn(conn net.Conn, idleTimeout time.Duration, onIdle func()) *IdleTimingConn

Conn creates a new net.Conn wrapping the given net.Conn that times out after the specified period. Read and Write calls will timeout if they take longer than the indicated idleTimeout.

idleTimeout specifies how long to wait for inactivity before considering connection idle.

onIdle is a required function that's called if a connection idles. idletiming.Conn does not close the underlying connection on idle, you have to do that in your onIdle callback.

Example

c, err := net.Dial("tcp", "127.0.0.1:8080")
if err != nil {
	log.Fatalf("Unable to dial %s", err)
}

ic := Conn(c, 5*time.Second, func() {
	log.Debugf("Connection was idled")
})

if _, err := ic.Write([]byte("My data")); err != nil {
	log.Fatalf("Unable to write to connection: %v", err)
}

func (*IdleTimingConn) Close

func (c *IdleTimingConn) Close() error

Close this IdleTimingConn. This will close the underlying net.Conn as well, returning the error from calling its Close method.

func (*IdleTimingConn) LocalAddr

func (c *IdleTimingConn) LocalAddr() net.Addr

func (*IdleTimingConn) Read

func (c *IdleTimingConn) Read(b []byte) (int, error)

Read implements the method from io.Reader

func (*IdleTimingConn) RemoteAddr

func (c *IdleTimingConn) RemoteAddr() net.Addr

func (*IdleTimingConn) SetDeadline

func (c *IdleTimingConn) SetDeadline(t time.Time) error

func (*IdleTimingConn) SetReadDeadline

func (c *IdleTimingConn) SetReadDeadline(t time.Time) error

func (*IdleTimingConn) SetWriteDeadline

func (c *IdleTimingConn) SetWriteDeadline(t time.Time) error

func (*IdleTimingConn) TimesOutAt

func (c *IdleTimingConn) TimesOutAt() time.Time

TimesOutAt returns the time at which this connection will time out, assuming there is no further activity

func (*IdleTimingConn) TimesOutIn

func (c *IdleTimingConn) TimesOutIn() time.Duration

TimesOutIn returns how much time is left before this connection will time out, assuming there is no further activity.

func (*IdleTimingConn) Write

func (c *IdleTimingConn) Write(b []byte) (int, error)

Write implements the method from io.Reader