Crosswork Data Gateway generates output in protobuf format. A sample output is shown below:

Note	Crosswork Data Gateway Collected Data Output Sequence Number resets if the Crosswork Data Gateway VM is rebooted or the collector is restarted.

Data Gateway Output protobuf message:

/*
 * Copyright (c) 2018 Cisco Systems, Inc.
 * All rights reserved.
 */
syntax = "proto3";

package output;
import "google/protobuf/timestamp.proto";

option java_package = "com.cisco.dg.protobuf.output";
option java_outer_classname = "DataOutput";

/*
    Supported collector types
*/
enum CollectorType {
    INVALID_COLLECTOR_TYPE = 0;
    CLI = 1;
    SNMP = 2;
    MDT = 3;
    NETCONF = 4;
}

/*
    CollectionSensorHeader contains all necessary fields that client app would need to
    relate to the data that was requested, via a collection job. It will also help the client app
    to determine if the data is missing or if any cadences not met.
*/
message CollectionSensorHeader {
    string collection_job_id = 1; // collection job id via collection job request.
    string source_name = 2; // Source name via collection job request.
    string device_host = 3; // Host or ip address from which data is collected.
    string device_name = 4; // device name or tag that was given via collection job request.
    string sensor_config_id = 5; // sensor config id that identifies each sensorConfig via collection job request.
    CollectorType collector_type = 6; // Type(CLI/SNMP/MDT etc.) of the collector used for data collection.
    string sensor_path = 7; // sensor path for which the data is collected.
}

message CollectionDetailHeader {
    google.protobuf.Timestamp collection_start_time = 1;    // time when the data was requested from device.
    google.protobuf.Timestamp collection_end_time = 2;      // time when the data was received from device.
    // Incrementing number per cadence for this device and sensor path.
    // Starts at 0. Incremented before requesting data.
    int64 sequence_number = 3;
}

/*
    DataEnvelop is how the data is received by client app. Dispatcher would construct this message and
    stream to client app transport set in the collection job request.
*/
message DataEnvelop {
    CollectionSensorHeader sensor_header = 1; // Header to identify collection job and sensor path.
    CollectionDetailHeader detail_header = 2; // collection stats to identify.
    CollectionOutput output = 3; // collected data or error.
}

/*
    CollectionOutput holds Data and Error details.
*/
message CollectionOutput {
    oneof type {
        CollectionData data = 1; // Data would have value in case of success, would be null in case of error.
        CollectionError error = 2; // Error string in case of collection error, would be null in case of success.
    }
}

/*
    Data holds the collected data from the device .
*/
message CollectionData {
    // data bytes is serialized data collected in different formats by each collector. Based on "CollectorType" in
    // CollectionSensorHeader the serialized bytes format would vary. Following format can be expected per type
    //
    // CLI: UTF-8 string containing the console output text of a CLI. In case of custom XDE packages the format would
    // depend on output format of a custom package. (ex. UTF-8 string which contains xml data etc.)
    //
    // MDT: serialized Telemetry proto. (can contain GPB or GPB-KV data). XR devices expose this telemetry.proto.
    //
    // SNMP: serialized SnmpData proto. (For OID, Table and MIB walk operations)
    // In case of custom XDE packages the format would depend on output format of a custom package.
    // (ex. UTF-8 string which contains xml data etc.)

    bytes data = 1; // Data collected from device.
}
/*
    Snmp data collected for OID, Table and Mib walk operation will have the following format.
*/

message SnmpData {
    repeated OidRecord oid_records = 1;    // list of OID records.
}

message OidRecord {
    string oid = 1;                    // SNMP object identifier (OID), e.g. 1.3.6.1.2.1.2.2.1.4.2
    string symbol = 2;                 // symbol for OID, textual / user friendly name representing OID, e.g. ifMtu
    string value = 3;                  // corresponding value from device, e.g. 1500
}

/*
    Error holds the details of the error occurred during processing.
*/
message CollectionError {
    string error_message = 1; // Error message to describe the reason for collection error.
    string detail_error = 2; // Detailed error message to analyse the failure.
    string error_code = 3; // Error code to determine the type of error.
}

/*
    This RPC service exposed to produce DataEnvelop.
    gRPC server has to implement this service to receive stream data.
    gRPC client has to use this service to send the stream data
*/
service OutputService {
    rpc streamData (stream DataEnvelop) returns (stream DataEnvelop) {
    };
}