in azkustoingest/status.go [170:202]
func (r *statusRecord) FromMap(data map[string]interface{}) {
strStatus := safeGetString(data, "Status")
if len(strStatus) > 0 {
r.Status = StatusCode(strStatus)
}
strStatus = safeGetString(data, "FailureStatus")
if len(strStatus) > 0 {
r.FailureStatus = FailureStatusCode(strStatus)
}
r.IngestionSourcePath = properties.RemoveQueryParamsFromUrl(safeGetString(data, "IngestionSourcePath"))
r.Database = safeGetString(data, "Database")
r.Table = safeGetString(data, "Table")
r.ErrorCode = safeGetString(data, "ErrorCode")
r.Details = safeGetString(data, "Details")
r.IngestionSourceID = getGoogleUUIDFromInterface(data, "IngestionSourceId")
r.OperationID = getGoogleUUIDFromInterface(data, "OperationId")
r.ActivityID = getGoogleUUIDFromInterface(data, "ActivityId")
if data["UpdatedOn"] != nil {
if t, err := getTimeFromInterface(data["UpdatedOn"]); err == nil {
r.UpdatedOn = t
}
}
if data["OriginatesFromUpdatePolicy"] != nil {
if b, ok := data["OriginatesFromUpdatePolicy"].(bool); ok {
r.OriginatesFromUpdatePolicy = b
}
}
}