handlers

Documentation

Overview

Package handlers contains the message handlers for entities.

Index

• func NewAddOriginatingEntityHandler(evt interfaces.Publisher, store db.Store, ...) interfaces.Consumer
• func NewGetEntityAndDeleteHandler(evt interfaces.Publisher, store db.Store, ...) interfaces.Consumer
• func NewRefreshByIDAndEvaluateHandler(evt interfaces.Publisher, store db.Store, ...) interfaces.Consumer
• func NewRefreshEntityAndEvaluateHandler(evt interfaces.Publisher, store db.Store, ...) interfaces.Consumer
• func NewRemoveOriginatingEntityHandler(evt interfaces.Publisher, store db.Store, ...) interfaces.Consumer

Functions

func NewAddOriginatingEntityHandler

func NewAddOriginatingEntityHandler(
	evt interfaces.Publisher,
	store db.Store,
	propSvc propertyService.PropertiesService,
	provMgr manager.ProviderManager,
	handlerMiddleware ...watermill.HandlerMiddleware,
) interfaces.Consumer

NewAddOriginatingEntityHandler creates a new handler that adds an originating entity.

func NewGetEntityAndDeleteHandler

func NewGetEntityAndDeleteHandler(
	evt interfaces.Publisher,
	store db.Store,
	propSvc propertyService.PropertiesService,
	handlerMiddleware ...watermill.HandlerMiddleware,
) interfaces.Consumer

NewGetEntityAndDeleteHandler creates a new handler that gets an entity and deletes it.

func NewRefreshByIDAndEvaluateHandler

func NewRefreshByIDAndEvaluateHandler(
	evt interfaces.Publisher,
	store db.Store,
	propSvc propertyService.PropertiesService,
	provMgr manager.ProviderManager,
	handlerMiddleware ...watermill.HandlerMiddleware,
) interfaces.Consumer

NewRefreshByIDAndEvaluateHandler creates a new handler that refreshes an entity and evaluates it.

func NewRefreshEntityAndEvaluateHandler

func NewRefreshEntityAndEvaluateHandler(
	evt interfaces.Publisher,
	store db.Store,
	propSvc propertyService.PropertiesService,
	provMgr manager.ProviderManager,
	handlerMiddleware ...watermill.HandlerMiddleware,
) interfaces.Consumer

NewRefreshEntityAndEvaluateHandler creates a new handler that refreshes an entity and evaluates it.

func NewRemoveOriginatingEntityHandler

func NewRemoveOriginatingEntityHandler(
	evt interfaces.Publisher,
	store db.Store,
	propSvc propertyService.PropertiesService,
	provMgr manager.ProviderManager,
	handlerMiddleware ...watermill.HandlerMiddleware,
) interfaces.Consumer

NewRemoveOriginatingEntityHandler creates a new handler that removes an originating entity.