handler

Documentation

Index

• Constants
• type ContentPublishedHandler
  • func (h *ContentPublishedHandler) Handle(ctx context.Context, cpEvent *models.ContentPublished, cfg config.Config) error

Constants

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

Types

type ContentPublishedHandler

type ContentPublishedHandler struct {
	ZebedeeCli clients.ZebedeeClient
	DatasetCli clients.DatasetClient
	Producer   event.SearchDataImportProducer
}

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

func (*ContentPublishedHandler) Handle

func (h *ContentPublishedHandler) Handle(ctx context.Context, cpEvent *models.ContentPublished, cfg config.Config) error

Handle takes a single event.