pool

package
v0.3.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 28, 2017 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Cache 

type Cache struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Cache - caches nodes by session ID. !!! no thread safe

func NewCache 

func NewCache(expirationTime time.Duration) *Cache

NewCache - constructor of Cache.

func (*Cache) CleanUp 

func (c *Cache) CleanUp()

CleanUp - removes an expired cache.

func (*Cache) Get 

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

Get - returns node from cache.

func (*Cache) Set 

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

Set - caches a node.

type Node 

type Node struct {
	Type             NodeType
	Address          string
	Status           NodeStatus
	SessionID        string
	Updated          int64
	Registered       int64
	CapabilitiesList []capabilities.Capabilities
}

func NewNode 

func NewNode(
	t NodeType,
	address string,
	status NodeStatus,
	sessionID string,
	updated int64,
	registered int64,
	capabilitiesList []capabilities.Capabilities,
) *Node

func (*Node) String 

func (n *Node) String() string

type NodeStatus 

type NodeStatus string
const (
	NodeStatusAvailable NodeStatus = "available"
	NodeStatusReserved  NodeStatus = "reserved"
	NodeStatusBusy      NodeStatus = "busy"
)

type NodeType 

type NodeType string
const (
	NodeTypePersistent NodeType = "persistent"
	NodeTypeKubernetes NodeType = "kubernetes"
)

type Pool 

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

func NewPool 

func NewPool(storage StorageInterface, strategyList StrategyListInterface) *Pool

func (*Pool) Add 

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

func (*Pool) CleanUpNode 

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

func (*Pool) CountNodes 

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

func (*Pool) FixNodeStatuses 

func (p *Pool) FixNodeStatuses()

func (*Pool) GetAll 

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

func (*Pool) GetNodeByAddress 

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

func (*Pool) GetNodeBySessionID 

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

func (*Pool) RegisterSession 

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

func (*Pool) Remove 

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

удаляет ноду из пула

func (*Pool) ReserveAvailableNode 

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

TODO: research close transaction and defer close mysql result body.

func (*Pool) SetBusyNodeDuration 

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

func (*Pool) SetReservedNodeDuration 

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

type StorageInterface 

type StorageInterface interface {
	Add(node Node, limit int) error
	ReserveAvailable([]Node) (Node, error)
	SetBusy(Node, string) error
	SetAvailable(Node) error
	GetCountWithStatus(*NodeStatus) (int, error)
	GetBySession(string) (Node, error)
	GetByAddress(string) (Node, error)
	GetAll() ([]Node, error)
	Remove(Node) error
}

type StorageMock 

type StorageMock struct {
	mock.Mock
}

func (*StorageMock) Add 

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

func (*StorageMock) GetAll 

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

func (*StorageMock) GetByAddress 

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

func (*StorageMock) GetBySession 

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

func (*StorageMock) GetCountWithStatus 

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

func (*StorageMock) Remove 

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

func (*StorageMock) ReserveAvailable 

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

func (*StorageMock) SetAvailable 

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

func (*StorageMock) SetBusy 

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

type StrategyInterface 

type StrategyInterface interface {
	Reserve(capabilities.Capabilities) (Node, error)
	CleanUp(Node) error
	FixNodeStatus(Node) error
}

type StrategyList 

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

func NewStrategyList 

func NewStrategyList(list []StrategyInterface) *StrategyList

func (*StrategyList) CleanUp 

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

func (*StrategyList) FixNodeStatus 

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

func (*StrategyList) Reserve 

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

type StrategyListInterface 

type StrategyListInterface interface {
	Reserve(caps capabilities.Capabilities) (node Node, err error)
	CleanUp(node Node) error
	FixNodeStatus(node Node) error
}

type StrategyListMock 

type StrategyListMock struct {
	mock.Mock
}

func (*StrategyListMock) CleanUp 

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

func (*StrategyListMock) FixNodeStatus 

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

func (*StrategyListMock) Reserve 

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

Source Files

  • cache.go
  • mocks.go
  • node.go
  • pool.go
  • strategyList.go

Directories

Path Synopsis
kubernetes
persistent

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.