thread

Documentation

Index

• type Controller
  • func NewController() *Controller
  • func (c *Controller) BeginPulse()
  • func (c *Controller) CanBegin() <-chan struct{}
  • func (c *Controller) CanProcess() <-chan struct{}
  • func (c *Controller) Cancel() <-chan struct{}
  • func (c *Controller) ClosePulse()
• type Thread
  • func NewThread(msg *message.Message, controller *Controller) *Thread
  • func (f *Thread) Continue(context.Context)
  • func (f *Thread) Handle(ctx context.Context, handle flow.Handle) error
  • func (f *Thread) Migrate(ctx context.Context, to flow.Handle) error
  • func (f *Thread) Procedure(ctx context.Context, proc flow.Procedure, cancel bool) error
  • func (f *Thread) Run(ctx context.Context, h flow.Handle) error

Types

type Controller

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

func NewController

func NewController() *Controller

func (*Controller) BeginPulse

func (c *Controller) BeginPulse()

func (*Controller) CanBegin

func (c *Controller) CanBegin() <-chan struct{}

func (*Controller) CanProcess

func (c *Controller) CanProcess() <-chan struct{}

func (*Controller) Cancel

func (c *Controller) Cancel() <-chan struct{}

func (*Controller) ClosePulse

func (c *Controller) ClosePulse()

type Thread

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

func NewThread

func NewThread(msg *message.Message, controller *Controller) *Thread

NewThread creates a new Thread instance. Thread implements the Flow interface.

func (*Thread) Continue

func (f *Thread) Continue(context.Context)

func (*Thread) Handle

func (f *Thread) Handle(ctx context.Context, handle flow.Handle) error

func (*Thread) Migrate

func (f *Thread) Migrate(ctx context.Context, to flow.Handle) error

func (*Thread) Procedure

func (f *Thread) Procedure(ctx context.Context, proc flow.Procedure, cancel bool) error

func (*Thread) Run

func (f *Thread) Run(ctx context.Context, h flow.Handle) error