event

type ContentPublished struct {
	URI          string `avro:"uri"`
	DataType     string `avro:"data_type"`
	CollectionID string `avro:"collection_id"`
	JobID        string `avro:"job_id"`
	SearchIndex  string `avro:"search_index"`
	TraceID      string `avro:"trace_id"`
}

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

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