step

Documentation

Index

• type ByteSource
  • func NewByteSource(bytes []byte) *ByteSource
  • func (self *ByteSource) Int63() int64
  • func (self *ByteSource) IsEmpty() bool
  • func (self *ByteSource) Seed(int64)
  • func (self *ByteSource) Uint64() uint64
• type StepManagerClientBase
  • func SpawnStepManager(log zerolog.Logger, name string, selector func(runnable int) int) (*StepManagerClientBase, error)
  • func (self *StepManagerClientBase) Spawn(server actors.Server, name string) (*actors.ClientBase, error)
• type StepManagerServer
  • func (self *StepManagerServer) HandleMsg(msg mailbox.Msg) (err error)
  • func (self *StepManagerServer) Terminated(err error, caughtPanic interface{})
• type SteppingChild

Types

type ByteSource

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

func NewByteSource

func NewByteSource(bytes []byte) *ByteSource

func (*ByteSource) Int63

func (self *ByteSource) Int63() int64

func (*ByteSource) IsEmpty

func (self *ByteSource) IsEmpty() bool

func (*ByteSource) Seed

func (self *ByteSource) Seed(int64)

func (*ByteSource) Uint64

func (self *ByteSource) Uint64() uint64

type StepManagerClientBase

type StepManagerClientBase struct {
	*actors.ClientBase
}

func SpawnStepManager

func SpawnStepManager(log zerolog.Logger, name string, selector func(runnable int) int) (*StepManagerClientBase, error)

If selector return number n where 0 <= n < runnable, then that child will be allowed to process one message from its mailbox. If selector returns -1 then no child will be allowed to continue, but it's not an error. If selector returns any other number then the manager exits with ErrNormalActorTermination, and will terminate all its children.

func (*StepManagerClientBase) Spawn

func (self *StepManagerClientBase) Spawn(server actors.Server, name string) (*actors.ClientBase, error)

type StepManagerServer

type StepManagerServer struct {
	actors.BackPressureServerBase
	Selector     func(runnable int) int
	Children     []*SteppingChild
	RunningCount int
}

func (*StepManagerServer) HandleMsg

func (self *StepManagerServer) HandleMsg(msg mailbox.Msg) (err error)

func (*StepManagerServer) Terminated

func (self *StepManagerServer) Terminated(err error, caughtPanic interface{})

type SteppingChild

type SteppingChild struct {
	actors.Client
	Throttle chan struct{}
	Running  bool
	Ready    int
	Name     string
}