event

Documentation

Index

• func Consume(ctx context.Context, messageConsumer kafka.IConsumerGroup, handler Handler, ...)
• type Handler
• type Marshaller
• type SearchDataImportProducer
  • func (p SearchDataImportProducer) SearchDataImport(ctx context.Context, event models.SearchDataImport) error

Functions

func Consume

func Consume(ctx context.Context, messageConsumer kafka.IConsumerGroup, handler Handler, cfg *config.Config)

Consume converts messages to event instances, and pass the event to the provided handler.

Types

type Handler

type Handler interface {
	Handle(ctx context.Context, contentPublished *models.ContentPublished, cfg config.Config) error
}

Handler represents a handler for processing a single event.

type Marshaller

type Marshaller interface {
	Marshal(s interface{}) ([]byte, error)
}

Marshaller defines a type for marshalling the requested object into the required format.

type SearchDataImportProducer

type SearchDataImportProducer struct {
	Marshaller Marshaller
	Producer   kafka.IProducer
}

SearchDataImportProducer produces kafka messages for instances which have been successfully processed.

func (SearchDataImportProducer) SearchDataImport

func (p SearchDataImportProducer) SearchDataImport(ctx context.Context, event models.SearchDataImport) error

SearchDataImport produce a kafka message for an instance which has been successfully processed.