flow

Documentation

Index

• type Controller
  • func NewController(flows ...Flow) *Controller
  • func (c *Controller) Active() string
  • func (c *Controller) FlowNames() []string
  • func (c *Controller) SelectFlow(ctx context.Context, name string) error
  • func (c *Controller) SubscribeToErrors() <-chan error
• type Flow

Types

type Controller

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

Controller executes the selected flow

func NewController

func NewController(flows ...Flow) *Controller

func (*Controller) Active

func (c *Controller) Active() string

FlowNames returns the list of available flows

func (*Controller) FlowNames

func (c *Controller) FlowNames() []string

FlowNames returns the list of available flows

func (*Controller) SelectFlow

func (c *Controller) SelectFlow(ctx context.Context, name string) error

SelectFlow selects the flow to be executed previous flow will be stopped

func (*Controller) SubscribeToErrors

func (c *Controller) SubscribeToErrors() <-chan error

SubscribeToErrors returns the channel to subscribe to errors

type Flow

type Flow interface {
	Start(ctx context.Context) error
	Stop()
	Name() string
}

Flow is the interface for implementation of ligths patterns