Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

dataflow

package

Go to main page

Versions in this module

v3

v3.6.0

Jan 27, 2025

v3.5.1

Jan 18, 2025

v3.5.0

Jan 18, 2025

v3.4.0

Dec 23, 2024

v3.3.1

Dec 8, 2024

v3.3.0

Dec 4, 2024

v3.2.4

Nov 22, 2024

v3.2.3

Jul 6, 2024

v3.2.2

Apr 16, 2024

v3.2.1

Feb 22, 2024

v3.2.0

Jan 7, 2024

Changes in this version

+ type Filterable interface

+ Category func() string

+ Name func() string

+ Writable func() bool

type Register

+ Writable func() bool

type RegisterStruct

+ func (r RegisterStruct) Writable() bool

v3.1.4

Dec 20, 2023

v3.1.3

Dec 19, 2023

Changes in this version

+ var EmptyFilter = func(Value) bool

+ func FilterRegisters[R Register](input []R, filterConf RegisterFilterConf) (output []R)

+ func SinkLog(prefix string, input <-chan Value)

+ func SortRegisterStructs(input []RegisterStruct)

+ type EnumRegisterValue struct

+ func NewEnumRegisterValue(deviceName string, register Register, value int) EnumRegisterValue

+ func (v EnumRegisterValue) EnumIdx() int

+ func (v EnumRegisterValue) Equals(comp Value) bool

+ func (v EnumRegisterValue) GenericValue() interface{}

+ func (v EnumRegisterValue) String() string

+ func (v EnumRegisterValue) Value() string

+ type Fillable interface

+ Fill func(value Value)

+ type NullRegisterValue struct

+ func NewNullRegisterValue(deviceName string, register Register) NullRegisterValue

+ func (v NullRegisterValue) Equals(comp Value) bool

+ func (v NullRegisterValue) GenericValue() interface{}

+ func (v NullRegisterValue) String() string

+ type NumericRegisterValue struct

+ func NewNumericRegisterValue(deviceName string, register Register, value float64) NumericRegisterValue

+ func (v NumericRegisterValue) Equals(comp Value) bool

+ func (v NumericRegisterValue) GenericValue() interface{}

+ func (v NumericRegisterValue) String() string

+ func (v NumericRegisterValue) Value() float64

+ type Register interface

+ Category func() string

+ Commandable func() bool

+ Description func() string

+ Enum func() map[int]string

+ Name func() string

+ RegisterType func() RegisterType

+ Sort func() int

+ Unit func() string

+ type RegisterDb struct

+ func NewRegisterDb() (registerDb *RegisterDb)

+ func (rdb *RegisterDb) Add(registers ...Register)

+ func (rdb *RegisterDb) AddStruct(registerStructs ...RegisterStruct)

+ func (rdb *RegisterDb) GetAll() []RegisterStruct

+ func (rdb *RegisterDb) GetByName(registerName string) (reg RegisterStruct, ok bool)

+ func (rdb *RegisterDb) GetFiltered(filter RegisterFilterFunc) []RegisterStruct

+ func (rdb *RegisterDb) Subscribe(ctx context.Context, filter RegisterFilterFunc) <-chan RegisterStruct

+ type RegisterFilterConf interface

+ DefaultInclude func() bool

+ IncludeCategories func() []string

+ IncludeRegisters func() []string

+ SkipCategories func() []string

+ SkipRegisters func() []string

+ type RegisterFilterFunc func(Register) bool

+ var AllRegisterFilter RegisterFilterFunc = func(Register) bool { ... }

+ func RegisterFilter(registerFilter RegisterFilterConf) RegisterFilterFunc

+ type RegisterStruct struct

+ func NewRegisterStruct(category, name, description string, registerType RegisterType, ...) RegisterStruct

+ func NewRegisterStructByInterface(reg Register) RegisterStruct

+ func (r RegisterStruct) Category() string

+ func (r RegisterStruct) Commandable() bool

+ func (r RegisterStruct) Description() string

+ func (r RegisterStruct) Enum() map[int]string

+ func (r RegisterStruct) Equals(b RegisterStruct) bool

+ func (r RegisterStruct) Name() string

+ func (r RegisterStruct) RegisterType() RegisterType

+ func (r RegisterStruct) Sort() int

+ func (r RegisterStruct) Unit() string

+ type RegisterSubscription struct

+ type RegisterType int

+ const EnumRegister

+ const NumberRegister

+ const TextRegister

+ const UndefinedRegister

+ func RegisterTypeFromString(s string) RegisterType

+ func (rt RegisterType) String() string

+ type RegisterValue struct

+ func (v RegisterValue) DeviceName() string

+ func (v RegisterValue) Register() Register

+ type StateKey struct

+ type TextRegisterValue struct

+ func NewTextRegisterValue(deviceName string, register Register, value string) TextRegisterValue

+ func (v TextRegisterValue) Equals(comp Value) bool

+ func (v TextRegisterValue) GenericValue() interface{}

+ func (v TextRegisterValue) String() string

+ func (v TextRegisterValue) Value() string

+ type Value interface

+ DeviceName func() string

+ Equals func(comp Value) bool

+ GenericValue func() interface{}

+ Register func() Register

+ String func() string

+ type ValueFilterFunc func(Value) bool

+ var AllValueFilter ValueFilterFunc = func(Value) bool { ... }

+ var NonNullValueFilter ValueFilterFunc = func(value Value) bool { ... }

+ func DeviceNameValueFilter(deviceName string) ValueFilterFunc

+ func DeviceNonNullValueFilter(deviceName string) ValueFilterFunc

+ func RegisterValueFilter(registerFilter RegisterFilterConf) ValueFilterFunc

+ type ValueStorage struct

+ func NewValueStorage() (valueStorage *ValueStorage)

+ func (vs *ValueStorage) Fill(value Value)

+ func (vs *ValueStorage) GetState() (result []Value)

+ func (vs *ValueStorage) GetStateFiltered(filter ValueFilterFunc) (result []Value)

+ func (vs *ValueStorage) Shutdown()

+ func (vs *ValueStorage) SubscribeReturnInitial(ctx context.Context, filter ValueFilterFunc) (initial []Value, subscription ValueSubscription)

+ func (vs *ValueStorage) SubscribeSendInitial(ctx context.Context, filter ValueFilterFunc) (subscription ValueSubscription)

+ func (vs *ValueStorage) Wait()

+ type ValueSubscription struct

+ func (s *ValueSubscription) Drain() <-chan Value

Other modules containing this package

github.com/koestler/go-iotdevice