orchestration

Documentation

Index

• func GetApplicationHealth() *models.ApplicationHealth
• func MapPolicyResultToEvent(originalEvent *models.SignalEvent, result *policy.PolicyResult) *models.SignalEvent
• func MapTransformedToSignalEvent(originalEvent *models.SignalEvent, data interface{}) *models.SignalEvent
• func MeasurePolicyAdherence(eventHub messaging.EventHub, event *models.SignalEvent) error
• func ProcessSignal(eventHub messaging.EventHub, signal *models.SignalMessage) error
• func SavePolicyResult(blobService data.BlobService, dataRepository data.Repository, ...) error
• func SaveSignal(blobService data.BlobService, event *models.SignalEvent) error
• func SaveStandardizedModel(blobService data.BlobService, dataRepository data.Repository, ...) error
• func SendSignal(messageHub messaging.MessageHub, toSend *models.SignalMessage) error
• func TransformSignal(eventHub messaging.EventHub, event *models.SignalEvent) error

Functions

func GetApplicationHealth

func GetApplicationHealth() *models.ApplicationHealth

func MapPolicyResultToEvent

func MapPolicyResultToEvent(originalEvent *models.SignalEvent, result *policy.PolicyResult) *models.SignalEvent

func MapTransformedToSignalEvent

func MapTransformedToSignalEvent(originalEvent *models.SignalEvent, data interface{}) *models.SignalEvent

func MeasurePolicyAdherence

func MeasurePolicyAdherence(eventHub messaging.EventHub, event *models.SignalEvent) error

func ProcessSignal

func ProcessSignal(eventHub messaging.EventHub, signal *models.SignalMessage) error

func SavePolicyResult

func SavePolicyResult(blobService data.BlobService, dataRepository data.Repository, event *models.SignalEvent) error

func SaveSignal

func SaveSignal(blobService data.BlobService, event *models.SignalEvent) error

func SaveStandardizedModel

func SaveStandardizedModel(blobService data.BlobService, dataRepository data.Repository, event *models.SignalEvent) error

func SendSignal

func SendSignal(messageHub messaging.MessageHub, toSend *models.SignalMessage) error

func TransformSignal

func TransformSignal(eventHub messaging.EventHub, event *models.SignalEvent) error