Documentation ¶
Index ¶
- type Factory
- type MysqlCapabilitiesModel
- type MysqlNodeModel
- type MysqlStorage
- func (s *MysqlStorage) Add(node pool.Node, limit int) error
- func (s *MysqlStorage) GetAll() ([]pool.Node, error)
- func (s *MysqlStorage) GetByAddress(address string) (pool.Node, error)
- func (s *MysqlStorage) GetBySession(sessionID string) (pool.Node, error)
- func (s *MysqlStorage) GetCountWithStatus(status *pool.NodeStatus) (int, error)
- func (s *MysqlStorage) Remove(node pool.Node) error
- func (s *MysqlStorage) ReserveAvailable(nodeList []pool.Node) (pool.Node, error)
- func (s *MysqlStorage) SetAvailable(node pool.Node) error
- func (s *MysqlStorage) SetBusy(node pool.Node, sessionID string) error
- func (s *MysqlStorage) UpdateAddress(node pool.Node, newAddress string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MysqlCapabilitiesModel ¶
type MysqlNodeModel ¶
type MysqlStorage ¶
type MysqlStorage struct {
// contains filtered or unexported fields
}
func NewMysqlStorage ¶
func NewMysqlStorage(db *sqlx.DB) *MysqlStorage
func (*MysqlStorage) GetByAddress ¶
func (s *MysqlStorage) GetByAddress(address string) (pool.Node, error)
func (*MysqlStorage) GetBySession ¶
func (s *MysqlStorage) GetBySession(sessionID string) (pool.Node, error)
func (*MysqlStorage) GetCountWithStatus ¶
func (s *MysqlStorage) GetCountWithStatus(status *pool.NodeStatus) (int, error)
func (*MysqlStorage) ReserveAvailable ¶
func (*MysqlStorage) SetAvailable ¶
func (s *MysqlStorage) SetAvailable(node pool.Node) error
func (*MysqlStorage) SetBusy ¶
func (s *MysqlStorage) SetBusy(node pool.Node, sessionID string) error
func (*MysqlStorage) UpdateAddress ¶ added in v0.4.0
func (s *MysqlStorage) UpdateAddress(node pool.Node, newAddress string) error
Click to show internal directories.
Click to hide internal directories.