mandrill

Documentation

Index

• func RegisterGlobalSystem(name string, p PidSystem)
• type MandrillPID
  • func (pid *MandrillPID) ExitChan() chan bool
  • func (pid *MandrillPID) GetValue(name string, v interface{}) bool
  • func (pid *MandrillPID) Kill()
  • func (pid *MandrillPID) PutValue(name string, v interface{})
  • func (pid *MandrillPID) Read() []interface{}
  • func (pid *MandrillPID) Read1(v interface{}) bool
  • func (pid *MandrillPID) Read2(v1, v2 interface{}) bool
  • func (pid *MandrillPID) Read3(v1, v2, v3 interface{}) bool
  • func (pid *MandrillPID) Send(message []interface{}) error
  • func (pid *MandrillPID) Send1(m interface{}) error
  • func (pid *MandrillPID) Send2(m1 interface{}, m2 interface{}) error
  • func (pid *MandrillPID) Send3(m1 interface{}, m2 interface{}, m3 interface{}) error
  • func (pid *MandrillPID) Stats() chan Stat
• type PID
  • func Spawn(sys PidSystem, descriptor string, mailboxSize int, concurrency int, ...) PID
  • func SpawnDefault(sys PidSystem, descriptor string, boundFunc func(PID, PidSystem) bool) PID
• type PIDList
• type PidSystem
  • func DefaultSystem() PidSystem
  • func FindSystem(name string) PidSystem
• type Stat
• type StatConsumer
• type StatNullCollector
  • func (col *StatNullCollector) Consume(ch chan Stat)
• type Statistic
  • func (stat *Statistic) Operation() string
  • func (stat *Statistic) Tags() []string
  • func (stat *Statistic) Value() *string
• type System
  • func (s *System) Find(name string) PID
  • func (s *System) Register(name string, pid PID)
  • func (s *System) Spawn(descriptor string, mailboxSize int, concurrency int, ...) PID
  • func (s *System) SpawnDefault(descriptor string, boundFunc func(PID, PidSystem) bool) PID

Functions

func RegisterGlobalSystem

func RegisterGlobalSystem(name string, p PidSystem)

Types

type MandrillPID

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

func (*MandrillPID) ExitChan

func (pid *MandrillPID) ExitChan() chan bool

func (*MandrillPID) GetValue

func (pid *MandrillPID) GetValue(name string, v interface{}) bool

func (*MandrillPID) Kill

func (pid *MandrillPID) Kill()

func (*MandrillPID) PutValue

func (pid *MandrillPID) PutValue(name string, v interface{})

func (*MandrillPID) Read

func (pid *MandrillPID) Read() []interface{}

func (*MandrillPID) Read1

func (pid *MandrillPID) Read1(v interface{}) bool

func (*MandrillPID) Read2

func (pid *MandrillPID) Read2(v1, v2 interface{}) bool

func (*MandrillPID) Read3

func (pid *MandrillPID) Read3(v1, v2, v3 interface{}) bool

func (*MandrillPID) Send

func (pid *MandrillPID) Send(message []interface{}) error

func (*MandrillPID) Send1

func (pid *MandrillPID) Send1(m interface{}) error

func (*MandrillPID) Send2

func (pid *MandrillPID) Send2(m1 interface{}, m2 interface{}) error

func (*MandrillPID) Send3

func (pid *MandrillPID) Send3(m1 interface{}, m2 interface{}, m3 interface{}) error

func (*MandrillPID) Stats

func (pid *MandrillPID) Stats() chan Stat

type PID

type PID interface {
	Kill()
	Send(message []interface{}) error
	Send1(m interface{}) error
	Send2(m1, m2 interface{}) error
	Send3(m1, m2, m3 interface{}) error
	Read() []interface{}
	Read1(v interface{}) bool
	Read2(v1, v2 interface{}) bool
	Read3(v1, v2, v3 interface{}) bool
	Stats() chan Stat
	ExitChan() chan bool
	PutValue(name string, item interface{})
	GetValue(name string, v interface{}) bool
}

func Spawn

func Spawn(sys PidSystem, descriptor string, mailboxSize int, concurrency int, dictionary map[string]interface{}, boundFunc func(PID, PidSystem) bool) PID

func SpawnDefault

func SpawnDefault(sys PidSystem, descriptor string, boundFunc func(PID, PidSystem) bool) PID

type PIDList

type PIDList []PID

type PidSystem

type PidSystem interface {
	Register(string, PID)
	Find(string) PID
	Spawn(string, int, int, map[string]interface{}, func(PID, PidSystem) bool) PID
	SpawnDefault(descriptor string, boundFunc func(PID, PidSystem) bool) PID
}

func DefaultSystem

func DefaultSystem() PidSystem

func FindSystem

func FindSystem(name string) PidSystem

type Stat

type Stat interface {
	Operation() string
	Tags() []string
	Value() *string
}

type StatConsumer

type StatConsumer interface {
	Consume(ch chan Stat)
}

type StatNullCollector

type StatNullCollector struct {
}

func (*StatNullCollector) Consume

func (col *StatNullCollector) Consume(ch chan Stat)

type Statistic

type Statistic struct {
	O string
	T []string
	S *string
}

func (*Statistic) Operation

func (stat *Statistic) Operation() string

func (*Statistic) Tags

func (stat *Statistic) Tags() []string

func (*Statistic) Value

func (stat *Statistic) Value() *string

type System

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

func (*System) Find

func (s *System) Find(name string) PID

func (*System) Register

func (s *System) Register(name string, pid PID)

func (*System) Spawn

func (s *System) Spawn(descriptor string, mailboxSize int, concurrency int, dictionary map[string]interface{}, boundFunc func(PID, PidSystem) bool) PID

func (*System) SpawnDefault

func (s *System) SpawnDefault(descriptor string, boundFunc func(PID, PidSystem) bool) PID