testplant

Documentation

Index

• Constants
• func LogSleep(logMu, logSigma float64, unit time.Duration)
• type Deserialiser
  • func NewDeserialiser(filename string) (*Deserialiser, error)
  • func (d *Deserialiser) Initial() uint
  • func (d *Deserialiser) Start(receiver chan struct{})
  • func (d *Deserialiser) Wait()
• type Generator
  • func NewGenerator(plant Plant, logMu, logSigma float64, unit time.Duration) *Generator
  • func (g *Generator) Burst(relMu, size uint)
  • func (g *Generator) IncreaseLogMu(delta float64)
  • func (g *Generator) Kill()
  • func (g *Generator) Start()
• type Manager
  • func NewManager(mu_p0, sigma_p0 uint, unit time.Duration) *Manager
  • func (m *Manager) Add(messages uint)
  • func (m *Manager) Beta() uint
  • func (m *Manager) DXY(unit time.Duration) (dx, dy float64)
  • func (m *Manager) Message() chan struct{}
  • func (m *Manager) MuP() (float64, bool)
  • func (m *Manager) Q() uint
  • func (m *Manager) SetB() chan float64
  • func (m *Manager) X() uint
  • func (m *Manager) XmY() uint
  • func (m *Manager) Y() uint
• type Messenger
• type Plant
• type Queue
  • func NewQueue() *Queue
  • func (q *Queue) Add(messages uint)
• type Serialiser
  • func NewSerialiser(filename string) *Serialiser
  • func (s *Serialiser) Close() error
  • func (s *Serialiser) Message() chan struct{}
  • func (s *Serialiser) Start(initial uint) error
• type Worker
  • func NewWorker(q *Queue, p chan uint, mu_p0, sigma_p0 uint, unit time.Duration) *Worker
  • func (w *Worker) Kill()

Constants

const MAX_P_UNIT = 30000

Functions

func LogSleep

func LogSleep(logMu, logSigma float64, unit time.Duration)

Convenience function for sleeping

Types

type Deserialiser

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

implements Messenger

func NewDeserialiser

func NewDeserialiser(filename string) (*Deserialiser, error)

func (*Deserialiser) Initial

func (d *Deserialiser) Initial() uint

func (*Deserialiser) Start

func (d *Deserialiser) Start(receiver chan struct{})

func (*Deserialiser) Wait

func (d *Deserialiser) Wait()

type Generator

type Generator struct {
	sync.Mutex // For kill
	// contains filtered or unexported fields
}

func NewGenerator

func NewGenerator(plant Plant, logMu, logSigma float64, unit time.Duration) *Generator

func (*Generator) Burst

func (g *Generator) Burst(relMu, size uint)

func (*Generator) IncreaseLogMu

func (g *Generator) IncreaseLogMu(delta float64)

func (*Generator) Kill

func (g *Generator) Kill()

func (*Generator) Start

func (g *Generator) Start()

type Manager

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

func NewManager

func NewManager(mu_p0, sigma_p0 uint, unit time.Duration) *Manager

func (*Manager) Add

func (m *Manager) Add(messages uint)

func (*Manager) Beta

func (m *Manager) Beta() uint

func (*Manager) DXY

func (m *Manager) DXY(unit time.Duration) (dx, dy float64)

func (*Manager) Message

func (m *Manager) Message() chan struct{}

func (*Manager) MuP

func (m *Manager) MuP() (float64, bool)

func (*Manager) Q

func (m *Manager) Q() uint

func (*Manager) SetB

func (m *Manager) SetB() chan float64

func (*Manager) X

func (m *Manager) X() uint

func (*Manager) XmY

func (m *Manager) XmY() uint

func (*Manager) Y

func (m *Manager) Y() uint

type Messenger

type Messenger interface {
	Start()
}

type Plant

type Plant interface {
	Message() chan struct{}
}

type Queue

type Queue struct {
	Send, Recv chan struct{}
	// contains filtered or unexported fields
}

func NewQueue

func NewQueue() *Queue

func (*Queue) Add

func (q *Queue) Add(messages uint)

type Serialiser

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

implements Plant

func NewSerialiser

func NewSerialiser(filename string) *Serialiser

func (*Serialiser) Close

func (s *Serialiser) Close() error

func (*Serialiser) Message

func (s *Serialiser) Message() chan struct{}

func (*Serialiser) Start

func (s *Serialiser) Start(initial uint) error

type Worker

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

func NewWorker

func NewWorker(q *Queue, p chan uint, mu_p0, sigma_p0 uint, unit time.Duration) *Worker

func (*Worker) Kill

func (w *Worker) Kill()