service

Documentation

Index

• type AnnotationMapperService
  • func NewAnnotationMapperService(whitelist *regexp.Regexp, messageProducer kafkaProducer, log *logger.UPPLogger) *AnnotationMapperService
  • func (mapper *AnnotationMapperService) HandleMessage(msg kafka.FTMessage)
• type MappedAnnotations
• type PacMetadataAnnotation
• type PacMetadataPublishEvent

Types

type AnnotationMapperService

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

func NewAnnotationMapperService

func NewAnnotationMapperService(whitelist *regexp.Regexp, messageProducer kafkaProducer, log *logger.UPPLogger) *AnnotationMapperService

func (*AnnotationMapperService) HandleMessage

func (mapper *AnnotationMapperService) HandleMessage(msg kafka.FTMessage)

type MappedAnnotations

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

MappedAnnotations are submitted to the writer topic

type PacMetadataAnnotation

type PacMetadataAnnotation struct {
	Predicate string `json:"predicate"`
	ConceptId string `json:"id"`
}

type PacMetadataPublishEvent

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

MetadataPublishEvent models the events we process from the queue