Merge "TBR: Remove a redundant "--enable-multiprocess" flag."
diff --git a/lib/gen/dart-gen/mojom/lib/mojo/syncbase.mojom.dart b/lib/gen/dart-gen/mojom/lib/mojo/syncbase.mojom.dart
index 16390ec..bb2f597 100644
--- a/lib/gen/dart-gen/mojom/lib/mojo/syncbase.mojom.dart
+++ b/lib/gen/dart-gen/mojom/lib/mojo/syncbase.mojom.dart
@@ -952,15 +952,15 @@
}
-class ExecStreamOnResultParams extends bindings.Struct {
+class _ExecStreamOnResultParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(16, 0)
];
Result result = null;
- ExecStreamOnResultParams() : super(kVersions.last.size);
+ _ExecStreamOnResultParams() : super(kVersions.last.size);
- static ExecStreamOnResultParams deserialize(bindings.Message message) {
+ static _ExecStreamOnResultParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -969,11 +969,11 @@
return result;
}
- static ExecStreamOnResultParams decode(bindings.Decoder decoder0) {
+ static _ExecStreamOnResultParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- ExecStreamOnResultParams result = new ExecStreamOnResultParams();
+ _ExecStreamOnResultParams result = new _ExecStreamOnResultParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -1008,7 +1008,7 @@
}
String toString() {
- return "ExecStreamOnResultParams("
+ return "_ExecStreamOnResultParams("
"result: $result" ")";
}
@@ -1078,15 +1078,15 @@
}
-class ExecStreamOnDoneParams extends bindings.Struct {
+class _ExecStreamOnDoneParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(16, 0)
];
Error err = null;
- ExecStreamOnDoneParams() : super(kVersions.last.size);
+ _ExecStreamOnDoneParams() : super(kVersions.last.size);
- static ExecStreamOnDoneParams deserialize(bindings.Message message) {
+ static _ExecStreamOnDoneParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -1095,11 +1095,11 @@
return result;
}
- static ExecStreamOnDoneParams decode(bindings.Decoder decoder0) {
+ static _ExecStreamOnDoneParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- ExecStreamOnDoneParams result = new ExecStreamOnDoneParams();
+ _ExecStreamOnDoneParams result = new _ExecStreamOnDoneParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -1134,7 +1134,7 @@
}
String toString() {
- return "ExecStreamOnDoneParams("
+ return "_ExecStreamOnDoneParams("
"err: $err" ")";
}
@@ -1146,15 +1146,15 @@
}
-class ScanStreamOnKeyValueParams extends bindings.Struct {
+class _ScanStreamOnKeyValueParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(16, 0)
];
KeyValue keyValue = null;
- ScanStreamOnKeyValueParams() : super(kVersions.last.size);
+ _ScanStreamOnKeyValueParams() : super(kVersions.last.size);
- static ScanStreamOnKeyValueParams deserialize(bindings.Message message) {
+ static _ScanStreamOnKeyValueParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -1163,11 +1163,11 @@
return result;
}
- static ScanStreamOnKeyValueParams decode(bindings.Decoder decoder0) {
+ static _ScanStreamOnKeyValueParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- ScanStreamOnKeyValueParams result = new ScanStreamOnKeyValueParams();
+ _ScanStreamOnKeyValueParams result = new _ScanStreamOnKeyValueParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -1202,7 +1202,7 @@
}
String toString() {
- return "ScanStreamOnKeyValueParams("
+ return "_ScanStreamOnKeyValueParams("
"keyValue: $keyValue" ")";
}
@@ -1272,15 +1272,15 @@
}
-class ScanStreamOnDoneParams extends bindings.Struct {
+class _ScanStreamOnDoneParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(16, 0)
];
Error err = null;
- ScanStreamOnDoneParams() : super(kVersions.last.size);
+ _ScanStreamOnDoneParams() : super(kVersions.last.size);
- static ScanStreamOnDoneParams deserialize(bindings.Message message) {
+ static _ScanStreamOnDoneParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -1289,11 +1289,11 @@
return result;
}
- static ScanStreamOnDoneParams decode(bindings.Decoder decoder0) {
+ static _ScanStreamOnDoneParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- ScanStreamOnDoneParams result = new ScanStreamOnDoneParams();
+ _ScanStreamOnDoneParams result = new _ScanStreamOnDoneParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -1328,7 +1328,7 @@
}
String toString() {
- return "ScanStreamOnDoneParams("
+ return "_ScanStreamOnDoneParams("
"err: $err" ")";
}
@@ -1340,15 +1340,15 @@
}
-class WatchGlobStreamOnChangeParams extends bindings.Struct {
+class _WatchGlobStreamOnChangeParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(16, 0)
];
WatchChange change = null;
- WatchGlobStreamOnChangeParams() : super(kVersions.last.size);
+ _WatchGlobStreamOnChangeParams() : super(kVersions.last.size);
- static WatchGlobStreamOnChangeParams deserialize(bindings.Message message) {
+ static _WatchGlobStreamOnChangeParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -1357,11 +1357,11 @@
return result;
}
- static WatchGlobStreamOnChangeParams decode(bindings.Decoder decoder0) {
+ static _WatchGlobStreamOnChangeParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- WatchGlobStreamOnChangeParams result = new WatchGlobStreamOnChangeParams();
+ _WatchGlobStreamOnChangeParams result = new _WatchGlobStreamOnChangeParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -1396,7 +1396,7 @@
}
String toString() {
- return "WatchGlobStreamOnChangeParams("
+ return "_WatchGlobStreamOnChangeParams("
"change: $change" ")";
}
@@ -1466,15 +1466,15 @@
}
-class WatchGlobStreamOnErrorParams extends bindings.Struct {
+class _WatchGlobStreamOnErrorParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(16, 0)
];
Error err = null;
- WatchGlobStreamOnErrorParams() : super(kVersions.last.size);
+ _WatchGlobStreamOnErrorParams() : super(kVersions.last.size);
- static WatchGlobStreamOnErrorParams deserialize(bindings.Message message) {
+ static _WatchGlobStreamOnErrorParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -1483,11 +1483,11 @@
return result;
}
- static WatchGlobStreamOnErrorParams decode(bindings.Decoder decoder0) {
+ static _WatchGlobStreamOnErrorParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- WatchGlobStreamOnErrorParams result = new WatchGlobStreamOnErrorParams();
+ _WatchGlobStreamOnErrorParams result = new _WatchGlobStreamOnErrorParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -1522,7 +1522,7 @@
}
String toString() {
- return "WatchGlobStreamOnErrorParams("
+ return "_WatchGlobStreamOnErrorParams("
"err: $err" ")";
}
@@ -1534,14 +1534,14 @@
}
-class SyncbaseServiceGetPermissionsParams extends bindings.Struct {
+class _SyncbaseServiceGetPermissionsParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(8, 0)
];
- SyncbaseServiceGetPermissionsParams() : super(kVersions.last.size);
+ _SyncbaseServiceGetPermissionsParams() : super(kVersions.last.size);
- static SyncbaseServiceGetPermissionsParams deserialize(bindings.Message message) {
+ static _SyncbaseServiceGetPermissionsParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -1550,11 +1550,11 @@
return result;
}
- static SyncbaseServiceGetPermissionsParams decode(bindings.Decoder decoder0) {
+ static _SyncbaseServiceGetPermissionsParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- SyncbaseServiceGetPermissionsParams result = new SyncbaseServiceGetPermissionsParams();
+ _SyncbaseServiceGetPermissionsParams result = new _SyncbaseServiceGetPermissionsParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -1582,7 +1582,7 @@
}
String toString() {
- return "SyncbaseServiceGetPermissionsParams("")";
+ return "_SyncbaseServiceGetPermissionsParams("")";
}
Map toJson() {
@@ -1679,16 +1679,16 @@
}
-class SyncbaseServiceSetPermissionsParams extends bindings.Struct {
+class _SyncbaseServiceSetPermissionsParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(24, 0)
];
Perms perms = null;
String version = null;
- SyncbaseServiceSetPermissionsParams() : super(kVersions.last.size);
+ _SyncbaseServiceSetPermissionsParams() : super(kVersions.last.size);
- static SyncbaseServiceSetPermissionsParams deserialize(bindings.Message message) {
+ static _SyncbaseServiceSetPermissionsParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -1697,11 +1697,11 @@
return result;
}
- static SyncbaseServiceSetPermissionsParams decode(bindings.Decoder decoder0) {
+ static _SyncbaseServiceSetPermissionsParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- SyncbaseServiceSetPermissionsParams result = new SyncbaseServiceSetPermissionsParams();
+ _SyncbaseServiceSetPermissionsParams result = new _SyncbaseServiceSetPermissionsParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -1742,7 +1742,7 @@
}
String toString() {
- return "SyncbaseServiceSetPermissionsParams("
+ return "_SyncbaseServiceSetPermissionsParams("
"perms: $perms" ", "
"version: $version" ")";
}
@@ -1824,14 +1824,14 @@
}
-class SyncbaseServiceListAppsParams extends bindings.Struct {
+class _SyncbaseServiceListAppsParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(8, 0)
];
- SyncbaseServiceListAppsParams() : super(kVersions.last.size);
+ _SyncbaseServiceListAppsParams() : super(kVersions.last.size);
- static SyncbaseServiceListAppsParams deserialize(bindings.Message message) {
+ static _SyncbaseServiceListAppsParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -1840,11 +1840,11 @@
return result;
}
- static SyncbaseServiceListAppsParams decode(bindings.Decoder decoder0) {
+ static _SyncbaseServiceListAppsParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- SyncbaseServiceListAppsParams result = new SyncbaseServiceListAppsParams();
+ _SyncbaseServiceListAppsParams result = new _SyncbaseServiceListAppsParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -1872,7 +1872,7 @@
}
String toString() {
- return "SyncbaseServiceListAppsParams("")";
+ return "_SyncbaseServiceListAppsParams("")";
}
Map toJson() {
@@ -1975,16 +1975,16 @@
}
-class SyncbaseAppCreateParams extends bindings.Struct {
+class _SyncbaseAppCreateParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(24, 0)
];
String name = null;
Perms perms = null;
- SyncbaseAppCreateParams() : super(kVersions.last.size);
+ _SyncbaseAppCreateParams() : super(kVersions.last.size);
- static SyncbaseAppCreateParams deserialize(bindings.Message message) {
+ static _SyncbaseAppCreateParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -1993,11 +1993,11 @@
return result;
}
- static SyncbaseAppCreateParams decode(bindings.Decoder decoder0) {
+ static _SyncbaseAppCreateParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- SyncbaseAppCreateParams result = new SyncbaseAppCreateParams();
+ _SyncbaseAppCreateParams result = new _SyncbaseAppCreateParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -2038,7 +2038,7 @@
}
String toString() {
- return "SyncbaseAppCreateParams("
+ return "_SyncbaseAppCreateParams("
"name: $name" ", "
"perms: $perms" ")";
}
@@ -2120,15 +2120,15 @@
}
-class SyncbaseAppDestroyParams extends bindings.Struct {
+class _SyncbaseAppDestroyParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(16, 0)
];
String name = null;
- SyncbaseAppDestroyParams() : super(kVersions.last.size);
+ _SyncbaseAppDestroyParams() : super(kVersions.last.size);
- static SyncbaseAppDestroyParams deserialize(bindings.Message message) {
+ static _SyncbaseAppDestroyParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -2137,11 +2137,11 @@
return result;
}
- static SyncbaseAppDestroyParams decode(bindings.Decoder decoder0) {
+ static _SyncbaseAppDestroyParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- SyncbaseAppDestroyParams result = new SyncbaseAppDestroyParams();
+ _SyncbaseAppDestroyParams result = new _SyncbaseAppDestroyParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -2175,7 +2175,7 @@
}
String toString() {
- return "SyncbaseAppDestroyParams("
+ return "_SyncbaseAppDestroyParams("
"name: $name" ")";
}
@@ -2255,15 +2255,15 @@
}
-class SyncbaseAppExistsParams extends bindings.Struct {
+class _SyncbaseAppExistsParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(16, 0)
];
String name = null;
- SyncbaseAppExistsParams() : super(kVersions.last.size);
+ _SyncbaseAppExistsParams() : super(kVersions.last.size);
- static SyncbaseAppExistsParams deserialize(bindings.Message message) {
+ static _SyncbaseAppExistsParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -2272,11 +2272,11 @@
return result;
}
- static SyncbaseAppExistsParams decode(bindings.Decoder decoder0) {
+ static _SyncbaseAppExistsParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- SyncbaseAppExistsParams result = new SyncbaseAppExistsParams();
+ _SyncbaseAppExistsParams result = new _SyncbaseAppExistsParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -2310,7 +2310,7 @@
}
String toString() {
- return "SyncbaseAppExistsParams("
+ return "_SyncbaseAppExistsParams("
"name: $name" ")";
}
@@ -2399,15 +2399,15 @@
}
-class SyncbaseAppGetPermissionsParams extends bindings.Struct {
+class _SyncbaseAppGetPermissionsParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(16, 0)
];
String name = null;
- SyncbaseAppGetPermissionsParams() : super(kVersions.last.size);
+ _SyncbaseAppGetPermissionsParams() : super(kVersions.last.size);
- static SyncbaseAppGetPermissionsParams deserialize(bindings.Message message) {
+ static _SyncbaseAppGetPermissionsParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -2416,11 +2416,11 @@
return result;
}
- static SyncbaseAppGetPermissionsParams decode(bindings.Decoder decoder0) {
+ static _SyncbaseAppGetPermissionsParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- SyncbaseAppGetPermissionsParams result = new SyncbaseAppGetPermissionsParams();
+ _SyncbaseAppGetPermissionsParams result = new _SyncbaseAppGetPermissionsParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -2454,7 +2454,7 @@
}
String toString() {
- return "SyncbaseAppGetPermissionsParams("
+ return "_SyncbaseAppGetPermissionsParams("
"name: $name" ")";
}
@@ -2553,15 +2553,15 @@
}
-class SyncbaseAppListDatabasesParams extends bindings.Struct {
+class _SyncbaseAppListDatabasesParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(16, 0)
];
String name = null;
- SyncbaseAppListDatabasesParams() : super(kVersions.last.size);
+ _SyncbaseAppListDatabasesParams() : super(kVersions.last.size);
- static SyncbaseAppListDatabasesParams deserialize(bindings.Message message) {
+ static _SyncbaseAppListDatabasesParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -2570,11 +2570,11 @@
return result;
}
- static SyncbaseAppListDatabasesParams decode(bindings.Decoder decoder0) {
+ static _SyncbaseAppListDatabasesParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- SyncbaseAppListDatabasesParams result = new SyncbaseAppListDatabasesParams();
+ _SyncbaseAppListDatabasesParams result = new _SyncbaseAppListDatabasesParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -2608,7 +2608,7 @@
}
String toString() {
- return "SyncbaseAppListDatabasesParams("
+ return "_SyncbaseAppListDatabasesParams("
"name: $name" ")";
}
@@ -2713,7 +2713,7 @@
}
-class SyncbaseAppSetPermissionsParams extends bindings.Struct {
+class _SyncbaseAppSetPermissionsParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(32, 0)
];
@@ -2721,9 +2721,9 @@
Perms perms = null;
String version = null;
- SyncbaseAppSetPermissionsParams() : super(kVersions.last.size);
+ _SyncbaseAppSetPermissionsParams() : super(kVersions.last.size);
- static SyncbaseAppSetPermissionsParams deserialize(bindings.Message message) {
+ static _SyncbaseAppSetPermissionsParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -2732,11 +2732,11 @@
return result;
}
- static SyncbaseAppSetPermissionsParams decode(bindings.Decoder decoder0) {
+ static _SyncbaseAppSetPermissionsParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- SyncbaseAppSetPermissionsParams result = new SyncbaseAppSetPermissionsParams();
+ _SyncbaseAppSetPermissionsParams result = new _SyncbaseAppSetPermissionsParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -2783,7 +2783,7 @@
}
String toString() {
- return "SyncbaseAppSetPermissionsParams("
+ return "_SyncbaseAppSetPermissionsParams("
"name: $name" ", "
"perms: $perms" ", "
"version: $version" ")";
@@ -2867,16 +2867,16 @@
}
-class SyncbaseDbCreateParams extends bindings.Struct {
+class _SyncbaseDbCreateParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(24, 0)
];
String name = null;
Perms perms = null;
- SyncbaseDbCreateParams() : super(kVersions.last.size);
+ _SyncbaseDbCreateParams() : super(kVersions.last.size);
- static SyncbaseDbCreateParams deserialize(bindings.Message message) {
+ static _SyncbaseDbCreateParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -2885,11 +2885,11 @@
return result;
}
- static SyncbaseDbCreateParams decode(bindings.Decoder decoder0) {
+ static _SyncbaseDbCreateParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- SyncbaseDbCreateParams result = new SyncbaseDbCreateParams();
+ _SyncbaseDbCreateParams result = new _SyncbaseDbCreateParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -2930,7 +2930,7 @@
}
String toString() {
- return "SyncbaseDbCreateParams("
+ return "_SyncbaseDbCreateParams("
"name: $name" ", "
"perms: $perms" ")";
}
@@ -3012,15 +3012,15 @@
}
-class SyncbaseDbDestroyParams extends bindings.Struct {
+class _SyncbaseDbDestroyParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(16, 0)
];
String name = null;
- SyncbaseDbDestroyParams() : super(kVersions.last.size);
+ _SyncbaseDbDestroyParams() : super(kVersions.last.size);
- static SyncbaseDbDestroyParams deserialize(bindings.Message message) {
+ static _SyncbaseDbDestroyParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -3029,11 +3029,11 @@
return result;
}
- static SyncbaseDbDestroyParams decode(bindings.Decoder decoder0) {
+ static _SyncbaseDbDestroyParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- SyncbaseDbDestroyParams result = new SyncbaseDbDestroyParams();
+ _SyncbaseDbDestroyParams result = new _SyncbaseDbDestroyParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -3067,7 +3067,7 @@
}
String toString() {
- return "SyncbaseDbDestroyParams("
+ return "_SyncbaseDbDestroyParams("
"name: $name" ")";
}
@@ -3147,15 +3147,15 @@
}
-class SyncbaseDbExistsParams extends bindings.Struct {
+class _SyncbaseDbExistsParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(16, 0)
];
String name = null;
- SyncbaseDbExistsParams() : super(kVersions.last.size);
+ _SyncbaseDbExistsParams() : super(kVersions.last.size);
- static SyncbaseDbExistsParams deserialize(bindings.Message message) {
+ static _SyncbaseDbExistsParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -3164,11 +3164,11 @@
return result;
}
- static SyncbaseDbExistsParams decode(bindings.Decoder decoder0) {
+ static _SyncbaseDbExistsParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- SyncbaseDbExistsParams result = new SyncbaseDbExistsParams();
+ _SyncbaseDbExistsParams result = new _SyncbaseDbExistsParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -3202,7 +3202,7 @@
}
String toString() {
- return "SyncbaseDbExistsParams("
+ return "_SyncbaseDbExistsParams("
"name: $name" ")";
}
@@ -3291,7 +3291,7 @@
}
-class SyncbaseDbExecParams extends bindings.Struct {
+class _SyncbaseDbExecParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(32, 0)
];
@@ -3299,9 +3299,9 @@
String query = null;
Object stream = null;
- SyncbaseDbExecParams() : super(kVersions.last.size);
+ _SyncbaseDbExecParams() : super(kVersions.last.size);
- static SyncbaseDbExecParams deserialize(bindings.Message message) {
+ static _SyncbaseDbExecParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -3310,11 +3310,11 @@
return result;
}
- static SyncbaseDbExecParams decode(bindings.Decoder decoder0) {
+ static _SyncbaseDbExecParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- SyncbaseDbExecParams result = new SyncbaseDbExecParams();
+ _SyncbaseDbExecParams result = new _SyncbaseDbExecParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -3360,7 +3360,7 @@
}
String toString() {
- return "SyncbaseDbExecParams("
+ return "_SyncbaseDbExecParams("
"name: $name" ", "
"query: $query" ", "
"stream: $stream" ")";
@@ -3441,16 +3441,16 @@
}
-class SyncbaseDbBeginBatchParams extends bindings.Struct {
+class _SyncbaseDbBeginBatchParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(24, 0)
];
String name = null;
BatchOptions bo = null;
- SyncbaseDbBeginBatchParams() : super(kVersions.last.size);
+ _SyncbaseDbBeginBatchParams() : super(kVersions.last.size);
- static SyncbaseDbBeginBatchParams deserialize(bindings.Message message) {
+ static _SyncbaseDbBeginBatchParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -3459,11 +3459,11 @@
return result;
}
- static SyncbaseDbBeginBatchParams decode(bindings.Decoder decoder0) {
+ static _SyncbaseDbBeginBatchParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- SyncbaseDbBeginBatchParams result = new SyncbaseDbBeginBatchParams();
+ _SyncbaseDbBeginBatchParams result = new _SyncbaseDbBeginBatchParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -3504,7 +3504,7 @@
}
String toString() {
- return "SyncbaseDbBeginBatchParams("
+ return "_SyncbaseDbBeginBatchParams("
"name: $name" ", "
"bo: $bo" ")";
}
@@ -3595,15 +3595,15 @@
}
-class SyncbaseDbCommitParams extends bindings.Struct {
+class _SyncbaseDbCommitParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(16, 0)
];
String name = null;
- SyncbaseDbCommitParams() : super(kVersions.last.size);
+ _SyncbaseDbCommitParams() : super(kVersions.last.size);
- static SyncbaseDbCommitParams deserialize(bindings.Message message) {
+ static _SyncbaseDbCommitParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -3612,11 +3612,11 @@
return result;
}
- static SyncbaseDbCommitParams decode(bindings.Decoder decoder0) {
+ static _SyncbaseDbCommitParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- SyncbaseDbCommitParams result = new SyncbaseDbCommitParams();
+ _SyncbaseDbCommitParams result = new _SyncbaseDbCommitParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -3650,7 +3650,7 @@
}
String toString() {
- return "SyncbaseDbCommitParams("
+ return "_SyncbaseDbCommitParams("
"name: $name" ")";
}
@@ -3730,15 +3730,15 @@
}
-class SyncbaseDbAbortParams extends bindings.Struct {
+class _SyncbaseDbAbortParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(16, 0)
];
String name = null;
- SyncbaseDbAbortParams() : super(kVersions.last.size);
+ _SyncbaseDbAbortParams() : super(kVersions.last.size);
- static SyncbaseDbAbortParams deserialize(bindings.Message message) {
+ static _SyncbaseDbAbortParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -3747,11 +3747,11 @@
return result;
}
- static SyncbaseDbAbortParams decode(bindings.Decoder decoder0) {
+ static _SyncbaseDbAbortParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- SyncbaseDbAbortParams result = new SyncbaseDbAbortParams();
+ _SyncbaseDbAbortParams result = new _SyncbaseDbAbortParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -3785,7 +3785,7 @@
}
String toString() {
- return "SyncbaseDbAbortParams("
+ return "_SyncbaseDbAbortParams("
"name: $name" ")";
}
@@ -3865,15 +3865,15 @@
}
-class SyncbaseDbGetPermissionsParams extends bindings.Struct {
+class _SyncbaseDbGetPermissionsParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(16, 0)
];
String name = null;
- SyncbaseDbGetPermissionsParams() : super(kVersions.last.size);
+ _SyncbaseDbGetPermissionsParams() : super(kVersions.last.size);
- static SyncbaseDbGetPermissionsParams deserialize(bindings.Message message) {
+ static _SyncbaseDbGetPermissionsParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -3882,11 +3882,11 @@
return result;
}
- static SyncbaseDbGetPermissionsParams decode(bindings.Decoder decoder0) {
+ static _SyncbaseDbGetPermissionsParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- SyncbaseDbGetPermissionsParams result = new SyncbaseDbGetPermissionsParams();
+ _SyncbaseDbGetPermissionsParams result = new _SyncbaseDbGetPermissionsParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -3920,7 +3920,7 @@
}
String toString() {
- return "SyncbaseDbGetPermissionsParams("
+ return "_SyncbaseDbGetPermissionsParams("
"name: $name" ")";
}
@@ -4019,7 +4019,7 @@
}
-class SyncbaseDbSetPermissionsParams extends bindings.Struct {
+class _SyncbaseDbSetPermissionsParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(32, 0)
];
@@ -4027,9 +4027,9 @@
Perms perms = null;
String version = null;
- SyncbaseDbSetPermissionsParams() : super(kVersions.last.size);
+ _SyncbaseDbSetPermissionsParams() : super(kVersions.last.size);
- static SyncbaseDbSetPermissionsParams deserialize(bindings.Message message) {
+ static _SyncbaseDbSetPermissionsParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -4038,11 +4038,11 @@
return result;
}
- static SyncbaseDbSetPermissionsParams decode(bindings.Decoder decoder0) {
+ static _SyncbaseDbSetPermissionsParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- SyncbaseDbSetPermissionsParams result = new SyncbaseDbSetPermissionsParams();
+ _SyncbaseDbSetPermissionsParams result = new _SyncbaseDbSetPermissionsParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -4089,7 +4089,7 @@
}
String toString() {
- return "SyncbaseDbSetPermissionsParams("
+ return "_SyncbaseDbSetPermissionsParams("
"name: $name" ", "
"perms: $perms" ", "
"version: $version" ")";
@@ -4173,7 +4173,7 @@
}
-class SyncbaseDbWatchGlobParams extends bindings.Struct {
+class _SyncbaseDbWatchGlobParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(32, 0)
];
@@ -4181,9 +4181,9 @@
GlobRequest req = null;
Object stream = null;
- SyncbaseDbWatchGlobParams() : super(kVersions.last.size);
+ _SyncbaseDbWatchGlobParams() : super(kVersions.last.size);
- static SyncbaseDbWatchGlobParams deserialize(bindings.Message message) {
+ static _SyncbaseDbWatchGlobParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -4192,11 +4192,11 @@
return result;
}
- static SyncbaseDbWatchGlobParams decode(bindings.Decoder decoder0) {
+ static _SyncbaseDbWatchGlobParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- SyncbaseDbWatchGlobParams result = new SyncbaseDbWatchGlobParams();
+ _SyncbaseDbWatchGlobParams result = new _SyncbaseDbWatchGlobParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -4243,7 +4243,7 @@
}
String toString() {
- return "SyncbaseDbWatchGlobParams("
+ return "_SyncbaseDbWatchGlobParams("
"name: $name" ", "
"req: $req" ", "
"stream: $stream" ")";
@@ -4324,15 +4324,15 @@
}
-class SyncbaseDbGetResumeMarkerParams extends bindings.Struct {
+class _SyncbaseDbGetResumeMarkerParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(16, 0)
];
String name = null;
- SyncbaseDbGetResumeMarkerParams() : super(kVersions.last.size);
+ _SyncbaseDbGetResumeMarkerParams() : super(kVersions.last.size);
- static SyncbaseDbGetResumeMarkerParams deserialize(bindings.Message message) {
+ static _SyncbaseDbGetResumeMarkerParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -4341,11 +4341,11 @@
return result;
}
- static SyncbaseDbGetResumeMarkerParams decode(bindings.Decoder decoder0) {
+ static _SyncbaseDbGetResumeMarkerParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- SyncbaseDbGetResumeMarkerParams result = new SyncbaseDbGetResumeMarkerParams();
+ _SyncbaseDbGetResumeMarkerParams result = new _SyncbaseDbGetResumeMarkerParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -4379,7 +4379,7 @@
}
String toString() {
- return "SyncbaseDbGetResumeMarkerParams("
+ return "_SyncbaseDbGetResumeMarkerParams("
"name: $name" ")";
}
@@ -4468,15 +4468,15 @@
}
-class SyncbaseDbListTablesParams extends bindings.Struct {
+class _SyncbaseDbListTablesParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(16, 0)
];
String name = null;
- SyncbaseDbListTablesParams() : super(kVersions.last.size);
+ _SyncbaseDbListTablesParams() : super(kVersions.last.size);
- static SyncbaseDbListTablesParams deserialize(bindings.Message message) {
+ static _SyncbaseDbListTablesParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -4485,11 +4485,11 @@
return result;
}
- static SyncbaseDbListTablesParams decode(bindings.Decoder decoder0) {
+ static _SyncbaseDbListTablesParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- SyncbaseDbListTablesParams result = new SyncbaseDbListTablesParams();
+ _SyncbaseDbListTablesParams result = new _SyncbaseDbListTablesParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -4523,7 +4523,7 @@
}
String toString() {
- return "SyncbaseDbListTablesParams("
+ return "_SyncbaseDbListTablesParams("
"name: $name" ")";
}
@@ -4628,15 +4628,15 @@
}
-class SyncbaseDbGetSyncgroupNamesParams extends bindings.Struct {
+class _SyncbaseDbGetSyncgroupNamesParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(16, 0)
];
String name = null;
- SyncbaseDbGetSyncgroupNamesParams() : super(kVersions.last.size);
+ _SyncbaseDbGetSyncgroupNamesParams() : super(kVersions.last.size);
- static SyncbaseDbGetSyncgroupNamesParams deserialize(bindings.Message message) {
+ static _SyncbaseDbGetSyncgroupNamesParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -4645,11 +4645,11 @@
return result;
}
- static SyncbaseDbGetSyncgroupNamesParams decode(bindings.Decoder decoder0) {
+ static _SyncbaseDbGetSyncgroupNamesParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- SyncbaseDbGetSyncgroupNamesParams result = new SyncbaseDbGetSyncgroupNamesParams();
+ _SyncbaseDbGetSyncgroupNamesParams result = new _SyncbaseDbGetSyncgroupNamesParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -4683,7 +4683,7 @@
}
String toString() {
- return "SyncbaseDbGetSyncgroupNamesParams("
+ return "_SyncbaseDbGetSyncgroupNamesParams("
"name: $name" ")";
}
@@ -4788,7 +4788,7 @@
}
-class SyncbaseDbCreateSyncgroupParams extends bindings.Struct {
+class _SyncbaseDbCreateSyncgroupParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(40, 0)
];
@@ -4797,9 +4797,9 @@
SyncgroupSpec spec = null;
SyncgroupMemberInfo myInfo = null;
- SyncbaseDbCreateSyncgroupParams() : super(kVersions.last.size);
+ _SyncbaseDbCreateSyncgroupParams() : super(kVersions.last.size);
- static SyncbaseDbCreateSyncgroupParams deserialize(bindings.Message message) {
+ static _SyncbaseDbCreateSyncgroupParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -4808,11 +4808,11 @@
return result;
}
- static SyncbaseDbCreateSyncgroupParams decode(bindings.Decoder decoder0) {
+ static _SyncbaseDbCreateSyncgroupParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- SyncbaseDbCreateSyncgroupParams result = new SyncbaseDbCreateSyncgroupParams();
+ _SyncbaseDbCreateSyncgroupParams result = new _SyncbaseDbCreateSyncgroupParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -4866,7 +4866,7 @@
}
String toString() {
- return "SyncbaseDbCreateSyncgroupParams("
+ return "_SyncbaseDbCreateSyncgroupParams("
"name: $name" ", "
"sgName: $sgName" ", "
"spec: $spec" ", "
@@ -4952,7 +4952,7 @@
}
-class SyncbaseDbJoinSyncgroupParams extends bindings.Struct {
+class _SyncbaseDbJoinSyncgroupParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(32, 0)
];
@@ -4960,9 +4960,9 @@
String sgName = null;
SyncgroupMemberInfo myInfo = null;
- SyncbaseDbJoinSyncgroupParams() : super(kVersions.last.size);
+ _SyncbaseDbJoinSyncgroupParams() : super(kVersions.last.size);
- static SyncbaseDbJoinSyncgroupParams deserialize(bindings.Message message) {
+ static _SyncbaseDbJoinSyncgroupParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -4971,11 +4971,11 @@
return result;
}
- static SyncbaseDbJoinSyncgroupParams decode(bindings.Decoder decoder0) {
+ static _SyncbaseDbJoinSyncgroupParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- SyncbaseDbJoinSyncgroupParams result = new SyncbaseDbJoinSyncgroupParams();
+ _SyncbaseDbJoinSyncgroupParams result = new _SyncbaseDbJoinSyncgroupParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -5022,7 +5022,7 @@
}
String toString() {
- return "SyncbaseDbJoinSyncgroupParams("
+ return "_SyncbaseDbJoinSyncgroupParams("
"name: $name" ", "
"sgName: $sgName" ", "
"myInfo: $myInfo" ")";
@@ -5116,16 +5116,16 @@
}
-class SyncbaseDbLeaveSyncgroupParams extends bindings.Struct {
+class _SyncbaseDbLeaveSyncgroupParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(24, 0)
];
String name = null;
String sgName = null;
- SyncbaseDbLeaveSyncgroupParams() : super(kVersions.last.size);
+ _SyncbaseDbLeaveSyncgroupParams() : super(kVersions.last.size);
- static SyncbaseDbLeaveSyncgroupParams deserialize(bindings.Message message) {
+ static _SyncbaseDbLeaveSyncgroupParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -5134,11 +5134,11 @@
return result;
}
- static SyncbaseDbLeaveSyncgroupParams decode(bindings.Decoder decoder0) {
+ static _SyncbaseDbLeaveSyncgroupParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- SyncbaseDbLeaveSyncgroupParams result = new SyncbaseDbLeaveSyncgroupParams();
+ _SyncbaseDbLeaveSyncgroupParams result = new _SyncbaseDbLeaveSyncgroupParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -5178,7 +5178,7 @@
}
String toString() {
- return "SyncbaseDbLeaveSyncgroupParams("
+ return "_SyncbaseDbLeaveSyncgroupParams("
"name: $name" ", "
"sgName: $sgName" ")";
}
@@ -5260,16 +5260,16 @@
}
-class SyncbaseDbDestroySyncgroupParams extends bindings.Struct {
+class _SyncbaseDbDestroySyncgroupParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(24, 0)
];
String name = null;
String sgName = null;
- SyncbaseDbDestroySyncgroupParams() : super(kVersions.last.size);
+ _SyncbaseDbDestroySyncgroupParams() : super(kVersions.last.size);
- static SyncbaseDbDestroySyncgroupParams deserialize(bindings.Message message) {
+ static _SyncbaseDbDestroySyncgroupParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -5278,11 +5278,11 @@
return result;
}
- static SyncbaseDbDestroySyncgroupParams decode(bindings.Decoder decoder0) {
+ static _SyncbaseDbDestroySyncgroupParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- SyncbaseDbDestroySyncgroupParams result = new SyncbaseDbDestroySyncgroupParams();
+ _SyncbaseDbDestroySyncgroupParams result = new _SyncbaseDbDestroySyncgroupParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -5322,7 +5322,7 @@
}
String toString() {
- return "SyncbaseDbDestroySyncgroupParams("
+ return "_SyncbaseDbDestroySyncgroupParams("
"name: $name" ", "
"sgName: $sgName" ")";
}
@@ -5404,7 +5404,7 @@
}
-class SyncbaseDbEjectFromSyncgroupParams extends bindings.Struct {
+class _SyncbaseDbEjectFromSyncgroupParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(32, 0)
];
@@ -5412,9 +5412,9 @@
String sgName = null;
String member = null;
- SyncbaseDbEjectFromSyncgroupParams() : super(kVersions.last.size);
+ _SyncbaseDbEjectFromSyncgroupParams() : super(kVersions.last.size);
- static SyncbaseDbEjectFromSyncgroupParams deserialize(bindings.Message message) {
+ static _SyncbaseDbEjectFromSyncgroupParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -5423,11 +5423,11 @@
return result;
}
- static SyncbaseDbEjectFromSyncgroupParams decode(bindings.Decoder decoder0) {
+ static _SyncbaseDbEjectFromSyncgroupParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- SyncbaseDbEjectFromSyncgroupParams result = new SyncbaseDbEjectFromSyncgroupParams();
+ _SyncbaseDbEjectFromSyncgroupParams result = new _SyncbaseDbEjectFromSyncgroupParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -5473,7 +5473,7 @@
}
String toString() {
- return "SyncbaseDbEjectFromSyncgroupParams("
+ return "_SyncbaseDbEjectFromSyncgroupParams("
"name: $name" ", "
"sgName: $sgName" ", "
"member: $member" ")";
@@ -5557,16 +5557,16 @@
}
-class SyncbaseDbGetSyncgroupSpecParams extends bindings.Struct {
+class _SyncbaseDbGetSyncgroupSpecParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(24, 0)
];
String name = null;
String sgName = null;
- SyncbaseDbGetSyncgroupSpecParams() : super(kVersions.last.size);
+ _SyncbaseDbGetSyncgroupSpecParams() : super(kVersions.last.size);
- static SyncbaseDbGetSyncgroupSpecParams deserialize(bindings.Message message) {
+ static _SyncbaseDbGetSyncgroupSpecParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -5575,11 +5575,11 @@
return result;
}
- static SyncbaseDbGetSyncgroupSpecParams decode(bindings.Decoder decoder0) {
+ static _SyncbaseDbGetSyncgroupSpecParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- SyncbaseDbGetSyncgroupSpecParams result = new SyncbaseDbGetSyncgroupSpecParams();
+ _SyncbaseDbGetSyncgroupSpecParams result = new _SyncbaseDbGetSyncgroupSpecParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -5619,7 +5619,7 @@
}
String toString() {
- return "SyncbaseDbGetSyncgroupSpecParams("
+ return "_SyncbaseDbGetSyncgroupSpecParams("
"name: $name" ", "
"sgName: $sgName" ")";
}
@@ -5720,7 +5720,7 @@
}
-class SyncbaseDbSetSyncgroupSpecParams extends bindings.Struct {
+class _SyncbaseDbSetSyncgroupSpecParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(40, 0)
];
@@ -5729,9 +5729,9 @@
SyncgroupSpec spec = null;
String version = null;
- SyncbaseDbSetSyncgroupSpecParams() : super(kVersions.last.size);
+ _SyncbaseDbSetSyncgroupSpecParams() : super(kVersions.last.size);
- static SyncbaseDbSetSyncgroupSpecParams deserialize(bindings.Message message) {
+ static _SyncbaseDbSetSyncgroupSpecParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -5740,11 +5740,11 @@
return result;
}
- static SyncbaseDbSetSyncgroupSpecParams decode(bindings.Decoder decoder0) {
+ static _SyncbaseDbSetSyncgroupSpecParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- SyncbaseDbSetSyncgroupSpecParams result = new SyncbaseDbSetSyncgroupSpecParams();
+ _SyncbaseDbSetSyncgroupSpecParams result = new _SyncbaseDbSetSyncgroupSpecParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -5797,7 +5797,7 @@
}
String toString() {
- return "SyncbaseDbSetSyncgroupSpecParams("
+ return "_SyncbaseDbSetSyncgroupSpecParams("
"name: $name" ", "
"sgName: $sgName" ", "
"spec: $spec" ", "
@@ -5883,16 +5883,16 @@
}
-class SyncbaseDbGetSyncgroupMembersParams extends bindings.Struct {
+class _SyncbaseDbGetSyncgroupMembersParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(24, 0)
];
String name = null;
String sgName = null;
- SyncbaseDbGetSyncgroupMembersParams() : super(kVersions.last.size);
+ _SyncbaseDbGetSyncgroupMembersParams() : super(kVersions.last.size);
- static SyncbaseDbGetSyncgroupMembersParams deserialize(bindings.Message message) {
+ static _SyncbaseDbGetSyncgroupMembersParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -5901,11 +5901,11 @@
return result;
}
- static SyncbaseDbGetSyncgroupMembersParams decode(bindings.Decoder decoder0) {
+ static _SyncbaseDbGetSyncgroupMembersParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- SyncbaseDbGetSyncgroupMembersParams result = new SyncbaseDbGetSyncgroupMembersParams();
+ _SyncbaseDbGetSyncgroupMembersParams result = new _SyncbaseDbGetSyncgroupMembersParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -5945,7 +5945,7 @@
}
String toString() {
- return "SyncbaseDbGetSyncgroupMembersParams("
+ return "_SyncbaseDbGetSyncgroupMembersParams("
"name: $name" ", "
"sgName: $sgName" ")";
}
@@ -6091,16 +6091,16 @@
}
-class SyncbaseTableCreateParams extends bindings.Struct {
+class _SyncbaseTableCreateParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(24, 0)
];
String name = null;
Perms perms = null;
- SyncbaseTableCreateParams() : super(kVersions.last.size);
+ _SyncbaseTableCreateParams() : super(kVersions.last.size);
- static SyncbaseTableCreateParams deserialize(bindings.Message message) {
+ static _SyncbaseTableCreateParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -6109,11 +6109,11 @@
return result;
}
- static SyncbaseTableCreateParams decode(bindings.Decoder decoder0) {
+ static _SyncbaseTableCreateParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- SyncbaseTableCreateParams result = new SyncbaseTableCreateParams();
+ _SyncbaseTableCreateParams result = new _SyncbaseTableCreateParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -6154,7 +6154,7 @@
}
String toString() {
- return "SyncbaseTableCreateParams("
+ return "_SyncbaseTableCreateParams("
"name: $name" ", "
"perms: $perms" ")";
}
@@ -6236,15 +6236,15 @@
}
-class SyncbaseTableDestroyParams extends bindings.Struct {
+class _SyncbaseTableDestroyParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(16, 0)
];
String name = null;
- SyncbaseTableDestroyParams() : super(kVersions.last.size);
+ _SyncbaseTableDestroyParams() : super(kVersions.last.size);
- static SyncbaseTableDestroyParams deserialize(bindings.Message message) {
+ static _SyncbaseTableDestroyParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -6253,11 +6253,11 @@
return result;
}
- static SyncbaseTableDestroyParams decode(bindings.Decoder decoder0) {
+ static _SyncbaseTableDestroyParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- SyncbaseTableDestroyParams result = new SyncbaseTableDestroyParams();
+ _SyncbaseTableDestroyParams result = new _SyncbaseTableDestroyParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -6291,7 +6291,7 @@
}
String toString() {
- return "SyncbaseTableDestroyParams("
+ return "_SyncbaseTableDestroyParams("
"name: $name" ")";
}
@@ -6371,15 +6371,15 @@
}
-class SyncbaseTableExistsParams extends bindings.Struct {
+class _SyncbaseTableExistsParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(16, 0)
];
String name = null;
- SyncbaseTableExistsParams() : super(kVersions.last.size);
+ _SyncbaseTableExistsParams() : super(kVersions.last.size);
- static SyncbaseTableExistsParams deserialize(bindings.Message message) {
+ static _SyncbaseTableExistsParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -6388,11 +6388,11 @@
return result;
}
- static SyncbaseTableExistsParams decode(bindings.Decoder decoder0) {
+ static _SyncbaseTableExistsParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- SyncbaseTableExistsParams result = new SyncbaseTableExistsParams();
+ _SyncbaseTableExistsParams result = new _SyncbaseTableExistsParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -6426,7 +6426,7 @@
}
String toString() {
- return "SyncbaseTableExistsParams("
+ return "_SyncbaseTableExistsParams("
"name: $name" ")";
}
@@ -6515,15 +6515,15 @@
}
-class SyncbaseTableGetPermissionsParams extends bindings.Struct {
+class _SyncbaseTableGetPermissionsParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(16, 0)
];
String name = null;
- SyncbaseTableGetPermissionsParams() : super(kVersions.last.size);
+ _SyncbaseTableGetPermissionsParams() : super(kVersions.last.size);
- static SyncbaseTableGetPermissionsParams deserialize(bindings.Message message) {
+ static _SyncbaseTableGetPermissionsParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -6532,11 +6532,11 @@
return result;
}
- static SyncbaseTableGetPermissionsParams decode(bindings.Decoder decoder0) {
+ static _SyncbaseTableGetPermissionsParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- SyncbaseTableGetPermissionsParams result = new SyncbaseTableGetPermissionsParams();
+ _SyncbaseTableGetPermissionsParams result = new _SyncbaseTableGetPermissionsParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -6570,7 +6570,7 @@
}
String toString() {
- return "SyncbaseTableGetPermissionsParams("
+ return "_SyncbaseTableGetPermissionsParams("
"name: $name" ")";
}
@@ -6660,16 +6660,16 @@
}
-class SyncbaseTableSetPermissionsParams extends bindings.Struct {
+class _SyncbaseTableSetPermissionsParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(24, 0)
];
String name = null;
Perms perms = null;
- SyncbaseTableSetPermissionsParams() : super(kVersions.last.size);
+ _SyncbaseTableSetPermissionsParams() : super(kVersions.last.size);
- static SyncbaseTableSetPermissionsParams deserialize(bindings.Message message) {
+ static _SyncbaseTableSetPermissionsParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -6678,11 +6678,11 @@
return result;
}
- static SyncbaseTableSetPermissionsParams decode(bindings.Decoder decoder0) {
+ static _SyncbaseTableSetPermissionsParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- SyncbaseTableSetPermissionsParams result = new SyncbaseTableSetPermissionsParams();
+ _SyncbaseTableSetPermissionsParams result = new _SyncbaseTableSetPermissionsParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -6723,7 +6723,7 @@
}
String toString() {
- return "SyncbaseTableSetPermissionsParams("
+ return "_SyncbaseTableSetPermissionsParams("
"name: $name" ", "
"perms: $perms" ")";
}
@@ -6805,7 +6805,7 @@
}
-class SyncbaseTableDeleteRangeParams extends bindings.Struct {
+class _SyncbaseTableDeleteRangeParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(32, 0)
];
@@ -6813,9 +6813,9 @@
List<int> start = null;
List<int> limit = null;
- SyncbaseTableDeleteRangeParams() : super(kVersions.last.size);
+ _SyncbaseTableDeleteRangeParams() : super(kVersions.last.size);
- static SyncbaseTableDeleteRangeParams deserialize(bindings.Message message) {
+ static _SyncbaseTableDeleteRangeParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -6824,11 +6824,11 @@
return result;
}
- static SyncbaseTableDeleteRangeParams decode(bindings.Decoder decoder0) {
+ static _SyncbaseTableDeleteRangeParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- SyncbaseTableDeleteRangeParams result = new SyncbaseTableDeleteRangeParams();
+ _SyncbaseTableDeleteRangeParams result = new _SyncbaseTableDeleteRangeParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -6874,7 +6874,7 @@
}
String toString() {
- return "SyncbaseTableDeleteRangeParams("
+ return "_SyncbaseTableDeleteRangeParams("
"name: $name" ", "
"start: $start" ", "
"limit: $limit" ")";
@@ -6958,7 +6958,7 @@
}
-class SyncbaseTableScanParams extends bindings.Struct {
+class _SyncbaseTableScanParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(40, 0)
];
@@ -6967,9 +6967,9 @@
List<int> limit = null;
Object stream = null;
- SyncbaseTableScanParams() : super(kVersions.last.size);
+ _SyncbaseTableScanParams() : super(kVersions.last.size);
- static SyncbaseTableScanParams deserialize(bindings.Message message) {
+ static _SyncbaseTableScanParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -6978,11 +6978,11 @@
return result;
}
- static SyncbaseTableScanParams decode(bindings.Decoder decoder0) {
+ static _SyncbaseTableScanParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- SyncbaseTableScanParams result = new SyncbaseTableScanParams();
+ _SyncbaseTableScanParams result = new _SyncbaseTableScanParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -7034,7 +7034,7 @@
}
String toString() {
- return "SyncbaseTableScanParams("
+ return "_SyncbaseTableScanParams("
"name: $name" ", "
"start: $start" ", "
"limit: $limit" ", "
@@ -7116,16 +7116,16 @@
}
-class SyncbaseTableGetPrefixPermissionsParams extends bindings.Struct {
+class _SyncbaseTableGetPrefixPermissionsParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(24, 0)
];
String name = null;
String key = null;
- SyncbaseTableGetPrefixPermissionsParams() : super(kVersions.last.size);
+ _SyncbaseTableGetPrefixPermissionsParams() : super(kVersions.last.size);
- static SyncbaseTableGetPrefixPermissionsParams deserialize(bindings.Message message) {
+ static _SyncbaseTableGetPrefixPermissionsParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -7134,11 +7134,11 @@
return result;
}
- static SyncbaseTableGetPrefixPermissionsParams decode(bindings.Decoder decoder0) {
+ static _SyncbaseTableGetPrefixPermissionsParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- SyncbaseTableGetPrefixPermissionsParams result = new SyncbaseTableGetPrefixPermissionsParams();
+ _SyncbaseTableGetPrefixPermissionsParams result = new _SyncbaseTableGetPrefixPermissionsParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -7178,7 +7178,7 @@
}
String toString() {
- return "SyncbaseTableGetPrefixPermissionsParams("
+ return "_SyncbaseTableGetPrefixPermissionsParams("
"name: $name" ", "
"key: $key" ")";
}
@@ -7286,7 +7286,7 @@
}
-class SyncbaseTableSetPrefixPermissionsParams extends bindings.Struct {
+class _SyncbaseTableSetPrefixPermissionsParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(32, 0)
];
@@ -7294,9 +7294,9 @@
String prefix = null;
Perms perms = null;
- SyncbaseTableSetPrefixPermissionsParams() : super(kVersions.last.size);
+ _SyncbaseTableSetPrefixPermissionsParams() : super(kVersions.last.size);
- static SyncbaseTableSetPrefixPermissionsParams deserialize(bindings.Message message) {
+ static _SyncbaseTableSetPrefixPermissionsParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -7305,11 +7305,11 @@
return result;
}
- static SyncbaseTableSetPrefixPermissionsParams decode(bindings.Decoder decoder0) {
+ static _SyncbaseTableSetPrefixPermissionsParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- SyncbaseTableSetPrefixPermissionsParams result = new SyncbaseTableSetPrefixPermissionsParams();
+ _SyncbaseTableSetPrefixPermissionsParams result = new _SyncbaseTableSetPrefixPermissionsParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -7356,7 +7356,7 @@
}
String toString() {
- return "SyncbaseTableSetPrefixPermissionsParams("
+ return "_SyncbaseTableSetPrefixPermissionsParams("
"name: $name" ", "
"prefix: $prefix" ", "
"perms: $perms" ")";
@@ -7440,16 +7440,16 @@
}
-class SyncbaseTableDeletePrefixPermissionsParams extends bindings.Struct {
+class _SyncbaseTableDeletePrefixPermissionsParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(24, 0)
];
String name = null;
String prefix = null;
- SyncbaseTableDeletePrefixPermissionsParams() : super(kVersions.last.size);
+ _SyncbaseTableDeletePrefixPermissionsParams() : super(kVersions.last.size);
- static SyncbaseTableDeletePrefixPermissionsParams deserialize(bindings.Message message) {
+ static _SyncbaseTableDeletePrefixPermissionsParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -7458,11 +7458,11 @@
return result;
}
- static SyncbaseTableDeletePrefixPermissionsParams decode(bindings.Decoder decoder0) {
+ static _SyncbaseTableDeletePrefixPermissionsParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- SyncbaseTableDeletePrefixPermissionsParams result = new SyncbaseTableDeletePrefixPermissionsParams();
+ _SyncbaseTableDeletePrefixPermissionsParams result = new _SyncbaseTableDeletePrefixPermissionsParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -7502,7 +7502,7 @@
}
String toString() {
- return "SyncbaseTableDeletePrefixPermissionsParams("
+ return "_SyncbaseTableDeletePrefixPermissionsParams("
"name: $name" ", "
"prefix: $prefix" ")";
}
@@ -7584,15 +7584,15 @@
}
-class SyncbaseRowExistsParams extends bindings.Struct {
+class _SyncbaseRowExistsParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(16, 0)
];
String name = null;
- SyncbaseRowExistsParams() : super(kVersions.last.size);
+ _SyncbaseRowExistsParams() : super(kVersions.last.size);
- static SyncbaseRowExistsParams deserialize(bindings.Message message) {
+ static _SyncbaseRowExistsParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -7601,11 +7601,11 @@
return result;
}
- static SyncbaseRowExistsParams decode(bindings.Decoder decoder0) {
+ static _SyncbaseRowExistsParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- SyncbaseRowExistsParams result = new SyncbaseRowExistsParams();
+ _SyncbaseRowExistsParams result = new _SyncbaseRowExistsParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -7639,7 +7639,7 @@
}
String toString() {
- return "SyncbaseRowExistsParams("
+ return "_SyncbaseRowExistsParams("
"name: $name" ")";
}
@@ -7728,15 +7728,15 @@
}
-class SyncbaseRowGetParams extends bindings.Struct {
+class _SyncbaseRowGetParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(16, 0)
];
String name = null;
- SyncbaseRowGetParams() : super(kVersions.last.size);
+ _SyncbaseRowGetParams() : super(kVersions.last.size);
- static SyncbaseRowGetParams deserialize(bindings.Message message) {
+ static _SyncbaseRowGetParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -7745,11 +7745,11 @@
return result;
}
- static SyncbaseRowGetParams decode(bindings.Decoder decoder0) {
+ static _SyncbaseRowGetParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- SyncbaseRowGetParams result = new SyncbaseRowGetParams();
+ _SyncbaseRowGetParams result = new _SyncbaseRowGetParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -7783,7 +7783,7 @@
}
String toString() {
- return "SyncbaseRowGetParams("
+ return "_SyncbaseRowGetParams("
"name: $name" ")";
}
@@ -7872,16 +7872,16 @@
}
-class SyncbaseRowPutParams extends bindings.Struct {
+class _SyncbaseRowPutParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(24, 0)
];
String name = null;
List<int> value = null;
- SyncbaseRowPutParams() : super(kVersions.last.size);
+ _SyncbaseRowPutParams() : super(kVersions.last.size);
- static SyncbaseRowPutParams deserialize(bindings.Message message) {
+ static _SyncbaseRowPutParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -7890,11 +7890,11 @@
return result;
}
- static SyncbaseRowPutParams decode(bindings.Decoder decoder0) {
+ static _SyncbaseRowPutParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- SyncbaseRowPutParams result = new SyncbaseRowPutParams();
+ _SyncbaseRowPutParams result = new _SyncbaseRowPutParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -7934,7 +7934,7 @@
}
String toString() {
- return "SyncbaseRowPutParams("
+ return "_SyncbaseRowPutParams("
"name: $name" ", "
"value: $value" ")";
}
@@ -8016,15 +8016,15 @@
}
-class SyncbaseRowDeleteParams extends bindings.Struct {
+class _SyncbaseRowDeleteParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(16, 0)
];
String name = null;
- SyncbaseRowDeleteParams() : super(kVersions.last.size);
+ _SyncbaseRowDeleteParams() : super(kVersions.last.size);
- static SyncbaseRowDeleteParams deserialize(bindings.Message message) {
+ static _SyncbaseRowDeleteParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -8033,11 +8033,11 @@
return result;
}
- static SyncbaseRowDeleteParams decode(bindings.Decoder decoder0) {
+ static _SyncbaseRowDeleteParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- SyncbaseRowDeleteParams result = new SyncbaseRowDeleteParams();
+ _SyncbaseRowDeleteParams result = new _SyncbaseRowDeleteParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -8071,7 +8071,7 @@
}
String toString() {
- return "SyncbaseRowDeleteParams("
+ return "_SyncbaseRowDeleteParams("
"name: $name" ")";
}
@@ -8150,37 +8150,34 @@
}
}
-const int kExecStream_onResult_name = 0;
-const int kExecStream_onDone_name = 1;
-const String ExecStreamName = "v23::syncbase::ExecStream";
+const int _ExecStream_onResultName = 0;
+const int _ExecStream_onDoneName = 1;
abstract class ExecStream {
+ static const String serviceName = "v23::syncbase::ExecStream";
dynamic onResult(Result result,[Function responseFactory = null]);
void onDone(Error err);
-
}
-class ExecStreamProxyImpl extends bindings.Proxy {
- ExecStreamProxyImpl.fromEndpoint(
+class _ExecStreamProxyImpl extends bindings.Proxy {
+ _ExecStreamProxyImpl.fromEndpoint(
core.MojoMessagePipeEndpoint endpoint) : super.fromEndpoint(endpoint);
- ExecStreamProxyImpl.fromHandle(core.MojoHandle handle) :
+ _ExecStreamProxyImpl.fromHandle(core.MojoHandle handle) :
super.fromHandle(handle);
- ExecStreamProxyImpl.unbound() : super.unbound();
+ _ExecStreamProxyImpl.unbound() : super.unbound();
- static ExecStreamProxyImpl newFromEndpoint(
+ static _ExecStreamProxyImpl newFromEndpoint(
core.MojoMessagePipeEndpoint endpoint) {
- assert(endpoint.setDescription("For ExecStreamProxyImpl"));
- return new ExecStreamProxyImpl.fromEndpoint(endpoint);
+ assert(endpoint.setDescription("For _ExecStreamProxyImpl"));
+ return new _ExecStreamProxyImpl.fromEndpoint(endpoint);
}
- String get name => ExecStreamName;
-
void handleResponse(bindings.ServiceMessage message) {
switch (message.header.type) {
- case kExecStream_onResult_name:
+ case _ExecStream_onResultName:
var r = ExecStreamOnResultResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -8209,21 +8206,21 @@
String toString() {
var superString = super.toString();
- return "ExecStreamProxyImpl($superString)";
+ return "_ExecStreamProxyImpl($superString)";
}
}
class _ExecStreamProxyCalls implements ExecStream {
- ExecStreamProxyImpl _proxyImpl;
+ _ExecStreamProxyImpl _proxyImpl;
_ExecStreamProxyCalls(this._proxyImpl);
dynamic onResult(Result result,[Function responseFactory = null]) {
- var params = new ExecStreamOnResultParams();
+ var params = new _ExecStreamOnResultParams();
params.result = result;
return _proxyImpl.sendMessageWithRequestId(
params,
- kExecStream_onResult_name,
+ _ExecStream_onResultName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
@@ -8232,36 +8229,34 @@
_proxyImpl.proxyError("The Proxy is closed.");
return;
}
- var params = new ExecStreamOnDoneParams();
+ var params = new _ExecStreamOnDoneParams();
params.err = err;
- _proxyImpl.sendMessage(params, kExecStream_onDone_name);
+ _proxyImpl.sendMessage(params, _ExecStream_onDoneName);
}
-
}
class ExecStreamProxy implements bindings.ProxyBase {
final bindings.Proxy impl;
ExecStream ptr;
- final String name = ExecStreamName;
- ExecStreamProxy(ExecStreamProxyImpl proxyImpl) :
+ ExecStreamProxy(_ExecStreamProxyImpl proxyImpl) :
impl = proxyImpl,
ptr = new _ExecStreamProxyCalls(proxyImpl);
ExecStreamProxy.fromEndpoint(
core.MojoMessagePipeEndpoint endpoint) :
- impl = new ExecStreamProxyImpl.fromEndpoint(endpoint) {
+ impl = new _ExecStreamProxyImpl.fromEndpoint(endpoint) {
ptr = new _ExecStreamProxyCalls(impl);
}
ExecStreamProxy.fromHandle(core.MojoHandle handle) :
- impl = new ExecStreamProxyImpl.fromHandle(handle) {
+ impl = new _ExecStreamProxyImpl.fromHandle(handle) {
ptr = new _ExecStreamProxyCalls(impl);
}
ExecStreamProxy.unbound() :
- impl = new ExecStreamProxyImpl.unbound() {
+ impl = new _ExecStreamProxyImpl.unbound() {
ptr = new _ExecStreamProxyCalls(impl);
}
@@ -8278,6 +8273,8 @@
return new ExecStreamProxy.fromEndpoint(endpoint);
}
+ String get serviceName => ExecStream.serviceName;
+
Future close({bool immediate: false}) => impl.close(immediate: immediate);
Future responseOrError(Future f) => impl.responseOrError(f);
@@ -8316,8 +8313,6 @@
return new ExecStreamStub.fromEndpoint(endpoint);
}
- static const String name = ExecStreamName;
-
ExecStreamOnResultResponseParams _ExecStreamOnResultResponseParamsFactory() {
var mojo_factory_result = new ExecStreamOnResultResponseParams();
@@ -8332,8 +8327,8 @@
}
assert(_impl != null);
switch (message.header.type) {
- case kExecStream_onResult_name:
- var params = ExecStreamOnResultParams.deserialize(
+ case _ExecStream_onResultName:
+ var params = _ExecStreamOnResultParams.deserialize(
message.payload);
var response = _impl.onResult(params.result,_ExecStreamOnResultResponseParamsFactory);
if (response is Future) {
@@ -8341,7 +8336,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kExecStream_onResult_name,
+ _ExecStream_onResultName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -8349,13 +8344,13 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kExecStream_onResult_name,
+ _ExecStream_onResultName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kExecStream_onDone_name:
- var params = ExecStreamOnDoneParams.deserialize(
+ case _ExecStream_onDoneName:
+ var params = _ExecStreamOnDoneParams.deserialize(
message.payload);
_impl.onDone(params.err);
break;
@@ -8380,37 +8375,34 @@
int get version => 0;
}
-const int kScanStream_onKeyValue_name = 0;
-const int kScanStream_onDone_name = 1;
-const String ScanStreamName = "v23::syncbase::ScanStream";
+const int _ScanStream_onKeyValueName = 0;
+const int _ScanStream_onDoneName = 1;
abstract class ScanStream {
+ static const String serviceName = "v23::syncbase::ScanStream";
dynamic onKeyValue(KeyValue keyValue,[Function responseFactory = null]);
void onDone(Error err);
-
}
-class ScanStreamProxyImpl extends bindings.Proxy {
- ScanStreamProxyImpl.fromEndpoint(
+class _ScanStreamProxyImpl extends bindings.Proxy {
+ _ScanStreamProxyImpl.fromEndpoint(
core.MojoMessagePipeEndpoint endpoint) : super.fromEndpoint(endpoint);
- ScanStreamProxyImpl.fromHandle(core.MojoHandle handle) :
+ _ScanStreamProxyImpl.fromHandle(core.MojoHandle handle) :
super.fromHandle(handle);
- ScanStreamProxyImpl.unbound() : super.unbound();
+ _ScanStreamProxyImpl.unbound() : super.unbound();
- static ScanStreamProxyImpl newFromEndpoint(
+ static _ScanStreamProxyImpl newFromEndpoint(
core.MojoMessagePipeEndpoint endpoint) {
- assert(endpoint.setDescription("For ScanStreamProxyImpl"));
- return new ScanStreamProxyImpl.fromEndpoint(endpoint);
+ assert(endpoint.setDescription("For _ScanStreamProxyImpl"));
+ return new _ScanStreamProxyImpl.fromEndpoint(endpoint);
}
- String get name => ScanStreamName;
-
void handleResponse(bindings.ServiceMessage message) {
switch (message.header.type) {
- case kScanStream_onKeyValue_name:
+ case _ScanStream_onKeyValueName:
var r = ScanStreamOnKeyValueResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -8439,21 +8431,21 @@
String toString() {
var superString = super.toString();
- return "ScanStreamProxyImpl($superString)";
+ return "_ScanStreamProxyImpl($superString)";
}
}
class _ScanStreamProxyCalls implements ScanStream {
- ScanStreamProxyImpl _proxyImpl;
+ _ScanStreamProxyImpl _proxyImpl;
_ScanStreamProxyCalls(this._proxyImpl);
dynamic onKeyValue(KeyValue keyValue,[Function responseFactory = null]) {
- var params = new ScanStreamOnKeyValueParams();
+ var params = new _ScanStreamOnKeyValueParams();
params.keyValue = keyValue;
return _proxyImpl.sendMessageWithRequestId(
params,
- kScanStream_onKeyValue_name,
+ _ScanStream_onKeyValueName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
@@ -8462,36 +8454,34 @@
_proxyImpl.proxyError("The Proxy is closed.");
return;
}
- var params = new ScanStreamOnDoneParams();
+ var params = new _ScanStreamOnDoneParams();
params.err = err;
- _proxyImpl.sendMessage(params, kScanStream_onDone_name);
+ _proxyImpl.sendMessage(params, _ScanStream_onDoneName);
}
-
}
class ScanStreamProxy implements bindings.ProxyBase {
final bindings.Proxy impl;
ScanStream ptr;
- final String name = ScanStreamName;
- ScanStreamProxy(ScanStreamProxyImpl proxyImpl) :
+ ScanStreamProxy(_ScanStreamProxyImpl proxyImpl) :
impl = proxyImpl,
ptr = new _ScanStreamProxyCalls(proxyImpl);
ScanStreamProxy.fromEndpoint(
core.MojoMessagePipeEndpoint endpoint) :
- impl = new ScanStreamProxyImpl.fromEndpoint(endpoint) {
+ impl = new _ScanStreamProxyImpl.fromEndpoint(endpoint) {
ptr = new _ScanStreamProxyCalls(impl);
}
ScanStreamProxy.fromHandle(core.MojoHandle handle) :
- impl = new ScanStreamProxyImpl.fromHandle(handle) {
+ impl = new _ScanStreamProxyImpl.fromHandle(handle) {
ptr = new _ScanStreamProxyCalls(impl);
}
ScanStreamProxy.unbound() :
- impl = new ScanStreamProxyImpl.unbound() {
+ impl = new _ScanStreamProxyImpl.unbound() {
ptr = new _ScanStreamProxyCalls(impl);
}
@@ -8508,6 +8498,8 @@
return new ScanStreamProxy.fromEndpoint(endpoint);
}
+ String get serviceName => ScanStream.serviceName;
+
Future close({bool immediate: false}) => impl.close(immediate: immediate);
Future responseOrError(Future f) => impl.responseOrError(f);
@@ -8546,8 +8538,6 @@
return new ScanStreamStub.fromEndpoint(endpoint);
}
- static const String name = ScanStreamName;
-
ScanStreamOnKeyValueResponseParams _ScanStreamOnKeyValueResponseParamsFactory() {
var mojo_factory_result = new ScanStreamOnKeyValueResponseParams();
@@ -8562,8 +8552,8 @@
}
assert(_impl != null);
switch (message.header.type) {
- case kScanStream_onKeyValue_name:
- var params = ScanStreamOnKeyValueParams.deserialize(
+ case _ScanStream_onKeyValueName:
+ var params = _ScanStreamOnKeyValueParams.deserialize(
message.payload);
var response = _impl.onKeyValue(params.keyValue,_ScanStreamOnKeyValueResponseParamsFactory);
if (response is Future) {
@@ -8571,7 +8561,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kScanStream_onKeyValue_name,
+ _ScanStream_onKeyValueName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -8579,13 +8569,13 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kScanStream_onKeyValue_name,
+ _ScanStream_onKeyValueName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kScanStream_onDone_name:
- var params = ScanStreamOnDoneParams.deserialize(
+ case _ScanStream_onDoneName:
+ var params = _ScanStreamOnDoneParams.deserialize(
message.payload);
_impl.onDone(params.err);
break;
@@ -8610,37 +8600,34 @@
int get version => 0;
}
-const int kWatchGlobStream_onChange_name = 0;
-const int kWatchGlobStream_onError_name = 1;
-const String WatchGlobStreamName = "v23::syncbase::WatchGlobStream";
+const int _WatchGlobStream_onChangeName = 0;
+const int _WatchGlobStream_onErrorName = 1;
abstract class WatchGlobStream {
+ static const String serviceName = "v23::syncbase::WatchGlobStream";
dynamic onChange(WatchChange change,[Function responseFactory = null]);
void onError(Error err);
-
}
-class WatchGlobStreamProxyImpl extends bindings.Proxy {
- WatchGlobStreamProxyImpl.fromEndpoint(
+class _WatchGlobStreamProxyImpl extends bindings.Proxy {
+ _WatchGlobStreamProxyImpl.fromEndpoint(
core.MojoMessagePipeEndpoint endpoint) : super.fromEndpoint(endpoint);
- WatchGlobStreamProxyImpl.fromHandle(core.MojoHandle handle) :
+ _WatchGlobStreamProxyImpl.fromHandle(core.MojoHandle handle) :
super.fromHandle(handle);
- WatchGlobStreamProxyImpl.unbound() : super.unbound();
+ _WatchGlobStreamProxyImpl.unbound() : super.unbound();
- static WatchGlobStreamProxyImpl newFromEndpoint(
+ static _WatchGlobStreamProxyImpl newFromEndpoint(
core.MojoMessagePipeEndpoint endpoint) {
- assert(endpoint.setDescription("For WatchGlobStreamProxyImpl"));
- return new WatchGlobStreamProxyImpl.fromEndpoint(endpoint);
+ assert(endpoint.setDescription("For _WatchGlobStreamProxyImpl"));
+ return new _WatchGlobStreamProxyImpl.fromEndpoint(endpoint);
}
- String get name => WatchGlobStreamName;
-
void handleResponse(bindings.ServiceMessage message) {
switch (message.header.type) {
- case kWatchGlobStream_onChange_name:
+ case _WatchGlobStream_onChangeName:
var r = WatchGlobStreamOnChangeResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -8669,21 +8656,21 @@
String toString() {
var superString = super.toString();
- return "WatchGlobStreamProxyImpl($superString)";
+ return "_WatchGlobStreamProxyImpl($superString)";
}
}
class _WatchGlobStreamProxyCalls implements WatchGlobStream {
- WatchGlobStreamProxyImpl _proxyImpl;
+ _WatchGlobStreamProxyImpl _proxyImpl;
_WatchGlobStreamProxyCalls(this._proxyImpl);
dynamic onChange(WatchChange change,[Function responseFactory = null]) {
- var params = new WatchGlobStreamOnChangeParams();
+ var params = new _WatchGlobStreamOnChangeParams();
params.change = change;
return _proxyImpl.sendMessageWithRequestId(
params,
- kWatchGlobStream_onChange_name,
+ _WatchGlobStream_onChangeName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
@@ -8692,36 +8679,34 @@
_proxyImpl.proxyError("The Proxy is closed.");
return;
}
- var params = new WatchGlobStreamOnErrorParams();
+ var params = new _WatchGlobStreamOnErrorParams();
params.err = err;
- _proxyImpl.sendMessage(params, kWatchGlobStream_onError_name);
+ _proxyImpl.sendMessage(params, _WatchGlobStream_onErrorName);
}
-
}
class WatchGlobStreamProxy implements bindings.ProxyBase {
final bindings.Proxy impl;
WatchGlobStream ptr;
- final String name = WatchGlobStreamName;
- WatchGlobStreamProxy(WatchGlobStreamProxyImpl proxyImpl) :
+ WatchGlobStreamProxy(_WatchGlobStreamProxyImpl proxyImpl) :
impl = proxyImpl,
ptr = new _WatchGlobStreamProxyCalls(proxyImpl);
WatchGlobStreamProxy.fromEndpoint(
core.MojoMessagePipeEndpoint endpoint) :
- impl = new WatchGlobStreamProxyImpl.fromEndpoint(endpoint) {
+ impl = new _WatchGlobStreamProxyImpl.fromEndpoint(endpoint) {
ptr = new _WatchGlobStreamProxyCalls(impl);
}
WatchGlobStreamProxy.fromHandle(core.MojoHandle handle) :
- impl = new WatchGlobStreamProxyImpl.fromHandle(handle) {
+ impl = new _WatchGlobStreamProxyImpl.fromHandle(handle) {
ptr = new _WatchGlobStreamProxyCalls(impl);
}
WatchGlobStreamProxy.unbound() :
- impl = new WatchGlobStreamProxyImpl.unbound() {
+ impl = new _WatchGlobStreamProxyImpl.unbound() {
ptr = new _WatchGlobStreamProxyCalls(impl);
}
@@ -8738,6 +8723,8 @@
return new WatchGlobStreamProxy.fromEndpoint(endpoint);
}
+ String get serviceName => WatchGlobStream.serviceName;
+
Future close({bool immediate: false}) => impl.close(immediate: immediate);
Future responseOrError(Future f) => impl.responseOrError(f);
@@ -8776,8 +8763,6 @@
return new WatchGlobStreamStub.fromEndpoint(endpoint);
}
- static const String name = WatchGlobStreamName;
-
WatchGlobStreamOnChangeResponseParams _WatchGlobStreamOnChangeResponseParamsFactory() {
var mojo_factory_result = new WatchGlobStreamOnChangeResponseParams();
@@ -8792,8 +8777,8 @@
}
assert(_impl != null);
switch (message.header.type) {
- case kWatchGlobStream_onChange_name:
- var params = WatchGlobStreamOnChangeParams.deserialize(
+ case _WatchGlobStream_onChangeName:
+ var params = _WatchGlobStreamOnChangeParams.deserialize(
message.payload);
var response = _impl.onChange(params.change,_WatchGlobStreamOnChangeResponseParamsFactory);
if (response is Future) {
@@ -8801,7 +8786,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kWatchGlobStream_onChange_name,
+ _WatchGlobStream_onChangeName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -8809,13 +8794,13 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kWatchGlobStream_onChange_name,
+ _WatchGlobStream_onChangeName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kWatchGlobStream_onError_name:
- var params = WatchGlobStreamOnErrorParams.deserialize(
+ case _WatchGlobStream_onErrorName:
+ var params = _WatchGlobStreamOnErrorParams.deserialize(
message.payload);
_impl.onError(params.err);
break;
@@ -8840,53 +8825,53 @@
int get version => 0;
}
-const int kSyncbase_serviceGetPermissions_name = 0;
-const int kSyncbase_serviceSetPermissions_name = 1;
-const int kSyncbase_serviceListApps_name = 2;
-const int kSyncbase_appCreate_name = 3;
-const int kSyncbase_appDestroy_name = 4;
-const int kSyncbase_appExists_name = 5;
-const int kSyncbase_appGetPermissions_name = 6;
-const int kSyncbase_appListDatabases_name = 7;
-const int kSyncbase_appSetPermissions_name = 8;
-const int kSyncbase_dbCreate_name = 9;
-const int kSyncbase_dbDestroy_name = 10;
-const int kSyncbase_dbExists_name = 11;
-const int kSyncbase_dbExec_name = 12;
-const int kSyncbase_dbBeginBatch_name = 13;
-const int kSyncbase_dbCommit_name = 14;
-const int kSyncbase_dbAbort_name = 15;
-const int kSyncbase_dbGetPermissions_name = 16;
-const int kSyncbase_dbSetPermissions_name = 17;
-const int kSyncbase_dbWatchGlob_name = 18;
-const int kSyncbase_dbGetResumeMarker_name = 19;
-const int kSyncbase_dbListTables_name = 20;
-const int kSyncbase_dbGetSyncgroupNames_name = 21;
-const int kSyncbase_dbCreateSyncgroup_name = 22;
-const int kSyncbase_dbJoinSyncgroup_name = 23;
-const int kSyncbase_dbLeaveSyncgroup_name = 24;
-const int kSyncbase_dbDestroySyncgroup_name = 25;
-const int kSyncbase_dbEjectFromSyncgroup_name = 26;
-const int kSyncbase_dbGetSyncgroupSpec_name = 27;
-const int kSyncbase_dbSetSyncgroupSpec_name = 28;
-const int kSyncbase_dbGetSyncgroupMembers_name = 29;
-const int kSyncbase_tableCreate_name = 30;
-const int kSyncbase_tableDestroy_name = 31;
-const int kSyncbase_tableExists_name = 32;
-const int kSyncbase_tableGetPermissions_name = 33;
-const int kSyncbase_tableSetPermissions_name = 34;
-const int kSyncbase_tableDeleteRange_name = 35;
-const int kSyncbase_tableScan_name = 36;
-const int kSyncbase_tableGetPrefixPermissions_name = 37;
-const int kSyncbase_tableSetPrefixPermissions_name = 38;
-const int kSyncbase_tableDeletePrefixPermissions_name = 39;
-const int kSyncbase_rowExists_name = 40;
-const int kSyncbase_rowGet_name = 41;
-const int kSyncbase_rowPut_name = 42;
-const int kSyncbase_rowDelete_name = 43;
-const String SyncbaseName = "v23::syncbase::Syncbase";
+const int _Syncbase_serviceGetPermissionsName = 0;
+const int _Syncbase_serviceSetPermissionsName = 1;
+const int _Syncbase_serviceListAppsName = 2;
+const int _Syncbase_appCreateName = 3;
+const int _Syncbase_appDestroyName = 4;
+const int _Syncbase_appExistsName = 5;
+const int _Syncbase_appGetPermissionsName = 6;
+const int _Syncbase_appListDatabasesName = 7;
+const int _Syncbase_appSetPermissionsName = 8;
+const int _Syncbase_dbCreateName = 9;
+const int _Syncbase_dbDestroyName = 10;
+const int _Syncbase_dbExistsName = 11;
+const int _Syncbase_dbExecName = 12;
+const int _Syncbase_dbBeginBatchName = 13;
+const int _Syncbase_dbCommitName = 14;
+const int _Syncbase_dbAbortName = 15;
+const int _Syncbase_dbGetPermissionsName = 16;
+const int _Syncbase_dbSetPermissionsName = 17;
+const int _Syncbase_dbWatchGlobName = 18;
+const int _Syncbase_dbGetResumeMarkerName = 19;
+const int _Syncbase_dbListTablesName = 20;
+const int _Syncbase_dbGetSyncgroupNamesName = 21;
+const int _Syncbase_dbCreateSyncgroupName = 22;
+const int _Syncbase_dbJoinSyncgroupName = 23;
+const int _Syncbase_dbLeaveSyncgroupName = 24;
+const int _Syncbase_dbDestroySyncgroupName = 25;
+const int _Syncbase_dbEjectFromSyncgroupName = 26;
+const int _Syncbase_dbGetSyncgroupSpecName = 27;
+const int _Syncbase_dbSetSyncgroupSpecName = 28;
+const int _Syncbase_dbGetSyncgroupMembersName = 29;
+const int _Syncbase_tableCreateName = 30;
+const int _Syncbase_tableDestroyName = 31;
+const int _Syncbase_tableExistsName = 32;
+const int _Syncbase_tableGetPermissionsName = 33;
+const int _Syncbase_tableSetPermissionsName = 34;
+const int _Syncbase_tableDeleteRangeName = 35;
+const int _Syncbase_tableScanName = 36;
+const int _Syncbase_tableGetPrefixPermissionsName = 37;
+const int _Syncbase_tableSetPrefixPermissionsName = 38;
+const int _Syncbase_tableDeletePrefixPermissionsName = 39;
+const int _Syncbase_rowExistsName = 40;
+const int _Syncbase_rowGetName = 41;
+const int _Syncbase_rowPutName = 42;
+const int _Syncbase_rowDeleteName = 43;
abstract class Syncbase {
+ static const String serviceName = "v23::syncbase::Syncbase";
dynamic serviceGetPermissions([Function responseFactory = null]);
dynamic serviceSetPermissions(Perms perms,String version,[Function responseFactory = null]);
dynamic serviceListApps([Function responseFactory = null]);
@@ -8931,30 +8916,27 @@
dynamic rowGet(String name,[Function responseFactory = null]);
dynamic rowPut(String name,List<int> value,[Function responseFactory = null]);
dynamic rowDelete(String name,[Function responseFactory = null]);
-
}
-class SyncbaseProxyImpl extends bindings.Proxy {
- SyncbaseProxyImpl.fromEndpoint(
+class _SyncbaseProxyImpl extends bindings.Proxy {
+ _SyncbaseProxyImpl.fromEndpoint(
core.MojoMessagePipeEndpoint endpoint) : super.fromEndpoint(endpoint);
- SyncbaseProxyImpl.fromHandle(core.MojoHandle handle) :
+ _SyncbaseProxyImpl.fromHandle(core.MojoHandle handle) :
super.fromHandle(handle);
- SyncbaseProxyImpl.unbound() : super.unbound();
+ _SyncbaseProxyImpl.unbound() : super.unbound();
- static SyncbaseProxyImpl newFromEndpoint(
+ static _SyncbaseProxyImpl newFromEndpoint(
core.MojoMessagePipeEndpoint endpoint) {
- assert(endpoint.setDescription("For SyncbaseProxyImpl"));
- return new SyncbaseProxyImpl.fromEndpoint(endpoint);
+ assert(endpoint.setDescription("For _SyncbaseProxyImpl"));
+ return new _SyncbaseProxyImpl.fromEndpoint(endpoint);
}
- String get name => SyncbaseName;
-
void handleResponse(bindings.ServiceMessage message) {
switch (message.header.type) {
- case kSyncbase_serviceGetPermissions_name:
+ case _Syncbase_serviceGetPermissionsName:
var r = SyncbaseServiceGetPermissionsResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -8974,7 +8956,7 @@
}
c.complete(r);
break;
- case kSyncbase_serviceSetPermissions_name:
+ case _Syncbase_serviceSetPermissionsName:
var r = SyncbaseServiceSetPermissionsResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -8994,7 +8976,7 @@
}
c.complete(r);
break;
- case kSyncbase_serviceListApps_name:
+ case _Syncbase_serviceListAppsName:
var r = SyncbaseServiceListAppsResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -9014,7 +8996,7 @@
}
c.complete(r);
break;
- case kSyncbase_appCreate_name:
+ case _Syncbase_appCreateName:
var r = SyncbaseAppCreateResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -9034,7 +9016,7 @@
}
c.complete(r);
break;
- case kSyncbase_appDestroy_name:
+ case _Syncbase_appDestroyName:
var r = SyncbaseAppDestroyResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -9054,7 +9036,7 @@
}
c.complete(r);
break;
- case kSyncbase_appExists_name:
+ case _Syncbase_appExistsName:
var r = SyncbaseAppExistsResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -9074,7 +9056,7 @@
}
c.complete(r);
break;
- case kSyncbase_appGetPermissions_name:
+ case _Syncbase_appGetPermissionsName:
var r = SyncbaseAppGetPermissionsResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -9094,7 +9076,7 @@
}
c.complete(r);
break;
- case kSyncbase_appListDatabases_name:
+ case _Syncbase_appListDatabasesName:
var r = SyncbaseAppListDatabasesResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -9114,7 +9096,7 @@
}
c.complete(r);
break;
- case kSyncbase_appSetPermissions_name:
+ case _Syncbase_appSetPermissionsName:
var r = SyncbaseAppSetPermissionsResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -9134,7 +9116,7 @@
}
c.complete(r);
break;
- case kSyncbase_dbCreate_name:
+ case _Syncbase_dbCreateName:
var r = SyncbaseDbCreateResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -9154,7 +9136,7 @@
}
c.complete(r);
break;
- case kSyncbase_dbDestroy_name:
+ case _Syncbase_dbDestroyName:
var r = SyncbaseDbDestroyResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -9174,7 +9156,7 @@
}
c.complete(r);
break;
- case kSyncbase_dbExists_name:
+ case _Syncbase_dbExistsName:
var r = SyncbaseDbExistsResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -9194,7 +9176,7 @@
}
c.complete(r);
break;
- case kSyncbase_dbExec_name:
+ case _Syncbase_dbExecName:
var r = SyncbaseDbExecResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -9214,7 +9196,7 @@
}
c.complete(r);
break;
- case kSyncbase_dbBeginBatch_name:
+ case _Syncbase_dbBeginBatchName:
var r = SyncbaseDbBeginBatchResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -9234,7 +9216,7 @@
}
c.complete(r);
break;
- case kSyncbase_dbCommit_name:
+ case _Syncbase_dbCommitName:
var r = SyncbaseDbCommitResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -9254,7 +9236,7 @@
}
c.complete(r);
break;
- case kSyncbase_dbAbort_name:
+ case _Syncbase_dbAbortName:
var r = SyncbaseDbAbortResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -9274,7 +9256,7 @@
}
c.complete(r);
break;
- case kSyncbase_dbGetPermissions_name:
+ case _Syncbase_dbGetPermissionsName:
var r = SyncbaseDbGetPermissionsResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -9294,7 +9276,7 @@
}
c.complete(r);
break;
- case kSyncbase_dbSetPermissions_name:
+ case _Syncbase_dbSetPermissionsName:
var r = SyncbaseDbSetPermissionsResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -9314,7 +9296,7 @@
}
c.complete(r);
break;
- case kSyncbase_dbWatchGlob_name:
+ case _Syncbase_dbWatchGlobName:
var r = SyncbaseDbWatchGlobResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -9334,7 +9316,7 @@
}
c.complete(r);
break;
- case kSyncbase_dbGetResumeMarker_name:
+ case _Syncbase_dbGetResumeMarkerName:
var r = SyncbaseDbGetResumeMarkerResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -9354,7 +9336,7 @@
}
c.complete(r);
break;
- case kSyncbase_dbListTables_name:
+ case _Syncbase_dbListTablesName:
var r = SyncbaseDbListTablesResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -9374,7 +9356,7 @@
}
c.complete(r);
break;
- case kSyncbase_dbGetSyncgroupNames_name:
+ case _Syncbase_dbGetSyncgroupNamesName:
var r = SyncbaseDbGetSyncgroupNamesResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -9394,7 +9376,7 @@
}
c.complete(r);
break;
- case kSyncbase_dbCreateSyncgroup_name:
+ case _Syncbase_dbCreateSyncgroupName:
var r = SyncbaseDbCreateSyncgroupResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -9414,7 +9396,7 @@
}
c.complete(r);
break;
- case kSyncbase_dbJoinSyncgroup_name:
+ case _Syncbase_dbJoinSyncgroupName:
var r = SyncbaseDbJoinSyncgroupResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -9434,7 +9416,7 @@
}
c.complete(r);
break;
- case kSyncbase_dbLeaveSyncgroup_name:
+ case _Syncbase_dbLeaveSyncgroupName:
var r = SyncbaseDbLeaveSyncgroupResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -9454,7 +9436,7 @@
}
c.complete(r);
break;
- case kSyncbase_dbDestroySyncgroup_name:
+ case _Syncbase_dbDestroySyncgroupName:
var r = SyncbaseDbDestroySyncgroupResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -9474,7 +9456,7 @@
}
c.complete(r);
break;
- case kSyncbase_dbEjectFromSyncgroup_name:
+ case _Syncbase_dbEjectFromSyncgroupName:
var r = SyncbaseDbEjectFromSyncgroupResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -9494,7 +9476,7 @@
}
c.complete(r);
break;
- case kSyncbase_dbGetSyncgroupSpec_name:
+ case _Syncbase_dbGetSyncgroupSpecName:
var r = SyncbaseDbGetSyncgroupSpecResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -9514,7 +9496,7 @@
}
c.complete(r);
break;
- case kSyncbase_dbSetSyncgroupSpec_name:
+ case _Syncbase_dbSetSyncgroupSpecName:
var r = SyncbaseDbSetSyncgroupSpecResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -9534,7 +9516,7 @@
}
c.complete(r);
break;
- case kSyncbase_dbGetSyncgroupMembers_name:
+ case _Syncbase_dbGetSyncgroupMembersName:
var r = SyncbaseDbGetSyncgroupMembersResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -9554,7 +9536,7 @@
}
c.complete(r);
break;
- case kSyncbase_tableCreate_name:
+ case _Syncbase_tableCreateName:
var r = SyncbaseTableCreateResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -9574,7 +9556,7 @@
}
c.complete(r);
break;
- case kSyncbase_tableDestroy_name:
+ case _Syncbase_tableDestroyName:
var r = SyncbaseTableDestroyResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -9594,7 +9576,7 @@
}
c.complete(r);
break;
- case kSyncbase_tableExists_name:
+ case _Syncbase_tableExistsName:
var r = SyncbaseTableExistsResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -9614,7 +9596,7 @@
}
c.complete(r);
break;
- case kSyncbase_tableGetPermissions_name:
+ case _Syncbase_tableGetPermissionsName:
var r = SyncbaseTableGetPermissionsResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -9634,7 +9616,7 @@
}
c.complete(r);
break;
- case kSyncbase_tableSetPermissions_name:
+ case _Syncbase_tableSetPermissionsName:
var r = SyncbaseTableSetPermissionsResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -9654,7 +9636,7 @@
}
c.complete(r);
break;
- case kSyncbase_tableDeleteRange_name:
+ case _Syncbase_tableDeleteRangeName:
var r = SyncbaseTableDeleteRangeResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -9674,7 +9656,7 @@
}
c.complete(r);
break;
- case kSyncbase_tableScan_name:
+ case _Syncbase_tableScanName:
var r = SyncbaseTableScanResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -9694,7 +9676,7 @@
}
c.complete(r);
break;
- case kSyncbase_tableGetPrefixPermissions_name:
+ case _Syncbase_tableGetPrefixPermissionsName:
var r = SyncbaseTableGetPrefixPermissionsResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -9714,7 +9696,7 @@
}
c.complete(r);
break;
- case kSyncbase_tableSetPrefixPermissions_name:
+ case _Syncbase_tableSetPrefixPermissionsName:
var r = SyncbaseTableSetPrefixPermissionsResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -9734,7 +9716,7 @@
}
c.complete(r);
break;
- case kSyncbase_tableDeletePrefixPermissions_name:
+ case _Syncbase_tableDeletePrefixPermissionsName:
var r = SyncbaseTableDeletePrefixPermissionsResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -9754,7 +9736,7 @@
}
c.complete(r);
break;
- case kSyncbase_rowExists_name:
+ case _Syncbase_rowExistsName:
var r = SyncbaseRowExistsResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -9774,7 +9756,7 @@
}
c.complete(r);
break;
- case kSyncbase_rowGet_name:
+ case _Syncbase_rowGetName:
var r = SyncbaseRowGetResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -9794,7 +9776,7 @@
}
c.complete(r);
break;
- case kSyncbase_rowPut_name:
+ case _Syncbase_rowPutName:
var r = SyncbaseRowPutResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -9814,7 +9796,7 @@
}
c.complete(r);
break;
- case kSyncbase_rowDelete_name:
+ case _Syncbase_rowDeleteName:
var r = SyncbaseRowDeleteResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
@@ -9843,444 +9825,444 @@
String toString() {
var superString = super.toString();
- return "SyncbaseProxyImpl($superString)";
+ return "_SyncbaseProxyImpl($superString)";
}
}
class _SyncbaseProxyCalls implements Syncbase {
- SyncbaseProxyImpl _proxyImpl;
+ _SyncbaseProxyImpl _proxyImpl;
_SyncbaseProxyCalls(this._proxyImpl);
dynamic serviceGetPermissions([Function responseFactory = null]) {
- var params = new SyncbaseServiceGetPermissionsParams();
+ var params = new _SyncbaseServiceGetPermissionsParams();
return _proxyImpl.sendMessageWithRequestId(
params,
- kSyncbase_serviceGetPermissions_name,
+ _Syncbase_serviceGetPermissionsName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
dynamic serviceSetPermissions(Perms perms,String version,[Function responseFactory = null]) {
- var params = new SyncbaseServiceSetPermissionsParams();
+ var params = new _SyncbaseServiceSetPermissionsParams();
params.perms = perms;
params.version = version;
return _proxyImpl.sendMessageWithRequestId(
params,
- kSyncbase_serviceSetPermissions_name,
+ _Syncbase_serviceSetPermissionsName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
dynamic serviceListApps([Function responseFactory = null]) {
- var params = new SyncbaseServiceListAppsParams();
+ var params = new _SyncbaseServiceListAppsParams();
return _proxyImpl.sendMessageWithRequestId(
params,
- kSyncbase_serviceListApps_name,
+ _Syncbase_serviceListAppsName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
dynamic appCreate(String name,Perms perms,[Function responseFactory = null]) {
- var params = new SyncbaseAppCreateParams();
+ var params = new _SyncbaseAppCreateParams();
params.name = name;
params.perms = perms;
return _proxyImpl.sendMessageWithRequestId(
params,
- kSyncbase_appCreate_name,
+ _Syncbase_appCreateName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
dynamic appDestroy(String name,[Function responseFactory = null]) {
- var params = new SyncbaseAppDestroyParams();
+ var params = new _SyncbaseAppDestroyParams();
params.name = name;
return _proxyImpl.sendMessageWithRequestId(
params,
- kSyncbase_appDestroy_name,
+ _Syncbase_appDestroyName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
dynamic appExists(String name,[Function responseFactory = null]) {
- var params = new SyncbaseAppExistsParams();
+ var params = new _SyncbaseAppExistsParams();
params.name = name;
return _proxyImpl.sendMessageWithRequestId(
params,
- kSyncbase_appExists_name,
+ _Syncbase_appExistsName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
dynamic appGetPermissions(String name,[Function responseFactory = null]) {
- var params = new SyncbaseAppGetPermissionsParams();
+ var params = new _SyncbaseAppGetPermissionsParams();
params.name = name;
return _proxyImpl.sendMessageWithRequestId(
params,
- kSyncbase_appGetPermissions_name,
+ _Syncbase_appGetPermissionsName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
dynamic appListDatabases(String name,[Function responseFactory = null]) {
- var params = new SyncbaseAppListDatabasesParams();
+ var params = new _SyncbaseAppListDatabasesParams();
params.name = name;
return _proxyImpl.sendMessageWithRequestId(
params,
- kSyncbase_appListDatabases_name,
+ _Syncbase_appListDatabasesName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
dynamic appSetPermissions(String name,Perms perms,String version,[Function responseFactory = null]) {
- var params = new SyncbaseAppSetPermissionsParams();
+ var params = new _SyncbaseAppSetPermissionsParams();
params.name = name;
params.perms = perms;
params.version = version;
return _proxyImpl.sendMessageWithRequestId(
params,
- kSyncbase_appSetPermissions_name,
+ _Syncbase_appSetPermissionsName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
dynamic dbCreate(String name,Perms perms,[Function responseFactory = null]) {
- var params = new SyncbaseDbCreateParams();
+ var params = new _SyncbaseDbCreateParams();
params.name = name;
params.perms = perms;
return _proxyImpl.sendMessageWithRequestId(
params,
- kSyncbase_dbCreate_name,
+ _Syncbase_dbCreateName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
dynamic dbDestroy(String name,[Function responseFactory = null]) {
- var params = new SyncbaseDbDestroyParams();
+ var params = new _SyncbaseDbDestroyParams();
params.name = name;
return _proxyImpl.sendMessageWithRequestId(
params,
- kSyncbase_dbDestroy_name,
+ _Syncbase_dbDestroyName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
dynamic dbExists(String name,[Function responseFactory = null]) {
- var params = new SyncbaseDbExistsParams();
+ var params = new _SyncbaseDbExistsParams();
params.name = name;
return _proxyImpl.sendMessageWithRequestId(
params,
- kSyncbase_dbExists_name,
+ _Syncbase_dbExistsName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
dynamic dbExec(String name,String query,Object stream,[Function responseFactory = null]) {
- var params = new SyncbaseDbExecParams();
+ var params = new _SyncbaseDbExecParams();
params.name = name;
params.query = query;
params.stream = stream;
return _proxyImpl.sendMessageWithRequestId(
params,
- kSyncbase_dbExec_name,
+ _Syncbase_dbExecName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
dynamic dbBeginBatch(String name,BatchOptions bo,[Function responseFactory = null]) {
- var params = new SyncbaseDbBeginBatchParams();
+ var params = new _SyncbaseDbBeginBatchParams();
params.name = name;
params.bo = bo;
return _proxyImpl.sendMessageWithRequestId(
params,
- kSyncbase_dbBeginBatch_name,
+ _Syncbase_dbBeginBatchName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
dynamic dbCommit(String name,[Function responseFactory = null]) {
- var params = new SyncbaseDbCommitParams();
+ var params = new _SyncbaseDbCommitParams();
params.name = name;
return _proxyImpl.sendMessageWithRequestId(
params,
- kSyncbase_dbCommit_name,
+ _Syncbase_dbCommitName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
dynamic dbAbort(String name,[Function responseFactory = null]) {
- var params = new SyncbaseDbAbortParams();
+ var params = new _SyncbaseDbAbortParams();
params.name = name;
return _proxyImpl.sendMessageWithRequestId(
params,
- kSyncbase_dbAbort_name,
+ _Syncbase_dbAbortName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
dynamic dbGetPermissions(String name,[Function responseFactory = null]) {
- var params = new SyncbaseDbGetPermissionsParams();
+ var params = new _SyncbaseDbGetPermissionsParams();
params.name = name;
return _proxyImpl.sendMessageWithRequestId(
params,
- kSyncbase_dbGetPermissions_name,
+ _Syncbase_dbGetPermissionsName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
dynamic dbSetPermissions(String name,Perms perms,String version,[Function responseFactory = null]) {
- var params = new SyncbaseDbSetPermissionsParams();
+ var params = new _SyncbaseDbSetPermissionsParams();
params.name = name;
params.perms = perms;
params.version = version;
return _proxyImpl.sendMessageWithRequestId(
params,
- kSyncbase_dbSetPermissions_name,
+ _Syncbase_dbSetPermissionsName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
dynamic dbWatchGlob(String name,GlobRequest req,Object stream,[Function responseFactory = null]) {
- var params = new SyncbaseDbWatchGlobParams();
+ var params = new _SyncbaseDbWatchGlobParams();
params.name = name;
params.req = req;
params.stream = stream;
return _proxyImpl.sendMessageWithRequestId(
params,
- kSyncbase_dbWatchGlob_name,
+ _Syncbase_dbWatchGlobName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
dynamic dbGetResumeMarker(String name,[Function responseFactory = null]) {
- var params = new SyncbaseDbGetResumeMarkerParams();
+ var params = new _SyncbaseDbGetResumeMarkerParams();
params.name = name;
return _proxyImpl.sendMessageWithRequestId(
params,
- kSyncbase_dbGetResumeMarker_name,
+ _Syncbase_dbGetResumeMarkerName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
dynamic dbListTables(String name,[Function responseFactory = null]) {
- var params = new SyncbaseDbListTablesParams();
+ var params = new _SyncbaseDbListTablesParams();
params.name = name;
return _proxyImpl.sendMessageWithRequestId(
params,
- kSyncbase_dbListTables_name,
+ _Syncbase_dbListTablesName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
dynamic dbGetSyncgroupNames(String name,[Function responseFactory = null]) {
- var params = new SyncbaseDbGetSyncgroupNamesParams();
+ var params = new _SyncbaseDbGetSyncgroupNamesParams();
params.name = name;
return _proxyImpl.sendMessageWithRequestId(
params,
- kSyncbase_dbGetSyncgroupNames_name,
+ _Syncbase_dbGetSyncgroupNamesName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
dynamic dbCreateSyncgroup(String name,String sgName,SyncgroupSpec spec,SyncgroupMemberInfo myInfo,[Function responseFactory = null]) {
- var params = new SyncbaseDbCreateSyncgroupParams();
+ var params = new _SyncbaseDbCreateSyncgroupParams();
params.name = name;
params.sgName = sgName;
params.spec = spec;
params.myInfo = myInfo;
return _proxyImpl.sendMessageWithRequestId(
params,
- kSyncbase_dbCreateSyncgroup_name,
+ _Syncbase_dbCreateSyncgroupName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
dynamic dbJoinSyncgroup(String name,String sgName,SyncgroupMemberInfo myInfo,[Function responseFactory = null]) {
- var params = new SyncbaseDbJoinSyncgroupParams();
+ var params = new _SyncbaseDbJoinSyncgroupParams();
params.name = name;
params.sgName = sgName;
params.myInfo = myInfo;
return _proxyImpl.sendMessageWithRequestId(
params,
- kSyncbase_dbJoinSyncgroup_name,
+ _Syncbase_dbJoinSyncgroupName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
dynamic dbLeaveSyncgroup(String name,String sgName,[Function responseFactory = null]) {
- var params = new SyncbaseDbLeaveSyncgroupParams();
+ var params = new _SyncbaseDbLeaveSyncgroupParams();
params.name = name;
params.sgName = sgName;
return _proxyImpl.sendMessageWithRequestId(
params,
- kSyncbase_dbLeaveSyncgroup_name,
+ _Syncbase_dbLeaveSyncgroupName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
dynamic dbDestroySyncgroup(String name,String sgName,[Function responseFactory = null]) {
- var params = new SyncbaseDbDestroySyncgroupParams();
+ var params = new _SyncbaseDbDestroySyncgroupParams();
params.name = name;
params.sgName = sgName;
return _proxyImpl.sendMessageWithRequestId(
params,
- kSyncbase_dbDestroySyncgroup_name,
+ _Syncbase_dbDestroySyncgroupName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
dynamic dbEjectFromSyncgroup(String name,String sgName,String member,[Function responseFactory = null]) {
- var params = new SyncbaseDbEjectFromSyncgroupParams();
+ var params = new _SyncbaseDbEjectFromSyncgroupParams();
params.name = name;
params.sgName = sgName;
params.member = member;
return _proxyImpl.sendMessageWithRequestId(
params,
- kSyncbase_dbEjectFromSyncgroup_name,
+ _Syncbase_dbEjectFromSyncgroupName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
dynamic dbGetSyncgroupSpec(String name,String sgName,[Function responseFactory = null]) {
- var params = new SyncbaseDbGetSyncgroupSpecParams();
+ var params = new _SyncbaseDbGetSyncgroupSpecParams();
params.name = name;
params.sgName = sgName;
return _proxyImpl.sendMessageWithRequestId(
params,
- kSyncbase_dbGetSyncgroupSpec_name,
+ _Syncbase_dbGetSyncgroupSpecName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
dynamic dbSetSyncgroupSpec(String name,String sgName,SyncgroupSpec spec,String version,[Function responseFactory = null]) {
- var params = new SyncbaseDbSetSyncgroupSpecParams();
+ var params = new _SyncbaseDbSetSyncgroupSpecParams();
params.name = name;
params.sgName = sgName;
params.spec = spec;
params.version = version;
return _proxyImpl.sendMessageWithRequestId(
params,
- kSyncbase_dbSetSyncgroupSpec_name,
+ _Syncbase_dbSetSyncgroupSpecName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
dynamic dbGetSyncgroupMembers(String name,String sgName,[Function responseFactory = null]) {
- var params = new SyncbaseDbGetSyncgroupMembersParams();
+ var params = new _SyncbaseDbGetSyncgroupMembersParams();
params.name = name;
params.sgName = sgName;
return _proxyImpl.sendMessageWithRequestId(
params,
- kSyncbase_dbGetSyncgroupMembers_name,
+ _Syncbase_dbGetSyncgroupMembersName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
dynamic tableCreate(String name,Perms perms,[Function responseFactory = null]) {
- var params = new SyncbaseTableCreateParams();
+ var params = new _SyncbaseTableCreateParams();
params.name = name;
params.perms = perms;
return _proxyImpl.sendMessageWithRequestId(
params,
- kSyncbase_tableCreate_name,
+ _Syncbase_tableCreateName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
dynamic tableDestroy(String name,[Function responseFactory = null]) {
- var params = new SyncbaseTableDestroyParams();
+ var params = new _SyncbaseTableDestroyParams();
params.name = name;
return _proxyImpl.sendMessageWithRequestId(
params,
- kSyncbase_tableDestroy_name,
+ _Syncbase_tableDestroyName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
dynamic tableExists(String name,[Function responseFactory = null]) {
- var params = new SyncbaseTableExistsParams();
+ var params = new _SyncbaseTableExistsParams();
params.name = name;
return _proxyImpl.sendMessageWithRequestId(
params,
- kSyncbase_tableExists_name,
+ _Syncbase_tableExistsName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
dynamic tableGetPermissions(String name,[Function responseFactory = null]) {
- var params = new SyncbaseTableGetPermissionsParams();
+ var params = new _SyncbaseTableGetPermissionsParams();
params.name = name;
return _proxyImpl.sendMessageWithRequestId(
params,
- kSyncbase_tableGetPermissions_name,
+ _Syncbase_tableGetPermissionsName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
dynamic tableSetPermissions(String name,Perms perms,[Function responseFactory = null]) {
- var params = new SyncbaseTableSetPermissionsParams();
+ var params = new _SyncbaseTableSetPermissionsParams();
params.name = name;
params.perms = perms;
return _proxyImpl.sendMessageWithRequestId(
params,
- kSyncbase_tableSetPermissions_name,
+ _Syncbase_tableSetPermissionsName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
dynamic tableDeleteRange(String name,List<int> start,List<int> limit,[Function responseFactory = null]) {
- var params = new SyncbaseTableDeleteRangeParams();
+ var params = new _SyncbaseTableDeleteRangeParams();
params.name = name;
params.start = start;
params.limit = limit;
return _proxyImpl.sendMessageWithRequestId(
params,
- kSyncbase_tableDeleteRange_name,
+ _Syncbase_tableDeleteRangeName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
dynamic tableScan(String name,List<int> start,List<int> limit,Object stream,[Function responseFactory = null]) {
- var params = new SyncbaseTableScanParams();
+ var params = new _SyncbaseTableScanParams();
params.name = name;
params.start = start;
params.limit = limit;
params.stream = stream;
return _proxyImpl.sendMessageWithRequestId(
params,
- kSyncbase_tableScan_name,
+ _Syncbase_tableScanName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
dynamic tableGetPrefixPermissions(String name,String key,[Function responseFactory = null]) {
- var params = new SyncbaseTableGetPrefixPermissionsParams();
+ var params = new _SyncbaseTableGetPrefixPermissionsParams();
params.name = name;
params.key = key;
return _proxyImpl.sendMessageWithRequestId(
params,
- kSyncbase_tableGetPrefixPermissions_name,
+ _Syncbase_tableGetPrefixPermissionsName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
dynamic tableSetPrefixPermissions(String name,String prefix,Perms perms,[Function responseFactory = null]) {
- var params = new SyncbaseTableSetPrefixPermissionsParams();
+ var params = new _SyncbaseTableSetPrefixPermissionsParams();
params.name = name;
params.prefix = prefix;
params.perms = perms;
return _proxyImpl.sendMessageWithRequestId(
params,
- kSyncbase_tableSetPrefixPermissions_name,
+ _Syncbase_tableSetPrefixPermissionsName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
dynamic tableDeletePrefixPermissions(String name,String prefix,[Function responseFactory = null]) {
- var params = new SyncbaseTableDeletePrefixPermissionsParams();
+ var params = new _SyncbaseTableDeletePrefixPermissionsParams();
params.name = name;
params.prefix = prefix;
return _proxyImpl.sendMessageWithRequestId(
params,
- kSyncbase_tableDeletePrefixPermissions_name,
+ _Syncbase_tableDeletePrefixPermissionsName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
dynamic rowExists(String name,[Function responseFactory = null]) {
- var params = new SyncbaseRowExistsParams();
+ var params = new _SyncbaseRowExistsParams();
params.name = name;
return _proxyImpl.sendMessageWithRequestId(
params,
- kSyncbase_rowExists_name,
+ _Syncbase_rowExistsName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
dynamic rowGet(String name,[Function responseFactory = null]) {
- var params = new SyncbaseRowGetParams();
+ var params = new _SyncbaseRowGetParams();
params.name = name;
return _proxyImpl.sendMessageWithRequestId(
params,
- kSyncbase_rowGet_name,
+ _Syncbase_rowGetName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
dynamic rowPut(String name,List<int> value,[Function responseFactory = null]) {
- var params = new SyncbaseRowPutParams();
+ var params = new _SyncbaseRowPutParams();
params.name = name;
params.value = value;
return _proxyImpl.sendMessageWithRequestId(
params,
- kSyncbase_rowPut_name,
+ _Syncbase_rowPutName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
dynamic rowDelete(String name,[Function responseFactory = null]) {
- var params = new SyncbaseRowDeleteParams();
+ var params = new _SyncbaseRowDeleteParams();
params.name = name;
return _proxyImpl.sendMessageWithRequestId(
params,
- kSyncbase_rowDelete_name,
+ _Syncbase_rowDeleteName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
@@ -10290,25 +10272,24 @@
class SyncbaseProxy implements bindings.ProxyBase {
final bindings.Proxy impl;
Syncbase ptr;
- final String name = SyncbaseName;
- SyncbaseProxy(SyncbaseProxyImpl proxyImpl) :
+ SyncbaseProxy(_SyncbaseProxyImpl proxyImpl) :
impl = proxyImpl,
ptr = new _SyncbaseProxyCalls(proxyImpl);
SyncbaseProxy.fromEndpoint(
core.MojoMessagePipeEndpoint endpoint) :
- impl = new SyncbaseProxyImpl.fromEndpoint(endpoint) {
+ impl = new _SyncbaseProxyImpl.fromEndpoint(endpoint) {
ptr = new _SyncbaseProxyCalls(impl);
}
SyncbaseProxy.fromHandle(core.MojoHandle handle) :
- impl = new SyncbaseProxyImpl.fromHandle(handle) {
+ impl = new _SyncbaseProxyImpl.fromHandle(handle) {
ptr = new _SyncbaseProxyCalls(impl);
}
SyncbaseProxy.unbound() :
- impl = new SyncbaseProxyImpl.unbound() {
+ impl = new _SyncbaseProxyImpl.unbound() {
ptr = new _SyncbaseProxyCalls(impl);
}
@@ -10325,6 +10306,8 @@
return new SyncbaseProxy.fromEndpoint(endpoint);
}
+ String get serviceName => Syncbase.serviceName;
+
Future close({bool immediate: false}) => impl.close(immediate: immediate);
Future responseOrError(Future f) => impl.responseOrError(f);
@@ -10363,8 +10346,6 @@
return new SyncbaseStub.fromEndpoint(endpoint);
}
- static const String name = SyncbaseName;
-
SyncbaseServiceGetPermissionsResponseParams _SyncbaseServiceGetPermissionsResponseParamsFactory(Error err, Perms perms, String version) {
var mojo_factory_result = new SyncbaseServiceGetPermissionsResponseParams();
@@ -10618,8 +10599,8 @@
}
assert(_impl != null);
switch (message.header.type) {
- case kSyncbase_serviceGetPermissions_name:
- var params = SyncbaseServiceGetPermissionsParams.deserialize(
+ case _Syncbase_serviceGetPermissionsName:
+ var params = _SyncbaseServiceGetPermissionsParams.deserialize(
message.payload);
var response = _impl.serviceGetPermissions(_SyncbaseServiceGetPermissionsResponseParamsFactory);
if (response is Future) {
@@ -10627,7 +10608,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_serviceGetPermissions_name,
+ _Syncbase_serviceGetPermissionsName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -10635,13 +10616,13 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_serviceGetPermissions_name,
+ _Syncbase_serviceGetPermissionsName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kSyncbase_serviceSetPermissions_name:
- var params = SyncbaseServiceSetPermissionsParams.deserialize(
+ case _Syncbase_serviceSetPermissionsName:
+ var params = _SyncbaseServiceSetPermissionsParams.deserialize(
message.payload);
var response = _impl.serviceSetPermissions(params.perms,params.version,_SyncbaseServiceSetPermissionsResponseParamsFactory);
if (response is Future) {
@@ -10649,7 +10630,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_serviceSetPermissions_name,
+ _Syncbase_serviceSetPermissionsName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -10657,13 +10638,13 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_serviceSetPermissions_name,
+ _Syncbase_serviceSetPermissionsName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kSyncbase_serviceListApps_name:
- var params = SyncbaseServiceListAppsParams.deserialize(
+ case _Syncbase_serviceListAppsName:
+ var params = _SyncbaseServiceListAppsParams.deserialize(
message.payload);
var response = _impl.serviceListApps(_SyncbaseServiceListAppsResponseParamsFactory);
if (response is Future) {
@@ -10671,7 +10652,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_serviceListApps_name,
+ _Syncbase_serviceListAppsName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -10679,13 +10660,13 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_serviceListApps_name,
+ _Syncbase_serviceListAppsName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kSyncbase_appCreate_name:
- var params = SyncbaseAppCreateParams.deserialize(
+ case _Syncbase_appCreateName:
+ var params = _SyncbaseAppCreateParams.deserialize(
message.payload);
var response = _impl.appCreate(params.name,params.perms,_SyncbaseAppCreateResponseParamsFactory);
if (response is Future) {
@@ -10693,7 +10674,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_appCreate_name,
+ _Syncbase_appCreateName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -10701,13 +10682,13 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_appCreate_name,
+ _Syncbase_appCreateName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kSyncbase_appDestroy_name:
- var params = SyncbaseAppDestroyParams.deserialize(
+ case _Syncbase_appDestroyName:
+ var params = _SyncbaseAppDestroyParams.deserialize(
message.payload);
var response = _impl.appDestroy(params.name,_SyncbaseAppDestroyResponseParamsFactory);
if (response is Future) {
@@ -10715,7 +10696,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_appDestroy_name,
+ _Syncbase_appDestroyName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -10723,13 +10704,13 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_appDestroy_name,
+ _Syncbase_appDestroyName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kSyncbase_appExists_name:
- var params = SyncbaseAppExistsParams.deserialize(
+ case _Syncbase_appExistsName:
+ var params = _SyncbaseAppExistsParams.deserialize(
message.payload);
var response = _impl.appExists(params.name,_SyncbaseAppExistsResponseParamsFactory);
if (response is Future) {
@@ -10737,7 +10718,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_appExists_name,
+ _Syncbase_appExistsName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -10745,13 +10726,13 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_appExists_name,
+ _Syncbase_appExistsName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kSyncbase_appGetPermissions_name:
- var params = SyncbaseAppGetPermissionsParams.deserialize(
+ case _Syncbase_appGetPermissionsName:
+ var params = _SyncbaseAppGetPermissionsParams.deserialize(
message.payload);
var response = _impl.appGetPermissions(params.name,_SyncbaseAppGetPermissionsResponseParamsFactory);
if (response is Future) {
@@ -10759,7 +10740,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_appGetPermissions_name,
+ _Syncbase_appGetPermissionsName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -10767,13 +10748,13 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_appGetPermissions_name,
+ _Syncbase_appGetPermissionsName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kSyncbase_appListDatabases_name:
- var params = SyncbaseAppListDatabasesParams.deserialize(
+ case _Syncbase_appListDatabasesName:
+ var params = _SyncbaseAppListDatabasesParams.deserialize(
message.payload);
var response = _impl.appListDatabases(params.name,_SyncbaseAppListDatabasesResponseParamsFactory);
if (response is Future) {
@@ -10781,7 +10762,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_appListDatabases_name,
+ _Syncbase_appListDatabasesName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -10789,13 +10770,13 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_appListDatabases_name,
+ _Syncbase_appListDatabasesName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kSyncbase_appSetPermissions_name:
- var params = SyncbaseAppSetPermissionsParams.deserialize(
+ case _Syncbase_appSetPermissionsName:
+ var params = _SyncbaseAppSetPermissionsParams.deserialize(
message.payload);
var response = _impl.appSetPermissions(params.name,params.perms,params.version,_SyncbaseAppSetPermissionsResponseParamsFactory);
if (response is Future) {
@@ -10803,7 +10784,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_appSetPermissions_name,
+ _Syncbase_appSetPermissionsName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -10811,13 +10792,13 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_appSetPermissions_name,
+ _Syncbase_appSetPermissionsName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kSyncbase_dbCreate_name:
- var params = SyncbaseDbCreateParams.deserialize(
+ case _Syncbase_dbCreateName:
+ var params = _SyncbaseDbCreateParams.deserialize(
message.payload);
var response = _impl.dbCreate(params.name,params.perms,_SyncbaseDbCreateResponseParamsFactory);
if (response is Future) {
@@ -10825,7 +10806,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_dbCreate_name,
+ _Syncbase_dbCreateName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -10833,13 +10814,13 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_dbCreate_name,
+ _Syncbase_dbCreateName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kSyncbase_dbDestroy_name:
- var params = SyncbaseDbDestroyParams.deserialize(
+ case _Syncbase_dbDestroyName:
+ var params = _SyncbaseDbDestroyParams.deserialize(
message.payload);
var response = _impl.dbDestroy(params.name,_SyncbaseDbDestroyResponseParamsFactory);
if (response is Future) {
@@ -10847,7 +10828,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_dbDestroy_name,
+ _Syncbase_dbDestroyName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -10855,13 +10836,13 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_dbDestroy_name,
+ _Syncbase_dbDestroyName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kSyncbase_dbExists_name:
- var params = SyncbaseDbExistsParams.deserialize(
+ case _Syncbase_dbExistsName:
+ var params = _SyncbaseDbExistsParams.deserialize(
message.payload);
var response = _impl.dbExists(params.name,_SyncbaseDbExistsResponseParamsFactory);
if (response is Future) {
@@ -10869,7 +10850,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_dbExists_name,
+ _Syncbase_dbExistsName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -10877,13 +10858,13 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_dbExists_name,
+ _Syncbase_dbExistsName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kSyncbase_dbExec_name:
- var params = SyncbaseDbExecParams.deserialize(
+ case _Syncbase_dbExecName:
+ var params = _SyncbaseDbExecParams.deserialize(
message.payload);
var response = _impl.dbExec(params.name,params.query,params.stream,_SyncbaseDbExecResponseParamsFactory);
if (response is Future) {
@@ -10891,7 +10872,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_dbExec_name,
+ _Syncbase_dbExecName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -10899,13 +10880,13 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_dbExec_name,
+ _Syncbase_dbExecName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kSyncbase_dbBeginBatch_name:
- var params = SyncbaseDbBeginBatchParams.deserialize(
+ case _Syncbase_dbBeginBatchName:
+ var params = _SyncbaseDbBeginBatchParams.deserialize(
message.payload);
var response = _impl.dbBeginBatch(params.name,params.bo,_SyncbaseDbBeginBatchResponseParamsFactory);
if (response is Future) {
@@ -10913,7 +10894,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_dbBeginBatch_name,
+ _Syncbase_dbBeginBatchName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -10921,13 +10902,13 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_dbBeginBatch_name,
+ _Syncbase_dbBeginBatchName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kSyncbase_dbCommit_name:
- var params = SyncbaseDbCommitParams.deserialize(
+ case _Syncbase_dbCommitName:
+ var params = _SyncbaseDbCommitParams.deserialize(
message.payload);
var response = _impl.dbCommit(params.name,_SyncbaseDbCommitResponseParamsFactory);
if (response is Future) {
@@ -10935,7 +10916,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_dbCommit_name,
+ _Syncbase_dbCommitName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -10943,13 +10924,13 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_dbCommit_name,
+ _Syncbase_dbCommitName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kSyncbase_dbAbort_name:
- var params = SyncbaseDbAbortParams.deserialize(
+ case _Syncbase_dbAbortName:
+ var params = _SyncbaseDbAbortParams.deserialize(
message.payload);
var response = _impl.dbAbort(params.name,_SyncbaseDbAbortResponseParamsFactory);
if (response is Future) {
@@ -10957,7 +10938,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_dbAbort_name,
+ _Syncbase_dbAbortName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -10965,13 +10946,13 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_dbAbort_name,
+ _Syncbase_dbAbortName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kSyncbase_dbGetPermissions_name:
- var params = SyncbaseDbGetPermissionsParams.deserialize(
+ case _Syncbase_dbGetPermissionsName:
+ var params = _SyncbaseDbGetPermissionsParams.deserialize(
message.payload);
var response = _impl.dbGetPermissions(params.name,_SyncbaseDbGetPermissionsResponseParamsFactory);
if (response is Future) {
@@ -10979,7 +10960,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_dbGetPermissions_name,
+ _Syncbase_dbGetPermissionsName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -10987,13 +10968,13 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_dbGetPermissions_name,
+ _Syncbase_dbGetPermissionsName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kSyncbase_dbSetPermissions_name:
- var params = SyncbaseDbSetPermissionsParams.deserialize(
+ case _Syncbase_dbSetPermissionsName:
+ var params = _SyncbaseDbSetPermissionsParams.deserialize(
message.payload);
var response = _impl.dbSetPermissions(params.name,params.perms,params.version,_SyncbaseDbSetPermissionsResponseParamsFactory);
if (response is Future) {
@@ -11001,7 +10982,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_dbSetPermissions_name,
+ _Syncbase_dbSetPermissionsName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -11009,13 +10990,13 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_dbSetPermissions_name,
+ _Syncbase_dbSetPermissionsName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kSyncbase_dbWatchGlob_name:
- var params = SyncbaseDbWatchGlobParams.deserialize(
+ case _Syncbase_dbWatchGlobName:
+ var params = _SyncbaseDbWatchGlobParams.deserialize(
message.payload);
var response = _impl.dbWatchGlob(params.name,params.req,params.stream,_SyncbaseDbWatchGlobResponseParamsFactory);
if (response is Future) {
@@ -11023,7 +11004,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_dbWatchGlob_name,
+ _Syncbase_dbWatchGlobName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -11031,13 +11012,13 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_dbWatchGlob_name,
+ _Syncbase_dbWatchGlobName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kSyncbase_dbGetResumeMarker_name:
- var params = SyncbaseDbGetResumeMarkerParams.deserialize(
+ case _Syncbase_dbGetResumeMarkerName:
+ var params = _SyncbaseDbGetResumeMarkerParams.deserialize(
message.payload);
var response = _impl.dbGetResumeMarker(params.name,_SyncbaseDbGetResumeMarkerResponseParamsFactory);
if (response is Future) {
@@ -11045,7 +11026,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_dbGetResumeMarker_name,
+ _Syncbase_dbGetResumeMarkerName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -11053,13 +11034,13 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_dbGetResumeMarker_name,
+ _Syncbase_dbGetResumeMarkerName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kSyncbase_dbListTables_name:
- var params = SyncbaseDbListTablesParams.deserialize(
+ case _Syncbase_dbListTablesName:
+ var params = _SyncbaseDbListTablesParams.deserialize(
message.payload);
var response = _impl.dbListTables(params.name,_SyncbaseDbListTablesResponseParamsFactory);
if (response is Future) {
@@ -11067,7 +11048,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_dbListTables_name,
+ _Syncbase_dbListTablesName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -11075,13 +11056,13 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_dbListTables_name,
+ _Syncbase_dbListTablesName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kSyncbase_dbGetSyncgroupNames_name:
- var params = SyncbaseDbGetSyncgroupNamesParams.deserialize(
+ case _Syncbase_dbGetSyncgroupNamesName:
+ var params = _SyncbaseDbGetSyncgroupNamesParams.deserialize(
message.payload);
var response = _impl.dbGetSyncgroupNames(params.name,_SyncbaseDbGetSyncgroupNamesResponseParamsFactory);
if (response is Future) {
@@ -11089,7 +11070,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_dbGetSyncgroupNames_name,
+ _Syncbase_dbGetSyncgroupNamesName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -11097,13 +11078,13 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_dbGetSyncgroupNames_name,
+ _Syncbase_dbGetSyncgroupNamesName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kSyncbase_dbCreateSyncgroup_name:
- var params = SyncbaseDbCreateSyncgroupParams.deserialize(
+ case _Syncbase_dbCreateSyncgroupName:
+ var params = _SyncbaseDbCreateSyncgroupParams.deserialize(
message.payload);
var response = _impl.dbCreateSyncgroup(params.name,params.sgName,params.spec,params.myInfo,_SyncbaseDbCreateSyncgroupResponseParamsFactory);
if (response is Future) {
@@ -11111,7 +11092,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_dbCreateSyncgroup_name,
+ _Syncbase_dbCreateSyncgroupName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -11119,13 +11100,13 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_dbCreateSyncgroup_name,
+ _Syncbase_dbCreateSyncgroupName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kSyncbase_dbJoinSyncgroup_name:
- var params = SyncbaseDbJoinSyncgroupParams.deserialize(
+ case _Syncbase_dbJoinSyncgroupName:
+ var params = _SyncbaseDbJoinSyncgroupParams.deserialize(
message.payload);
var response = _impl.dbJoinSyncgroup(params.name,params.sgName,params.myInfo,_SyncbaseDbJoinSyncgroupResponseParamsFactory);
if (response is Future) {
@@ -11133,7 +11114,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_dbJoinSyncgroup_name,
+ _Syncbase_dbJoinSyncgroupName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -11141,13 +11122,13 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_dbJoinSyncgroup_name,
+ _Syncbase_dbJoinSyncgroupName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kSyncbase_dbLeaveSyncgroup_name:
- var params = SyncbaseDbLeaveSyncgroupParams.deserialize(
+ case _Syncbase_dbLeaveSyncgroupName:
+ var params = _SyncbaseDbLeaveSyncgroupParams.deserialize(
message.payload);
var response = _impl.dbLeaveSyncgroup(params.name,params.sgName,_SyncbaseDbLeaveSyncgroupResponseParamsFactory);
if (response is Future) {
@@ -11155,7 +11136,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_dbLeaveSyncgroup_name,
+ _Syncbase_dbLeaveSyncgroupName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -11163,13 +11144,13 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_dbLeaveSyncgroup_name,
+ _Syncbase_dbLeaveSyncgroupName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kSyncbase_dbDestroySyncgroup_name:
- var params = SyncbaseDbDestroySyncgroupParams.deserialize(
+ case _Syncbase_dbDestroySyncgroupName:
+ var params = _SyncbaseDbDestroySyncgroupParams.deserialize(
message.payload);
var response = _impl.dbDestroySyncgroup(params.name,params.sgName,_SyncbaseDbDestroySyncgroupResponseParamsFactory);
if (response is Future) {
@@ -11177,7 +11158,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_dbDestroySyncgroup_name,
+ _Syncbase_dbDestroySyncgroupName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -11185,13 +11166,13 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_dbDestroySyncgroup_name,
+ _Syncbase_dbDestroySyncgroupName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kSyncbase_dbEjectFromSyncgroup_name:
- var params = SyncbaseDbEjectFromSyncgroupParams.deserialize(
+ case _Syncbase_dbEjectFromSyncgroupName:
+ var params = _SyncbaseDbEjectFromSyncgroupParams.deserialize(
message.payload);
var response = _impl.dbEjectFromSyncgroup(params.name,params.sgName,params.member,_SyncbaseDbEjectFromSyncgroupResponseParamsFactory);
if (response is Future) {
@@ -11199,7 +11180,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_dbEjectFromSyncgroup_name,
+ _Syncbase_dbEjectFromSyncgroupName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -11207,13 +11188,13 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_dbEjectFromSyncgroup_name,
+ _Syncbase_dbEjectFromSyncgroupName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kSyncbase_dbGetSyncgroupSpec_name:
- var params = SyncbaseDbGetSyncgroupSpecParams.deserialize(
+ case _Syncbase_dbGetSyncgroupSpecName:
+ var params = _SyncbaseDbGetSyncgroupSpecParams.deserialize(
message.payload);
var response = _impl.dbGetSyncgroupSpec(params.name,params.sgName,_SyncbaseDbGetSyncgroupSpecResponseParamsFactory);
if (response is Future) {
@@ -11221,7 +11202,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_dbGetSyncgroupSpec_name,
+ _Syncbase_dbGetSyncgroupSpecName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -11229,13 +11210,13 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_dbGetSyncgroupSpec_name,
+ _Syncbase_dbGetSyncgroupSpecName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kSyncbase_dbSetSyncgroupSpec_name:
- var params = SyncbaseDbSetSyncgroupSpecParams.deserialize(
+ case _Syncbase_dbSetSyncgroupSpecName:
+ var params = _SyncbaseDbSetSyncgroupSpecParams.deserialize(
message.payload);
var response = _impl.dbSetSyncgroupSpec(params.name,params.sgName,params.spec,params.version,_SyncbaseDbSetSyncgroupSpecResponseParamsFactory);
if (response is Future) {
@@ -11243,7 +11224,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_dbSetSyncgroupSpec_name,
+ _Syncbase_dbSetSyncgroupSpecName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -11251,13 +11232,13 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_dbSetSyncgroupSpec_name,
+ _Syncbase_dbSetSyncgroupSpecName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kSyncbase_dbGetSyncgroupMembers_name:
- var params = SyncbaseDbGetSyncgroupMembersParams.deserialize(
+ case _Syncbase_dbGetSyncgroupMembersName:
+ var params = _SyncbaseDbGetSyncgroupMembersParams.deserialize(
message.payload);
var response = _impl.dbGetSyncgroupMembers(params.name,params.sgName,_SyncbaseDbGetSyncgroupMembersResponseParamsFactory);
if (response is Future) {
@@ -11265,7 +11246,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_dbGetSyncgroupMembers_name,
+ _Syncbase_dbGetSyncgroupMembersName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -11273,13 +11254,13 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_dbGetSyncgroupMembers_name,
+ _Syncbase_dbGetSyncgroupMembersName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kSyncbase_tableCreate_name:
- var params = SyncbaseTableCreateParams.deserialize(
+ case _Syncbase_tableCreateName:
+ var params = _SyncbaseTableCreateParams.deserialize(
message.payload);
var response = _impl.tableCreate(params.name,params.perms,_SyncbaseTableCreateResponseParamsFactory);
if (response is Future) {
@@ -11287,7 +11268,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_tableCreate_name,
+ _Syncbase_tableCreateName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -11295,13 +11276,13 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_tableCreate_name,
+ _Syncbase_tableCreateName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kSyncbase_tableDestroy_name:
- var params = SyncbaseTableDestroyParams.deserialize(
+ case _Syncbase_tableDestroyName:
+ var params = _SyncbaseTableDestroyParams.deserialize(
message.payload);
var response = _impl.tableDestroy(params.name,_SyncbaseTableDestroyResponseParamsFactory);
if (response is Future) {
@@ -11309,7 +11290,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_tableDestroy_name,
+ _Syncbase_tableDestroyName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -11317,13 +11298,13 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_tableDestroy_name,
+ _Syncbase_tableDestroyName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kSyncbase_tableExists_name:
- var params = SyncbaseTableExistsParams.deserialize(
+ case _Syncbase_tableExistsName:
+ var params = _SyncbaseTableExistsParams.deserialize(
message.payload);
var response = _impl.tableExists(params.name,_SyncbaseTableExistsResponseParamsFactory);
if (response is Future) {
@@ -11331,7 +11312,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_tableExists_name,
+ _Syncbase_tableExistsName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -11339,13 +11320,13 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_tableExists_name,
+ _Syncbase_tableExistsName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kSyncbase_tableGetPermissions_name:
- var params = SyncbaseTableGetPermissionsParams.deserialize(
+ case _Syncbase_tableGetPermissionsName:
+ var params = _SyncbaseTableGetPermissionsParams.deserialize(
message.payload);
var response = _impl.tableGetPermissions(params.name,_SyncbaseTableGetPermissionsResponseParamsFactory);
if (response is Future) {
@@ -11353,7 +11334,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_tableGetPermissions_name,
+ _Syncbase_tableGetPermissionsName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -11361,13 +11342,13 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_tableGetPermissions_name,
+ _Syncbase_tableGetPermissionsName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kSyncbase_tableSetPermissions_name:
- var params = SyncbaseTableSetPermissionsParams.deserialize(
+ case _Syncbase_tableSetPermissionsName:
+ var params = _SyncbaseTableSetPermissionsParams.deserialize(
message.payload);
var response = _impl.tableSetPermissions(params.name,params.perms,_SyncbaseTableSetPermissionsResponseParamsFactory);
if (response is Future) {
@@ -11375,7 +11356,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_tableSetPermissions_name,
+ _Syncbase_tableSetPermissionsName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -11383,13 +11364,13 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_tableSetPermissions_name,
+ _Syncbase_tableSetPermissionsName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kSyncbase_tableDeleteRange_name:
- var params = SyncbaseTableDeleteRangeParams.deserialize(
+ case _Syncbase_tableDeleteRangeName:
+ var params = _SyncbaseTableDeleteRangeParams.deserialize(
message.payload);
var response = _impl.tableDeleteRange(params.name,params.start,params.limit,_SyncbaseTableDeleteRangeResponseParamsFactory);
if (response is Future) {
@@ -11397,7 +11378,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_tableDeleteRange_name,
+ _Syncbase_tableDeleteRangeName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -11405,13 +11386,13 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_tableDeleteRange_name,
+ _Syncbase_tableDeleteRangeName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kSyncbase_tableScan_name:
- var params = SyncbaseTableScanParams.deserialize(
+ case _Syncbase_tableScanName:
+ var params = _SyncbaseTableScanParams.deserialize(
message.payload);
var response = _impl.tableScan(params.name,params.start,params.limit,params.stream,_SyncbaseTableScanResponseParamsFactory);
if (response is Future) {
@@ -11419,7 +11400,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_tableScan_name,
+ _Syncbase_tableScanName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -11427,13 +11408,13 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_tableScan_name,
+ _Syncbase_tableScanName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kSyncbase_tableGetPrefixPermissions_name:
- var params = SyncbaseTableGetPrefixPermissionsParams.deserialize(
+ case _Syncbase_tableGetPrefixPermissionsName:
+ var params = _SyncbaseTableGetPrefixPermissionsParams.deserialize(
message.payload);
var response = _impl.tableGetPrefixPermissions(params.name,params.key,_SyncbaseTableGetPrefixPermissionsResponseParamsFactory);
if (response is Future) {
@@ -11441,7 +11422,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_tableGetPrefixPermissions_name,
+ _Syncbase_tableGetPrefixPermissionsName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -11449,13 +11430,13 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_tableGetPrefixPermissions_name,
+ _Syncbase_tableGetPrefixPermissionsName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kSyncbase_tableSetPrefixPermissions_name:
- var params = SyncbaseTableSetPrefixPermissionsParams.deserialize(
+ case _Syncbase_tableSetPrefixPermissionsName:
+ var params = _SyncbaseTableSetPrefixPermissionsParams.deserialize(
message.payload);
var response = _impl.tableSetPrefixPermissions(params.name,params.prefix,params.perms,_SyncbaseTableSetPrefixPermissionsResponseParamsFactory);
if (response is Future) {
@@ -11463,7 +11444,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_tableSetPrefixPermissions_name,
+ _Syncbase_tableSetPrefixPermissionsName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -11471,13 +11452,13 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_tableSetPrefixPermissions_name,
+ _Syncbase_tableSetPrefixPermissionsName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kSyncbase_tableDeletePrefixPermissions_name:
- var params = SyncbaseTableDeletePrefixPermissionsParams.deserialize(
+ case _Syncbase_tableDeletePrefixPermissionsName:
+ var params = _SyncbaseTableDeletePrefixPermissionsParams.deserialize(
message.payload);
var response = _impl.tableDeletePrefixPermissions(params.name,params.prefix,_SyncbaseTableDeletePrefixPermissionsResponseParamsFactory);
if (response is Future) {
@@ -11485,7 +11466,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_tableDeletePrefixPermissions_name,
+ _Syncbase_tableDeletePrefixPermissionsName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -11493,13 +11474,13 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_tableDeletePrefixPermissions_name,
+ _Syncbase_tableDeletePrefixPermissionsName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kSyncbase_rowExists_name:
- var params = SyncbaseRowExistsParams.deserialize(
+ case _Syncbase_rowExistsName:
+ var params = _SyncbaseRowExistsParams.deserialize(
message.payload);
var response = _impl.rowExists(params.name,_SyncbaseRowExistsResponseParamsFactory);
if (response is Future) {
@@ -11507,7 +11488,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_rowExists_name,
+ _Syncbase_rowExistsName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -11515,13 +11496,13 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_rowExists_name,
+ _Syncbase_rowExistsName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kSyncbase_rowGet_name:
- var params = SyncbaseRowGetParams.deserialize(
+ case _Syncbase_rowGetName:
+ var params = _SyncbaseRowGetParams.deserialize(
message.payload);
var response = _impl.rowGet(params.name,_SyncbaseRowGetResponseParamsFactory);
if (response is Future) {
@@ -11529,7 +11510,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_rowGet_name,
+ _Syncbase_rowGetName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -11537,13 +11518,13 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_rowGet_name,
+ _Syncbase_rowGetName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kSyncbase_rowPut_name:
- var params = SyncbaseRowPutParams.deserialize(
+ case _Syncbase_rowPutName:
+ var params = _SyncbaseRowPutParams.deserialize(
message.payload);
var response = _impl.rowPut(params.name,params.value,_SyncbaseRowPutResponseParamsFactory);
if (response is Future) {
@@ -11551,7 +11532,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_rowPut_name,
+ _Syncbase_rowPutName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -11559,13 +11540,13 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_rowPut_name,
+ _Syncbase_rowPutName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kSyncbase_rowDelete_name:
- var params = SyncbaseRowDeleteParams.deserialize(
+ case _Syncbase_rowDeleteName:
+ var params = _SyncbaseRowDeleteParams.deserialize(
message.payload);
var response = _impl.rowDelete(params.name,_SyncbaseRowDeleteResponseParamsFactory);
if (response is Future) {
@@ -11573,7 +11554,7 @@
if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_rowDelete_name,
+ _Syncbase_rowDeleteName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -11581,7 +11562,7 @@
} else if (response != null) {
return buildResponseWithId(
response,
- kSyncbase_rowDelete_name,
+ _Syncbase_rowDeleteName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
diff --git a/pubspec.yaml b/pubspec.yaml
index e0cc87b..1db13ae 100644
--- a/pubspec.yaml
+++ b/pubspec.yaml
@@ -4,7 +4,7 @@
name: syncbase
version: 0.0.27
dependencies:
- mojo_sdk: 0.2.7
+ mojo_sdk: 0.2.11
dev_dependencies:
dart_style: any
test: any
diff --git a/test/integration/syncbase_test.dart b/test/integration/syncbase_test.dart
index ac10c73..e26c2d5 100755
--- a/test/integration/syncbase_test.dart
+++ b/test/integration/syncbase_test.dart
@@ -34,6 +34,7 @@
app.resetConnections();
});
+
// Run imported tests.
runAppTests(c);
runDatabaseTests(c);
@@ -42,10 +43,7 @@
runTableTests(c);
runRowTests(c);
- // Append a final test to terminate shell connection.
- // TODO(nlacasse): Remove this once package 'test' supports a global tearDown
- // callback. See https://github.com/dart-lang/test/issues/18.
- test('terminate shell connection', () async {
+ tearDownAll(() async {
await c.close();
// TODO(aghassemi): mojo_test does not exit gracefully when
