controllers

Documentation

Index

• Constants
• type Controller
  • func New(subscribers []ControllerObserver) *Controller
  • func (controller *Controller) Exit()
  • func (controller *Controller) Sorter() func(*gin.Context)
• type ControllerObserver
• type ControllerPublisher
  • func NewControllerPublisher(subscribers []ControllerObserver) *ControllerPublisher
  • func (publisher *ControllerPublisher) Notify(data *models.Data)
  • func (publisher *ControllerPublisher) Subscribe(subscriber ControllerObserver)
• type Sor

Constants

const (
	MAX_N_LOC_THREADS = 4
	MAX_N_THREADS     = 100
)

Types

type Controller

type Controller struct {
	Publisher  *ControllerPublisher
	Channel    chan *models.Data
	ChannelLoc chan *models.Data
	Quit       chan int
}

func New

func New(subscribers []ControllerObserver) *Controller

func (*Controller) Exit

func (controller *Controller) Exit()

func (*Controller) Sorter

func (controller *Controller) Sorter() func(*gin.Context)

type ControllerObserver

type ControllerObserver interface {
	Run(data *models.Data)
}

type ControllerPublisher

type ControllerPublisher struct {
	Subscribers []ControllerObserver
	PuMutex     sync.Mutex
}

func NewControllerPublisher

func NewControllerPublisher(subscribers []ControllerObserver) *ControllerPublisher

func (*ControllerPublisher) Notify

func (publisher *ControllerPublisher) Notify(data *models.Data)

func (*ControllerPublisher) Subscribe

func (publisher *ControllerPublisher) Subscribe(subscriber ControllerObserver)

type Sor

type Sor struct {
	Body        io.Reader
	ContentType string
	Cont        *Controller
}