eventrepo

type Environment[Payload any] interface {
	IsServiceMessage(message model.ConsumerMessage) bool
	ParseServiceMessage(message model.ConsumerMessage) (deviceId string, serviceId string, payload Payload, err error)
	GetServiceEventDescriptions(deviceId string, serviceId string) ([]model.EventDesc, error)

	IsImportMessage(message model.ConsumerMessage) bool
	ParseImportMessage(message model.ConsumerMessage) (importId string, payload Payload, err error)
	GetImportEventDescriptions(importId string) ([]model.EventDesc, error)

	SerializeMessage(payload Payload, service models.Service) (result model.SerializedMessage, err error)
}

type EventRepo[Payload any] struct {
	// contains filtered or unexported fields
}

type Interface interface {
	Get(message model.ConsumerMessage) (eventDesc []model.EventMessageDesc, err error)
}

type Notifier interface {
	NotifyError(desc model.EventMessageDesc, err error) error
}