pool

Documentation

Overview

Package pool implements a kite pool for staying connected to all matching kites in a query.

Index

• Variables
• type Pool
  • func New(k *kite.Kite, q protocol.KontrolQuery) *Pool
  • func (p *Pool) Get() (*kite.Client, error)
  • func (p *Pool) Len() int
  • func (p *Pool) Run() error
  • func (p *Pool) Start() chan error

Variables

var ErrNotFound = errors.New("not found")

Types

type Pool

type Pool struct {
	sync.Mutex // protects Kites map
	// contains filtered or unexported fields
}

Pool is helper for staying connected to every kite in a query.

func New

func New(k *kite.Kite, q protocol.KontrolQuery) *Pool

func (*Pool) Get

func (p *Pool) Get() (*kite.Client, error)

Get returns a random connect kite from the pool.

func (*Pool) Len

func (p *Pool) Len() int

Len returns the number of total connected kites in the pool.

func (*Pool) Run

func (p *Pool) Run() error

Run the pool (blocking).

func (*Pool) Start

func (p *Pool) Start() chan error

Start the pool (unblocking).