Initial cleanup push.

Based on agldemo2024 on commit 2a5dc04d801134338150c3f6afc67eaa65599763

Disable device preview.

Disable Lottie animation.

The original commit was b3c493c340fcb4bb0a937692838fc830bec3e9ea
but I am just keeping this change, because the json did not really
needed to change. I think.

Signed-off-by: Lisandro Pérez Meyer <lpmeyer@ics.com>

11 files changed, 2663 insertions, 0 deletions

diff --git a/protos/lib/src/generated/sdv/databroker/v1/broker.pb.dart b/protos/lib/src/generated/sdv/databroker/v1/broker.pb.dart
new file mode 100644
index 0000000..12b0977
--- /dev/null
+++ b/protos/lib/src/generated/sdv/databroker/v1/broker.pb.dart
@@ -0,0 +1,400 @@
+//
+//  Generated code. Do not modify.
+//  source: sdv/databroker/v1/broker.proto
+//
+// @dart = 2.12
+
+// ignore_for_file: annotate_overrides, camel_case_types, comment_references
+// ignore_for_file: constant_identifier_names, library_prefixes
+// ignore_for_file: non_constant_identifier_names, prefer_final_fields
+// ignore_for_file: unnecessary_import, unnecessary_this, unused_import
+
+import 'dart:core' as $core;
+
+import 'package:protobuf/protobuf.dart' as $pb;
+
+import 'types.pb.dart' as $3;
+import 'types.pbenum.dart' as $3;
+
+class GetDatapointsRequest extends $pb.GeneratedMessage {
+  factory GetDatapointsRequest({
+    $core.Iterable<$core.String>? datapoints,
+  }) {
+    final $result = create();
+    if (datapoints != null) {
+      $result.datapoints.addAll(datapoints);
+    }
+    return $result;
+  }
+  GetDatapointsRequest._() : super();
+  factory GetDatapointsRequest.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
+  factory GetDatapointsRequest.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
+
+  static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'GetDatapointsRequest', package: const $pb.PackageName(_omitMessageNames ? '' : 'sdv.databroker.v1'), createEmptyInstance: create)
+    ..pPS(1, _omitFieldNames ? '' : 'datapoints')
+    ..hasRequiredFields = false
+  ;
+
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
+  'Will be removed in next major version')
+  GetDatapointsRequest clone() => GetDatapointsRequest()..mergeFromMessage(this);
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
+  'Will be removed in next major version')
+  GetDatapointsRequest copyWith(void Function(GetDatapointsRequest) updates) => super.copyWith((message) => updates(message as GetDatapointsRequest)) as GetDatapointsRequest;
+
+  $pb.BuilderInfo get info_ => _i;
+
+  @$core.pragma('dart2js:noInline')
+  static GetDatapointsRequest create() => GetDatapointsRequest._();
+  GetDatapointsRequest createEmptyInstance() => create();
+  static $pb.PbList<GetDatapointsRequest> createRepeated() => $pb.PbList<GetDatapointsRequest>();
+  @$core.pragma('dart2js:noInline')
+  static GetDatapointsRequest getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<GetDatapointsRequest>(create);
+  static GetDatapointsRequest? _defaultInstance;
+
+  /// A list of requested data points.
+  @$pb.TagNumber(1)
+  $core.List<$core.String> get datapoints => $_getList(0);
+}
+
+class GetDatapointsReply extends $pb.GeneratedMessage {
+  factory GetDatapointsReply({
+    $core.Map<$core.String, $3.Datapoint>? datapoints,
+  }) {
+    final $result = create();
+    if (datapoints != null) {
+      $result.datapoints.addAll(datapoints);
+    }
+    return $result;
+  }
+  GetDatapointsReply._() : super();
+  factory GetDatapointsReply.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
+  factory GetDatapointsReply.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
+
+  static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'GetDatapointsReply', package: const $pb.PackageName(_omitMessageNames ? '' : 'sdv.databroker.v1'), createEmptyInstance: create)
+    ..m<$core.String, $3.Datapoint>(1, _omitFieldNames ? '' : 'datapoints', entryClassName: 'GetDatapointsReply.DatapointsEntry', keyFieldType: $pb.PbFieldType.OS, valueFieldType: $pb.PbFieldType.OM, valueCreator: $3.Datapoint.create, valueDefaultOrMaker: $3.Datapoint.getDefault, packageName: const $pb.PackageName('sdv.databroker.v1'))
+    ..hasRequiredFields = false
+  ;
+
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
+  'Will be removed in next major version')
+  GetDatapointsReply clone() => GetDatapointsReply()..mergeFromMessage(this);
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
+  'Will be removed in next major version')
+  GetDatapointsReply copyWith(void Function(GetDatapointsReply) updates) => super.copyWith((message) => updates(message as GetDatapointsReply)) as GetDatapointsReply;
+
+  $pb.BuilderInfo get info_ => _i;
+
+  @$core.pragma('dart2js:noInline')
+  static GetDatapointsReply create() => GetDatapointsReply._();
+  GetDatapointsReply createEmptyInstance() => create();
+  static $pb.PbList<GetDatapointsReply> createRepeated() => $pb.PbList<GetDatapointsReply>();
+  @$core.pragma('dart2js:noInline')
+  static GetDatapointsReply getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<GetDatapointsReply>(create);
+  static GetDatapointsReply? _defaultInstance;
+
+  /// Contains the values of the requested data points.
+  /// If a requested data point is not available, the corresponding Datapoint
+  /// will have the respective failure value set.
+  @$pb.TagNumber(1)
+  $core.Map<$core.String, $3.Datapoint> get datapoints => $_getMap(0);
+}
+
+class SetDatapointsRequest extends $pb.GeneratedMessage {
+  factory SetDatapointsRequest({
+    $core.Map<$core.String, $3.Datapoint>? datapoints,
+  }) {
+    final $result = create();
+    if (datapoints != null) {
+      $result.datapoints.addAll(datapoints);
+    }
+    return $result;
+  }
+  SetDatapointsRequest._() : super();
+  factory SetDatapointsRequest.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
+  factory SetDatapointsRequest.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
+
+  static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'SetDatapointsRequest', package: const $pb.PackageName(_omitMessageNames ? '' : 'sdv.databroker.v1'), createEmptyInstance: create)
+    ..m<$core.String, $3.Datapoint>(1, _omitFieldNames ? '' : 'datapoints', entryClassName: 'SetDatapointsRequest.DatapointsEntry', keyFieldType: $pb.PbFieldType.OS, valueFieldType: $pb.PbFieldType.OM, valueCreator: $3.Datapoint.create, valueDefaultOrMaker: $3.Datapoint.getDefault, packageName: const $pb.PackageName('sdv.databroker.v1'))
+    ..hasRequiredFields = false
+  ;
+
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
+  'Will be removed in next major version')
+  SetDatapointsRequest clone() => SetDatapointsRequest()..mergeFromMessage(this);
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
+  'Will be removed in next major version')
+  SetDatapointsRequest copyWith(void Function(SetDatapointsRequest) updates) => super.copyWith((message) => updates(message as SetDatapointsRequest)) as SetDatapointsRequest;
+
+  $pb.BuilderInfo get info_ => _i;
+
+  @$core.pragma('dart2js:noInline')
+  static SetDatapointsRequest create() => SetDatapointsRequest._();
+  SetDatapointsRequest createEmptyInstance() => create();
+  static $pb.PbList<SetDatapointsRequest> createRepeated() => $pb.PbList<SetDatapointsRequest>();
+  @$core.pragma('dart2js:noInline')
+  static SetDatapointsRequest getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<SetDatapointsRequest>(create);
+  static SetDatapointsRequest? _defaultInstance;
+
+  /// A map of data points to set
+  @$pb.TagNumber(1)
+  $core.Map<$core.String, $3.Datapoint> get datapoints => $_getMap(0);
+}
+
+class SetDatapointsReply extends $pb.GeneratedMessage {
+  factory SetDatapointsReply({
+    $core.Map<$core.String, $3.DatapointError>? errors,
+  }) {
+    final $result = create();
+    if (errors != null) {
+      $result.errors.addAll(errors);
+    }
+    return $result;
+  }
+  SetDatapointsReply._() : super();
+  factory SetDatapointsReply.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
+  factory SetDatapointsReply.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
+
+  static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'SetDatapointsReply', package: const $pb.PackageName(_omitMessageNames ? '' : 'sdv.databroker.v1'), createEmptyInstance: create)
+    ..m<$core.String, $3.DatapointError>(1, _omitFieldNames ? '' : 'errors', entryClassName: 'SetDatapointsReply.ErrorsEntry', keyFieldType: $pb.PbFieldType.OS, valueFieldType: $pb.PbFieldType.OE, valueOf: $3.DatapointError.valueOf, enumValues: $3.DatapointError.values, valueDefaultOrMaker: $3.DatapointError.UNKNOWN_DATAPOINT, defaultEnumValue: $3.DatapointError.UNKNOWN_DATAPOINT, packageName: const $pb.PackageName('sdv.databroker.v1'))
+    ..hasRequiredFields = false
+  ;
+
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
+  'Will be removed in next major version')
+  SetDatapointsReply clone() => SetDatapointsReply()..mergeFromMessage(this);
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
+  'Will be removed in next major version')
+  SetDatapointsReply copyWith(void Function(SetDatapointsReply) updates) => super.copyWith((message) => updates(message as SetDatapointsReply)) as SetDatapointsReply;
+
+  $pb.BuilderInfo get info_ => _i;
+
+  @$core.pragma('dart2js:noInline')
+  static SetDatapointsReply create() => SetDatapointsReply._();
+  SetDatapointsReply createEmptyInstance() => create();
+  static $pb.PbList<SetDatapointsReply> createRepeated() => $pb.PbList<SetDatapointsReply>();
+  @$core.pragma('dart2js:noInline')
+  static SetDatapointsReply getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<SetDatapointsReply>(create);
+  static SetDatapointsReply? _defaultInstance;
+
+  /// A map of errors (if any)
+  @$pb.TagNumber(1)
+  $core.Map<$core.String, $3.DatapointError> get errors => $_getMap(0);
+}
+
+class SubscribeRequest extends $pb.GeneratedMessage {
+  factory SubscribeRequest({
+    $core.String? query,
+  }) {
+    final $result = create();
+    if (query != null) {
+      $result.query = query;
+    }
+    return $result;
+  }
+  SubscribeRequest._() : super();
+  factory SubscribeRequest.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
+  factory SubscribeRequest.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
+
+  static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'SubscribeRequest', package: const $pb.PackageName(_omitMessageNames ? '' : 'sdv.databroker.v1'), createEmptyInstance: create)
+    ..aOS(2, _omitFieldNames ? '' : 'query')
+    ..hasRequiredFields = false
+  ;
+
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
+  'Will be removed in next major version')
+  SubscribeRequest clone() => SubscribeRequest()..mergeFromMessage(this);
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
+  'Will be removed in next major version')
+  SubscribeRequest copyWith(void Function(SubscribeRequest) updates) => super.copyWith((message) => updates(message as SubscribeRequest)) as SubscribeRequest;
+
+  $pb.BuilderInfo get info_ => _i;
+
+  @$core.pragma('dart2js:noInline')
+  static SubscribeRequest create() => SubscribeRequest._();
+  SubscribeRequest createEmptyInstance() => create();
+  static $pb.PbList<SubscribeRequest> createRepeated() => $pb.PbList<SubscribeRequest>();
+  @$core.pragma('dart2js:noInline')
+  static SubscribeRequest getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<SubscribeRequest>(create);
+  static SubscribeRequest? _defaultInstance;
+
+  /// Subscribe to a set of data points (or expressions) described
+  /// by the provided query.
+  /// The query syntax is a subset of SQL and is described in more
+  /// detail in the QUERY.md file.
+  @$pb.TagNumber(2)
+  $core.String get query => $_getSZ(0);
+  @$pb.TagNumber(2)
+  set query($core.String v) { $_setString(0, v); }
+  @$pb.TagNumber(2)
+  $core.bool hasQuery() => $_has(0);
+  @$pb.TagNumber(2)
+  void clearQuery() => clearField(2);
+}
+
+class SubscribeReply extends $pb.GeneratedMessage {
+  factory SubscribeReply({
+    $core.Map<$core.String, $3.Datapoint>? fields,
+  }) {
+    final $result = create();
+    if (fields != null) {
+      $result.fields.addAll(fields);
+    }
+    return $result;
+  }
+  SubscribeReply._() : super();
+  factory SubscribeReply.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
+  factory SubscribeReply.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
+
+  static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'SubscribeReply', package: const $pb.PackageName(_omitMessageNames ? '' : 'sdv.databroker.v1'), createEmptyInstance: create)
+    ..m<$core.String, $3.Datapoint>(1, _omitFieldNames ? '' : 'fields', entryClassName: 'SubscribeReply.FieldsEntry', keyFieldType: $pb.PbFieldType.OS, valueFieldType: $pb.PbFieldType.OM, valueCreator: $3.Datapoint.create, valueDefaultOrMaker: $3.Datapoint.getDefault, packageName: const $pb.PackageName('sdv.databroker.v1'))
+    ..hasRequiredFields = false
+  ;
+
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
+  'Will be removed in next major version')
+  SubscribeReply clone() => SubscribeReply()..mergeFromMessage(this);
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
+  'Will be removed in next major version')
+  SubscribeReply copyWith(void Function(SubscribeReply) updates) => super.copyWith((message) => updates(message as SubscribeReply)) as SubscribeReply;
+
+  $pb.BuilderInfo get info_ => _i;
+
+  @$core.pragma('dart2js:noInline')
+  static SubscribeReply create() => SubscribeReply._();
+  SubscribeReply createEmptyInstance() => create();
+  static $pb.PbList<SubscribeReply> createRepeated() => $pb.PbList<SubscribeReply>();
+  @$core.pragma('dart2js:noInline')
+  static SubscribeReply getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<SubscribeReply>(create);
+  static SubscribeReply? _defaultInstance;
+
+  /// Contains the fields specified by the query.
+  /// If a requested data point value is not available, the corresponding
+  /// Datapoint will have it's respective failure value set.
+  @$pb.TagNumber(1)
+  $core.Map<$core.String, $3.Datapoint> get fields => $_getMap(0);
+}
+
+class GetMetadataRequest extends $pb.GeneratedMessage {
+  factory GetMetadataRequest({
+    $core.Iterable<$core.String>? names,
+  }) {
+    final $result = create();
+    if (names != null) {
+      $result.names.addAll(names);
+    }
+    return $result;
+  }
+  GetMetadataRequest._() : super();
+  factory GetMetadataRequest.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
+  factory GetMetadataRequest.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
+
+  static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'GetMetadataRequest', package: const $pb.PackageName(_omitMessageNames ? '' : 'sdv.databroker.v1'), createEmptyInstance: create)
+    ..pPS(1, _omitFieldNames ? '' : 'names')
+    ..hasRequiredFields = false
+  ;
+
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
+  'Will be removed in next major version')
+  GetMetadataRequest clone() => GetMetadataRequest()..mergeFromMessage(this);
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
+  'Will be removed in next major version')
+  GetMetadataRequest copyWith(void Function(GetMetadataRequest) updates) => super.copyWith((message) => updates(message as GetMetadataRequest)) as GetMetadataRequest;
+
+  $pb.BuilderInfo get info_ => _i;
+
+  @$core.pragma('dart2js:noInline')
+  static GetMetadataRequest create() => GetMetadataRequest._();
+  GetMetadataRequest createEmptyInstance() => create();
+  static $pb.PbList<GetMetadataRequest> createRepeated() => $pb.PbList<GetMetadataRequest>();
+  @$core.pragma('dart2js:noInline')
+  static GetMetadataRequest getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<GetMetadataRequest>(create);
+  static GetMetadataRequest? _defaultInstance;
+
+  ///  Request metadata for a list of data points referenced by their names.
+  ///  e.g. "Vehicle.Cabin.Seat.Row1.Pos1.Position" or "Vehicle.Speed".
+  ///
+  ///  If no names are provided, metadata for all known data points will be
+  ///  returned.
+  @$pb.TagNumber(1)
+  $core.List<$core.String> get names => $_getList(0);
+}
+
+class GetMetadataReply extends $pb.GeneratedMessage {
+  factory GetMetadataReply({
+    $core.Iterable<$3.Metadata>? list,
+  }) {
+    final $result = create();
+    if (list != null) {
+      $result.list.addAll(list);
+    }
+    return $result;
+  }
+  GetMetadataReply._() : super();
+  factory GetMetadataReply.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
+  factory GetMetadataReply.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
+
+  static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'GetMetadataReply', package: const $pb.PackageName(_omitMessageNames ? '' : 'sdv.databroker.v1'), createEmptyInstance: create)
+    ..pc<$3.Metadata>(1, _omitFieldNames ? '' : 'list', $pb.PbFieldType.PM, subBuilder: $3.Metadata.create)
+    ..hasRequiredFields = false
+  ;
+
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
+  'Will be removed in next major version')
+  GetMetadataReply clone() => GetMetadataReply()..mergeFromMessage(this);
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
+  'Will be removed in next major version')
+  GetMetadataReply copyWith(void Function(GetMetadataReply) updates) => super.copyWith((message) => updates(message as GetMetadataReply)) as GetMetadataReply;
+
+  $pb.BuilderInfo get info_ => _i;
+
+  @$core.pragma('dart2js:noInline')
+  static GetMetadataReply create() => GetMetadataReply._();
+  GetMetadataReply createEmptyInstance() => create();
+  static $pb.PbList<GetMetadataReply> createRepeated() => $pb.PbList<GetMetadataReply>();
+  @$core.pragma('dart2js:noInline')
+  static GetMetadataReply getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<GetMetadataReply>(create);
+  static GetMetadataReply? _defaultInstance;
+
+  /// Contains metadata of the requested data points. If a data point
+  /// doesn't exist (i.e. not known to the Data Broker) the corresponding
+  /// Metadata isn't part of the returned list.
+  @$pb.TagNumber(1)
+  $core.List<$3.Metadata> get list => $_getList(0);
+}
+
+
+const _omitFieldNames = $core.bool.fromEnvironment('protobuf.omit_field_names');
+const _omitMessageNames = $core.bool.fromEnvironment('protobuf.omit_message_names');
diff --git a/protos/lib/src/generated/sdv/databroker/v1/broker.pbenum.dart b/protos/lib/src/generated/sdv/databroker/v1/broker.pbenum.dart
new file mode 100644
index 0000000..99be056
--- /dev/null
+++ b/protos/lib/src/generated/sdv/databroker/v1/broker.pbenum.dart
@@ -0,0 +1,11 @@
+//
+//  Generated code. Do not modify.
+//  source: sdv/databroker/v1/broker.proto
+//
+// @dart = 2.12
+
+// ignore_for_file: annotate_overrides, camel_case_types, comment_references
+// ignore_for_file: constant_identifier_names, library_prefixes
+// ignore_for_file: non_constant_identifier_names, prefer_final_fields
+// ignore_for_file: unnecessary_import, unnecessary_this, unused_import
+
diff --git a/protos/lib/src/generated/sdv/databroker/v1/broker.pbgrpc.dart b/protos/lib/src/generated/sdv/databroker/v1/broker.pbgrpc.dart
new file mode 100644
index 0000000..62b05c0
--- /dev/null
+++ b/protos/lib/src/generated/sdv/databroker/v1/broker.pbgrpc.dart
@@ -0,0 +1,119 @@
+//
+//  Generated code. Do not modify.
+//  source: sdv/databroker/v1/broker.proto
+//
+// @dart = 2.12
+
+// ignore_for_file: annotate_overrides, camel_case_types, comment_references
+// ignore_for_file: constant_identifier_names, library_prefixes
+// ignore_for_file: non_constant_identifier_names, prefer_final_fields
+// ignore_for_file: unnecessary_import, unnecessary_this, unused_import
+
+import 'dart:async' as $async;
+import 'dart:core' as $core;
+
+import 'package:grpc/service_api.dart' as $grpc;
+import 'package:protobuf/protobuf.dart' as $pb;
+
+import 'broker.pb.dart' as $0;
+
+export 'broker.pb.dart';
+
+@$pb.GrpcServiceName('sdv.databroker.v1.Broker')
+class BrokerClient extends $grpc.Client {
+  static final _$getDatapoints = $grpc.ClientMethod<$0.GetDatapointsRequest, $0.GetDatapointsReply>(
+      '/sdv.databroker.v1.Broker/GetDatapoints',
+      ($0.GetDatapointsRequest value) => value.writeToBuffer(),
+      ($core.List<$core.int> value) => $0.GetDatapointsReply.fromBuffer(value));
+  static final _$setDatapoints = $grpc.ClientMethod<$0.SetDatapointsRequest, $0.SetDatapointsReply>(
+      '/sdv.databroker.v1.Broker/SetDatapoints',
+      ($0.SetDatapointsRequest value) => value.writeToBuffer(),
+      ($core.List<$core.int> value) => $0.SetDatapointsReply.fromBuffer(value));
+  static final _$subscribe = $grpc.ClientMethod<$0.SubscribeRequest, $0.SubscribeReply>(
+      '/sdv.databroker.v1.Broker/Subscribe',
+      ($0.SubscribeRequest value) => value.writeToBuffer(),
+      ($core.List<$core.int> value) => $0.SubscribeReply.fromBuffer(value));
+  static final _$getMetadata = $grpc.ClientMethod<$0.GetMetadataRequest, $0.GetMetadataReply>(
+      '/sdv.databroker.v1.Broker/GetMetadata',
+      ($0.GetMetadataRequest value) => value.writeToBuffer(),
+      ($core.List<$core.int> value) => $0.GetMetadataReply.fromBuffer(value));
+
+  BrokerClient($grpc.ClientChannel channel,
+      {$grpc.CallOptions? options,
+      $core.Iterable<$grpc.ClientInterceptor>? interceptors})
+      : super(channel, options: options,
+        interceptors: interceptors);
+
+  $grpc.ResponseFuture<$0.GetDatapointsReply> getDatapoints($0.GetDatapointsRequest request, {$grpc.CallOptions? options}) {
+    return $createUnaryCall(_$getDatapoints, request, options: options);
+  }
+
+  $grpc.ResponseFuture<$0.SetDatapointsReply> setDatapoints($0.SetDatapointsRequest request, {$grpc.CallOptions? options}) {
+    return $createUnaryCall(_$setDatapoints, request, options: options);
+  }
+
+  $grpc.ResponseStream<$0.SubscribeReply> subscribe($0.SubscribeRequest request, {$grpc.CallOptions? options}) {
+    return $createStreamingCall(_$subscribe, $async.Stream.fromIterable([request]), options: options);
+  }
+
+  $grpc.ResponseFuture<$0.GetMetadataReply> getMetadata($0.GetMetadataRequest request, {$grpc.CallOptions? options}) {
+    return $createUnaryCall(_$getMetadata, request, options: options);
+  }
+}
+
+@$pb.GrpcServiceName('sdv.databroker.v1.Broker')
+abstract class BrokerServiceBase extends $grpc.Service {
+  $core.String get $name => 'sdv.databroker.v1.Broker';
+
+  BrokerServiceBase() {
+    $addMethod($grpc.ServiceMethod<$0.GetDatapointsRequest, $0.GetDatapointsReply>(
+        'GetDatapoints',
+        getDatapoints_Pre,
+        false,
+        false,
+        ($core.List<$core.int> value) => $0.GetDatapointsRequest.fromBuffer(value),
+        ($0.GetDatapointsReply value) => value.writeToBuffer()));
+    $addMethod($grpc.ServiceMethod<$0.SetDatapointsRequest, $0.SetDatapointsReply>(
+        'SetDatapoints',
+        setDatapoints_Pre,
+        false,
+        false,
+        ($core.List<$core.int> value) => $0.SetDatapointsRequest.fromBuffer(value),
+        ($0.SetDatapointsReply value) => value.writeToBuffer()));
+    $addMethod($grpc.ServiceMethod<$0.SubscribeRequest, $0.SubscribeReply>(
+        'Subscribe',
+        subscribe_Pre,
+        false,
+        true,
+        ($core.List<$core.int> value) => $0.SubscribeRequest.fromBuffer(value),
+        ($0.SubscribeReply value) => value.writeToBuffer()));
+    $addMethod($grpc.ServiceMethod<$0.GetMetadataRequest, $0.GetMetadataReply>(
+        'GetMetadata',
+        getMetadata_Pre,
+        false,
+        false,
+        ($core.List<$core.int> value) => $0.GetMetadataRequest.fromBuffer(value),
+        ($0.GetMetadataReply value) => value.writeToBuffer()));
+  }
+
+  $async.Future<$0.GetDatapointsReply> getDatapoints_Pre($grpc.ServiceCall call, $async.Future<$0.GetDatapointsRequest> request) async {
+    return getDatapoints(call, await request);
+  }
+
+  $async.Future<$0.SetDatapointsReply> setDatapoints_Pre($grpc.ServiceCall call, $async.Future<$0.SetDatapointsRequest> request) async {
+    return setDatapoints(call, await request);
+  }
+
+  $async.Stream<$0.SubscribeReply> subscribe_Pre($grpc.ServiceCall call, $async.Future<$0.SubscribeRequest> request) async* {
+    yield* subscribe(call, await request);
+  }
+
+  $async.Future<$0.GetMetadataReply> getMetadata_Pre($grpc.ServiceCall call, $async.Future<$0.GetMetadataRequest> request) async {
+    return getMetadata(call, await request);
+  }
+
+  $async.Future<$0.GetDatapointsReply> getDatapoints($grpc.ServiceCall call, $0.GetDatapointsRequest request);
+  $async.Future<$0.SetDatapointsReply> setDatapoints($grpc.ServiceCall call, $0.SetDatapointsRequest request);
+  $async.Stream<$0.SubscribeReply> subscribe($grpc.ServiceCall call, $0.SubscribeRequest request);
+  $async.Future<$0.GetMetadataReply> getMetadata($grpc.ServiceCall call, $0.GetMetadataRequest request);
+}
diff --git a/protos/lib/src/generated/sdv/databroker/v1/broker.pbjson.dart b/protos/lib/src/generated/sdv/databroker/v1/broker.pbjson.dart
new file mode 100644
index 0000000..4b06fe7
--- /dev/null
+++ b/protos/lib/src/generated/sdv/databroker/v1/broker.pbjson.dart
@@ -0,0 +1,168 @@
+//
+//  Generated code. Do not modify.
+//  source: sdv/databroker/v1/broker.proto
+//
+// @dart = 2.12
+
+// ignore_for_file: annotate_overrides, camel_case_types, comment_references
+// ignore_for_file: constant_identifier_names, library_prefixes
+// ignore_for_file: non_constant_identifier_names, prefer_final_fields
+// ignore_for_file: unnecessary_import, unnecessary_this, unused_import
+
+import 'dart:convert' as $convert;
+import 'dart:core' as $core;
+import 'dart:typed_data' as $typed_data;
+
+@$core.Deprecated('Use getDatapointsRequestDescriptor instead')
+const GetDatapointsRequest$json = {
+  '1': 'GetDatapointsRequest',
+  '2': [
+    {'1': 'datapoints', '3': 1, '4': 3, '5': 9, '10': 'datapoints'},
+  ],
+};
+
+/// Descriptor for `GetDatapointsRequest`. Decode as a `google.protobuf.DescriptorProto`.
+final $typed_data.Uint8List getDatapointsRequestDescriptor = $convert.base64Decode(
+    'ChRHZXREYXRhcG9pbnRzUmVxdWVzdBIeCgpkYXRhcG9pbnRzGAEgAygJUgpkYXRhcG9pbnRz');
+
+@$core.Deprecated('Use getDatapointsReplyDescriptor instead')
+const GetDatapointsReply$json = {
+  '1': 'GetDatapointsReply',
+  '2': [
+    {'1': 'datapoints', '3': 1, '4': 3, '5': 11, '6': '.sdv.databroker.v1.GetDatapointsReply.DatapointsEntry', '10': 'datapoints'},
+  ],
+  '3': [GetDatapointsReply_DatapointsEntry$json],
+};
+
+@$core.Deprecated('Use getDatapointsReplyDescriptor instead')
+const GetDatapointsReply_DatapointsEntry$json = {
+  '1': 'DatapointsEntry',
+  '2': [
+    {'1': 'key', '3': 1, '4': 1, '5': 9, '10': 'key'},
+    {'1': 'value', '3': 2, '4': 1, '5': 11, '6': '.sdv.databroker.v1.Datapoint', '10': 'value'},
+  ],
+  '7': {'7': true},
+};
+
+/// Descriptor for `GetDatapointsReply`. Decode as a `google.protobuf.DescriptorProto`.
+final $typed_data.Uint8List getDatapointsReplyDescriptor = $convert.base64Decode(
+    'ChJHZXREYXRhcG9pbnRzUmVwbHkSVQoKZGF0YXBvaW50cxgBIAMoCzI1LnNkdi5kYXRhYnJva2'
+    'VyLnYxLkdldERhdGFwb2ludHNSZXBseS5EYXRhcG9pbnRzRW50cnlSCmRhdGFwb2ludHMaWwoP'
+    'RGF0YXBvaW50c0VudHJ5EhAKA2tleRgBIAEoCVIDa2V5EjIKBXZhbHVlGAIgASgLMhwuc2R2Lm'
+    'RhdGFicm9rZXIudjEuRGF0YXBvaW50UgV2YWx1ZToCOAE=');
+
+@$core.Deprecated('Use setDatapointsRequestDescriptor instead')
+const SetDatapointsRequest$json = {
+  '1': 'SetDatapointsRequest',
+  '2': [
+    {'1': 'datapoints', '3': 1, '4': 3, '5': 11, '6': '.sdv.databroker.v1.SetDatapointsRequest.DatapointsEntry', '10': 'datapoints'},
+  ],
+  '3': [SetDatapointsRequest_DatapointsEntry$json],
+};
+
+@$core.Deprecated('Use setDatapointsRequestDescriptor instead')
+const SetDatapointsRequest_DatapointsEntry$json = {
+  '1': 'DatapointsEntry',
+  '2': [
+    {'1': 'key', '3': 1, '4': 1, '5': 9, '10': 'key'},
+    {'1': 'value', '3': 2, '4': 1, '5': 11, '6': '.sdv.databroker.v1.Datapoint', '10': 'value'},
+  ],
+  '7': {'7': true},
+};
+
+/// Descriptor for `SetDatapointsRequest`. Decode as a `google.protobuf.DescriptorProto`.
+final $typed_data.Uint8List setDatapointsRequestDescriptor = $convert.base64Decode(
+    'ChRTZXREYXRhcG9pbnRzUmVxdWVzdBJXCgpkYXRhcG9pbnRzGAEgAygLMjcuc2R2LmRhdGFicm'
+    '9rZXIudjEuU2V0RGF0YXBvaW50c1JlcXVlc3QuRGF0YXBvaW50c0VudHJ5UgpkYXRhcG9pbnRz'
+    'GlsKD0RhdGFwb2ludHNFbnRyeRIQCgNrZXkYASABKAlSA2tleRIyCgV2YWx1ZRgCIAEoCzIcLn'
+    'Nkdi5kYXRhYnJva2VyLnYxLkRhdGFwb2ludFIFdmFsdWU6AjgB');
+
+@$core.Deprecated('Use setDatapointsReplyDescriptor instead')
+const SetDatapointsReply$json = {
+  '1': 'SetDatapointsReply',
+  '2': [
+    {'1': 'errors', '3': 1, '4': 3, '5': 11, '6': '.sdv.databroker.v1.SetDatapointsReply.ErrorsEntry', '10': 'errors'},
+  ],
+  '3': [SetDatapointsReply_ErrorsEntry$json],
+};
+
+@$core.Deprecated('Use setDatapointsReplyDescriptor instead')
+const SetDatapointsReply_ErrorsEntry$json = {
+  '1': 'ErrorsEntry',
+  '2': [
+    {'1': 'key', '3': 1, '4': 1, '5': 9, '10': 'key'},
+    {'1': 'value', '3': 2, '4': 1, '5': 14, '6': '.sdv.databroker.v1.DatapointError', '10': 'value'},
+  ],
+  '7': {'7': true},
+};
+
+/// Descriptor for `SetDatapointsReply`. Decode as a `google.protobuf.DescriptorProto`.
+final $typed_data.Uint8List setDatapointsReplyDescriptor = $convert.base64Decode(
+    'ChJTZXREYXRhcG9pbnRzUmVwbHkSSQoGZXJyb3JzGAEgAygLMjEuc2R2LmRhdGFicm9rZXIudj'
+    'EuU2V0RGF0YXBvaW50c1JlcGx5LkVycm9yc0VudHJ5UgZlcnJvcnMaXAoLRXJyb3JzRW50cnkS'
+    'EAoDa2V5GAEgASgJUgNrZXkSNwoFdmFsdWUYAiABKA4yIS5zZHYuZGF0YWJyb2tlci52MS5EYX'
+    'RhcG9pbnRFcnJvclIFdmFsdWU6AjgB');
+
+@$core.Deprecated('Use subscribeRequestDescriptor instead')
+const SubscribeRequest$json = {
+  '1': 'SubscribeRequest',
+  '2': [
+    {'1': 'query', '3': 2, '4': 1, '5': 9, '10': 'query'},
+  ],
+};
+
+/// Descriptor for `SubscribeRequest`. Decode as a `google.protobuf.DescriptorProto`.
+final $typed_data.Uint8List subscribeRequestDescriptor = $convert.base64Decode(
+    'ChBTdWJzY3JpYmVSZXF1ZXN0EhQKBXF1ZXJ5GAIgASgJUgVxdWVyeQ==');
+
+@$core.Deprecated('Use subscribeReplyDescriptor instead')
+const SubscribeReply$json = {
+  '1': 'SubscribeReply',
+  '2': [
+    {'1': 'fields', '3': 1, '4': 3, '5': 11, '6': '.sdv.databroker.v1.SubscribeReply.FieldsEntry', '10': 'fields'},
+  ],
+  '3': [SubscribeReply_FieldsEntry$json],
+};
+
+@$core.Deprecated('Use subscribeReplyDescriptor instead')
+const SubscribeReply_FieldsEntry$json = {
+  '1': 'FieldsEntry',
+  '2': [
+    {'1': 'key', '3': 1, '4': 1, '5': 9, '10': 'key'},
+    {'1': 'value', '3': 2, '4': 1, '5': 11, '6': '.sdv.databroker.v1.Datapoint', '10': 'value'},
+  ],
+  '7': {'7': true},
+};
+
+/// Descriptor for `SubscribeReply`. Decode as a `google.protobuf.DescriptorProto`.
+final $typed_data.Uint8List subscribeReplyDescriptor = $convert.base64Decode(
+    'Cg5TdWJzY3JpYmVSZXBseRJFCgZmaWVsZHMYASADKAsyLS5zZHYuZGF0YWJyb2tlci52MS5TdW'
+    'JzY3JpYmVSZXBseS5GaWVsZHNFbnRyeVIGZmllbGRzGlcKC0ZpZWxkc0VudHJ5EhAKA2tleRgB'
+    'IAEoCVIDa2V5EjIKBXZhbHVlGAIgASgLMhwuc2R2LmRhdGFicm9rZXIudjEuRGF0YXBvaW50Ug'
+    'V2YWx1ZToCOAE=');
+
+@$core.Deprecated('Use getMetadataRequestDescriptor instead')
+const GetMetadataRequest$json = {
+  '1': 'GetMetadataRequest',
+  '2': [
+    {'1': 'names', '3': 1, '4': 3, '5': 9, '10': 'names'},
+  ],
+};
+
+/// Descriptor for `GetMetadataRequest`. Decode as a `google.protobuf.DescriptorProto`.
+final $typed_data.Uint8List getMetadataRequestDescriptor = $convert.base64Decode(
+    'ChJHZXRNZXRhZGF0YVJlcXVlc3QSFAoFbmFtZXMYASADKAlSBW5hbWVz');
+
+@$core.Deprecated('Use getMetadataReplyDescriptor instead')
+const GetMetadataReply$json = {
+  '1': 'GetMetadataReply',
+  '2': [
+    {'1': 'list', '3': 1, '4': 3, '5': 11, '6': '.sdv.databroker.v1.Metadata', '10': 'list'},
+  ],
+};
+
+/// Descriptor for `GetMetadataReply`. Decode as a `google.protobuf.DescriptorProto`.
+final $typed_data.Uint8List getMetadataReplyDescriptor = $convert.base64Decode(
+    'ChBHZXRNZXRhZGF0YVJlcGx5Ei8KBGxpc3QYASADKAsyGy5zZHYuZGF0YWJyb2tlci52MS5NZX'
+    'RhZGF0YVIEbGlzdA==');
+
diff --git a/protos/lib/src/generated/sdv/databroker/v1/collector.pb.dart b/protos/lib/src/generated/sdv/databroker/v1/collector.pb.dart
new file mode 100644
index 0000000..532e01a
--- /dev/null
+++ b/protos/lib/src/generated/sdv/databroker/v1/collector.pb.dart
@@ -0,0 +1,380 @@
+//
+//  Generated code. Do not modify.
+//  source: sdv/databroker/v1/collector.proto
+//
+// @dart = 2.12
+
+// ignore_for_file: annotate_overrides, camel_case_types, comment_references
+// ignore_for_file: constant_identifier_names, library_prefixes
+// ignore_for_file: non_constant_identifier_names, prefer_final_fields
+// ignore_for_file: unnecessary_import, unnecessary_this, unused_import
+
+import 'dart:core' as $core;
+
+import 'package:protobuf/protobuf.dart' as $pb;
+
+import 'types.pb.dart' as $3;
+import 'types.pbenum.dart' as $3;
+
+class UpdateDatapointsRequest extends $pb.GeneratedMessage {
+  factory UpdateDatapointsRequest({
+    $core.Map<$core.int, $3.Datapoint>? datapoints,
+  }) {
+    final $result = create();
+    if (datapoints != null) {
+      $result.datapoints.addAll(datapoints);
+    }
+    return $result;
+  }
+  UpdateDatapointsRequest._() : super();
+  factory UpdateDatapointsRequest.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
+  factory UpdateDatapointsRequest.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
+
+  static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'UpdateDatapointsRequest', package: const $pb.PackageName(_omitMessageNames ? '' : 'sdv.databroker.v1'), createEmptyInstance: create)
+    ..m<$core.int, $3.Datapoint>(1, _omitFieldNames ? '' : 'datapoints', entryClassName: 'UpdateDatapointsRequest.DatapointsEntry', keyFieldType: $pb.PbFieldType.O3, valueFieldType: $pb.PbFieldType.OM, valueCreator: $3.Datapoint.create, valueDefaultOrMaker: $3.Datapoint.getDefault, packageName: const $pb.PackageName('sdv.databroker.v1'))
+    ..hasRequiredFields = false
+  ;
+
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
+  'Will be removed in next major version')
+  UpdateDatapointsRequest clone() => UpdateDatapointsRequest()..mergeFromMessage(this);
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
+  'Will be removed in next major version')
+  UpdateDatapointsRequest copyWith(void Function(UpdateDatapointsRequest) updates) => super.copyWith((message) => updates(message as UpdateDatapointsRequest)) as UpdateDatapointsRequest;
+
+  $pb.BuilderInfo get info_ => _i;
+
+  @$core.pragma('dart2js:noInline')
+  static UpdateDatapointsRequest create() => UpdateDatapointsRequest._();
+  UpdateDatapointsRequest createEmptyInstance() => create();
+  static $pb.PbList<UpdateDatapointsRequest> createRepeated() => $pb.PbList<UpdateDatapointsRequest>();
+  @$core.pragma('dart2js:noInline')
+  static UpdateDatapointsRequest getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<UpdateDatapointsRequest>(create);
+  static UpdateDatapointsRequest? _defaultInstance;
+
+  @$pb.TagNumber(1)
+  $core.Map<$core.int, $3.Datapoint> get datapoints => $_getMap(0);
+}
+
+class UpdateDatapointsReply extends $pb.GeneratedMessage {
+  factory UpdateDatapointsReply({
+    $core.Map<$core.int, $3.DatapointError>? errors,
+  }) {
+    final $result = create();
+    if (errors != null) {
+      $result.errors.addAll(errors);
+    }
+    return $result;
+  }
+  UpdateDatapointsReply._() : super();
+  factory UpdateDatapointsReply.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
+  factory UpdateDatapointsReply.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
+
+  static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'UpdateDatapointsReply', package: const $pb.PackageName(_omitMessageNames ? '' : 'sdv.databroker.v1'), createEmptyInstance: create)
+    ..m<$core.int, $3.DatapointError>(1, _omitFieldNames ? '' : 'errors', entryClassName: 'UpdateDatapointsReply.ErrorsEntry', keyFieldType: $pb.PbFieldType.O3, valueFieldType: $pb.PbFieldType.OE, valueOf: $3.DatapointError.valueOf, enumValues: $3.DatapointError.values, valueDefaultOrMaker: $3.DatapointError.UNKNOWN_DATAPOINT, defaultEnumValue: $3.DatapointError.UNKNOWN_DATAPOINT, packageName: const $pb.PackageName('sdv.databroker.v1'))
+    ..hasRequiredFields = false
+  ;
+
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
+  'Will be removed in next major version')
+  UpdateDatapointsReply clone() => UpdateDatapointsReply()..mergeFromMessage(this);
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
+  'Will be removed in next major version')
+  UpdateDatapointsReply copyWith(void Function(UpdateDatapointsReply) updates) => super.copyWith((message) => updates(message as UpdateDatapointsReply)) as UpdateDatapointsReply;
+
+  $pb.BuilderInfo get info_ => _i;
+
+  @$core.pragma('dart2js:noInline')
+  static UpdateDatapointsReply create() => UpdateDatapointsReply._();
+  UpdateDatapointsReply createEmptyInstance() => create();
+  static $pb.PbList<UpdateDatapointsReply> createRepeated() => $pb.PbList<UpdateDatapointsReply>();
+  @$core.pragma('dart2js:noInline')
+  static UpdateDatapointsReply getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<UpdateDatapointsReply>(create);
+  static UpdateDatapointsReply? _defaultInstance;
+
+  @$pb.TagNumber(1)
+  $core.Map<$core.int, $3.DatapointError> get errors => $_getMap(0);
+}
+
+class StreamDatapointsRequest extends $pb.GeneratedMessage {
+  factory StreamDatapointsRequest({
+    $core.Map<$core.int, $3.Datapoint>? datapoints,
+  }) {
+    final $result = create();
+    if (datapoints != null) {
+      $result.datapoints.addAll(datapoints);
+    }
+    return $result;
+  }
+  StreamDatapointsRequest._() : super();
+  factory StreamDatapointsRequest.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
+  factory StreamDatapointsRequest.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
+
+  static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'StreamDatapointsRequest', package: const $pb.PackageName(_omitMessageNames ? '' : 'sdv.databroker.v1'), createEmptyInstance: create)
+    ..m<$core.int, $3.Datapoint>(1, _omitFieldNames ? '' : 'datapoints', entryClassName: 'StreamDatapointsRequest.DatapointsEntry', keyFieldType: $pb.PbFieldType.O3, valueFieldType: $pb.PbFieldType.OM, valueCreator: $3.Datapoint.create, valueDefaultOrMaker: $3.Datapoint.getDefault, packageName: const $pb.PackageName('sdv.databroker.v1'))
+    ..hasRequiredFields = false
+  ;
+
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
+  'Will be removed in next major version')
+  StreamDatapointsRequest clone() => StreamDatapointsRequest()..mergeFromMessage(this);
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
+  'Will be removed in next major version')
+  StreamDatapointsRequest copyWith(void Function(StreamDatapointsRequest) updates) => super.copyWith((message) => updates(message as StreamDatapointsRequest)) as StreamDatapointsRequest;
+
+  $pb.BuilderInfo get info_ => _i;
+
+  @$core.pragma('dart2js:noInline')
+  static StreamDatapointsRequest create() => StreamDatapointsRequest._();
+  StreamDatapointsRequest createEmptyInstance() => create();
+  static $pb.PbList<StreamDatapointsRequest> createRepeated() => $pb.PbList<StreamDatapointsRequest>();
+  @$core.pragma('dart2js:noInline')
+  static StreamDatapointsRequest getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<StreamDatapointsRequest>(create);
+  static StreamDatapointsRequest? _defaultInstance;
+
+  @$pb.TagNumber(1)
+  $core.Map<$core.int, $3.Datapoint> get datapoints => $_getMap(0);
+}
+
+class StreamDatapointsReply extends $pb.GeneratedMessage {
+  factory StreamDatapointsReply({
+    $core.Map<$core.int, $3.DatapointError>? errors,
+  }) {
+    final $result = create();
+    if (errors != null) {
+      $result.errors.addAll(errors);
+    }
+    return $result;
+  }
+  StreamDatapointsReply._() : super();
+  factory StreamDatapointsReply.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
+  factory StreamDatapointsReply.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
+
+  static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'StreamDatapointsReply', package: const $pb.PackageName(_omitMessageNames ? '' : 'sdv.databroker.v1'), createEmptyInstance: create)
+    ..m<$core.int, $3.DatapointError>(1, _omitFieldNames ? '' : 'errors', entryClassName: 'StreamDatapointsReply.ErrorsEntry', keyFieldType: $pb.PbFieldType.O3, valueFieldType: $pb.PbFieldType.OE, valueOf: $3.DatapointError.valueOf, enumValues: $3.DatapointError.values, valueDefaultOrMaker: $3.DatapointError.UNKNOWN_DATAPOINT, defaultEnumValue: $3.DatapointError.UNKNOWN_DATAPOINT, packageName: const $pb.PackageName('sdv.databroker.v1'))
+    ..hasRequiredFields = false
+  ;
+
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
+  'Will be removed in next major version')
+  StreamDatapointsReply clone() => StreamDatapointsReply()..mergeFromMessage(this);
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
+  'Will be removed in next major version')
+  StreamDatapointsReply copyWith(void Function(StreamDatapointsReply) updates) => super.copyWith((message) => updates(message as StreamDatapointsReply)) as StreamDatapointsReply;
+
+  $pb.BuilderInfo get info_ => _i;
+
+  @$core.pragma('dart2js:noInline')
+  static StreamDatapointsReply create() => StreamDatapointsReply._();
+  StreamDatapointsReply createEmptyInstance() => create();
+  static $pb.PbList<StreamDatapointsReply> createRepeated() => $pb.PbList<StreamDatapointsReply>();
+  @$core.pragma('dart2js:noInline')
+  static StreamDatapointsReply getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<StreamDatapointsReply>(create);
+  static StreamDatapointsReply? _defaultInstance;
+
+  @$pb.TagNumber(1)
+  $core.Map<$core.int, $3.DatapointError> get errors => $_getMap(0);
+}
+
+class RegisterDatapointsRequest extends $pb.GeneratedMessage {
+  factory RegisterDatapointsRequest({
+    $core.Iterable<RegistrationMetadata>? list,
+  }) {
+    final $result = create();
+    if (list != null) {
+      $result.list.addAll(list);
+    }
+    return $result;
+  }
+  RegisterDatapointsRequest._() : super();
+  factory RegisterDatapointsRequest.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
+  factory RegisterDatapointsRequest.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
+
+  static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'RegisterDatapointsRequest', package: const $pb.PackageName(_omitMessageNames ? '' : 'sdv.databroker.v1'), createEmptyInstance: create)
+    ..pc<RegistrationMetadata>(1, _omitFieldNames ? '' : 'list', $pb.PbFieldType.PM, subBuilder: RegistrationMetadata.create)
+    ..hasRequiredFields = false
+  ;
+
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
+  'Will be removed in next major version')
+  RegisterDatapointsRequest clone() => RegisterDatapointsRequest()..mergeFromMessage(this);
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
+  'Will be removed in next major version')
+  RegisterDatapointsRequest copyWith(void Function(RegisterDatapointsRequest) updates) => super.copyWith((message) => updates(message as RegisterDatapointsRequest)) as RegisterDatapointsRequest;
+
+  $pb.BuilderInfo get info_ => _i;
+
+  @$core.pragma('dart2js:noInline')
+  static RegisterDatapointsRequest create() => RegisterDatapointsRequest._();
+  RegisterDatapointsRequest createEmptyInstance() => create();
+  static $pb.PbList<RegisterDatapointsRequest> createRepeated() => $pb.PbList<RegisterDatapointsRequest>();
+  @$core.pragma('dart2js:noInline')
+  static RegisterDatapointsRequest getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<RegisterDatapointsRequest>(create);
+  static RegisterDatapointsRequest? _defaultInstance;
+
+  @$pb.TagNumber(1)
+  $core.List<RegistrationMetadata> get list => $_getList(0);
+}
+
+class RegistrationMetadata extends $pb.GeneratedMessage {
+  factory RegistrationMetadata({
+    $core.String? name,
+    $3.DataType? dataType,
+    $core.String? description,
+    $3.ChangeType? changeType,
+  }) {
+    final $result = create();
+    if (name != null) {
+      $result.name = name;
+    }
+    if (dataType != null) {
+      $result.dataType = dataType;
+    }
+    if (description != null) {
+      $result.description = description;
+    }
+    if (changeType != null) {
+      $result.changeType = changeType;
+    }
+    return $result;
+  }
+  RegistrationMetadata._() : super();
+  factory RegistrationMetadata.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
+  factory RegistrationMetadata.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
+
+  static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'RegistrationMetadata', package: const $pb.PackageName(_omitMessageNames ? '' : 'sdv.databroker.v1'), createEmptyInstance: create)
+    ..aOS(1, _omitFieldNames ? '' : 'name')
+    ..e<$3.DataType>(2, _omitFieldNames ? '' : 'dataType', $pb.PbFieldType.OE, defaultOrMaker: $3.DataType.STRING, valueOf: $3.DataType.valueOf, enumValues: $3.DataType.values)
+    ..aOS(3, _omitFieldNames ? '' : 'description')
+    ..e<$3.ChangeType>(4, _omitFieldNames ? '' : 'changeType', $pb.PbFieldType.OE, defaultOrMaker: $3.ChangeType.STATIC, valueOf: $3.ChangeType.valueOf, enumValues: $3.ChangeType.values)
+    ..hasRequiredFields = false
+  ;
+
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
+  'Will be removed in next major version')
+  RegistrationMetadata clone() => RegistrationMetadata()..mergeFromMessage(this);
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
+  'Will be removed in next major version')
+  RegistrationMetadata copyWith(void Function(RegistrationMetadata) updates) => super.copyWith((message) => updates(message as RegistrationMetadata)) as RegistrationMetadata;
+
+  $pb.BuilderInfo get info_ => _i;
+
+  @$core.pragma('dart2js:noInline')
+  static RegistrationMetadata create() => RegistrationMetadata._();
+  RegistrationMetadata createEmptyInstance() => create();
+  static $pb.PbList<RegistrationMetadata> createRepeated() => $pb.PbList<RegistrationMetadata>();
+  @$core.pragma('dart2js:noInline')
+  static RegistrationMetadata getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<RegistrationMetadata>(create);
+  static RegistrationMetadata? _defaultInstance;
+
+  /// Name of the data point
+  /// (e.g. "Vehicle.Cabin.Seat.Row1.Pos1.Position" or "Vehicle.Speed")
+  @$pb.TagNumber(1)
+  $core.String get name => $_getSZ(0);
+  @$pb.TagNumber(1)
+  set name($core.String v) { $_setString(0, v); }
+  @$pb.TagNumber(1)
+  $core.bool hasName() => $_has(0);
+  @$pb.TagNumber(1)
+  void clearName() => clearField(1);
+
+  @$pb.TagNumber(2)
+  $3.DataType get dataType => $_getN(1);
+  @$pb.TagNumber(2)
+  set dataType($3.DataType v) { setField(2, v); }
+  @$pb.TagNumber(2)
+  $core.bool hasDataType() => $_has(1);
+  @$pb.TagNumber(2)
+  void clearDataType() => clearField(2);
+
+  @$pb.TagNumber(3)
+  $core.String get description => $_getSZ(2);
+  @$pb.TagNumber(3)
+  set description($core.String v) { $_setString(2, v); }
+  @$pb.TagNumber(3)
+  $core.bool hasDescription() => $_has(2);
+  @$pb.TagNumber(3)
+  void clearDescription() => clearField(3);
+
+  @$pb.TagNumber(4)
+  $3.ChangeType get changeType => $_getN(3);
+  @$pb.TagNumber(4)
+  set changeType($3.ChangeType v) { setField(4, v); }
+  @$pb.TagNumber(4)
+  $core.bool hasChangeType() => $_has(3);
+  @$pb.TagNumber(4)
+  void clearChangeType() => clearField(4);
+}
+
+class RegisterDatapointsReply extends $pb.GeneratedMessage {
+  factory RegisterDatapointsReply({
+    $core.Map<$core.String, $core.int>? results,
+  }) {
+    final $result = create();
+    if (results != null) {
+      $result.results.addAll(results);
+    }
+    return $result;
+  }
+  RegisterDatapointsReply._() : super();
+  factory RegisterDatapointsReply.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
+  factory RegisterDatapointsReply.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
+
+  static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'RegisterDatapointsReply', package: const $pb.PackageName(_omitMessageNames ? '' : 'sdv.databroker.v1'), createEmptyInstance: create)
+    ..m<$core.String, $core.int>(1, _omitFieldNames ? '' : 'results', entryClassName: 'RegisterDatapointsReply.ResultsEntry', keyFieldType: $pb.PbFieldType.OS, valueFieldType: $pb.PbFieldType.O3, packageName: const $pb.PackageName('sdv.databroker.v1'))
+    ..hasRequiredFields = false
+  ;
+
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
+  'Will be removed in next major version')
+  RegisterDatapointsReply clone() => RegisterDatapointsReply()..mergeFromMessage(this);
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
+  'Will be removed in next major version')
+  RegisterDatapointsReply copyWith(void Function(RegisterDatapointsReply) updates) => super.copyWith((message) => updates(message as RegisterDatapointsReply)) as RegisterDatapointsReply;
+
+  $pb.BuilderInfo get info_ => _i;
+
+  @$core.pragma('dart2js:noInline')
+  static RegisterDatapointsReply create() => RegisterDatapointsReply._();
+  RegisterDatapointsReply createEmptyInstance() => create();
+  static $pb.PbList<RegisterDatapointsReply> createRepeated() => $pb.PbList<RegisterDatapointsReply>();
+  @$core.pragma('dart2js:noInline')
+  static RegisterDatapointsReply getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<RegisterDatapointsReply>(create);
+  static RegisterDatapointsReply? _defaultInstance;
+
+  /// Maps each data point name passed in RegisterDatapointsRequest to a data point id
+  @$pb.TagNumber(1)
+  $core.Map<$core.String, $core.int> get results => $_getMap(0);
+}
+
+
+const _omitFieldNames = $core.bool.fromEnvironment('protobuf.omit_field_names');
+const _omitMessageNames = $core.bool.fromEnvironment('protobuf.omit_message_names');
diff --git a/protos/lib/src/generated/sdv/databroker/v1/collector.pbenum.dart b/protos/lib/src/generated/sdv/databroker/v1/collector.pbenum.dart
new file mode 100644
index 0000000..6b4cef3
--- /dev/null
+++ b/protos/lib/src/generated/sdv/databroker/v1/collector.pbenum.dart
@@ -0,0 +1,11 @@
+//
+//  Generated code. Do not modify.
+//  source: sdv/databroker/v1/collector.proto
+//
+// @dart = 2.12
+
+// ignore_for_file: annotate_overrides, camel_case_types, comment_references
+// ignore_for_file: constant_identifier_names, library_prefixes
+// ignore_for_file: non_constant_identifier_names, prefer_final_fields
+// ignore_for_file: unnecessary_import, unnecessary_this, unused_import
+
diff --git a/protos/lib/src/generated/sdv/databroker/v1/collector.pbgrpc.dart b/protos/lib/src/generated/sdv/databroker/v1/collector.pbgrpc.dart
new file mode 100644
index 0000000..843cff2
--- /dev/null
+++ b/protos/lib/src/generated/sdv/databroker/v1/collector.pbgrpc.dart
@@ -0,0 +1,95 @@
+//
+//  Generated code. Do not modify.
+//  source: sdv/databroker/v1/collector.proto
+//
+// @dart = 2.12
+
+// ignore_for_file: annotate_overrides, camel_case_types, comment_references
+// ignore_for_file: constant_identifier_names, library_prefixes
+// ignore_for_file: non_constant_identifier_names, prefer_final_fields
+// ignore_for_file: unnecessary_import, unnecessary_this, unused_import
+
+import 'dart:async' as $async;
+import 'dart:core' as $core;
+
+import 'package:grpc/service_api.dart' as $grpc;
+import 'package:protobuf/protobuf.dart' as $pb;
+
+import 'collector.pb.dart' as $1;
+
+export 'collector.pb.dart';
+
+@$pb.GrpcServiceName('sdv.databroker.v1.Collector')
+class CollectorClient extends $grpc.Client {
+  static final _$registerDatapoints = $grpc.ClientMethod<$1.RegisterDatapointsRequest, $1.RegisterDatapointsReply>(
+      '/sdv.databroker.v1.Collector/RegisterDatapoints',
+      ($1.RegisterDatapointsRequest value) => value.writeToBuffer(),
+      ($core.List<$core.int> value) => $1.RegisterDatapointsReply.fromBuffer(value));
+  static final _$updateDatapoints = $grpc.ClientMethod<$1.UpdateDatapointsRequest, $1.UpdateDatapointsReply>(
+      '/sdv.databroker.v1.Collector/UpdateDatapoints',
+      ($1.UpdateDatapointsRequest value) => value.writeToBuffer(),
+      ($core.List<$core.int> value) => $1.UpdateDatapointsReply.fromBuffer(value));
+  static final _$streamDatapoints = $grpc.ClientMethod<$1.StreamDatapointsRequest, $1.StreamDatapointsReply>(
+      '/sdv.databroker.v1.Collector/StreamDatapoints',
+      ($1.StreamDatapointsRequest value) => value.writeToBuffer(),
+      ($core.List<$core.int> value) => $1.StreamDatapointsReply.fromBuffer(value));
+
+  CollectorClient($grpc.ClientChannel channel,
+      {$grpc.CallOptions? options,
+      $core.Iterable<$grpc.ClientInterceptor>? interceptors})
+      : super(channel, options: options,
+        interceptors: interceptors);
+
+  $grpc.ResponseFuture<$1.RegisterDatapointsReply> registerDatapoints($1.RegisterDatapointsRequest request, {$grpc.CallOptions? options}) {
+    return $createUnaryCall(_$registerDatapoints, request, options: options);
+  }
+
+  $grpc.ResponseFuture<$1.UpdateDatapointsReply> updateDatapoints($1.UpdateDatapointsRequest request, {$grpc.CallOptions? options}) {
+    return $createUnaryCall(_$updateDatapoints, request, options: options);
+  }
+
+  $grpc.ResponseStream<$1.StreamDatapointsReply> streamDatapoints($async.Stream<$1.StreamDatapointsRequest> request, {$grpc.CallOptions? options}) {
+    return $createStreamingCall(_$streamDatapoints, request, options: options);
+  }
+}
+
+@$pb.GrpcServiceName('sdv.databroker.v1.Collector')
+abstract class CollectorServiceBase extends $grpc.Service {
+  $core.String get $name => 'sdv.databroker.v1.Collector';
+
+  CollectorServiceBase() {
+    $addMethod($grpc.ServiceMethod<$1.RegisterDatapointsRequest, $1.RegisterDatapointsReply>(
+        'RegisterDatapoints',
+        registerDatapoints_Pre,
+        false,
+        false,
+        ($core.List<$core.int> value) => $1.RegisterDatapointsRequest.fromBuffer(value),
+        ($1.RegisterDatapointsReply value) => value.writeToBuffer()));
+    $addMethod($grpc.ServiceMethod<$1.UpdateDatapointsRequest, $1.UpdateDatapointsReply>(
+        'UpdateDatapoints',
+        updateDatapoints_Pre,
+        false,
+        false,
+        ($core.List<$core.int> value) => $1.UpdateDatapointsRequest.fromBuffer(value),
+        ($1.UpdateDatapointsReply value) => value.writeToBuffer()));
+    $addMethod($grpc.ServiceMethod<$1.StreamDatapointsRequest, $1.StreamDatapointsReply>(
+        'StreamDatapoints',
+        streamDatapoints,
+        true,
+        true,
+        ($core.List<$core.int> value) => $1.StreamDatapointsRequest.fromBuffer(value),
+        ($1.StreamDatapointsReply value) => value.writeToBuffer()));
+  }
+
+  $async.Future<$1.RegisterDatapointsReply> registerDatapoints_Pre($grpc.ServiceCall call, $async.Future<$1.RegisterDatapointsRequest> request) async {
+    return registerDatapoints(call, await request);
+  }
+
+  $async.Future<$1.UpdateDatapointsReply> updateDatapoints_Pre($grpc.ServiceCall call, $async.Future<$1.UpdateDatapointsRequest> request) async {
+    return updateDatapoints(call, await request);
+  }
+
+  $async.Future<$1.RegisterDatapointsReply> registerDatapoints($grpc.ServiceCall call, $1.RegisterDatapointsRequest request);
+  $async.Future<$1.UpdateDatapointsReply> updateDatapoints($grpc.ServiceCall call, $1.UpdateDatapointsRequest request);
+  $async.Stream<$1.StreamDatapointsReply> streamDatapoints($grpc.ServiceCall call, $async.Stream<$1.StreamDatapointsRequest> request);
+}
diff --git a/protos/lib/src/generated/sdv/databroker/v1/collector.pbjson.dart b/protos/lib/src/generated/sdv/databroker/v1/collector.pbjson.dart
new file mode 100644
index 0000000..91522a3
--- /dev/null
+++ b/protos/lib/src/generated/sdv/databroker/v1/collector.pbjson.dart
@@ -0,0 +1,176 @@
+//
+//  Generated code. Do not modify.
+//  source: sdv/databroker/v1/collector.proto
+//
+// @dart = 2.12
+
+// ignore_for_file: annotate_overrides, camel_case_types, comment_references
+// ignore_for_file: constant_identifier_names, library_prefixes
+// ignore_for_file: non_constant_identifier_names, prefer_final_fields
+// ignore_for_file: unnecessary_import, unnecessary_this, unused_import
+
+import 'dart:convert' as $convert;
+import 'dart:core' as $core;
+import 'dart:typed_data' as $typed_data;
+
+@$core.Deprecated('Use updateDatapointsRequestDescriptor instead')
+const UpdateDatapointsRequest$json = {
+  '1': 'UpdateDatapointsRequest',
+  '2': [
+    {'1': 'datapoints', '3': 1, '4': 3, '5': 11, '6': '.sdv.databroker.v1.UpdateDatapointsRequest.DatapointsEntry', '10': 'datapoints'},
+  ],
+  '3': [UpdateDatapointsRequest_DatapointsEntry$json],
+};
+
+@$core.Deprecated('Use updateDatapointsRequestDescriptor instead')
+const UpdateDatapointsRequest_DatapointsEntry$json = {
+  '1': 'DatapointsEntry',
+  '2': [
+    {'1': 'key', '3': 1, '4': 1, '5': 5, '10': 'key'},
+    {'1': 'value', '3': 2, '4': 1, '5': 11, '6': '.sdv.databroker.v1.Datapoint', '10': 'value'},
+  ],
+  '7': {'7': true},
+};
+
+/// Descriptor for `UpdateDatapointsRequest`. Decode as a `google.protobuf.DescriptorProto`.
+final $typed_data.Uint8List updateDatapointsRequestDescriptor = $convert.base64Decode(
+    'ChdVcGRhdGVEYXRhcG9pbnRzUmVxdWVzdBJaCgpkYXRhcG9pbnRzGAEgAygLMjouc2R2LmRhdG'
+    'Ficm9rZXIudjEuVXBkYXRlRGF0YXBvaW50c1JlcXVlc3QuRGF0YXBvaW50c0VudHJ5UgpkYXRh'
+    'cG9pbnRzGlsKD0RhdGFwb2ludHNFbnRyeRIQCgNrZXkYASABKAVSA2tleRIyCgV2YWx1ZRgCIA'
+    'EoCzIcLnNkdi5kYXRhYnJva2VyLnYxLkRhdGFwb2ludFIFdmFsdWU6AjgB');
+
+@$core.Deprecated('Use updateDatapointsReplyDescriptor instead')
+const UpdateDatapointsReply$json = {
+  '1': 'UpdateDatapointsReply',
+  '2': [
+    {'1': 'errors', '3': 1, '4': 3, '5': 11, '6': '.sdv.databroker.v1.UpdateDatapointsReply.ErrorsEntry', '10': 'errors'},
+  ],
+  '3': [UpdateDatapointsReply_ErrorsEntry$json],
+};
+
+@$core.Deprecated('Use updateDatapointsReplyDescriptor instead')
+const UpdateDatapointsReply_ErrorsEntry$json = {
+  '1': 'ErrorsEntry',
+  '2': [
+    {'1': 'key', '3': 1, '4': 1, '5': 5, '10': 'key'},
+    {'1': 'value', '3': 2, '4': 1, '5': 14, '6': '.sdv.databroker.v1.DatapointError', '10': 'value'},
+  ],
+  '7': {'7': true},
+};
+
+/// Descriptor for `UpdateDatapointsReply`. Decode as a `google.protobuf.DescriptorProto`.
+final $typed_data.Uint8List updateDatapointsReplyDescriptor = $convert.base64Decode(
+    'ChVVcGRhdGVEYXRhcG9pbnRzUmVwbHkSTAoGZXJyb3JzGAEgAygLMjQuc2R2LmRhdGFicm9rZX'
+    'IudjEuVXBkYXRlRGF0YXBvaW50c1JlcGx5LkVycm9yc0VudHJ5UgZlcnJvcnMaXAoLRXJyb3Jz'
+    'RW50cnkSEAoDa2V5GAEgASgFUgNrZXkSNwoFdmFsdWUYAiABKA4yIS5zZHYuZGF0YWJyb2tlci'
+    '52MS5EYXRhcG9pbnRFcnJvclIFdmFsdWU6AjgB');
+
+@$core.Deprecated('Use streamDatapointsRequestDescriptor instead')
+const StreamDatapointsRequest$json = {
+  '1': 'StreamDatapointsRequest',
+  '2': [
+    {'1': 'datapoints', '3': 1, '4': 3, '5': 11, '6': '.sdv.databroker.v1.StreamDatapointsRequest.DatapointsEntry', '10': 'datapoints'},
+  ],
+  '3': [StreamDatapointsRequest_DatapointsEntry$json],
+};
+
+@$core.Deprecated('Use streamDatapointsRequestDescriptor instead')
+const StreamDatapointsRequest_DatapointsEntry$json = {
+  '1': 'DatapointsEntry',
+  '2': [
+    {'1': 'key', '3': 1, '4': 1, '5': 5, '10': 'key'},
+    {'1': 'value', '3': 2, '4': 1, '5': 11, '6': '.sdv.databroker.v1.Datapoint', '10': 'value'},
+  ],
+  '7': {'7': true},
+};
+
+/// Descriptor for `StreamDatapointsRequest`. Decode as a `google.protobuf.DescriptorProto`.
+final $typed_data.Uint8List streamDatapointsRequestDescriptor = $convert.base64Decode(
+    'ChdTdHJlYW1EYXRhcG9pbnRzUmVxdWVzdBJaCgpkYXRhcG9pbnRzGAEgAygLMjouc2R2LmRhdG'
+    'Ficm9rZXIudjEuU3RyZWFtRGF0YXBvaW50c1JlcXVlc3QuRGF0YXBvaW50c0VudHJ5UgpkYXRh'
+    'cG9pbnRzGlsKD0RhdGFwb2ludHNFbnRyeRIQCgNrZXkYASABKAVSA2tleRIyCgV2YWx1ZRgCIA'
+    'EoCzIcLnNkdi5kYXRhYnJva2VyLnYxLkRhdGFwb2ludFIFdmFsdWU6AjgB');
+
+@$core.Deprecated('Use streamDatapointsReplyDescriptor instead')
+const StreamDatapointsReply$json = {
+  '1': 'StreamDatapointsReply',
+  '2': [
+    {'1': 'errors', '3': 1, '4': 3, '5': 11, '6': '.sdv.databroker.v1.StreamDatapointsReply.ErrorsEntry', '10': 'errors'},
+  ],
+  '3': [StreamDatapointsReply_ErrorsEntry$json],
+};
+
+@$core.Deprecated('Use streamDatapointsReplyDescriptor instead')
+const StreamDatapointsReply_ErrorsEntry$json = {
+  '1': 'ErrorsEntry',
+  '2': [
+    {'1': 'key', '3': 1, '4': 1, '5': 5, '10': 'key'},
+    {'1': 'value', '3': 2, '4': 1, '5': 14, '6': '.sdv.databroker.v1.DatapointError', '10': 'value'},
+  ],
+  '7': {'7': true},
+};
+
+/// Descriptor for `StreamDatapointsReply`. Decode as a `google.protobuf.DescriptorProto`.
+final $typed_data.Uint8List streamDatapointsReplyDescriptor = $convert.base64Decode(
+    'ChVTdHJlYW1EYXRhcG9pbnRzUmVwbHkSTAoGZXJyb3JzGAEgAygLMjQuc2R2LmRhdGFicm9rZX'
+    'IudjEuU3RyZWFtRGF0YXBvaW50c1JlcGx5LkVycm9yc0VudHJ5UgZlcnJvcnMaXAoLRXJyb3Jz'
+    'RW50cnkSEAoDa2V5GAEgASgFUgNrZXkSNwoFdmFsdWUYAiABKA4yIS5zZHYuZGF0YWJyb2tlci'
+    '52MS5EYXRhcG9pbnRFcnJvclIFdmFsdWU6AjgB');
+
+@$core.Deprecated('Use registerDatapointsRequestDescriptor instead')
+const RegisterDatapointsRequest$json = {
+  '1': 'RegisterDatapointsRequest',
+  '2': [
+    {'1': 'list', '3': 1, '4': 3, '5': 11, '6': '.sdv.databroker.v1.RegistrationMetadata', '10': 'list'},
+  ],
+};
+
+/// Descriptor for `RegisterDatapointsRequest`. Decode as a `google.protobuf.DescriptorProto`.
+final $typed_data.Uint8List registerDatapointsRequestDescriptor = $convert.base64Decode(
+    'ChlSZWdpc3RlckRhdGFwb2ludHNSZXF1ZXN0EjsKBGxpc3QYASADKAsyJy5zZHYuZGF0YWJyb2'
+    'tlci52MS5SZWdpc3RyYXRpb25NZXRhZGF0YVIEbGlzdA==');
+
+@$core.Deprecated('Use registrationMetadataDescriptor instead')
+const RegistrationMetadata$json = {
+  '1': 'RegistrationMetadata',
+  '2': [
+    {'1': 'name', '3': 1, '4': 1, '5': 9, '10': 'name'},
+    {'1': 'data_type', '3': 2, '4': 1, '5': 14, '6': '.sdv.databroker.v1.DataType', '10': 'dataType'},
+    {'1': 'description', '3': 3, '4': 1, '5': 9, '10': 'description'},
+    {'1': 'change_type', '3': 4, '4': 1, '5': 14, '6': '.sdv.databroker.v1.ChangeType', '10': 'changeType'},
+  ],
+};
+
+/// Descriptor for `RegistrationMetadata`. Decode as a `google.protobuf.DescriptorProto`.
+final $typed_data.Uint8List registrationMetadataDescriptor = $convert.base64Decode(
+    'ChRSZWdpc3RyYXRpb25NZXRhZGF0YRISCgRuYW1lGAEgASgJUgRuYW1lEjgKCWRhdGFfdHlwZR'
+    'gCIAEoDjIbLnNkdi5kYXRhYnJva2VyLnYxLkRhdGFUeXBlUghkYXRhVHlwZRIgCgtkZXNjcmlw'
+    'dGlvbhgDIAEoCVILZGVzY3JpcHRpb24SPgoLY2hhbmdlX3R5cGUYBCABKA4yHS5zZHYuZGF0YW'
+    'Jyb2tlci52MS5DaGFuZ2VUeXBlUgpjaGFuZ2VUeXBl');
+
+@$core.Deprecated('Use registerDatapointsReplyDescriptor instead')
+const RegisterDatapointsReply$json = {
+  '1': 'RegisterDatapointsReply',
+  '2': [
+    {'1': 'results', '3': 1, '4': 3, '5': 11, '6': '.sdv.databroker.v1.RegisterDatapointsReply.ResultsEntry', '10': 'results'},
+  ],
+  '3': [RegisterDatapointsReply_ResultsEntry$json],
+};
+
+@$core.Deprecated('Use registerDatapointsReplyDescriptor instead')
+const RegisterDatapointsReply_ResultsEntry$json = {
+  '1': 'ResultsEntry',
+  '2': [
+    {'1': 'key', '3': 1, '4': 1, '5': 9, '10': 'key'},
+    {'1': 'value', '3': 2, '4': 1, '5': 5, '10': 'value'},
+  ],
+  '7': {'7': true},
+};
+
+/// Descriptor for `RegisterDatapointsReply`. Decode as a `google.protobuf.DescriptorProto`.
+final $typed_data.Uint8List registerDatapointsReplyDescriptor = $convert.base64Decode(
+    'ChdSZWdpc3RlckRhdGFwb2ludHNSZXBseRJRCgdyZXN1bHRzGAEgAygLMjcuc2R2LmRhdGFicm'
+    '9rZXIudjEuUmVnaXN0ZXJEYXRhcG9pbnRzUmVwbHkuUmVzdWx0c0VudHJ5UgdyZXN1bHRzGjoK'
+    'DFJlc3VsdHNFbnRyeRIQCgNrZXkYASABKAlSA2tleRIUCgV2YWx1ZRgCIAEoBVIFdmFsdWU6Aj'
+    'gB');
+
diff --git a/protos/lib/src/generated/sdv/databroker/v1/types.pb.dart b/protos/lib/src/generated/sdv/databroker/v1/types.pb.dart
new file mode 100644
index 0000000..03ee374
--- /dev/null
+++ b/protos/lib/src/generated/sdv/databroker/v1/types.pb.dart
@@ -0,0 +1,851 @@
+//
+//  Generated code. Do not modify.
+//  source: sdv/databroker/v1/types.proto
+//
+// @dart = 2.12
+
+// ignore_for_file: annotate_overrides, camel_case_types, comment_references
+// ignore_for_file: constant_identifier_names, library_prefixes
+// ignore_for_file: non_constant_identifier_names, prefer_final_fields
+// ignore_for_file: unnecessary_import, unnecessary_this, unused_import
+
+import 'dart:core' as $core;
+
+// ignore: depend_on_referenced_packages
+import 'package:fixnum/fixnum.dart' as $fixnum;
+import 'package:protobuf/protobuf.dart' as $pb;
+
+import '../../../google/protobuf/timestamp.pb.dart' as $2;
+import 'types.pbenum.dart';
+
+export 'types.pbenum.dart';
+
+class StringArray extends $pb.GeneratedMessage {
+  factory StringArray({
+    $core.Iterable<$core.String>? values,
+  }) {
+    final $result = create();
+    if (values != null) {
+      $result.values.addAll(values);
+    }
+    return $result;
+  }
+  StringArray._() : super();
+  factory StringArray.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
+  factory StringArray.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
+
+  static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'StringArray', package: const $pb.PackageName(_omitMessageNames ? '' : 'sdv.databroker.v1'), createEmptyInstance: create)
+    ..pPS(1, _omitFieldNames ? '' : 'values')
+    ..hasRequiredFields = false
+  ;
+
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
+  'Will be removed in next major version')
+  StringArray clone() => StringArray()..mergeFromMessage(this);
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
+  'Will be removed in next major version')
+  StringArray copyWith(void Function(StringArray) updates) => super.copyWith((message) => updates(message as StringArray)) as StringArray;
+
+  $pb.BuilderInfo get info_ => _i;
+
+  @$core.pragma('dart2js:noInline')
+  static StringArray create() => StringArray._();
+  StringArray createEmptyInstance() => create();
+  static $pb.PbList<StringArray> createRepeated() => $pb.PbList<StringArray>();
+  @$core.pragma('dart2js:noInline')
+  static StringArray getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<StringArray>(create);
+  static StringArray? _defaultInstance;
+
+  @$pb.TagNumber(1)
+  $core.List<$core.String> get values => $_getList(0);
+}
+
+class BoolArray extends $pb.GeneratedMessage {
+  factory BoolArray({
+    $core.Iterable<$core.bool>? values,
+  }) {
+    final $result = create();
+    if (values != null) {
+      $result.values.addAll(values);
+    }
+    return $result;
+  }
+  BoolArray._() : super();
+  factory BoolArray.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
+  factory BoolArray.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
+
+  static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'BoolArray', package: const $pb.PackageName(_omitMessageNames ? '' : 'sdv.databroker.v1'), createEmptyInstance: create)
+    ..p<$core.bool>(1, _omitFieldNames ? '' : 'values', $pb.PbFieldType.KB)
+    ..hasRequiredFields = false
+  ;
+
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
+  'Will be removed in next major version')
+  BoolArray clone() => BoolArray()..mergeFromMessage(this);
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
+  'Will be removed in next major version')
+  BoolArray copyWith(void Function(BoolArray) updates) => super.copyWith((message) => updates(message as BoolArray)) as BoolArray;
+
+  $pb.BuilderInfo get info_ => _i;
+
+  @$core.pragma('dart2js:noInline')
+  static BoolArray create() => BoolArray._();
+  BoolArray createEmptyInstance() => create();
+  static $pb.PbList<BoolArray> createRepeated() => $pb.PbList<BoolArray>();
+  @$core.pragma('dart2js:noInline')
+  static BoolArray getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<BoolArray>(create);
+  static BoolArray? _defaultInstance;
+
+  @$pb.TagNumber(1)
+  $core.List<$core.bool> get values => $_getList(0);
+}
+
+class Int32Array extends $pb.GeneratedMessage {
+  factory Int32Array({
+    $core.Iterable<$core.int>? values,
+  }) {
+    final $result = create();
+    if (values != null) {
+      $result.values.addAll(values);
+    }
+    return $result;
+  }
+  Int32Array._() : super();
+  factory Int32Array.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
+  factory Int32Array.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
+
+  static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'Int32Array', package: const $pb.PackageName(_omitMessageNames ? '' : 'sdv.databroker.v1'), createEmptyInstance: create)
+    ..p<$core.int>(1, _omitFieldNames ? '' : 'values', $pb.PbFieldType.KS3)
+    ..hasRequiredFields = false
+  ;
+
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
+  'Will be removed in next major version')
+  Int32Array clone() => Int32Array()..mergeFromMessage(this);
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
+  'Will be removed in next major version')
+  Int32Array copyWith(void Function(Int32Array) updates) => super.copyWith((message) => updates(message as Int32Array)) as Int32Array;
+
+  $pb.BuilderInfo get info_ => _i;
+
+  @$core.pragma('dart2js:noInline')
+  static Int32Array create() => Int32Array._();
+  Int32Array createEmptyInstance() => create();
+  static $pb.PbList<Int32Array> createRepeated() => $pb.PbList<Int32Array>();
+  @$core.pragma('dart2js:noInline')
+  static Int32Array getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<Int32Array>(create);
+  static Int32Array? _defaultInstance;
+
+  @$pb.TagNumber(1)
+  $core.List<$core.int> get values => $_getList(0);
+}
+
+class Int64Array extends $pb.GeneratedMessage {
+  factory Int64Array({
+    $core.Iterable<$fixnum.Int64>? values,
+  }) {
+    final $result = create();
+    if (values != null) {
+      $result.values.addAll(values);
+    }
+    return $result;
+  }
+  Int64Array._() : super();
+  factory Int64Array.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
+  factory Int64Array.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
+
+  static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'Int64Array', package: const $pb.PackageName(_omitMessageNames ? '' : 'sdv.databroker.v1'), createEmptyInstance: create)
+    ..p<$fixnum.Int64>(1, _omitFieldNames ? '' : 'values', $pb.PbFieldType.KS6)
+    ..hasRequiredFields = false
+  ;
+
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
+  'Will be removed in next major version')
+  Int64Array clone() => Int64Array()..mergeFromMessage(this);
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
+  'Will be removed in next major version')
+  Int64Array copyWith(void Function(Int64Array) updates) => super.copyWith((message) => updates(message as Int64Array)) as Int64Array;
+
+  $pb.BuilderInfo get info_ => _i;
+
+  @$core.pragma('dart2js:noInline')
+  static Int64Array create() => Int64Array._();
+  Int64Array createEmptyInstance() => create();
+  static $pb.PbList<Int64Array> createRepeated() => $pb.PbList<Int64Array>();
+  @$core.pragma('dart2js:noInline')
+  static Int64Array getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<Int64Array>(create);
+  static Int64Array? _defaultInstance;
+
+  @$pb.TagNumber(1)
+  $core.List<$fixnum.Int64> get values => $_getList(0);
+}
+
+class Uint32Array extends $pb.GeneratedMessage {
+  factory Uint32Array({
+    $core.Iterable<$core.int>? values,
+  }) {
+    final $result = create();
+    if (values != null) {
+      $result.values.addAll(values);
+    }
+    return $result;
+  }
+  Uint32Array._() : super();
+  factory Uint32Array.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
+  factory Uint32Array.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
+
+  static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'Uint32Array', package: const $pb.PackageName(_omitMessageNames ? '' : 'sdv.databroker.v1'), createEmptyInstance: create)
+    ..p<$core.int>(1, _omitFieldNames ? '' : 'values', $pb.PbFieldType.KU3)
+    ..hasRequiredFields = false
+  ;
+
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
+  'Will be removed in next major version')
+  Uint32Array clone() => Uint32Array()..mergeFromMessage(this);
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
+  'Will be removed in next major version')
+  Uint32Array copyWith(void Function(Uint32Array) updates) => super.copyWith((message) => updates(message as Uint32Array)) as Uint32Array;
+
+  $pb.BuilderInfo get info_ => _i;
+
+  @$core.pragma('dart2js:noInline')
+  static Uint32Array create() => Uint32Array._();
+  Uint32Array createEmptyInstance() => create();
+  static $pb.PbList<Uint32Array> createRepeated() => $pb.PbList<Uint32Array>();
+  @$core.pragma('dart2js:noInline')
+  static Uint32Array getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<Uint32Array>(create);
+  static Uint32Array? _defaultInstance;
+
+  @$pb.TagNumber(1)
+  $core.List<$core.int> get values => $_getList(0);
+}
+
+class Uint64Array extends $pb.GeneratedMessage {
+  factory Uint64Array({
+    $core.Iterable<$fixnum.Int64>? values,
+  }) {
+    final $result = create();
+    if (values != null) {
+      $result.values.addAll(values);
+    }
+    return $result;
+  }
+  Uint64Array._() : super();
+  factory Uint64Array.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
+  factory Uint64Array.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
+
+  static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'Uint64Array', package: const $pb.PackageName(_omitMessageNames ? '' : 'sdv.databroker.v1'), createEmptyInstance: create)
+    ..p<$fixnum.Int64>(1, _omitFieldNames ? '' : 'values', $pb.PbFieldType.KU6)
+    ..hasRequiredFields = false
+  ;
+
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
+  'Will be removed in next major version')
+  Uint64Array clone() => Uint64Array()..mergeFromMessage(this);
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
+  'Will be removed in next major version')
+  Uint64Array copyWith(void Function(Uint64Array) updates) => super.copyWith((message) => updates(message as Uint64Array)) as Uint64Array;
+
+  $pb.BuilderInfo get info_ => _i;
+
+  @$core.pragma('dart2js:noInline')
+  static Uint64Array create() => Uint64Array._();
+  Uint64Array createEmptyInstance() => create();
+  static $pb.PbList<Uint64Array> createRepeated() => $pb.PbList<Uint64Array>();
+  @$core.pragma('dart2js:noInline')
+  static Uint64Array getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<Uint64Array>(create);
+  static Uint64Array? _defaultInstance;
+
+  @$pb.TagNumber(1)
+  $core.List<$fixnum.Int64> get values => $_getList(0);
+}
+
+class FloatArray extends $pb.GeneratedMessage {
+  factory FloatArray({
+    $core.Iterable<$core.double>? values,
+  }) {
+    final $result = create();
+    if (values != null) {
+      $result.values.addAll(values);
+    }
+    return $result;
+  }
+  FloatArray._() : super();
+  factory FloatArray.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
+  factory FloatArray.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
+
+  static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'FloatArray', package: const $pb.PackageName(_omitMessageNames ? '' : 'sdv.databroker.v1'), createEmptyInstance: create)
+    ..p<$core.double>(1, _omitFieldNames ? '' : 'values', $pb.PbFieldType.KF)
+    ..hasRequiredFields = false
+  ;
+
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
+  'Will be removed in next major version')
+  FloatArray clone() => FloatArray()..mergeFromMessage(this);
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
+  'Will be removed in next major version')
+  FloatArray copyWith(void Function(FloatArray) updates) => super.copyWith((message) => updates(message as FloatArray)) as FloatArray;
+
+  $pb.BuilderInfo get info_ => _i;
+
+  @$core.pragma('dart2js:noInline')
+  static FloatArray create() => FloatArray._();
+  FloatArray createEmptyInstance() => create();
+  static $pb.PbList<FloatArray> createRepeated() => $pb.PbList<FloatArray>();
+  @$core.pragma('dart2js:noInline')
+  static FloatArray getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<FloatArray>(create);
+  static FloatArray? _defaultInstance;
+
+  @$pb.TagNumber(1)
+  $core.List<$core.double> get values => $_getList(0);
+}
+
+class DoubleArray extends $pb.GeneratedMessage {
+  factory DoubleArray({
+    $core.Iterable<$core.double>? values,
+  }) {
+    final $result = create();
+    if (values != null) {
+      $result.values.addAll(values);
+    }
+    return $result;
+  }
+  DoubleArray._() : super();
+  factory DoubleArray.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
+  factory DoubleArray.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
+
+  static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'DoubleArray', package: const $pb.PackageName(_omitMessageNames ? '' : 'sdv.databroker.v1'), createEmptyInstance: create)
+    ..p<$core.double>(1, _omitFieldNames ? '' : 'values', $pb.PbFieldType.KD)
+    ..hasRequiredFields = false
+  ;
+
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
+  'Will be removed in next major version')
+  DoubleArray clone() => DoubleArray()..mergeFromMessage(this);
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
+  'Will be removed in next major version')
+  DoubleArray copyWith(void Function(DoubleArray) updates) => super.copyWith((message) => updates(message as DoubleArray)) as DoubleArray;
+
+  $pb.BuilderInfo get info_ => _i;
+
+  @$core.pragma('dart2js:noInline')
+  static DoubleArray create() => DoubleArray._();
+  DoubleArray createEmptyInstance() => create();
+  static $pb.PbList<DoubleArray> createRepeated() => $pb.PbList<DoubleArray>();
+  @$core.pragma('dart2js:noInline')
+  static DoubleArray getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<DoubleArray>(create);
+  static DoubleArray? _defaultInstance;
+
+  @$pb.TagNumber(1)
+  $core.List<$core.double> get values => $_getList(0);
+}
+
+enum Datapoint_Value {
+  failureValue, 
+  stringValue, 
+  boolValue, 
+  int32Value, 
+  int64Value, 
+  uint32Value, 
+  uint64Value, 
+  floatValue, 
+  doubleValue, 
+  stringArray, 
+  boolArray, 
+  int32Array, 
+  int64Array, 
+  uint32Array, 
+  uint64Array, 
+  floatArray, 
+  doubleArray, 
+  notSet
+}
+
+class Datapoint extends $pb.GeneratedMessage {
+  factory Datapoint({
+    $2.Timestamp? timestamp,
+    Datapoint_Failure? failureValue,
+    $core.String? stringValue,
+    $core.bool? boolValue,
+    $core.int? int32Value,
+    $fixnum.Int64? int64Value,
+    $core.int? uint32Value,
+    $fixnum.Int64? uint64Value,
+    $core.double? floatValue,
+    $core.double? doubleValue,
+    StringArray? stringArray,
+    BoolArray? boolArray,
+    Int32Array? int32Array,
+    Int64Array? int64Array,
+    Uint32Array? uint32Array,
+    Uint64Array? uint64Array,
+    FloatArray? floatArray,
+    DoubleArray? doubleArray,
+  }) {
+    final $result = create();
+    if (timestamp != null) {
+      $result.timestamp = timestamp;
+    }
+    if (failureValue != null) {
+      $result.failureValue = failureValue;
+    }
+    if (stringValue != null) {
+      $result.stringValue = stringValue;
+    }
+    if (boolValue != null) {
+      $result.boolValue = boolValue;
+    }
+    if (int32Value != null) {
+      $result.int32Value = int32Value;
+    }
+    if (int64Value != null) {
+      $result.int64Value = int64Value;
+    }
+    if (uint32Value != null) {
+      $result.uint32Value = uint32Value;
+    }
+    if (uint64Value != null) {
+      $result.uint64Value = uint64Value;
+    }
+    if (floatValue != null) {
+      $result.floatValue = floatValue;
+    }
+    if (doubleValue != null) {
+      $result.doubleValue = doubleValue;
+    }
+    if (stringArray != null) {
+      $result.stringArray = stringArray;
+    }
+    if (boolArray != null) {
+      $result.boolArray = boolArray;
+    }
+    if (int32Array != null) {
+      $result.int32Array = int32Array;
+    }
+    if (int64Array != null) {
+      $result.int64Array = int64Array;
+    }
+    if (uint32Array != null) {
+      $result.uint32Array = uint32Array;
+    }
+    if (uint64Array != null) {
+      $result.uint64Array = uint64Array;
+    }
+    if (floatArray != null) {
+      $result.floatArray = floatArray;
+    }
+    if (doubleArray != null) {
+      $result.doubleArray = doubleArray;
+    }
+    return $result;
+  }
+  Datapoint._() : super();
+  factory Datapoint.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
+  factory Datapoint.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
+
+  static const $core.Map<$core.int, Datapoint_Value> _Datapoint_ValueByTag = {
+    10 : Datapoint_Value.failureValue,
+    11 : Datapoint_Value.stringValue,
+    12 : Datapoint_Value.boolValue,
+    13 : Datapoint_Value.int32Value,
+    14 : Datapoint_Value.int64Value,
+    15 : Datapoint_Value.uint32Value,
+    16 : Datapoint_Value.uint64Value,
+    17 : Datapoint_Value.floatValue,
+    18 : Datapoint_Value.doubleValue,
+    21 : Datapoint_Value.stringArray,
+    22 : Datapoint_Value.boolArray,
+    23 : Datapoint_Value.int32Array,
+    24 : Datapoint_Value.int64Array,
+    25 : Datapoint_Value.uint32Array,
+    26 : Datapoint_Value.uint64Array,
+    27 : Datapoint_Value.floatArray,
+    28 : Datapoint_Value.doubleArray,
+    0 : Datapoint_Value.notSet
+  };
+  static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'Datapoint', package: const $pb.PackageName(_omitMessageNames ? '' : 'sdv.databroker.v1'), createEmptyInstance: create)
+    ..oo(0, [10, 11, 12, 13, 14, 15, 16, 17, 18, 21, 22, 23, 24, 25, 26, 27, 28])
+    ..aOM<$2.Timestamp>(1, _omitFieldNames ? '' : 'timestamp', subBuilder: $2.Timestamp.create)
+    ..e<Datapoint_Failure>(10, _omitFieldNames ? '' : 'failureValue', $pb.PbFieldType.OE, defaultOrMaker: Datapoint_Failure.INVALID_VALUE, valueOf: Datapoint_Failure.valueOf, enumValues: Datapoint_Failure.values)
+    ..aOS(11, _omitFieldNames ? '' : 'stringValue')
+    ..aOB(12, _omitFieldNames ? '' : 'boolValue')
+    ..a<$core.int>(13, _omitFieldNames ? '' : 'int32Value', $pb.PbFieldType.OS3)
+    ..a<$fixnum.Int64>(14, _omitFieldNames ? '' : 'int64Value', $pb.PbFieldType.OS6, defaultOrMaker: $fixnum.Int64.ZERO)
+    ..a<$core.int>(15, _omitFieldNames ? '' : 'uint32Value', $pb.PbFieldType.OU3)
+    ..a<$fixnum.Int64>(16, _omitFieldNames ? '' : 'uint64Value', $pb.PbFieldType.OU6, defaultOrMaker: $fixnum.Int64.ZERO)
+    ..a<$core.double>(17, _omitFieldNames ? '' : 'floatValue', $pb.PbFieldType.OF)
+    ..a<$core.double>(18, _omitFieldNames ? '' : 'doubleValue', $pb.PbFieldType.OD)
+    ..aOM<StringArray>(21, _omitFieldNames ? '' : 'stringArray', subBuilder: StringArray.create)
+    ..aOM<BoolArray>(22, _omitFieldNames ? '' : 'boolArray', subBuilder: BoolArray.create)
+    ..aOM<Int32Array>(23, _omitFieldNames ? '' : 'int32Array', subBuilder: Int32Array.create)
+    ..aOM<Int64Array>(24, _omitFieldNames ? '' : 'int64Array', subBuilder: Int64Array.create)
+    ..aOM<Uint32Array>(25, _omitFieldNames ? '' : 'uint32Array', subBuilder: Uint32Array.create)
+    ..aOM<Uint64Array>(26, _omitFieldNames ? '' : 'uint64Array', subBuilder: Uint64Array.create)
+    ..aOM<FloatArray>(27, _omitFieldNames ? '' : 'floatArray', subBuilder: FloatArray.create)
+    ..aOM<DoubleArray>(28, _omitFieldNames ? '' : 'doubleArray', subBuilder: DoubleArray.create)
+    ..hasRequiredFields = false
+  ;
+
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
+  'Will be removed in next major version')
+  Datapoint clone() => Datapoint()..mergeFromMessage(this);
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
+  'Will be removed in next major version')
+  Datapoint copyWith(void Function(Datapoint) updates) => super.copyWith((message) => updates(message as Datapoint)) as Datapoint;
+
+  $pb.BuilderInfo get info_ => _i;
+
+  @$core.pragma('dart2js:noInline')
+  static Datapoint create() => Datapoint._();
+  Datapoint createEmptyInstance() => create();
+  static $pb.PbList<Datapoint> createRepeated() => $pb.PbList<Datapoint>();
+  @$core.pragma('dart2js:noInline')
+  static Datapoint getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<Datapoint>(create);
+  static Datapoint? _defaultInstance;
+
+  Datapoint_Value whichValue() => _Datapoint_ValueByTag[$_whichOneof(0)]!;
+  void clearValue() => clearField($_whichOneof(0));
+
+  /// Timestamp of the value
+  @$pb.TagNumber(1)
+  $2.Timestamp get timestamp => $_getN(0);
+  @$pb.TagNumber(1)
+  set timestamp($2.Timestamp v) { setField(1, v); }
+  @$pb.TagNumber(1)
+  $core.bool hasTimestamp() => $_has(0);
+  @$pb.TagNumber(1)
+  void clearTimestamp() => clearField(1);
+  @$pb.TagNumber(1)
+  $2.Timestamp ensureTimestamp() => $_ensure(0);
+
+  @$pb.TagNumber(10)
+  Datapoint_Failure get failureValue => $_getN(1);
+  @$pb.TagNumber(10)
+  set failureValue(Datapoint_Failure v) { setField(10, v); }
+  @$pb.TagNumber(10)
+  $core.bool hasFailureValue() => $_has(1);
+  @$pb.TagNumber(10)
+  void clearFailureValue() => clearField(10);
+
+  @$pb.TagNumber(11)
+  $core.String get stringValue => $_getSZ(2);
+  @$pb.TagNumber(11)
+  set stringValue($core.String v) { $_setString(2, v); }
+  @$pb.TagNumber(11)
+  $core.bool hasStringValue() => $_has(2);
+  @$pb.TagNumber(11)
+  void clearStringValue() => clearField(11);
+
+  @$pb.TagNumber(12)
+  $core.bool get boolValue => $_getBF(3);
+  @$pb.TagNumber(12)
+  set boolValue($core.bool v) { $_setBool(3, v); }
+  @$pb.TagNumber(12)
+  $core.bool hasBoolValue() => $_has(3);
+  @$pb.TagNumber(12)
+  void clearBoolValue() => clearField(12);
+
+  @$pb.TagNumber(13)
+  $core.int get int32Value => $_getIZ(4);
+  @$pb.TagNumber(13)
+  set int32Value($core.int v) { $_setSignedInt32(4, v); }
+  @$pb.TagNumber(13)
+  $core.bool hasInt32Value() => $_has(4);
+  @$pb.TagNumber(13)
+  void clearInt32Value() => clearField(13);
+
+  @$pb.TagNumber(14)
+  $fixnum.Int64 get int64Value => $_getI64(5);
+  @$pb.TagNumber(14)
+  set int64Value($fixnum.Int64 v) { $_setInt64(5, v); }
+  @$pb.TagNumber(14)
+  $core.bool hasInt64Value() => $_has(5);
+  @$pb.TagNumber(14)
+  void clearInt64Value() => clearField(14);
+
+  @$pb.TagNumber(15)
+  $core.int get uint32Value => $_getIZ(6);
+  @$pb.TagNumber(15)
+  set uint32Value($core.int v) { $_setUnsignedInt32(6, v); }
+  @$pb.TagNumber(15)
+  $core.bool hasUint32Value() => $_has(6);
+  @$pb.TagNumber(15)
+  void clearUint32Value() => clearField(15);
+
+  @$pb.TagNumber(16)
+  $fixnum.Int64 get uint64Value => $_getI64(7);
+  @$pb.TagNumber(16)
+  set uint64Value($fixnum.Int64 v) { $_setInt64(7, v); }
+  @$pb.TagNumber(16)
+  $core.bool hasUint64Value() => $_has(7);
+  @$pb.TagNumber(16)
+  void clearUint64Value() => clearField(16);
+
+  @$pb.TagNumber(17)
+  $core.double get floatValue => $_getN(8);
+  @$pb.TagNumber(17)
+  set floatValue($core.double v) { $_setFloat(8, v); }
+  @$pb.TagNumber(17)
+  $core.bool hasFloatValue() => $_has(8);
+  @$pb.TagNumber(17)
+  void clearFloatValue() => clearField(17);
+
+  @$pb.TagNumber(18)
+  $core.double get doubleValue => $_getN(9);
+  @$pb.TagNumber(18)
+  set doubleValue($core.double v) { $_setDouble(9, v); }
+  @$pb.TagNumber(18)
+  $core.bool hasDoubleValue() => $_has(9);
+  @$pb.TagNumber(18)
+  void clearDoubleValue() => clearField(18);
+
+  @$pb.TagNumber(21)
+  StringArray get stringArray => $_getN(10);
+  @$pb.TagNumber(21)
+  set stringArray(StringArray v) { setField(21, v); }
+  @$pb.TagNumber(21)
+  $core.bool hasStringArray() => $_has(10);
+  @$pb.TagNumber(21)
+  void clearStringArray() => clearField(21);
+  @$pb.TagNumber(21)
+  StringArray ensureStringArray() => $_ensure(10);
+
+  @$pb.TagNumber(22)
+  BoolArray get boolArray => $_getN(11);
+  @$pb.TagNumber(22)
+  set boolArray(BoolArray v) { setField(22, v); }
+  @$pb.TagNumber(22)
+  $core.bool hasBoolArray() => $_has(11);
+  @$pb.TagNumber(22)
+  void clearBoolArray() => clearField(22);
+  @$pb.TagNumber(22)
+  BoolArray ensureBoolArray() => $_ensure(11);
+
+  @$pb.TagNumber(23)
+  Int32Array get int32Array => $_getN(12);
+  @$pb.TagNumber(23)
+  set int32Array(Int32Array v) { setField(23, v); }
+  @$pb.TagNumber(23)
+  $core.bool hasInt32Array() => $_has(12);
+  @$pb.TagNumber(23)
+  void clearInt32Array() => clearField(23);
+  @$pb.TagNumber(23)
+  Int32Array ensureInt32Array() => $_ensure(12);
+
+  @$pb.TagNumber(24)
+  Int64Array get int64Array => $_getN(13);
+  @$pb.TagNumber(24)
+  set int64Array(Int64Array v) { setField(24, v); }
+  @$pb.TagNumber(24)
+  $core.bool hasInt64Array() => $_has(13);
+  @$pb.TagNumber(24)
+  void clearInt64Array() => clearField(24);
+  @$pb.TagNumber(24)
+  Int64Array ensureInt64Array() => $_ensure(13);
+
+  @$pb.TagNumber(25)
+  Uint32Array get uint32Array => $_getN(14);
+  @$pb.TagNumber(25)
+  set uint32Array(Uint32Array v) { setField(25, v); }
+  @$pb.TagNumber(25)
+  $core.bool hasUint32Array() => $_has(14);
+  @$pb.TagNumber(25)
+  void clearUint32Array() => clearField(25);
+  @$pb.TagNumber(25)
+  Uint32Array ensureUint32Array() => $_ensure(14);
+
+  @$pb.TagNumber(26)
+  Uint64Array get uint64Array => $_getN(15);
+  @$pb.TagNumber(26)
+  set uint64Array(Uint64Array v) { setField(26, v); }
+  @$pb.TagNumber(26)
+  $core.bool hasUint64Array() => $_has(15);
+  @$pb.TagNumber(26)
+  void clearUint64Array() => clearField(26);
+  @$pb.TagNumber(26)
+  Uint64Array ensureUint64Array() => $_ensure(15);
+
+  @$pb.TagNumber(27)
+  FloatArray get floatArray => $_getN(16);
+  @$pb.TagNumber(27)
+  set floatArray(FloatArray v) { setField(27, v); }
+  @$pb.TagNumber(27)
+  $core.bool hasFloatArray() => $_has(16);
+  @$pb.TagNumber(27)
+  void clearFloatArray() => clearField(27);
+  @$pb.TagNumber(27)
+  FloatArray ensureFloatArray() => $_ensure(16);
+
+  @$pb.TagNumber(28)
+  DoubleArray get doubleArray => $_getN(17);
+  @$pb.TagNumber(28)
+  set doubleArray(DoubleArray v) { setField(28, v); }
+  @$pb.TagNumber(28)
+  $core.bool hasDoubleArray() => $_has(17);
+  @$pb.TagNumber(28)
+  void clearDoubleArray() => clearField(28);
+  @$pb.TagNumber(28)
+  DoubleArray ensureDoubleArray() => $_ensure(17);
+}
+
+class Metadata extends $pb.GeneratedMessage {
+  factory Metadata({
+    $core.int? id,
+    EntryType? entryType,
+    $core.String? name,
+    DataType? dataType,
+    ChangeType? changeType,
+    $core.String? description,
+  }) {
+    final $result = create();
+    if (id != null) {
+      $result.id = id;
+    }
+    if (entryType != null) {
+      $result.entryType = entryType;
+    }
+    if (name != null) {
+      $result.name = name;
+    }
+    if (dataType != null) {
+      $result.dataType = dataType;
+    }
+    if (changeType != null) {
+      $result.changeType = changeType;
+    }
+    if (description != null) {
+      $result.description = description;
+    }
+    return $result;
+  }
+  Metadata._() : super();
+  factory Metadata.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
+  factory Metadata.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
+
+  static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'Metadata', package: const $pb.PackageName(_omitMessageNames ? '' : 'sdv.databroker.v1'), createEmptyInstance: create)
+    ..a<$core.int>(1, _omitFieldNames ? '' : 'id', $pb.PbFieldType.O3)
+    ..e<EntryType>(2, _omitFieldNames ? '' : 'entryType', $pb.PbFieldType.OE, defaultOrMaker: EntryType.ENTRY_TYPE_UNSPECIFIED, valueOf: EntryType.valueOf, enumValues: EntryType.values)
+    ..aOS(4, _omitFieldNames ? '' : 'name')
+    ..e<DataType>(5, _omitFieldNames ? '' : 'dataType', $pb.PbFieldType.OE, defaultOrMaker: DataType.STRING, valueOf: DataType.valueOf, enumValues: DataType.values)
+    ..e<ChangeType>(6, _omitFieldNames ? '' : 'changeType', $pb.PbFieldType.OE, defaultOrMaker: ChangeType.STATIC, valueOf: ChangeType.valueOf, enumValues: ChangeType.values)
+    ..aOS(7, _omitFieldNames ? '' : 'description')
+    ..hasRequiredFields = false
+  ;
+
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
+  'Will be removed in next major version')
+  Metadata clone() => Metadata()..mergeFromMessage(this);
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
+  'Will be removed in next major version')
+  Metadata copyWith(void Function(Metadata) updates) => super.copyWith((message) => updates(message as Metadata)) as Metadata;
+
+  $pb.BuilderInfo get info_ => _i;
+
+  @$core.pragma('dart2js:noInline')
+  static Metadata create() => Metadata._();
+  Metadata createEmptyInstance() => create();
+  static $pb.PbList<Metadata> createRepeated() => $pb.PbList<Metadata>();
+  @$core.pragma('dart2js:noInline')
+  static Metadata getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<Metadata>(create);
+  static Metadata? _defaultInstance;
+
+  /// Id to be used in "get" and "subscribe" requests. Ids stay valid during
+  /// one power cycle, only.
+  @$pb.TagNumber(1)
+  $core.int get id => $_getIZ(0);
+  @$pb.TagNumber(1)
+  set id($core.int v) { $_setSignedInt32(0, v); }
+  @$pb.TagNumber(1)
+  $core.bool hasId() => $_has(0);
+  @$pb.TagNumber(1)
+  void clearId() => clearField(1);
+
+  @$pb.TagNumber(2)
+  EntryType get entryType => $_getN(1);
+  @$pb.TagNumber(2)
+  set entryType(EntryType v) { setField(2, v); }
+  @$pb.TagNumber(2)
+  $core.bool hasEntryType() => $_has(1);
+  @$pb.TagNumber(2)
+  void clearEntryType() => clearField(2);
+
+  @$pb.TagNumber(4)
+  $core.String get name => $_getSZ(2);
+  @$pb.TagNumber(4)
+  set name($core.String v) { $_setString(2, v); }
+  @$pb.TagNumber(4)
+  $core.bool hasName() => $_has(2);
+  @$pb.TagNumber(4)
+  void clearName() => clearField(4);
+
+  @$pb.TagNumber(5)
+  DataType get dataType => $_getN(3);
+  @$pb.TagNumber(5)
+  set dataType(DataType v) { setField(5, v); }
+  @$pb.TagNumber(5)
+  $core.bool hasDataType() => $_has(3);
+  @$pb.TagNumber(5)
+  void clearDataType() => clearField(5);
+
+  @$pb.TagNumber(6)
+  ChangeType get changeType => $_getN(4);
+  @$pb.TagNumber(6)
+  set changeType(ChangeType v) { setField(6, v); }
+  @$pb.TagNumber(6)
+  $core.bool hasChangeType() => $_has(4);
+  @$pb.TagNumber(6)
+  void clearChangeType() => clearField(6);
+
+  @$pb.TagNumber(7)
+  $core.String get description => $_getSZ(5);
+  @$pb.TagNumber(7)
+  set description($core.String v) { $_setString(5, v); }
+  @$pb.TagNumber(7)
+  $core.bool hasDescription() => $_has(5);
+  @$pb.TagNumber(7)
+  void clearDescription() => clearField(7);
+}
+
+
+const _omitFieldNames = $core.bool.fromEnvironment('protobuf.omit_field_names');
+const _omitMessageNames = $core.bool.fromEnvironment('protobuf.omit_message_names');
diff --git a/protos/lib/src/generated/sdv/databroker/v1/types.pbenum.dart b/protos/lib/src/generated/sdv/databroker/v1/types.pbenum.dart
new file mode 100644
index 0000000..b3fc8b4
--- /dev/null
+++ b/protos/lib/src/generated/sdv/databroker/v1/types.pbenum.dart
@@ -0,0 +1,162 @@
+//
+//  Generated code. Do not modify.
+//  source: sdv/databroker/v1/types.proto
+//
+// @dart = 2.12
+
+// ignore_for_file: annotate_overrides, camel_case_types, comment_references
+// ignore_for_file: constant_identifier_names, library_prefixes
+// ignore_for_file: non_constant_identifier_names, prefer_final_fields
+// ignore_for_file: unnecessary_import, unnecessary_this, unused_import
+
+import 'dart:core' as $core;
+
+import 'package:protobuf/protobuf.dart' as $pb;
+
+///  Data type of a signal
+///
+///  Protobuf doesn't support int8, int16, uint8 or uint16.
+///  These are mapped to sint32 and uint32 respectively.
+class DataType extends $pb.ProtobufEnum {
+  static const DataType STRING = DataType._(0, _omitEnumNames ? '' : 'STRING');
+  static const DataType BOOL = DataType._(1, _omitEnumNames ? '' : 'BOOL');
+  static const DataType INT8 = DataType._(2, _omitEnumNames ? '' : 'INT8');
+  static const DataType INT16 = DataType._(3, _omitEnumNames ? '' : 'INT16');
+  static const DataType INT32 = DataType._(4, _omitEnumNames ? '' : 'INT32');
+  static const DataType INT64 = DataType._(5, _omitEnumNames ? '' : 'INT64');
+  static const DataType UINT8 = DataType._(6, _omitEnumNames ? '' : 'UINT8');
+  static const DataType UINT16 = DataType._(7, _omitEnumNames ? '' : 'UINT16');
+  static const DataType UINT32 = DataType._(8, _omitEnumNames ? '' : 'UINT32');
+  static const DataType UINT64 = DataType._(9, _omitEnumNames ? '' : 'UINT64');
+  static const DataType FLOAT = DataType._(10, _omitEnumNames ? '' : 'FLOAT');
+  static const DataType DOUBLE = DataType._(11, _omitEnumNames ? '' : 'DOUBLE');
+  static const DataType TIMESTAMP = DataType._(12, _omitEnumNames ? '' : 'TIMESTAMP');
+  static const DataType STRING_ARRAY = DataType._(20, _omitEnumNames ? '' : 'STRING_ARRAY');
+  static const DataType BOOL_ARRAY = DataType._(21, _omitEnumNames ? '' : 'BOOL_ARRAY');
+  static const DataType INT8_ARRAY = DataType._(22, _omitEnumNames ? '' : 'INT8_ARRAY');
+  static const DataType INT16_ARRAY = DataType._(23, _omitEnumNames ? '' : 'INT16_ARRAY');
+  static const DataType INT32_ARRAY = DataType._(24, _omitEnumNames ? '' : 'INT32_ARRAY');
+  static const DataType INT64_ARRAY = DataType._(25, _omitEnumNames ? '' : 'INT64_ARRAY');
+  static const DataType UINT8_ARRAY = DataType._(26, _omitEnumNames ? '' : 'UINT8_ARRAY');
+  static const DataType UINT16_ARRAY = DataType._(27, _omitEnumNames ? '' : 'UINT16_ARRAY');
+  static const DataType UINT32_ARRAY = DataType._(28, _omitEnumNames ? '' : 'UINT32_ARRAY');
+  static const DataType UINT64_ARRAY = DataType._(29, _omitEnumNames ? '' : 'UINT64_ARRAY');
+  static const DataType FLOAT_ARRAY = DataType._(30, _omitEnumNames ? '' : 'FLOAT_ARRAY');
+  static const DataType DOUBLE_ARRAY = DataType._(31, _omitEnumNames ? '' : 'DOUBLE_ARRAY');
+  static const DataType TIMESTAMP_ARRAY = DataType._(32, _omitEnumNames ? '' : 'TIMESTAMP_ARRAY');
+
+  static const $core.List<DataType> values = <DataType> [
+    STRING,
+    BOOL,
+    INT8,
+    INT16,
+    INT32,
+    INT64,
+    UINT8,
+    UINT16,
+    UINT32,
+    UINT64,
+    FLOAT,
+    DOUBLE,
+    TIMESTAMP,
+    STRING_ARRAY,
+    BOOL_ARRAY,
+    INT8_ARRAY,
+    INT16_ARRAY,
+    INT32_ARRAY,
+    INT64_ARRAY,
+    UINT8_ARRAY,
+    UINT16_ARRAY,
+    UINT32_ARRAY,
+    UINT64_ARRAY,
+    FLOAT_ARRAY,
+    DOUBLE_ARRAY,
+    TIMESTAMP_ARRAY,
+  ];
+
+  static final $core.Map<$core.int, DataType> _byValue = $pb.ProtobufEnum.initByValue(values);
+  static DataType? valueOf($core.int value) => _byValue[value];
+
+  const DataType._($core.int v, $core.String n) : super(v, n);
+}
+
+class DatapointError extends $pb.ProtobufEnum {
+  static const DatapointError UNKNOWN_DATAPOINT = DatapointError._(0, _omitEnumNames ? '' : 'UNKNOWN_DATAPOINT');
+  static const DatapointError INVALID_TYPE = DatapointError._(1, _omitEnumNames ? '' : 'INVALID_TYPE');
+  static const DatapointError ACCESS_DENIED = DatapointError._(2, _omitEnumNames ? '' : 'ACCESS_DENIED');
+  static const DatapointError INTERNAL_ERROR = DatapointError._(3, _omitEnumNames ? '' : 'INTERNAL_ERROR');
+  static const DatapointError OUT_OF_BOUNDS = DatapointError._(4, _omitEnumNames ? '' : 'OUT_OF_BOUNDS');
+
+  static const $core.List<DatapointError> values = <DatapointError> [
+    UNKNOWN_DATAPOINT,
+    INVALID_TYPE,
+    ACCESS_DENIED,
+    INTERNAL_ERROR,
+    OUT_OF_BOUNDS,
+  ];
+
+  static final $core.Map<$core.int, DatapointError> _byValue = $pb.ProtobufEnum.initByValue(values);
+  static DatapointError? valueOf($core.int value) => _byValue[value];
+
+  const DatapointError._($core.int v, $core.String n) : super(v, n);
+}
+
+class EntryType extends $pb.ProtobufEnum {
+  static const EntryType ENTRY_TYPE_UNSPECIFIED = EntryType._(0, _omitEnumNames ? '' : 'ENTRY_TYPE_UNSPECIFIED');
+  static const EntryType ENTRY_TYPE_SENSOR = EntryType._(1, _omitEnumNames ? '' : 'ENTRY_TYPE_SENSOR');
+  static const EntryType ENTRY_TYPE_ACTUATOR = EntryType._(2, _omitEnumNames ? '' : 'ENTRY_TYPE_ACTUATOR');
+  static const EntryType ENTRY_TYPE_ATTRIBUTE = EntryType._(3, _omitEnumNames ? '' : 'ENTRY_TYPE_ATTRIBUTE');
+
+  static const $core.List<EntryType> values = <EntryType> [
+    ENTRY_TYPE_UNSPECIFIED,
+    ENTRY_TYPE_SENSOR,
+    ENTRY_TYPE_ACTUATOR,
+    ENTRY_TYPE_ATTRIBUTE,
+  ];
+
+  static final $core.Map<$core.int, EntryType> _byValue = $pb.ProtobufEnum.initByValue(values);
+  static EntryType? valueOf($core.int value) => _byValue[value];
+
+  const EntryType._($core.int v, $core.String n) : super(v, n);
+}
+
+class ChangeType extends $pb.ProtobufEnum {
+  static const ChangeType STATIC = ChangeType._(0, _omitEnumNames ? '' : 'STATIC');
+  static const ChangeType ON_CHANGE = ChangeType._(1, _omitEnumNames ? '' : 'ON_CHANGE');
+  static const ChangeType CONTINUOUS = ChangeType._(2, _omitEnumNames ? '' : 'CONTINUOUS');
+
+  static const $core.List<ChangeType> values = <ChangeType> [
+    STATIC,
+    ON_CHANGE,
+    CONTINUOUS,
+  ];
+
+  static final $core.Map<$core.int, ChangeType> _byValue = $pb.ProtobufEnum.initByValue(values);
+  static ChangeType? valueOf($core.int value) => _byValue[value];
+
+  const ChangeType._($core.int v, $core.String n) : super(v, n);
+}
+
+class Datapoint_Failure extends $pb.ProtobufEnum {
+  static const Datapoint_Failure INVALID_VALUE = Datapoint_Failure._(0, _omitEnumNames ? '' : 'INVALID_VALUE');
+  static const Datapoint_Failure NOT_AVAILABLE = Datapoint_Failure._(1, _omitEnumNames ? '' : 'NOT_AVAILABLE');
+  static const Datapoint_Failure UNKNOWN_DATAPOINT = Datapoint_Failure._(2, _omitEnumNames ? '' : 'UNKNOWN_DATAPOINT');
+  static const Datapoint_Failure ACCESS_DENIED = Datapoint_Failure._(3, _omitEnumNames ? '' : 'ACCESS_DENIED');
+  static const Datapoint_Failure INTERNAL_ERROR = Datapoint_Failure._(4, _omitEnumNames ? '' : 'INTERNAL_ERROR');
+
+  static const $core.List<Datapoint_Failure> values = <Datapoint_Failure> [
+    INVALID_VALUE,
+    NOT_AVAILABLE,
+    UNKNOWN_DATAPOINT,
+    ACCESS_DENIED,
+    INTERNAL_ERROR,
+  ];
+
+  static final $core.Map<$core.int, Datapoint_Failure> _byValue = $pb.ProtobufEnum.initByValue(values);
+  static Datapoint_Failure? valueOf($core.int value) => _byValue[value];
+
+  const Datapoint_Failure._($core.int v, $core.String n) : super(v, n);
+}
+
+
+const _omitEnumNames = $core.bool.fromEnvironment('protobuf.omit_enum_names');
diff --git a/protos/lib/src/generated/sdv/databroker/v1/types.pbjson.dart b/protos/lib/src/generated/sdv/databroker/v1/types.pbjson.dart
new file mode 100644
index 0000000..2cb774f
--- /dev/null
+++ b/protos/lib/src/generated/sdv/databroker/v1/types.pbjson.dart
@@ -0,0 +1,290 @@
+//
+//  Generated code. Do not modify.
+//  source: sdv/databroker/v1/types.proto
+//
+// @dart = 2.12
+
+// ignore_for_file: annotate_overrides, camel_case_types, comment_references
+// ignore_for_file: constant_identifier_names, library_prefixes
+// ignore_for_file: non_constant_identifier_names, prefer_final_fields
+// ignore_for_file: unnecessary_import, unnecessary_this, unused_import
+
+import 'dart:convert' as $convert;
+import 'dart:core' as $core;
+import 'dart:typed_data' as $typed_data;
+
+@$core.Deprecated('Use dataTypeDescriptor instead')
+const DataType$json = {
+  '1': 'DataType',
+  '2': [
+    {'1': 'STRING', '2': 0},
+    {'1': 'BOOL', '2': 1},
+    {'1': 'INT8', '2': 2},
+    {'1': 'INT16', '2': 3},
+    {'1': 'INT32', '2': 4},
+    {'1': 'INT64', '2': 5},
+    {'1': 'UINT8', '2': 6},
+    {'1': 'UINT16', '2': 7},
+    {'1': 'UINT32', '2': 8},
+    {'1': 'UINT64', '2': 9},
+    {'1': 'FLOAT', '2': 10},
+    {'1': 'DOUBLE', '2': 11},
+    {'1': 'TIMESTAMP', '2': 12},
+    {'1': 'STRING_ARRAY', '2': 20},
+    {'1': 'BOOL_ARRAY', '2': 21},
+    {'1': 'INT8_ARRAY', '2': 22},
+    {'1': 'INT16_ARRAY', '2': 23},
+    {'1': 'INT32_ARRAY', '2': 24},
+    {'1': 'INT64_ARRAY', '2': 25},
+    {'1': 'UINT8_ARRAY', '2': 26},
+    {'1': 'UINT16_ARRAY', '2': 27},
+    {'1': 'UINT32_ARRAY', '2': 28},
+    {'1': 'UINT64_ARRAY', '2': 29},
+    {'1': 'FLOAT_ARRAY', '2': 30},
+    {'1': 'DOUBLE_ARRAY', '2': 31},
+    {'1': 'TIMESTAMP_ARRAY', '2': 32},
+  ],
+};
+
+/// Descriptor for `DataType`. Decode as a `google.protobuf.EnumDescriptorProto`.
+final $typed_data.Uint8List dataTypeDescriptor = $convert.base64Decode(
+    'CghEYXRhVHlwZRIKCgZTVFJJTkcQABIICgRCT09MEAESCAoESU5UOBACEgkKBUlOVDE2EAMSCQ'
+    'oFSU5UMzIQBBIJCgVJTlQ2NBAFEgkKBVVJTlQ4EAYSCgoGVUlOVDE2EAcSCgoGVUlOVDMyEAgS'
+    'CgoGVUlOVDY0EAkSCQoFRkxPQVQQChIKCgZET1VCTEUQCxINCglUSU1FU1RBTVAQDBIQCgxTVF'
+    'JJTkdfQVJSQVkQFBIOCgpCT09MX0FSUkFZEBUSDgoKSU5UOF9BUlJBWRAWEg8KC0lOVDE2X0FS'
+    'UkFZEBcSDwoLSU5UMzJfQVJSQVkQGBIPCgtJTlQ2NF9BUlJBWRAZEg8KC1VJTlQ4X0FSUkFZEB'
+    'oSEAoMVUlOVDE2X0FSUkFZEBsSEAoMVUlOVDMyX0FSUkFZEBwSEAoMVUlOVDY0X0FSUkFZEB0S'
+    'DwoLRkxPQVRfQVJSQVkQHhIQCgxET1VCTEVfQVJSQVkQHxITCg9USU1FU1RBTVBfQVJSQVkQIA'
+    '==');
+
+@$core.Deprecated('Use datapointErrorDescriptor instead')
+const DatapointError$json = {
+  '1': 'DatapointError',
+  '2': [
+    {'1': 'UNKNOWN_DATAPOINT', '2': 0},
+    {'1': 'INVALID_TYPE', '2': 1},
+    {'1': 'ACCESS_DENIED', '2': 2},
+    {'1': 'INTERNAL_ERROR', '2': 3},
+    {'1': 'OUT_OF_BOUNDS', '2': 4},
+  ],
+};
+
+/// Descriptor for `DatapointError`. Decode as a `google.protobuf.EnumDescriptorProto`.
+final $typed_data.Uint8List datapointErrorDescriptor = $convert.base64Decode(
+    'Cg5EYXRhcG9pbnRFcnJvchIVChFVTktOT1dOX0RBVEFQT0lOVBAAEhAKDElOVkFMSURfVFlQRR'
+    'ABEhEKDUFDQ0VTU19ERU5JRUQQAhISCg5JTlRFUk5BTF9FUlJPUhADEhEKDU9VVF9PRl9CT1VO'
+    'RFMQBA==');
+
+@$core.Deprecated('Use entryTypeDescriptor instead')
+const EntryType$json = {
+  '1': 'EntryType',
+  '2': [
+    {'1': 'ENTRY_TYPE_UNSPECIFIED', '2': 0},
+    {'1': 'ENTRY_TYPE_SENSOR', '2': 1},
+    {'1': 'ENTRY_TYPE_ACTUATOR', '2': 2},
+    {'1': 'ENTRY_TYPE_ATTRIBUTE', '2': 3},
+  ],
+};
+
+/// Descriptor for `EntryType`. Decode as a `google.protobuf.EnumDescriptorProto`.
+final $typed_data.Uint8List entryTypeDescriptor = $convert.base64Decode(
+    'CglFbnRyeVR5cGUSGgoWRU5UUllfVFlQRV9VTlNQRUNJRklFRBAAEhUKEUVOVFJZX1RZUEVfU0'
+    'VOU09SEAESFwoTRU5UUllfVFlQRV9BQ1RVQVRPUhACEhgKFEVOVFJZX1RZUEVfQVRUUklCVVRF'
+    'EAM=');
+
+@$core.Deprecated('Use changeTypeDescriptor instead')
+const ChangeType$json = {
+  '1': 'ChangeType',
+  '2': [
+    {'1': 'STATIC', '2': 0},
+    {'1': 'ON_CHANGE', '2': 1},
+    {'1': 'CONTINUOUS', '2': 2},
+  ],
+};
+
+/// Descriptor for `ChangeType`. Decode as a `google.protobuf.EnumDescriptorProto`.
+final $typed_data.Uint8List changeTypeDescriptor = $convert.base64Decode(
+    'CgpDaGFuZ2VUeXBlEgoKBlNUQVRJQxAAEg0KCU9OX0NIQU5HRRABEg4KCkNPTlRJTlVPVVMQAg'
+    '==');
+
+@$core.Deprecated('Use stringArrayDescriptor instead')
+const StringArray$json = {
+  '1': 'StringArray',
+  '2': [
+    {'1': 'values', '3': 1, '4': 3, '5': 9, '10': 'values'},
+  ],
+};
+
+/// Descriptor for `StringArray`. Decode as a `google.protobuf.DescriptorProto`.
+final $typed_data.Uint8List stringArrayDescriptor = $convert.base64Decode(
+    'CgtTdHJpbmdBcnJheRIWCgZ2YWx1ZXMYASADKAlSBnZhbHVlcw==');
+
+@$core.Deprecated('Use boolArrayDescriptor instead')
+const BoolArray$json = {
+  '1': 'BoolArray',
+  '2': [
+    {'1': 'values', '3': 1, '4': 3, '5': 8, '10': 'values'},
+  ],
+};
+
+/// Descriptor for `BoolArray`. Decode as a `google.protobuf.DescriptorProto`.
+final $typed_data.Uint8List boolArrayDescriptor = $convert.base64Decode(
+    'CglCb29sQXJyYXkSFgoGdmFsdWVzGAEgAygIUgZ2YWx1ZXM=');
+
+@$core.Deprecated('Use int32ArrayDescriptor instead')
+const Int32Array$json = {
+  '1': 'Int32Array',
+  '2': [
+    {'1': 'values', '3': 1, '4': 3, '5': 17, '10': 'values'},
+  ],
+};
+
+/// Descriptor for `Int32Array`. Decode as a `google.protobuf.DescriptorProto`.
+final $typed_data.Uint8List int32ArrayDescriptor = $convert.base64Decode(
+    'CgpJbnQzMkFycmF5EhYKBnZhbHVlcxgBIAMoEVIGdmFsdWVz');
+
+@$core.Deprecated('Use int64ArrayDescriptor instead')
+const Int64Array$json = {
+  '1': 'Int64Array',
+  '2': [
+    {'1': 'values', '3': 1, '4': 3, '5': 18, '10': 'values'},
+  ],
+};
+
+/// Descriptor for `Int64Array`. Decode as a `google.protobuf.DescriptorProto`.
+final $typed_data.Uint8List int64ArrayDescriptor = $convert.base64Decode(
+    'CgpJbnQ2NEFycmF5EhYKBnZhbHVlcxgBIAMoElIGdmFsdWVz');
+
+@$core.Deprecated('Use uint32ArrayDescriptor instead')
+const Uint32Array$json = {
+  '1': 'Uint32Array',
+  '2': [
+    {'1': 'values', '3': 1, '4': 3, '5': 13, '10': 'values'},
+  ],
+};
+
+/// Descriptor for `Uint32Array`. Decode as a `google.protobuf.DescriptorProto`.
+final $typed_data.Uint8List uint32ArrayDescriptor = $convert.base64Decode(
+    'CgtVaW50MzJBcnJheRIWCgZ2YWx1ZXMYASADKA1SBnZhbHVlcw==');
+
+@$core.Deprecated('Use uint64ArrayDescriptor instead')
+const Uint64Array$json = {
+  '1': 'Uint64Array',
+  '2': [
+    {'1': 'values', '3': 1, '4': 3, '5': 4, '10': 'values'},
+  ],
+};
+
+/// Descriptor for `Uint64Array`. Decode as a `google.protobuf.DescriptorProto`.
+final $typed_data.Uint8List uint64ArrayDescriptor = $convert.base64Decode(
+    'CgtVaW50NjRBcnJheRIWCgZ2YWx1ZXMYASADKARSBnZhbHVlcw==');
+
+@$core.Deprecated('Use floatArrayDescriptor instead')
+const FloatArray$json = {
+  '1': 'FloatArray',
+  '2': [
+    {'1': 'values', '3': 1, '4': 3, '5': 2, '10': 'values'},
+  ],
+};
+
+/// Descriptor for `FloatArray`. Decode as a `google.protobuf.DescriptorProto`.
+final $typed_data.Uint8List floatArrayDescriptor = $convert.base64Decode(
+    'CgpGbG9hdEFycmF5EhYKBnZhbHVlcxgBIAMoAlIGdmFsdWVz');
+
+@$core.Deprecated('Use doubleArrayDescriptor instead')
+const DoubleArray$json = {
+  '1': 'DoubleArray',
+  '2': [
+    {'1': 'values', '3': 1, '4': 3, '5': 1, '10': 'values'},
+  ],
+};
+
+/// Descriptor for `DoubleArray`. Decode as a `google.protobuf.DescriptorProto`.
+final $typed_data.Uint8List doubleArrayDescriptor = $convert.base64Decode(
+    'CgtEb3VibGVBcnJheRIWCgZ2YWx1ZXMYASADKAFSBnZhbHVlcw==');
+
+@$core.Deprecated('Use datapointDescriptor instead')
+const Datapoint$json = {
+  '1': 'Datapoint',
+  '2': [
+    {'1': 'timestamp', '3': 1, '4': 1, '5': 11, '6': '.google.protobuf.Timestamp', '10': 'timestamp'},
+    {'1': 'failure_value', '3': 10, '4': 1, '5': 14, '6': '.sdv.databroker.v1.Datapoint.Failure', '9': 0, '10': 'failureValue'},
+    {'1': 'string_value', '3': 11, '4': 1, '5': 9, '9': 0, '10': 'stringValue'},
+    {'1': 'bool_value', '3': 12, '4': 1, '5': 8, '9': 0, '10': 'boolValue'},
+    {'1': 'int32_value', '3': 13, '4': 1, '5': 17, '9': 0, '10': 'int32Value'},
+    {'1': 'int64_value', '3': 14, '4': 1, '5': 18, '9': 0, '10': 'int64Value'},
+    {'1': 'uint32_value', '3': 15, '4': 1, '5': 13, '9': 0, '10': 'uint32Value'},
+    {'1': 'uint64_value', '3': 16, '4': 1, '5': 4, '9': 0, '10': 'uint64Value'},
+    {'1': 'float_value', '3': 17, '4': 1, '5': 2, '9': 0, '10': 'floatValue'},
+    {'1': 'double_value', '3': 18, '4': 1, '5': 1, '9': 0, '10': 'doubleValue'},
+    {'1': 'string_array', '3': 21, '4': 1, '5': 11, '6': '.sdv.databroker.v1.StringArray', '9': 0, '10': 'stringArray'},
+    {'1': 'bool_array', '3': 22, '4': 1, '5': 11, '6': '.sdv.databroker.v1.BoolArray', '9': 0, '10': 'boolArray'},
+    {'1': 'int32_array', '3': 23, '4': 1, '5': 11, '6': '.sdv.databroker.v1.Int32Array', '9': 0, '10': 'int32Array'},
+    {'1': 'int64_array', '3': 24, '4': 1, '5': 11, '6': '.sdv.databroker.v1.Int64Array', '9': 0, '10': 'int64Array'},
+    {'1': 'uint32_array', '3': 25, '4': 1, '5': 11, '6': '.sdv.databroker.v1.Uint32Array', '9': 0, '10': 'uint32Array'},
+    {'1': 'uint64_array', '3': 26, '4': 1, '5': 11, '6': '.sdv.databroker.v1.Uint64Array', '9': 0, '10': 'uint64Array'},
+    {'1': 'float_array', '3': 27, '4': 1, '5': 11, '6': '.sdv.databroker.v1.FloatArray', '9': 0, '10': 'floatArray'},
+    {'1': 'double_array', '3': 28, '4': 1, '5': 11, '6': '.sdv.databroker.v1.DoubleArray', '9': 0, '10': 'doubleArray'},
+  ],
+  '4': [Datapoint_Failure$json],
+  '8': [
+    {'1': 'value'},
+  ],
+};
+
+@$core.Deprecated('Use datapointDescriptor instead')
+const Datapoint_Failure$json = {
+  '1': 'Failure',
+  '2': [
+    {'1': 'INVALID_VALUE', '2': 0},
+    {'1': 'NOT_AVAILABLE', '2': 1},
+    {'1': 'UNKNOWN_DATAPOINT', '2': 2},
+    {'1': 'ACCESS_DENIED', '2': 3},
+    {'1': 'INTERNAL_ERROR', '2': 4},
+  ],
+};
+
+/// Descriptor for `Datapoint`. Decode as a `google.protobuf.DescriptorProto`.
+final $typed_data.Uint8List datapointDescriptor = $convert.base64Decode(
+    'CglEYXRhcG9pbnQSOAoJdGltZXN0YW1wGAEgASgLMhouZ29vZ2xlLnByb3RvYnVmLlRpbWVzdG'
+    'FtcFIJdGltZXN0YW1wEksKDWZhaWx1cmVfdmFsdWUYCiABKA4yJC5zZHYuZGF0YWJyb2tlci52'
+    'MS5EYXRhcG9pbnQuRmFpbHVyZUgAUgxmYWlsdXJlVmFsdWUSIwoMc3RyaW5nX3ZhbHVlGAsgAS'
+    'gJSABSC3N0cmluZ1ZhbHVlEh8KCmJvb2xfdmFsdWUYDCABKAhIAFIJYm9vbFZhbHVlEiEKC2lu'
+    'dDMyX3ZhbHVlGA0gASgRSABSCmludDMyVmFsdWUSIQoLaW50NjRfdmFsdWUYDiABKBJIAFIKaW'
+    '50NjRWYWx1ZRIjCgx1aW50MzJfdmFsdWUYDyABKA1IAFILdWludDMyVmFsdWUSIwoMdWludDY0'
+    'X3ZhbHVlGBAgASgESABSC3VpbnQ2NFZhbHVlEiEKC2Zsb2F0X3ZhbHVlGBEgASgCSABSCmZsb2'
+    'F0VmFsdWUSIwoMZG91YmxlX3ZhbHVlGBIgASgBSABSC2RvdWJsZVZhbHVlEkMKDHN0cmluZ19h'
+    'cnJheRgVIAEoCzIeLnNkdi5kYXRhYnJva2VyLnYxLlN0cmluZ0FycmF5SABSC3N0cmluZ0Fycm'
+    'F5Ej0KCmJvb2xfYXJyYXkYFiABKAsyHC5zZHYuZGF0YWJyb2tlci52MS5Cb29sQXJyYXlIAFIJ'
+    'Ym9vbEFycmF5EkAKC2ludDMyX2FycmF5GBcgASgLMh0uc2R2LmRhdGFicm9rZXIudjEuSW50Mz'
+    'JBcnJheUgAUgppbnQzMkFycmF5EkAKC2ludDY0X2FycmF5GBggASgLMh0uc2R2LmRhdGFicm9r'
+    'ZXIudjEuSW50NjRBcnJheUgAUgppbnQ2NEFycmF5EkMKDHVpbnQzMl9hcnJheRgZIAEoCzIeLn'
+    'Nkdi5kYXRhYnJva2VyLnYxLlVpbnQzMkFycmF5SABSC3VpbnQzMkFycmF5EkMKDHVpbnQ2NF9h'
+    'cnJheRgaIAEoCzIeLnNkdi5kYXRhYnJva2VyLnYxLlVpbnQ2NEFycmF5SABSC3VpbnQ2NEFycm'
+    'F5EkAKC2Zsb2F0X2FycmF5GBsgASgLMh0uc2R2LmRhdGFicm9rZXIudjEuRmxvYXRBcnJheUgA'
+    'UgpmbG9hdEFycmF5EkMKDGRvdWJsZV9hcnJheRgcIAEoCzIeLnNkdi5kYXRhYnJva2VyLnYxLk'
+    'RvdWJsZUFycmF5SABSC2RvdWJsZUFycmF5Im0KB0ZhaWx1cmUSEQoNSU5WQUxJRF9WQUxVRRAA'
+    'EhEKDU5PVF9BVkFJTEFCTEUQARIVChFVTktOT1dOX0RBVEFQT0lOVBACEhEKDUFDQ0VTU19ERU'
+    '5JRUQQAxISCg5JTlRFUk5BTF9FUlJPUhAEQgcKBXZhbHVl');
+
+@$core.Deprecated('Use metadataDescriptor instead')
+const Metadata$json = {
+  '1': 'Metadata',
+  '2': [
+    {'1': 'id', '3': 1, '4': 1, '5': 5, '10': 'id'},
+    {'1': 'entry_type', '3': 2, '4': 1, '5': 14, '6': '.sdv.databroker.v1.EntryType', '10': 'entryType'},
+    {'1': 'name', '3': 4, '4': 1, '5': 9, '10': 'name'},
+    {'1': 'data_type', '3': 5, '4': 1, '5': 14, '6': '.sdv.databroker.v1.DataType', '10': 'dataType'},
+    {'1': 'change_type', '3': 6, '4': 1, '5': 14, '6': '.sdv.databroker.v1.ChangeType', '10': 'changeType'},
+    {'1': 'description', '3': 7, '4': 1, '5': 9, '10': 'description'},
+  ],
+};
+
+/// Descriptor for `Metadata`. Decode as a `google.protobuf.DescriptorProto`.
+final $typed_data.Uint8List metadataDescriptor = $convert.base64Decode(
+    'CghNZXRhZGF0YRIOCgJpZBgBIAEoBVICaWQSOwoKZW50cnlfdHlwZRgCIAEoDjIcLnNkdi5kYX'
+    'RhYnJva2VyLnYxLkVudHJ5VHlwZVIJZW50cnlUeXBlEhIKBG5hbWUYBCABKAlSBG5hbWUSOAoJ'
+    'ZGF0YV90eXBlGAUgASgOMhsuc2R2LmRhdGFicm9rZXIudjEuRGF0YVR5cGVSCGRhdGFUeXBlEj'
+    '4KC2NoYW5nZV90eXBlGAYgASgOMh0uc2R2LmRhdGFicm9rZXIudjEuQ2hhbmdlVHlwZVIKY2hh'
+    'bmdlVHlwZRIgCgtkZXNjcmlwdGlvbhgHIAEoCVILZGVzY3JpcHRpb24=');
+