handler

Documentation

Index

• type CompletedProducer
• type InstanceEventHandler
  • func (hdlr *InstanceEventHandler) Handle(ctx context.Context, newInstance event.NewInstance) error

Types

type CompletedProducer

type CompletedProducer interface {
	Completed(ctx context.Context, e event.InstanceCompleted) error
}

CompletedProducer Producer kafka messages for instances that have been successfully processed.

type InstanceEventHandler

type InstanceEventHandler struct {
	Store         store.Storer
	DatasetAPICli *client.DatasetAPI
	Producer      CompletedProducer
}

InstanceEventHandler provides functions for handling DimensionsExtractedEvents.

func (*InstanceEventHandler) Handle

func (hdlr *InstanceEventHandler) Handle(ctx context.Context, newInstance event.NewInstance) error

Handle retrieves the dimensions for specified instanceID from the Import API, creates an MyInstance entity for provided instanceID, creates a Dimension entity for each dimension and a relationship to the MyInstance it belongs to and makes a PUT request to the Import API with the database ID of each Dimension entity.