fsm

May 29, 2025

Changes in this version

type Machine

+ func (fsm *Machine) GetAllStates() []string

+ func (fsm *Machine) GetStateChanWithOptions(ctx context.Context, opts ...SubscriberOption) <-chan string

+ type SubscriberOption func(*subscriberConfig)

+ func WithBufferSize(size int) SubscriberOption

+ func WithCustomChannel(ch chan string) SubscriberOption

+ func WithSyncBroadcast() SubscriberOption

+ func WithSyncTimeout(timeout time.Duration) SubscriberOption

+ func WithoutInitialState() SubscriberOption

May 25, 2025

Changes in this version

type Machine

+ func (fsm *Machine) GetStateChanBuffer(ctx context.Context, chanBufferSize int) <-chan string

Apr 1, 2025

Changes in this version

type Machine

+ func NewFromJSON(handler slog.Handler, jsonData []byte, allowedTransitions TransitionsConfig) (*Machine, error)

+ func (fsm *Machine) MarshalJSON() ([]byte, error)

Mar 14, 2025

Changes in this version

+ const StatusBooting

+ const StatusError

+ const StatusNew

+ const StatusReloading

+ const StatusRunning

+ const StatusStopped

+ const StatusStopping

+ const StatusUnknown

+ var ErrAvailableStateData = errors.New("available state data is malformed")

+ var ErrCurrentStateIncorrect = errors.New("current state is incorrect")

+ var ErrInvalidState = errors.New("state is invalid")

+ var ErrInvalidStateTransition = errors.New("state transition is invalid")

+ var TypicalTransitions = TransitionsConfig

+ type Machine struct

+ func New(handler slog.Handler, initialState string, ...) (*Machine, error)

+ func (fsm *Machine) AddSubscriber(ch chan string) func()

+ func (fsm *Machine) GetState() string

+ func (fsm *Machine) GetStateChan(ctx context.Context) <-chan string

+ func (fsm *Machine) SetState(state string) error

+ func (fsm *Machine) Transition(toState string) error

+ func (fsm *Machine) TransitionBool(toState string) bool

+ func (fsm *Machine) TransitionIfCurrentState(fromState, toState string) error

+ type TransitionsConfig map[string][]string