netpool

README

netpool

Connection Pool

Install

go get github.com/tristanwietsma/netpool

Usage

Create a connection pool

p, err := netpool.NewConnectionPool("<type>", "<server ip address>", <pool size>)

Get a connection from the pool

c, err := p.Connect()

Use a connection

Connections implement Write and Read.

err := c.Write([]byte("ping"))
msg, err := c.Read()

Return a connection to the pool

p.Release(c)

Testing

Build and start the echoServer, then go test as normal.

Documentation

Index

• type Connection
  • func NewConnection(network, address string) (*Connection, error)
  • func (c *Connection) Close() error
  • func (c *Connection) Read() ([]byte, error)
  • func (c *Connection) Write(msg []byte) error
• type ConnectionPool
  • func NewConnectionPool(network, address string, size uint) (*ConnectionPool, error)
  • func (p *ConnectionPool) Connect() (*Connection, error)
  • func (p *ConnectionPool) Release(c *Connection)

Types

type Connection

type Connection struct {
	IsClosed bool
	// contains filtered or unexported fields
}

func NewConnection

func NewConnection(network, address string) (*Connection, error)

Returns a connection to `address`.

func (*Connection) Close

func (c *Connection) Close() error

func (*Connection) Read

func (c *Connection) Read() ([]byte, error)

func (*Connection) Write

func (c *Connection) Write(msg []byte) error

type ConnectionPool

type ConnectionPool struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewConnectionPool

func NewConnectionPool(network, address string, size uint) (*ConnectionPool, error)

func (*ConnectionPool) Connect

func (p *ConnectionPool) Connect() (*Connection, error)

func (*ConnectionPool) Release

func (p *ConnectionPool) Release(c *Connection)