master

Documentation

Index

• func AddQueue(q *models.Queue) error
• func Queues(userID int64) ([]models.Queue, error)
• type Service
  • func NewService(address string) *Service
  • func (s *Service) AddNode(info models.NodeInfo)
  • func (s *Service) AssignNode(userID int64, queueName string, squadName string) (string, error)
  • func (s *Service) Start()

Functions

func AddQueue

func AddQueue(q *models.Queue) error

AddQueue adds a queue into root queues

func Queues

func Queues(userID int64) ([]models.Queue, error)

Queues returns all queues

Types

type Service

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

Service for a master server

func NewService

func NewService(address string) *Service

NewService allocates a new Service

func (*Service) AddNode

func (s *Service) AddNode(info models.NodeInfo)

AddNode joins a node to the ready-to-serve nodes list

func (*Service) AssignNode

func (s *Service) AssignNode(userID int64, queueName string, squadName string) (string, error)

AssignNode assigns a node to serve one client

func (*Service) Start

func (s *Service) Start()

Start starts the service