local

Documentation

Index

• type Factory
  • func (f *Factory) Create(cfg config.Config) (pool.StorageInterface, error)
• type Storage
  • func (s *Storage) Add(node pool.Node, limit int) error
  • func (s *Storage) GetAll() ([]pool.Node, error)
  • func (s *Storage) GetByAddress(address string) (pool.Node, error)
  • func (s *Storage) GetBySession(sessionID string) (pool.Node, error)
  • func (s *Storage) GetCountWithStatus(status *pool.NodeStatus) (int, error)
  • func (s *Storage) Remove(node pool.Node) error
  • func (s *Storage) ReserveAvailable(nodeList []pool.Node) (pool.Node, error)
  • func (s *Storage) SetAvailable(node pool.Node) error
  • func (s *Storage) SetBusy(node pool.Node, sessionID string) error

Types

type Factory

type Factory struct {
}

func (*Factory) Create

func (f *Factory) Create(cfg config.Config) (pool.StorageInterface, error)

type Storage

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

func (*Storage) Add

func (s *Storage) Add(node pool.Node, limit int) error

func (*Storage) GetAll

func (s *Storage) GetAll() ([]pool.Node, error)

func (*Storage) GetByAddress

func (s *Storage) GetByAddress(address string) (pool.Node, error)

func (*Storage) GetBySession

func (s *Storage) GetBySession(sessionID string) (pool.Node, error)

func (*Storage) GetCountWithStatus

func (s *Storage) GetCountWithStatus(status *pool.NodeStatus) (int, error)

func (*Storage) Remove

func (s *Storage) Remove(node pool.Node) error

func (*Storage) ReserveAvailable

func (s *Storage) ReserveAvailable(nodeList []pool.Node) (pool.Node, error)

func (*Storage) SetAvailable

func (s *Storage) SetAvailable(node pool.Node) error

func (*Storage) SetBusy

func (s *Storage) SetBusy(node pool.Node, sessionID string) error