pool

package

Go to main page

Versions in this module

v0

v0.5.0

Oct 28, 2019

v0.4.0

Oct 7, 2019

Changes in this version

type Node

+ Key string

type StorageInterface

+ UpdateAddress func(node Node, newAddress string) error

type StorageMock

+ func (s *StorageMock) UpdateAddress(node Node, newAddress string) error

v0.3.2

Apr 4, 2018

v0.3.1

Oct 30, 2017

v0.3.0

Oct 28, 2017

Changes in this version

+ type Cache struct

+ func NewCache(expirationTime time.Duration) *Cache

+ func (c *Cache) CleanUp()

+ func (c *Cache) Get(key string) (node *Node, ok bool)

+ func (c *Cache) Set(key string, node *Node)

+ type Node struct

+ Address string

+ CapabilitiesList []capabilities.Capabilities

+ Registered int64

+ SessionID string

+ Status NodeStatus

+ Type NodeType

+ Updated int64

+ func NewNode(t NodeType, address string, status NodeStatus, sessionID string, updated int64, ...) *Node

+ func (n *Node) String() string

+ type NodeStatus string

+ const NodeStatusAvailable

+ const NodeStatusBusy

+ const NodeStatusReserved

+ type NodeType string

+ const NodeTypeKubernetes

+ const NodeTypePersistent

+ type Pool struct

+ func NewPool(storage StorageInterface, strategyList StrategyListInterface) *Pool

+ func (p *Pool) Add(t NodeType, address string, capabilitiesList []capabilities.Capabilities) error

+ func (p *Pool) CleanUpNode(node *Node) error

+ func (p *Pool) CountNodes(status *NodeStatus) (int, error)

+ func (p *Pool) FixNodeStatuses()

+ func (p *Pool) GetAll() ([]Node, error)

+ func (p *Pool) GetNodeByAddress(address string) (*Node, error)

+ func (p *Pool) GetNodeBySessionID(sessionID string) (*Node, error)

+ func (p *Pool) RegisterSession(node *Node, sessionID string) error

+ func (p *Pool) Remove(node *Node) error

+ func (p *Pool) ReserveAvailableNode(caps capabilities.Capabilities) (*Node, error)

+ func (p *Pool) SetBusyNodeDuration(duration time.Duration)

+ func (p *Pool) SetReservedNodeDuration(duration time.Duration)

+ type StorageInterface interface

+ Add func(node Node, limit int) error

+ GetAll func() ([]Node, error)

+ GetByAddress func(string) (Node, error)

+ GetBySession func(string) (Node, error)

+ GetCountWithStatus func(*NodeStatus) (int, error)

+ Remove func(Node) error

+ ReserveAvailable func([]Node) (Node, error)

+ SetAvailable func(Node) error

+ SetBusy func(Node, string) error

+ type StorageMock struct

+ func (s *StorageMock) Add(node Node, limit int) error

+ func (s *StorageMock) GetAll() ([]Node, error)

+ func (s *StorageMock) GetByAddress(address string) (Node, error)

+ func (s *StorageMock) GetBySession(sessionID string) (Node, error)

+ func (s *StorageMock) GetCountWithStatus(nodeStatus *NodeStatus) (int, error)

+ func (s *StorageMock) Remove(node Node) error

+ func (s *StorageMock) ReserveAvailable(nodeList []Node) (Node, error)

+ func (s *StorageMock) SetAvailable(node Node) error

+ func (s *StorageMock) SetBusy(node Node, sessionID string) error

+ type StrategyInterface interface

+ CleanUp func(Node) error

+ FixNodeStatus func(Node) error

+ Reserve func(capabilities.Capabilities) (Node, error)

+ type StrategyList struct

+ func NewStrategyList(list []StrategyInterface) *StrategyList

+ func (s *StrategyList) CleanUp(node Node) error

+ func (s *StrategyList) FixNodeStatus(node Node) error

+ func (s *StrategyList) Reserve(caps capabilities.Capabilities) (node Node, err error)

+ type StrategyListInterface interface

+ CleanUp func(node Node) error

+ FixNodeStatus func(node Node) error

+ Reserve func(caps capabilities.Capabilities) (node Node, err error)

+ type StrategyListMock struct

+ func (s *StrategyListMock) CleanUp(node Node) error

+ func (s *StrategyListMock) FixNodeStatus(node Node) error

+ func (s *StrategyListMock) Reserve(caps capabilities.Capabilities) (Node, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL