Documentation
¶
Index ¶
- Variables
- func ComFactory(ctx context.Context, config configuration.Config, ...) (producer interfaces.Producer, err error)
- func DefaultIdProviderImpl() string
- func IotFactory(ctx context.Context, config configuration.Config) (result interfaces.Iot, err error)
- func MarshallerFactory(ctx context.Context, config configuration.Config, iot interfaces.Iot) (interfaces.Marshaller, error)
- func TimescaleFactory(ctx context.Context, config configuration.Config) (interfaces.Timescale, error)
- type ComImpl
- type Command
- type Correlation
- type CorrelationImpl
- type Request
- type Response
- type Timescale
Constants ¶
This section is empty.
Variables ¶
View Source
var DefaultCorrelation = &CorrelationImpl{}
View Source
var IdProvider = DefaultIdProviderImpl
Functions ¶
func ComFactory ¶
func ComFactory(ctx context.Context, config configuration.Config, responseListener func(msg messages.ProtocolMsg) error, errorListener func(msg messages.ProtocolMsg) error) (producer interfaces.Producer, err error)
func DefaultIdProviderImpl ¶
func DefaultIdProviderImpl() string
func IotFactory ¶
func IotFactory(ctx context.Context, config configuration.Config) (result interfaces.Iot, err error)
func MarshallerFactory ¶
func MarshallerFactory(ctx context.Context, config configuration.Config, iot interfaces.Iot) (interfaces.Marshaller, error)
func TimescaleFactory ¶
func TimescaleFactory(ctx context.Context, config configuration.Config) (interfaces.Timescale, error)
Types ¶
type ComImpl ¶
type ComImpl struct {
// contains filtered or unexported fields
}
func (*ComImpl) SendCommand ¶
func (this *ComImpl) SendCommand(msg messages.ProtocolMsg) (err error)
type Correlation ¶
type Correlation interface {
Get(id string) (messages.ProtocolMsg, error)
Set(id string, element messages.ProtocolMsg) error
}
type CorrelationImpl ¶
type CorrelationImpl struct {
// contains filtered or unexported fields
}
func (*CorrelationImpl) Get ¶
func (this *CorrelationImpl) Get(id string) (messages.ProtocolMsg, error)
func (*CorrelationImpl) Set ¶
func (this *CorrelationImpl) Set(id string, element messages.ProtocolMsg) error
type Response ¶ added in v1.0.30
type Response struct {
Time *string `json:"time"`
Value interface{} `json:"value"`
}
Click to show internal directories.
Click to hide internal directories.