handler

Documentation

Index

• Constants
• func AddTopicWithParents(ctx context.Context, slug, parentSlug string, topicCache *cache.TopicCache, ...)
• type ContentPublished
  • func (h *ContentPublished) Handle(ctx context.Context, _ int, msg kafka.Message) error
• type Error
  • func NewError(err error, logData map[string]interface{}) *Error
  • func (e *Error) Error() string
  • func (e *Error) LogData() map[string]interface{}
  • func (e *Error) Unwrap() error
• type SearchContentHandler
  • func (h *SearchContentHandler) Handle(ctx context.Context, _ int, msg kafka.Message) error

Constants

const (
	OnsSearchIndex  = "ons"
	ZebedeeDataType = "legacy"
	DatasetDataType = "datasets"
)

const DefaultType = "dataset_landing_page"

const (
	ReleaseDataType = "release"
)

Functions

func AddTopicWithParents

func AddTopicWithParents(ctx context.Context, slug, parentSlug string, topicCache *cache.TopicCache, uniqueTopics map[string]struct{})

AddTopicWithParents adds a topic and its parents to the uniqueTopics map if they don't already exist. It recursively adds parent topics until it reaches the root topic.

Types

type ContentPublished

type ContentPublished struct {
	Cfg        *config.Config
	Cache      cache.List
	ZebedeeCli clients.ZebedeeClient
	DatasetCli clients.DatasetClient
	Producer   kafka.IProducer
}

ContentPublished struct to hold handle for config with zebedee, datasetAPI client and the producer

func (*ContentPublished) Handle

func (h *ContentPublished) Handle(ctx context.Context, _ int, msg kafka.Message) error

Handle takes a single event and triages it according to its data type, which can be 'legacy' (zebedee) or 'datasets' If the type is not correct, the message is ignored with just a log.

type Error

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

Error is the handler package's error type. Is not meant to be compared as a type, but information should be extracted via the interfaces it implements with callback functions. Is not guaranteed to remain exported so shouldn't be treated as such.

func NewError

func NewError(err error, logData map[string]interface{}) *Error

NewError creates a new Error

func (*Error) Error

func (e *Error) Error() string

Error implements the Go standard error interface

func (*Error) LogData

func (e *Error) LogData() map[string]interface{}

LogData implements the DataLogger interface which allows you extract embedded log.Data from an error

func (*Error) Unwrap

func (e *Error) Unwrap() error

type SearchContentHandler

type SearchContentHandler struct {
	Cfg      *config.Config
	Producer kafka.IProducer
}

func (*SearchContentHandler) Handle

func (h *SearchContentHandler) Handle(ctx context.Context, _ int, msg kafka.Message) error

Handle processes the search-content-updated event and generates messages.