resource

Documentation

Index

• Variables
• type Action
  • func NewAction(callback func(storage *storage.Storage, events *event.Events) bool) *Action
  • func (action *Action) Read() (any, error)
  • func (action *Action) Start(name string, storage *storage.Storage, events *event.Events)
  • func (action *Action) Stop()
  • func (action *Action) Write(value any) error
• type Computed
  • func NewComputed[T storage.Supported](callback func(name string, storage *storage.Storage) T, dependencies []string) *Computed[T]
  • func (computed *Computed[T]) Read() (any, error)
  • func (computed *Computed[T]) Start(name string, storage *storage.Storage, events *event.Events)
  • func (computed *Computed[T]) Stop()
• type Constant
  • func NewConstant[T storage.Supported](value T) *Constant[T]
  • func (static *Constant[T]) Read() (any, error)
  • func (static *Constant[T]) Start(name string, storage *storage.Storage, events *event.Events)
  • func (static *Constant[T]) Stop()
• type Increment
  • func NewIncrement[T storage.SupportedNumeric](initial T, step T, interval time.Duration) *Increment[T]
  • func (increment *Increment[T]) Read() (any, error)
  • func (increment *Increment[T]) Start(name string, storage *storage.Storage, events *event.Events)
  • func (increment *Increment[T]) Stop()
• type LinearFeedback
  • func NewLinearFeedback[T storage.SupportedNumeric](step T, stepInterval time.Duration, setpoint string) *LinearFeedback[T]
  • func (feedback *LinearFeedback[T]) Read() (any, error)
  • func (feedback *LinearFeedback[T]) Start(name string, storage *storage.Storage, events *event.Events)
  • func (feedback *LinearFeedback[T]) Stop()
• type Random
  • func NewRandom[T storage.Supported](min T, max T, interval time.Duration) *Random[T]
  • func (random *Random[T]) Read() (any, error)
  • func (random *Random[T]) Start(name string, storage *storage.Storage, events *event.Events)
  • func (random *Random[T]) Stop()
• type SineWave
  • func NewSineWave(frequency float64, amplitude float64, offset float64, interval time.Duration) *SineWave
  • func (sine *SineWave) Read() (any, error)
  • func (sine *SineWave) Start(name string, storage *storage.Storage, events *event.Events)
  • func (sine *SineWave) Stop()
• type Static
  • func NewStatic[T storage.Supported](value T) *Static[T]
  • func (static *Static[T]) Read() (any, error)
  • func (static *Static[T]) Write(value any) error

Variables

var ErrMissmatchedTypes = errors.New("missatched types")

var (
	ErrNotNumeric = errors.New("setpoint type must be int32 or float32")
)

Types

type Action

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

func NewAction

func NewAction(callback func(storage *storage.Storage, events *event.Events) bool) *Action

func (*Action) Read

func (action *Action) Read() (any, error)

func (*Action) Start

func (action *Action) Start(name string, storage *storage.Storage, events *event.Events)

func (*Action) Stop

func (action *Action) Stop()

func (*Action) Write

func (action *Action) Write(value any) error

type Computed

type Computed[T storage.Supported] struct {
	// contains filtered or unexported fields
}

func NewComputed

func NewComputed[T storage.Supported](callback func(name string, storage *storage.Storage) T, dependencies []string) *Computed[T]

func (*Computed[T]) Read

func (computed *Computed[T]) Read() (any, error)

func (*Computed[T]) Start

func (computed *Computed[T]) Start(name string, storage *storage.Storage, events *event.Events)

func (*Computed[T]) Stop

func (computed *Computed[T]) Stop()

type Constant

type Constant[T storage.Supported] struct {
	// contains filtered or unexported fields
}

func NewConstant

func NewConstant[T storage.Supported](value T) *Constant[T]

func (*Constant[T]) Read

func (static *Constant[T]) Read() (any, error)

func (*Constant[T]) Start

func (static *Constant[T]) Start(name string, storage *storage.Storage, events *event.Events)

func (*Constant[T]) Stop

func (static *Constant[T]) Stop()

type Increment

type Increment[T storage.SupportedNumeric] struct {
	// contains filtered or unexported fields
}

func NewIncrement

func NewIncrement[T storage.SupportedNumeric](initial T, step T, interval time.Duration) *Increment[T]

func (*Increment[T]) Read

func (increment *Increment[T]) Read() (any, error)

func (*Increment[T]) Start

func (increment *Increment[T]) Start(name string, storage *storage.Storage, events *event.Events)

func (*Increment[T]) Stop

func (increment *Increment[T]) Stop()

type LinearFeedback

type LinearFeedback[T storage.SupportedNumeric] struct {
	// contains filtered or unexported fields
}

func NewLinearFeedback

func NewLinearFeedback[T storage.SupportedNumeric](step T, stepInterval time.Duration, setpoint string) *LinearFeedback[T]

func (*LinearFeedback[T]) Read

func (feedback *LinearFeedback[T]) Read() (any, error)

func (*LinearFeedback[T]) Start

func (feedback *LinearFeedback[T]) Start(name string, storage *storage.Storage, events *event.Events)

func (*LinearFeedback[T]) Stop

func (feedback *LinearFeedback[T]) Stop()

type Random

type Random[T storage.Supported] struct {
	// contains filtered or unexported fields
}

func NewRandom

func NewRandom[T storage.Supported](min T, max T, interval time.Duration) *Random[T]

func (*Random[T]) Read

func (random *Random[T]) Read() (any, error)

func (*Random[T]) Start

func (random *Random[T]) Start(name string, storage *storage.Storage, events *event.Events)

func (*Random[T]) Stop

func (random *Random[T]) Stop()

type SineWave

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

func NewSineWave

func NewSineWave(frequency float64, amplitude float64, offset float64, interval time.Duration) *SineWave

func (*SineWave) Read

func (sine *SineWave) Read() (any, error)

func (*SineWave) Start

func (sine *SineWave) Start(name string, storage *storage.Storage, events *event.Events)

func (*SineWave) Stop

func (sine *SineWave) Stop()

type Static

type Static[T storage.Supported] struct {
	*Constant[T]
	// contains filtered or unexported fields
}

func NewStatic

func NewStatic[T storage.Supported](value T) *Static[T]

func (*Static[T]) Read

func (static *Static[T]) Read() (any, error)

func (*Static[T]) Write

func (static *Static[T]) Write(value any) error