state

Nov 1, 2024

Changes in this version

+ var ErrCouldNotCreateDirectory = fmt.Errorf("could not create state directory")

+ var ErrCouldNotOpenFile = fmt.Errorf("could not open state file")

+ var ErrCouldNotReadFile = fmt.Errorf("could not read state file")

+ var ErrCouldNotWriteFile = fmt.Errorf("could not write state file")

+ var ErrFileCorrupted = fmt.Errorf("state file corrupted, could not unmarshal")

+ var ErrOnlyLocalStateSupported = fmt.Errorf("only local state is supported")

+ var ErrUnsupportedStateType = errors.New("unsupported state type")

+ func NewLocalStateManager(statePath string, id uuid.UUID) definitions.StateManager

+ func NewMultipleStateTypesManager(stateManagers map[definitions.StateType]definitions.StateManager) definitions.StateManager

+ func NewStateManagerFactory(zkClient *zk.Conn, localStatePath string, zookeeperPath string) definitions.StateManagerFactory

+ type MultipleStateTypesManager struct

+ func (m *MultipleStateTypesManager) Close() error

+ func (m *MultipleStateTypesManager) GetState(stateType definitions.StateType) (map[string]any, error)

+ func (m *MultipleStateTypesManager) GetStateManagers() map[definitions.StateType]definitions.StateManager

+ func (m *MultipleStateTypesManager) Reset() error

+ func (m *MultipleStateTypesManager) SetState(stateType definitions.StateType, state map[string]any) error

+ func (m *MultipleStateTypesManager) WatchState(state definitions.StateType, callback func()) error