client

Documentation

Index

• type ClientPool
  • func NewClientPool(settings *config.NebulaClientSettings, statsCh chan<- base.Stats) (*ClientPool, error)
  • func (p *ClientPool) Close()
  • func (p *ClientPool) Init() error
• type NebulaClientMgr
  • func NewNebulaClientMgr(settings *config.NebulaClientSettings, statsCh chan<- base.Stats) (*NebulaClientMgr, error)
  • func (m *NebulaClientMgr) Close()
  • func (m *NebulaClientMgr) GetNumConnections() int
  • func (m *NebulaClientMgr) GetRequestChans() []chan base.ClientRequest

Types

type ClientPool

type ClientPool struct {
	Sessions []*nebula.Session
	// contains filtered or unexported fields
}

func NewClientPool

func NewClientPool(settings *config.NebulaClientSettings, statsCh chan<- base.Stats) (*ClientPool, error)

func (*ClientPool) Close

func (p *ClientPool) Close()

func (*ClientPool) Init

func (p *ClientPool) Init() error

type NebulaClientMgr

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

func NewNebulaClientMgr

func NewNebulaClientMgr(settings *config.NebulaClientSettings, statsCh chan<- base.Stats) (*NebulaClientMgr, error)

func (*NebulaClientMgr) Close

func (m *NebulaClientMgr) Close()

func (*NebulaClientMgr) GetNumConnections

func (m *NebulaClientMgr) GetNumConnections() int

func (*NebulaClientMgr) GetRequestChans

func (m *NebulaClientMgr) GetRequestChans() []chan base.ClientRequest