status(
+ pb.ReplicationOuterClass.Subscription request) {
+ return blockingServerStreamingCall(
+ getChannel(), getStatusMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * GetSubscriptionUpdate returns the latest version of subscribed replication
+ *
+ */
+ public pb.ReplicationOuterClass.SubscriptionUpdate getSubscriptionUpdate(pb.ReplicationOuterClass.Subscription request) {
+ return blockingUnaryCall(
+ getChannel(), getGetSubscriptionUpdateMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * SubmitReplication is used by client agents to start replications, after they
+ * have uploaded the files and retrieved the cid, and collected servers to replicate too.
+ *
+ */
+ public java.util.Iterator submitReplication(
+ pb.ReplicationOuterClass.SignedSubscription request) {
+ return blockingServerStreamingCall(
+ getChannel(), getSubmitReplicationMethod(), getCallOptions(), request);
+ }
+ }
+
+ /**
+ *
+ * The replicator provides replication services.
+ *
+ */
+ public static final class replicatorFutureStub extends io.grpc.stub.AbstractFutureStub {
+ private replicatorFutureStub(
+ io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ super(channel, callOptions);
+ }
+
+ @java.lang.Override
+ protected replicatorFutureStub build(
+ io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ return new replicatorFutureStub(channel, callOptions);
+ }
+
+ /**
+ *
+ * GetSubscriptionUpdate returns the latest version of subscribed replication
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture getSubscriptionUpdate(
+ pb.ReplicationOuterClass.Subscription request) {
+ return futureUnaryCall(
+ getChannel().newCall(getGetSubscriptionUpdateMethod(), getCallOptions()), request);
+ }
+ }
+
+ private static final int METHODID_ADD = 0;
+ private static final int METHODID_STATUS = 1;
+ private static final int METHODID_GET_SUBSCRIPTION_UPDATE = 2;
+ private static final int METHODID_SUBMIT_REPLICATION = 3;
+
+ private static final class MethodHandlers implements
+ io.grpc.stub.ServerCalls.UnaryMethod,
+ io.grpc.stub.ServerCalls.ServerStreamingMethod,
+ io.grpc.stub.ServerCalls.ClientStreamingMethod,
+ io.grpc.stub.ServerCalls.BidiStreamingMethod {
+ private final replicatorImplBase serviceImpl;
+ private final int methodId;
+
+ MethodHandlers(replicatorImplBase serviceImpl, int methodId) {
+ this.serviceImpl = serviceImpl;
+ this.methodId = methodId;
+ }
+
+ @java.lang.Override
+ @java.lang.SuppressWarnings("unchecked")
+ public void invoke(Req request, io.grpc.stub.StreamObserver responseObserver) {
+ switch (methodId) {
+ case METHODID_ADD:
+ serviceImpl.add((pb.ReplicationOuterClass.Subscription) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_STATUS:
+ serviceImpl.status((pb.ReplicationOuterClass.Subscription) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_GET_SUBSCRIPTION_UPDATE:
+ serviceImpl.getSubscriptionUpdate((pb.ReplicationOuterClass.Subscription) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_SUBMIT_REPLICATION:
+ serviceImpl.submitReplication((pb.ReplicationOuterClass.SignedSubscription) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ default:
+ throw new AssertionError();
+ }
+ }
+
+ @java.lang.Override
+ @java.lang.SuppressWarnings("unchecked")
+ public io.grpc.stub.StreamObserver invoke(
+ io.grpc.stub.StreamObserver responseObserver) {
+ switch (methodId) {
+ default:
+ throw new AssertionError();
+ }
+ }
+ }
+
+ private static abstract class replicatorBaseDescriptorSupplier
+ implements io.grpc.protobuf.ProtoFileDescriptorSupplier, io.grpc.protobuf.ProtoServiceDescriptorSupplier {
+ replicatorBaseDescriptorSupplier() {}
+
+ @java.lang.Override
+ public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() {
+ return pb.ReplicationOuterClass.getDescriptor();
+ }
+
+ @java.lang.Override
+ public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() {
+ return getFileDescriptor().findServiceByName("replicator");
+ }
+ }
+
+ private static final class replicatorFileDescriptorSupplier
+ extends replicatorBaseDescriptorSupplier {
+ replicatorFileDescriptorSupplier() {}
+ }
+
+ private static final class replicatorMethodDescriptorSupplier
+ extends replicatorBaseDescriptorSupplier
+ implements io.grpc.protobuf.ProtoMethodDescriptorSupplier {
+ private final String methodName;
+
+ replicatorMethodDescriptorSupplier(String methodName) {
+ this.methodName = methodName;
+ }
+
+ @java.lang.Override
+ public com.google.protobuf.Descriptors.MethodDescriptor getMethodDescriptor() {
+ return getServiceDescriptor().findMethodByName(methodName);
+ }
+ }
+
+ private static volatile io.grpc.ServiceDescriptor serviceDescriptor;
+
+ public static io.grpc.ServiceDescriptor getServiceDescriptor() {
+ io.grpc.ServiceDescriptor result = serviceDescriptor;
+ if (result == null) {
+ synchronized (replicatorGrpc.class) {
+ result = serviceDescriptor;
+ if (result == null) {
+ serviceDescriptor = result = io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
+ .setSchemaDescriptor(new replicatorFileDescriptorSupplier())
+ .addMethod(getAddMethod())
+ .addMethod(getStatusMethod())
+ .addMethod(getGetSubscriptionUpdateMethod())
+ .addMethod(getSubmitReplicationMethod())
+ .build();
+ }
+ }
+ }
+ return result;
+ }
+}
diff --git a/js/admin_grpc_pb.js b/js/admin_grpc_pb.js
index 3a30924..b092e3f 100644
--- a/js/admin_grpc_pb.js
+++ b/js/admin_grpc_pb.js
@@ -52,7 +52,7 @@ function deserialize_pb_RefCountResponse(buffer_arg) {
// AdminAPI facilitates administrative management of TemporalX via a localhost gRPC API
var AdminAPIService = exports.AdminAPIService = {
// ManageGC is used to manage TemporalX's garbage collection process
- manageGC: {
+manageGC: {
path: '/pb.AdminAPI/ManageGC',
requestStream: false,
responseStream: false,
@@ -64,7 +64,7 @@ var AdminAPIService = exports.AdminAPIService = {
responseDeserialize: deserialize_pb_ManageGCResponse,
},
// RefCount is used to analyze the counter store and pull reference count information
- refCount: {
+refCount: {
path: '/pb.AdminAPI/RefCount',
requestStream: false,
responseStream: false,
diff --git a/js/file_grpc_pb.js b/js/file_grpc_pb.js
index 80d91cd..634fab0 100644
--- a/js/file_grpc_pb.js
+++ b/js/file_grpc_pb.js
@@ -53,7 +53,7 @@ function deserialize_pb_UploadRequest(buffer_arg) {
// FileAPI provides a gRPC api to upload/download files as UnixFS objects
var FileAPIService = exports.FileAPIService = {
// UploadFile allows uploading a file as a UnixFS object (equivalent to ipfs add)
- uploadFile: {
+uploadFile: {
path: '/pb.FileAPI/UploadFile',
requestStream: true,
responseStream: false,
@@ -65,7 +65,7 @@ var FileAPIService = exports.FileAPIService = {
responseDeserialize: deserialize_pb_PutResponse,
},
// DownloadFile allows downloading a UnixFS object (equivalent to ipfs get)
- downloadFile: {
+downloadFile: {
path: '/pb.FileAPI/DownloadFile',
requestStream: false,
responseStream: true,
diff --git a/js/node_grpc_pb.js b/js/node_grpc_pb.js
index 5c39b2c..c7fcca1 100644
--- a/js/node_grpc_pb.js
+++ b/js/node_grpc_pb.js
@@ -163,7 +163,7 @@ function deserialize_pb_PersistResponse(buffer_arg) {
// NodeAPI provide an API to control the underlying custom ipfs node
var NodeAPIService = exports.NodeAPIService = {
// ConnMgmt provides control over libp2p connections
- connMgmt: {
+connMgmt: {
path: '/pb.NodeAPI/ConnMgmt',
requestStream: false,
responseStream: false,
@@ -175,7 +175,7 @@ var NodeAPIService = exports.NodeAPIService = {
responseDeserialize: deserialize_pb_ConnMgmtResponse,
},
// Extras provide control over node extras capabilities
- extras: {
+extras: {
path: '/pb.NodeAPI/Extras',
requestStream: false,
responseStream: false,
@@ -187,9 +187,9 @@ var NodeAPIService = exports.NodeAPIService = {
responseDeserialize: deserialize_pb_Empty,
},
// P2P allows control of generalized p2p streams for tcp/udp based protocol.
- // By using this RPC, we can tunnel traffic similar to ssh tunneling
- // except using libp2p as the transport layer, and and tcp/udp port.
- p2P: {
+// By using this RPC, we can tunnel traffic similar to ssh tunneling
+// except using libp2p as the transport layer, and and tcp/udp port.
+p2P: {
path: '/pb.NodeAPI/P2P',
requestStream: false,
responseStream: false,
@@ -201,7 +201,7 @@ var NodeAPIService = exports.NodeAPIService = {
responseDeserialize: deserialize_pb_P2PResponse,
},
// Blockstore allows low-level management of the underlying blockstore
- blockstore: {
+blockstore: {
path: '/pb.NodeAPI/Blockstore',
requestStream: false,
responseStream: false,
@@ -213,7 +213,7 @@ var NodeAPIService = exports.NodeAPIService = {
responseDeserialize: deserialize_pb_BlockstoreResponse,
},
// Dag is a unidirectional rpc allowing manipulation of low-level ipld objects
- dag: {
+dag: {
path: '/pb.NodeAPI/Dag',
requestStream: false,
responseStream: false,
@@ -225,7 +225,7 @@ var NodeAPIService = exports.NodeAPIService = {
responseDeserialize: deserialize_pb_DagResponse,
},
// Keystore is a unidirectional RPC allowing management of ipfs keystores
- keystore: {
+keystore: {
path: '/pb.NodeAPI/Keystore',
requestStream: false,
responseStream: false,
@@ -237,7 +237,7 @@ var NodeAPIService = exports.NodeAPIService = {
responseDeserialize: deserialize_pb_KeystoreResponse,
},
// Persist is used to retrieve data from the network and make it available locally
- persist: {
+persist: {
path: '/pb.NodeAPI/Persist',
requestStream: false,
responseStream: false,
diff --git a/js/pubsub_grpc_pb.js b/js/pubsub_grpc_pb.js
index 96bfb0e..dfc19c5 100644
--- a/js/pubsub_grpc_pb.js
+++ b/js/pubsub_grpc_pb.js
@@ -31,8 +31,8 @@ function deserialize_pb_PubSubResponse(buffer_arg) {
// `ipfs pubsub` subset of commands.
var PubSubAPIService = exports.PubSubAPIService = {
// PubSub allows controlling libp2p pubsub topics and subscriptions using
- // a bidirectional streaming API
- pubSub: {
+// a bidirectional streaming API
+pubSub: {
path: '/pb.PubSubAPI/PubSub',
requestStream: true,
responseStream: true,
diff --git a/js/replication_grpc_pb.js b/js/replication_grpc_pb.js
new file mode 100644
index 0000000..65b57f8
--- /dev/null
+++ b/js/replication_grpc_pb.js
@@ -0,0 +1,105 @@
+// GENERATED CODE -- DO NOT EDIT!
+
+'use strict';
+var grpc = require('grpc');
+var replication_pb = require('./replication_pb.js');
+
+function serialize_pb_ReplicationStatus(arg) {
+ if (!(arg instanceof replication_pb.ReplicationStatus)) {
+ throw new Error('Expected argument of type pb.ReplicationStatus');
+ }
+ return Buffer.from(arg.serializeBinary());
+}
+
+function deserialize_pb_ReplicationStatus(buffer_arg) {
+ return replication_pb.ReplicationStatus.deserializeBinary(new Uint8Array(buffer_arg));
+}
+
+function serialize_pb_SignedSubscription(arg) {
+ if (!(arg instanceof replication_pb.SignedSubscription)) {
+ throw new Error('Expected argument of type pb.SignedSubscription');
+ }
+ return Buffer.from(arg.serializeBinary());
+}
+
+function deserialize_pb_SignedSubscription(buffer_arg) {
+ return replication_pb.SignedSubscription.deserializeBinary(new Uint8Array(buffer_arg));
+}
+
+function serialize_pb_Subscription(arg) {
+ if (!(arg instanceof replication_pb.Subscription)) {
+ throw new Error('Expected argument of type pb.Subscription');
+ }
+ return Buffer.from(arg.serializeBinary());
+}
+
+function deserialize_pb_Subscription(buffer_arg) {
+ return replication_pb.Subscription.deserializeBinary(new Uint8Array(buffer_arg));
+}
+
+function serialize_pb_SubscriptionUpdate(arg) {
+ if (!(arg instanceof replication_pb.SubscriptionUpdate)) {
+ throw new Error('Expected argument of type pb.SubscriptionUpdate');
+ }
+ return Buffer.from(arg.serializeBinary());
+}
+
+function deserialize_pb_SubscriptionUpdate(buffer_arg) {
+ return replication_pb.SubscriptionUpdate.deserializeBinary(new Uint8Array(buffer_arg));
+}
+
+
+// The replicator provides replication services.
+var replicatorService = exports.replicatorService = {
+ // Add is used to add a replication to this server, changing it's status from reserved to active.
+add: {
+ path: '/pb.replicator/Add',
+ requestStream: false,
+ responseStream: true,
+ requestType: replication_pb.Subscription,
+ responseType: replication_pb.ReplicationStatus,
+ requestSerialize: serialize_pb_Subscription,
+ requestDeserialize: deserialize_pb_Subscription,
+ responseSerialize: serialize_pb_ReplicationStatus,
+ responseDeserialize: deserialize_pb_ReplicationStatus,
+ },
+ // Status returns an updating stream of the replication status on the server.
+status: {
+ path: '/pb.replicator/Status',
+ requestStream: false,
+ responseStream: true,
+ requestType: replication_pb.Subscription,
+ responseType: replication_pb.ReplicationStatus,
+ requestSerialize: serialize_pb_Subscription,
+ requestDeserialize: deserialize_pb_Subscription,
+ responseSerialize: serialize_pb_ReplicationStatus,
+ responseDeserialize: deserialize_pb_ReplicationStatus,
+ },
+ // GetSubscriptionUpdate returns the latest version of subscribed replication
+getSubscriptionUpdate: {
+ path: '/pb.replicator/GetSubscriptionUpdate',
+ requestStream: false,
+ responseStream: false,
+ requestType: replication_pb.Subscription,
+ responseType: replication_pb.SubscriptionUpdate,
+ requestSerialize: serialize_pb_Subscription,
+ requestDeserialize: deserialize_pb_Subscription,
+ responseSerialize: serialize_pb_SubscriptionUpdate,
+ responseDeserialize: deserialize_pb_SubscriptionUpdate,
+ },
+ // SubmitReplication is used by client agents to start replications, after they
+// have uploaded the files and retrieved the cid, and collected servers to replicate too.
+submitReplication: {
+ path: '/pb.replicator/SubmitReplication',
+ requestStream: false,
+ responseStream: true,
+ requestType: replication_pb.SignedSubscription,
+ responseType: replication_pb.ReplicationStatus,
+ requestSerialize: serialize_pb_SignedSubscription,
+ requestDeserialize: deserialize_pb_SignedSubscription,
+ responseSerialize: serialize_pb_ReplicationStatus,
+ responseDeserialize: deserialize_pb_ReplicationStatus,
+ },
+};
+
+exports.replicatorClient = grpc.makeGenericClientConstructor(replicatorService);
diff --git a/js/replication_pb.js b/js/replication_pb.js
new file mode 100644
index 0000000..b7be4a2
--- /dev/null
+++ b/js/replication_pb.js
@@ -0,0 +1,1811 @@
+// source: replication.proto
+/**
+ * @fileoverview
+ * @enhanceable
+ * @suppress {messageConventions} JS Compiler reports an error if a variable or
+ * field starts with 'MSG_' and isn't a translatable message.
+ * @public
+ */
+// GENERATED CODE -- DO NOT EDIT!
+
+var jspb = require('google-protobuf');
+var goog = jspb;
+var global = Function('return this')();
+
+goog.exportSymbol('proto.pb.AddrInfo', null, global);
+goog.exportSymbol('proto.pb.Replication', null, global);
+goog.exportSymbol('proto.pb.ReplicationStatus', null, global);
+goog.exportSymbol('proto.pb.ServerSource', null, global);
+goog.exportSymbol('proto.pb.SignedSubscription', null, global);
+goog.exportSymbol('proto.pb.Subscription', null, global);
+goog.exportSymbol('proto.pb.SubscriptionUpdate', null, global);
+/**
+ * Generated by JsPbCodeGenerator.
+ * @param {Array=} opt_data Optional initial data array, typically from a
+ * server response, or constructed directly in Javascript. The array is used
+ * in place and becomes part of the constructed object. It is not cloned.
+ * If no data is provided, the constructed object will be empty, but still
+ * valid.
+ * @extends {jspb.Message}
+ * @constructor
+ */
+proto.pb.Replication = function(opt_data) {
+ jspb.Message.initialize(this, opt_data, 0, -1, proto.pb.Replication.repeatedFields_, null);
+};
+goog.inherits(proto.pb.Replication, jspb.Message);
+if (goog.DEBUG && !COMPILED) {
+ /**
+ * @public
+ * @override
+ */
+ proto.pb.Replication.displayName = 'proto.pb.Replication';
+}
+/**
+ * Generated by JsPbCodeGenerator.
+ * @param {Array=} opt_data Optional initial data array, typically from a
+ * server response, or constructed directly in Javascript. The array is used
+ * in place and becomes part of the constructed object. It is not cloned.
+ * If no data is provided, the constructed object will be empty, but still
+ * valid.
+ * @extends {jspb.Message}
+ * @constructor
+ */
+proto.pb.ServerSource = function(opt_data) {
+ jspb.Message.initialize(this, opt_data, 0, -1, null, null);
+};
+goog.inherits(proto.pb.ServerSource, jspb.Message);
+if (goog.DEBUG && !COMPILED) {
+ /**
+ * @public
+ * @override
+ */
+ proto.pb.ServerSource.displayName = 'proto.pb.ServerSource';
+}
+/**
+ * Generated by JsPbCodeGenerator.
+ * @param {Array=} opt_data Optional initial data array, typically from a
+ * server response, or constructed directly in Javascript. The array is used
+ * in place and becomes part of the constructed object. It is not cloned.
+ * If no data is provided, the constructed object will be empty, but still
+ * valid.
+ * @extends {jspb.Message}
+ * @constructor
+ */
+proto.pb.AddrInfo = function(opt_data) {
+ jspb.Message.initialize(this, opt_data, 0, -1, proto.pb.AddrInfo.repeatedFields_, null);
+};
+goog.inherits(proto.pb.AddrInfo, jspb.Message);
+if (goog.DEBUG && !COMPILED) {
+ /**
+ * @public
+ * @override
+ */
+ proto.pb.AddrInfo.displayName = 'proto.pb.AddrInfo';
+}
+/**
+ * Generated by JsPbCodeGenerator.
+ * @param {Array=} opt_data Optional initial data array, typically from a
+ * server response, or constructed directly in Javascript. The array is used
+ * in place and becomes part of the constructed object. It is not cloned.
+ * If no data is provided, the constructed object will be empty, but still
+ * valid.
+ * @extends {jspb.Message}
+ * @constructor
+ */
+proto.pb.Subscription = function(opt_data) {
+ jspb.Message.initialize(this, opt_data, 0, -1, null, null);
+};
+goog.inherits(proto.pb.Subscription, jspb.Message);
+if (goog.DEBUG && !COMPILED) {
+ /**
+ * @public
+ * @override
+ */
+ proto.pb.Subscription.displayName = 'proto.pb.Subscription';
+}
+/**
+ * Generated by JsPbCodeGenerator.
+ * @param {Array=} opt_data Optional initial data array, typically from a
+ * server response, or constructed directly in Javascript. The array is used
+ * in place and becomes part of the constructed object. It is not cloned.
+ * If no data is provided, the constructed object will be empty, but still
+ * valid.
+ * @extends {jspb.Message}
+ * @constructor
+ */
+proto.pb.ReplicationStatus = function(opt_data) {
+ jspb.Message.initialize(this, opt_data, 0, -1, null, null);
+};
+goog.inherits(proto.pb.ReplicationStatus, jspb.Message);
+if (goog.DEBUG && !COMPILED) {
+ /**
+ * @public
+ * @override
+ */
+ proto.pb.ReplicationStatus.displayName = 'proto.pb.ReplicationStatus';
+}
+/**
+ * Generated by JsPbCodeGenerator.
+ * @param {Array=} opt_data Optional initial data array, typically from a
+ * server response, or constructed directly in Javascript. The array is used
+ * in place and becomes part of the constructed object. It is not cloned.
+ * If no data is provided, the constructed object will be empty, but still
+ * valid.
+ * @extends {jspb.Message}
+ * @constructor
+ */
+proto.pb.SubscriptionUpdate = function(opt_data) {
+ jspb.Message.initialize(this, opt_data, 0, -1, null, null);
+};
+goog.inherits(proto.pb.SubscriptionUpdate, jspb.Message);
+if (goog.DEBUG && !COMPILED) {
+ /**
+ * @public
+ * @override
+ */
+ proto.pb.SubscriptionUpdate.displayName = 'proto.pb.SubscriptionUpdate';
+}
+/**
+ * Generated by JsPbCodeGenerator.
+ * @param {Array=} opt_data Optional initial data array, typically from a
+ * server response, or constructed directly in Javascript. The array is used
+ * in place and becomes part of the constructed object. It is not cloned.
+ * If no data is provided, the constructed object will be empty, but still
+ * valid.
+ * @extends {jspb.Message}
+ * @constructor
+ */
+proto.pb.SignedSubscription = function(opt_data) {
+ jspb.Message.initialize(this, opt_data, 0, -1, null, null);
+};
+goog.inherits(proto.pb.SignedSubscription, jspb.Message);
+if (goog.DEBUG && !COMPILED) {
+ /**
+ * @public
+ * @override
+ */
+ proto.pb.SignedSubscription.displayName = 'proto.pb.SignedSubscription';
+}
+
+/**
+ * List of repeated fields within this message type.
+ * @private {!Array}
+ * @const
+ */
+proto.pb.Replication.repeatedFields_ = [2,3];
+
+
+
+if (jspb.Message.GENERATE_TO_OBJECT) {
+/**
+ * Creates an object representation of this proto.
+ * Field names that are reserved in JavaScript and will be renamed to pb_name.
+ * Optional fields that are not set will be set to undefined.
+ * To access a reserved field use, foo.pb_, eg, foo.pb_default.
+ * For the list of reserved names please see:
+ * net/proto2/compiler/js/internal/generator.cc#kKeyword.
+ * @param {boolean=} opt_includeInstance Deprecated. whether to include the
+ * JSPB instance for transitional soy proto support:
+ * http://goto/soy-param-migration
+ * @return {!Object}
+ */
+proto.pb.Replication.prototype.toObject = function(opt_includeInstance) {
+ return proto.pb.Replication.toObject(opt_includeInstance, this);
+};
+
+
+/**
+ * Static version of the {@see toObject} method.
+ * @param {boolean|undefined} includeInstance Deprecated. Whether to include
+ * the JSPB instance for transitional soy proto support:
+ * http://goto/soy-param-migration
+ * @param {!proto.pb.Replication} msg The msg instance to transform.
+ * @return {!Object}
+ * @suppress {unusedLocalVariables} f is only used for nested messages
+ */
+proto.pb.Replication.toObject = function(includeInstance, msg) {
+ var f, obj = {
+ header: jspb.Message.getFieldWithDefault(msg, 1, ""),
+ cidsBytesList: msg.getCidsBytesList_asB64(),
+ serversList: jspb.Message.toObjectList(msg.getServersList(),
+ proto.pb.ServerSource.toObject, includeInstance),
+ replicationFactor: jspb.Message.getFieldWithDefault(msg, 4, 0),
+ refreshIntervalSeconds: jspb.Message.getFieldWithDefault(msg, 5, 0),
+ serverDownDelaySeconds: jspb.Message.getFieldWithDefault(msg, 6, 0)
+ };
+
+ if (includeInstance) {
+ obj.$jspbMessageInstance = msg;
+ }
+ return obj;
+};
+}
+
+
+/**
+ * Deserializes binary data (in protobuf wire format).
+ * @param {jspb.ByteSource} bytes The bytes to deserialize.
+ * @return {!proto.pb.Replication}
+ */
+proto.pb.Replication.deserializeBinary = function(bytes) {
+ var reader = new jspb.BinaryReader(bytes);
+ var msg = new proto.pb.Replication;
+ return proto.pb.Replication.deserializeBinaryFromReader(msg, reader);
+};
+
+
+/**
+ * Deserializes binary data (in protobuf wire format) from the
+ * given reader into the given message object.
+ * @param {!proto.pb.Replication} msg The message object to deserialize into.
+ * @param {!jspb.BinaryReader} reader The BinaryReader to use.
+ * @return {!proto.pb.Replication}
+ */
+proto.pb.Replication.deserializeBinaryFromReader = function(msg, reader) {
+ while (reader.nextField()) {
+ if (reader.isEndGroup()) {
+ break;
+ }
+ var field = reader.getFieldNumber();
+ switch (field) {
+ case 1:
+ var value = /** @type {string} */ (reader.readString());
+ msg.setHeader(value);
+ break;
+ case 2:
+ var value = /** @type {!Uint8Array} */ (reader.readBytes());
+ msg.addCidsBytes(value);
+ break;
+ case 3:
+ var value = new proto.pb.ServerSource;
+ reader.readMessage(value,proto.pb.ServerSource.deserializeBinaryFromReader);
+ msg.addServers(value);
+ break;
+ case 4:
+ var value = /** @type {number} */ (reader.readInt32());
+ msg.setReplicationFactor(value);
+ break;
+ case 5:
+ var value = /** @type {number} */ (reader.readInt32());
+ msg.setRefreshIntervalSeconds(value);
+ break;
+ case 6:
+ var value = /** @type {number} */ (reader.readInt32());
+ msg.setServerDownDelaySeconds(value);
+ break;
+ default:
+ reader.skipField();
+ break;
+ }
+ }
+ return msg;
+};
+
+
+/**
+ * Serializes the message to binary data (in protobuf wire format).
+ * @return {!Uint8Array}
+ */
+proto.pb.Replication.prototype.serializeBinary = function() {
+ var writer = new jspb.BinaryWriter();
+ proto.pb.Replication.serializeBinaryToWriter(this, writer);
+ return writer.getResultBuffer();
+};
+
+
+/**
+ * Serializes the given message to binary data (in protobuf wire
+ * format), writing to the given BinaryWriter.
+ * @param {!proto.pb.Replication} message
+ * @param {!jspb.BinaryWriter} writer
+ * @suppress {unusedLocalVariables} f is only used for nested messages
+ */
+proto.pb.Replication.serializeBinaryToWriter = function(message, writer) {
+ var f = undefined;
+ f = message.getHeader();
+ if (f.length > 0) {
+ writer.writeString(
+ 1,
+ f
+ );
+ }
+ f = message.getCidsBytesList_asU8();
+ if (f.length > 0) {
+ writer.writeRepeatedBytes(
+ 2,
+ f
+ );
+ }
+ f = message.getServersList();
+ if (f.length > 0) {
+ writer.writeRepeatedMessage(
+ 3,
+ f,
+ proto.pb.ServerSource.serializeBinaryToWriter
+ );
+ }
+ f = message.getReplicationFactor();
+ if (f !== 0) {
+ writer.writeInt32(
+ 4,
+ f
+ );
+ }
+ f = message.getRefreshIntervalSeconds();
+ if (f !== 0) {
+ writer.writeInt32(
+ 5,
+ f
+ );
+ }
+ f = message.getServerDownDelaySeconds();
+ if (f !== 0) {
+ writer.writeInt32(
+ 6,
+ f
+ );
+ }
+};
+
+
+/**
+ * optional string header = 1;
+ * @return {string}
+ */
+proto.pb.Replication.prototype.getHeader = function() {
+ return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 1, ""));
+};
+
+
+/**
+ * @param {string} value
+ * @return {!proto.pb.Replication} returns this
+ */
+proto.pb.Replication.prototype.setHeader = function(value) {
+ return jspb.Message.setProto3StringField(this, 1, value);
+};
+
+
+/**
+ * repeated bytes cids_bytes = 2;
+ * @return {!(Array|Array)}
+ */
+proto.pb.Replication.prototype.getCidsBytesList = function() {
+ return /** @type {!(Array|Array)} */ (jspb.Message.getRepeatedField(this, 2));
+};
+
+
+/**
+ * repeated bytes cids_bytes = 2;
+ * This is a type-conversion wrapper around `getCidsBytesList()`
+ * @return {!Array}
+ */
+proto.pb.Replication.prototype.getCidsBytesList_asB64 = function() {
+ return /** @type {!Array} */ (jspb.Message.bytesListAsB64(
+ this.getCidsBytesList()));
+};
+
+
+/**
+ * repeated bytes cids_bytes = 2;
+ * Note that Uint8Array is not supported on all browsers.
+ * @see http://caniuse.com/Uint8Array
+ * This is a type-conversion wrapper around `getCidsBytesList()`
+ * @return {!Array}
+ */
+proto.pb.Replication.prototype.getCidsBytesList_asU8 = function() {
+ return /** @type {!Array} */ (jspb.Message.bytesListAsU8(
+ this.getCidsBytesList()));
+};
+
+
+/**
+ * @param {!(Array|Array)} value
+ * @return {!proto.pb.Replication} returns this
+ */
+proto.pb.Replication.prototype.setCidsBytesList = function(value) {
+ return jspb.Message.setField(this, 2, value || []);
+};
+
+
+/**
+ * @param {!(string|Uint8Array)} value
+ * @param {number=} opt_index
+ * @return {!proto.pb.Replication} returns this
+ */
+proto.pb.Replication.prototype.addCidsBytes = function(value, opt_index) {
+ return jspb.Message.addToRepeatedField(this, 2, value, opt_index);
+};
+
+
+/**
+ * Clears the list making it empty but non-null.
+ * @return {!proto.pb.Replication} returns this
+ */
+proto.pb.Replication.prototype.clearCidsBytesList = function() {
+ return this.setCidsBytesList([]);
+};
+
+
+/**
+ * repeated ServerSource servers = 3;
+ * @return {!Array}
+ */
+proto.pb.Replication.prototype.getServersList = function() {
+ return /** @type{!Array} */ (
+ jspb.Message.getRepeatedWrapperField(this, proto.pb.ServerSource, 3));
+};
+
+
+/**
+ * @param {!Array} value
+ * @return {!proto.pb.Replication} returns this
+*/
+proto.pb.Replication.prototype.setServersList = function(value) {
+ return jspb.Message.setRepeatedWrapperField(this, 3, value);
+};
+
+
+/**
+ * @param {!proto.pb.ServerSource=} opt_value
+ * @param {number=} opt_index
+ * @return {!proto.pb.ServerSource}
+ */
+proto.pb.Replication.prototype.addServers = function(opt_value, opt_index) {
+ return jspb.Message.addToRepeatedWrapperField(this, 3, opt_value, proto.pb.ServerSource, opt_index);
+};
+
+
+/**
+ * Clears the list making it empty but non-null.
+ * @return {!proto.pb.Replication} returns this
+ */
+proto.pb.Replication.prototype.clearServersList = function() {
+ return this.setServersList([]);
+};
+
+
+/**
+ * optional int32 replication_factor = 4;
+ * @return {number}
+ */
+proto.pb.Replication.prototype.getReplicationFactor = function() {
+ return /** @type {number} */ (jspb.Message.getFieldWithDefault(this, 4, 0));
+};
+
+
+/**
+ * @param {number} value
+ * @return {!proto.pb.Replication} returns this
+ */
+proto.pb.Replication.prototype.setReplicationFactor = function(value) {
+ return jspb.Message.setProto3IntField(this, 4, value);
+};
+
+
+/**
+ * optional int32 refresh_interval_seconds = 5;
+ * @return {number}
+ */
+proto.pb.Replication.prototype.getRefreshIntervalSeconds = function() {
+ return /** @type {number} */ (jspb.Message.getFieldWithDefault(this, 5, 0));
+};
+
+
+/**
+ * @param {number} value
+ * @return {!proto.pb.Replication} returns this
+ */
+proto.pb.Replication.prototype.setRefreshIntervalSeconds = function(value) {
+ return jspb.Message.setProto3IntField(this, 5, value);
+};
+
+
+/**
+ * optional int32 server_down_delay_seconds = 6;
+ * @return {number}
+ */
+proto.pb.Replication.prototype.getServerDownDelaySeconds = function() {
+ return /** @type {number} */ (jspb.Message.getFieldWithDefault(this, 6, 0));
+};
+
+
+/**
+ * @param {number} value
+ * @return {!proto.pb.Replication} returns this
+ */
+proto.pb.Replication.prototype.setServerDownDelaySeconds = function(value) {
+ return jspb.Message.setProto3IntField(this, 6, value);
+};
+
+
+
+
+
+if (jspb.Message.GENERATE_TO_OBJECT) {
+/**
+ * Creates an object representation of this proto.
+ * Field names that are reserved in JavaScript and will be renamed to pb_name.
+ * Optional fields that are not set will be set to undefined.
+ * To access a reserved field use, foo.pb_, eg, foo.pb_default.
+ * For the list of reserved names please see:
+ * net/proto2/compiler/js/internal/generator.cc#kKeyword.
+ * @param {boolean=} opt_includeInstance Deprecated. whether to include the
+ * JSPB instance for transitional soy proto support:
+ * http://goto/soy-param-migration
+ * @return {!Object}
+ */
+proto.pb.ServerSource.prototype.toObject = function(opt_includeInstance) {
+ return proto.pb.ServerSource.toObject(opt_includeInstance, this);
+};
+
+
+/**
+ * Static version of the {@see toObject} method.
+ * @param {boolean|undefined} includeInstance Deprecated. Whether to include
+ * the JSPB instance for transitional soy proto support:
+ * http://goto/soy-param-migration
+ * @param {!proto.pb.ServerSource} msg The msg instance to transform.
+ * @return {!Object}
+ * @suppress {unusedLocalVariables} f is only used for nested messages
+ */
+proto.pb.ServerSource.toObject = function(includeInstance, msg) {
+ var f, obj = {
+ addrInfo: (f = msg.getAddrInfo()) && proto.pb.AddrInfo.toObject(includeInstance, f)
+ };
+
+ if (includeInstance) {
+ obj.$jspbMessageInstance = msg;
+ }
+ return obj;
+};
+}
+
+
+/**
+ * Deserializes binary data (in protobuf wire format).
+ * @param {jspb.ByteSource} bytes The bytes to deserialize.
+ * @return {!proto.pb.ServerSource}
+ */
+proto.pb.ServerSource.deserializeBinary = function(bytes) {
+ var reader = new jspb.BinaryReader(bytes);
+ var msg = new proto.pb.ServerSource;
+ return proto.pb.ServerSource.deserializeBinaryFromReader(msg, reader);
+};
+
+
+/**
+ * Deserializes binary data (in protobuf wire format) from the
+ * given reader into the given message object.
+ * @param {!proto.pb.ServerSource} msg The message object to deserialize into.
+ * @param {!jspb.BinaryReader} reader The BinaryReader to use.
+ * @return {!proto.pb.ServerSource}
+ */
+proto.pb.ServerSource.deserializeBinaryFromReader = function(msg, reader) {
+ while (reader.nextField()) {
+ if (reader.isEndGroup()) {
+ break;
+ }
+ var field = reader.getFieldNumber();
+ switch (field) {
+ case 1:
+ var value = new proto.pb.AddrInfo;
+ reader.readMessage(value,proto.pb.AddrInfo.deserializeBinaryFromReader);
+ msg.setAddrInfo(value);
+ break;
+ default:
+ reader.skipField();
+ break;
+ }
+ }
+ return msg;
+};
+
+
+/**
+ * Serializes the message to binary data (in protobuf wire format).
+ * @return {!Uint8Array}
+ */
+proto.pb.ServerSource.prototype.serializeBinary = function() {
+ var writer = new jspb.BinaryWriter();
+ proto.pb.ServerSource.serializeBinaryToWriter(this, writer);
+ return writer.getResultBuffer();
+};
+
+
+/**
+ * Serializes the given message to binary data (in protobuf wire
+ * format), writing to the given BinaryWriter.
+ * @param {!proto.pb.ServerSource} message
+ * @param {!jspb.BinaryWriter} writer
+ * @suppress {unusedLocalVariables} f is only used for nested messages
+ */
+proto.pb.ServerSource.serializeBinaryToWriter = function(message, writer) {
+ var f = undefined;
+ f = message.getAddrInfo();
+ if (f != null) {
+ writer.writeMessage(
+ 1,
+ f,
+ proto.pb.AddrInfo.serializeBinaryToWriter
+ );
+ }
+};
+
+
+/**
+ * optional AddrInfo addr_info = 1;
+ * @return {?proto.pb.AddrInfo}
+ */
+proto.pb.ServerSource.prototype.getAddrInfo = function() {
+ return /** @type{?proto.pb.AddrInfo} */ (
+ jspb.Message.getWrapperField(this, proto.pb.AddrInfo, 1));
+};
+
+
+/**
+ * @param {?proto.pb.AddrInfo|undefined} value
+ * @return {!proto.pb.ServerSource} returns this
+*/
+proto.pb.ServerSource.prototype.setAddrInfo = function(value) {
+ return jspb.Message.setWrapperField(this, 1, value);
+};
+
+
+/**
+ * Clears the message field making it undefined.
+ * @return {!proto.pb.ServerSource} returns this
+ */
+proto.pb.ServerSource.prototype.clearAddrInfo = function() {
+ return this.setAddrInfo(undefined);
+};
+
+
+/**
+ * Returns whether this field is set.
+ * @return {boolean}
+ */
+proto.pb.ServerSource.prototype.hasAddrInfo = function() {
+ return jspb.Message.getField(this, 1) != null;
+};
+
+
+
+/**
+ * List of repeated fields within this message type.
+ * @private {!Array}
+ * @const
+ */
+proto.pb.AddrInfo.repeatedFields_ = [2];
+
+
+
+if (jspb.Message.GENERATE_TO_OBJECT) {
+/**
+ * Creates an object representation of this proto.
+ * Field names that are reserved in JavaScript and will be renamed to pb_name.
+ * Optional fields that are not set will be set to undefined.
+ * To access a reserved field use, foo.pb_, eg, foo.pb_default.
+ * For the list of reserved names please see:
+ * net/proto2/compiler/js/internal/generator.cc#kKeyword.
+ * @param {boolean=} opt_includeInstance Deprecated. whether to include the
+ * JSPB instance for transitional soy proto support:
+ * http://goto/soy-param-migration
+ * @return {!Object}
+ */
+proto.pb.AddrInfo.prototype.toObject = function(opt_includeInstance) {
+ return proto.pb.AddrInfo.toObject(opt_includeInstance, this);
+};
+
+
+/**
+ * Static version of the {@see toObject} method.
+ * @param {boolean|undefined} includeInstance Deprecated. Whether to include
+ * the JSPB instance for transitional soy proto support:
+ * http://goto/soy-param-migration
+ * @param {!proto.pb.AddrInfo} msg The msg instance to transform.
+ * @return {!Object}
+ * @suppress {unusedLocalVariables} f is only used for nested messages
+ */
+proto.pb.AddrInfo.toObject = function(includeInstance, msg) {
+ var f, obj = {
+ idBytes: msg.getIdBytes_asB64(),
+ addrsBytesList: msg.getAddrsBytesList_asB64(),
+ grpcPort: jspb.Message.getFieldWithDefault(msg, 3, 0)
+ };
+
+ if (includeInstance) {
+ obj.$jspbMessageInstance = msg;
+ }
+ return obj;
+};
+}
+
+
+/**
+ * Deserializes binary data (in protobuf wire format).
+ * @param {jspb.ByteSource} bytes The bytes to deserialize.
+ * @return {!proto.pb.AddrInfo}
+ */
+proto.pb.AddrInfo.deserializeBinary = function(bytes) {
+ var reader = new jspb.BinaryReader(bytes);
+ var msg = new proto.pb.AddrInfo;
+ return proto.pb.AddrInfo.deserializeBinaryFromReader(msg, reader);
+};
+
+
+/**
+ * Deserializes binary data (in protobuf wire format) from the
+ * given reader into the given message object.
+ * @param {!proto.pb.AddrInfo} msg The message object to deserialize into.
+ * @param {!jspb.BinaryReader} reader The BinaryReader to use.
+ * @return {!proto.pb.AddrInfo}
+ */
+proto.pb.AddrInfo.deserializeBinaryFromReader = function(msg, reader) {
+ while (reader.nextField()) {
+ if (reader.isEndGroup()) {
+ break;
+ }
+ var field = reader.getFieldNumber();
+ switch (field) {
+ case 1:
+ var value = /** @type {!Uint8Array} */ (reader.readBytes());
+ msg.setIdBytes(value);
+ break;
+ case 2:
+ var value = /** @type {!Uint8Array} */ (reader.readBytes());
+ msg.addAddrsBytes(value);
+ break;
+ case 3:
+ var value = /** @type {number} */ (reader.readInt32());
+ msg.setGrpcPort(value);
+ break;
+ default:
+ reader.skipField();
+ break;
+ }
+ }
+ return msg;
+};
+
+
+/**
+ * Serializes the message to binary data (in protobuf wire format).
+ * @return {!Uint8Array}
+ */
+proto.pb.AddrInfo.prototype.serializeBinary = function() {
+ var writer = new jspb.BinaryWriter();
+ proto.pb.AddrInfo.serializeBinaryToWriter(this, writer);
+ return writer.getResultBuffer();
+};
+
+
+/**
+ * Serializes the given message to binary data (in protobuf wire
+ * format), writing to the given BinaryWriter.
+ * @param {!proto.pb.AddrInfo} message
+ * @param {!jspb.BinaryWriter} writer
+ * @suppress {unusedLocalVariables} f is only used for nested messages
+ */
+proto.pb.AddrInfo.serializeBinaryToWriter = function(message, writer) {
+ var f = undefined;
+ f = message.getIdBytes_asU8();
+ if (f.length > 0) {
+ writer.writeBytes(
+ 1,
+ f
+ );
+ }
+ f = message.getAddrsBytesList_asU8();
+ if (f.length > 0) {
+ writer.writeRepeatedBytes(
+ 2,
+ f
+ );
+ }
+ f = message.getGrpcPort();
+ if (f !== 0) {
+ writer.writeInt32(
+ 3,
+ f
+ );
+ }
+};
+
+
+/**
+ * optional bytes id_bytes = 1;
+ * @return {!(string|Uint8Array)}
+ */
+proto.pb.AddrInfo.prototype.getIdBytes = function() {
+ return /** @type {!(string|Uint8Array)} */ (jspb.Message.getFieldWithDefault(this, 1, ""));
+};
+
+
+/**
+ * optional bytes id_bytes = 1;
+ * This is a type-conversion wrapper around `getIdBytes()`
+ * @return {string}
+ */
+proto.pb.AddrInfo.prototype.getIdBytes_asB64 = function() {
+ return /** @type {string} */ (jspb.Message.bytesAsB64(
+ this.getIdBytes()));
+};
+
+
+/**
+ * optional bytes id_bytes = 1;
+ * Note that Uint8Array is not supported on all browsers.
+ * @see http://caniuse.com/Uint8Array
+ * This is a type-conversion wrapper around `getIdBytes()`
+ * @return {!Uint8Array}
+ */
+proto.pb.AddrInfo.prototype.getIdBytes_asU8 = function() {
+ return /** @type {!Uint8Array} */ (jspb.Message.bytesAsU8(
+ this.getIdBytes()));
+};
+
+
+/**
+ * @param {!(string|Uint8Array)} value
+ * @return {!proto.pb.AddrInfo} returns this
+ */
+proto.pb.AddrInfo.prototype.setIdBytes = function(value) {
+ return jspb.Message.setProto3BytesField(this, 1, value);
+};
+
+
+/**
+ * repeated bytes addrs_bytes = 2;
+ * @return {!(Array|Array)}
+ */
+proto.pb.AddrInfo.prototype.getAddrsBytesList = function() {
+ return /** @type {!(Array|Array)} */ (jspb.Message.getRepeatedField(this, 2));
+};
+
+
+/**
+ * repeated bytes addrs_bytes = 2;
+ * This is a type-conversion wrapper around `getAddrsBytesList()`
+ * @return {!Array}
+ */
+proto.pb.AddrInfo.prototype.getAddrsBytesList_asB64 = function() {
+ return /** @type {!Array} */ (jspb.Message.bytesListAsB64(
+ this.getAddrsBytesList()));
+};
+
+
+/**
+ * repeated bytes addrs_bytes = 2;
+ * Note that Uint8Array is not supported on all browsers.
+ * @see http://caniuse.com/Uint8Array
+ * This is a type-conversion wrapper around `getAddrsBytesList()`
+ * @return {!Array}
+ */
+proto.pb.AddrInfo.prototype.getAddrsBytesList_asU8 = function() {
+ return /** @type {!Array} */ (jspb.Message.bytesListAsU8(
+ this.getAddrsBytesList()));
+};
+
+
+/**
+ * @param {!(Array|Array)} value
+ * @return {!proto.pb.AddrInfo} returns this
+ */
+proto.pb.AddrInfo.prototype.setAddrsBytesList = function(value) {
+ return jspb.Message.setField(this, 2, value || []);
+};
+
+
+/**
+ * @param {!(string|Uint8Array)} value
+ * @param {number=} opt_index
+ * @return {!proto.pb.AddrInfo} returns this
+ */
+proto.pb.AddrInfo.prototype.addAddrsBytes = function(value, opt_index) {
+ return jspb.Message.addToRepeatedField(this, 2, value, opt_index);
+};
+
+
+/**
+ * Clears the list making it empty but non-null.
+ * @return {!proto.pb.AddrInfo} returns this
+ */
+proto.pb.AddrInfo.prototype.clearAddrsBytesList = function() {
+ return this.setAddrsBytesList([]);
+};
+
+
+/**
+ * optional int32 grpc_port = 3;
+ * @return {number}
+ */
+proto.pb.AddrInfo.prototype.getGrpcPort = function() {
+ return /** @type {number} */ (jspb.Message.getFieldWithDefault(this, 3, 0));
+};
+
+
+/**
+ * @param {number} value
+ * @return {!proto.pb.AddrInfo} returns this
+ */
+proto.pb.AddrInfo.prototype.setGrpcPort = function(value) {
+ return jspb.Message.setProto3IntField(this, 3, value);
+};
+
+
+
+
+
+if (jspb.Message.GENERATE_TO_OBJECT) {
+/**
+ * Creates an object representation of this proto.
+ * Field names that are reserved in JavaScript and will be renamed to pb_name.
+ * Optional fields that are not set will be set to undefined.
+ * To access a reserved field use, foo.pb_, eg, foo.pb_default.
+ * For the list of reserved names please see:
+ * net/proto2/compiler/js/internal/generator.cc#kKeyword.
+ * @param {boolean=} opt_includeInstance Deprecated. whether to include the
+ * JSPB instance for transitional soy proto support:
+ * http://goto/soy-param-migration
+ * @return {!Object}
+ */
+proto.pb.Subscription.prototype.toObject = function(opt_includeInstance) {
+ return proto.pb.Subscription.toObject(opt_includeInstance, this);
+};
+
+
+/**
+ * Static version of the {@see toObject} method.
+ * @param {boolean|undefined} includeInstance Deprecated. Whether to include
+ * the JSPB instance for transitional soy proto support:
+ * http://goto/soy-param-migration
+ * @param {!proto.pb.Subscription} msg The msg instance to transform.
+ * @return {!Object}
+ * @suppress {unusedLocalVariables} f is only used for nested messages
+ */
+proto.pb.Subscription.toObject = function(includeInstance, msg) {
+ var f, obj = {
+ topic: jspb.Message.getFieldWithDefault(msg, 1, ""),
+ authorIdBytes: msg.getAuthorIdBytes_asB64(),
+ remove: jspb.Message.getBooleanFieldWithDefault(msg, 3, false)
+ };
+
+ if (includeInstance) {
+ obj.$jspbMessageInstance = msg;
+ }
+ return obj;
+};
+}
+
+
+/**
+ * Deserializes binary data (in protobuf wire format).
+ * @param {jspb.ByteSource} bytes The bytes to deserialize.
+ * @return {!proto.pb.Subscription}
+ */
+proto.pb.Subscription.deserializeBinary = function(bytes) {
+ var reader = new jspb.BinaryReader(bytes);
+ var msg = new proto.pb.Subscription;
+ return proto.pb.Subscription.deserializeBinaryFromReader(msg, reader);
+};
+
+
+/**
+ * Deserializes binary data (in protobuf wire format) from the
+ * given reader into the given message object.
+ * @param {!proto.pb.Subscription} msg The message object to deserialize into.
+ * @param {!jspb.BinaryReader} reader The BinaryReader to use.
+ * @return {!proto.pb.Subscription}
+ */
+proto.pb.Subscription.deserializeBinaryFromReader = function(msg, reader) {
+ while (reader.nextField()) {
+ if (reader.isEndGroup()) {
+ break;
+ }
+ var field = reader.getFieldNumber();
+ switch (field) {
+ case 1:
+ var value = /** @type {string} */ (reader.readString());
+ msg.setTopic(value);
+ break;
+ case 2:
+ var value = /** @type {!Uint8Array} */ (reader.readBytes());
+ msg.setAuthorIdBytes(value);
+ break;
+ case 3:
+ var value = /** @type {boolean} */ (reader.readBool());
+ msg.setRemove(value);
+ break;
+ default:
+ reader.skipField();
+ break;
+ }
+ }
+ return msg;
+};
+
+
+/**
+ * Serializes the message to binary data (in protobuf wire format).
+ * @return {!Uint8Array}
+ */
+proto.pb.Subscription.prototype.serializeBinary = function() {
+ var writer = new jspb.BinaryWriter();
+ proto.pb.Subscription.serializeBinaryToWriter(this, writer);
+ return writer.getResultBuffer();
+};
+
+
+/**
+ * Serializes the given message to binary data (in protobuf wire
+ * format), writing to the given BinaryWriter.
+ * @param {!proto.pb.Subscription} message
+ * @param {!jspb.BinaryWriter} writer
+ * @suppress {unusedLocalVariables} f is only used for nested messages
+ */
+proto.pb.Subscription.serializeBinaryToWriter = function(message, writer) {
+ var f = undefined;
+ f = message.getTopic();
+ if (f.length > 0) {
+ writer.writeString(
+ 1,
+ f
+ );
+ }
+ f = message.getAuthorIdBytes_asU8();
+ if (f.length > 0) {
+ writer.writeBytes(
+ 2,
+ f
+ );
+ }
+ f = message.getRemove();
+ if (f) {
+ writer.writeBool(
+ 3,
+ f
+ );
+ }
+};
+
+
+/**
+ * optional string topic = 1;
+ * @return {string}
+ */
+proto.pb.Subscription.prototype.getTopic = function() {
+ return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 1, ""));
+};
+
+
+/**
+ * @param {string} value
+ * @return {!proto.pb.Subscription} returns this
+ */
+proto.pb.Subscription.prototype.setTopic = function(value) {
+ return jspb.Message.setProto3StringField(this, 1, value);
+};
+
+
+/**
+ * optional bytes author_id_bytes = 2;
+ * @return {!(string|Uint8Array)}
+ */
+proto.pb.Subscription.prototype.getAuthorIdBytes = function() {
+ return /** @type {!(string|Uint8Array)} */ (jspb.Message.getFieldWithDefault(this, 2, ""));
+};
+
+
+/**
+ * optional bytes author_id_bytes = 2;
+ * This is a type-conversion wrapper around `getAuthorIdBytes()`
+ * @return {string}
+ */
+proto.pb.Subscription.prototype.getAuthorIdBytes_asB64 = function() {
+ return /** @type {string} */ (jspb.Message.bytesAsB64(
+ this.getAuthorIdBytes()));
+};
+
+
+/**
+ * optional bytes author_id_bytes = 2;
+ * Note that Uint8Array is not supported on all browsers.
+ * @see http://caniuse.com/Uint8Array
+ * This is a type-conversion wrapper around `getAuthorIdBytes()`
+ * @return {!Uint8Array}
+ */
+proto.pb.Subscription.prototype.getAuthorIdBytes_asU8 = function() {
+ return /** @type {!Uint8Array} */ (jspb.Message.bytesAsU8(
+ this.getAuthorIdBytes()));
+};
+
+
+/**
+ * @param {!(string|Uint8Array)} value
+ * @return {!proto.pb.Subscription} returns this
+ */
+proto.pb.Subscription.prototype.setAuthorIdBytes = function(value) {
+ return jspb.Message.setProto3BytesField(this, 2, value);
+};
+
+
+/**
+ * optional bool remove = 3;
+ * @return {boolean}
+ */
+proto.pb.Subscription.prototype.getRemove = function() {
+ return /** @type {boolean} */ (jspb.Message.getBooleanFieldWithDefault(this, 3, false));
+};
+
+
+/**
+ * @param {boolean} value
+ * @return {!proto.pb.Subscription} returns this
+ */
+proto.pb.Subscription.prototype.setRemove = function(value) {
+ return jspb.Message.setProto3BooleanField(this, 3, value);
+};
+
+
+
+
+
+if (jspb.Message.GENERATE_TO_OBJECT) {
+/**
+ * Creates an object representation of this proto.
+ * Field names that are reserved in JavaScript and will be renamed to pb_name.
+ * Optional fields that are not set will be set to undefined.
+ * To access a reserved field use, foo.pb_, eg, foo.pb_default.
+ * For the list of reserved names please see:
+ * net/proto2/compiler/js/internal/generator.cc#kKeyword.
+ * @param {boolean=} opt_includeInstance Deprecated. whether to include the
+ * JSPB instance for transitional soy proto support:
+ * http://goto/soy-param-migration
+ * @return {!Object}
+ */
+proto.pb.ReplicationStatus.prototype.toObject = function(opt_includeInstance) {
+ return proto.pb.ReplicationStatus.toObject(opt_includeInstance, this);
+};
+
+
+/**
+ * Static version of the {@see toObject} method.
+ * @param {boolean|undefined} includeInstance Deprecated. Whether to include
+ * the JSPB instance for transitional soy proto support:
+ * http://goto/soy-param-migration
+ * @param {!proto.pb.ReplicationStatus} msg The msg instance to transform.
+ * @return {!Object}
+ * @suppress {unusedLocalVariables} f is only used for nested messages
+ */
+proto.pb.ReplicationStatus.toObject = function(includeInstance, msg) {
+ var f, obj = {
+ ok: jspb.Message.getBooleanFieldWithDefault(msg, 1, false),
+ isActive: jspb.Message.getBooleanFieldWithDefault(msg, 2, false),
+ currentVersion: jspb.Message.getFieldWithDefault(msg, 3, 0),
+ targetVersion: jspb.Message.getFieldWithDefault(msg, 4, 0)
+ };
+
+ if (includeInstance) {
+ obj.$jspbMessageInstance = msg;
+ }
+ return obj;
+};
+}
+
+
+/**
+ * Deserializes binary data (in protobuf wire format).
+ * @param {jspb.ByteSource} bytes The bytes to deserialize.
+ * @return {!proto.pb.ReplicationStatus}
+ */
+proto.pb.ReplicationStatus.deserializeBinary = function(bytes) {
+ var reader = new jspb.BinaryReader(bytes);
+ var msg = new proto.pb.ReplicationStatus;
+ return proto.pb.ReplicationStatus.deserializeBinaryFromReader(msg, reader);
+};
+
+
+/**
+ * Deserializes binary data (in protobuf wire format) from the
+ * given reader into the given message object.
+ * @param {!proto.pb.ReplicationStatus} msg The message object to deserialize into.
+ * @param {!jspb.BinaryReader} reader The BinaryReader to use.
+ * @return {!proto.pb.ReplicationStatus}
+ */
+proto.pb.ReplicationStatus.deserializeBinaryFromReader = function(msg, reader) {
+ while (reader.nextField()) {
+ if (reader.isEndGroup()) {
+ break;
+ }
+ var field = reader.getFieldNumber();
+ switch (field) {
+ case 1:
+ var value = /** @type {boolean} */ (reader.readBool());
+ msg.setOk(value);
+ break;
+ case 2:
+ var value = /** @type {boolean} */ (reader.readBool());
+ msg.setIsActive(value);
+ break;
+ case 3:
+ var value = /** @type {number} */ (reader.readInt64());
+ msg.setCurrentVersion(value);
+ break;
+ case 4:
+ var value = /** @type {number} */ (reader.readInt64());
+ msg.setTargetVersion(value);
+ break;
+ default:
+ reader.skipField();
+ break;
+ }
+ }
+ return msg;
+};
+
+
+/**
+ * Serializes the message to binary data (in protobuf wire format).
+ * @return {!Uint8Array}
+ */
+proto.pb.ReplicationStatus.prototype.serializeBinary = function() {
+ var writer = new jspb.BinaryWriter();
+ proto.pb.ReplicationStatus.serializeBinaryToWriter(this, writer);
+ return writer.getResultBuffer();
+};
+
+
+/**
+ * Serializes the given message to binary data (in protobuf wire
+ * format), writing to the given BinaryWriter.
+ * @param {!proto.pb.ReplicationStatus} message
+ * @param {!jspb.BinaryWriter} writer
+ * @suppress {unusedLocalVariables} f is only used for nested messages
+ */
+proto.pb.ReplicationStatus.serializeBinaryToWriter = function(message, writer) {
+ var f = undefined;
+ f = message.getOk();
+ if (f) {
+ writer.writeBool(
+ 1,
+ f
+ );
+ }
+ f = message.getIsActive();
+ if (f) {
+ writer.writeBool(
+ 2,
+ f
+ );
+ }
+ f = message.getCurrentVersion();
+ if (f !== 0) {
+ writer.writeInt64(
+ 3,
+ f
+ );
+ }
+ f = message.getTargetVersion();
+ if (f !== 0) {
+ writer.writeInt64(
+ 4,
+ f
+ );
+ }
+};
+
+
+/**
+ * optional bool ok = 1;
+ * @return {boolean}
+ */
+proto.pb.ReplicationStatus.prototype.getOk = function() {
+ return /** @type {boolean} */ (jspb.Message.getBooleanFieldWithDefault(this, 1, false));
+};
+
+
+/**
+ * @param {boolean} value
+ * @return {!proto.pb.ReplicationStatus} returns this
+ */
+proto.pb.ReplicationStatus.prototype.setOk = function(value) {
+ return jspb.Message.setProto3BooleanField(this, 1, value);
+};
+
+
+/**
+ * optional bool is_active = 2;
+ * @return {boolean}
+ */
+proto.pb.ReplicationStatus.prototype.getIsActive = function() {
+ return /** @type {boolean} */ (jspb.Message.getBooleanFieldWithDefault(this, 2, false));
+};
+
+
+/**
+ * @param {boolean} value
+ * @return {!proto.pb.ReplicationStatus} returns this
+ */
+proto.pb.ReplicationStatus.prototype.setIsActive = function(value) {
+ return jspb.Message.setProto3BooleanField(this, 2, value);
+};
+
+
+/**
+ * optional int64 current_version = 3;
+ * @return {number}
+ */
+proto.pb.ReplicationStatus.prototype.getCurrentVersion = function() {
+ return /** @type {number} */ (jspb.Message.getFieldWithDefault(this, 3, 0));
+};
+
+
+/**
+ * @param {number} value
+ * @return {!proto.pb.ReplicationStatus} returns this
+ */
+proto.pb.ReplicationStatus.prototype.setCurrentVersion = function(value) {
+ return jspb.Message.setProto3IntField(this, 3, value);
+};
+
+
+/**
+ * optional int64 target_version = 4;
+ * @return {number}
+ */
+proto.pb.ReplicationStatus.prototype.getTargetVersion = function() {
+ return /** @type {number} */ (jspb.Message.getFieldWithDefault(this, 4, 0));
+};
+
+
+/**
+ * @param {number} value
+ * @return {!proto.pb.ReplicationStatus} returns this
+ */
+proto.pb.ReplicationStatus.prototype.setTargetVersion = function(value) {
+ return jspb.Message.setProto3IntField(this, 4, value);
+};
+
+
+
+
+
+if (jspb.Message.GENERATE_TO_OBJECT) {
+/**
+ * Creates an object representation of this proto.
+ * Field names that are reserved in JavaScript and will be renamed to pb_name.
+ * Optional fields that are not set will be set to undefined.
+ * To access a reserved field use, foo.pb_, eg, foo.pb_default.
+ * For the list of reserved names please see:
+ * net/proto2/compiler/js/internal/generator.cc#kKeyword.
+ * @param {boolean=} opt_includeInstance Deprecated. whether to include the
+ * JSPB instance for transitional soy proto support:
+ * http://goto/soy-param-migration
+ * @return {!Object}
+ */
+proto.pb.SubscriptionUpdate.prototype.toObject = function(opt_includeInstance) {
+ return proto.pb.SubscriptionUpdate.toObject(opt_includeInstance, this);
+};
+
+
+/**
+ * Static version of the {@see toObject} method.
+ * @param {boolean|undefined} includeInstance Deprecated. Whether to include
+ * the JSPB instance for transitional soy proto support:
+ * http://goto/soy-param-migration
+ * @param {!proto.pb.SubscriptionUpdate} msg The msg instance to transform.
+ * @return {!Object}
+ * @suppress {unusedLocalVariables} f is only used for nested messages
+ */
+proto.pb.SubscriptionUpdate.toObject = function(includeInstance, msg) {
+ var f, obj = {
+ version: jspb.Message.getFieldWithDefault(msg, 1, 0),
+ replicationBytes: msg.getReplicationBytes_asB64(),
+ signature: msg.getSignature_asB64()
+ };
+
+ if (includeInstance) {
+ obj.$jspbMessageInstance = msg;
+ }
+ return obj;
+};
+}
+
+
+/**
+ * Deserializes binary data (in protobuf wire format).
+ * @param {jspb.ByteSource} bytes The bytes to deserialize.
+ * @return {!proto.pb.SubscriptionUpdate}
+ */
+proto.pb.SubscriptionUpdate.deserializeBinary = function(bytes) {
+ var reader = new jspb.BinaryReader(bytes);
+ var msg = new proto.pb.SubscriptionUpdate;
+ return proto.pb.SubscriptionUpdate.deserializeBinaryFromReader(msg, reader);
+};
+
+
+/**
+ * Deserializes binary data (in protobuf wire format) from the
+ * given reader into the given message object.
+ * @param {!proto.pb.SubscriptionUpdate} msg The message object to deserialize into.
+ * @param {!jspb.BinaryReader} reader The BinaryReader to use.
+ * @return {!proto.pb.SubscriptionUpdate}
+ */
+proto.pb.SubscriptionUpdate.deserializeBinaryFromReader = function(msg, reader) {
+ while (reader.nextField()) {
+ if (reader.isEndGroup()) {
+ break;
+ }
+ var field = reader.getFieldNumber();
+ switch (field) {
+ case 1:
+ var value = /** @type {number} */ (reader.readInt64());
+ msg.setVersion(value);
+ break;
+ case 2:
+ var value = /** @type {!Uint8Array} */ (reader.readBytes());
+ msg.setReplicationBytes(value);
+ break;
+ case 3:
+ var value = /** @type {!Uint8Array} */ (reader.readBytes());
+ msg.setSignature(value);
+ break;
+ default:
+ reader.skipField();
+ break;
+ }
+ }
+ return msg;
+};
+
+
+/**
+ * Serializes the message to binary data (in protobuf wire format).
+ * @return {!Uint8Array}
+ */
+proto.pb.SubscriptionUpdate.prototype.serializeBinary = function() {
+ var writer = new jspb.BinaryWriter();
+ proto.pb.SubscriptionUpdate.serializeBinaryToWriter(this, writer);
+ return writer.getResultBuffer();
+};
+
+
+/**
+ * Serializes the given message to binary data (in protobuf wire
+ * format), writing to the given BinaryWriter.
+ * @param {!proto.pb.SubscriptionUpdate} message
+ * @param {!jspb.BinaryWriter} writer
+ * @suppress {unusedLocalVariables} f is only used for nested messages
+ */
+proto.pb.SubscriptionUpdate.serializeBinaryToWriter = function(message, writer) {
+ var f = undefined;
+ f = message.getVersion();
+ if (f !== 0) {
+ writer.writeInt64(
+ 1,
+ f
+ );
+ }
+ f = message.getReplicationBytes_asU8();
+ if (f.length > 0) {
+ writer.writeBytes(
+ 2,
+ f
+ );
+ }
+ f = message.getSignature_asU8();
+ if (f.length > 0) {
+ writer.writeBytes(
+ 3,
+ f
+ );
+ }
+};
+
+
+/**
+ * optional int64 version = 1;
+ * @return {number}
+ */
+proto.pb.SubscriptionUpdate.prototype.getVersion = function() {
+ return /** @type {number} */ (jspb.Message.getFieldWithDefault(this, 1, 0));
+};
+
+
+/**
+ * @param {number} value
+ * @return {!proto.pb.SubscriptionUpdate} returns this
+ */
+proto.pb.SubscriptionUpdate.prototype.setVersion = function(value) {
+ return jspb.Message.setProto3IntField(this, 1, value);
+};
+
+
+/**
+ * optional bytes replication_bytes = 2;
+ * @return {!(string|Uint8Array)}
+ */
+proto.pb.SubscriptionUpdate.prototype.getReplicationBytes = function() {
+ return /** @type {!(string|Uint8Array)} */ (jspb.Message.getFieldWithDefault(this, 2, ""));
+};
+
+
+/**
+ * optional bytes replication_bytes = 2;
+ * This is a type-conversion wrapper around `getReplicationBytes()`
+ * @return {string}
+ */
+proto.pb.SubscriptionUpdate.prototype.getReplicationBytes_asB64 = function() {
+ return /** @type {string} */ (jspb.Message.bytesAsB64(
+ this.getReplicationBytes()));
+};
+
+
+/**
+ * optional bytes replication_bytes = 2;
+ * Note that Uint8Array is not supported on all browsers.
+ * @see http://caniuse.com/Uint8Array
+ * This is a type-conversion wrapper around `getReplicationBytes()`
+ * @return {!Uint8Array}
+ */
+proto.pb.SubscriptionUpdate.prototype.getReplicationBytes_asU8 = function() {
+ return /** @type {!Uint8Array} */ (jspb.Message.bytesAsU8(
+ this.getReplicationBytes()));
+};
+
+
+/**
+ * @param {!(string|Uint8Array)} value
+ * @return {!proto.pb.SubscriptionUpdate} returns this
+ */
+proto.pb.SubscriptionUpdate.prototype.setReplicationBytes = function(value) {
+ return jspb.Message.setProto3BytesField(this, 2, value);
+};
+
+
+/**
+ * optional bytes signature = 3;
+ * @return {!(string|Uint8Array)}
+ */
+proto.pb.SubscriptionUpdate.prototype.getSignature = function() {
+ return /** @type {!(string|Uint8Array)} */ (jspb.Message.getFieldWithDefault(this, 3, ""));
+};
+
+
+/**
+ * optional bytes signature = 3;
+ * This is a type-conversion wrapper around `getSignature()`
+ * @return {string}
+ */
+proto.pb.SubscriptionUpdate.prototype.getSignature_asB64 = function() {
+ return /** @type {string} */ (jspb.Message.bytesAsB64(
+ this.getSignature()));
+};
+
+
+/**
+ * optional bytes signature = 3;
+ * Note that Uint8Array is not supported on all browsers.
+ * @see http://caniuse.com/Uint8Array
+ * This is a type-conversion wrapper around `getSignature()`
+ * @return {!Uint8Array}
+ */
+proto.pb.SubscriptionUpdate.prototype.getSignature_asU8 = function() {
+ return /** @type {!Uint8Array} */ (jspb.Message.bytesAsU8(
+ this.getSignature()));
+};
+
+
+/**
+ * @param {!(string|Uint8Array)} value
+ * @return {!proto.pb.SubscriptionUpdate} returns this
+ */
+proto.pb.SubscriptionUpdate.prototype.setSignature = function(value) {
+ return jspb.Message.setProto3BytesField(this, 3, value);
+};
+
+
+
+
+
+if (jspb.Message.GENERATE_TO_OBJECT) {
+/**
+ * Creates an object representation of this proto.
+ * Field names that are reserved in JavaScript and will be renamed to pb_name.
+ * Optional fields that are not set will be set to undefined.
+ * To access a reserved field use, foo.pb_, eg, foo.pb_default.
+ * For the list of reserved names please see:
+ * net/proto2/compiler/js/internal/generator.cc#kKeyword.
+ * @param {boolean=} opt_includeInstance Deprecated. whether to include the
+ * JSPB instance for transitional soy proto support:
+ * http://goto/soy-param-migration
+ * @return {!Object}
+ */
+proto.pb.SignedSubscription.prototype.toObject = function(opt_includeInstance) {
+ return proto.pb.SignedSubscription.toObject(opt_includeInstance, this);
+};
+
+
+/**
+ * Static version of the {@see toObject} method.
+ * @param {boolean|undefined} includeInstance Deprecated. Whether to include
+ * the JSPB instance for transitional soy proto support:
+ * http://goto/soy-param-migration
+ * @param {!proto.pb.SignedSubscription} msg The msg instance to transform.
+ * @return {!Object}
+ * @suppress {unusedLocalVariables} f is only used for nested messages
+ */
+proto.pb.SignedSubscription.toObject = function(includeInstance, msg) {
+ var f, obj = {
+ subPart: (f = msg.getSubPart()) && proto.pb.Subscription.toObject(includeInstance, f),
+ updatePart: (f = msg.getUpdatePart()) && proto.pb.SubscriptionUpdate.toObject(includeInstance, f)
+ };
+
+ if (includeInstance) {
+ obj.$jspbMessageInstance = msg;
+ }
+ return obj;
+};
+}
+
+
+/**
+ * Deserializes binary data (in protobuf wire format).
+ * @param {jspb.ByteSource} bytes The bytes to deserialize.
+ * @return {!proto.pb.SignedSubscription}
+ */
+proto.pb.SignedSubscription.deserializeBinary = function(bytes) {
+ var reader = new jspb.BinaryReader(bytes);
+ var msg = new proto.pb.SignedSubscription;
+ return proto.pb.SignedSubscription.deserializeBinaryFromReader(msg, reader);
+};
+
+
+/**
+ * Deserializes binary data (in protobuf wire format) from the
+ * given reader into the given message object.
+ * @param {!proto.pb.SignedSubscription} msg The message object to deserialize into.
+ * @param {!jspb.BinaryReader} reader The BinaryReader to use.
+ * @return {!proto.pb.SignedSubscription}
+ */
+proto.pb.SignedSubscription.deserializeBinaryFromReader = function(msg, reader) {
+ while (reader.nextField()) {
+ if (reader.isEndGroup()) {
+ break;
+ }
+ var field = reader.getFieldNumber();
+ switch (field) {
+ case 1:
+ var value = new proto.pb.Subscription;
+ reader.readMessage(value,proto.pb.Subscription.deserializeBinaryFromReader);
+ msg.setSubPart(value);
+ break;
+ case 2:
+ var value = new proto.pb.SubscriptionUpdate;
+ reader.readMessage(value,proto.pb.SubscriptionUpdate.deserializeBinaryFromReader);
+ msg.setUpdatePart(value);
+ break;
+ default:
+ reader.skipField();
+ break;
+ }
+ }
+ return msg;
+};
+
+
+/**
+ * Serializes the message to binary data (in protobuf wire format).
+ * @return {!Uint8Array}
+ */
+proto.pb.SignedSubscription.prototype.serializeBinary = function() {
+ var writer = new jspb.BinaryWriter();
+ proto.pb.SignedSubscription.serializeBinaryToWriter(this, writer);
+ return writer.getResultBuffer();
+};
+
+
+/**
+ * Serializes the given message to binary data (in protobuf wire
+ * format), writing to the given BinaryWriter.
+ * @param {!proto.pb.SignedSubscription} message
+ * @param {!jspb.BinaryWriter} writer
+ * @suppress {unusedLocalVariables} f is only used for nested messages
+ */
+proto.pb.SignedSubscription.serializeBinaryToWriter = function(message, writer) {
+ var f = undefined;
+ f = message.getSubPart();
+ if (f != null) {
+ writer.writeMessage(
+ 1,
+ f,
+ proto.pb.Subscription.serializeBinaryToWriter
+ );
+ }
+ f = message.getUpdatePart();
+ if (f != null) {
+ writer.writeMessage(
+ 2,
+ f,
+ proto.pb.SubscriptionUpdate.serializeBinaryToWriter
+ );
+ }
+};
+
+
+/**
+ * optional Subscription sub_part = 1;
+ * @return {?proto.pb.Subscription}
+ */
+proto.pb.SignedSubscription.prototype.getSubPart = function() {
+ return /** @type{?proto.pb.Subscription} */ (
+ jspb.Message.getWrapperField(this, proto.pb.Subscription, 1));
+};
+
+
+/**
+ * @param {?proto.pb.Subscription|undefined} value
+ * @return {!proto.pb.SignedSubscription} returns this
+*/
+proto.pb.SignedSubscription.prototype.setSubPart = function(value) {
+ return jspb.Message.setWrapperField(this, 1, value);
+};
+
+
+/**
+ * Clears the message field making it undefined.
+ * @return {!proto.pb.SignedSubscription} returns this
+ */
+proto.pb.SignedSubscription.prototype.clearSubPart = function() {
+ return this.setSubPart(undefined);
+};
+
+
+/**
+ * Returns whether this field is set.
+ * @return {boolean}
+ */
+proto.pb.SignedSubscription.prototype.hasSubPart = function() {
+ return jspb.Message.getField(this, 1) != null;
+};
+
+
+/**
+ * optional SubscriptionUpdate update_part = 2;
+ * @return {?proto.pb.SubscriptionUpdate}
+ */
+proto.pb.SignedSubscription.prototype.getUpdatePart = function() {
+ return /** @type{?proto.pb.SubscriptionUpdate} */ (
+ jspb.Message.getWrapperField(this, proto.pb.SubscriptionUpdate, 2));
+};
+
+
+/**
+ * @param {?proto.pb.SubscriptionUpdate|undefined} value
+ * @return {!proto.pb.SignedSubscription} returns this
+*/
+proto.pb.SignedSubscription.prototype.setUpdatePart = function(value) {
+ return jspb.Message.setWrapperField(this, 2, value);
+};
+
+
+/**
+ * Clears the message field making it undefined.
+ * @return {!proto.pb.SignedSubscription} returns this
+ */
+proto.pb.SignedSubscription.prototype.clearUpdatePart = function() {
+ return this.setUpdatePart(undefined);
+};
+
+
+/**
+ * Returns whether this field is set.
+ * @return {boolean}
+ */
+proto.pb.SignedSubscription.prototype.hasUpdatePart = function() {
+ return jspb.Message.getField(this, 2) != null;
+};
+
+
+goog.object.extend(exports, proto.pb);
diff --git a/js/status_grpc_pb.js b/js/status_grpc_pb.js
index 83106ef..8d36595 100644
--- a/js/status_grpc_pb.js
+++ b/js/status_grpc_pb.js
@@ -42,7 +42,7 @@ function deserialize_pb_VersionResponse(buffer_arg) {
// provides utilities to retrieve api status information from
var StatusAPIService = exports.StatusAPIService = {
// Version is used to retrieve api version information
- version: {
+version: {
path: '/pb.StatusAPI/Version',
requestStream: false,
responseStream: false,
@@ -54,7 +54,7 @@ var StatusAPIService = exports.StatusAPIService = {
responseDeserialize: deserialize_pb_VersionResponse,
},
// Status is used to retrieve api status information.
- status: {
+status: {
path: '/pb.StatusAPI/Status',
requestStream: false,
responseStream: false,
diff --git a/py/replication_pb2.py b/py/replication_pb2.py
new file mode 100644
index 0000000..bca1934
--- /dev/null
+++ b/py/replication_pb2.py
@@ -0,0 +1,464 @@
+# -*- coding: utf-8 -*-
+# Generated by the protocol buffer compiler. DO NOT EDIT!
+# source: replication.proto
+
+import sys
+_b=sys.version_info[0]<3 and (lambda x:x) or (lambda x:x.encode('latin1'))
+from google.protobuf import descriptor as _descriptor
+from google.protobuf import message as _message
+from google.protobuf import reflection as _reflection
+from google.protobuf import symbol_database as _symbol_database
+# @@protoc_insertion_point(imports)
+
+_sym_db = _symbol_database.Default()
+
+
+
+
+DESCRIPTOR = _descriptor.FileDescriptor(
+ name='replication.proto',
+ package='pb',
+ syntax='proto3',
+ serialized_options=None,
+ serialized_pb=_b('\n\x11replication.proto\x12\x02pb\"\xb5\x01\n\x0bReplication\x12\x0e\n\x06header\x18\x01 \x01(\t\x12\x12\n\ncids_bytes\x18\x02 \x03(\x0c\x12!\n\x07servers\x18\x03 \x03(\x0b\x32\x10.pb.ServerSource\x12\x1a\n\x12replication_factor\x18\x04 \x01(\x05\x12 \n\x18refresh_interval_seconds\x18\x05 \x01(\x05\x12!\n\x19server_down_delay_seconds\x18\x06 \x01(\x05\"/\n\x0cServerSource\x12\x1f\n\taddr_info\x18\x01 \x01(\x0b\x32\x0c.pb.AddrInfo\"D\n\x08\x41\x64\x64rInfo\x12\x10\n\x08id_bytes\x18\x01 \x01(\x0c\x12\x13\n\x0b\x61\x64\x64rs_bytes\x18\x02 \x03(\x0c\x12\x11\n\tgrpc_port\x18\x03 \x01(\x05\"F\n\x0cSubscription\x12\r\n\x05topic\x18\x01 \x01(\t\x12\x17\n\x0f\x61uthor_id_bytes\x18\x02 \x01(\x0c\x12\x0e\n\x06remove\x18\x03 \x01(\x08\"c\n\x11ReplicationStatus\x12\n\n\x02ok\x18\x01 \x01(\x08\x12\x11\n\tis_active\x18\x02 \x01(\x08\x12\x17\n\x0f\x63urrent_version\x18\x03 \x01(\x03\x12\x16\n\x0etarget_version\x18\x04 \x01(\x03\"S\n\x12SubscriptionUpdate\x12\x0f\n\x07version\x18\x01 \x01(\x03\x12\x19\n\x11replication_bytes\x18\x02 \x01(\x0c\x12\x11\n\tsignature\x18\x03 \x01(\x0c\"e\n\x12SignedSubscription\x12\"\n\x08sub_part\x18\x01 \x01(\x0b\x32\x10.pb.Subscription\x12+\n\x0bupdate_part\x18\x02 \x01(\x0b\x32\x16.pb.SubscriptionUpdate2\xfc\x01\n\nreplicator\x12\x30\n\x03\x41\x64\x64\x12\x10.pb.Subscription\x1a\x15.pb.ReplicationStatus0\x01\x12\x33\n\x06Status\x12\x10.pb.Subscription\x1a\x15.pb.ReplicationStatus0\x01\x12\x41\n\x15GetSubscriptionUpdate\x12\x10.pb.Subscription\x1a\x16.pb.SubscriptionUpdate\x12\x44\n\x11SubmitReplication\x12\x16.pb.SignedSubscription\x1a\x15.pb.ReplicationStatus0\x01\x62\x06proto3')
+)
+
+
+
+
+_REPLICATION = _descriptor.Descriptor(
+ name='Replication',
+ full_name='pb.Replication',
+ filename=None,
+ file=DESCRIPTOR,
+ containing_type=None,
+ fields=[
+ _descriptor.FieldDescriptor(
+ name='header', full_name='pb.Replication.header', index=0,
+ number=1, type=9, cpp_type=9, label=1,
+ has_default_value=False, default_value=_b("").decode('utf-8'),
+ message_type=None, enum_type=None, containing_type=None,
+ is_extension=False, extension_scope=None,
+ serialized_options=None, file=DESCRIPTOR),
+ _descriptor.FieldDescriptor(
+ name='cids_bytes', full_name='pb.Replication.cids_bytes', index=1,
+ number=2, type=12, cpp_type=9, label=3,
+ has_default_value=False, default_value=[],
+ message_type=None, enum_type=None, containing_type=None,
+ is_extension=False, extension_scope=None,
+ serialized_options=None, file=DESCRIPTOR),
+ _descriptor.FieldDescriptor(
+ name='servers', full_name='pb.Replication.servers', index=2,
+ number=3, type=11, cpp_type=10, label=3,
+ has_default_value=False, default_value=[],
+ message_type=None, enum_type=None, containing_type=None,
+ is_extension=False, extension_scope=None,
+ serialized_options=None, file=DESCRIPTOR),
+ _descriptor.FieldDescriptor(
+ name='replication_factor', full_name='pb.Replication.replication_factor', index=3,
+ number=4, type=5, cpp_type=1, label=1,
+ has_default_value=False, default_value=0,
+ message_type=None, enum_type=None, containing_type=None,
+ is_extension=False, extension_scope=None,
+ serialized_options=None, file=DESCRIPTOR),
+ _descriptor.FieldDescriptor(
+ name='refresh_interval_seconds', full_name='pb.Replication.refresh_interval_seconds', index=4,
+ number=5, type=5, cpp_type=1, label=1,
+ has_default_value=False, default_value=0,
+ message_type=None, enum_type=None, containing_type=None,
+ is_extension=False, extension_scope=None,
+ serialized_options=None, file=DESCRIPTOR),
+ _descriptor.FieldDescriptor(
+ name='server_down_delay_seconds', full_name='pb.Replication.server_down_delay_seconds', index=5,
+ number=6, type=5, cpp_type=1, label=1,
+ has_default_value=False, default_value=0,
+ message_type=None, enum_type=None, containing_type=None,
+ is_extension=False, extension_scope=None,
+ serialized_options=None, file=DESCRIPTOR),
+ ],
+ extensions=[
+ ],
+ nested_types=[],
+ enum_types=[
+ ],
+ serialized_options=None,
+ is_extendable=False,
+ syntax='proto3',
+ extension_ranges=[],
+ oneofs=[
+ ],
+ serialized_start=26,
+ serialized_end=207,
+)
+
+
+_SERVERSOURCE = _descriptor.Descriptor(
+ name='ServerSource',
+ full_name='pb.ServerSource',
+ filename=None,
+ file=DESCRIPTOR,
+ containing_type=None,
+ fields=[
+ _descriptor.FieldDescriptor(
+ name='addr_info', full_name='pb.ServerSource.addr_info', index=0,
+ number=1, type=11, cpp_type=10, label=1,
+ has_default_value=False, default_value=None,
+ message_type=None, enum_type=None, containing_type=None,
+ is_extension=False, extension_scope=None,
+ serialized_options=None, file=DESCRIPTOR),
+ ],
+ extensions=[
+ ],
+ nested_types=[],
+ enum_types=[
+ ],
+ serialized_options=None,
+ is_extendable=False,
+ syntax='proto3',
+ extension_ranges=[],
+ oneofs=[
+ ],
+ serialized_start=209,
+ serialized_end=256,
+)
+
+
+_ADDRINFO = _descriptor.Descriptor(
+ name='AddrInfo',
+ full_name='pb.AddrInfo',
+ filename=None,
+ file=DESCRIPTOR,
+ containing_type=None,
+ fields=[
+ _descriptor.FieldDescriptor(
+ name='id_bytes', full_name='pb.AddrInfo.id_bytes', index=0,
+ number=1, type=12, cpp_type=9, label=1,
+ has_default_value=False, default_value=_b(""),
+ message_type=None, enum_type=None, containing_type=None,
+ is_extension=False, extension_scope=None,
+ serialized_options=None, file=DESCRIPTOR),
+ _descriptor.FieldDescriptor(
+ name='addrs_bytes', full_name='pb.AddrInfo.addrs_bytes', index=1,
+ number=2, type=12, cpp_type=9, label=3,
+ has_default_value=False, default_value=[],
+ message_type=None, enum_type=None, containing_type=None,
+ is_extension=False, extension_scope=None,
+ serialized_options=None, file=DESCRIPTOR),
+ _descriptor.FieldDescriptor(
+ name='grpc_port', full_name='pb.AddrInfo.grpc_port', index=2,
+ number=3, type=5, cpp_type=1, label=1,
+ has_default_value=False, default_value=0,
+ message_type=None, enum_type=None, containing_type=None,
+ is_extension=False, extension_scope=None,
+ serialized_options=None, file=DESCRIPTOR),
+ ],
+ extensions=[
+ ],
+ nested_types=[],
+ enum_types=[
+ ],
+ serialized_options=None,
+ is_extendable=False,
+ syntax='proto3',
+ extension_ranges=[],
+ oneofs=[
+ ],
+ serialized_start=258,
+ serialized_end=326,
+)
+
+
+_SUBSCRIPTION = _descriptor.Descriptor(
+ name='Subscription',
+ full_name='pb.Subscription',
+ filename=None,
+ file=DESCRIPTOR,
+ containing_type=None,
+ fields=[
+ _descriptor.FieldDescriptor(
+ name='topic', full_name='pb.Subscription.topic', index=0,
+ number=1, type=9, cpp_type=9, label=1,
+ has_default_value=False, default_value=_b("").decode('utf-8'),
+ message_type=None, enum_type=None, containing_type=None,
+ is_extension=False, extension_scope=None,
+ serialized_options=None, file=DESCRIPTOR),
+ _descriptor.FieldDescriptor(
+ name='author_id_bytes', full_name='pb.Subscription.author_id_bytes', index=1,
+ number=2, type=12, cpp_type=9, label=1,
+ has_default_value=False, default_value=_b(""),
+ message_type=None, enum_type=None, containing_type=None,
+ is_extension=False, extension_scope=None,
+ serialized_options=None, file=DESCRIPTOR),
+ _descriptor.FieldDescriptor(
+ name='remove', full_name='pb.Subscription.remove', index=2,
+ number=3, type=8, cpp_type=7, label=1,
+ has_default_value=False, default_value=False,
+ message_type=None, enum_type=None, containing_type=None,
+ is_extension=False, extension_scope=None,
+ serialized_options=None, file=DESCRIPTOR),
+ ],
+ extensions=[
+ ],
+ nested_types=[],
+ enum_types=[
+ ],
+ serialized_options=None,
+ is_extendable=False,
+ syntax='proto3',
+ extension_ranges=[],
+ oneofs=[
+ ],
+ serialized_start=328,
+ serialized_end=398,
+)
+
+
+_REPLICATIONSTATUS = _descriptor.Descriptor(
+ name='ReplicationStatus',
+ full_name='pb.ReplicationStatus',
+ filename=None,
+ file=DESCRIPTOR,
+ containing_type=None,
+ fields=[
+ _descriptor.FieldDescriptor(
+ name='ok', full_name='pb.ReplicationStatus.ok', index=0,
+ number=1, type=8, cpp_type=7, label=1,
+ has_default_value=False, default_value=False,
+ message_type=None, enum_type=None, containing_type=None,
+ is_extension=False, extension_scope=None,
+ serialized_options=None, file=DESCRIPTOR),
+ _descriptor.FieldDescriptor(
+ name='is_active', full_name='pb.ReplicationStatus.is_active', index=1,
+ number=2, type=8, cpp_type=7, label=1,
+ has_default_value=False, default_value=False,
+ message_type=None, enum_type=None, containing_type=None,
+ is_extension=False, extension_scope=None,
+ serialized_options=None, file=DESCRIPTOR),
+ _descriptor.FieldDescriptor(
+ name='current_version', full_name='pb.ReplicationStatus.current_version', index=2,
+ number=3, type=3, cpp_type=2, label=1,
+ has_default_value=False, default_value=0,
+ message_type=None, enum_type=None, containing_type=None,
+ is_extension=False, extension_scope=None,
+ serialized_options=None, file=DESCRIPTOR),
+ _descriptor.FieldDescriptor(
+ name='target_version', full_name='pb.ReplicationStatus.target_version', index=3,
+ number=4, type=3, cpp_type=2, label=1,
+ has_default_value=False, default_value=0,
+ message_type=None, enum_type=None, containing_type=None,
+ is_extension=False, extension_scope=None,
+ serialized_options=None, file=DESCRIPTOR),
+ ],
+ extensions=[
+ ],
+ nested_types=[],
+ enum_types=[
+ ],
+ serialized_options=None,
+ is_extendable=False,
+ syntax='proto3',
+ extension_ranges=[],
+ oneofs=[
+ ],
+ serialized_start=400,
+ serialized_end=499,
+)
+
+
+_SUBSCRIPTIONUPDATE = _descriptor.Descriptor(
+ name='SubscriptionUpdate',
+ full_name='pb.SubscriptionUpdate',
+ filename=None,
+ file=DESCRIPTOR,
+ containing_type=None,
+ fields=[
+ _descriptor.FieldDescriptor(
+ name='version', full_name='pb.SubscriptionUpdate.version', index=0,
+ number=1, type=3, cpp_type=2, label=1,
+ has_default_value=False, default_value=0,
+ message_type=None, enum_type=None, containing_type=None,
+ is_extension=False, extension_scope=None,
+ serialized_options=None, file=DESCRIPTOR),
+ _descriptor.FieldDescriptor(
+ name='replication_bytes', full_name='pb.SubscriptionUpdate.replication_bytes', index=1,
+ number=2, type=12, cpp_type=9, label=1,
+ has_default_value=False, default_value=_b(""),
+ message_type=None, enum_type=None, containing_type=None,
+ is_extension=False, extension_scope=None,
+ serialized_options=None, file=DESCRIPTOR),
+ _descriptor.FieldDescriptor(
+ name='signature', full_name='pb.SubscriptionUpdate.signature', index=2,
+ number=3, type=12, cpp_type=9, label=1,
+ has_default_value=False, default_value=_b(""),
+ message_type=None, enum_type=None, containing_type=None,
+ is_extension=False, extension_scope=None,
+ serialized_options=None, file=DESCRIPTOR),
+ ],
+ extensions=[
+ ],
+ nested_types=[],
+ enum_types=[
+ ],
+ serialized_options=None,
+ is_extendable=False,
+ syntax='proto3',
+ extension_ranges=[],
+ oneofs=[
+ ],
+ serialized_start=501,
+ serialized_end=584,
+)
+
+
+_SIGNEDSUBSCRIPTION = _descriptor.Descriptor(
+ name='SignedSubscription',
+ full_name='pb.SignedSubscription',
+ filename=None,
+ file=DESCRIPTOR,
+ containing_type=None,
+ fields=[
+ _descriptor.FieldDescriptor(
+ name='sub_part', full_name='pb.SignedSubscription.sub_part', index=0,
+ number=1, type=11, cpp_type=10, label=1,
+ has_default_value=False, default_value=None,
+ message_type=None, enum_type=None, containing_type=None,
+ is_extension=False, extension_scope=None,
+ serialized_options=None, file=DESCRIPTOR),
+ _descriptor.FieldDescriptor(
+ name='update_part', full_name='pb.SignedSubscription.update_part', index=1,
+ number=2, type=11, cpp_type=10, label=1,
+ has_default_value=False, default_value=None,
+ message_type=None, enum_type=None, containing_type=None,
+ is_extension=False, extension_scope=None,
+ serialized_options=None, file=DESCRIPTOR),
+ ],
+ extensions=[
+ ],
+ nested_types=[],
+ enum_types=[
+ ],
+ serialized_options=None,
+ is_extendable=False,
+ syntax='proto3',
+ extension_ranges=[],
+ oneofs=[
+ ],
+ serialized_start=586,
+ serialized_end=687,
+)
+
+_REPLICATION.fields_by_name['servers'].message_type = _SERVERSOURCE
+_SERVERSOURCE.fields_by_name['addr_info'].message_type = _ADDRINFO
+_SIGNEDSUBSCRIPTION.fields_by_name['sub_part'].message_type = _SUBSCRIPTION
+_SIGNEDSUBSCRIPTION.fields_by_name['update_part'].message_type = _SUBSCRIPTIONUPDATE
+DESCRIPTOR.message_types_by_name['Replication'] = _REPLICATION
+DESCRIPTOR.message_types_by_name['ServerSource'] = _SERVERSOURCE
+DESCRIPTOR.message_types_by_name['AddrInfo'] = _ADDRINFO
+DESCRIPTOR.message_types_by_name['Subscription'] = _SUBSCRIPTION
+DESCRIPTOR.message_types_by_name['ReplicationStatus'] = _REPLICATIONSTATUS
+DESCRIPTOR.message_types_by_name['SubscriptionUpdate'] = _SUBSCRIPTIONUPDATE
+DESCRIPTOR.message_types_by_name['SignedSubscription'] = _SIGNEDSUBSCRIPTION
+_sym_db.RegisterFileDescriptor(DESCRIPTOR)
+
+Replication = _reflection.GeneratedProtocolMessageType('Replication', (_message.Message,), {
+ 'DESCRIPTOR' : _REPLICATION,
+ '__module__' : 'replication_pb2'
+ # @@protoc_insertion_point(class_scope:pb.Replication)
+ })
+_sym_db.RegisterMessage(Replication)
+
+ServerSource = _reflection.GeneratedProtocolMessageType('ServerSource', (_message.Message,), {
+ 'DESCRIPTOR' : _SERVERSOURCE,
+ '__module__' : 'replication_pb2'
+ # @@protoc_insertion_point(class_scope:pb.ServerSource)
+ })
+_sym_db.RegisterMessage(ServerSource)
+
+AddrInfo = _reflection.GeneratedProtocolMessageType('AddrInfo', (_message.Message,), {
+ 'DESCRIPTOR' : _ADDRINFO,
+ '__module__' : 'replication_pb2'
+ # @@protoc_insertion_point(class_scope:pb.AddrInfo)
+ })
+_sym_db.RegisterMessage(AddrInfo)
+
+Subscription = _reflection.GeneratedProtocolMessageType('Subscription', (_message.Message,), {
+ 'DESCRIPTOR' : _SUBSCRIPTION,
+ '__module__' : 'replication_pb2'
+ # @@protoc_insertion_point(class_scope:pb.Subscription)
+ })
+_sym_db.RegisterMessage(Subscription)
+
+ReplicationStatus = _reflection.GeneratedProtocolMessageType('ReplicationStatus', (_message.Message,), {
+ 'DESCRIPTOR' : _REPLICATIONSTATUS,
+ '__module__' : 'replication_pb2'
+ # @@protoc_insertion_point(class_scope:pb.ReplicationStatus)
+ })
+_sym_db.RegisterMessage(ReplicationStatus)
+
+SubscriptionUpdate = _reflection.GeneratedProtocolMessageType('SubscriptionUpdate', (_message.Message,), {
+ 'DESCRIPTOR' : _SUBSCRIPTIONUPDATE,
+ '__module__' : 'replication_pb2'
+ # @@protoc_insertion_point(class_scope:pb.SubscriptionUpdate)
+ })
+_sym_db.RegisterMessage(SubscriptionUpdate)
+
+SignedSubscription = _reflection.GeneratedProtocolMessageType('SignedSubscription', (_message.Message,), {
+ 'DESCRIPTOR' : _SIGNEDSUBSCRIPTION,
+ '__module__' : 'replication_pb2'
+ # @@protoc_insertion_point(class_scope:pb.SignedSubscription)
+ })
+_sym_db.RegisterMessage(SignedSubscription)
+
+
+
+_REPLICATOR = _descriptor.ServiceDescriptor(
+ name='replicator',
+ full_name='pb.replicator',
+ file=DESCRIPTOR,
+ index=0,
+ serialized_options=None,
+ serialized_start=690,
+ serialized_end=942,
+ methods=[
+ _descriptor.MethodDescriptor(
+ name='Add',
+ full_name='pb.replicator.Add',
+ index=0,
+ containing_service=None,
+ input_type=_SUBSCRIPTION,
+ output_type=_REPLICATIONSTATUS,
+ serialized_options=None,
+ ),
+ _descriptor.MethodDescriptor(
+ name='Status',
+ full_name='pb.replicator.Status',
+ index=1,
+ containing_service=None,
+ input_type=_SUBSCRIPTION,
+ output_type=_REPLICATIONSTATUS,
+ serialized_options=None,
+ ),
+ _descriptor.MethodDescriptor(
+ name='GetSubscriptionUpdate',
+ full_name='pb.replicator.GetSubscriptionUpdate',
+ index=2,
+ containing_service=None,
+ input_type=_SUBSCRIPTION,
+ output_type=_SUBSCRIPTIONUPDATE,
+ serialized_options=None,
+ ),
+ _descriptor.MethodDescriptor(
+ name='SubmitReplication',
+ full_name='pb.replicator.SubmitReplication',
+ index=3,
+ containing_service=None,
+ input_type=_SIGNEDSUBSCRIPTION,
+ output_type=_REPLICATIONSTATUS,
+ serialized_options=None,
+ ),
+])
+_sym_db.RegisterServiceDescriptor(_REPLICATOR)
+
+DESCRIPTOR.services_by_name['replicator'] = _REPLICATOR
+
+# @@protoc_insertion_point(module_scope)
diff --git a/py/replication_pb2_grpc.py b/py/replication_pb2_grpc.py
new file mode 100644
index 0000000..abab33e
--- /dev/null
+++ b/py/replication_pb2_grpc.py
@@ -0,0 +1,98 @@
+# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
+import grpc
+
+import replication_pb2 as replication__pb2
+
+
+class replicatorStub(object):
+ """The replicator provides replication services.
+ """
+
+ def __init__(self, channel):
+ """Constructor.
+
+ Args:
+ channel: A grpc.Channel.
+ """
+ self.Add = channel.unary_stream(
+ '/pb.replicator/Add',
+ request_serializer=replication__pb2.Subscription.SerializeToString,
+ response_deserializer=replication__pb2.ReplicationStatus.FromString,
+ )
+ self.Status = channel.unary_stream(
+ '/pb.replicator/Status',
+ request_serializer=replication__pb2.Subscription.SerializeToString,
+ response_deserializer=replication__pb2.ReplicationStatus.FromString,
+ )
+ self.GetSubscriptionUpdate = channel.unary_unary(
+ '/pb.replicator/GetSubscriptionUpdate',
+ request_serializer=replication__pb2.Subscription.SerializeToString,
+ response_deserializer=replication__pb2.SubscriptionUpdate.FromString,
+ )
+ self.SubmitReplication = channel.unary_stream(
+ '/pb.replicator/SubmitReplication',
+ request_serializer=replication__pb2.SignedSubscription.SerializeToString,
+ response_deserializer=replication__pb2.ReplicationStatus.FromString,
+ )
+
+
+class replicatorServicer(object):
+ """The replicator provides replication services.
+ """
+
+ def Add(self, request, context):
+ """Add is used to add a replication to this server, changing it's status from reserved to active.
+ """
+ context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+ context.set_details('Method not implemented!')
+ raise NotImplementedError('Method not implemented!')
+
+ def Status(self, request, context):
+ """Status returns an updating stream of the replication status on the server.
+ """
+ context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+ context.set_details('Method not implemented!')
+ raise NotImplementedError('Method not implemented!')
+
+ def GetSubscriptionUpdate(self, request, context):
+ """GetSubscriptionUpdate returns the latest version of subscribed replication
+ """
+ context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+ context.set_details('Method not implemented!')
+ raise NotImplementedError('Method not implemented!')
+
+ def SubmitReplication(self, request, context):
+ """SubmitReplication is used by client agents to start replications, after they
+ have uploaded the files and retrieved the cid, and collected servers to replicate too.
+ """
+ context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+ context.set_details('Method not implemented!')
+ raise NotImplementedError('Method not implemented!')
+
+
+def add_replicatorServicer_to_server(servicer, server):
+ rpc_method_handlers = {
+ 'Add': grpc.unary_stream_rpc_method_handler(
+ servicer.Add,
+ request_deserializer=replication__pb2.Subscription.FromString,
+ response_serializer=replication__pb2.ReplicationStatus.SerializeToString,
+ ),
+ 'Status': grpc.unary_stream_rpc_method_handler(
+ servicer.Status,
+ request_deserializer=replication__pb2.Subscription.FromString,
+ response_serializer=replication__pb2.ReplicationStatus.SerializeToString,
+ ),
+ 'GetSubscriptionUpdate': grpc.unary_unary_rpc_method_handler(
+ servicer.GetSubscriptionUpdate,
+ request_deserializer=replication__pb2.Subscription.FromString,
+ response_serializer=replication__pb2.SubscriptionUpdate.SerializeToString,
+ ),
+ 'SubmitReplication': grpc.unary_stream_rpc_method_handler(
+ servicer.SubmitReplication,
+ request_deserializer=replication__pb2.SignedSubscription.FromString,
+ response_serializer=replication__pb2.ReplicationStatus.SerializeToString,
+ ),
+ }
+ generic_handler = grpc.method_handlers_generic_handler(
+ 'pb.replicator', rpc_method_handlers)
+ server.add_generic_rpc_handlers((generic_handler,))
diff --git a/ts/replication_pb.d.ts b/ts/replication_pb.d.ts
new file mode 100644
index 0000000..4409d04
--- /dev/null
+++ b/ts/replication_pb.d.ts
@@ -0,0 +1,229 @@
+// package: pb
+// file: replication.proto
+
+import * as jspb from "google-protobuf";
+
+export class Replication extends jspb.Message {
+ getHeader(): string;
+ setHeader(value: string): void;
+
+ clearCidsBytesList(): void;
+ getCidsBytesList(): Array;
+ getCidsBytesList_asU8(): Array;
+ getCidsBytesList_asB64(): Array;
+ setCidsBytesList(value: Array): void;
+ addCidsBytes(value: Uint8Array | string, index?: number): Uint8Array | string;
+
+ clearServersList(): void;
+ getServersList(): Array;
+ setServersList(value: Array): void;
+ addServers(value?: ServerSource, index?: number): ServerSource;
+
+ getReplicationFactor(): number;
+ setReplicationFactor(value: number): void;
+
+ getRefreshIntervalSeconds(): number;
+ setRefreshIntervalSeconds(value: number): void;
+
+ getServerDownDelaySeconds(): number;
+ setServerDownDelaySeconds(value: number): void;
+
+ serializeBinary(): Uint8Array;
+ toObject(includeInstance?: boolean): Replication.AsObject;
+ static toObject(includeInstance: boolean, msg: Replication): Replication.AsObject;
+ static extensions: {[key: number]: jspb.ExtensionFieldInfo};
+ static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo};
+ static serializeBinaryToWriter(message: Replication, writer: jspb.BinaryWriter): void;
+ static deserializeBinary(bytes: Uint8Array): Replication;
+ static deserializeBinaryFromReader(message: Replication, reader: jspb.BinaryReader): Replication;
+}
+
+export namespace Replication {
+ export type AsObject = {
+ header: string,
+ cidsBytesList: Array,
+ serversList: Array,
+ replicationFactor: number,
+ refreshIntervalSeconds: number,
+ serverDownDelaySeconds: number,
+ }
+}
+
+export class ServerSource extends jspb.Message {
+ hasAddrInfo(): boolean;
+ clearAddrInfo(): void;
+ getAddrInfo(): AddrInfo | undefined;
+ setAddrInfo(value?: AddrInfo): void;
+
+ serializeBinary(): Uint8Array;
+ toObject(includeInstance?: boolean): ServerSource.AsObject;
+ static toObject(includeInstance: boolean, msg: ServerSource): ServerSource.AsObject;
+ static extensions: {[key: number]: jspb.ExtensionFieldInfo};
+ static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo};
+ static serializeBinaryToWriter(message: ServerSource, writer: jspb.BinaryWriter): void;
+ static deserializeBinary(bytes: Uint8Array): ServerSource;
+ static deserializeBinaryFromReader(message: ServerSource, reader: jspb.BinaryReader): ServerSource;
+}
+
+export namespace ServerSource {
+ export type AsObject = {
+ addrInfo?: AddrInfo.AsObject,
+ }
+}
+
+export class AddrInfo extends jspb.Message {
+ getIdBytes(): Uint8Array | string;
+ getIdBytes_asU8(): Uint8Array;
+ getIdBytes_asB64(): string;
+ setIdBytes(value: Uint8Array | string): void;
+
+ clearAddrsBytesList(): void;
+ getAddrsBytesList(): Array;
+ getAddrsBytesList_asU8(): Array;
+ getAddrsBytesList_asB64(): Array;
+ setAddrsBytesList(value: Array): void;
+ addAddrsBytes(value: Uint8Array | string, index?: number): Uint8Array | string;
+
+ getGrpcPort(): number;
+ setGrpcPort(value: number): void;
+
+ serializeBinary(): Uint8Array;
+ toObject(includeInstance?: boolean): AddrInfo.AsObject;
+ static toObject(includeInstance: boolean, msg: AddrInfo): AddrInfo.AsObject;
+ static extensions: {[key: number]: jspb.ExtensionFieldInfo};
+ static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo};
+ static serializeBinaryToWriter(message: AddrInfo, writer: jspb.BinaryWriter): void;
+ static deserializeBinary(bytes: Uint8Array): AddrInfo;
+ static deserializeBinaryFromReader(message: AddrInfo, reader: jspb.BinaryReader): AddrInfo;
+}
+
+export namespace AddrInfo {
+ export type AsObject = {
+ idBytes: Uint8Array | string,
+ addrsBytesList: Array,
+ grpcPort: number,
+ }
+}
+
+export class Subscription extends jspb.Message {
+ getTopic(): string;
+ setTopic(value: string): void;
+
+ getAuthorIdBytes(): Uint8Array | string;
+ getAuthorIdBytes_asU8(): Uint8Array;
+ getAuthorIdBytes_asB64(): string;
+ setAuthorIdBytes(value: Uint8Array | string): void;
+
+ getRemove(): boolean;
+ setRemove(value: boolean): void;
+
+ serializeBinary(): Uint8Array;
+ toObject(includeInstance?: boolean): Subscription.AsObject;
+ static toObject(includeInstance: boolean, msg: Subscription): Subscription.AsObject;
+ static extensions: {[key: number]: jspb.ExtensionFieldInfo};
+ static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo};
+ static serializeBinaryToWriter(message: Subscription, writer: jspb.BinaryWriter): void;
+ static deserializeBinary(bytes: Uint8Array): Subscription;
+ static deserializeBinaryFromReader(message: Subscription, reader: jspb.BinaryReader): Subscription;
+}
+
+export namespace Subscription {
+ export type AsObject = {
+ topic: string,
+ authorIdBytes: Uint8Array | string,
+ remove: boolean,
+ }
+}
+
+export class ReplicationStatus extends jspb.Message {
+ getOk(): boolean;
+ setOk(value: boolean): void;
+
+ getIsActive(): boolean;
+ setIsActive(value: boolean): void;
+
+ getCurrentVersion(): number;
+ setCurrentVersion(value: number): void;
+
+ getTargetVersion(): number;
+ setTargetVersion(value: number): void;
+
+ serializeBinary(): Uint8Array;
+ toObject(includeInstance?: boolean): ReplicationStatus.AsObject;
+ static toObject(includeInstance: boolean, msg: ReplicationStatus): ReplicationStatus.AsObject;
+ static extensions: {[key: number]: jspb.ExtensionFieldInfo};
+ static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo};
+ static serializeBinaryToWriter(message: ReplicationStatus, writer: jspb.BinaryWriter): void;
+ static deserializeBinary(bytes: Uint8Array): ReplicationStatus;
+ static deserializeBinaryFromReader(message: ReplicationStatus, reader: jspb.BinaryReader): ReplicationStatus;
+}
+
+export namespace ReplicationStatus {
+ export type AsObject = {
+ ok: boolean,
+ isActive: boolean,
+ currentVersion: number,
+ targetVersion: number,
+ }
+}
+
+export class SubscriptionUpdate extends jspb.Message {
+ getVersion(): number;
+ setVersion(value: number): void;
+
+ getReplicationBytes(): Uint8Array | string;
+ getReplicationBytes_asU8(): Uint8Array;
+ getReplicationBytes_asB64(): string;
+ setReplicationBytes(value: Uint8Array | string): void;
+
+ getSignature(): Uint8Array | string;
+ getSignature_asU8(): Uint8Array;
+ getSignature_asB64(): string;
+ setSignature(value: Uint8Array | string): void;
+
+ serializeBinary(): Uint8Array;
+ toObject(includeInstance?: boolean): SubscriptionUpdate.AsObject;
+ static toObject(includeInstance: boolean, msg: SubscriptionUpdate): SubscriptionUpdate.AsObject;
+ static extensions: {[key: number]: jspb.ExtensionFieldInfo};
+ static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo};
+ static serializeBinaryToWriter(message: SubscriptionUpdate, writer: jspb.BinaryWriter): void;
+ static deserializeBinary(bytes: Uint8Array): SubscriptionUpdate;
+ static deserializeBinaryFromReader(message: SubscriptionUpdate, reader: jspb.BinaryReader): SubscriptionUpdate;
+}
+
+export namespace SubscriptionUpdate {
+ export type AsObject = {
+ version: number,
+ replicationBytes: Uint8Array | string,
+ signature: Uint8Array | string,
+ }
+}
+
+export class SignedSubscription extends jspb.Message {
+ hasSubPart(): boolean;
+ clearSubPart(): void;
+ getSubPart(): Subscription | undefined;
+ setSubPart(value?: Subscription): void;
+
+ hasUpdatePart(): boolean;
+ clearUpdatePart(): void;
+ getUpdatePart(): SubscriptionUpdate | undefined;
+ setUpdatePart(value?: SubscriptionUpdate): void;
+
+ serializeBinary(): Uint8Array;
+ toObject(includeInstance?: boolean): SignedSubscription.AsObject;
+ static toObject(includeInstance: boolean, msg: SignedSubscription): SignedSubscription.AsObject;
+ static extensions: {[key: number]: jspb.ExtensionFieldInfo};
+ static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo};
+ static serializeBinaryToWriter(message: SignedSubscription, writer: jspb.BinaryWriter): void;
+ static deserializeBinary(bytes: Uint8Array): SignedSubscription;
+ static deserializeBinaryFromReader(message: SignedSubscription, reader: jspb.BinaryReader): SignedSubscription;
+}
+
+export namespace SignedSubscription {
+ export type AsObject = {
+ subPart?: Subscription.AsObject,
+ updatePart?: SubscriptionUpdate.AsObject,
+ }
+}
+
diff --git a/ts/replication_pb_service.d.ts b/ts/replication_pb_service.d.ts
new file mode 100644
index 0000000..5a3e345
--- /dev/null
+++ b/ts/replication_pb_service.d.ts
@@ -0,0 +1,96 @@
+// package: pb
+// file: replication.proto
+
+import * as replication_pb from "./replication_pb";
+import {grpc} from "@improbable-eng/grpc-web";
+
+type replicatorAdd = {
+ readonly methodName: string;
+ readonly service: typeof replicator;
+ readonly requestStream: false;
+ readonly responseStream: true;
+ readonly requestType: typeof replication_pb.Subscription;
+ readonly responseType: typeof replication_pb.ReplicationStatus;
+};
+
+type replicatorStatus = {
+ readonly methodName: string;
+ readonly service: typeof replicator;
+ readonly requestStream: false;
+ readonly responseStream: true;
+ readonly requestType: typeof replication_pb.Subscription;
+ readonly responseType: typeof replication_pb.ReplicationStatus;
+};
+
+type replicatorGetSubscriptionUpdate = {
+ readonly methodName: string;
+ readonly service: typeof replicator;
+ readonly requestStream: false;
+ readonly responseStream: false;
+ readonly requestType: typeof replication_pb.Subscription;
+ readonly responseType: typeof replication_pb.SubscriptionUpdate;
+};
+
+type replicatorSubmitReplication = {
+ readonly methodName: string;
+ readonly service: typeof replicator;
+ readonly requestStream: false;
+ readonly responseStream: true;
+ readonly requestType: typeof replication_pb.SignedSubscription;
+ readonly responseType: typeof replication_pb.ReplicationStatus;
+};
+
+export class replicator {
+ static readonly serviceName: string;
+ static readonly Add: replicatorAdd;
+ static readonly Status: replicatorStatus;
+ static readonly GetSubscriptionUpdate: replicatorGetSubscriptionUpdate;
+ static readonly SubmitReplication: replicatorSubmitReplication;
+}
+
+export type ServiceError = { message: string, code: number; metadata: grpc.Metadata }
+export type Status = { details: string, code: number; metadata: grpc.Metadata }
+
+interface UnaryResponse {
+ cancel(): void;
+}
+interface ResponseStream {
+ cancel(): void;
+ on(type: 'data', handler: (message: T) => void): ResponseStream;
+ on(type: 'end', handler: (status?: Status) => void): ResponseStream;
+ on(type: 'status', handler: (status: Status) => void): ResponseStream;
+}
+interface RequestStream {
+ write(message: T): RequestStream;
+ end(): void;
+ cancel(): void;
+ on(type: 'end', handler: (status?: Status) => void): RequestStream;
+ on(type: 'status', handler: (status: Status) => void): RequestStream;
+}
+interface BidirectionalStream {
+ write(message: ReqT): BidirectionalStream;
+ end(): void;
+ cancel(): void;
+ on(type: 'data', handler: (message: ResT) => void): BidirectionalStream;
+ on(type: 'end', handler: (status?: Status) => void): BidirectionalStream;
+ on(type: 'status', handler: (status: Status) => void): BidirectionalStream;
+}
+
+export class replicatorClient {
+ readonly serviceHost: string;
+
+ constructor(serviceHost: string, options?: grpc.RpcOptions);
+ add(requestMessage: replication_pb.Subscription, metadata?: grpc.Metadata): ResponseStream;
+ status(requestMessage: replication_pb.Subscription, metadata?: grpc.Metadata): ResponseStream;
+ getSubscriptionUpdate(
+ requestMessage: replication_pb.Subscription,
+ metadata: grpc.Metadata,
+ callback: (error: ServiceError|null, responseMessage: replication_pb.SubscriptionUpdate|null) => void
+ ): UnaryResponse;
+ getSubscriptionUpdate(
+ requestMessage: replication_pb.Subscription,
+ callback: (error: ServiceError|null, responseMessage: replication_pb.SubscriptionUpdate|null) => void
+ ): UnaryResponse;
+ submitReplication(requestMessage: replication_pb.SignedSubscription, metadata?: grpc.Metadata): ResponseStream;
+}
+
diff --git a/ts/replication_pb_service.js b/ts/replication_pb_service.js
new file mode 100644
index 0000000..e59a2d4
--- /dev/null
+++ b/ts/replication_pb_service.js
@@ -0,0 +1,205 @@
+// package: pb
+// file: replication.proto
+
+var replication_pb = require("./replication_pb");
+var grpc = require("@improbable-eng/grpc-web").grpc;
+
+var replicator = (function () {
+ function replicator() {}
+ replicator.serviceName = "pb.replicator";
+ return replicator;
+}());
+
+replicator.Add = {
+ methodName: "Add",
+ service: replicator,
+ requestStream: false,
+ responseStream: true,
+ requestType: replication_pb.Subscription,
+ responseType: replication_pb.ReplicationStatus
+};
+
+replicator.Status = {
+ methodName: "Status",
+ service: replicator,
+ requestStream: false,
+ responseStream: true,
+ requestType: replication_pb.Subscription,
+ responseType: replication_pb.ReplicationStatus
+};
+
+replicator.GetSubscriptionUpdate = {
+ methodName: "GetSubscriptionUpdate",
+ service: replicator,
+ requestStream: false,
+ responseStream: false,
+ requestType: replication_pb.Subscription,
+ responseType: replication_pb.SubscriptionUpdate
+};
+
+replicator.SubmitReplication = {
+ methodName: "SubmitReplication",
+ service: replicator,
+ requestStream: false,
+ responseStream: true,
+ requestType: replication_pb.SignedSubscription,
+ responseType: replication_pb.ReplicationStatus
+};
+
+exports.replicator = replicator;
+
+function replicatorClient(serviceHost, options) {
+ this.serviceHost = serviceHost;
+ this.options = options || {};
+}
+
+replicatorClient.prototype.add = function add(requestMessage, metadata) {
+ var listeners = {
+ data: [],
+ end: [],
+ status: []
+ };
+ var client = grpc.invoke(replicator.Add, {
+ request: requestMessage,
+ host: this.serviceHost,
+ metadata: metadata,
+ transport: this.options.transport,
+ debug: this.options.debug,
+ onMessage: function (responseMessage) {
+ listeners.data.forEach(function (handler) {
+ handler(responseMessage);
+ });
+ },
+ onEnd: function (status, statusMessage, trailers) {
+ listeners.status.forEach(function (handler) {
+ handler({ code: status, details: statusMessage, metadata: trailers });
+ });
+ listeners.end.forEach(function (handler) {
+ handler({ code: status, details: statusMessage, metadata: trailers });
+ });
+ listeners = null;
+ }
+ });
+ return {
+ on: function (type, handler) {
+ listeners[type].push(handler);
+ return this;
+ },
+ cancel: function () {
+ listeners = null;
+ client.close();
+ }
+ };
+};
+
+replicatorClient.prototype.status = function status(requestMessage, metadata) {
+ var listeners = {
+ data: [],
+ end: [],
+ status: []
+ };
+ var client = grpc.invoke(replicator.Status, {
+ request: requestMessage,
+ host: this.serviceHost,
+ metadata: metadata,
+ transport: this.options.transport,
+ debug: this.options.debug,
+ onMessage: function (responseMessage) {
+ listeners.data.forEach(function (handler) {
+ handler(responseMessage);
+ });
+ },
+ onEnd: function (status, statusMessage, trailers) {
+ listeners.status.forEach(function (handler) {
+ handler({ code: status, details: statusMessage, metadata: trailers });
+ });
+ listeners.end.forEach(function (handler) {
+ handler({ code: status, details: statusMessage, metadata: trailers });
+ });
+ listeners = null;
+ }
+ });
+ return {
+ on: function (type, handler) {
+ listeners[type].push(handler);
+ return this;
+ },
+ cancel: function () {
+ listeners = null;
+ client.close();
+ }
+ };
+};
+
+replicatorClient.prototype.getSubscriptionUpdate = function getSubscriptionUpdate(requestMessage, metadata, callback) {
+ if (arguments.length === 2) {
+ callback = arguments[1];
+ }
+ var client = grpc.unary(replicator.GetSubscriptionUpdate, {
+ request: requestMessage,
+ host: this.serviceHost,
+ metadata: metadata,
+ transport: this.options.transport,
+ debug: this.options.debug,
+ onEnd: function (response) {
+ if (callback) {
+ if (response.status !== grpc.Code.OK) {
+ var err = new Error(response.statusMessage);
+ err.code = response.status;
+ err.metadata = response.trailers;
+ callback(err, null);
+ } else {
+ callback(null, response.message);
+ }
+ }
+ }
+ });
+ return {
+ cancel: function () {
+ callback = null;
+ client.close();
+ }
+ };
+};
+
+replicatorClient.prototype.submitReplication = function submitReplication(requestMessage, metadata) {
+ var listeners = {
+ data: [],
+ end: [],
+ status: []
+ };
+ var client = grpc.invoke(replicator.SubmitReplication, {
+ request: requestMessage,
+ host: this.serviceHost,
+ metadata: metadata,
+ transport: this.options.transport,
+ debug: this.options.debug,
+ onMessage: function (responseMessage) {
+ listeners.data.forEach(function (handler) {
+ handler(responseMessage);
+ });
+ },
+ onEnd: function (status, statusMessage, trailers) {
+ listeners.status.forEach(function (handler) {
+ handler({ code: status, details: statusMessage, metadata: trailers });
+ });
+ listeners.end.forEach(function (handler) {
+ handler({ code: status, details: statusMessage, metadata: trailers });
+ });
+ listeners = null;
+ }
+ });
+ return {
+ on: function (type, handler) {
+ listeners[type].push(handler);
+ return this;
+ },
+ cancel: function () {
+ listeners = null;
+ client.close();
+ }
+ };
+};
+
+exports.replicatorClient = replicatorClient;
+