event

package

v0.2.0 Latest Latest Go to latest Published: Oct 20, 2021 License: MIT Imports: 7 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

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.

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

Handler represents a handler for processing a single event.

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

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

type SearchDataImportProducer struct {
	Marshaller Marshaller
	Producer   kafka.IProducer
}

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

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

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

Path	Synopsis
mock