channel

Documentation

Index

• type Listener
  • func New(chanSize int) *Listener
  • func (l *Listener) AfterStart(ctx context.Context)
  • func (l *Listener) AfterTransition(ctx context.Context, transitionID string, state gowfnet.StateOpInterface)
  • func (l *Listener) BeforeStart(ctx context.Context) error
  • func (l *Listener) BeforeTransition(ctx context.Context, transitionID string, state gowfnet.StateOpInterface) error
  • func (l *Listener) GetStateListener() state.ListenerInterface
  • func (l *Listener) HasStateListener() bool
  • func (l *Listener) ReadEvt() string
• type State
  • func NewState(eventChan chan string) *State
  • func (s *State) AfterMove(ctx context.Context, st state.OpInterface, from []string, to []string)
  • func (s *State) BeforeMove(ctx context.Context, st state.OpInterface, from []string, to []string) error
  • func (s *State) OnError(st state.OpInterface)
  • func (s *State) OnFinish(st state.OpInterface)

Types

type Listener

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

func New

func New(chanSize int) *Listener

func (*Listener) AfterStart

func (l *Listener) AfterStart(ctx context.Context)

func (*Listener) AfterTransition

func (l *Listener) AfterTransition(ctx context.Context, transitionID string, state gowfnet.StateOpInterface)

func (*Listener) BeforeStart

func (l *Listener) BeforeStart(ctx context.Context) error

func (*Listener) BeforeTransition

func (l *Listener) BeforeTransition(ctx context.Context, transitionID string, state gowfnet.StateOpInterface) error

func (*Listener) GetStateListener

func (l *Listener) GetStateListener() state.ListenerInterface

func (*Listener) HasStateListener

func (l *Listener) HasStateListener() bool

func (*Listener) ReadEvt

func (l *Listener) ReadEvt() string

type State

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

func NewState

func NewState(eventChan chan string) *State

func (*State) AfterMove

func (s *State) AfterMove(ctx context.Context, st state.OpInterface, from []string, to []string)

func (*State) BeforeMove

func (s *State) BeforeMove(ctx context.Context, st state.OpInterface, from []string, to []string) error

func (*State) OnError

func (s *State) OnError(st state.OpInterface)

func (*State) OnFinish

func (s *State) OnFinish(st state.OpInterface)