marshaller

Documentation

Index

• type DeviceRepo
• type Marshaller
  • func New(ctx context.Context, wg *sync.WaitGroup, config configuration.Config, ...) (result *Marshaller, err error)
  • func (this *Marshaller) Unmarshal(desc model.EventMessageDesc) (value interface{}, err error)

Types

type DeviceRepo

type DeviceRepo interface {
	GetCharacteristic(id string) (characteristic models.Characteristic, err error)
	GetConcept(id string) (concept models.Concept, err error)
	GetConceptIdOfFunction(id string) string
	GetAspectNode(id string) (models.AspectNode, error)
}

type Marshaller

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

func New

func New(ctx context.Context, wg *sync.WaitGroup, config configuration.Config, deviceRepo DeviceRepo) (result *Marshaller, err error)

func (*Marshaller) Unmarshal

func (this *Marshaller) Unmarshal(desc model.EventMessageDesc) (value interface{}, err error)