processor

type Annotation struct {
	Thing `json:"thing,omitempty"`
}

type Annotations struct {
	Annotations []Annotation `json:"annotations"`
	UUID        string       `json:"uuid"`
}

type CombinedModel struct {
	UUID     string       `json:"uuid"`
	Content  ContentModel `json:"content"`
	Metadata []Annotation `json:"metadata"`

	ContentURI    string `json:"contentUri"`
	LastModified  string `json:"lastModified"`
	MarkedDeleted string `json:"markedDeleted"`
}

type ContentModel map[string]interface{}

type DataCombiner struct {
	ContentRetriever  contentRetrieverI
	MetadataRetriever metadataRetrieverI
}

type DataCombinerI interface {
	GetCombinedModelForContent(content ContentModel) (CombinedModel, error)
	GetCombinedModelForAnnotations(metadata Annotations) (CombinedModel, error)
	GetCombinedModel(uuid string) (CombinedModel, error)
}

type Forwarder struct {
	MsgProducer           producer.MessageProducer
	SupportedContentTypes []string
}

type Identifier struct {
	Authority       string `json:"authority"`
	IdentifierValue string `json:"identifierValue"`
}

type KafkaQConsumer struct {
	Consumer consumer.MessageConsumer
	// contains filtered or unexported fields
}

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

type MessageContent struct {
	ContentURI   string       `json:"contentUri"`
	ContentModel ContentModel `json:"payload"`
	LastModified string       `json:"lastModified"`
}

type MsgProcessor struct {
	DataCombiner DataCombinerI
	Forwarder    Forwarder
	// contains filtered or unexported fields
}

type MsgProcessorConfig struct {
	SupportedContentURIs []string
	SupportedHeaders     []string
	ContentTopic         string
	MetadataTopic        string
}

type QConsumer interface {
	ProcessMsg(m consumer.Message)
}

type RequestProcessor struct {
	DataCombiner DataCombinerI
	Forwarder    Forwarder
}

type RequestProcessorI interface {
	ForceMessagePublish(uuid string, tid string) error
}

type Thing struct {
	ID        string   `json:"id,omitempty"`
	PrefLabel string   `json:"prefLabel,omitempty"`
	Types     []string `json:"types,omitempty"`
	Predicate string   `json:"predicate,omitempty"`
	ApiUrl    string   `json:"apiUrl,omitempty"`
}