handler

Documentation

Index

• Constants
• 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

Constants

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

const DefaultType = "dataset_landing_page"

Types

type ContentPublished

type ContentPublished struct {
	Cfg        *config.Config
	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