Cleanup: update to and use latest pkg:lints with associated fixes (#587)

Bump min Dart SDK for grpc to 2.17
Regenerate all code
Fix generate scripts
Add dependabot
This commit is contained in:
Kevin Moore 2022-10-31 11:47:31 -07:00 committed by GitHub
parent 19ba902d7e
commit dbf5421eb6
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
119 changed files with 640 additions and 458 deletions

11
.github/dependabot.yml vendored Normal file
View File

@ -0,0 +1,11 @@
# Set update schedule for GitHub Actions
# See https://docs.github.com/en/free-pro-team@latest/github/administering-a-repository/keeping-your-actions-up-to-date-with-dependabot
version: 2
updates:
- package-ecosystem: "github-actions"
directory: "/"
schedule:
# Check for updates to GitHub Actions every weekday
interval: "monthly"

View File

@ -16,10 +16,10 @@ jobs:
runs-on: ubuntu-latest
strategy:
matrix:
sdk: [dev, 2.12.0]
sdk: [dev, 2.17.0]
steps:
- uses: actions/checkout@v2
- uses: dart-lang/setup-dart@v1.2
- uses: actions/checkout@93ea575cb5d8a053eaa0ac8fa3b40d7e05a33cc8
- uses: dart-lang/setup-dart@6a218f2413a3e78e9087f638a238f6b40893203d
with:
sdk: ${{ matrix.sdk }}
- name: Report version
@ -60,7 +60,7 @@ jobs:
strategy:
matrix:
os: [ubuntu-latest, macos-latest, windows-latest]
sdk: [dev, 2.12.0]
sdk: [dev, 2.17.0]
platform: [vm, chrome]
exclude:
# We only run Chrome tests on Linux. No need to run them
@ -70,8 +70,8 @@ jobs:
- os: macos-latest
platform: chrome
steps:
- uses: actions/checkout@v2
- uses: dart-lang/setup-dart@v1.2
- uses: actions/checkout@93ea575cb5d8a053eaa0ac8fa3b40d7e05a33cc8
- uses: dart-lang/setup-dart@6a218f2413a3e78e9087f638a238f6b40893203d
with:
sdk: ${{ matrix.sdk }}
- name: Report version

View File

@ -1,3 +1,7 @@
## 3.1.1-dev
* Require Dart 2.17 or greater.
## 3.1.0
* Expose a stream for connection state changes on ClientChannel to address

View File

@ -1,56 +1,20 @@
# Lint rules and documentation, see http://dart-lang.github.io/linter/lints
# https://dart.dev/guides/language/analysis-options
include: package:lints/recommended.yaml
analyzer:
errors:
# These should be fixed or ignored in the proto generator
implementation_imports: ignore
no_leading_underscores_for_local_identifiers: ignore
linter:
rules:
- always_declare_return_types
- always_require_non_null_named_parameters
- annotate_overrides
- avoid_empty_else
- avoid_init_to_null
- avoid_null_checks_in_equality_operators
- avoid_relative_lib_imports
- avoid_return_types_on_setters
- avoid_shadowing_type_parameters
- avoid_types_as_parameter_names
- camel_case_extensions
- cancel_subscriptions
- close_sinks
- curly_braces_in_flow_control_structures
- directives_ordering
- empty_catches
- empty_constructor_bodies
- hash_and_equals
- iterable_contains_unrelated_type
- library_names
- library_prefixes
- list_remove_unrelated_type
- no_duplicate_case_values
- null_closures
- omit_local_variable_types
- prefer_adjacent_string_concatenation
- prefer_collection_literals
- prefer_conditional_assignment
- prefer_contains
- prefer_equal_for_default_values
- prefer_final_fields
- prefer_final_locals
- prefer_for_elements_to_map_fromIterable
- prefer_generic_function_type_aliases
- prefer_if_null_operators
- prefer_is_empty
- prefer_is_not_empty
- prefer_iterable_whereType
- prefer_single_quotes
- prefer_spread_collections
- recursive_getters
- slash_for_doc_comments
- test_types_in_equals
- type_init_formals
- unnecessary_const
- unnecessary_new
- unnecessary_null_in_if_null_operators
- unnecessary_this
- unrelated_type_equality_checks
- use_function_type_syntax_for_parameters
- use_rethrow_when_possible
- valid_regexps
- use_super_parameters

View File

@ -3,7 +3,7 @@
// source: google/api/label.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:core' as $core;

View File

@ -3,7 +3,7 @@
// source: google/api/label.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
// ignore_for_file: UNDEFINED_SHOWN_NAME
import 'dart:core' as $core;

View File

@ -3,7 +3,7 @@
// source: google/api/label.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields,deprecated_member_use_from_same_package
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,deprecated_member_use_from_same_package,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:core' as $core;
import 'dart:convert' as $convert;

View File

@ -3,7 +3,7 @@
// source: google/api/launch_stage.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:core' as $core;

View File

@ -3,7 +3,7 @@
// source: google/api/launch_stage.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
// ignore_for_file: UNDEFINED_SHOWN_NAME
import 'dart:core' as $core;

View File

@ -3,7 +3,7 @@
// source: google/api/launch_stage.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields,deprecated_member_use_from_same_package
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,deprecated_member_use_from_same_package,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:core' as $core;
import 'dart:convert' as $convert;

View File

@ -3,7 +3,7 @@
// source: google/api/monitored_resource.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:core' as $core;

View File

@ -3,4 +3,4 @@
// source: google/api/monitored_resource.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name

View File

@ -3,7 +3,7 @@
// source: google/api/monitored_resource.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields,deprecated_member_use_from_same_package
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,deprecated_member_use_from_same_package,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:core' as $core;
import 'dart:convert' as $convert;

View File

@ -3,7 +3,7 @@
// source: google/logging/type/http_request.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:core' as $core;

View File

@ -3,4 +3,4 @@
// source: google/logging/type/http_request.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name

View File

@ -3,7 +3,7 @@
// source: google/logging/type/http_request.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields,deprecated_member_use_from_same_package
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,deprecated_member_use_from_same_package,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:core' as $core;
import 'dart:convert' as $convert;

View File

@ -3,7 +3,7 @@
// source: google/logging/type/log_severity.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:core' as $core;

View File

@ -3,7 +3,7 @@
// source: google/logging/type/log_severity.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
// ignore_for_file: UNDEFINED_SHOWN_NAME
import 'dart:core' as $core;

View File

@ -3,7 +3,7 @@
// source: google/logging/type/log_severity.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields,deprecated_member_use_from_same_package
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,deprecated_member_use_from_same_package,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:core' as $core;
import 'dart:convert' as $convert;

View File

@ -3,7 +3,7 @@
// source: google/logging/v2/log_entry.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:core' as $core;
@ -133,6 +133,12 @@ class LogEntry extends $pb.GeneratedMessage {
const $core.bool.fromEnvironment('protobuf.omit_field_names')
? ''
: 'traceSampled')
..aOM<LogSplit>(
35,
const $core.bool.fromEnvironment('protobuf.omit_field_names')
? ''
: 'split',
subBuilder: LogSplit.create)
..hasRequiredFields = false;
LogEntry._() : super();
@ -153,6 +159,7 @@ class LogEntry extends $pb.GeneratedMessage {
$4.Timestamp? receiveTimestamp,
$core.String? spanId,
$core.bool? traceSampled,
LogSplit? split,
}) {
final _result = create();
if (protoPayload != null) {
@ -203,6 +210,9 @@ class LogEntry extends $pb.GeneratedMessage {
if (traceSampled != null) {
_result.traceSampled = traceSampled;
}
if (split != null) {
_result.split = split;
}
return _result;
}
factory LogEntry.fromBuffer($core.List<$core.int> i,
@ -432,6 +442,20 @@ class LogEntry extends $pb.GeneratedMessage {
$core.bool hasTraceSampled() => $_has(15);
@$pb.TagNumber(30)
void clearTraceSampled() => clearField(30);
@$pb.TagNumber(35)
LogSplit get split => $_getN(16);
@$pb.TagNumber(35)
set split(LogSplit v) {
setField(35, v);
}
@$pb.TagNumber(35)
$core.bool hasSplit() => $_has(16);
@$pb.TagNumber(35)
void clearSplit() => clearField(35);
@$pb.TagNumber(35)
LogSplit ensureSplit() => $_ensure(16);
}
class LogEntryOperation extends $pb.GeneratedMessage {
@ -674,3 +698,113 @@ class LogEntrySourceLocation extends $pb.GeneratedMessage {
@$pb.TagNumber(3)
void clearFunction() => clearField(3);
}
class LogSplit extends $pb.GeneratedMessage {
static final $pb.BuilderInfo _i = $pb.BuilderInfo(
const $core.bool.fromEnvironment('protobuf.omit_message_names')
? ''
: 'LogSplit',
package: const $pb.PackageName(
const $core.bool.fromEnvironment('protobuf.omit_message_names')
? ''
: 'google.logging.v2'),
createEmptyInstance: create)
..aOS(
1,
const $core.bool.fromEnvironment('protobuf.omit_field_names')
? ''
: 'uid')
..a<$core.int>(
2,
const $core.bool.fromEnvironment('protobuf.omit_field_names')
? ''
: 'index',
$pb.PbFieldType.O3)
..a<$core.int>(
3,
const $core.bool.fromEnvironment('protobuf.omit_field_names')
? ''
: 'totalSplits',
$pb.PbFieldType.O3)
..hasRequiredFields = false;
LogSplit._() : super();
factory LogSplit({
$core.String? uid,
$core.int? index,
$core.int? totalSplits,
}) {
final _result = create();
if (uid != null) {
_result.uid = uid;
}
if (index != null) {
_result.index = index;
}
if (totalSplits != null) {
_result.totalSplits = totalSplits;
}
return _result;
}
factory LogSplit.fromBuffer($core.List<$core.int> i,
[$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) =>
create()..mergeFromBuffer(i, r);
factory LogSplit.fromJson($core.String i,
[$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) =>
create()..mergeFromJson(i, r);
@$core.Deprecated('Using this can add significant overhead to your binary. '
'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
'Will be removed in next major version')
LogSplit clone() => LogSplit()..mergeFromMessage(this);
@$core.Deprecated('Using this can add significant overhead to your binary. '
'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
'Will be removed in next major version')
LogSplit copyWith(void Function(LogSplit) updates) =>
super.copyWith((message) => updates(message as LogSplit))
as LogSplit; // ignore: deprecated_member_use
$pb.BuilderInfo get info_ => _i;
@$core.pragma('dart2js:noInline')
static LogSplit create() => LogSplit._();
LogSplit createEmptyInstance() => create();
static $pb.PbList<LogSplit> createRepeated() => $pb.PbList<LogSplit>();
@$core.pragma('dart2js:noInline')
static LogSplit getDefault() =>
_defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<LogSplit>(create);
static LogSplit? _defaultInstance;
@$pb.TagNumber(1)
$core.String get uid => $_getSZ(0);
@$pb.TagNumber(1)
set uid($core.String v) {
$_setString(0, v);
}
@$pb.TagNumber(1)
$core.bool hasUid() => $_has(0);
@$pb.TagNumber(1)
void clearUid() => clearField(1);
@$pb.TagNumber(2)
$core.int get index => $_getIZ(1);
@$pb.TagNumber(2)
set index($core.int v) {
$_setSignedInt32(1, v);
}
@$pb.TagNumber(2)
$core.bool hasIndex() => $_has(1);
@$pb.TagNumber(2)
void clearIndex() => clearField(2);
@$pb.TagNumber(3)
$core.int get totalSplits => $_getIZ(2);
@$pb.TagNumber(3)
set totalSplits($core.int v) {
$_setSignedInt32(2, v);
}
@$pb.TagNumber(3)
$core.bool hasTotalSplits() => $_has(2);
@$pb.TagNumber(3)
void clearTotalSplits() => clearField(3);
}

View File

@ -3,4 +3,4 @@
// source: google/logging/v2/log_entry.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name

View File

@ -3,7 +3,7 @@
// source: google/logging/v2/log_entry.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields,deprecated_member_use_from_same_package
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,deprecated_member_use_from_same_package,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:core' as $core;
import 'dart:convert' as $convert;
@ -144,6 +144,15 @@ const LogEntry$json = const {
'8': const {},
'10': 'sourceLocation'
},
const {
'1': 'split',
'3': 35,
'4': 1,
'5': 11,
'6': '.google.logging.v2.LogSplit',
'8': const {},
'10': 'split'
},
],
'3': const [LogEntry_LabelsEntry$json],
'7': const {},
@ -164,7 +173,7 @@ const LogEntry_LabelsEntry$json = const {
/// Descriptor for `LogEntry`. Decode as a `google.protobuf.DescriptorProto`.
final $typed_data.Uint8List logEntryDescriptor = $convert.base64Decode(
'CghMb2dFbnRyeRIeCghsb2dfbmFtZRgMIAEoCUID4EECUgdsb2dOYW1lEj4KCHJlc291cmNlGAggASgLMh0uZ29vZ2xlLmFwaS5Nb25pdG9yZWRSZXNvdXJjZUID4EECUghyZXNvdXJjZRI7Cg1wcm90b19wYXlsb2FkGAIgASgLMhQuZ29vZ2xlLnByb3RvYnVmLkFueUgAUgxwcm90b1BheWxvYWQSIwoMdGV4dF9wYXlsb2FkGAMgASgJSABSC3RleHRQYXlsb2FkEjwKDGpzb25fcGF5bG9hZBgGIAEoCzIXLmdvb2dsZS5wcm90b2J1Zi5TdHJ1Y3RIAFILanNvblBheWxvYWQSPQoJdGltZXN0YW1wGAkgASgLMhouZ29vZ2xlLnByb3RvYnVmLlRpbWVzdGFtcEID4EEBUgl0aW1lc3RhbXASTAoRcmVjZWl2ZV90aW1lc3RhbXAYGCABKAsyGi5nb29nbGUucHJvdG9idWYuVGltZXN0YW1wQgPgQQNSEHJlY2VpdmVUaW1lc3RhbXASQQoIc2V2ZXJpdHkYCiABKA4yIC5nb29nbGUubG9nZ2luZy50eXBlLkxvZ1NldmVyaXR5QgPgQQFSCHNldmVyaXR5EiAKCWluc2VydF9pZBgEIAEoCUID4EEBUghpbnNlcnRJZBJICgxodHRwX3JlcXVlc3QYByABKAsyIC5nb29nbGUubG9nZ2luZy50eXBlLkh0dHBSZXF1ZXN0QgPgQQFSC2h0dHBSZXF1ZXN0EkQKBmxhYmVscxgLIAMoCzInLmdvb2dsZS5sb2dnaW5nLnYyLkxvZ0VudHJ5LkxhYmVsc0VudHJ5QgPgQQFSBmxhYmVscxJHCglvcGVyYXRpb24YDyABKAsyJC5nb29nbGUubG9nZ2luZy52Mi5Mb2dFbnRyeU9wZXJhdGlvbkID4EEBUglvcGVyYXRpb24SGQoFdHJhY2UYFiABKAlCA+BBAVIFdHJhY2USHAoHc3Bhbl9pZBgbIAEoCUID4EEBUgZzcGFuSWQSKAoNdHJhY2Vfc2FtcGxlZBgeIAEoCEID4EEBUgx0cmFjZVNhbXBsZWQSVwoPc291cmNlX2xvY2F0aW9uGBcgASgLMikuZ29vZ2xlLmxvZ2dpbmcudjIuTG9nRW50cnlTb3VyY2VMb2NhdGlvbkID4EEBUg5zb3VyY2VMb2NhdGlvbho5CgtMYWJlbHNFbnRyeRIQCgNrZXkYASABKAlSA2tleRIUCgV2YWx1ZRgCIAEoCVIFdmFsdWU6AjgBOr0B6kG5AQoabG9nZ2luZy5nb29nbGVhcGlzLmNvbS9Mb2cSHXByb2plY3RzL3twcm9qZWN0fS9sb2dzL3tsb2d9Eidvcmdhbml6YXRpb25zL3tvcmdhbml6YXRpb259L2xvZ3Mve2xvZ30SG2ZvbGRlcnMve2ZvbGRlcn0vbG9ncy97bG9nfRIsYmlsbGluZ0FjY291bnRzL3tiaWxsaW5nX2FjY291bnR9L2xvZ3Mve2xvZ30aCGxvZ19uYW1lQgkKB3BheWxvYWQ=');
'CghMb2dFbnRyeRIeCghsb2dfbmFtZRgMIAEoCUID4EECUgdsb2dOYW1lEj4KCHJlc291cmNlGAggASgLMh0uZ29vZ2xlLmFwaS5Nb25pdG9yZWRSZXNvdXJjZUID4EECUghyZXNvdXJjZRI7Cg1wcm90b19wYXlsb2FkGAIgASgLMhQuZ29vZ2xlLnByb3RvYnVmLkFueUgAUgxwcm90b1BheWxvYWQSIwoMdGV4dF9wYXlsb2FkGAMgASgJSABSC3RleHRQYXlsb2FkEjwKDGpzb25fcGF5bG9hZBgGIAEoCzIXLmdvb2dsZS5wcm90b2J1Zi5TdHJ1Y3RIAFILanNvblBheWxvYWQSPQoJdGltZXN0YW1wGAkgASgLMhouZ29vZ2xlLnByb3RvYnVmLlRpbWVzdGFtcEID4EEBUgl0aW1lc3RhbXASTAoRcmVjZWl2ZV90aW1lc3RhbXAYGCABKAsyGi5nb29nbGUucHJvdG9idWYuVGltZXN0YW1wQgPgQQNSEHJlY2VpdmVUaW1lc3RhbXASQQoIc2V2ZXJpdHkYCiABKA4yIC5nb29nbGUubG9nZ2luZy50eXBlLkxvZ1NldmVyaXR5QgPgQQFSCHNldmVyaXR5EiAKCWluc2VydF9pZBgEIAEoCUID4EEBUghpbnNlcnRJZBJICgxodHRwX3JlcXVlc3QYByABKAsyIC5nb29nbGUubG9nZ2luZy50eXBlLkh0dHBSZXF1ZXN0QgPgQQFSC2h0dHBSZXF1ZXN0EkQKBmxhYmVscxgLIAMoCzInLmdvb2dsZS5sb2dnaW5nLnYyLkxvZ0VudHJ5LkxhYmVsc0VudHJ5QgPgQQFSBmxhYmVscxJHCglvcGVyYXRpb24YDyABKAsyJC5nb29nbGUubG9nZ2luZy52Mi5Mb2dFbnRyeU9wZXJhdGlvbkID4EEBUglvcGVyYXRpb24SGQoFdHJhY2UYFiABKAlCA+BBAVIFdHJhY2USHAoHc3Bhbl9pZBgbIAEoCUID4EEBUgZzcGFuSWQSKAoNdHJhY2Vfc2FtcGxlZBgeIAEoCEID4EEBUgx0cmFjZVNhbXBsZWQSVwoPc291cmNlX2xvY2F0aW9uGBcgASgLMikuZ29vZ2xlLmxvZ2dpbmcudjIuTG9nRW50cnlTb3VyY2VMb2NhdGlvbkID4EEBUg5zb3VyY2VMb2NhdGlvbhI2CgVzcGxpdBgjIAEoCzIbLmdvb2dsZS5sb2dnaW5nLnYyLkxvZ1NwbGl0QgPgQQFSBXNwbGl0GjkKC0xhYmVsc0VudHJ5EhAKA2tleRgBIAEoCVIDa2V5EhQKBXZhbHVlGAIgASgJUgV2YWx1ZToCOAE6vQHqQbkBChpsb2dnaW5nLmdvb2dsZWFwaXMuY29tL0xvZxIdcHJvamVjdHMve3Byb2plY3R9L2xvZ3Mve2xvZ30SJ29yZ2FuaXphdGlvbnMve29yZ2FuaXphdGlvbn0vbG9ncy97bG9nfRIbZm9sZGVycy97Zm9sZGVyfS9sb2dzL3tsb2d9EixiaWxsaW5nQWNjb3VudHMve2JpbGxpbmdfYWNjb3VudH0vbG9ncy97bG9nfRoIbG9nX25hbWVCCQoHcGF5bG9hZA==');
@$core.Deprecated('Use logEntryOperationDescriptor instead')
const LogEntryOperation$json = const {
'1': 'LogEntryOperation',
@ -207,3 +216,16 @@ const LogEntrySourceLocation$json = const {
final $typed_data.Uint8List logEntrySourceLocationDescriptor =
$convert.base64Decode(
'ChZMb2dFbnRyeVNvdXJjZUxvY2F0aW9uEhcKBGZpbGUYASABKAlCA+BBAVIEZmlsZRIXCgRsaW5lGAIgASgDQgPgQQFSBGxpbmUSHwoIZnVuY3Rpb24YAyABKAlCA+BBAVIIZnVuY3Rpb24=');
@$core.Deprecated('Use logSplitDescriptor instead')
const LogSplit$json = const {
'1': 'LogSplit',
'2': const [
const {'1': 'uid', '3': 1, '4': 1, '5': 9, '10': 'uid'},
const {'1': 'index', '3': 2, '4': 1, '5': 5, '10': 'index'},
const {'1': 'total_splits', '3': 3, '4': 1, '5': 5, '10': 'totalSplits'},
],
};
/// Descriptor for `LogSplit`. Decode as a `google.protobuf.DescriptorProto`.
final $typed_data.Uint8List logSplitDescriptor = $convert.base64Decode(
'CghMb2dTcGxpdBIQCgN1aWQYASABKAlSA3VpZBIUCgVpbmRleBgCIAEoBVIFaW5kZXgSIQoMdG90YWxfc3BsaXRzGAMgASgFUgt0b3RhbFNwbGl0cw==');

View File

@ -3,16 +3,16 @@
// source: google/logging/v2/logging.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:core' as $core;
import 'package:protobuf/protobuf.dart' as $pb;
import '../../api/monitored_resource.pb.dart' as $3;
import 'log_entry.pb.dart' as $4;
import '../../rpc/status.pb.dart' as $5;
import '../../protobuf/duration.pb.dart' as $6;
import '../../api/monitored_resource.pb.dart' as $2;
import 'log_entry.pb.dart' as $3;
import '../../rpc/status.pb.dart' as $4;
import '../../protobuf/duration.pb.dart' as $5;
import 'logging.pbenum.dart';
@ -100,12 +100,12 @@ class WriteLogEntriesRequest extends $pb.GeneratedMessage {
const $core.bool.fromEnvironment('protobuf.omit_field_names')
? ''
: 'logName')
..aOM<$3.MonitoredResource>(
..aOM<$2.MonitoredResource>(
2,
const $core.bool.fromEnvironment('protobuf.omit_field_names')
? ''
: 'resource',
subBuilder: $3.MonitoredResource.create)
subBuilder: $2.MonitoredResource.create)
..m<$core.String, $core.String>(
3,
const $core.bool.fromEnvironment('protobuf.omit_field_names')
@ -115,13 +115,13 @@ class WriteLogEntriesRequest extends $pb.GeneratedMessage {
keyFieldType: $pb.PbFieldType.OS,
valueFieldType: $pb.PbFieldType.OS,
packageName: const $pb.PackageName('google.logging.v2'))
..pc<$4.LogEntry>(
..pc<$3.LogEntry>(
4,
const $core.bool.fromEnvironment('protobuf.omit_field_names')
? ''
: 'entries',
$pb.PbFieldType.PM,
subBuilder: $4.LogEntry.create)
subBuilder: $3.LogEntry.create)
..aOB(
5,
const $core.bool.fromEnvironment('protobuf.omit_field_names')
@ -137,9 +137,9 @@ class WriteLogEntriesRequest extends $pb.GeneratedMessage {
WriteLogEntriesRequest._() : super();
factory WriteLogEntriesRequest({
$core.String? logName,
$3.MonitoredResource? resource,
$2.MonitoredResource? resource,
$core.Map<$core.String, $core.String>? labels,
$core.Iterable<$4.LogEntry>? entries,
$core.Iterable<$3.LogEntry>? entries,
$core.bool? partialSuccess,
$core.bool? dryRun,
}) {
@ -206,9 +206,9 @@ class WriteLogEntriesRequest extends $pb.GeneratedMessage {
void clearLogName() => clearField(1);
@$pb.TagNumber(2)
$3.MonitoredResource get resource => $_getN(1);
$2.MonitoredResource get resource => $_getN(1);
@$pb.TagNumber(2)
set resource($3.MonitoredResource v) {
set resource($2.MonitoredResource v) {
setField(2, v);
}
@ -217,13 +217,13 @@ class WriteLogEntriesRequest extends $pb.GeneratedMessage {
@$pb.TagNumber(2)
void clearResource() => clearField(2);
@$pb.TagNumber(2)
$3.MonitoredResource ensureResource() => $_ensure(1);
$2.MonitoredResource ensureResource() => $_ensure(1);
@$pb.TagNumber(3)
$core.Map<$core.String, $core.String> get labels => $_getMap(2);
@$pb.TagNumber(4)
$core.List<$4.LogEntry> get entries => $_getList(3);
$core.List<$3.LogEntry> get entries => $_getList(3);
@$pb.TagNumber(5)
$core.bool get partialSuccess => $_getBF(4);
@ -304,7 +304,7 @@ class WriteLogEntriesPartialErrors extends $pb.GeneratedMessage {
? ''
: 'google.logging.v2'),
createEmptyInstance: create)
..m<$core.int, $5.Status>(
..m<$core.int, $4.Status>(
1,
const $core.bool.fromEnvironment('protobuf.omit_field_names')
? ''
@ -312,13 +312,13 @@ class WriteLogEntriesPartialErrors extends $pb.GeneratedMessage {
entryClassName: 'WriteLogEntriesPartialErrors.LogEntryErrorsEntry',
keyFieldType: $pb.PbFieldType.O3,
valueFieldType: $pb.PbFieldType.OM,
valueCreator: $5.Status.create,
valueCreator: $4.Status.create,
packageName: const $pb.PackageName('google.logging.v2'))
..hasRequiredFields = false;
WriteLogEntriesPartialErrors._() : super();
factory WriteLogEntriesPartialErrors({
$core.Map<$core.int, $5.Status>? logEntryErrors,
$core.Map<$core.int, $4.Status>? logEntryErrors,
}) {
final _result = create();
if (logEntryErrors != null) {
@ -358,7 +358,7 @@ class WriteLogEntriesPartialErrors extends $pb.GeneratedMessage {
static WriteLogEntriesPartialErrors? _defaultInstance;
@$pb.TagNumber(1)
$core.Map<$core.int, $5.Status> get logEntryErrors => $_getMap(0);
$core.Map<$core.int, $4.Status> get logEntryErrors => $_getMap(0);
}
class ListLogEntriesRequest extends $pb.GeneratedMessage {
@ -516,13 +516,13 @@ class ListLogEntriesResponse extends $pb.GeneratedMessage {
? ''
: 'google.logging.v2'),
createEmptyInstance: create)
..pc<$4.LogEntry>(
..pc<$3.LogEntry>(
1,
const $core.bool.fromEnvironment('protobuf.omit_field_names')
? ''
: 'entries',
$pb.PbFieldType.PM,
subBuilder: $4.LogEntry.create)
subBuilder: $3.LogEntry.create)
..aOS(
2,
const $core.bool.fromEnvironment('protobuf.omit_field_names')
@ -532,7 +532,7 @@ class ListLogEntriesResponse extends $pb.GeneratedMessage {
ListLogEntriesResponse._() : super();
factory ListLogEntriesResponse({
$core.Iterable<$4.LogEntry>? entries,
$core.Iterable<$3.LogEntry>? entries,
$core.String? nextPageToken,
}) {
final _result = create();
@ -574,7 +574,7 @@ class ListLogEntriesResponse extends $pb.GeneratedMessage {
static ListLogEntriesResponse? _defaultInstance;
@$pb.TagNumber(1)
$core.List<$4.LogEntry> get entries => $_getList(0);
$core.List<$3.LogEntry> get entries => $_getList(0);
@$pb.TagNumber(2)
$core.String get nextPageToken => $_getSZ(1);
@ -694,13 +694,13 @@ class ListMonitoredResourceDescriptorsResponse extends $pb.GeneratedMessage {
? ''
: 'google.logging.v2'),
createEmptyInstance: create)
..pc<$3.MonitoredResourceDescriptor>(
..pc<$2.MonitoredResourceDescriptor>(
1,
const $core.bool.fromEnvironment('protobuf.omit_field_names')
? ''
: 'resourceDescriptors',
$pb.PbFieldType.PM,
subBuilder: $3.MonitoredResourceDescriptor.create)
subBuilder: $2.MonitoredResourceDescriptor.create)
..aOS(
2,
const $core.bool.fromEnvironment('protobuf.omit_field_names')
@ -710,7 +710,7 @@ class ListMonitoredResourceDescriptorsResponse extends $pb.GeneratedMessage {
ListMonitoredResourceDescriptorsResponse._() : super();
factory ListMonitoredResourceDescriptorsResponse({
$core.Iterable<$3.MonitoredResourceDescriptor>? resourceDescriptors,
$core.Iterable<$2.MonitoredResourceDescriptor>? resourceDescriptors,
$core.String? nextPageToken,
}) {
final _result = create();
@ -757,7 +757,7 @@ class ListMonitoredResourceDescriptorsResponse extends $pb.GeneratedMessage {
static ListMonitoredResourceDescriptorsResponse? _defaultInstance;
@$pb.TagNumber(1)
$core.List<$3.MonitoredResourceDescriptor> get resourceDescriptors =>
$core.List<$2.MonitoredResourceDescriptor> get resourceDescriptors =>
$_getList(0);
@$pb.TagNumber(2)
@ -994,19 +994,19 @@ class TailLogEntriesRequest extends $pb.GeneratedMessage {
const $core.bool.fromEnvironment('protobuf.omit_field_names')
? ''
: 'filter')
..aOM<$6.Duration>(
..aOM<$5.Duration>(
3,
const $core.bool.fromEnvironment('protobuf.omit_field_names')
? ''
: 'bufferWindow',
subBuilder: $6.Duration.create)
subBuilder: $5.Duration.create)
..hasRequiredFields = false;
TailLogEntriesRequest._() : super();
factory TailLogEntriesRequest({
$core.Iterable<$core.String>? resourceNames,
$core.String? filter,
$6.Duration? bufferWindow,
$5.Duration? bufferWindow,
}) {
final _result = create();
if (resourceNames != null) {
@ -1065,9 +1065,9 @@ class TailLogEntriesRequest extends $pb.GeneratedMessage {
void clearFilter() => clearField(2);
@$pb.TagNumber(3)
$6.Duration get bufferWindow => $_getN(2);
$5.Duration get bufferWindow => $_getN(2);
@$pb.TagNumber(3)
set bufferWindow($6.Duration v) {
set bufferWindow($5.Duration v) {
setField(3, v);
}
@ -1076,7 +1076,7 @@ class TailLogEntriesRequest extends $pb.GeneratedMessage {
@$pb.TagNumber(3)
void clearBufferWindow() => clearField(3);
@$pb.TagNumber(3)
$6.Duration ensureBufferWindow() => $_ensure(2);
$5.Duration ensureBufferWindow() => $_ensure(2);
}
class TailLogEntriesResponse_SuppressionInfo extends $pb.GeneratedMessage {
@ -1189,13 +1189,13 @@ class TailLogEntriesResponse extends $pb.GeneratedMessage {
? ''
: 'google.logging.v2'),
createEmptyInstance: create)
..pc<$4.LogEntry>(
..pc<$3.LogEntry>(
1,
const $core.bool.fromEnvironment('protobuf.omit_field_names')
? ''
: 'entries',
$pb.PbFieldType.PM,
subBuilder: $4.LogEntry.create)
subBuilder: $3.LogEntry.create)
..pc<TailLogEntriesResponse_SuppressionInfo>(
2,
const $core.bool.fromEnvironment('protobuf.omit_field_names')
@ -1207,7 +1207,7 @@ class TailLogEntriesResponse extends $pb.GeneratedMessage {
TailLogEntriesResponse._() : super();
factory TailLogEntriesResponse({
$core.Iterable<$4.LogEntry>? entries,
$core.Iterable<$3.LogEntry>? entries,
$core.Iterable<TailLogEntriesResponse_SuppressionInfo>? suppressionInfo,
}) {
final _result = create();
@ -1249,7 +1249,7 @@ class TailLogEntriesResponse extends $pb.GeneratedMessage {
static TailLogEntriesResponse? _defaultInstance;
@$pb.TagNumber(1)
$core.List<$4.LogEntry> get entries => $_getList(0);
$core.List<$3.LogEntry> get entries => $_getList(0);
@$pb.TagNumber(2)
$core.List<TailLogEntriesResponse_SuppressionInfo> get suppressionInfo =>

View File

@ -3,7 +3,7 @@
// source: google/logging/v2/logging.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
// ignore_for_file: UNDEFINED_SHOWN_NAME
import 'dart:core' as $core;

View File

@ -3,92 +3,92 @@
// source: google/logging/v2/logging.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:async' as $async;
import 'dart:core' as $core;
import 'package:grpc/service_api.dart' as $grpc;
import 'logging.pb.dart' as $2;
import 'logging.pb.dart' as $0;
import '../../protobuf/empty.pb.dart' as $1;
export 'logging.pb.dart';
class LoggingServiceV2Client extends $grpc.Client {
static final _$deleteLog = $grpc.ClientMethod<$2.DeleteLogRequest, $1.Empty>(
static final _$deleteLog = $grpc.ClientMethod<$0.DeleteLogRequest, $1.Empty>(
'/google.logging.v2.LoggingServiceV2/DeleteLog',
($2.DeleteLogRequest value) => value.writeToBuffer(),
($0.DeleteLogRequest value) => value.writeToBuffer(),
($core.List<$core.int> value) => $1.Empty.fromBuffer(value));
static final _$writeLogEntries =
$grpc.ClientMethod<$2.WriteLogEntriesRequest, $2.WriteLogEntriesResponse>(
$grpc.ClientMethod<$0.WriteLogEntriesRequest, $0.WriteLogEntriesResponse>(
'/google.logging.v2.LoggingServiceV2/WriteLogEntries',
($2.WriteLogEntriesRequest value) => value.writeToBuffer(),
($0.WriteLogEntriesRequest value) => value.writeToBuffer(),
($core.List<$core.int> value) =>
$2.WriteLogEntriesResponse.fromBuffer(value));
$0.WriteLogEntriesResponse.fromBuffer(value));
static final _$listLogEntries =
$grpc.ClientMethod<$2.ListLogEntriesRequest, $2.ListLogEntriesResponse>(
$grpc.ClientMethod<$0.ListLogEntriesRequest, $0.ListLogEntriesResponse>(
'/google.logging.v2.LoggingServiceV2/ListLogEntries',
($2.ListLogEntriesRequest value) => value.writeToBuffer(),
($0.ListLogEntriesRequest value) => value.writeToBuffer(),
($core.List<$core.int> value) =>
$2.ListLogEntriesResponse.fromBuffer(value));
$0.ListLogEntriesResponse.fromBuffer(value));
static final _$listMonitoredResourceDescriptors = $grpc.ClientMethod<
$2.ListMonitoredResourceDescriptorsRequest,
$2.ListMonitoredResourceDescriptorsResponse>(
$0.ListMonitoredResourceDescriptorsRequest,
$0.ListMonitoredResourceDescriptorsResponse>(
'/google.logging.v2.LoggingServiceV2/ListMonitoredResourceDescriptors',
($2.ListMonitoredResourceDescriptorsRequest value) =>
($0.ListMonitoredResourceDescriptorsRequest value) =>
value.writeToBuffer(),
($core.List<$core.int> value) =>
$2.ListMonitoredResourceDescriptorsResponse.fromBuffer(value));
$0.ListMonitoredResourceDescriptorsResponse.fromBuffer(value));
static final _$listLogs =
$grpc.ClientMethod<$2.ListLogsRequest, $2.ListLogsResponse>(
$grpc.ClientMethod<$0.ListLogsRequest, $0.ListLogsResponse>(
'/google.logging.v2.LoggingServiceV2/ListLogs',
($2.ListLogsRequest value) => value.writeToBuffer(),
($0.ListLogsRequest value) => value.writeToBuffer(),
($core.List<$core.int> value) =>
$2.ListLogsResponse.fromBuffer(value));
$0.ListLogsResponse.fromBuffer(value));
static final _$tailLogEntries =
$grpc.ClientMethod<$2.TailLogEntriesRequest, $2.TailLogEntriesResponse>(
$grpc.ClientMethod<$0.TailLogEntriesRequest, $0.TailLogEntriesResponse>(
'/google.logging.v2.LoggingServiceV2/TailLogEntries',
($2.TailLogEntriesRequest value) => value.writeToBuffer(),
($0.TailLogEntriesRequest value) => value.writeToBuffer(),
($core.List<$core.int> value) =>
$2.TailLogEntriesResponse.fromBuffer(value));
$0.TailLogEntriesResponse.fromBuffer(value));
LoggingServiceV2Client($grpc.ClientChannel channel,
{$grpc.CallOptions? options,
$core.Iterable<$grpc.ClientInterceptor>? interceptors})
: super(channel, options: options, interceptors: interceptors);
$grpc.ResponseFuture<$1.Empty> deleteLog($2.DeleteLogRequest request,
$grpc.ResponseFuture<$1.Empty> deleteLog($0.DeleteLogRequest request,
{$grpc.CallOptions? options}) {
return $createUnaryCall(_$deleteLog, request, options: options);
}
$grpc.ResponseFuture<$2.WriteLogEntriesResponse> writeLogEntries(
$2.WriteLogEntriesRequest request,
$grpc.ResponseFuture<$0.WriteLogEntriesResponse> writeLogEntries(
$0.WriteLogEntriesRequest request,
{$grpc.CallOptions? options}) {
return $createUnaryCall(_$writeLogEntries, request, options: options);
}
$grpc.ResponseFuture<$2.ListLogEntriesResponse> listLogEntries(
$2.ListLogEntriesRequest request,
$grpc.ResponseFuture<$0.ListLogEntriesResponse> listLogEntries(
$0.ListLogEntriesRequest request,
{$grpc.CallOptions? options}) {
return $createUnaryCall(_$listLogEntries, request, options: options);
}
$grpc.ResponseFuture<$2.ListMonitoredResourceDescriptorsResponse>
$grpc.ResponseFuture<$0.ListMonitoredResourceDescriptorsResponse>
listMonitoredResourceDescriptors(
$2.ListMonitoredResourceDescriptorsRequest request,
$0.ListMonitoredResourceDescriptorsRequest request,
{$grpc.CallOptions? options}) {
return $createUnaryCall(_$listMonitoredResourceDescriptors, request,
options: options);
}
$grpc.ResponseFuture<$2.ListLogsResponse> listLogs($2.ListLogsRequest request,
$grpc.ResponseFuture<$0.ListLogsResponse> listLogs($0.ListLogsRequest request,
{$grpc.CallOptions? options}) {
return $createUnaryCall(_$listLogs, request, options: options);
}
$grpc.ResponseStream<$2.TailLogEntriesResponse> tailLogEntries(
$async.Stream<$2.TailLogEntriesRequest> request,
$grpc.ResponseStream<$0.TailLogEntriesResponse> tailLogEntries(
$async.Stream<$0.TailLogEntriesRequest> request,
{$grpc.CallOptions? options}) {
return $createStreamingCall(_$tailLogEntries, request, options: options);
}
@ -98,100 +98,100 @@ abstract class LoggingServiceV2ServiceBase extends $grpc.Service {
$core.String get $name => 'google.logging.v2.LoggingServiceV2';
LoggingServiceV2ServiceBase() {
$addMethod($grpc.ServiceMethod<$2.DeleteLogRequest, $1.Empty>(
$addMethod($grpc.ServiceMethod<$0.DeleteLogRequest, $1.Empty>(
'DeleteLog',
deleteLog_Pre,
false,
false,
($core.List<$core.int> value) => $2.DeleteLogRequest.fromBuffer(value),
($core.List<$core.int> value) => $0.DeleteLogRequest.fromBuffer(value),
($1.Empty value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$2.WriteLogEntriesRequest,
$2.WriteLogEntriesResponse>(
$addMethod($grpc.ServiceMethod<$0.WriteLogEntriesRequest,
$0.WriteLogEntriesResponse>(
'WriteLogEntries',
writeLogEntries_Pre,
false,
false,
($core.List<$core.int> value) =>
$2.WriteLogEntriesRequest.fromBuffer(value),
($2.WriteLogEntriesResponse value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$2.ListLogEntriesRequest,
$2.ListLogEntriesResponse>(
$0.WriteLogEntriesRequest.fromBuffer(value),
($0.WriteLogEntriesResponse value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$0.ListLogEntriesRequest,
$0.ListLogEntriesResponse>(
'ListLogEntries',
listLogEntries_Pre,
false,
false,
($core.List<$core.int> value) =>
$2.ListLogEntriesRequest.fromBuffer(value),
($2.ListLogEntriesResponse value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$2.ListMonitoredResourceDescriptorsRequest,
$2.ListMonitoredResourceDescriptorsResponse>(
$0.ListLogEntriesRequest.fromBuffer(value),
($0.ListLogEntriesResponse value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$0.ListMonitoredResourceDescriptorsRequest,
$0.ListMonitoredResourceDescriptorsResponse>(
'ListMonitoredResourceDescriptors',
listMonitoredResourceDescriptors_Pre,
false,
false,
($core.List<$core.int> value) =>
$2.ListMonitoredResourceDescriptorsRequest.fromBuffer(value),
($2.ListMonitoredResourceDescriptorsResponse value) =>
$0.ListMonitoredResourceDescriptorsRequest.fromBuffer(value),
($0.ListMonitoredResourceDescriptorsResponse value) =>
value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$2.ListLogsRequest, $2.ListLogsResponse>(
$addMethod($grpc.ServiceMethod<$0.ListLogsRequest, $0.ListLogsResponse>(
'ListLogs',
listLogs_Pre,
false,
false,
($core.List<$core.int> value) => $2.ListLogsRequest.fromBuffer(value),
($2.ListLogsResponse value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$2.TailLogEntriesRequest,
$2.TailLogEntriesResponse>(
($core.List<$core.int> value) => $0.ListLogsRequest.fromBuffer(value),
($0.ListLogsResponse value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$0.TailLogEntriesRequest,
$0.TailLogEntriesResponse>(
'TailLogEntries',
tailLogEntries,
true,
true,
($core.List<$core.int> value) =>
$2.TailLogEntriesRequest.fromBuffer(value),
($2.TailLogEntriesResponse value) => value.writeToBuffer()));
$0.TailLogEntriesRequest.fromBuffer(value),
($0.TailLogEntriesResponse value) => value.writeToBuffer()));
}
$async.Future<$1.Empty> deleteLog_Pre($grpc.ServiceCall call,
$async.Future<$2.DeleteLogRequest> request) async {
$async.Future<$0.DeleteLogRequest> request) async {
return deleteLog(call, await request);
}
$async.Future<$2.WriteLogEntriesResponse> writeLogEntries_Pre(
$async.Future<$0.WriteLogEntriesResponse> writeLogEntries_Pre(
$grpc.ServiceCall call,
$async.Future<$2.WriteLogEntriesRequest> request) async {
$async.Future<$0.WriteLogEntriesRequest> request) async {
return writeLogEntries(call, await request);
}
$async.Future<$2.ListLogEntriesResponse> listLogEntries_Pre(
$async.Future<$0.ListLogEntriesResponse> listLogEntries_Pre(
$grpc.ServiceCall call,
$async.Future<$2.ListLogEntriesRequest> request) async {
$async.Future<$0.ListLogEntriesRequest> request) async {
return listLogEntries(call, await request);
}
$async.Future<$2.ListMonitoredResourceDescriptorsResponse>
$async.Future<$0.ListMonitoredResourceDescriptorsResponse>
listMonitoredResourceDescriptors_Pre(
$grpc.ServiceCall call,
$async.Future<$2.ListMonitoredResourceDescriptorsRequest>
$async.Future<$0.ListMonitoredResourceDescriptorsRequest>
request) async {
return listMonitoredResourceDescriptors(call, await request);
}
$async.Future<$2.ListLogsResponse> listLogs_Pre(
$grpc.ServiceCall call, $async.Future<$2.ListLogsRequest> request) async {
$async.Future<$0.ListLogsResponse> listLogs_Pre(
$grpc.ServiceCall call, $async.Future<$0.ListLogsRequest> request) async {
return listLogs(call, await request);
}
$async.Future<$1.Empty> deleteLog(
$grpc.ServiceCall call, $2.DeleteLogRequest request);
$async.Future<$2.WriteLogEntriesResponse> writeLogEntries(
$grpc.ServiceCall call, $2.WriteLogEntriesRequest request);
$async.Future<$2.ListLogEntriesResponse> listLogEntries(
$grpc.ServiceCall call, $2.ListLogEntriesRequest request);
$async.Future<$2.ListMonitoredResourceDescriptorsResponse>
$grpc.ServiceCall call, $0.DeleteLogRequest request);
$async.Future<$0.WriteLogEntriesResponse> writeLogEntries(
$grpc.ServiceCall call, $0.WriteLogEntriesRequest request);
$async.Future<$0.ListLogEntriesResponse> listLogEntries(
$grpc.ServiceCall call, $0.ListLogEntriesRequest request);
$async.Future<$0.ListMonitoredResourceDescriptorsResponse>
listMonitoredResourceDescriptors($grpc.ServiceCall call,
$2.ListMonitoredResourceDescriptorsRequest request);
$async.Future<$2.ListLogsResponse> listLogs(
$grpc.ServiceCall call, $2.ListLogsRequest request);
$async.Stream<$2.TailLogEntriesResponse> tailLogEntries(
$grpc.ServiceCall call, $async.Stream<$2.TailLogEntriesRequest> request);
$0.ListMonitoredResourceDescriptorsRequest request);
$async.Future<$0.ListLogsResponse> listLogs(
$grpc.ServiceCall call, $0.ListLogsRequest request);
$async.Stream<$0.TailLogEntriesResponse> tailLogEntries(
$grpc.ServiceCall call, $async.Stream<$0.TailLogEntriesRequest> request);
}

View File

@ -3,7 +3,7 @@
// source: google/logging/v2/logging.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields,deprecated_member_use_from_same_package
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,deprecated_member_use_from_same_package,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:core' as $core;
import 'dart:convert' as $convert;
@ -318,7 +318,7 @@ const ListLogsRequest$json = const {
/// Descriptor for `ListLogsRequest`. Decode as a `google.protobuf.DescriptorProto`.
final $typed_data.Uint8List listLogsRequestDescriptor = $convert.base64Decode(
'Cg9MaXN0TG9nc1JlcXVlc3QSOgoGcGFyZW50GAEgASgJQiLgQQL6QRwSGmxvZ2dpbmcuZ29vZ2xlYXBpcy5jb20vTG9nUgZwYXJlbnQSIAoJcGFnZV9zaXplGAIgASgFQgPgQQFSCHBhZ2VTaXplEiIKCnBhZ2VfdG9rZW4YAyABKAlCA+BBAVIJcGFnZVRva2VuEioKDnJlc291cmNlX25hbWVzGAggAygJQgPgQQFSDXJlc291cmNlTmFtZXM=');
'Cg9MaXN0TG9nc1JlcXVlc3QSOgoGcGFyZW50GAEgASgJQiLgQQL6QRwSGmxvZ2dpbmcuZ29vZ2xlYXBpcy5jb20vTG9nUgZwYXJlbnQSIAoJcGFnZV9zaXplGAIgASgFQgPgQQFSCHBhZ2VTaXplEiIKCnBhZ2VfdG9rZW4YAyABKAlCA+BBAVIJcGFnZVRva2VuEkkKDnJlc291cmNlX25hbWVzGAggAygJQiLgQQH6QRwSGmxvZ2dpbmcuZ29vZ2xlYXBpcy5jb20vTG9nUg1yZXNvdXJjZU5hbWVz');
@$core.Deprecated('Use listLogsResponseDescriptor instead')
const ListLogsResponse$json = const {
'1': 'ListLogsResponse',

View File

@ -3,7 +3,7 @@
// source: google/protobuf/any.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:core' as $core;

View File

@ -3,4 +3,4 @@
// source: google/protobuf/any.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name

View File

@ -3,7 +3,7 @@
// source: google/protobuf/any.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields,deprecated_member_use_from_same_package
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,deprecated_member_use_from_same_package,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:core' as $core;
import 'dart:convert' as $convert;

View File

@ -3,7 +3,7 @@
// source: google/protobuf/duration.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:core' as $core;

View File

@ -3,4 +3,4 @@
// source: google/protobuf/duration.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name

View File

@ -3,7 +3,7 @@
// source: google/protobuf/duration.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields,deprecated_member_use_from_same_package
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,deprecated_member_use_from_same_package,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:core' as $core;
import 'dart:convert' as $convert;

View File

@ -3,7 +3,7 @@
// source: google/protobuf/empty.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:core' as $core;

View File

@ -3,4 +3,4 @@
// source: google/protobuf/empty.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name

View File

@ -3,7 +3,7 @@
// source: google/protobuf/empty.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields,deprecated_member_use_from_same_package
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,deprecated_member_use_from_same_package,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:core' as $core;
import 'dart:convert' as $convert;

View File

@ -3,7 +3,7 @@
// source: google/protobuf/struct.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:core' as $core;

View File

@ -3,7 +3,7 @@
// source: google/protobuf/struct.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
// ignore_for_file: UNDEFINED_SHOWN_NAME
import 'dart:core' as $core;

View File

@ -3,7 +3,7 @@
// source: google/protobuf/struct.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields,deprecated_member_use_from_same_package
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,deprecated_member_use_from_same_package,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:core' as $core;
import 'dart:convert' as $convert;

View File

@ -3,7 +3,7 @@
// source: google/protobuf/timestamp.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:core' as $core;

View File

@ -3,4 +3,4 @@
// source: google/protobuf/timestamp.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name

View File

@ -3,7 +3,7 @@
// source: google/protobuf/timestamp.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields,deprecated_member_use_from_same_package
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,deprecated_member_use_from_same_package,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:core' as $core;
import 'dart:convert' as $convert;

View File

@ -3,7 +3,7 @@
// source: google/rpc/status.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:core' as $core;

View File

@ -3,4 +3,4 @@
// source: google/rpc/status.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name

View File

@ -3,7 +3,7 @@
// source: google/rpc/status.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields,deprecated_member_use_from_same_package
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,deprecated_member_use_from_same_package,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:core' as $core;
import 'dart:convert' as $convert;

View File

@ -7,9 +7,11 @@ environment:
dependencies:
async: ^2.2.0
fixnum:
grpc:
path: ../../
protobuf: ^2.0.0
dev_dependencies:
lints: ^2.0.0
test: ^1.6.4

View File

@ -1,7 +1,7 @@
#!/usr/bin/env bash
if [ ! -d "$PROTOBUF" ]; then
echo "Please set the PROTOBUF environment variable to your clone of google/protobuf."
echo "Please set the PROTOBUF environment variable to your clone of protocolbuffers/protobuf."
exit -1
fi

View File

@ -3,7 +3,7 @@
// source: echo.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:core' as $core;

View File

@ -3,4 +3,4 @@
// source: echo.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name

View File

@ -3,7 +3,7 @@
// source: echo.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:async' as $async;

View File

@ -3,7 +3,7 @@
// source: echo.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields,deprecated_member_use_from_same_package
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,deprecated_member_use_from_same_package,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:core' as $core;
import 'dart:convert' as $convert;

View File

@ -13,3 +13,4 @@ dependencies:
dev_dependencies:
build_runner: ^2.0.0
build_web_compilers: ^3.0.0
lints: ^2.0.0

View File

@ -3,7 +3,7 @@
// source: helloworld.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:core' as $core;

View File

@ -3,4 +3,4 @@
// source: helloworld.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name

View File

@ -3,7 +3,7 @@
// source: helloworld.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:async' as $async;

View File

@ -3,7 +3,7 @@
// source: helloworld.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields,deprecated_member_use_from_same_package
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,deprecated_member_use_from_same_package,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:core' as $core;
import 'dart:convert' as $convert;

View File

@ -10,3 +10,6 @@ dependencies:
grpc:
path: ../../
protobuf: ^2.0.0
dev_dependencies:
lints: ^2.0.0

View File

@ -3,7 +3,7 @@
// source: metadata.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:core' as $core;

View File

@ -1,6 +0,0 @@
///
// Generated code. Do not modify.
// source: metadata.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields

View File

@ -3,7 +3,7 @@
// source: metadata.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:async' as $async;

View File

@ -1,41 +0,0 @@
///
// Generated code. Do not modify.
// source: metadata.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields,deprecated_member_use_from_same_package
import 'dart:core' as $core;
import 'dart:convert' as $convert;
import 'dart:typed_data' as $typed_data;
@$core.Deprecated('Use recordDescriptor instead')
const Record$json = const {
'1': 'Record',
'2': const [
const {'1': 'value', '3': 1, '4': 1, '5': 9, '10': 'value'},
],
};
/// Descriptor for `Record`. Decode as a `google.protobuf.DescriptorProto`.
final $typed_data.Uint8List recordDescriptor =
$convert.base64Decode('CgZSZWNvcmQSFAoFdmFsdWUYASABKAlSBXZhbHVl');
@$core.Deprecated('Use numberDescriptor instead')
const Number$json = const {
'1': 'Number',
'2': const [
const {'1': 'value', '3': 1, '4': 1, '5': 5, '10': 'value'},
],
};
/// Descriptor for `Number`. Decode as a `google.protobuf.DescriptorProto`.
final $typed_data.Uint8List numberDescriptor =
$convert.base64Decode('CgZOdW1iZXISFAoFdmFsdWUYASABKAVSBXZhbHVl');
@$core.Deprecated('Use emptyDescriptor instead')
const Empty$json = const {
'1': 'Empty',
};
/// Descriptor for `Empty`. Decode as a `google.protobuf.DescriptorProto`.
final $typed_data.Uint8List emptyDescriptor =
$convert.base64Decode('CgVFbXB0eQ==');

View File

@ -27,7 +27,7 @@ class MetadataService extends MetadataServiceBase {
final peer = call.clientMetadata!['peer']!;
final count = callCount++;
print('Echo: Call #$count: Peer: $peer, request: ${request.value}');
call.headers!['count'] = '${count}';
call.headers!['count'] = '$count';
call.trailers!['hello'] = request.value;
final delay = call.clientMetadata!['delay'];

View File

@ -12,4 +12,5 @@ dependencies:
protobuf: ^2.0.0
dev_dependencies:
lints: ^2.0.0
test: ^1.6.0

View File

@ -1,4 +1,4 @@
#!/usr/bin/env bash
protoc --dart_out=grpc:lib/src/generated -Iprotos protos/metadata.proto
rm lib/src/generated/metadata.pb{enum,json}.dart
dartfmt -w lib/src/generated
dart format -o write lib/src/generated

View File

@ -3,7 +3,7 @@
// source: route_guide.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:core' as $core;

View File

@ -3,4 +3,4 @@
// source: route_guide.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name

View File

@ -3,7 +3,7 @@
// source: route_guide.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:async' as $async;

View File

@ -3,7 +3,7 @@
// source: route_guide.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields,deprecated_member_use_from_same_package
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,deprecated_member_use_from_same_package,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:core' as $core;
import 'dart:convert' as $convert;

View File

@ -11,3 +11,6 @@ dependencies:
path: ../../
protobuf: ^2.0.0
collection: ^1.15.0-nullsafety.4
dev_dependencies:
lints: ^2.0.0

View File

@ -3,7 +3,7 @@
// source: empty.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:core' as $core;

View File

@ -3,7 +3,7 @@
// source: messages.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:core' as $core;
@ -1181,7 +1181,7 @@ class ReconnectInfo extends $pb.GeneratedMessage {
const $core.bool.fromEnvironment('protobuf.omit_field_names')
? ''
: 'backoffMs',
$pb.PbFieldType.P3)
$pb.PbFieldType.K3)
..hasRequiredFields = false;
ReconnectInfo._() : super();

View File

@ -3,7 +3,7 @@
// source: messages.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
// ignore_for_file: UNDEFINED_SHOWN_NAME
import 'dart:core' as $core;

View File

@ -3,6 +3,6 @@
// source: test.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:core' as $core;

View File

@ -3,7 +3,7 @@
// source: test.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:async' as $async;

View File

@ -3,4 +3,4 @@ mkdir -p lib/src/generated
protoc --dart_out=grpc:lib/src/generated -Iprotos/ protos/*.proto
rm lib/src/generated/*.pbjson.dart
rm lib/src/generated/{empty,test}.pbenum.dart
dartfmt -w lib/src/generated
dart format -o write lib/src/generated

View File

@ -34,34 +34,23 @@ export 'src/shared/api.dart';
/// provided for each case.
class GrpcOrGrpcWebClientChannel extends GrpcOrGrpcWebClientChannelInternal {
GrpcOrGrpcWebClientChannel.toSeparateEndpoints({
required String grpcHost,
required int grpcPort,
required bool grpcTransportSecure,
required String grpcWebHost,
required int grpcWebPort,
required bool grpcWebTransportSecure,
}) : super(
grpcHost: grpcHost,
grpcPort: grpcPort,
grpcTransportSecure: grpcTransportSecure,
grpcWebHost: grpcWebHost,
grpcWebPort: grpcWebPort,
grpcWebTransportSecure: grpcWebTransportSecure,
);
required super.grpcHost,
required super.grpcPort,
required super.grpcTransportSecure,
required super.grpcWebHost,
required super.grpcWebPort,
required super.grpcWebTransportSecure,
});
GrpcOrGrpcWebClientChannel.toSeparatePorts({
required String host,
required int grpcPort,
required bool grpcTransportSecure,
required int grpcWebPort,
required bool grpcWebTransportSecure,
required super.grpcPort,
required super.grpcTransportSecure,
required super.grpcWebPort,
required super.grpcWebTransportSecure,
}) : super(
grpcHost: host,
grpcPort: grpcPort,
grpcTransportSecure: grpcTransportSecure,
grpcWebHost: host,
grpcWebPort: grpcWebPort,
grpcWebTransportSecure: grpcWebTransportSecure,
);
GrpcOrGrpcWebClientChannel.toSingleEndpoint({
@ -78,8 +67,8 @@ class GrpcOrGrpcWebClientChannel extends GrpcOrGrpcWebClientChannelInternal {
);
GrpcOrGrpcWebClientChannel.grpc(
Object host, {
int port = 443,
ChannelOptions options = const ChannelOptions(),
}) : super.grpc(host, port: port, options: options);
super.host, {
super.port = 443,
super.options = const ChannelOptions(),
}) : super.grpc();
}

View File

@ -118,7 +118,7 @@ Future<HttpBasedAuthenticator> applicationDefaultCredentialsAuthenticator(
// Attempt to load form credFile, if detected
if (credFile != null) {
var credentials;
Object? credentials;
try {
credentials = json.decode(await credFile.readAsString());
} on IOException {

View File

@ -30,7 +30,7 @@ class RS256Signer {
// NIST sha-256 OID (2 16 840 1 101 3 4 2 1)
// See a reference for the encoding here:
// http://msdn.microsoft.com/en-us/library/bb540809%28v=vs.85%29.aspx
static const _RSA_SHA256_ALGORITHM_IDENTIFIER = [
static const _rsaSha256AlgorithmIdentifier = [
0x06,
0x09,
0x60,
@ -69,21 +69,21 @@ class RS256Signer {
// }
var offset = 0;
final digestInfo = Uint8List(
2 + 2 + _RSA_SHA256_ALGORITHM_IDENTIFIER.length + 2 + 2 + hash.length);
2 + 2 + _rsaSha256AlgorithmIdentifier.length + 2 + 2 + hash.length);
{
// DigestInfo
digestInfo[offset++] = ASN1Parser.SEQUENCE_TAG;
digestInfo[offset++] = ASN1Parser.sequenceTag;
digestInfo[offset++] = digestInfo.length - 2;
{
// AlgorithmIdentifier.
digestInfo[offset++] = ASN1Parser.SEQUENCE_TAG;
digestInfo[offset++] = _RSA_SHA256_ALGORITHM_IDENTIFIER.length + 2;
digestInfo.setAll(offset, _RSA_SHA256_ALGORITHM_IDENTIFIER);
offset += _RSA_SHA256_ALGORITHM_IDENTIFIER.length;
digestInfo[offset++] = ASN1Parser.NULL_TAG;
digestInfo[offset++] = ASN1Parser.sequenceTag;
digestInfo[offset++] = _rsaSha256AlgorithmIdentifier.length + 2;
digestInfo.setAll(offset, _rsaSha256AlgorithmIdentifier);
offset += _rsaSha256AlgorithmIdentifier.length;
digestInfo[offset++] = ASN1Parser.nullTag;
digestInfo[offset++] = 0;
}
digestInfo[offset++] = ASN1Parser.OCTET_STRING_TAG;
digestInfo[offset++] = ASN1Parser.octetStringTag;
digestInfo[offset++] = hash.length;
digestInfo.setAll(offset, hash);
}
@ -92,11 +92,11 @@ class RS256Signer {
}
class ASN1Parser {
static const INTEGER_TAG = 0x02;
static const OCTET_STRING_TAG = 0x04;
static const NULL_TAG = 0x05;
static const OBJECT_ID_TAG = 0x06;
static const SEQUENCE_TAG = 0x30;
static const integerTag = 0x02;
static const octetStringTag = 0x04;
static const nullTag = 0x05;
static const objectIdTag = 0x06;
static const sequenceTag = 0x30;
static ASN1Object parse(Uint8List bytes) {
Never invalidFormat(String msg) {
@ -157,19 +157,19 @@ class ASN1Parser {
checkNBytesAvailable(1);
final tag = bytes[offset++];
switch (tag) {
case INTEGER_TAG:
case integerTag:
final size = readEncodedLength();
return ASN1Integer(RSAAlgorithm.bytes2BigInt(readBytes(size)));
case OCTET_STRING_TAG:
case octetStringTag:
final size = readEncodedLength();
return ASN1OctetString(readBytes(size));
case NULL_TAG:
case nullTag:
readNullBytes();
return ASN1Null();
case OBJECT_ID_TAG:
case objectIdTag:
final size = readEncodedLength();
return ASN1ObjectIdentifier(readBytes(size));
case SEQUENCE_TAG:
case sequenceTag:
final lengthInBytes = readEncodedLength();
if ((offset + lengthInBytes) > end) {
invalidFormat('Tried to read more bytes than available.');

View File

@ -36,8 +36,8 @@ class GrpcOrGrpcWebClientChannelInternal extends ClientChannel {
);
GrpcOrGrpcWebClientChannelInternal.grpc(
Object host, {
required int port,
required ChannelOptions options,
}) : super(host, port: port, options: options);
super.host, {
required super.port,
required super.options,
});
}

View File

@ -193,7 +193,7 @@ class Http2ClientConnection implements connection.ClientConnection {
@override
Future<void> shutdown() async {
if (_state == ConnectionState.shutdown) return null;
if (_state == ConnectionState.shutdown) return;
_setShutdownState();
await _transportConnection?.finish();
}
@ -254,7 +254,9 @@ class Http2ClientConnection implements connection.ClientConnection {
}
// TODO(jakobr): Log error.
_cancelTimer();
_pendingCalls.forEach((call) => _failCall(call, error));
for (var call in _pendingCalls) {
_failCall(call, error);
}
_pendingCalls.clear();
_setState(ConnectionState.idle);
}
@ -361,9 +363,9 @@ class _SocketTransportConnector implements ClientTransportConnector {
String _makeAuthority() {
final host = _host;
final portSuffix = _port == 443 ? '' : ':$_port';
final hostName;
final String hostName;
if (host is String) {
hostName = '$host';
hostName = host;
} else {
host as InternetAddress;
if (host.type == InternetAddressType.unix) {

View File

@ -20,7 +20,7 @@ import 'dart:typed_data';
import '../../shared/message.dart';
import '../../shared/status.dart';
enum _GrpcWebParseState { Init, Length, Message }
enum _GrpcWebParseState { init, length, message }
class GrpcWebDecoder extends Converter<ByteBuffer, GrpcMessage> {
@override
@ -46,7 +46,7 @@ class _GrpcWebConversionSink extends ChunkedConversionSink<ByteBuffer> {
final _dataHeader = Uint8List(4);
_GrpcWebParseState _state = _GrpcWebParseState.Init;
_GrpcWebParseState _state = _GrpcWebParseState.init;
var _chunkOffset = 0;
int? _frameType;
var _dataOffset = 0;
@ -58,9 +58,9 @@ class _GrpcWebConversionSink extends ChunkedConversionSink<ByteBuffer> {
final frameType = chunkData[_chunkOffset];
_chunkOffset++;
if (frameType != frameTypeData && frameType != frameTypeTrailers) {
throw GrpcError.unimplemented('Invalid frame type: ${frameType}');
throw GrpcError.unimplemented('Invalid frame type: $frameType');
}
_state = _GrpcWebParseState.Length;
_state = _GrpcWebParseState.length;
return frameType;
}
@ -77,7 +77,7 @@ class _GrpcWebConversionSink extends ChunkedConversionSink<ByteBuffer> {
if (_dataOffset == _dataHeader.lengthInBytes) {
final dataLength = _dataHeader.buffer.asByteData().getUint32(0);
_dataOffset = 0;
_state = _GrpcWebParseState.Message;
_state = _GrpcWebParseState.message;
_data = Uint8List(dataLength);
if (dataLength == 0) {
// empty message
@ -112,7 +112,7 @@ class _GrpcWebConversionSink extends ChunkedConversionSink<ByteBuffer> {
_out.add(GrpcMetadata(headers));
break;
}
_state = _GrpcWebParseState.Init;
_state = _GrpcWebParseState.init;
_data = null;
_dataOffset = 0;
}
@ -134,13 +134,13 @@ class _GrpcWebConversionSink extends ChunkedConversionSink<ByteBuffer> {
final chunkData = chunk.asUint8List();
while (_chunkOffset < chunk.lengthInBytes) {
switch (_state) {
case _GrpcWebParseState.Init:
case _GrpcWebParseState.init:
_frameType = _parseFrameType(chunkData);
break;
case _GrpcWebParseState.Length:
case _GrpcWebParseState.length:
_parseLength(chunkData);
break;
case _GrpcWebParseState.Message:
case _GrpcWebParseState.message:
_parseMessage(chunkData);
break;
}

View File

@ -3,7 +3,7 @@
// source: google/protobuf/any.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:core' as $core;

View File

@ -3,4 +3,4 @@
// source: google/protobuf/any.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name

View File

@ -3,10 +3,13 @@
// source: google/protobuf/any.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,deprecated_member_use_from_same_package,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:core' as $core;
import 'dart:convert' as $convert;
import 'dart:typed_data' as $typed_data;
@$core.Deprecated('Use anyDescriptor instead')
const Any$json = const {
'1': 'Any',
'2': const [
@ -14,3 +17,7 @@ const Any$json = const {
const {'1': 'value', '3': 2, '4': 1, '5': 12, '10': 'value'},
],
};
/// Descriptor for `Any`. Decode as a `google.protobuf.DescriptorProto`.
final $typed_data.Uint8List anyDescriptor = $convert.base64Decode(
'CgNBbnkSGQoIdHlwZV91cmwYASABKAlSB3R5cGVVcmwSFAoFdmFsdWUYAiABKAxSBXZhbHVl');

View File

@ -3,7 +3,7 @@
// source: google/protobuf/duration.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:core' as $core;

View File

@ -3,4 +3,4 @@
// source: google/protobuf/duration.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name

View File

@ -3,10 +3,13 @@
// source: google/protobuf/duration.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,deprecated_member_use_from_same_package,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:core' as $core;
import 'dart:convert' as $convert;
import 'dart:typed_data' as $typed_data;
@$core.Deprecated('Use durationDescriptor instead')
const Duration$json = const {
'1': 'Duration',
'2': const [
@ -14,3 +17,7 @@ const Duration$json = const {
const {'1': 'nanos', '3': 2, '4': 1, '5': 5, '10': 'nanos'},
],
};
/// Descriptor for `Duration`. Decode as a `google.protobuf.DescriptorProto`.
final $typed_data.Uint8List durationDescriptor = $convert.base64Decode(
'CghEdXJhdGlvbhIYCgdzZWNvbmRzGAEgASgDUgdzZWNvbmRzEhQKBW5hbm9zGAIgASgFUgVuYW5vcw==');

View File

@ -3,7 +3,7 @@
// source: google/rpc/code.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:core' as $core;

View File

@ -3,7 +3,7 @@
// source: google/rpc/code.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
// ignore_for_file: UNDEFINED_SHOWN_NAME
import 'dart:core' as $core;

View File

@ -3,10 +3,13 @@
// source: google/rpc/code.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,deprecated_member_use_from_same_package,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:core' as $core;
import 'dart:convert' as $convert;
import 'dart:typed_data' as $typed_data;
@$core.Deprecated('Use codeDescriptor instead')
const Code$json = const {
'1': 'Code',
'2': const [
@ -29,3 +32,7 @@ const Code$json = const {
const {'1': 'DATA_LOSS', '2': 15},
],
};
/// Descriptor for `Code`. Decode as a `google.protobuf.EnumDescriptorProto`.
final $typed_data.Uint8List codeDescriptor = $convert.base64Decode(
'CgRDb2RlEgYKAk9LEAASDQoJQ0FOQ0VMTEVEEAESCwoHVU5LTk9XThACEhQKEElOVkFMSURfQVJHVU1FTlQQAxIVChFERUFETElORV9FWENFRURFRBAEEg0KCU5PVF9GT1VORBAFEhIKDkFMUkVBRFlfRVhJU1RTEAYSFQoRUEVSTUlTU0lPTl9ERU5JRUQQBxITCg9VTkFVVEhFTlRJQ0FURUQQEBIWChJSRVNPVVJDRV9FWEhBVVNURUQQCBIXChNGQUlMRURfUFJFQ09ORElUSU9OEAkSCwoHQUJPUlRFRBAKEhAKDE9VVF9PRl9SQU5HRRALEhEKDVVOSU1QTEVNRU5URUQQDBIMCghJTlRFUk5BTBANEg8KC1VOQVZBSUxBQkxFEA4SDQoJREFUQV9MT1NTEA8=');

View File

@ -3,7 +3,7 @@
// source: google/rpc/error_details.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:core' as $core;

View File

@ -3,4 +3,4 @@
// source: google/rpc/error_details.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name

View File

@ -3,10 +3,13 @@
// source: google/rpc/error_details.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,deprecated_member_use_from_same_package,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:core' as $core;
import 'dart:convert' as $convert;
import 'dart:typed_data' as $typed_data;
@$core.Deprecated('Use retryInfoDescriptor instead')
const RetryInfo$json = const {
'1': 'RetryInfo',
'2': const [
@ -21,6 +24,10 @@ const RetryInfo$json = const {
],
};
/// Descriptor for `RetryInfo`. Decode as a `google.protobuf.DescriptorProto`.
final $typed_data.Uint8List retryInfoDescriptor = $convert.base64Decode(
'CglSZXRyeUluZm8SOgoLcmV0cnlfZGVsYXkYASABKAsyGS5nb29nbGUucHJvdG9idWYuRHVyYXRpb25SCnJldHJ5RGVsYXk=');
@$core.Deprecated('Use debugInfoDescriptor instead')
const DebugInfo$json = const {
'1': 'DebugInfo',
'2': const [
@ -29,6 +36,10 @@ const DebugInfo$json = const {
],
};
/// Descriptor for `DebugInfo`. Decode as a `google.protobuf.DescriptorProto`.
final $typed_data.Uint8List debugInfoDescriptor = $convert.base64Decode(
'CglEZWJ1Z0luZm8SIwoNc3RhY2tfZW50cmllcxgBIAMoCVIMc3RhY2tFbnRyaWVzEhYKBmRldGFpbBgCIAEoCVIGZGV0YWls');
@$core.Deprecated('Use quotaFailureDescriptor instead')
const QuotaFailure$json = const {
'1': 'QuotaFailure',
'2': const [
@ -44,6 +55,7 @@ const QuotaFailure$json = const {
'3': const [QuotaFailure_Violation$json],
};
@$core.Deprecated('Use quotaFailureDescriptor instead')
const QuotaFailure_Violation$json = const {
'1': 'Violation',
'2': const [
@ -52,6 +64,10 @@ const QuotaFailure_Violation$json = const {
],
};
/// Descriptor for `QuotaFailure`. Decode as a `google.protobuf.DescriptorProto`.
final $typed_data.Uint8List quotaFailureDescriptor = $convert.base64Decode(
'CgxRdW90YUZhaWx1cmUSQgoKdmlvbGF0aW9ucxgBIAMoCzIiLmdvb2dsZS5ycGMuUXVvdGFGYWlsdXJlLlZpb2xhdGlvblIKdmlvbGF0aW9ucxpHCglWaW9sYXRpb24SGAoHc3ViamVjdBgBIAEoCVIHc3ViamVjdBIgCgtkZXNjcmlwdGlvbhgCIAEoCVILZGVzY3JpcHRpb24=');
@$core.Deprecated('Use errorInfoDescriptor instead')
const ErrorInfo$json = const {
'1': 'ErrorInfo',
'2': const [
@ -69,6 +85,7 @@ const ErrorInfo$json = const {
'3': const [ErrorInfo_MetadataEntry$json],
};
@$core.Deprecated('Use errorInfoDescriptor instead')
const ErrorInfo_MetadataEntry$json = const {
'1': 'MetadataEntry',
'2': const [
@ -78,6 +95,10 @@ const ErrorInfo_MetadataEntry$json = const {
'7': const {'7': true},
};
/// Descriptor for `ErrorInfo`. Decode as a `google.protobuf.DescriptorProto`.
final $typed_data.Uint8List errorInfoDescriptor = $convert.base64Decode(
'CglFcnJvckluZm8SFgoGcmVhc29uGAEgASgJUgZyZWFzb24SFgoGZG9tYWluGAIgASgJUgZkb21haW4SPwoIbWV0YWRhdGEYAyADKAsyIy5nb29nbGUucnBjLkVycm9ySW5mby5NZXRhZGF0YUVudHJ5UghtZXRhZGF0YRo7Cg1NZXRhZGF0YUVudHJ5EhAKA2tleRgBIAEoCVIDa2V5EhQKBXZhbHVlGAIgASgJUgV2YWx1ZToCOAE=');
@$core.Deprecated('Use preconditionFailureDescriptor instead')
const PreconditionFailure$json = const {
'1': 'PreconditionFailure',
'2': const [
@ -93,6 +114,7 @@ const PreconditionFailure$json = const {
'3': const [PreconditionFailure_Violation$json],
};
@$core.Deprecated('Use preconditionFailureDescriptor instead')
const PreconditionFailure_Violation$json = const {
'1': 'Violation',
'2': const [
@ -102,6 +124,10 @@ const PreconditionFailure_Violation$json = const {
],
};
/// Descriptor for `PreconditionFailure`. Decode as a `google.protobuf.DescriptorProto`.
final $typed_data.Uint8List preconditionFailureDescriptor = $convert.base64Decode(
'ChNQcmVjb25kaXRpb25GYWlsdXJlEkkKCnZpb2xhdGlvbnMYASADKAsyKS5nb29nbGUucnBjLlByZWNvbmRpdGlvbkZhaWx1cmUuVmlvbGF0aW9uUgp2aW9sYXRpb25zGlsKCVZpb2xhdGlvbhISCgR0eXBlGAEgASgJUgR0eXBlEhgKB3N1YmplY3QYAiABKAlSB3N1YmplY3QSIAoLZGVzY3JpcHRpb24YAyABKAlSC2Rlc2NyaXB0aW9u');
@$core.Deprecated('Use badRequestDescriptor instead')
const BadRequest$json = const {
'1': 'BadRequest',
'2': const [
@ -117,6 +143,7 @@ const BadRequest$json = const {
'3': const [BadRequest_FieldViolation$json],
};
@$core.Deprecated('Use badRequestDescriptor instead')
const BadRequest_FieldViolation$json = const {
'1': 'FieldViolation',
'2': const [
@ -125,6 +152,10 @@ const BadRequest_FieldViolation$json = const {
],
};
/// Descriptor for `BadRequest`. Decode as a `google.protobuf.DescriptorProto`.
final $typed_data.Uint8List badRequestDescriptor = $convert.base64Decode(
'CgpCYWRSZXF1ZXN0ElAKEGZpZWxkX3Zpb2xhdGlvbnMYASADKAsyJS5nb29nbGUucnBjLkJhZFJlcXVlc3QuRmllbGRWaW9sYXRpb25SD2ZpZWxkVmlvbGF0aW9ucxpICg5GaWVsZFZpb2xhdGlvbhIUCgVmaWVsZBgBIAEoCVIFZmllbGQSIAoLZGVzY3JpcHRpb24YAiABKAlSC2Rlc2NyaXB0aW9u');
@$core.Deprecated('Use requestInfoDescriptor instead')
const RequestInfo$json = const {
'1': 'RequestInfo',
'2': const [
@ -133,6 +164,10 @@ const RequestInfo$json = const {
],
};
/// Descriptor for `RequestInfo`. Decode as a `google.protobuf.DescriptorProto`.
final $typed_data.Uint8List requestInfoDescriptor = $convert.base64Decode(
'CgtSZXF1ZXN0SW5mbxIdCgpyZXF1ZXN0X2lkGAEgASgJUglyZXF1ZXN0SWQSIQoMc2VydmluZ19kYXRhGAIgASgJUgtzZXJ2aW5nRGF0YQ==');
@$core.Deprecated('Use resourceInfoDescriptor instead')
const ResourceInfo$json = const {
'1': 'ResourceInfo',
'2': const [
@ -143,6 +178,10 @@ const ResourceInfo$json = const {
],
};
/// Descriptor for `ResourceInfo`. Decode as a `google.protobuf.DescriptorProto`.
final $typed_data.Uint8List resourceInfoDescriptor = $convert.base64Decode(
'CgxSZXNvdXJjZUluZm8SIwoNcmVzb3VyY2VfdHlwZRgBIAEoCVIMcmVzb3VyY2VUeXBlEiMKDXJlc291cmNlX25hbWUYAiABKAlSDHJlc291cmNlTmFtZRIUCgVvd25lchgDIAEoCVIFb3duZXISIAoLZGVzY3JpcHRpb24YBCABKAlSC2Rlc2NyaXB0aW9u');
@$core.Deprecated('Use helpDescriptor instead')
const Help$json = const {
'1': 'Help',
'2': const [
@ -158,6 +197,7 @@ const Help$json = const {
'3': const [Help_Link$json],
};
@$core.Deprecated('Use helpDescriptor instead')
const Help_Link$json = const {
'1': 'Link',
'2': const [
@ -166,6 +206,10 @@ const Help_Link$json = const {
],
};
/// Descriptor for `Help`. Decode as a `google.protobuf.DescriptorProto`.
final $typed_data.Uint8List helpDescriptor = $convert.base64Decode(
'CgRIZWxwEisKBWxpbmtzGAEgAygLMhUuZ29vZ2xlLnJwYy5IZWxwLkxpbmtSBWxpbmtzGjoKBExpbmsSIAoLZGVzY3JpcHRpb24YASABKAlSC2Rlc2NyaXB0aW9uEhAKA3VybBgCIAEoCVIDdXJs');
@$core.Deprecated('Use localizedMessageDescriptor instead')
const LocalizedMessage$json = const {
'1': 'LocalizedMessage',
'2': const [
@ -173,3 +217,7 @@ const LocalizedMessage$json = const {
const {'1': 'message', '3': 2, '4': 1, '5': 9, '10': 'message'},
],
};
/// Descriptor for `LocalizedMessage`. Decode as a `google.protobuf.DescriptorProto`.
final $typed_data.Uint8List localizedMessageDescriptor = $convert.base64Decode(
'ChBMb2NhbGl6ZWRNZXNzYWdlEhYKBmxvY2FsZRgBIAEoCVIGbG9jYWxlEhgKB21lc3NhZ2UYAiABKAlSB21lc3NhZ2U=');

View File

@ -3,7 +3,7 @@
// source: google/rpc/status.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:core' as $core;

View File

@ -3,4 +3,4 @@
// source: google/rpc/status.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name

View File

@ -3,10 +3,13 @@
// source: google/rpc/status.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,unnecessary_const,non_constant_identifier_names,library_prefixes,unused_import,unused_shown_name,return_of_invalid_type,unnecessary_this,prefer_final_fields
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,deprecated_member_use_from_same_package,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:core' as $core;
import 'dart:convert' as $convert;
import 'dart:typed_data' as $typed_data;
@$core.Deprecated('Use statusDescriptor instead')
const Status$json = const {
'1': 'Status',
'2': const [
@ -22,3 +25,7 @@ const Status$json = const {
},
],
};
/// Descriptor for `Status`. Decode as a `google.protobuf.DescriptorProto`.
final $typed_data.Uint8List statusDescriptor = $convert.base64Decode(
'CgZTdGF0dXMSEgoEY29kZRgBIAEoBVIEY29kZRIYCgdtZXNzYWdlGAIgASgJUgdtZXNzYWdlEi4KB2RldGFpbHMYAyADKAsyFC5nb29nbGUucHJvdG9idWYuQW55UgdkZXRhaWxz');

View File

@ -30,7 +30,7 @@ import 'interceptor.dart';
import 'service.dart';
/// Handles an incoming gRPC call.
class ServerHandler_ extends ServiceCall {
class ServerHandlerImpl extends ServiceCall {
final ServerTransportStream _stream;
final Service? Function(String service) _serviceLookup;
final List<Interceptor> _interceptors;
@ -61,7 +61,7 @@ class ServerHandler_ extends ServiceCall {
Timer? _timeoutTimer;
final X509Certificate? _clientCertificate;
ServerHandler_(this._serviceLookup, this._stream, this._interceptors,
ServerHandlerImpl(this._serviceLookup, this._stream, this._interceptors,
this._codecRegistry,
[this._clientCertificate]);
@ -251,7 +251,7 @@ class ServerHandler_ extends ServiceCall {
}
final data = message;
var request;
Object? request;
try {
request = _descriptor.deserialize(data.data);
} catch (error) {
@ -425,7 +425,8 @@ class ServerHandler_ extends ServiceCall {
}
}
class ServerHandler extends ServerHandler_ {
class ServerHandler extends ServerHandlerImpl {
// ignore: use_super_parameters
ServerHandler(Service Function(String service) serviceLookup, stream,
[List<Interceptor> interceptors = const <Interceptor>[],
CodecRegistry? codecRegistry,

View File

@ -107,7 +107,7 @@ class ConnectionServer {
Future<void> serveConnection(ServerTransportConnection connection,
[X509Certificate? clientCertificate]) async {
_connections.add(connection);
ServerHandler_? handler;
ServerHandlerImpl? handler;
// TODO(jakobr): Set active state handlers, close connection after idle
// timeout.
connection.incomingStreams.listen((stream) {
@ -127,9 +127,9 @@ class ConnectionServer {
}
@visibleForTesting
ServerHandler_ serveStream_(ServerTransportStream stream,
ServerHandlerImpl serveStream_(ServerTransportStream stream,
[X509Certificate? clientCertificate]) {
return ServerHandler_(
return ServerHandlerImpl(
lookupService, stream, _interceptors, _codecRegistry,
// ignore: unnecessary_cast
clientCertificate as io_bits.X509Certificate?,
@ -146,10 +146,10 @@ class Server extends ConnectionServer {
/// Create a server for the given [services].
Server(
List<Service> services, [
List<Interceptor> interceptors = const <Interceptor>[],
CodecRegistry? codecRegistry,
]) : super(services, interceptors, codecRegistry);
super.services, [
super.interceptors,
super.codecRegistry,
]);
/// The port that the server is listening on, or `null` if the server is not
/// active.
@ -223,9 +223,9 @@ class Server extends ConnectionServer {
@override
@visibleForTesting
ServerHandler_ serveStream_(ServerTransportStream stream,
ServerHandlerImpl serveStream_(ServerTransportStream stream,
[X509Certificate? clientCertificate]) {
return ServerHandler_(
return ServerHandlerImpl(
lookupService,
stream,
_interceptors,

View File

@ -64,20 +64,20 @@ class ServiceMethod<Q, R> {
}
Future<Q> _toSingleFuture(Stream<Q> stream) {
Q _ensureOnlyOneRequest(Q? previous, Q element) {
Q ensureOnlyOneRequest(Q? previous, Q element) {
if (previous != null) {
throw GrpcError.unimplemented('More than one request received');
}
return element;
}
Q _ensureOneRequest(Q? value) {
Q ensureOneRequest(Q? value) {
if (value == null) throw GrpcError.unimplemented('No requests received');
return value;
}
final future =
stream.fold<Q?>(null, _ensureOnlyOneRequest).then(_ensureOneRequest);
stream.fold<Q?>(null, ensureOnlyOneRequest).then(ensureOneRequest);
// Make sure errors on the future aren't unhandled, but return the original
// future so the request handler can also get the error.
_awaitAndCatch(future);

View File

@ -400,7 +400,7 @@ void validateHttpStatusAndContentType(
throw GrpcError.custom(
status,
error?.message ??
'HTTP connection completed with ${httpStatus} instead of 200',
'HTTP connection completed with $httpStatus instead of 200',
error?.details,
rawResponse,
error?.trailers ?? toCustomTrailers(headers),
@ -417,7 +417,7 @@ void validateHttpStatusAndContentType(
// Check if content-type header indicates a supported format.
if (!_validContentTypePrefix.any(contentType.startsWith)) {
throw GrpcError.unknown(
'unsupported content-type (${contentType})', null, rawResponse);
'unsupported content-type ($contentType)', null, rawResponse);
}
}

View File

@ -1,12 +1,12 @@
name: grpc
description: Dart implementation of gRPC, a high performance, open-source universal RPC framework.
version: 3.1.0
version: 3.1.1-dev
repository: https://github.com/grpc/grpc-dart
environment:
sdk: '>=2.12.0 <3.0.0'
sdk: '>=2.17.0 <3.0.0'
dependencies:
archive: ^3.0.0
@ -22,6 +22,7 @@ dependencies:
dev_dependencies:
build_runner: ^2.0.0
build_test: ^2.0.0
lints: ^2.0.0
mockito: ^5.0.0
path: ^1.8.0
test: ^1.16.0

Some files were not shown because too many files have changed in this diff Show More