Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

quacktors

package module

Go to main page

Versions in this module

v0

v0.0.6

Mar 23, 2021

Changes in this version

type Context

+ func (c *Context) PassthroughPoisonPill(val bool)

v0.0.5

Jan 19, 2021

Changes in this version

+ func Run()

type Context

+ func RootContextWithSpan(span opentracing.Span) Context

+ func VectorContext(name string, span opentracing.Span) Context

+ func (c *Context) Span() opentracing.Span

+ func (c *Context) Trace(name string)

+ func (c *Context) TraceFork(traceFork func(ctx opentracing.SpanContext) opentracing.SpanReference)

v0.0.4

Jan 12, 2021

v0.0.3

Jan 12, 2021

v0.0.2

Jan 11, 2021

v0.0.1

Jan 9, 2021

Changes in this version

+ func MachineId() string

+ func RegisterType(message Message)

+ func Wait()

+ type Abortable interface

+ Abort func()

+ type Actor interface

+ Init func(ctx *Context)

+ Run func(ctx *Context, message Message)

+ type Context struct

+ Logger contextLogger

+ func RootContext() Context

+ func (c *Context) Defer(action func())

+ func (c *Context) Kill(pid *Pid)

+ func (c *Context) Monitor(pid *Pid) Abortable

+ func (c *Context) MonitorMachine(machine *Machine) Abortable

+ func (c *Context) Quit()

+ func (c *Context) Self() *Pid

+ func (c *Context) Send(to *Pid, message Message)

+ func (c *Context) SendAfter(to *Pid, message Message, duration time.Duration) Abortable

+ type DisconnectMessage struct

+ Address string

+ MachineId string

+ func (d DisconnectMessage) Type() string

+ type DownMessage struct

+ Who *Pid

+ func (d DownMessage) Type() string

+ type EmptyMessage struct

+ func (e EmptyMessage) Type() string

+ type GenericMessage struct

+ Value interface{}

+ func (g GenericMessage) Type() string

+ type KillMessage struct

+ func (k KillMessage) Type() string

+ type Machine struct

+ Address string

+ GeneralPurposePort uint16

+ MachineId string

+ MessageGatewayPort uint16

+ type Message interface

+ Type func() string

+ type Pid struct

+ Id string

+ MachineId string

+ func Spawn(action func(ctx *Context, message Message)) *Pid

+ func SpawnStateful(actor Actor) *Pid

+ func SpawnWithInit(init func(ctx *Context), action func(ctx *Context, message Message)) *Pid

+ func (pid *Pid) Is(other *Pid) bool

+ func (pid *Pid) String() string

+ func (pid Pid) Type() string

+ type PoisonPill struct

+ func (p PoisonPill) Type() string

+ type RemoteSystem struct

+ Address string

+ Machine *Machine

+ MachineId string

+ Port uint16

+ func Connect(name string) (*RemoteSystem, error)

+ func (r *RemoteSystem) Remote(handlerName string) (*Pid, error)

+ type StatelessActor struct

+ InitFunction func(ctx *Context)

+ ReceiveFunction func(ctx *Context, message Message)

+ func (s *StatelessActor) Init(ctx *Context)

+ func (s *StatelessActor) Run(ctx *Context, message Message)

+ type System struct

+ func NewSystem(name string) (*System, error)

+ func (s *System) Close()

+ func (s *System) HandleRemote(name string, process *Pid)

+ func (s *System) IsClosed() bool