mongo

package

v0.5.1-0...-18e6f4e Latest Latest Go to latest Published: Mar 4, 2020 License: MIT Imports: 12 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Factory struct {
}

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

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

func NewMongoStorage(db *mongo.Database) *Storage

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

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

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

func (m *Storage) GetBySession(session string) (pool.Node, error)

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

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

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

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

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

func (m *Storage) UpdateAddress(node pool.Node, newAddress string) error