TBR: js.syncbase: syncbase: s/yncGroup/yncgroup/
With this change, we establish a convention of treating
"syncgroup" as a single, common (non-proper) noun.
The main motivation for this change was consistency, for
a term that's used widely across our codebase and docs.
Arguments for "Syncgroup" over "SyncGroup" were:
- it's "Syncbase", not "SyncBase"
- we'd probably like to use "syncgroup" rather than
"sync_group" in snake-case text, e.g. in filenames like
"syncgroup_test.go"; using "SyncGroup" for camel-case
text would make these two inconsistent (Nick pointed
this out)
- avoids ambiguity about capitalization at the start of a
sentence vs. inside a sentence ("SyncGroup" vs.
"syncgroup"?)
(Note, I discussed this change with Bindu, Raja, and Nick
before making it.)
I mainly used 'find -exec perl -pi -e' to prepare this
change, plus manual inspection and tweaks. The main
painful part was updating lots of comments in the Syncbase
implementation to use "syncgroup" instead of "Syncgroup"
where that was the intended usage.
MultiPart: 6/11
Change-Id: Ifb53c6d6004759391278daf438dc7032f573326f
diff --git a/src/gen-vdl/v.io/v23/services/syncbase/nosql/index.js b/src/gen-vdl/v.io/v23/services/syncbase/nosql/index.js
index 0003006..c413b8d 100644
--- a/src/gen-vdl/v.io/v23/services/syncbase/nosql/index.js
+++ b/src/gen-vdl/v.io/v23/services/syncbase/nosql/index.js
@@ -51,9 +51,9 @@
var _typeScanOp = new vdl.Type();
var _typeSchemaMetadata = new vdl.Type();
var _typeStoreChange = new vdl.Type();
-var _typeSyncGroupMemberInfo = new vdl.Type();
-var _typeSyncGroupPrefix = new vdl.Type();
-var _typeSyncGroupSpec = new vdl.Type();
+var _typeSyncgroupMemberInfo = new vdl.Type();
+var _typeSyncgroupPrefix = new vdl.Type();
+var _typeSyncgroupSpec = new vdl.Type();
var _typeValue = new vdl.Type();
var _typeValueSelection = new vdl.Type();
_type1.kind = vdl.kind.LIST;
@@ -64,10 +64,10 @@
_type10.elem = _typePrefixPermissions;
_type2.kind = vdl.kind.LIST;
_type2.name = "";
-_type2.elem = _typeSyncGroupPrefix;
+_type2.elem = _typeSyncgroupPrefix;
_type3.kind = vdl.kind.MAP;
_type3.name = "";
-_type3.elem = _typeSyncGroupMemberInfo;
+_type3.elem = _typeSyncgroupMemberInfo;
_type3.key = vdl.types.STRING;
_type4.kind = vdl.kind.LIST;
_type4.name = "";
@@ -146,15 +146,15 @@
_typeStoreChange.kind = vdl.kind.STRUCT;
_typeStoreChange.name = "v.io/v23/services/syncbase/nosql.StoreChange";
_typeStoreChange.fields = [{name: "Value", type: _type4}, {name: "FromSync", type: vdl.types.BOOL}];
-_typeSyncGroupMemberInfo.kind = vdl.kind.STRUCT;
-_typeSyncGroupMemberInfo.name = "v.io/v23/services/syncbase/nosql.SyncGroupMemberInfo";
-_typeSyncGroupMemberInfo.fields = [{name: "SyncPriority", type: vdl.types.BYTE}];
-_typeSyncGroupPrefix.kind = vdl.kind.STRUCT;
-_typeSyncGroupPrefix.name = "v.io/v23/services/syncbase/nosql.SyncGroupPrefix";
-_typeSyncGroupPrefix.fields = [{name: "TableName", type: vdl.types.STRING}, {name: "RowPrefix", type: vdl.types.STRING}];
-_typeSyncGroupSpec.kind = vdl.kind.STRUCT;
-_typeSyncGroupSpec.name = "v.io/v23/services/syncbase/nosql.SyncGroupSpec";
-_typeSyncGroupSpec.fields = [{name: "Description", type: vdl.types.STRING}, {name: "Perms", type: new access.Permissions()._type}, {name: "Prefixes", type: _type2}, {name: "MountTables", type: _type1}, {name: "IsPrivate", type: vdl.types.BOOL}];
+_typeSyncgroupMemberInfo.kind = vdl.kind.STRUCT;
+_typeSyncgroupMemberInfo.name = "v.io/v23/services/syncbase/nosql.SyncgroupMemberInfo";
+_typeSyncgroupMemberInfo.fields = [{name: "SyncPriority", type: vdl.types.BYTE}];
+_typeSyncgroupPrefix.kind = vdl.kind.STRUCT;
+_typeSyncgroupPrefix.name = "v.io/v23/services/syncbase/nosql.SyncgroupPrefix";
+_typeSyncgroupPrefix.fields = [{name: "TableName", type: vdl.types.STRING}, {name: "RowPrefix", type: vdl.types.STRING}];
+_typeSyncgroupSpec.kind = vdl.kind.STRUCT;
+_typeSyncgroupSpec.name = "v.io/v23/services/syncbase/nosql.SyncgroupSpec";
+_typeSyncgroupSpec.fields = [{name: "Description", type: vdl.types.STRING}, {name: "Perms", type: new access.Permissions()._type}, {name: "Prefixes", type: _type2}, {name: "MountTables", type: _type1}, {name: "IsPrivate", type: vdl.types.BOOL}];
_typeValue.kind = vdl.kind.STRUCT;
_typeValue.name = "v.io/v23/services/syncbase/nosql.Value";
_typeValue.fields = [{name: "Bytes", type: _type4}, {name: "WriteTs", type: vdl.types.INT64}];
@@ -191,9 +191,9 @@
_typeScanOp.freeze();
_typeSchemaMetadata.freeze();
_typeStoreChange.freeze();
-_typeSyncGroupMemberInfo.freeze();
-_typeSyncGroupPrefix.freeze();
-_typeSyncGroupSpec.freeze();
+_typeSyncgroupMemberInfo.freeze();
+_typeSyncgroupPrefix.freeze();
+_typeSyncgroupSpec.freeze();
_typeValue.freeze();
_typeValueSelection.freeze();
module.exports.BatchInfo = (vdl.registry.lookupOrCreateConstructor(_typeBatchInfo));
@@ -228,9 +228,9 @@
module.exports.ScanOp = (vdl.registry.lookupOrCreateConstructor(_typeScanOp));
module.exports.SchemaMetadata = (vdl.registry.lookupOrCreateConstructor(_typeSchemaMetadata));
module.exports.StoreChange = (vdl.registry.lookupOrCreateConstructor(_typeStoreChange));
-module.exports.SyncGroupMemberInfo = (vdl.registry.lookupOrCreateConstructor(_typeSyncGroupMemberInfo));
-module.exports.SyncGroupPrefix = (vdl.registry.lookupOrCreateConstructor(_typeSyncGroupPrefix));
-module.exports.SyncGroupSpec = (vdl.registry.lookupOrCreateConstructor(_typeSyncGroupSpec));
+module.exports.SyncgroupMemberInfo = (vdl.registry.lookupOrCreateConstructor(_typeSyncgroupMemberInfo));
+module.exports.SyncgroupPrefix = (vdl.registry.lookupOrCreateConstructor(_typeSyncgroupPrefix));
+module.exports.SyncgroupSpec = (vdl.registry.lookupOrCreateConstructor(_typeSyncgroupSpec));
module.exports.Value = (vdl.registry.lookupOrCreateConstructor(_typeValue));
module.exports.ValueSelection = {
LOCAL: canonicalize.reduce(new (vdl.registry.lookupOrCreateConstructor(_typeValueSelection))('Local', true), _typeValueSelection),
@@ -360,68 +360,68 @@
-function SyncGroupManager(){}
-module.exports.SyncGroupManager = SyncGroupManager;
+function SyncgroupManager(){}
+module.exports.SyncgroupManager = SyncgroupManager;
-SyncGroupManager.prototype.getSyncGroupNames = function(ctx, serverCall) {
- throw new Error('Method GetSyncGroupNames not implemented');
+SyncgroupManager.prototype.getSyncgroupNames = function(ctx, serverCall) {
+ throw new Error('Method GetSyncgroupNames not implemented');
};
-SyncGroupManager.prototype.createSyncGroup = function(ctx, serverCall, sgName, spec, myInfo) {
- throw new Error('Method CreateSyncGroup not implemented');
+SyncgroupManager.prototype.createSyncgroup = function(ctx, serverCall, sgName, spec, myInfo) {
+ throw new Error('Method CreateSyncgroup not implemented');
};
-SyncGroupManager.prototype.joinSyncGroup = function(ctx, serverCall, sgName, myInfo) {
- throw new Error('Method JoinSyncGroup not implemented');
+SyncgroupManager.prototype.joinSyncgroup = function(ctx, serverCall, sgName, myInfo) {
+ throw new Error('Method JoinSyncgroup not implemented');
};
-SyncGroupManager.prototype.leaveSyncGroup = function(ctx, serverCall, sgName) {
- throw new Error('Method LeaveSyncGroup not implemented');
+SyncgroupManager.prototype.leaveSyncgroup = function(ctx, serverCall, sgName) {
+ throw new Error('Method LeaveSyncgroup not implemented');
};
-SyncGroupManager.prototype.destroySyncGroup = function(ctx, serverCall, sgName) {
- throw new Error('Method DestroySyncGroup not implemented');
+SyncgroupManager.prototype.destroySyncgroup = function(ctx, serverCall, sgName) {
+ throw new Error('Method DestroySyncgroup not implemented');
};
-SyncGroupManager.prototype.ejectFromSyncGroup = function(ctx, serverCall, sgName, member) {
- throw new Error('Method EjectFromSyncGroup not implemented');
+SyncgroupManager.prototype.ejectFromSyncgroup = function(ctx, serverCall, sgName, member) {
+ throw new Error('Method EjectFromSyncgroup not implemented');
};
-SyncGroupManager.prototype.getSyncGroupSpec = function(ctx, serverCall, sgName) {
- throw new Error('Method GetSyncGroupSpec not implemented');
+SyncgroupManager.prototype.getSyncgroupSpec = function(ctx, serverCall, sgName) {
+ throw new Error('Method GetSyncgroupSpec not implemented');
};
-SyncGroupManager.prototype.setSyncGroupSpec = function(ctx, serverCall, sgName, spec, version) {
- throw new Error('Method SetSyncGroupSpec not implemented');
+SyncgroupManager.prototype.setSyncgroupSpec = function(ctx, serverCall, sgName, spec, version) {
+ throw new Error('Method SetSyncgroupSpec not implemented');
};
-SyncGroupManager.prototype.getSyncGroupMembers = function(ctx, serverCall, sgName) {
- throw new Error('Method GetSyncGroupMembers not implemented');
+SyncgroupManager.prototype.getSyncgroupMembers = function(ctx, serverCall, sgName) {
+ throw new Error('Method GetSyncgroupMembers not implemented');
};
-SyncGroupManager.prototype._serviceDescription = {
- name: 'SyncGroupManager',
+SyncgroupManager.prototype._serviceDescription = {
+ name: 'SyncgroupManager',
pkgPath: 'v.io/v23/services/syncbase/nosql',
- doc: "// SyncGroupManager is the interface for SyncGroup operations.\n// TODO(hpucha): Add blessings to create/join and add a refresh method.",
+ doc: "// SyncgroupManager is the interface for Syncgroup operations.\n// TODO(hpucha): Add blessings to create/join and add a refresh method.",
embeds: [],
methods: [
{
- name: 'GetSyncGroupNames',
- doc: "// GetSyncGroupNames returns the global names of all SyncGroups attached to\n// this database.",
+ name: 'GetSyncgroupNames',
+ doc: "// GetSyncgroupNames returns the global names of all Syncgroups attached to\n// this database.",
inArgs: [],
outArgs: [{
name: '',
@@ -436,8 +436,8 @@
{
- name: 'CreateSyncGroup',
- doc: "// CreateSyncGroup creates a new SyncGroup with the given spec.\n//\n// Requires: Client must have at least Read access on the Database; prefix ACL\n// must exist at each SyncGroup prefix; Client must have at least Read access\n// on each of these prefix ACLs.",
+ name: 'CreateSyncgroup',
+ doc: "// CreateSyncgroup creates a new Syncgroup with the given spec.\n//\n// Requires: Client must have at least Read access on the Database; prefix ACL\n// must exist at each Syncgroup prefix; Client must have at least Read access\n// on each of these prefix ACLs.",
inArgs: [{
name: 'sgName',
doc: "",
@@ -446,12 +446,12 @@
{
name: 'spec',
doc: "",
- type: _typeSyncGroupSpec
+ type: _typeSyncgroupSpec
},
{
name: 'myInfo',
doc: "",
- type: _typeSyncGroupMemberInfo
+ type: _typeSyncgroupMemberInfo
},
],
outArgs: [],
@@ -462,8 +462,8 @@
{
- name: 'JoinSyncGroup',
- doc: "// JoinSyncGroup joins the SyncGroup.\n//\n// Requires: Client must have at least Read access on the Database and on the\n// SyncGroup ACL.",
+ name: 'JoinSyncgroup',
+ doc: "// JoinSyncgroup joins the Syncgroup.\n//\n// Requires: Client must have at least Read access on the Database and on the\n// Syncgroup ACL.",
inArgs: [{
name: 'sgName',
doc: "",
@@ -472,13 +472,13 @@
{
name: 'myInfo',
doc: "",
- type: _typeSyncGroupMemberInfo
+ type: _typeSyncgroupMemberInfo
},
],
outArgs: [{
name: 'spec',
doc: "",
- type: _typeSyncGroupSpec
+ type: _typeSyncgroupSpec
},
],
inStream: null,
@@ -488,8 +488,8 @@
{
- name: 'LeaveSyncGroup',
- doc: "// LeaveSyncGroup leaves the SyncGroup. Previously synced data will continue\n// to be available.\n//\n// Requires: Client must have at least Read access on the Database.",
+ name: 'LeaveSyncgroup',
+ doc: "// LeaveSyncgroup leaves the Syncgroup. Previously synced data will continue\n// to be available.\n//\n// Requires: Client must have at least Read access on the Database.",
inArgs: [{
name: 'sgName',
doc: "",
@@ -504,8 +504,8 @@
{
- name: 'DestroySyncGroup',
- doc: "// DestroySyncGroup destroys the SyncGroup. Previously synced data will\n// continue to be available to all members.\n//\n// Requires: Client must have at least Read access on the Database, and must\n// have Admin access on the SyncGroup ACL.",
+ name: 'DestroySyncgroup',
+ doc: "// DestroySyncgroup destroys the Syncgroup. Previously synced data will\n// continue to be available to all members.\n//\n// Requires: Client must have at least Read access on the Database, and must\n// have Admin access on the Syncgroup ACL.",
inArgs: [{
name: 'sgName',
doc: "",
@@ -520,8 +520,8 @@
{
- name: 'EjectFromSyncGroup',
- doc: "// EjectFromSyncGroup ejects a member from the SyncGroup. The ejected member\n// will not be able to sync further, but will retain any data it has already\n// synced.\n//\n// Requires: Client must have at least Read access on the Database, and must\n// have Admin access on the SyncGroup ACL.",
+ name: 'EjectFromSyncgroup',
+ doc: "// EjectFromSyncgroup ejects a member from the Syncgroup. The ejected member\n// will not be able to sync further, but will retain any data it has already\n// synced.\n//\n// Requires: Client must have at least Read access on the Database, and must\n// have Admin access on the Syncgroup ACL.",
inArgs: [{
name: 'sgName',
doc: "",
@@ -541,8 +541,8 @@
{
- name: 'GetSyncGroupSpec',
- doc: "// GetSyncGroupSpec gets the SyncGroup spec. version allows for atomic\n// read-modify-write of the spec - see comment for SetSyncGroupSpec.\n//\n// Requires: Client must have at least Read access on the Database and on the\n// SyncGroup ACL.",
+ name: 'GetSyncgroupSpec',
+ doc: "// GetSyncgroupSpec gets the Syncgroup spec. version allows for atomic\n// read-modify-write of the spec - see comment for SetSyncgroupSpec.\n//\n// Requires: Client must have at least Read access on the Database and on the\n// Syncgroup ACL.",
inArgs: [{
name: 'sgName',
doc: "",
@@ -552,7 +552,7 @@
outArgs: [{
name: 'spec',
doc: "",
- type: _typeSyncGroupSpec
+ type: _typeSyncgroupSpec
},
{
name: 'version',
@@ -567,8 +567,8 @@
{
- name: 'SetSyncGroupSpec',
- doc: "// SetSyncGroupSpec sets the SyncGroup spec. version may be either empty or\n// the value from a previous Get. If not empty, Set will only succeed if the\n// current version matches the specified one.\n//\n// Requires: Client must have at least Read access on the Database, and must\n// have Admin access on the SyncGroup ACL.",
+ name: 'SetSyncgroupSpec',
+ doc: "// SetSyncgroupSpec sets the Syncgroup spec. version may be either empty or\n// the value from a previous Get. If not empty, Set will only succeed if the\n// current version matches the specified one.\n//\n// Requires: Client must have at least Read access on the Database, and must\n// have Admin access on the Syncgroup ACL.",
inArgs: [{
name: 'sgName',
doc: "",
@@ -577,7 +577,7 @@
{
name: 'spec',
doc: "",
- type: _typeSyncGroupSpec
+ type: _typeSyncgroupSpec
},
{
name: 'version',
@@ -593,8 +593,8 @@
{
- name: 'GetSyncGroupMembers',
- doc: "// GetSyncGroupMembers gets the info objects for members of the SyncGroup.\n//\n// Requires: Client must have at least Read access on the Database and on the\n// SyncGroup ACL.",
+ name: 'GetSyncgroupMembers',
+ doc: "// GetSyncgroupMembers gets the info objects for members of the Syncgroup.\n//\n// Requires: Client must have at least Read access on the Database and on the\n// Syncgroup ACL.",
inArgs: [{
name: 'sgName',
doc: "",
@@ -1044,48 +1044,48 @@
};
-Database.prototype.getSyncGroupNames = function(ctx, serverCall) {
- throw new Error('Method GetSyncGroupNames not implemented');
+Database.prototype.getSyncgroupNames = function(ctx, serverCall) {
+ throw new Error('Method GetSyncgroupNames not implemented');
};
-Database.prototype.createSyncGroup = function(ctx, serverCall, sgName, spec, myInfo) {
- throw new Error('Method CreateSyncGroup not implemented');
+Database.prototype.createSyncgroup = function(ctx, serverCall, sgName, spec, myInfo) {
+ throw new Error('Method CreateSyncgroup not implemented');
};
-Database.prototype.joinSyncGroup = function(ctx, serverCall, sgName, myInfo) {
- throw new Error('Method JoinSyncGroup not implemented');
+Database.prototype.joinSyncgroup = function(ctx, serverCall, sgName, myInfo) {
+ throw new Error('Method JoinSyncgroup not implemented');
};
-Database.prototype.leaveSyncGroup = function(ctx, serverCall, sgName) {
- throw new Error('Method LeaveSyncGroup not implemented');
+Database.prototype.leaveSyncgroup = function(ctx, serverCall, sgName) {
+ throw new Error('Method LeaveSyncgroup not implemented');
};
-Database.prototype.destroySyncGroup = function(ctx, serverCall, sgName) {
- throw new Error('Method DestroySyncGroup not implemented');
+Database.prototype.destroySyncgroup = function(ctx, serverCall, sgName) {
+ throw new Error('Method DestroySyncgroup not implemented');
};
-Database.prototype.ejectFromSyncGroup = function(ctx, serverCall, sgName, member) {
- throw new Error('Method EjectFromSyncGroup not implemented');
+Database.prototype.ejectFromSyncgroup = function(ctx, serverCall, sgName, member) {
+ throw new Error('Method EjectFromSyncgroup not implemented');
};
-Database.prototype.getSyncGroupSpec = function(ctx, serverCall, sgName) {
- throw new Error('Method GetSyncGroupSpec not implemented');
+Database.prototype.getSyncgroupSpec = function(ctx, serverCall, sgName) {
+ throw new Error('Method GetSyncgroupSpec not implemented');
};
-Database.prototype.setSyncGroupSpec = function(ctx, serverCall, sgName, spec, version) {
- throw new Error('Method SetSyncGroupSpec not implemented');
+Database.prototype.setSyncgroupSpec = function(ctx, serverCall, sgName, spec, version) {
+ throw new Error('Method SetSyncgroupSpec not implemented');
};
-Database.prototype.getSyncGroupMembers = function(ctx, serverCall, sgName) {
- throw new Error('Method GetSyncGroupMembers not implemented');
+Database.prototype.getSyncgroupMembers = function(ctx, serverCall, sgName) {
+ throw new Error('Method GetSyncgroupMembers not implemented');
};
@@ -1170,9 +1170,9 @@
doc: "// DatabaseWatcher allows a client to watch for updates to the database. For\n// each watch request, the client will receive a reliable stream of watch events\n// without re-ordering. See watch.GlobWatcher for a detailed explanation of the\n// behavior.\n// TODO(rogulenko): Currently the only supported watch patterns are\n// \"<tableName>/<rowPrefix>*\". Consider changing that.\n//\n// The watching is done by starting a streaming RPC. The argument to the RPC\n// contains the ResumeMarker that points to a particular place in the database\n// event log. The result stream consists of a never-ending sequence of Change\n// messages (until the call fails or is canceled). Each Change contains the Name\n// field in the form \"<tableName>/<rowKey>\" and the Value field of the\n// StoreChange type. If the client has no access to a row specified in a change,\n// that change is excluded from the result stream.\n//\n// DatabaseWatcher is designed to be used in the following way:\n// 1) begin a read-only batch\n// 2) read all data your app needs\n// 3) read the ResumeMarker\n// 4) abort the batch\n// 5) start watching for changes to the data using the ResumeMarker\n// In this configuration the client will not miss any changes to the data."
},
{
- name: 'SyncGroupManager',
+ name: 'SyncgroupManager',
pkgPath: 'v.io/v23/services/syncbase/nosql',
- doc: "// SyncGroupManager is the interface for SyncGroup operations.\n// TODO(hpucha): Add blessings to create/join and add a refresh method."
+ doc: "// SyncgroupManager is the interface for Syncgroup operations.\n// TODO(hpucha): Add blessings to create/join and add a refresh method."
},
{
name: 'BlobManager',
@@ -1429,8 +1429,8 @@
{
- name: 'GetSyncGroupNames',
- doc: "// GetSyncGroupNames returns the global names of all SyncGroups attached to\n// this database.",
+ name: 'GetSyncgroupNames',
+ doc: "// GetSyncgroupNames returns the global names of all Syncgroups attached to\n// this database.",
inArgs: [],
outArgs: [{
name: '',
@@ -1445,8 +1445,8 @@
{
- name: 'CreateSyncGroup',
- doc: "// CreateSyncGroup creates a new SyncGroup with the given spec.\n//\n// Requires: Client must have at least Read access on the Database; prefix ACL\n// must exist at each SyncGroup prefix; Client must have at least Read access\n// on each of these prefix ACLs.",
+ name: 'CreateSyncgroup',
+ doc: "// CreateSyncgroup creates a new Syncgroup with the given spec.\n//\n// Requires: Client must have at least Read access on the Database; prefix ACL\n// must exist at each Syncgroup prefix; Client must have at least Read access\n// on each of these prefix ACLs.",
inArgs: [{
name: 'sgName',
doc: "",
@@ -1455,12 +1455,12 @@
{
name: 'spec',
doc: "",
- type: _typeSyncGroupSpec
+ type: _typeSyncgroupSpec
},
{
name: 'myInfo',
doc: "",
- type: _typeSyncGroupMemberInfo
+ type: _typeSyncgroupMemberInfo
},
],
outArgs: [],
@@ -1471,8 +1471,8 @@
{
- name: 'JoinSyncGroup',
- doc: "// JoinSyncGroup joins the SyncGroup.\n//\n// Requires: Client must have at least Read access on the Database and on the\n// SyncGroup ACL.",
+ name: 'JoinSyncgroup',
+ doc: "// JoinSyncgroup joins the Syncgroup.\n//\n// Requires: Client must have at least Read access on the Database and on the\n// Syncgroup ACL.",
inArgs: [{
name: 'sgName',
doc: "",
@@ -1481,13 +1481,13 @@
{
name: 'myInfo',
doc: "",
- type: _typeSyncGroupMemberInfo
+ type: _typeSyncgroupMemberInfo
},
],
outArgs: [{
name: 'spec',
doc: "",
- type: _typeSyncGroupSpec
+ type: _typeSyncgroupSpec
},
],
inStream: null,
@@ -1497,8 +1497,8 @@
{
- name: 'LeaveSyncGroup',
- doc: "// LeaveSyncGroup leaves the SyncGroup. Previously synced data will continue\n// to be available.\n//\n// Requires: Client must have at least Read access on the Database.",
+ name: 'LeaveSyncgroup',
+ doc: "// LeaveSyncgroup leaves the Syncgroup. Previously synced data will continue\n// to be available.\n//\n// Requires: Client must have at least Read access on the Database.",
inArgs: [{
name: 'sgName',
doc: "",
@@ -1513,8 +1513,8 @@
{
- name: 'DestroySyncGroup',
- doc: "// DestroySyncGroup destroys the SyncGroup. Previously synced data will\n// continue to be available to all members.\n//\n// Requires: Client must have at least Read access on the Database, and must\n// have Admin access on the SyncGroup ACL.",
+ name: 'DestroySyncgroup',
+ doc: "// DestroySyncgroup destroys the Syncgroup. Previously synced data will\n// continue to be available to all members.\n//\n// Requires: Client must have at least Read access on the Database, and must\n// have Admin access on the Syncgroup ACL.",
inArgs: [{
name: 'sgName',
doc: "",
@@ -1529,8 +1529,8 @@
{
- name: 'EjectFromSyncGroup',
- doc: "// EjectFromSyncGroup ejects a member from the SyncGroup. The ejected member\n// will not be able to sync further, but will retain any data it has already\n// synced.\n//\n// Requires: Client must have at least Read access on the Database, and must\n// have Admin access on the SyncGroup ACL.",
+ name: 'EjectFromSyncgroup',
+ doc: "// EjectFromSyncgroup ejects a member from the Syncgroup. The ejected member\n// will not be able to sync further, but will retain any data it has already\n// synced.\n//\n// Requires: Client must have at least Read access on the Database, and must\n// have Admin access on the Syncgroup ACL.",
inArgs: [{
name: 'sgName',
doc: "",
@@ -1550,8 +1550,8 @@
{
- name: 'GetSyncGroupSpec',
- doc: "// GetSyncGroupSpec gets the SyncGroup spec. version allows for atomic\n// read-modify-write of the spec - see comment for SetSyncGroupSpec.\n//\n// Requires: Client must have at least Read access on the Database and on the\n// SyncGroup ACL.",
+ name: 'GetSyncgroupSpec',
+ doc: "// GetSyncgroupSpec gets the Syncgroup spec. version allows for atomic\n// read-modify-write of the spec - see comment for SetSyncgroupSpec.\n//\n// Requires: Client must have at least Read access on the Database and on the\n// Syncgroup ACL.",
inArgs: [{
name: 'sgName',
doc: "",
@@ -1561,7 +1561,7 @@
outArgs: [{
name: 'spec',
doc: "",
- type: _typeSyncGroupSpec
+ type: _typeSyncgroupSpec
},
{
name: 'version',
@@ -1576,8 +1576,8 @@
{
- name: 'SetSyncGroupSpec',
- doc: "// SetSyncGroupSpec sets the SyncGroup spec. version may be either empty or\n// the value from a previous Get. If not empty, Set will only succeed if the\n// current version matches the specified one.\n//\n// Requires: Client must have at least Read access on the Database, and must\n// have Admin access on the SyncGroup ACL.",
+ name: 'SetSyncgroupSpec',
+ doc: "// SetSyncgroupSpec sets the Syncgroup spec. version may be either empty or\n// the value from a previous Get. If not empty, Set will only succeed if the\n// current version matches the specified one.\n//\n// Requires: Client must have at least Read access on the Database, and must\n// have Admin access on the Syncgroup ACL.",
inArgs: [{
name: 'sgName',
doc: "",
@@ -1586,7 +1586,7 @@
{
name: 'spec',
doc: "",
- type: _typeSyncGroupSpec
+ type: _typeSyncgroupSpec
},
{
name: 'version',
@@ -1602,8 +1602,8 @@
{
- name: 'GetSyncGroupMembers',
- doc: "// GetSyncGroupMembers gets the info objects for members of the SyncGroup.\n//\n// Requires: Client must have at least Read access on the Database and on the\n// SyncGroup ACL.",
+ name: 'GetSyncgroupMembers',
+ doc: "// GetSyncgroupMembers gets the info objects for members of the Syncgroup.\n//\n// Requires: Client must have at least Read access on the Database and on the\n// Syncgroup ACL.",
inArgs: [{
name: 'sgName',
doc: "",
diff --git a/src/nosql/database.js b/src/nosql/database.js
index 4438831..07c2313 100644
--- a/src/nosql/database.js
+++ b/src/nosql/database.js
@@ -17,7 +17,7 @@
// Silence jshint's error about redefining 'Blob'.
var Blob = require('./blob');
/* jshint +W079 */
-var SyncGroup = require('./syncgroup');
+var Syncgroup = require('./syncgroup');
var Table = require('./table');
var util = require('../util');
var watch = require('./watch');
@@ -339,21 +339,21 @@
};
/**
- * Gets a handle to the SyncGroup with the given name.
+ * Gets a handle to the syncgroup with the given name.
*
- * @param {string} name SyncGroup name.
+ * @param {string} name Syncgroup name.
*/
-Database.prototype.syncGroup = function(name) {
- return new SyncGroup(this, name);
+Database.prototype.syncgroup = function(name) {
+ return new Syncgroup(this, name);
};
/**
- * Gets the global names of all SyncGroups attached to this database.
+ * Gets the global names of all syncgroups attached to this database.
* @param {module:vanadium.context.Context} ctx Vanadium context.
* @param {function} cb Callback.
*/
-Database.prototype.getSyncGroupNames = function(ctx, cb) {
- this._wire(ctx).getSyncGroupNames(ctx, cb);
+Database.prototype.getSyncgroupNames = function(ctx, cb) {
+ this._wire(ctx).getSyncgroupNames(ctx, cb);
};
/**
diff --git a/src/nosql/index.js b/src/nosql/index.js
index 340d583..597a67a 100644
--- a/src/nosql/index.js
+++ b/src/nosql/index.js
@@ -24,8 +24,8 @@
runInBatch: runInBatch,
Schema: Schema,
SchemaMetadata: vdl.SchemaMetadata,
- SyncGroupMemberInfo: vdl.SyncGroupMemberInfo,
- SyncGroupPrefix: vdl.SyncGroupPrefix,
- SyncGroupSpec: vdl.SyncGroupSpec,
+ SyncgroupMemberInfo: vdl.SyncgroupMemberInfo,
+ SyncgroupPrefix: vdl.SyncgroupPrefix,
+ SyncgroupSpec: vdl.SyncgroupSpec,
WatchChange: watch.WatchChange
};
diff --git a/src/nosql/syncgroup.js b/src/nosql/syncgroup.js
index 52b2b37..4b7b081 100644
--- a/src/nosql/syncgroup.js
+++ b/src/nosql/syncgroup.js
@@ -2,14 +2,14 @@
// Use of this source code is governed by a BSD-style
// license that can be found in the LICENSE file.
-module.exports = SyncGroup;
+module.exports = Syncgroup;
/**
- * SyncGroup is the interface for a SyncGroup in the store.
+ * Syncgroup is the interface for a syncgroup in the store.
*/
-function SyncGroup(db, name) {
- if (!(this instanceof SyncGroup)) {
- return new SyncGroup(db, name);
+function Syncgroup(db, name) {
+ if (!(this instanceof Syncgroup)) {
+ return new Syncgroup(db, name);
}
/**
@@ -33,39 +33,39 @@
}
/**
- * Creates a new SyncGroup with the given spec.
+ * Creates a new syncgroup with the given spec.
*
* Requires: Client must have at least Read access on the Database; prefix ACL
- * must exist at each SyncGroup prefix; Client must have at least Read access
+ * must exist at each syncgroup prefix; Client must have at least Read access
* on each of these prefix ACLs.
*
* @param {module:vanadium.context.Context} ctx Vanadium context.
- * @param {module:syncbase.nosql.SyncGroupSpec} spec SyncGroupSpec.
- * @param {module:syncbase.nosql.SyncGroupMemberInfo} myInfo
- * SyncGroupMemberInfo.
+ * @param {module:syncbase.nosql.SyncgroupSpec} spec SyncgroupSpec.
+ * @param {module:syncbase.nosql.SyncgroupMemberInfo} myInfo
+ * SyncgroupMemberInfo.
* @param {function} cb Callback.
*/
-SyncGroup.prototype.create = function(ctx, spec, myInfo, cb) {
- this._db._wire(ctx).createSyncGroup(ctx, this.name, spec, myInfo, cb);
+Syncgroup.prototype.create = function(ctx, spec, myInfo, cb) {
+ this._db._wire(ctx).createSyncgroup(ctx, this.name, spec, myInfo, cb);
};
/**
- * Joins a SyncGroup.
+ * Joins a syncgroup.
*
* Requires: Client must have at least Read access on the Database and on the
- * SyncGroup ACL.
+ * syncgroup ACL.
*
* @param {module:vanadium.context.Context} ctx Vanadium context.
- * @param {module:syncbase.nosql.SyncGroupMemberInfo} myInfo
- * SyncGroupMemberInfo.
+ * @param {module:syncbase.nosql.SyncgroupMemberInfo} myInfo
+ * SyncgroupMemberInfo.
* @param {function} cb Callback.
*/
-SyncGroup.prototype.join = function(ctx, myInfo, cb) {
- this._db._wire(ctx).joinSyncGroup(ctx, this.name, myInfo, cb);
+Syncgroup.prototype.join = function(ctx, myInfo, cb) {
+ this._db._wire(ctx).joinSyncgroup(ctx, this.name, myInfo, cb);
};
/**
- * Leaves the SyncGroup. Previously synced data will continue to be
+ * Leaves the syncgroup. Previously synced data will continue to be
* available.
*
* Requires: Client must have at least Read access on the Database.
@@ -73,80 +73,80 @@
* @param {module:vanadium.context.Context} ctx Vanadium context.
* @param {function} cb Callback.
*/
-SyncGroup.prototype.leave = function(ctx, cb) {
- this._db._wire(ctx).leaveSyncGroup(ctx, this.name, cb);
+Syncgroup.prototype.leave = function(ctx, cb) {
+ this._db._wire(ctx).leaveSyncgroup(ctx, this.name, cb);
};
/**
- * Destroys a SyncGroup. Previously synced data will continue to be available
+ * Destroys a syncgroup. Previously synced data will continue to be available
* to all members.
*
* Requires: Client must have at least Read access on the Database, and must
- * have Admin access on the SyncGroup ACL.
+ * have Admin access on the syncgroup ACL.
*
* @param {module:vanadium.context.Context} ctx Vanadium context.
* @param {function} cb Callback.
*/
-SyncGroup.prototype.destroy = function(ctx, cb) {
- this._db._wire(ctx).destroySyncGroup(ctx, this.name, cb);
+Syncgroup.prototype.destroy = function(ctx, cb) {
+ this._db._wire(ctx).destroySyncgroup(ctx, this.name, cb);
};
/**
- * Ejects a member from the SyncGroup. The ejected member will not be able to
+ * Ejects a member from the syncgroup. The ejected member will not be able to
* sync further, but will retain any data it has already synced.
*
* Requires: Client must have at least Read access on the Database, and must
- * have Admin access on the SyncGroup ACL.
+ * have Admin access on the syncgroup ACL.
*
* @param {module:vanadium.context.Context} ctx Vanadium context.
- * @param {module:syncbase.nosql.SyncGroupMemberInfo} member
- * SyncGroupMemberInfo.
+ * @param {module:syncbase.nosql.SyncgroupMemberInfo} member
+ * SyncgroupMemberInfo.
* @param {function} cb Callback.
*/
-SyncGroup.prototype.eject = function(ctx, member, cb) {
- this._db._wire(ctx).ejectFromSyncGroup(ctx, this.name, member, cb);
+Syncgroup.prototype.eject = function(ctx, member, cb) {
+ this._db._wire(ctx).ejectFromSyncgroup(ctx, this.name, member, cb);
};
/**
- * Gets the SyncGroup spec. version allows for atomic read-modify-write of the
+ * Gets the syncgroup spec. version allows for atomic read-modify-write of the
* spec - see comment for setSpec.
*
* Requires: Client must have at least Read access on the Database and on the
- * SyncGroup ACL.
+ * syncgroup ACL.
*
* @param {module:vanadium.context.Context} ctx Vanadium context.
* @param {function} cb Callback.
*/
-SyncGroup.prototype.getSpec = function(ctx, cb) {
- this._db._wire(ctx).getSyncGroupSpec(ctx, this.name, cb);
+Syncgroup.prototype.getSpec = function(ctx, cb) {
+ this._db._wire(ctx).getSyncgroupSpec(ctx, this.name, cb);
};
/**
- * Sets the SyncGroup spec. version may be either empty or the value from a
+ * Sets the syncgroup spec. version may be either empty or the value from a
* previous Get. If not empty, Set will only succeed if the current version
* matches the specified one.
*
* Requires: Client must have at least Read access on the Database, and must
- * have Admin access on the SyncGroup ACL.
+ * have Admin access on the syncgroup ACL.
*
* @param {module:vanadium.context.Context} ctx Vanadium context.
- * @param {module:syncbase.nosql.SyncGroupSpec} spec SyncGroupSpec.
- * @param {string} version Version of the current SyncGroupSpec object which
+ * @param {module:syncbase.nosql.SyncgroupSpec} spec SyncgroupSpec.
+ * @param {string} version Version of the current SyncgroupSpec object which
* will be overwritten. If empty, setSpec will perform an unconditional update.
* @param {function} cb Callback.
*/
-SyncGroup.prototype.setSpec = function(ctx, spec, version, cb) {
- this._db._wire(ctx).setSyncGroupSpec(ctx, this.name, spec, version, cb);
+Syncgroup.prototype.setSpec = function(ctx, spec, version, cb) {
+ this._db._wire(ctx).setSyncgroupSpec(ctx, this.name, spec, version, cb);
};
/**
- * Gets the info objects for members of the SyncGroup.
+ * Gets the info objects for members of the syncgroup.
*
* Requires: Client must have at least Read access on the Database and on the
- * SyncGroup ACL.
+ * syncgroup ACL.
* @param {module:vanadium.context.Context} ctx Vanadium context.
* @param {function} cb Callback.
*/
-SyncGroup.prototype.getMembers = function(ctx, cb) {
- this._db._wire(ctx).getSyncGroupMembers(ctx, this.name, cb);
+Syncgroup.prototype.getMembers = function(ctx, cb) {
+ this._db._wire(ctx).getSyncgroupMembers(ctx, this.name, cb);
};
diff --git a/test/integration/test-syncgroup.js b/test/integration/test-syncgroup.js
index 67c6d99..c1e570f 100644
--- a/test/integration/test-syncgroup.js
+++ b/test/integration/test-syncgroup.js
@@ -9,21 +9,21 @@
var syncbase = require('../..');
var nosql = syncbase.nosql;
var syncbaseSuffix = syncbase.syncbaseSuffix;
-var SyncGroup = require('../../src/nosql/syncgroup');
+var Syncgroup = require('../../src/nosql/syncgroup');
var verror = require('vanadium').verror;
var testUtil = require('./util');
var setupDatabase = testUtil.setupDatabase;
-var setupSyncGroup = testUtil.setupSyncGroup;
+var setupSyncgroup = testUtil.setupSyncgroup;
var uniqueName = testUtil.uniqueName;
// TODO(nlacasse): Where does this magic number 8 come from? It's in
// syncgroup_test.go.
-var myInfo = new nosql.SyncGroupMemberInfo({
+var myInfo = new nosql.SyncgroupMemberInfo({
syncPriority: 8
});
-test('db.syncGroup returns a SyncGroup with name', function(t) {
+test('db.syncgroup returns a syncgroup with name', function(t) {
setupDatabase(t, function(err, o) {
if (err) {
return t.end(err);
@@ -32,8 +32,8 @@
var db = o.database;
var sgName = uniqueName('syncgroup');
- var sg = db.syncGroup(sgName);
- t.ok(sg instanceof SyncGroup, 'syncgroup is instanceof SyncGroup');
+ var sg = db.syncgroup(sgName);
+ t.ok(sg instanceof Syncgroup, 'syncgroup is instanceof Syncgroup');
t.equal(sg.name, sgName, 'syncgroup has correct name');
o.teardown(t.end);
});
@@ -48,10 +48,10 @@
var db = o.database;
var ctx = o.ctx;
- var spec = new nosql.SyncGroupSpec();
+ var spec = new nosql.SyncgroupSpec();
var name = uniqueName('syncgroup');
- db.syncGroup(name).create(ctx, spec, myInfo, function(err) {
+ db.syncgroup(name).create(ctx, spec, myInfo, function(err) {
t.ok(err, 'should error');
t.ok(err instanceof verror.BadArgError, 'err is BadArgError');
o.teardown(t.end);
@@ -62,7 +62,7 @@
test('syncgroup.create with valid spec', function(t) {
var perms = {};
var prefixes = [
- new nosql.SyncGroupPrefix({tableName: 't1', rowPrefix: 'foo'})
+ new nosql.SyncgroupPrefix({tableName: 't1', rowPrefix: 'foo'})
];
setupDatabase(t, function(err, o) {
@@ -79,13 +79,13 @@
syncbaseSuffix,
uniqueName('syncgroup'));
- var spec = new nosql.SyncGroupSpec({
+ var spec = new nosql.SyncgroupSpec({
description: 'test syncgroup ' + name,
perms: perms,
prefixes: prefixes
});
- db.syncGroup(name).create(ctx, spec, myInfo, function(err) {
+ db.syncgroup(name).create(ctx, spec, myInfo, function(err) {
t.error(err, 'should not error');
o.teardown(t.end);
});
@@ -95,13 +95,13 @@
test('creating a nested syncgroup', function(t) {
var perms = {};
var prefixes = [
- new nosql.SyncGroupPrefix({tableName: 't1', rowPrefix: 'foo'})
+ new nosql.SyncgroupPrefix({tableName: 't1', rowPrefix: 'foo'})
];
var prefixes2 = [
- new nosql.SyncGroupPrefix({tableName: 't1', rowPrefix: 'foobar'})
+ new nosql.SyncgroupPrefix({tableName: 't1', rowPrefix: 'foobar'})
];
- setupSyncGroup(t, perms, prefixes, function(err, o) {
+ setupSyncgroup(t, perms, prefixes, function(err, o) {
if (err) {
return t.end(err);
}
@@ -115,13 +115,13 @@
syncbaseSuffix,
uniqueName('syncgroup'));
- var spec = new nosql.SyncGroupSpec({
+ var spec = new nosql.SyncgroupSpec({
description: 'another syncgroup named ' + name,
perms: perms,
prefixes: prefixes2
});
- var sg2 = db.syncGroup(name);
+ var sg2 = db.syncgroup(name);
sg2.create(ctx, spec, myInfo, function(err) {
t.error(err, 'should not error');
o.teardown(t.end);
@@ -132,13 +132,13 @@
test('creating a syncgroup that already exists', function(t) {
var perms = {};
var prefixes = [
- new nosql.SyncGroupPrefix({tableName: 't1', rowPrefix: 'foo'})
+ new nosql.SyncgroupPrefix({tableName: 't1', rowPrefix: 'foo'})
];
var prefixes2 = [
- new nosql.SyncGroupPrefix({tableName: 'another', rowPrefix: 'prefix'})
+ new nosql.SyncgroupPrefix({tableName: 'another', rowPrefix: 'prefix'})
];
- setupSyncGroup(t, perms, prefixes, function(err, o) {
+ setupSyncgroup(t, perms, prefixes, function(err, o) {
if (err) {
return t.end(err);
}
@@ -148,13 +148,13 @@
var name = o.syncgroup.name;
- var spec = new nosql.SyncGroupSpec({
+ var spec = new nosql.SyncgroupSpec({
description: 'another syncgroup named ' + name,
perms: perms,
prefixes: prefixes2
});
- var sg2 = db.syncGroup(name);
+ var sg2 = db.syncgroup(name);
sg2.create(ctx, spec, myInfo, function(err) {
t.ok(err, 'should error');
t.ok(err instanceof verror.ExistError, 'err is ExistError');
@@ -170,10 +170,10 @@
}]
]);
var prefixes = [
- new nosql.SyncGroupPrefix({tableName: 't1', rowPrefix: 'foo'})
+ new nosql.SyncgroupPrefix({tableName: 't1', rowPrefix: 'foo'})
];
- setupSyncGroup(t, perms, prefixes, function(err, o) {
+ setupSyncgroup(t, perms, prefixes, function(err, o) {
if (err) {
return t.end(err);
}
@@ -192,10 +192,10 @@
}]
]);
var prefixes = [
- new nosql.SyncGroupPrefix({tableName: 't1', rowPrefix: 'foo'})
+ new nosql.SyncgroupPrefix({tableName: 't1', rowPrefix: 'foo'})
];
- setupSyncGroup(t, perms, prefixes, function(err, o) {
+ setupSyncgroup(t, perms, prefixes, function(err, o) {
if (err) {
return t.end(err);
}
@@ -212,8 +212,8 @@
});
// TODO(nlacasse): Enable this test once Syncbase server implements
-// Database.GetSyncGroupNames.
-test.skip('db.getSyncGroupNames returns the correct names', function(t) {
+// Database.GetSyncgroupNames.
+test.skip('db.getSyncgroupNames returns the correct names', function(t) {
setupDatabase(t, function(err, o) {
if (err) {
return t.end(err);
@@ -234,29 +234,29 @@
name);
});
- createSyncGroups();
+ createSyncgroups();
- function createSyncGroups() {
+ function createSyncgroups() {
async.forEach(fullNames, function(fullName, cb) {
- var spec = new nosql.SyncGroupSpec({
+ var spec = new nosql.SyncgroupSpec({
description: 'syncgroup named ' + fullName,
- prefixes: [new nosql.SyncGroupPrefix({tableName: '', rowPrefix: ''})]
+ prefixes: [new nosql.SyncgroupPrefix({tableName: '', rowPrefix: ''})]
});
- db.syncGroup(fullName).create(ctx, spec, myInfo, cb);
- }, getSyncGroupNames);
+ db.syncgroup(fullName).create(ctx, spec, myInfo, cb);
+ }, getSyncgroupNames);
}
- function getSyncGroupNames(err) {
+ function getSyncgroupNames(err) {
if (err) {
t.error(err);
o.teardown(t.end);
}
- db.getSyncGroupNames(ctx, assertSyncGroupNames);
+ db.getSyncgroupNames(ctx, assertSyncgroupNames);
}
- function assertSyncGroupNames(err, gotNames) {
+ function assertSyncgroupNames(err, gotNames) {
if (err) {
t.error(err);
return o.teardown(t.end);
@@ -273,22 +273,22 @@
test('syncgroup.get/setSpec', function(t) {
var perms = {};
var prefixes = [
- new nosql.SyncGroupPrefix({tableName: 'biz', rowPrefix: 'bazz'})
+ new nosql.SyncgroupPrefix({tableName: 'biz', rowPrefix: 'bazz'})
];
var firstVersion;
- var newSpec = new nosql.SyncGroupSpec({
+ var newSpec = new nosql.SyncgroupSpec({
description: 'new spec',
prefixes: prefixes
});
- var newSpec2 = new nosql.SyncGroupSpec({
+ var newSpec2 = new nosql.SyncgroupSpec({
description: 'another new spec',
prefixes: prefixes
});
- setupSyncGroup(t, perms, prefixes, function(err, o) {
+ setupSyncgroup(t, perms, prefixes, function(err, o) {
if (err) {
return t.end(err);
}
diff --git a/test/integration/util.js b/test/integration/util.js
index 954a92b..75487e1 100644
--- a/test/integration/util.js
+++ b/test/integration/util.js
@@ -6,7 +6,7 @@
setupApp: setupApp,
setupDatabase: setupDatabase,
setupService: setupService,
- setupSyncGroup: setupSyncGroup,
+ setupSyncgroup: setupSyncgroup,
setupTable: setupTable,
assertScanRows: assertScanRows,
@@ -102,8 +102,8 @@
});
}
-// Initializes Vanadium runtime and creats an App, Database and SyncGroup.
-function setupSyncGroup(t, perms, prefixes, cb) {
+// Initializes Vanadium runtime and creats an App, Database and Syncgroup.
+function setupSyncgroup(t, perms, prefixes, cb) {
setupDatabase(t, function(err, o) {
if (err) {
return cb(err);
@@ -116,17 +116,17 @@
// TODO(nlacasse): Where does this magic number 8 come from? It's in
// syncgroup_test.go.
- var myInfo = new syncbase.nosql.SyncGroupMemberInfo({
+ var myInfo = new syncbase.nosql.SyncgroupMemberInfo({
syncPriority: 8
});
- var spec = new syncbase.nosql.SyncGroupSpec({
+ var spec = new syncbase.nosql.SyncgroupSpec({
description: 'test syncgroup ' + fullSgName,
perms: perms,
prefixes: prefixes
});
- var sg = o.database.syncGroup(fullSgName);
+ var sg = o.database.syncgroup(fullSgName);
sg.create(o.ctx, spec, myInfo, function(err) {
if (err) {
o.rt.close(t.error);
