internal

Documentation

Index

• type Context
  • func MakeContext(supervisor actor.Address) *Context
  • func (c *Context) Address() actor.Address
  • func (c *Context) EqualTo(other actor.Address) bool
  • func (c *Context) Spawn(f actor.Factory, args ...actor.Arg) actor.Address
  • func (c *Context) Supervisor() actor.Address
• type Mailbox
  • func MakeMailbox() *Mailbox
  • func (m *Mailbox) Close()
  • func (m *Mailbox) Receive() <-chan actor.Message
  • func (m *Mailbox) Send() chan<- actor.Message
• type System
  • func MakeSystem(cfg system.Config) *System
  • func (s *System) Shutdown()

Types

type Context

type Context struct {
	sync.RWMutex
	*Mailbox
	// contains filtered or unexported fields
}

Context is the internal implementation of both an actor.Context (and an actor.Address). It also serves as the foundation for the internal implementation of system.System

func MakeContext

func MakeContext(supervisor actor.Address) *Context

MakeContext instantiates a new Context

func (*Context) Address

func (c *Context) Address() actor.Address

Address returns the actor.Address that is managed by this Context

func (*Context) EqualTo

func (c *Context) EqualTo(other actor.Address) bool

EqualTo compares the two actor.Address instances for equality

func (*Context) Spawn

func (c *Context) Spawn(f actor.Factory, args ...actor.Arg) actor.Address

Spawn instantiates a new actor.Actor as a child of this Context

func (*Context) Supervisor

func (c *Context) Supervisor() actor.Address

Supervisor returns the actor.Address of the Supervisor of this Context

type Mailbox

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

Mailbox is the queueing mechanism for a local actor.Actor

func MakeMailbox

func MakeMailbox() *Mailbox

MakeMailbox instantiates a new Mailbox

func (*Mailbox) Close

func (m *Mailbox) Close()

Close the Mailbox

func (*Mailbox) Receive

func (m *Mailbox) Receive() <-chan actor.Message

Receive returns the Mailbox's receiving channel. Will usually be exposed by an actor.Context implementation that composes it in

func (*Mailbox) Send

func (m *Mailbox) Send() chan<- actor.Message

Send returns the Mailbox's sending channel. Will usually be exposed by an actor.Address implementation that composes it in

type System

type System struct {
	*Context
	system.Config
}

System is the internal implementation of system.System

func MakeSystem

func MakeSystem(cfg system.Config) *System

MakeSystem instantiates a new System

func (*System) Shutdown

func (s *System) Shutdown()

Shutdown instructs the System to stop processing Messages and to destroy all of its actor.Actor children