context

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

type EnrichmentCenter interface {
	// Handle context creation and update on received event.
	// param source: the original event as byte slice.
	// param ef: which fields are included/excluded from extra infos enrichment.
	//     see EnrichFields doc for more infos.
	Handle(ctx context.Context, event types.Event, ef EnrichFields) (*types.Entity, UpdatedEntityServices, error)

	// HandleEntityServiceUpdate updates context graph for entity service.
	HandleEntityServiceUpdate(ctx context.Context, serviceID string) (*UpdatedEntityServices, error)

	// Get finds entity for event.
	Get(event types.Event) (*types.Entity, error)

	// UpdateEntityInfos updates an entity.
	// It also recomputes the link between the entity and the services, since
	// those may be changed by the modifications of the entity, and returns the
	// modified entity.
	UpdateEntityInfos(ctx context.Context, entity *types.Entity) (UpdatedEntityServices, error)

	// UpdateImpactedServices updates the impacted_services field in connector documents
	UpdateImpactedServices(ctx context.Context) error

	// LoadServices loads services from storage to cache.
	LoadServices(ctx context.Context) error

	// ReloadService loads service from storage to cache.
	ReloadService(ctx context.Context, serviceID string) error
}

type UpdatedEntityServices struct {
	// AddedTo contains ids of entity services to which entity has been
	// added as dependency.
	AddedTo []string
	// RemovedFrom contains ids of entity services from which entity has been
	// removed as dependency.
	RemovedFrom []string
	// UpdatedComponentInfosResources contains ids of entities which component infos
	// were updated on component event.
	UpdatedComponentInfosResources []string
}