AnalyticsReactiveProcessingUpdate.fromReader constructor

AnalyticsReactiveProcessingUpdate.fromReader(TeleportObjectReader reader)

Implementation

factory AnalyticsReactiveProcessingUpdate.fromReader(TeleportObjectReader reader) {
    final instance = AnalyticsReactiveProcessingUpdate();
    TeleportField? field;
    while ((field = reader.next()) != null) {
        if (field!.isNull) continue;
        switch (field.fieldId) {
            case fieldIdProcessingId: {
                instance.processingId = field.asString();
                break;
            }
            case fieldIdStartedAt: {
                instance.startedAt = field.asString();
                break;
            }
            case fieldIdElapsedSeconds: {
                instance.elapsedSeconds = field.asFloat32();
                break;
            }
            case fieldIdInputItemCount: {
                instance.inputItemCount = field.asInt32();
                break;
            }
            case fieldIdInputItemCacheHits: {
                instance.inputItemCacheHits = field.asInt32();
                break;
            }
            case fieldIdInputItemCacheMiss: {
                instance.inputItemCacheMiss = field.asInt32();
                break;
            }
            case fieldIdProcessedItemCount: {
                instance.processedItemCount = field.asInt32();
                break;
            }
            case fieldIdProcessedItemCacheHits: {
                instance.processedItemCacheHits = field.asInt32();
                break;
            }
            case fieldIdProcessedItemCacheMiss: {
                instance.processedItemCacheMiss = field.asInt32();
                break;
            }
            case fieldIdOutputItemCount: {
                instance.outputItemCount = field.asInt32();
                break;
            }
            case fieldIdOutputItemCacheHits: {
                instance.outputItemCacheHits = field.asInt32();
                break;
            }
            case fieldIdOutputItemCacheMiss: {
                instance.outputItemCacheMiss = field.asInt32();
                break;
            }
            case fieldIdInvalidItemCount: {
                instance.invalidItemCount = field.asInt32();
                break;
            }
            case fieldIdDuplicateItemCount: {
                instance.duplicateItemCount = field.asInt32();
                break;
            }
            case fieldIdProcessRetryCount: {
                instance.processRetryCount = field.asInt32();
                break;
            }
            case fieldIdProcessFailureCount: {
                instance.processFailureCount = field.asInt32();
                break;
            }
            case fieldIdWarningLogCount: {
                instance.warningLogCount = field.asInt32();
                break;
            }
            case fieldIdErrorLogCount: {
                instance.errorLogCount = field.asInt32();
                break;
            }
            case fieldIdHasCompleted: {
                instance.hasCompleted = field.asBool();
                break;
            }
            case fieldIdHasFaulted: {
                instance.hasFaulted = field.asBool();
                break;
            }
            case fieldIdWasCancelled: {
                instance.wasCancelled = field.asBool();
                break;
            }
            case fieldIdUsages: {
                final dr = field.asDictionary();
                final map = <String, double>{};
                TeleportDictEntry? en;
                while ((en = dr.next()) != null) {
                    final entry = en!;
                    map[entry.keyAsString()] = entry.valueAsField().asFloat32();
                }
                instance.usages = map;
                break;
            }
        }
    }
    return instance;
}