From c7e7b7945ba81ccb53f9519240d66b69067f2e4d Mon Sep 17 00:00:00 2001 From: Pagan Gazzard Date: Tue, 29 Oct 2024 18:03:03 +0000 Subject: [PATCH] Update protobuf definitions to loki 2.4.2 Change-type: minor --- proto/compiled/logproto_grpc_pb.d.ts | 102 ++ proto/compiled/logproto_grpc_pb.js | 66 + proto/compiled/logproto_pb.d.ts | 234 +++ proto/compiled/logproto_pb.js | 2227 +++++++++++++++++++++----- proto/logproto.proto | 36 + 5 files changed, 2278 insertions(+), 387 deletions(-) diff --git a/proto/compiled/logproto_grpc_pb.d.ts b/proto/compiled/logproto_grpc_pb.d.ts index 1b80f8b..6e40bae 100644 --- a/proto/compiled/logproto_grpc_pb.d.ts +++ b/proto/compiled/logproto_grpc_pb.d.ts @@ -96,10 +96,12 @@ export class PusherClient extends grpc.Client implements IPusherClient { interface IQuerierService extends grpc.ServiceDefinition { query: IQuerierService_IQuery; + querySample: IQuerierService_IQuerySample; label: IQuerierService_ILabel; tail: IQuerierService_ITail; series: IQuerierService_ISeries; tailersCount: IQuerierService_ITailersCount; + getChunkIDs: IQuerierService_IGetChunkIDs; } interface IQuerierService_IQuery @@ -115,6 +117,19 @@ interface IQuerierService_IQuery responseSerialize: grpc.serialize; responseDeserialize: grpc.deserialize; } +interface IQuerierService_IQuerySample + extends grpc.MethodDefinition< + logproto_pb.SampleQueryRequest, + logproto_pb.SampleQueryResponse + > { + path: '/logproto.Querier/QuerySample'; + requestStream: false; + responseStream: true; + requestSerialize: grpc.serialize; + requestDeserialize: grpc.deserialize; + responseSerialize: grpc.serialize; + responseDeserialize: grpc.deserialize; +} interface IQuerierService_ILabel extends grpc.MethodDefinition< logproto_pb.LabelRequest, @@ -167,6 +182,19 @@ interface IQuerierService_ITailersCount responseSerialize: grpc.serialize; responseDeserialize: grpc.deserialize; } +interface IQuerierService_IGetChunkIDs + extends grpc.MethodDefinition< + logproto_pb.GetChunkIDsRequest, + logproto_pb.GetChunkIDsResponse + > { + path: '/logproto.Querier/GetChunkIDs'; + requestStream: false; + responseStream: false; + requestSerialize: grpc.serialize; + requestDeserialize: grpc.deserialize; + responseSerialize: grpc.serialize; + responseDeserialize: grpc.deserialize; +} export const QuerierService: IQuerierService; @@ -175,6 +203,10 @@ export interface IQuerierServer extends grpc.UntypedServiceImplementation { logproto_pb.QueryRequest, logproto_pb.QueryResponse >; + querySample: grpc.handleServerStreamingCall< + logproto_pb.SampleQueryRequest, + logproto_pb.SampleQueryResponse + >; label: grpc.handleUnaryCall< logproto_pb.LabelRequest, logproto_pb.LabelResponse @@ -191,6 +223,10 @@ export interface IQuerierServer extends grpc.UntypedServiceImplementation { logproto_pb.TailersCountRequest, logproto_pb.TailersCountResponse >; + getChunkIDs: grpc.handleUnaryCall< + logproto_pb.GetChunkIDsRequest, + logproto_pb.GetChunkIDsResponse + >; } export interface IQuerierClient { @@ -203,6 +239,15 @@ export interface IQuerierClient { metadata?: grpc.Metadata, options?: Partial, ): grpc.ClientReadableStream; + querySample( + request: logproto_pb.SampleQueryRequest, + options?: Partial, + ): grpc.ClientReadableStream; + querySample( + request: logproto_pb.SampleQueryRequest, + metadata?: grpc.Metadata, + options?: Partial, + ): grpc.ClientReadableStream; label( request: logproto_pb.LabelRequest, callback: ( @@ -284,6 +329,30 @@ export interface IQuerierClient { response: logproto_pb.TailersCountResponse, ) => void, ): grpc.ClientUnaryCall; + getChunkIDs( + request: logproto_pb.GetChunkIDsRequest, + callback: ( + error: grpc.ServiceError | null, + response: logproto_pb.GetChunkIDsResponse, + ) => void, + ): grpc.ClientUnaryCall; + getChunkIDs( + request: logproto_pb.GetChunkIDsRequest, + metadata: grpc.Metadata, + callback: ( + error: grpc.ServiceError | null, + response: logproto_pb.GetChunkIDsResponse, + ) => void, + ): grpc.ClientUnaryCall; + getChunkIDs( + request: logproto_pb.GetChunkIDsRequest, + metadata: grpc.Metadata, + options: Partial, + callback: ( + error: grpc.ServiceError | null, + response: logproto_pb.GetChunkIDsResponse, + ) => void, + ): grpc.ClientUnaryCall; } export class QuerierClient extends grpc.Client implements IQuerierClient { @@ -301,6 +370,15 @@ export class QuerierClient extends grpc.Client implements IQuerierClient { metadata?: grpc.Metadata, options?: Partial, ): grpc.ClientReadableStream; + public querySample( + request: logproto_pb.SampleQueryRequest, + options?: Partial, + ): grpc.ClientReadableStream; + public querySample( + request: logproto_pb.SampleQueryRequest, + metadata?: grpc.Metadata, + options?: Partial, + ): grpc.ClientReadableStream; public label( request: logproto_pb.LabelRequest, callback: ( @@ -382,6 +460,30 @@ export class QuerierClient extends grpc.Client implements IQuerierClient { response: logproto_pb.TailersCountResponse, ) => void, ): grpc.ClientUnaryCall; + public getChunkIDs( + request: logproto_pb.GetChunkIDsRequest, + callback: ( + error: grpc.ServiceError | null, + response: logproto_pb.GetChunkIDsResponse, + ) => void, + ): grpc.ClientUnaryCall; + public getChunkIDs( + request: logproto_pb.GetChunkIDsRequest, + metadata: grpc.Metadata, + callback: ( + error: grpc.ServiceError | null, + response: logproto_pb.GetChunkIDsResponse, + ) => void, + ): grpc.ClientUnaryCall; + public getChunkIDs( + request: logproto_pb.GetChunkIDsRequest, + metadata: grpc.Metadata, + options: Partial, + callback: ( + error: grpc.ServiceError | null, + response: logproto_pb.GetChunkIDsResponse, + ) => void, + ): grpc.ClientUnaryCall; } interface IIngesterService diff --git a/proto/compiled/logproto_grpc_pb.js b/proto/compiled/logproto_grpc_pb.js index fabc786..59ba230 100644 --- a/proto/compiled/logproto_grpc_pb.js +++ b/proto/compiled/logproto_grpc_pb.js @@ -6,6 +6,28 @@ var logproto_pb = require('./logproto_pb.js'); var google_protobuf_timestamp_pb = require('google-protobuf/google/protobuf/timestamp_pb.js'); var gogo_pb = require('./gogo_pb.js'); +function serialize_logproto_GetChunkIDsRequest(arg) { + if (!(arg instanceof logproto_pb.GetChunkIDsRequest)) { + throw new Error('Expected argument of type logproto.GetChunkIDsRequest'); + } + return Buffer.from(arg.serializeBinary()); +} + +function deserialize_logproto_GetChunkIDsRequest(buffer_arg) { + return logproto_pb.GetChunkIDsRequest.deserializeBinary(new Uint8Array(buffer_arg)); +} + +function serialize_logproto_GetChunkIDsResponse(arg) { + if (!(arg instanceof logproto_pb.GetChunkIDsResponse)) { + throw new Error('Expected argument of type logproto.GetChunkIDsResponse'); + } + return Buffer.from(arg.serializeBinary()); +} + +function deserialize_logproto_GetChunkIDsResponse(buffer_arg) { + return logproto_pb.GetChunkIDsResponse.deserializeBinary(new Uint8Array(buffer_arg)); +} + function serialize_logproto_LabelRequest(arg) { if (!(arg instanceof logproto_pb.LabelRequest)) { throw new Error('Expected argument of type logproto.LabelRequest'); @@ -72,6 +94,28 @@ function deserialize_logproto_QueryResponse(buffer_arg) { return logproto_pb.QueryResponse.deserializeBinary(new Uint8Array(buffer_arg)); } +function serialize_logproto_SampleQueryRequest(arg) { + if (!(arg instanceof logproto_pb.SampleQueryRequest)) { + throw new Error('Expected argument of type logproto.SampleQueryRequest'); + } + return Buffer.from(arg.serializeBinary()); +} + +function deserialize_logproto_SampleQueryRequest(buffer_arg) { + return logproto_pb.SampleQueryRequest.deserializeBinary(new Uint8Array(buffer_arg)); +} + +function serialize_logproto_SampleQueryResponse(arg) { + if (!(arg instanceof logproto_pb.SampleQueryResponse)) { + throw new Error('Expected argument of type logproto.SampleQueryResponse'); + } + return Buffer.from(arg.serializeBinary()); +} + +function deserialize_logproto_SampleQueryResponse(buffer_arg) { + return logproto_pb.SampleQueryResponse.deserializeBinary(new Uint8Array(buffer_arg)); +} + function serialize_logproto_SeriesRequest(arg) { if (!(arg instanceof logproto_pb.SeriesRequest)) { throw new Error('Expected argument of type logproto.SeriesRequest'); @@ -188,6 +232,17 @@ var QuerierService = exports.QuerierService = { responseSerialize: serialize_logproto_QueryResponse, responseDeserialize: deserialize_logproto_QueryResponse, }, + querySample: { + path: '/logproto.Querier/QuerySample', + requestStream: false, + responseStream: true, + requestType: logproto_pb.SampleQueryRequest, + responseType: logproto_pb.SampleQueryResponse, + requestSerialize: serialize_logproto_SampleQueryRequest, + requestDeserialize: deserialize_logproto_SampleQueryRequest, + responseSerialize: serialize_logproto_SampleQueryResponse, + responseDeserialize: deserialize_logproto_SampleQueryResponse, + }, label: { path: '/logproto.Querier/Label', requestStream: false, @@ -232,6 +287,17 @@ var QuerierService = exports.QuerierService = { responseSerialize: serialize_logproto_TailersCountResponse, responseDeserialize: deserialize_logproto_TailersCountResponse, }, + getChunkIDs: { + path: '/logproto.Querier/GetChunkIDs', + requestStream: false, + responseStream: false, + requestType: logproto_pb.GetChunkIDsRequest, + responseType: logproto_pb.GetChunkIDsResponse, + requestSerialize: serialize_logproto_GetChunkIDsRequest, + requestDeserialize: deserialize_logproto_GetChunkIDsRequest, + responseSerialize: serialize_logproto_GetChunkIDsResponse, + responseDeserialize: deserialize_logproto_GetChunkIDsResponse, + }, }; exports.QuerierClient = grpc.makeGenericClientConstructor(QuerierService); diff --git a/proto/compiled/logproto_pb.d.ts b/proto/compiled/logproto_pb.d.ts index 1848893..8091434 100644 --- a/proto/compiled/logproto_pb.d.ts +++ b/proto/compiled/logproto_pb.d.ts @@ -84,6 +84,10 @@ export class QueryRequest extends jspb.Message { setEnd(value?: google_protobuf_timestamp_pb.Timestamp): QueryRequest; getDirection(): Direction; setDirection(value: Direction): QueryRequest; + clearShardsList(): void; + getShardsList(): Array; + setShardsList(value: Array): QueryRequest; + addShards(value: string, index?: number): string; serializeBinary(): Uint8Array; toObject(includeInstance?: boolean): QueryRequest.AsObject; @@ -113,6 +117,88 @@ export namespace QueryRequest { start?: google_protobuf_timestamp_pb.Timestamp.AsObject; end?: google_protobuf_timestamp_pb.Timestamp.AsObject; direction: Direction; + shardsList: Array; + }; +} + +export class SampleQueryRequest extends jspb.Message { + getSelector(): string; + setSelector(value: string): SampleQueryRequest; + + hasStart(): boolean; + clearStart(): void; + getStart(): google_protobuf_timestamp_pb.Timestamp | undefined; + setStart(value?: google_protobuf_timestamp_pb.Timestamp): SampleQueryRequest; + + hasEnd(): boolean; + clearEnd(): void; + getEnd(): google_protobuf_timestamp_pb.Timestamp | undefined; + setEnd(value?: google_protobuf_timestamp_pb.Timestamp): SampleQueryRequest; + clearShardsList(): void; + getShardsList(): Array; + setShardsList(value: Array): SampleQueryRequest; + addShards(value: string, index?: number): string; + + serializeBinary(): Uint8Array; + toObject(includeInstance?: boolean): SampleQueryRequest.AsObject; + static toObject( + includeInstance: boolean, + msg: SampleQueryRequest, + ): SampleQueryRequest.AsObject; + static extensions: { [key: number]: jspb.ExtensionFieldInfo }; + static extensionsBinary: { + [key: number]: jspb.ExtensionFieldBinaryInfo; + }; + static serializeBinaryToWriter( + message: SampleQueryRequest, + writer: jspb.BinaryWriter, + ): void; + static deserializeBinary(bytes: Uint8Array): SampleQueryRequest; + static deserializeBinaryFromReader( + message: SampleQueryRequest, + reader: jspb.BinaryReader, + ): SampleQueryRequest; +} + +export namespace SampleQueryRequest { + export type AsObject = { + selector: string; + start?: google_protobuf_timestamp_pb.Timestamp.AsObject; + end?: google_protobuf_timestamp_pb.Timestamp.AsObject; + shardsList: Array; + }; +} + +export class SampleQueryResponse extends jspb.Message { + clearSeriesList(): void; + getSeriesList(): Array; + setSeriesList(value: Array): SampleQueryResponse; + addSeries(value?: Series, index?: number): Series; + + serializeBinary(): Uint8Array; + toObject(includeInstance?: boolean): SampleQueryResponse.AsObject; + static toObject( + includeInstance: boolean, + msg: SampleQueryResponse, + ): SampleQueryResponse.AsObject; + static extensions: { [key: number]: jspb.ExtensionFieldInfo }; + static extensionsBinary: { + [key: number]: jspb.ExtensionFieldBinaryInfo; + }; + static serializeBinaryToWriter( + message: SampleQueryResponse, + writer: jspb.BinaryWriter, + ): void; + static deserializeBinary(bytes: Uint8Array): SampleQueryResponse; + static deserializeBinaryFromReader( + message: SampleQueryResponse, + reader: jspb.BinaryReader, + ): SampleQueryResponse; +} + +export namespace SampleQueryResponse { + export type AsObject = { + seriesList: Array; }; } @@ -300,6 +386,73 @@ export namespace EntryAdapter { }; } +export class Sample extends jspb.Message { + getTimestamp(): number; + setTimestamp(value: number): Sample; + getValue(): number; + setValue(value: number): Sample; + getHash(): number; + setHash(value: number): Sample; + + serializeBinary(): Uint8Array; + toObject(includeInstance?: boolean): Sample.AsObject; + static toObject(includeInstance: boolean, msg: Sample): Sample.AsObject; + static extensions: { [key: number]: jspb.ExtensionFieldInfo }; + static extensionsBinary: { + [key: number]: jspb.ExtensionFieldBinaryInfo; + }; + static serializeBinaryToWriter( + message: Sample, + writer: jspb.BinaryWriter, + ): void; + static deserializeBinary(bytes: Uint8Array): Sample; + static deserializeBinaryFromReader( + message: Sample, + reader: jspb.BinaryReader, + ): Sample; +} + +export namespace Sample { + export type AsObject = { + timestamp: number; + value: number; + hash: number; + }; +} + +export class Series extends jspb.Message { + getLabels(): string; + setLabels(value: string): Series; + clearSamplesList(): void; + getSamplesList(): Array; + setSamplesList(value: Array): Series; + addSamples(value?: Sample, index?: number): Sample; + + serializeBinary(): Uint8Array; + toObject(includeInstance?: boolean): Series.AsObject; + static toObject(includeInstance: boolean, msg: Series): Series.AsObject; + static extensions: { [key: number]: jspb.ExtensionFieldInfo }; + static extensionsBinary: { + [key: number]: jspb.ExtensionFieldBinaryInfo; + }; + static serializeBinaryToWriter( + message: Series, + writer: jspb.BinaryWriter, + ): void; + static deserializeBinary(bytes: Uint8Array): Series; + static deserializeBinaryFromReader( + message: Series, + reader: jspb.BinaryReader, + ): Series; +} + +export namespace Series { + export type AsObject = { + labels: string; + samplesList: Array; + }; +} + export class TailRequest extends jspb.Message { getQuery(): string; setQuery(value: string): TailRequest; @@ -395,6 +548,10 @@ export class SeriesRequest extends jspb.Message { getGroupsList(): Array; setGroupsList(value: Array): SeriesRequest; addGroups(value: string, index?: number): string; + clearShardsList(): void; + getShardsList(): Array; + setShardsList(value: Array): SeriesRequest; + addShards(value: string, index?: number): string; serializeBinary(): Uint8Array; toObject(includeInstance?: boolean): SeriesRequest.AsObject; @@ -422,6 +579,7 @@ export namespace SeriesRequest { start?: google_protobuf_timestamp_pb.Timestamp.AsObject; end?: google_protobuf_timestamp_pb.Timestamp.AsObject; groupsList: Array; + shardsList: Array; }; } @@ -719,6 +877,82 @@ export namespace TailersCountResponse { }; } +export class GetChunkIDsRequest extends jspb.Message { + getMatchers(): string; + setMatchers(value: string): GetChunkIDsRequest; + + hasStart(): boolean; + clearStart(): void; + getStart(): google_protobuf_timestamp_pb.Timestamp | undefined; + setStart(value?: google_protobuf_timestamp_pb.Timestamp): GetChunkIDsRequest; + + hasEnd(): boolean; + clearEnd(): void; + getEnd(): google_protobuf_timestamp_pb.Timestamp | undefined; + setEnd(value?: google_protobuf_timestamp_pb.Timestamp): GetChunkIDsRequest; + + serializeBinary(): Uint8Array; + toObject(includeInstance?: boolean): GetChunkIDsRequest.AsObject; + static toObject( + includeInstance: boolean, + msg: GetChunkIDsRequest, + ): GetChunkIDsRequest.AsObject; + static extensions: { [key: number]: jspb.ExtensionFieldInfo }; + static extensionsBinary: { + [key: number]: jspb.ExtensionFieldBinaryInfo; + }; + static serializeBinaryToWriter( + message: GetChunkIDsRequest, + writer: jspb.BinaryWriter, + ): void; + static deserializeBinary(bytes: Uint8Array): GetChunkIDsRequest; + static deserializeBinaryFromReader( + message: GetChunkIDsRequest, + reader: jspb.BinaryReader, + ): GetChunkIDsRequest; +} + +export namespace GetChunkIDsRequest { + export type AsObject = { + matchers: string; + start?: google_protobuf_timestamp_pb.Timestamp.AsObject; + end?: google_protobuf_timestamp_pb.Timestamp.AsObject; + }; +} + +export class GetChunkIDsResponse extends jspb.Message { + clearChunkidsList(): void; + getChunkidsList(): Array; + setChunkidsList(value: Array): GetChunkIDsResponse; + addChunkids(value: string, index?: number): string; + + serializeBinary(): Uint8Array; + toObject(includeInstance?: boolean): GetChunkIDsResponse.AsObject; + static toObject( + includeInstance: boolean, + msg: GetChunkIDsResponse, + ): GetChunkIDsResponse.AsObject; + static extensions: { [key: number]: jspb.ExtensionFieldInfo }; + static extensionsBinary: { + [key: number]: jspb.ExtensionFieldBinaryInfo; + }; + static serializeBinaryToWriter( + message: GetChunkIDsResponse, + writer: jspb.BinaryWriter, + ): void; + static deserializeBinary(bytes: Uint8Array): GetChunkIDsResponse; + static deserializeBinaryFromReader( + message: GetChunkIDsResponse, + reader: jspb.BinaryReader, + ): GetChunkIDsResponse; +} + +export namespace GetChunkIDsResponse { + export type AsObject = { + chunkidsList: Array; + }; +} + export enum Direction { FORWARD = 0, BACKWARD = 1, diff --git a/proto/compiled/logproto_pb.js b/proto/compiled/logproto_pb.js index 4796eb0..361fbbb 100644 --- a/proto/compiled/logproto_pb.js +++ b/proto/compiled/logproto_pb.js @@ -29,6 +29,8 @@ goog.exportSymbol('proto.logproto.Chunk', null, global); goog.exportSymbol('proto.logproto.Direction', null, global); goog.exportSymbol('proto.logproto.DroppedStream', null, global); goog.exportSymbol('proto.logproto.EntryAdapter', null, global); +goog.exportSymbol('proto.logproto.GetChunkIDsRequest', null, global); +goog.exportSymbol('proto.logproto.GetChunkIDsResponse', null, global); goog.exportSymbol('proto.logproto.LabelPair', null, global); goog.exportSymbol('proto.logproto.LabelRequest', null, global); goog.exportSymbol('proto.logproto.LabelResponse', null, global); @@ -36,6 +38,10 @@ goog.exportSymbol('proto.logproto.PushRequest', null, global); goog.exportSymbol('proto.logproto.PushResponse', null, global); goog.exportSymbol('proto.logproto.QueryRequest', null, global); goog.exportSymbol('proto.logproto.QueryResponse', null, global); +goog.exportSymbol('proto.logproto.Sample', null, global); +goog.exportSymbol('proto.logproto.SampleQueryRequest', null, global); +goog.exportSymbol('proto.logproto.SampleQueryResponse', null, global); +goog.exportSymbol('proto.logproto.Series', null, global); goog.exportSymbol('proto.logproto.SeriesIdentifier', null, global); goog.exportSymbol('proto.logproto.SeriesRequest', null, global); goog.exportSymbol('proto.logproto.SeriesResponse', null, global); @@ -99,7 +105,7 @@ if (goog.DEBUG && !COMPILED) { * @constructor */ proto.logproto.QueryRequest = function(opt_data) { - jspb.Message.initialize(this, opt_data, 0, -1, null, null); + jspb.Message.initialize(this, opt_data, 0, -1, proto.logproto.QueryRequest.repeatedFields_, null); }; goog.inherits(proto.logproto.QueryRequest, jspb.Message); if (goog.DEBUG && !COMPILED) { @@ -109,6 +115,48 @@ if (goog.DEBUG && !COMPILED) { */ proto.logproto.QueryRequest.displayName = 'proto.logproto.QueryRequest'; } +/** + * 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.logproto.SampleQueryRequest = function(opt_data) { + jspb.Message.initialize(this, opt_data, 0, -1, proto.logproto.SampleQueryRequest.repeatedFields_, null); +}; +goog.inherits(proto.logproto.SampleQueryRequest, jspb.Message); +if (goog.DEBUG && !COMPILED) { + /** + * @public + * @override + */ + proto.logproto.SampleQueryRequest.displayName = 'proto.logproto.SampleQueryRequest'; +} +/** + * 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.logproto.SampleQueryResponse = function(opt_data) { + jspb.Message.initialize(this, opt_data, 0, -1, proto.logproto.SampleQueryResponse.repeatedFields_, null); +}; +goog.inherits(proto.logproto.SampleQueryResponse, jspb.Message); +if (goog.DEBUG && !COMPILED) { + /** + * @public + * @override + */ + proto.logproto.SampleQueryResponse.displayName = 'proto.logproto.SampleQueryResponse'; +} /** * Generated by JsPbCodeGenerator. * @param {Array=} opt_data Optional initial data array, typically from a @@ -214,6 +262,48 @@ if (goog.DEBUG && !COMPILED) { */ proto.logproto.EntryAdapter.displayName = 'proto.logproto.EntryAdapter'; } +/** + * 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.logproto.Sample = function(opt_data) { + jspb.Message.initialize(this, opt_data, 0, -1, null, null); +}; +goog.inherits(proto.logproto.Sample, jspb.Message); +if (goog.DEBUG && !COMPILED) { + /** + * @public + * @override + */ + proto.logproto.Sample.displayName = 'proto.logproto.Sample'; +} +/** + * 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.logproto.Series = function(opt_data) { + jspb.Message.initialize(this, opt_data, 0, -1, proto.logproto.Series.repeatedFields_, null); +}; +goog.inherits(proto.logproto.Series, jspb.Message); +if (goog.DEBUG && !COMPILED) { + /** + * @public + * @override + */ + proto.logproto.Series.displayName = 'proto.logproto.Series'; +} /** * Generated by JsPbCodeGenerator. * @param {Array=} opt_data Optional initial data array, typically from a @@ -466,6 +556,48 @@ if (goog.DEBUG && !COMPILED) { */ proto.logproto.TailersCountResponse.displayName = 'proto.logproto.TailersCountResponse'; } +/** + * 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.logproto.GetChunkIDsRequest = function(opt_data) { + jspb.Message.initialize(this, opt_data, 0, -1, null, null); +}; +goog.inherits(proto.logproto.GetChunkIDsRequest, jspb.Message); +if (goog.DEBUG && !COMPILED) { + /** + * @public + * @override + */ + proto.logproto.GetChunkIDsRequest.displayName = 'proto.logproto.GetChunkIDsRequest'; +} +/** + * 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.logproto.GetChunkIDsResponse = function(opt_data) { + jspb.Message.initialize(this, opt_data, 0, -1, proto.logproto.GetChunkIDsResponse.repeatedFields_, null); +}; +goog.inherits(proto.logproto.GetChunkIDsResponse, jspb.Message); +if (goog.DEBUG && !COMPILED) { + /** + * @public + * @override + */ + proto.logproto.GetChunkIDsResponse.displayName = 'proto.logproto.GetChunkIDsResponse'; +} /** * List of repeated fields within this message type. @@ -728,6 +860,13 @@ proto.logproto.PushResponse.serializeBinaryToWriter = function(message, writer) +/** + * List of repeated fields within this message type. + * @private {!Array} + * @const + */ +proto.logproto.QueryRequest.repeatedFields_ = [7]; + if (jspb.Message.GENERATE_TO_OBJECT) { @@ -763,7 +902,8 @@ proto.logproto.QueryRequest.toObject = function(includeInstance, msg) { limit: jspb.Message.getFieldWithDefault(msg, 2, 0), start: (f = msg.getStart()) && google_protobuf_timestamp_pb.Timestamp.toObject(includeInstance, f), end: (f = msg.getEnd()) && google_protobuf_timestamp_pb.Timestamp.toObject(includeInstance, f), - direction: jspb.Message.getFieldWithDefault(msg, 5, 0) + direction: jspb.Message.getFieldWithDefault(msg, 5, 0), + shardsList: (f = jspb.Message.getRepeatedField(msg, 7)) == null ? undefined : f }; if (includeInstance) { @@ -822,6 +962,10 @@ proto.logproto.QueryRequest.deserializeBinaryFromReader = function(msg, reader) var value = /** @type {!proto.logproto.Direction} */ (reader.readEnum()); msg.setDirection(value); break; + case 7: + var value = /** @type {string} */ (reader.readString()); + msg.addShards(value); + break; default: reader.skipField(); break; @@ -888,6 +1032,13 @@ proto.logproto.QueryRequest.serializeBinaryToWriter = function(message, writer) f ); } + f = message.getShardsList(); + if (f.length > 0) { + writer.writeRepeatedString( + 7, + f + ); + } }; @@ -1019,13 +1170,50 @@ proto.logproto.QueryRequest.prototype.setDirection = function(value) { }; +/** + * repeated string shards = 7; + * @return {!Array} + */ +proto.logproto.QueryRequest.prototype.getShardsList = function() { + return /** @type {!Array} */ (jspb.Message.getRepeatedField(this, 7)); +}; + + +/** + * @param {!Array} value + * @return {!proto.logproto.QueryRequest} returns this + */ +proto.logproto.QueryRequest.prototype.setShardsList = function(value) { + return jspb.Message.setField(this, 7, value || []); +}; + + +/** + * @param {string} value + * @param {number=} opt_index + * @return {!proto.logproto.QueryRequest} returns this + */ +proto.logproto.QueryRequest.prototype.addShards = function(value, opt_index) { + return jspb.Message.addToRepeatedField(this, 7, value, opt_index); +}; + + +/** + * Clears the list making it empty but non-null. + * @return {!proto.logproto.QueryRequest} returns this + */ +proto.logproto.QueryRequest.prototype.clearShardsList = function() { + return this.setShardsList([]); +}; + + /** * List of repeated fields within this message type. * @private {!Array} * @const */ -proto.logproto.QueryResponse.repeatedFields_ = [1]; +proto.logproto.SampleQueryRequest.repeatedFields_ = [4]; @@ -1042,8 +1230,8 @@ if (jspb.Message.GENERATE_TO_OBJECT) { * http://goto/soy-param-migration * @return {!Object} */ -proto.logproto.QueryResponse.prototype.toObject = function(opt_includeInstance) { - return proto.logproto.QueryResponse.toObject(opt_includeInstance, this); +proto.logproto.SampleQueryRequest.prototype.toObject = function(opt_includeInstance) { + return proto.logproto.SampleQueryRequest.toObject(opt_includeInstance, this); }; @@ -1052,14 +1240,16 @@ proto.logproto.QueryResponse.prototype.toObject = function(opt_includeInstance) * @param {boolean|undefined} includeInstance Deprecated. Whether to include * the JSPB instance for transitional soy proto support: * http://goto/soy-param-migration - * @param {!proto.logproto.QueryResponse} msg The msg instance to transform. + * @param {!proto.logproto.SampleQueryRequest} msg The msg instance to transform. * @return {!Object} * @suppress {unusedLocalVariables} f is only used for nested messages */ -proto.logproto.QueryResponse.toObject = function(includeInstance, msg) { +proto.logproto.SampleQueryRequest.toObject = function(includeInstance, msg) { var f, obj = { - streamsList: jspb.Message.toObjectList(msg.getStreamsList(), - proto.logproto.StreamAdapter.toObject, includeInstance) + selector: jspb.Message.getFieldWithDefault(msg, 1, ""), + start: (f = msg.getStart()) && google_protobuf_timestamp_pb.Timestamp.toObject(includeInstance, f), + end: (f = msg.getEnd()) && google_protobuf_timestamp_pb.Timestamp.toObject(includeInstance, f), + shardsList: (f = jspb.Message.getRepeatedField(msg, 4)) == null ? undefined : f }; if (includeInstance) { @@ -1073,23 +1263,23 @@ proto.logproto.QueryResponse.toObject = function(includeInstance, msg) { /** * Deserializes binary data (in protobuf wire format). * @param {jspb.ByteSource} bytes The bytes to deserialize. - * @return {!proto.logproto.QueryResponse} + * @return {!proto.logproto.SampleQueryRequest} */ -proto.logproto.QueryResponse.deserializeBinary = function(bytes) { +proto.logproto.SampleQueryRequest.deserializeBinary = function(bytes) { var reader = new jspb.BinaryReader(bytes); - var msg = new proto.logproto.QueryResponse; - return proto.logproto.QueryResponse.deserializeBinaryFromReader(msg, reader); + var msg = new proto.logproto.SampleQueryRequest; + return proto.logproto.SampleQueryRequest.deserializeBinaryFromReader(msg, reader); }; /** * Deserializes binary data (in protobuf wire format) from the * given reader into the given message object. - * @param {!proto.logproto.QueryResponse} msg The message object to deserialize into. + * @param {!proto.logproto.SampleQueryRequest} msg The message object to deserialize into. * @param {!jspb.BinaryReader} reader The BinaryReader to use. - * @return {!proto.logproto.QueryResponse} + * @return {!proto.logproto.SampleQueryRequest} */ -proto.logproto.QueryResponse.deserializeBinaryFromReader = function(msg, reader) { +proto.logproto.SampleQueryRequest.deserializeBinaryFromReader = function(msg, reader) { while (reader.nextField()) { if (reader.isEndGroup()) { break; @@ -1097,9 +1287,22 @@ proto.logproto.QueryResponse.deserializeBinaryFromReader = function(msg, reader) var field = reader.getFieldNumber(); switch (field) { case 1: - var value = new proto.logproto.StreamAdapter; - reader.readMessage(value,proto.logproto.StreamAdapter.deserializeBinaryFromReader); - msg.addStreams(value); + var value = /** @type {string} */ (reader.readString()); + msg.setSelector(value); + break; + case 2: + var value = new google_protobuf_timestamp_pb.Timestamp; + reader.readMessage(value,google_protobuf_timestamp_pb.Timestamp.deserializeBinaryFromReader); + msg.setStart(value); + break; + case 3: + var value = new google_protobuf_timestamp_pb.Timestamp; + reader.readMessage(value,google_protobuf_timestamp_pb.Timestamp.deserializeBinaryFromReader); + msg.setEnd(value); + break; + case 4: + var value = /** @type {string} */ (reader.readString()); + msg.addShards(value); break; default: reader.skipField(); @@ -1114,9 +1317,9 @@ proto.logproto.QueryResponse.deserializeBinaryFromReader = function(msg, reader) * Serializes the message to binary data (in protobuf wire format). * @return {!Uint8Array} */ -proto.logproto.QueryResponse.prototype.serializeBinary = function() { +proto.logproto.SampleQueryRequest.prototype.serializeBinary = function() { var writer = new jspb.BinaryWriter(); - proto.logproto.QueryResponse.serializeBinaryToWriter(this, writer); + proto.logproto.SampleQueryRequest.serializeBinaryToWriter(this, writer); return writer.getResultBuffer(); }; @@ -1124,79 +1327,199 @@ proto.logproto.QueryResponse.prototype.serializeBinary = function() { /** * Serializes the given message to binary data (in protobuf wire * format), writing to the given BinaryWriter. - * @param {!proto.logproto.QueryResponse} message + * @param {!proto.logproto.SampleQueryRequest} message * @param {!jspb.BinaryWriter} writer * @suppress {unusedLocalVariables} f is only used for nested messages */ -proto.logproto.QueryResponse.serializeBinaryToWriter = function(message, writer) { +proto.logproto.SampleQueryRequest.serializeBinaryToWriter = function(message, writer) { var f = undefined; - f = message.getStreamsList(); + f = message.getSelector(); if (f.length > 0) { - writer.writeRepeatedMessage( + writer.writeString( 1, + f + ); + } + f = message.getStart(); + if (f != null) { + writer.writeMessage( + 2, f, - proto.logproto.StreamAdapter.serializeBinaryToWriter + google_protobuf_timestamp_pb.Timestamp.serializeBinaryToWriter + ); + } + f = message.getEnd(); + if (f != null) { + writer.writeMessage( + 3, + f, + google_protobuf_timestamp_pb.Timestamp.serializeBinaryToWriter + ); + } + f = message.getShardsList(); + if (f.length > 0) { + writer.writeRepeatedString( + 4, + f ); } }; /** - * repeated StreamAdapter streams = 1; - * @return {!Array} + * optional string selector = 1; + * @return {string} */ -proto.logproto.QueryResponse.prototype.getStreamsList = function() { - return /** @type{!Array} */ ( - jspb.Message.getRepeatedWrapperField(this, proto.logproto.StreamAdapter, 1)); +proto.logproto.SampleQueryRequest.prototype.getSelector = function() { + return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 1, "")); }; /** - * @param {!Array} value - * @return {!proto.logproto.QueryResponse} returns this -*/ -proto.logproto.QueryResponse.prototype.setStreamsList = function(value) { - return jspb.Message.setRepeatedWrapperField(this, 1, value); + * @param {string} value + * @return {!proto.logproto.SampleQueryRequest} returns this + */ +proto.logproto.SampleQueryRequest.prototype.setSelector = function(value) { + return jspb.Message.setProto3StringField(this, 1, value); }; /** - * @param {!proto.logproto.StreamAdapter=} opt_value - * @param {number=} opt_index - * @return {!proto.logproto.StreamAdapter} + * optional google.protobuf.Timestamp start = 2; + * @return {?proto.google.protobuf.Timestamp} */ -proto.logproto.QueryResponse.prototype.addStreams = function(opt_value, opt_index) { - return jspb.Message.addToRepeatedWrapperField(this, 1, opt_value, proto.logproto.StreamAdapter, opt_index); +proto.logproto.SampleQueryRequest.prototype.getStart = function() { + return /** @type{?proto.google.protobuf.Timestamp} */ ( + jspb.Message.getWrapperField(this, google_protobuf_timestamp_pb.Timestamp, 2)); }; /** - * Clears the list making it empty but non-null. - * @return {!proto.logproto.QueryResponse} returns this - */ -proto.logproto.QueryResponse.prototype.clearStreamsList = function() { - return this.setStreamsList([]); + * @param {?proto.google.protobuf.Timestamp|undefined} value + * @return {!proto.logproto.SampleQueryRequest} returns this +*/ +proto.logproto.SampleQueryRequest.prototype.setStart = function(value) { + return jspb.Message.setWrapperField(this, 2, value); }; +/** + * Clears the message field making it undefined. + * @return {!proto.logproto.SampleQueryRequest} returns this + */ +proto.logproto.SampleQueryRequest.prototype.clearStart = function() { + return this.setStart(undefined); +}; - -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: + * Returns whether this field is set. + * @return {boolean} + */ +proto.logproto.SampleQueryRequest.prototype.hasStart = function() { + return jspb.Message.getField(this, 2) != null; +}; + + +/** + * optional google.protobuf.Timestamp end = 3; + * @return {?proto.google.protobuf.Timestamp} + */ +proto.logproto.SampleQueryRequest.prototype.getEnd = function() { + return /** @type{?proto.google.protobuf.Timestamp} */ ( + jspb.Message.getWrapperField(this, google_protobuf_timestamp_pb.Timestamp, 3)); +}; + + +/** + * @param {?proto.google.protobuf.Timestamp|undefined} value + * @return {!proto.logproto.SampleQueryRequest} returns this +*/ +proto.logproto.SampleQueryRequest.prototype.setEnd = function(value) { + return jspb.Message.setWrapperField(this, 3, value); +}; + + +/** + * Clears the message field making it undefined. + * @return {!proto.logproto.SampleQueryRequest} returns this + */ +proto.logproto.SampleQueryRequest.prototype.clearEnd = function() { + return this.setEnd(undefined); +}; + + +/** + * Returns whether this field is set. + * @return {boolean} + */ +proto.logproto.SampleQueryRequest.prototype.hasEnd = function() { + return jspb.Message.getField(this, 3) != null; +}; + + +/** + * repeated string shards = 4; + * @return {!Array} + */ +proto.logproto.SampleQueryRequest.prototype.getShardsList = function() { + return /** @type {!Array} */ (jspb.Message.getRepeatedField(this, 4)); +}; + + +/** + * @param {!Array} value + * @return {!proto.logproto.SampleQueryRequest} returns this + */ +proto.logproto.SampleQueryRequest.prototype.setShardsList = function(value) { + return jspb.Message.setField(this, 4, value || []); +}; + + +/** + * @param {string} value + * @param {number=} opt_index + * @return {!proto.logproto.SampleQueryRequest} returns this + */ +proto.logproto.SampleQueryRequest.prototype.addShards = function(value, opt_index) { + return jspb.Message.addToRepeatedField(this, 4, value, opt_index); +}; + + +/** + * Clears the list making it empty but non-null. + * @return {!proto.logproto.SampleQueryRequest} returns this + */ +proto.logproto.SampleQueryRequest.prototype.clearShardsList = function() { + return this.setShardsList([]); +}; + + + +/** + * List of repeated fields within this message type. + * @private {!Array} + * @const + */ +proto.logproto.SampleQueryResponse.repeatedFields_ = [1]; + + + +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.logproto.LabelRequest.prototype.toObject = function(opt_includeInstance) { - return proto.logproto.LabelRequest.toObject(opt_includeInstance, this); +proto.logproto.SampleQueryResponse.prototype.toObject = function(opt_includeInstance) { + return proto.logproto.SampleQueryResponse.toObject(opt_includeInstance, this); }; @@ -1205,16 +1528,14 @@ proto.logproto.LabelRequest.prototype.toObject = function(opt_includeInstance) { * @param {boolean|undefined} includeInstance Deprecated. Whether to include * the JSPB instance for transitional soy proto support: * http://goto/soy-param-migration - * @param {!proto.logproto.LabelRequest} msg The msg instance to transform. + * @param {!proto.logproto.SampleQueryResponse} msg The msg instance to transform. * @return {!Object} * @suppress {unusedLocalVariables} f is only used for nested messages */ -proto.logproto.LabelRequest.toObject = function(includeInstance, msg) { +proto.logproto.SampleQueryResponse.toObject = function(includeInstance, msg) { var f, obj = { - name: jspb.Message.getFieldWithDefault(msg, 1, ""), - values: jspb.Message.getBooleanFieldWithDefault(msg, 2, false), - start: (f = msg.getStart()) && google_protobuf_timestamp_pb.Timestamp.toObject(includeInstance, f), - end: (f = msg.getEnd()) && google_protobuf_timestamp_pb.Timestamp.toObject(includeInstance, f) + seriesList: jspb.Message.toObjectList(msg.getSeriesList(), + proto.logproto.Series.toObject, includeInstance) }; if (includeInstance) { @@ -1228,23 +1549,23 @@ proto.logproto.LabelRequest.toObject = function(includeInstance, msg) { /** * Deserializes binary data (in protobuf wire format). * @param {jspb.ByteSource} bytes The bytes to deserialize. - * @return {!proto.logproto.LabelRequest} + * @return {!proto.logproto.SampleQueryResponse} */ -proto.logproto.LabelRequest.deserializeBinary = function(bytes) { +proto.logproto.SampleQueryResponse.deserializeBinary = function(bytes) { var reader = new jspb.BinaryReader(bytes); - var msg = new proto.logproto.LabelRequest; - return proto.logproto.LabelRequest.deserializeBinaryFromReader(msg, reader); + var msg = new proto.logproto.SampleQueryResponse; + return proto.logproto.SampleQueryResponse.deserializeBinaryFromReader(msg, reader); }; /** * Deserializes binary data (in protobuf wire format) from the * given reader into the given message object. - * @param {!proto.logproto.LabelRequest} msg The message object to deserialize into. + * @param {!proto.logproto.SampleQueryResponse} msg The message object to deserialize into. * @param {!jspb.BinaryReader} reader The BinaryReader to use. - * @return {!proto.logproto.LabelRequest} + * @return {!proto.logproto.SampleQueryResponse} */ -proto.logproto.LabelRequest.deserializeBinaryFromReader = function(msg, reader) { +proto.logproto.SampleQueryResponse.deserializeBinaryFromReader = function(msg, reader) { while (reader.nextField()) { if (reader.isEndGroup()) { break; @@ -1252,22 +1573,9 @@ proto.logproto.LabelRequest.deserializeBinaryFromReader = function(msg, reader) var field = reader.getFieldNumber(); switch (field) { case 1: - var value = /** @type {string} */ (reader.readString()); - msg.setName(value); - break; - case 2: - var value = /** @type {boolean} */ (reader.readBool()); - msg.setValues(value); - break; - case 3: - var value = new google_protobuf_timestamp_pb.Timestamp; - reader.readMessage(value,google_protobuf_timestamp_pb.Timestamp.deserializeBinaryFromReader); - msg.setStart(value); - break; - case 4: - var value = new google_protobuf_timestamp_pb.Timestamp; - reader.readMessage(value,google_protobuf_timestamp_pb.Timestamp.deserializeBinaryFromReader); - msg.setEnd(value); + var value = new proto.logproto.Series; + reader.readMessage(value,proto.logproto.Series.deserializeBinaryFromReader); + msg.addSeries(value); break; default: reader.skipField(); @@ -1282,9 +1590,9 @@ proto.logproto.LabelRequest.deserializeBinaryFromReader = function(msg, reader) * Serializes the message to binary data (in protobuf wire format). * @return {!Uint8Array} */ -proto.logproto.LabelRequest.prototype.serializeBinary = function() { +proto.logproto.SampleQueryResponse.prototype.serializeBinary = function() { var writer = new jspb.BinaryWriter(); - proto.logproto.LabelRequest.serializeBinaryToWriter(this, writer); + proto.logproto.SampleQueryResponse.serializeBinaryToWriter(this, writer); return writer.getResultBuffer(); }; @@ -1292,125 +1600,453 @@ proto.logproto.LabelRequest.prototype.serializeBinary = function() { /** * Serializes the given message to binary data (in protobuf wire * format), writing to the given BinaryWriter. - * @param {!proto.logproto.LabelRequest} message + * @param {!proto.logproto.SampleQueryResponse} message * @param {!jspb.BinaryWriter} writer * @suppress {unusedLocalVariables} f is only used for nested messages */ -proto.logproto.LabelRequest.serializeBinaryToWriter = function(message, writer) { +proto.logproto.SampleQueryResponse.serializeBinaryToWriter = function(message, writer) { var f = undefined; - f = message.getName(); + f = message.getSeriesList(); if (f.length > 0) { - writer.writeString( + writer.writeRepeatedMessage( 1, - f - ); - } - f = message.getValues(); - if (f) { - writer.writeBool( - 2, - f - ); - } - f = message.getStart(); - if (f != null) { - writer.writeMessage( - 3, - f, - google_protobuf_timestamp_pb.Timestamp.serializeBinaryToWriter - ); - } - f = message.getEnd(); - if (f != null) { - writer.writeMessage( - 4, f, - google_protobuf_timestamp_pb.Timestamp.serializeBinaryToWriter + proto.logproto.Series.serializeBinaryToWriter ); } }; /** - * optional string name = 1; - * @return {string} + * repeated Series series = 1; + * @return {!Array} */ -proto.logproto.LabelRequest.prototype.getName = function() { - return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 1, "")); +proto.logproto.SampleQueryResponse.prototype.getSeriesList = function() { + return /** @type{!Array} */ ( + jspb.Message.getRepeatedWrapperField(this, proto.logproto.Series, 1)); }; /** - * @param {string} value - * @return {!proto.logproto.LabelRequest} returns this - */ -proto.logproto.LabelRequest.prototype.setName = function(value) { - return jspb.Message.setProto3StringField(this, 1, value); + * @param {!Array} value + * @return {!proto.logproto.SampleQueryResponse} returns this +*/ +proto.logproto.SampleQueryResponse.prototype.setSeriesList = function(value) { + return jspb.Message.setRepeatedWrapperField(this, 1, value); }; /** - * optional bool values = 2; - * @return {boolean} + * @param {!proto.logproto.Series=} opt_value + * @param {number=} opt_index + * @return {!proto.logproto.Series} */ -proto.logproto.LabelRequest.prototype.getValues = function() { - return /** @type {boolean} */ (jspb.Message.getBooleanFieldWithDefault(this, 2, false)); +proto.logproto.SampleQueryResponse.prototype.addSeries = function(opt_value, opt_index) { + return jspb.Message.addToRepeatedWrapperField(this, 1, opt_value, proto.logproto.Series, opt_index); }; /** - * @param {boolean} value - * @return {!proto.logproto.LabelRequest} returns this + * Clears the list making it empty but non-null. + * @return {!proto.logproto.SampleQueryResponse} returns this */ -proto.logproto.LabelRequest.prototype.setValues = function(value) { - return jspb.Message.setProto3BooleanField(this, 2, value); +proto.logproto.SampleQueryResponse.prototype.clearSeriesList = function() { + return this.setSeriesList([]); }; + /** - * optional google.protobuf.Timestamp start = 3; - * @return {?proto.google.protobuf.Timestamp} + * List of repeated fields within this message type. + * @private {!Array} + * @const */ -proto.logproto.LabelRequest.prototype.getStart = function() { - return /** @type{?proto.google.protobuf.Timestamp} */ ( - jspb.Message.getWrapperField(this, google_protobuf_timestamp_pb.Timestamp, 3)); -}; +proto.logproto.QueryResponse.repeatedFields_ = [1]; + +if (jspb.Message.GENERATE_TO_OBJECT) { /** - * @param {?proto.google.protobuf.Timestamp|undefined} value - * @return {!proto.logproto.LabelRequest} returns this -*/ -proto.logproto.LabelRequest.prototype.setStart = function(value) { - return jspb.Message.setWrapperField(this, 3, value); + * 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.logproto.QueryResponse.prototype.toObject = function(opt_includeInstance) { + return proto.logproto.QueryResponse.toObject(opt_includeInstance, this); }; /** - * Clears the message field making it undefined. - * @return {!proto.logproto.LabelRequest} returns 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.logproto.QueryResponse} msg The msg instance to transform. + * @return {!Object} + * @suppress {unusedLocalVariables} f is only used for nested messages */ -proto.logproto.LabelRequest.prototype.clearStart = function() { - return this.setStart(undefined); +proto.logproto.QueryResponse.toObject = function(includeInstance, msg) { + var f, obj = { + streamsList: jspb.Message.toObjectList(msg.getStreamsList(), + proto.logproto.StreamAdapter.toObject, includeInstance) + }; + + if (includeInstance) { + obj.$jspbMessageInstance = msg; + } + return obj; }; +} /** - * Returns whether this field is set. - * @return {boolean} + * Deserializes binary data (in protobuf wire format). + * @param {jspb.ByteSource} bytes The bytes to deserialize. + * @return {!proto.logproto.QueryResponse} */ -proto.logproto.LabelRequest.prototype.hasStart = function() { - return jspb.Message.getField(this, 3) != null; +proto.logproto.QueryResponse.deserializeBinary = function(bytes) { + var reader = new jspb.BinaryReader(bytes); + var msg = new proto.logproto.QueryResponse; + return proto.logproto.QueryResponse.deserializeBinaryFromReader(msg, reader); }; /** - * optional google.protobuf.Timestamp end = 4; - * @return {?proto.google.protobuf.Timestamp} + * Deserializes binary data (in protobuf wire format) from the + * given reader into the given message object. + * @param {!proto.logproto.QueryResponse} msg The message object to deserialize into. + * @param {!jspb.BinaryReader} reader The BinaryReader to use. + * @return {!proto.logproto.QueryResponse} */ -proto.logproto.LabelRequest.prototype.getEnd = function() { - return /** @type{?proto.google.protobuf.Timestamp} */ ( - jspb.Message.getWrapperField(this, google_protobuf_timestamp_pb.Timestamp, 4)); +proto.logproto.QueryResponse.deserializeBinaryFromReader = function(msg, reader) { + while (reader.nextField()) { + if (reader.isEndGroup()) { + break; + } + var field = reader.getFieldNumber(); + switch (field) { + case 1: + var value = new proto.logproto.StreamAdapter; + reader.readMessage(value,proto.logproto.StreamAdapter.deserializeBinaryFromReader); + msg.addStreams(value); + break; + default: + reader.skipField(); + break; + } + } + return msg; +}; + + +/** + * Serializes the message to binary data (in protobuf wire format). + * @return {!Uint8Array} + */ +proto.logproto.QueryResponse.prototype.serializeBinary = function() { + var writer = new jspb.BinaryWriter(); + proto.logproto.QueryResponse.serializeBinaryToWriter(this, writer); + return writer.getResultBuffer(); +}; + + +/** + * Serializes the given message to binary data (in protobuf wire + * format), writing to the given BinaryWriter. + * @param {!proto.logproto.QueryResponse} message + * @param {!jspb.BinaryWriter} writer + * @suppress {unusedLocalVariables} f is only used for nested messages + */ +proto.logproto.QueryResponse.serializeBinaryToWriter = function(message, writer) { + var f = undefined; + f = message.getStreamsList(); + if (f.length > 0) { + writer.writeRepeatedMessage( + 1, + f, + proto.logproto.StreamAdapter.serializeBinaryToWriter + ); + } +}; + + +/** + * repeated StreamAdapter streams = 1; + * @return {!Array} + */ +proto.logproto.QueryResponse.prototype.getStreamsList = function() { + return /** @type{!Array} */ ( + jspb.Message.getRepeatedWrapperField(this, proto.logproto.StreamAdapter, 1)); +}; + + +/** + * @param {!Array} value + * @return {!proto.logproto.QueryResponse} returns this +*/ +proto.logproto.QueryResponse.prototype.setStreamsList = function(value) { + return jspb.Message.setRepeatedWrapperField(this, 1, value); +}; + + +/** + * @param {!proto.logproto.StreamAdapter=} opt_value + * @param {number=} opt_index + * @return {!proto.logproto.StreamAdapter} + */ +proto.logproto.QueryResponse.prototype.addStreams = function(opt_value, opt_index) { + return jspb.Message.addToRepeatedWrapperField(this, 1, opt_value, proto.logproto.StreamAdapter, opt_index); +}; + + +/** + * Clears the list making it empty but non-null. + * @return {!proto.logproto.QueryResponse} returns this + */ +proto.logproto.QueryResponse.prototype.clearStreamsList = function() { + return this.setStreamsList([]); +}; + + + + + +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.logproto.LabelRequest.prototype.toObject = function(opt_includeInstance) { + return proto.logproto.LabelRequest.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.logproto.LabelRequest} msg The msg instance to transform. + * @return {!Object} + * @suppress {unusedLocalVariables} f is only used for nested messages + */ +proto.logproto.LabelRequest.toObject = function(includeInstance, msg) { + var f, obj = { + name: jspb.Message.getFieldWithDefault(msg, 1, ""), + values: jspb.Message.getBooleanFieldWithDefault(msg, 2, false), + start: (f = msg.getStart()) && google_protobuf_timestamp_pb.Timestamp.toObject(includeInstance, f), + end: (f = msg.getEnd()) && google_protobuf_timestamp_pb.Timestamp.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.logproto.LabelRequest} + */ +proto.logproto.LabelRequest.deserializeBinary = function(bytes) { + var reader = new jspb.BinaryReader(bytes); + var msg = new proto.logproto.LabelRequest; + return proto.logproto.LabelRequest.deserializeBinaryFromReader(msg, reader); +}; + + +/** + * Deserializes binary data (in protobuf wire format) from the + * given reader into the given message object. + * @param {!proto.logproto.LabelRequest} msg The message object to deserialize into. + * @param {!jspb.BinaryReader} reader The BinaryReader to use. + * @return {!proto.logproto.LabelRequest} + */ +proto.logproto.LabelRequest.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.setName(value); + break; + case 2: + var value = /** @type {boolean} */ (reader.readBool()); + msg.setValues(value); + break; + case 3: + var value = new google_protobuf_timestamp_pb.Timestamp; + reader.readMessage(value,google_protobuf_timestamp_pb.Timestamp.deserializeBinaryFromReader); + msg.setStart(value); + break; + case 4: + var value = new google_protobuf_timestamp_pb.Timestamp; + reader.readMessage(value,google_protobuf_timestamp_pb.Timestamp.deserializeBinaryFromReader); + msg.setEnd(value); + break; + default: + reader.skipField(); + break; + } + } + return msg; +}; + + +/** + * Serializes the message to binary data (in protobuf wire format). + * @return {!Uint8Array} + */ +proto.logproto.LabelRequest.prototype.serializeBinary = function() { + var writer = new jspb.BinaryWriter(); + proto.logproto.LabelRequest.serializeBinaryToWriter(this, writer); + return writer.getResultBuffer(); +}; + + +/** + * Serializes the given message to binary data (in protobuf wire + * format), writing to the given BinaryWriter. + * @param {!proto.logproto.LabelRequest} message + * @param {!jspb.BinaryWriter} writer + * @suppress {unusedLocalVariables} f is only used for nested messages + */ +proto.logproto.LabelRequest.serializeBinaryToWriter = function(message, writer) { + var f = undefined; + f = message.getName(); + if (f.length > 0) { + writer.writeString( + 1, + f + ); + } + f = message.getValues(); + if (f) { + writer.writeBool( + 2, + f + ); + } + f = message.getStart(); + if (f != null) { + writer.writeMessage( + 3, + f, + google_protobuf_timestamp_pb.Timestamp.serializeBinaryToWriter + ); + } + f = message.getEnd(); + if (f != null) { + writer.writeMessage( + 4, + f, + google_protobuf_timestamp_pb.Timestamp.serializeBinaryToWriter + ); + } +}; + + +/** + * optional string name = 1; + * @return {string} + */ +proto.logproto.LabelRequest.prototype.getName = function() { + return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 1, "")); +}; + + +/** + * @param {string} value + * @return {!proto.logproto.LabelRequest} returns this + */ +proto.logproto.LabelRequest.prototype.setName = function(value) { + return jspb.Message.setProto3StringField(this, 1, value); +}; + + +/** + * optional bool values = 2; + * @return {boolean} + */ +proto.logproto.LabelRequest.prototype.getValues = function() { + return /** @type {boolean} */ (jspb.Message.getBooleanFieldWithDefault(this, 2, false)); +}; + + +/** + * @param {boolean} value + * @return {!proto.logproto.LabelRequest} returns this + */ +proto.logproto.LabelRequest.prototype.setValues = function(value) { + return jspb.Message.setProto3BooleanField(this, 2, value); +}; + + +/** + * optional google.protobuf.Timestamp start = 3; + * @return {?proto.google.protobuf.Timestamp} + */ +proto.logproto.LabelRequest.prototype.getStart = function() { + return /** @type{?proto.google.protobuf.Timestamp} */ ( + jspb.Message.getWrapperField(this, google_protobuf_timestamp_pb.Timestamp, 3)); +}; + + +/** + * @param {?proto.google.protobuf.Timestamp|undefined} value + * @return {!proto.logproto.LabelRequest} returns this +*/ +proto.logproto.LabelRequest.prototype.setStart = function(value) { + return jspb.Message.setWrapperField(this, 3, value); +}; + + +/** + * Clears the message field making it undefined. + * @return {!proto.logproto.LabelRequest} returns this + */ +proto.logproto.LabelRequest.prototype.clearStart = function() { + return this.setStart(undefined); +}; + + +/** + * Returns whether this field is set. + * @return {boolean} + */ +proto.logproto.LabelRequest.prototype.hasStart = function() { + return jspb.Message.getField(this, 3) != null; +}; + + +/** + * optional google.protobuf.Timestamp end = 4; + * @return {?proto.google.protobuf.Timestamp} + */ +proto.logproto.LabelRequest.prototype.getEnd = function() { + return /** @type{?proto.google.protobuf.Timestamp} */ ( + jspb.Message.getWrapperField(this, google_protobuf_timestamp_pb.Timestamp, 4)); }; @@ -1424,20 +2060,176 @@ proto.logproto.LabelRequest.prototype.setEnd = function(value) { /** - * Clears the message field making it undefined. - * @return {!proto.logproto.LabelRequest} returns this + * Clears the message field making it undefined. + * @return {!proto.logproto.LabelRequest} returns this + */ +proto.logproto.LabelRequest.prototype.clearEnd = function() { + return this.setEnd(undefined); +}; + + +/** + * Returns whether this field is set. + * @return {boolean} + */ +proto.logproto.LabelRequest.prototype.hasEnd = function() { + return jspb.Message.getField(this, 4) != null; +}; + + + +/** + * List of repeated fields within this message type. + * @private {!Array} + * @const + */ +proto.logproto.LabelResponse.repeatedFields_ = [1]; + + + +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.logproto.LabelResponse.prototype.toObject = function(opt_includeInstance) { + return proto.logproto.LabelResponse.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.logproto.LabelResponse} msg The msg instance to transform. + * @return {!Object} + * @suppress {unusedLocalVariables} f is only used for nested messages + */ +proto.logproto.LabelResponse.toObject = function(includeInstance, msg) { + var f, obj = { + valuesList: (f = jspb.Message.getRepeatedField(msg, 1)) == null ? undefined : 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.logproto.LabelResponse} + */ +proto.logproto.LabelResponse.deserializeBinary = function(bytes) { + var reader = new jspb.BinaryReader(bytes); + var msg = new proto.logproto.LabelResponse; + return proto.logproto.LabelResponse.deserializeBinaryFromReader(msg, reader); +}; + + +/** + * Deserializes binary data (in protobuf wire format) from the + * given reader into the given message object. + * @param {!proto.logproto.LabelResponse} msg The message object to deserialize into. + * @param {!jspb.BinaryReader} reader The BinaryReader to use. + * @return {!proto.logproto.LabelResponse} + */ +proto.logproto.LabelResponse.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.addValues(value); + break; + default: + reader.skipField(); + break; + } + } + return msg; +}; + + +/** + * Serializes the message to binary data (in protobuf wire format). + * @return {!Uint8Array} */ -proto.logproto.LabelRequest.prototype.clearEnd = function() { - return this.setEnd(undefined); +proto.logproto.LabelResponse.prototype.serializeBinary = function() { + var writer = new jspb.BinaryWriter(); + proto.logproto.LabelResponse.serializeBinaryToWriter(this, writer); + return writer.getResultBuffer(); }; /** - * Returns whether this field is set. - * @return {boolean} + * Serializes the given message to binary data (in protobuf wire + * format), writing to the given BinaryWriter. + * @param {!proto.logproto.LabelResponse} message + * @param {!jspb.BinaryWriter} writer + * @suppress {unusedLocalVariables} f is only used for nested messages */ -proto.logproto.LabelRequest.prototype.hasEnd = function() { - return jspb.Message.getField(this, 4) != null; +proto.logproto.LabelResponse.serializeBinaryToWriter = function(message, writer) { + var f = undefined; + f = message.getValuesList(); + if (f.length > 0) { + writer.writeRepeatedString( + 1, + f + ); + } +}; + + +/** + * repeated string values = 1; + * @return {!Array} + */ +proto.logproto.LabelResponse.prototype.getValuesList = function() { + return /** @type {!Array} */ (jspb.Message.getRepeatedField(this, 1)); +}; + + +/** + * @param {!Array} value + * @return {!proto.logproto.LabelResponse} returns this + */ +proto.logproto.LabelResponse.prototype.setValuesList = function(value) { + return jspb.Message.setField(this, 1, value || []); +}; + + +/** + * @param {string} value + * @param {number=} opt_index + * @return {!proto.logproto.LabelResponse} returns this + */ +proto.logproto.LabelResponse.prototype.addValues = function(value, opt_index) { + return jspb.Message.addToRepeatedField(this, 1, value, opt_index); +}; + + +/** + * Clears the list making it empty but non-null. + * @return {!proto.logproto.LabelResponse} returns this + */ +proto.logproto.LabelResponse.prototype.clearValuesList = function() { + return this.setValuesList([]); }; @@ -1447,7 +2239,190 @@ proto.logproto.LabelRequest.prototype.hasEnd = function() { * @private {!Array} * @const */ -proto.logproto.LabelResponse.repeatedFields_ = [1]; +proto.logproto.StreamAdapter.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.logproto.StreamAdapter.prototype.toObject = function(opt_includeInstance) { + return proto.logproto.StreamAdapter.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.logproto.StreamAdapter} msg The msg instance to transform. + * @return {!Object} + * @suppress {unusedLocalVariables} f is only used for nested messages + */ +proto.logproto.StreamAdapter.toObject = function(includeInstance, msg) { + var f, obj = { + labels: jspb.Message.getFieldWithDefault(msg, 1, ""), + entriesList: jspb.Message.toObjectList(msg.getEntriesList(), + proto.logproto.EntryAdapter.toObject, includeInstance) + }; + + if (includeInstance) { + obj.$jspbMessageInstance = msg; + } + return obj; +}; +} + + +/** + * Deserializes binary data (in protobuf wire format). + * @param {jspb.ByteSource} bytes The bytes to deserialize. + * @return {!proto.logproto.StreamAdapter} + */ +proto.logproto.StreamAdapter.deserializeBinary = function(bytes) { + var reader = new jspb.BinaryReader(bytes); + var msg = new proto.logproto.StreamAdapter; + return proto.logproto.StreamAdapter.deserializeBinaryFromReader(msg, reader); +}; + + +/** + * Deserializes binary data (in protobuf wire format) from the + * given reader into the given message object. + * @param {!proto.logproto.StreamAdapter} msg The message object to deserialize into. + * @param {!jspb.BinaryReader} reader The BinaryReader to use. + * @return {!proto.logproto.StreamAdapter} + */ +proto.logproto.StreamAdapter.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.setLabels(value); + break; + case 2: + var value = new proto.logproto.EntryAdapter; + reader.readMessage(value,proto.logproto.EntryAdapter.deserializeBinaryFromReader); + msg.addEntries(value); + break; + default: + reader.skipField(); + break; + } + } + return msg; +}; + + +/** + * Serializes the message to binary data (in protobuf wire format). + * @return {!Uint8Array} + */ +proto.logproto.StreamAdapter.prototype.serializeBinary = function() { + var writer = new jspb.BinaryWriter(); + proto.logproto.StreamAdapter.serializeBinaryToWriter(this, writer); + return writer.getResultBuffer(); +}; + + +/** + * Serializes the given message to binary data (in protobuf wire + * format), writing to the given BinaryWriter. + * @param {!proto.logproto.StreamAdapter} message + * @param {!jspb.BinaryWriter} writer + * @suppress {unusedLocalVariables} f is only used for nested messages + */ +proto.logproto.StreamAdapter.serializeBinaryToWriter = function(message, writer) { + var f = undefined; + f = message.getLabels(); + if (f.length > 0) { + writer.writeString( + 1, + f + ); + } + f = message.getEntriesList(); + if (f.length > 0) { + writer.writeRepeatedMessage( + 2, + f, + proto.logproto.EntryAdapter.serializeBinaryToWriter + ); + } +}; + + +/** + * optional string labels = 1; + * @return {string} + */ +proto.logproto.StreamAdapter.prototype.getLabels = function() { + return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 1, "")); +}; + + +/** + * @param {string} value + * @return {!proto.logproto.StreamAdapter} returns this + */ +proto.logproto.StreamAdapter.prototype.setLabels = function(value) { + return jspb.Message.setProto3StringField(this, 1, value); +}; + + +/** + * repeated EntryAdapter entries = 2; + * @return {!Array} + */ +proto.logproto.StreamAdapter.prototype.getEntriesList = function() { + return /** @type{!Array} */ ( + jspb.Message.getRepeatedWrapperField(this, proto.logproto.EntryAdapter, 2)); +}; + + +/** + * @param {!Array} value + * @return {!proto.logproto.StreamAdapter} returns this +*/ +proto.logproto.StreamAdapter.prototype.setEntriesList = function(value) { + return jspb.Message.setRepeatedWrapperField(this, 2, value); +}; + + +/** + * @param {!proto.logproto.EntryAdapter=} opt_value + * @param {number=} opt_index + * @return {!proto.logproto.EntryAdapter} + */ +proto.logproto.StreamAdapter.prototype.addEntries = function(opt_value, opt_index) { + return jspb.Message.addToRepeatedWrapperField(this, 2, opt_value, proto.logproto.EntryAdapter, opt_index); +}; + + +/** + * Clears the list making it empty but non-null. + * @return {!proto.logproto.StreamAdapter} returns this + */ +proto.logproto.StreamAdapter.prototype.clearEntriesList = function() { + return this.setEntriesList([]); +}; + + @@ -1464,8 +2439,8 @@ if (jspb.Message.GENERATE_TO_OBJECT) { * http://goto/soy-param-migration * @return {!Object} */ -proto.logproto.LabelResponse.prototype.toObject = function(opt_includeInstance) { - return proto.logproto.LabelResponse.toObject(opt_includeInstance, this); +proto.logproto.EntryAdapter.prototype.toObject = function(opt_includeInstance) { + return proto.logproto.EntryAdapter.toObject(opt_includeInstance, this); }; @@ -1474,13 +2449,14 @@ proto.logproto.LabelResponse.prototype.toObject = function(opt_includeInstance) * @param {boolean|undefined} includeInstance Deprecated. Whether to include * the JSPB instance for transitional soy proto support: * http://goto/soy-param-migration - * @param {!proto.logproto.LabelResponse} msg The msg instance to transform. + * @param {!proto.logproto.EntryAdapter} msg The msg instance to transform. * @return {!Object} * @suppress {unusedLocalVariables} f is only used for nested messages */ -proto.logproto.LabelResponse.toObject = function(includeInstance, msg) { +proto.logproto.EntryAdapter.toObject = function(includeInstance, msg) { var f, obj = { - valuesList: (f = jspb.Message.getRepeatedField(msg, 1)) == null ? undefined : f + timestamp: (f = msg.getTimestamp()) && google_protobuf_timestamp_pb.Timestamp.toObject(includeInstance, f), + line: jspb.Message.getFieldWithDefault(msg, 2, "") }; if (includeInstance) { @@ -1494,23 +2470,23 @@ proto.logproto.LabelResponse.toObject = function(includeInstance, msg) { /** * Deserializes binary data (in protobuf wire format). * @param {jspb.ByteSource} bytes The bytes to deserialize. - * @return {!proto.logproto.LabelResponse} + * @return {!proto.logproto.EntryAdapter} */ -proto.logproto.LabelResponse.deserializeBinary = function(bytes) { +proto.logproto.EntryAdapter.deserializeBinary = function(bytes) { var reader = new jspb.BinaryReader(bytes); - var msg = new proto.logproto.LabelResponse; - return proto.logproto.LabelResponse.deserializeBinaryFromReader(msg, reader); + var msg = new proto.logproto.EntryAdapter; + return proto.logproto.EntryAdapter.deserializeBinaryFromReader(msg, reader); }; /** * Deserializes binary data (in protobuf wire format) from the * given reader into the given message object. - * @param {!proto.logproto.LabelResponse} msg The message object to deserialize into. + * @param {!proto.logproto.EntryAdapter} msg The message object to deserialize into. * @param {!jspb.BinaryReader} reader The BinaryReader to use. - * @return {!proto.logproto.LabelResponse} + * @return {!proto.logproto.EntryAdapter} */ -proto.logproto.LabelResponse.deserializeBinaryFromReader = function(msg, reader) { +proto.logproto.EntryAdapter.deserializeBinaryFromReader = function(msg, reader) { while (reader.nextField()) { if (reader.isEndGroup()) { break; @@ -1518,8 +2494,13 @@ proto.logproto.LabelResponse.deserializeBinaryFromReader = function(msg, reader) var field = reader.getFieldNumber(); switch (field) { case 1: + var value = new google_protobuf_timestamp_pb.Timestamp; + reader.readMessage(value,google_protobuf_timestamp_pb.Timestamp.deserializeBinaryFromReader); + msg.setTimestamp(value); + break; + case 2: var value = /** @type {string} */ (reader.readString()); - msg.addValues(value); + msg.setLine(value); break; default: reader.skipField(); @@ -1534,9 +2515,9 @@ proto.logproto.LabelResponse.deserializeBinaryFromReader = function(msg, reader) * Serializes the message to binary data (in protobuf wire format). * @return {!Uint8Array} */ -proto.logproto.LabelResponse.prototype.serializeBinary = function() { +proto.logproto.EntryAdapter.prototype.serializeBinary = function() { var writer = new jspb.BinaryWriter(); - proto.logproto.LabelResponse.serializeBinaryToWriter(this, writer); + proto.logproto.EntryAdapter.serializeBinaryToWriter(this, writer); return writer.getResultBuffer(); }; @@ -1544,16 +2525,24 @@ proto.logproto.LabelResponse.prototype.serializeBinary = function() { /** * Serializes the given message to binary data (in protobuf wire * format), writing to the given BinaryWriter. - * @param {!proto.logproto.LabelResponse} message + * @param {!proto.logproto.EntryAdapter} message * @param {!jspb.BinaryWriter} writer * @suppress {unusedLocalVariables} f is only used for nested messages */ -proto.logproto.LabelResponse.serializeBinaryToWriter = function(message, writer) { +proto.logproto.EntryAdapter.serializeBinaryToWriter = function(message, writer) { var f = undefined; - f = message.getValuesList(); - if (f.length > 0) { - writer.writeRepeatedString( + f = message.getTimestamp(); + if (f != null) { + writer.writeMessage( 1, + f, + google_protobuf_timestamp_pb.Timestamp.serializeBinaryToWriter + ); + } + f = message.getLine(); + if (f.length > 0) { + writer.writeString( + 2, f ); } @@ -1561,49 +2550,60 @@ proto.logproto.LabelResponse.serializeBinaryToWriter = function(message, writer) /** - * repeated string values = 1; - * @return {!Array} + * optional google.protobuf.Timestamp timestamp = 1; + * @return {?proto.google.protobuf.Timestamp} */ -proto.logproto.LabelResponse.prototype.getValuesList = function() { - return /** @type {!Array} */ (jspb.Message.getRepeatedField(this, 1)); +proto.logproto.EntryAdapter.prototype.getTimestamp = function() { + return /** @type{?proto.google.protobuf.Timestamp} */ ( + jspb.Message.getWrapperField(this, google_protobuf_timestamp_pb.Timestamp, 1)); }; /** - * @param {!Array} value - * @return {!proto.logproto.LabelResponse} returns this - */ -proto.logproto.LabelResponse.prototype.setValuesList = function(value) { - return jspb.Message.setField(this, 1, value || []); + * @param {?proto.google.protobuf.Timestamp|undefined} value + * @return {!proto.logproto.EntryAdapter} returns this +*/ +proto.logproto.EntryAdapter.prototype.setTimestamp = function(value) { + return jspb.Message.setWrapperField(this, 1, value); }; /** - * @param {string} value - * @param {number=} opt_index - * @return {!proto.logproto.LabelResponse} returns this + * Clears the message field making it undefined. + * @return {!proto.logproto.EntryAdapter} returns this */ -proto.logproto.LabelResponse.prototype.addValues = function(value, opt_index) { - return jspb.Message.addToRepeatedField(this, 1, value, opt_index); +proto.logproto.EntryAdapter.prototype.clearTimestamp = function() { + return this.setTimestamp(undefined); }; /** - * Clears the list making it empty but non-null. - * @return {!proto.logproto.LabelResponse} returns this + * Returns whether this field is set. + * @return {boolean} */ -proto.logproto.LabelResponse.prototype.clearValuesList = function() { - return this.setValuesList([]); +proto.logproto.EntryAdapter.prototype.hasTimestamp = function() { + return jspb.Message.getField(this, 1) != null; }; +/** + * optional string line = 2; + * @return {string} + */ +proto.logproto.EntryAdapter.prototype.getLine = function() { + return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 2, "")); +}; + /** - * List of repeated fields within this message type. - * @private {!Array} - * @const + * @param {string} value + * @return {!proto.logproto.EntryAdapter} returns this */ -proto.logproto.StreamAdapter.repeatedFields_ = [2]; +proto.logproto.EntryAdapter.prototype.setLine = function(value) { + return jspb.Message.setProto3StringField(this, 2, value); +}; + + @@ -1620,8 +2620,8 @@ if (jspb.Message.GENERATE_TO_OBJECT) { * http://goto/soy-param-migration * @return {!Object} */ -proto.logproto.StreamAdapter.prototype.toObject = function(opt_includeInstance) { - return proto.logproto.StreamAdapter.toObject(opt_includeInstance, this); +proto.logproto.Sample.prototype.toObject = function(opt_includeInstance) { + return proto.logproto.Sample.toObject(opt_includeInstance, this); }; @@ -1630,15 +2630,15 @@ proto.logproto.StreamAdapter.prototype.toObject = function(opt_includeInstance) * @param {boolean|undefined} includeInstance Deprecated. Whether to include * the JSPB instance for transitional soy proto support: * http://goto/soy-param-migration - * @param {!proto.logproto.StreamAdapter} msg The msg instance to transform. + * @param {!proto.logproto.Sample} msg The msg instance to transform. * @return {!Object} * @suppress {unusedLocalVariables} f is only used for nested messages */ -proto.logproto.StreamAdapter.toObject = function(includeInstance, msg) { +proto.logproto.Sample.toObject = function(includeInstance, msg) { var f, obj = { - labels: jspb.Message.getFieldWithDefault(msg, 1, ""), - entriesList: jspb.Message.toObjectList(msg.getEntriesList(), - proto.logproto.EntryAdapter.toObject, includeInstance) + timestamp: jspb.Message.getFieldWithDefault(msg, 1, 0), + value: jspb.Message.getFloatingPointFieldWithDefault(msg, 2, 0.0), + hash: jspb.Message.getFieldWithDefault(msg, 3, 0) }; if (includeInstance) { @@ -1652,23 +2652,23 @@ proto.logproto.StreamAdapter.toObject = function(includeInstance, msg) { /** * Deserializes binary data (in protobuf wire format). * @param {jspb.ByteSource} bytes The bytes to deserialize. - * @return {!proto.logproto.StreamAdapter} + * @return {!proto.logproto.Sample} */ -proto.logproto.StreamAdapter.deserializeBinary = function(bytes) { +proto.logproto.Sample.deserializeBinary = function(bytes) { var reader = new jspb.BinaryReader(bytes); - var msg = new proto.logproto.StreamAdapter; - return proto.logproto.StreamAdapter.deserializeBinaryFromReader(msg, reader); + var msg = new proto.logproto.Sample; + return proto.logproto.Sample.deserializeBinaryFromReader(msg, reader); }; /** * Deserializes binary data (in protobuf wire format) from the * given reader into the given message object. - * @param {!proto.logproto.StreamAdapter} msg The message object to deserialize into. + * @param {!proto.logproto.Sample} msg The message object to deserialize into. * @param {!jspb.BinaryReader} reader The BinaryReader to use. - * @return {!proto.logproto.StreamAdapter} + * @return {!proto.logproto.Sample} */ -proto.logproto.StreamAdapter.deserializeBinaryFromReader = function(msg, reader) { +proto.logproto.Sample.deserializeBinaryFromReader = function(msg, reader) { while (reader.nextField()) { if (reader.isEndGroup()) { break; @@ -1676,13 +2676,16 @@ proto.logproto.StreamAdapter.deserializeBinaryFromReader = function(msg, reader) var field = reader.getFieldNumber(); switch (field) { case 1: - var value = /** @type {string} */ (reader.readString()); - msg.setLabels(value); + var value = /** @type {number} */ (reader.readInt64()); + msg.setTimestamp(value); break; case 2: - var value = new proto.logproto.EntryAdapter; - reader.readMessage(value,proto.logproto.EntryAdapter.deserializeBinaryFromReader); - msg.addEntries(value); + var value = /** @type {number} */ (reader.readDouble()); + msg.setValue(value); + break; + case 3: + var value = /** @type {number} */ (reader.readUint64()); + msg.setHash(value); break; default: reader.skipField(); @@ -1697,9 +2700,9 @@ proto.logproto.StreamAdapter.deserializeBinaryFromReader = function(msg, reader) * Serializes the message to binary data (in protobuf wire format). * @return {!Uint8Array} */ -proto.logproto.StreamAdapter.prototype.serializeBinary = function() { +proto.logproto.Sample.prototype.serializeBinary = function() { var writer = new jspb.BinaryWriter(); - proto.logproto.StreamAdapter.serializeBinaryToWriter(this, writer); + proto.logproto.Sample.serializeBinaryToWriter(this, writer); return writer.getResultBuffer(); }; @@ -1707,87 +2710,98 @@ proto.logproto.StreamAdapter.prototype.serializeBinary = function() { /** * Serializes the given message to binary data (in protobuf wire * format), writing to the given BinaryWriter. - * @param {!proto.logproto.StreamAdapter} message + * @param {!proto.logproto.Sample} message * @param {!jspb.BinaryWriter} writer * @suppress {unusedLocalVariables} f is only used for nested messages */ -proto.logproto.StreamAdapter.serializeBinaryToWriter = function(message, writer) { +proto.logproto.Sample.serializeBinaryToWriter = function(message, writer) { var f = undefined; - f = message.getLabels(); - if (f.length > 0) { - writer.writeString( + f = message.getTimestamp(); + if (f !== 0) { + writer.writeInt64( 1, f ); } - f = message.getEntriesList(); - if (f.length > 0) { - writer.writeRepeatedMessage( + f = message.getValue(); + if (f !== 0.0) { + writer.writeDouble( 2, - f, - proto.logproto.EntryAdapter.serializeBinaryToWriter + f + ); + } + f = message.getHash(); + if (f !== 0) { + writer.writeUint64( + 3, + f ); } }; /** - * optional string labels = 1; - * @return {string} + * optional int64 timestamp = 1; + * @return {number} */ -proto.logproto.StreamAdapter.prototype.getLabels = function() { - return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 1, "")); +proto.logproto.Sample.prototype.getTimestamp = function() { + return /** @type {number} */ (jspb.Message.getFieldWithDefault(this, 1, 0)); }; /** - * @param {string} value - * @return {!proto.logproto.StreamAdapter} returns this + * @param {number} value + * @return {!proto.logproto.Sample} returns this */ -proto.logproto.StreamAdapter.prototype.setLabels = function(value) { - return jspb.Message.setProto3StringField(this, 1, value); +proto.logproto.Sample.prototype.setTimestamp = function(value) { + return jspb.Message.setProto3IntField(this, 1, value); }; /** - * repeated EntryAdapter entries = 2; - * @return {!Array} + * optional double value = 2; + * @return {number} */ -proto.logproto.StreamAdapter.prototype.getEntriesList = function() { - return /** @type{!Array} */ ( - jspb.Message.getRepeatedWrapperField(this, proto.logproto.EntryAdapter, 2)); +proto.logproto.Sample.prototype.getValue = function() { + return /** @type {number} */ (jspb.Message.getFloatingPointFieldWithDefault(this, 2, 0.0)); }; /** - * @param {!Array} value - * @return {!proto.logproto.StreamAdapter} returns this -*/ -proto.logproto.StreamAdapter.prototype.setEntriesList = function(value) { - return jspb.Message.setRepeatedWrapperField(this, 2, value); + * @param {number} value + * @return {!proto.logproto.Sample} returns this + */ +proto.logproto.Sample.prototype.setValue = function(value) { + return jspb.Message.setProto3FloatField(this, 2, value); }; /** - * @param {!proto.logproto.EntryAdapter=} opt_value - * @param {number=} opt_index - * @return {!proto.logproto.EntryAdapter} + * optional uint64 hash = 3; + * @return {number} */ -proto.logproto.StreamAdapter.prototype.addEntries = function(opt_value, opt_index) { - return jspb.Message.addToRepeatedWrapperField(this, 2, opt_value, proto.logproto.EntryAdapter, opt_index); +proto.logproto.Sample.prototype.getHash = function() { + return /** @type {number} */ (jspb.Message.getFieldWithDefault(this, 3, 0)); }; /** - * Clears the list making it empty but non-null. - * @return {!proto.logproto.StreamAdapter} returns this + * @param {number} value + * @return {!proto.logproto.Sample} returns this */ -proto.logproto.StreamAdapter.prototype.clearEntriesList = function() { - return this.setEntriesList([]); +proto.logproto.Sample.prototype.setHash = function(value) { + return jspb.Message.setProto3IntField(this, 3, value); }; +/** + * List of repeated fields within this message type. + * @private {!Array} + * @const + */ +proto.logproto.Series.repeatedFields_ = [2]; + if (jspb.Message.GENERATE_TO_OBJECT) { @@ -1803,8 +2817,8 @@ if (jspb.Message.GENERATE_TO_OBJECT) { * http://goto/soy-param-migration * @return {!Object} */ -proto.logproto.EntryAdapter.prototype.toObject = function(opt_includeInstance) { - return proto.logproto.EntryAdapter.toObject(opt_includeInstance, this); +proto.logproto.Series.prototype.toObject = function(opt_includeInstance) { + return proto.logproto.Series.toObject(opt_includeInstance, this); }; @@ -1813,14 +2827,15 @@ proto.logproto.EntryAdapter.prototype.toObject = function(opt_includeInstance) { * @param {boolean|undefined} includeInstance Deprecated. Whether to include * the JSPB instance for transitional soy proto support: * http://goto/soy-param-migration - * @param {!proto.logproto.EntryAdapter} msg The msg instance to transform. + * @param {!proto.logproto.Series} msg The msg instance to transform. * @return {!Object} * @suppress {unusedLocalVariables} f is only used for nested messages */ -proto.logproto.EntryAdapter.toObject = function(includeInstance, msg) { +proto.logproto.Series.toObject = function(includeInstance, msg) { var f, obj = { - timestamp: (f = msg.getTimestamp()) && google_protobuf_timestamp_pb.Timestamp.toObject(includeInstance, f), - line: jspb.Message.getFieldWithDefault(msg, 2, "") + labels: jspb.Message.getFieldWithDefault(msg, 1, ""), + samplesList: jspb.Message.toObjectList(msg.getSamplesList(), + proto.logproto.Sample.toObject, includeInstance) }; if (includeInstance) { @@ -1834,23 +2849,23 @@ proto.logproto.EntryAdapter.toObject = function(includeInstance, msg) { /** * Deserializes binary data (in protobuf wire format). * @param {jspb.ByteSource} bytes The bytes to deserialize. - * @return {!proto.logproto.EntryAdapter} + * @return {!proto.logproto.Series} */ -proto.logproto.EntryAdapter.deserializeBinary = function(bytes) { +proto.logproto.Series.deserializeBinary = function(bytes) { var reader = new jspb.BinaryReader(bytes); - var msg = new proto.logproto.EntryAdapter; - return proto.logproto.EntryAdapter.deserializeBinaryFromReader(msg, reader); + var msg = new proto.logproto.Series; + return proto.logproto.Series.deserializeBinaryFromReader(msg, reader); }; /** * Deserializes binary data (in protobuf wire format) from the * given reader into the given message object. - * @param {!proto.logproto.EntryAdapter} msg The message object to deserialize into. + * @param {!proto.logproto.Series} msg The message object to deserialize into. * @param {!jspb.BinaryReader} reader The BinaryReader to use. - * @return {!proto.logproto.EntryAdapter} + * @return {!proto.logproto.Series} */ -proto.logproto.EntryAdapter.deserializeBinaryFromReader = function(msg, reader) { +proto.logproto.Series.deserializeBinaryFromReader = function(msg, reader) { while (reader.nextField()) { if (reader.isEndGroup()) { break; @@ -1858,13 +2873,13 @@ proto.logproto.EntryAdapter.deserializeBinaryFromReader = function(msg, reader) var field = reader.getFieldNumber(); switch (field) { case 1: - var value = new google_protobuf_timestamp_pb.Timestamp; - reader.readMessage(value,google_protobuf_timestamp_pb.Timestamp.deserializeBinaryFromReader); - msg.setTimestamp(value); + var value = /** @type {string} */ (reader.readString()); + msg.setLabels(value); break; case 2: - var value = /** @type {string} */ (reader.readString()); - msg.setLine(value); + var value = new proto.logproto.Sample; + reader.readMessage(value,proto.logproto.Sample.deserializeBinaryFromReader); + msg.addSamples(value); break; default: reader.skipField(); @@ -1879,9 +2894,9 @@ proto.logproto.EntryAdapter.deserializeBinaryFromReader = function(msg, reader) * Serializes the message to binary data (in protobuf wire format). * @return {!Uint8Array} */ -proto.logproto.EntryAdapter.prototype.serializeBinary = function() { +proto.logproto.Series.prototype.serializeBinary = function() { var writer = new jspb.BinaryWriter(); - proto.logproto.EntryAdapter.serializeBinaryToWriter(this, writer); + proto.logproto.Series.serializeBinaryToWriter(this, writer); return writer.getResultBuffer(); }; @@ -1889,82 +2904,83 @@ proto.logproto.EntryAdapter.prototype.serializeBinary = function() { /** * Serializes the given message to binary data (in protobuf wire * format), writing to the given BinaryWriter. - * @param {!proto.logproto.EntryAdapter} message + * @param {!proto.logproto.Series} message * @param {!jspb.BinaryWriter} writer * @suppress {unusedLocalVariables} f is only used for nested messages */ -proto.logproto.EntryAdapter.serializeBinaryToWriter = function(message, writer) { +proto.logproto.Series.serializeBinaryToWriter = function(message, writer) { var f = undefined; - f = message.getTimestamp(); - if (f != null) { - writer.writeMessage( + f = message.getLabels(); + if (f.length > 0) { + writer.writeString( 1, - f, - google_protobuf_timestamp_pb.Timestamp.serializeBinaryToWriter + f ); } - f = message.getLine(); + f = message.getSamplesList(); if (f.length > 0) { - writer.writeString( + writer.writeRepeatedMessage( 2, - f + f, + proto.logproto.Sample.serializeBinaryToWriter ); } }; /** - * optional google.protobuf.Timestamp timestamp = 1; - * @return {?proto.google.protobuf.Timestamp} + * optional string labels = 1; + * @return {string} */ -proto.logproto.EntryAdapter.prototype.getTimestamp = function() { - return /** @type{?proto.google.protobuf.Timestamp} */ ( - jspb.Message.getWrapperField(this, google_protobuf_timestamp_pb.Timestamp, 1)); +proto.logproto.Series.prototype.getLabels = function() { + return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 1, "")); }; /** - * @param {?proto.google.protobuf.Timestamp|undefined} value - * @return {!proto.logproto.EntryAdapter} returns this -*/ -proto.logproto.EntryAdapter.prototype.setTimestamp = function(value) { - return jspb.Message.setWrapperField(this, 1, value); + * @param {string} value + * @return {!proto.logproto.Series} returns this + */ +proto.logproto.Series.prototype.setLabels = function(value) { + return jspb.Message.setProto3StringField(this, 1, value); }; /** - * Clears the message field making it undefined. - * @return {!proto.logproto.EntryAdapter} returns this + * repeated Sample samples = 2; + * @return {!Array} */ -proto.logproto.EntryAdapter.prototype.clearTimestamp = function() { - return this.setTimestamp(undefined); +proto.logproto.Series.prototype.getSamplesList = function() { + return /** @type{!Array} */ ( + jspb.Message.getRepeatedWrapperField(this, proto.logproto.Sample, 2)); }; /** - * Returns whether this field is set. - * @return {boolean} - */ -proto.logproto.EntryAdapter.prototype.hasTimestamp = function() { - return jspb.Message.getField(this, 1) != null; + * @param {!Array} value + * @return {!proto.logproto.Series} returns this +*/ +proto.logproto.Series.prototype.setSamplesList = function(value) { + return jspb.Message.setRepeatedWrapperField(this, 2, value); }; /** - * optional string line = 2; - * @return {string} + * @param {!proto.logproto.Sample=} opt_value + * @param {number=} opt_index + * @return {!proto.logproto.Sample} */ -proto.logproto.EntryAdapter.prototype.getLine = function() { - return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 2, "")); +proto.logproto.Series.prototype.addSamples = function(opt_value, opt_index) { + return jspb.Message.addToRepeatedWrapperField(this, 2, opt_value, proto.logproto.Sample, opt_index); }; /** - * @param {string} value - * @return {!proto.logproto.EntryAdapter} returns this + * Clears the list making it empty but non-null. + * @return {!proto.logproto.Series} returns this */ -proto.logproto.EntryAdapter.prototype.setLine = function(value) { - return jspb.Message.setProto3StringField(this, 2, value); +proto.logproto.Series.prototype.clearSamplesList = function() { + return this.setSamplesList([]); }; @@ -2426,7 +3442,7 @@ proto.logproto.TailResponse.prototype.clearDroppedstreamsList = function() { * @private {!Array} * @const */ -proto.logproto.SeriesRequest.repeatedFields_ = [3]; +proto.logproto.SeriesRequest.repeatedFields_ = [3,4]; @@ -2461,7 +3477,8 @@ proto.logproto.SeriesRequest.toObject = function(includeInstance, msg) { var f, obj = { start: (f = msg.getStart()) && google_protobuf_timestamp_pb.Timestamp.toObject(includeInstance, f), end: (f = msg.getEnd()) && google_protobuf_timestamp_pb.Timestamp.toObject(includeInstance, f), - groupsList: (f = jspb.Message.getRepeatedField(msg, 3)) == null ? undefined : f + groupsList: (f = jspb.Message.getRepeatedField(msg, 3)) == null ? undefined : f, + shardsList: (f = jspb.Message.getRepeatedField(msg, 4)) == null ? undefined : f }; if (includeInstance) { @@ -2512,6 +3529,10 @@ proto.logproto.SeriesRequest.deserializeBinaryFromReader = function(msg, reader) var value = /** @type {string} */ (reader.readString()); msg.addGroups(value); break; + case 4: + var value = /** @type {string} */ (reader.readString()); + msg.addShards(value); + break; default: reader.skipField(); break; @@ -2564,6 +3585,13 @@ proto.logproto.SeriesRequest.serializeBinaryToWriter = function(message, writer) f ); } + f = message.getShardsList(); + if (f.length > 0) { + writer.writeRepeatedString( + 4, + f + ); + } }; @@ -2678,6 +3706,43 @@ proto.logproto.SeriesRequest.prototype.clearGroupsList = function() { }; +/** + * repeated string shards = 4; + * @return {!Array} + */ +proto.logproto.SeriesRequest.prototype.getShardsList = function() { + return /** @type {!Array} */ (jspb.Message.getRepeatedField(this, 4)); +}; + + +/** + * @param {!Array} value + * @return {!proto.logproto.SeriesRequest} returns this + */ +proto.logproto.SeriesRequest.prototype.setShardsList = function(value) { + return jspb.Message.setField(this, 4, value || []); +}; + + +/** + * @param {string} value + * @param {number=} opt_index + * @return {!proto.logproto.SeriesRequest} returns this + */ +proto.logproto.SeriesRequest.prototype.addShards = function(value, opt_index) { + return jspb.Message.addToRepeatedField(this, 4, value, opt_index); +}; + + +/** + * Clears the list making it empty but non-null. + * @return {!proto.logproto.SeriesRequest} returns this + */ +proto.logproto.SeriesRequest.prototype.clearShardsList = function() { + return this.setShardsList([]); +}; + + /** * List of repeated fields within this message type. @@ -3782,11 +4847,213 @@ proto.logproto.Chunk.prototype.getData_asU8 = function() { /** - * @param {!(string|Uint8Array)} value - * @return {!proto.logproto.Chunk} returns this + * @param {!(string|Uint8Array)} value + * @return {!proto.logproto.Chunk} returns this + */ +proto.logproto.Chunk.prototype.setData = function(value) { + return jspb.Message.setProto3BytesField(this, 1, 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.logproto.TransferChunksResponse.prototype.toObject = function(opt_includeInstance) { + return proto.logproto.TransferChunksResponse.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.logproto.TransferChunksResponse} msg The msg instance to transform. + * @return {!Object} + * @suppress {unusedLocalVariables} f is only used for nested messages + */ +proto.logproto.TransferChunksResponse.toObject = function(includeInstance, msg) { + var f, obj = { + + }; + + if (includeInstance) { + obj.$jspbMessageInstance = msg; + } + return obj; +}; +} + + +/** + * Deserializes binary data (in protobuf wire format). + * @param {jspb.ByteSource} bytes The bytes to deserialize. + * @return {!proto.logproto.TransferChunksResponse} + */ +proto.logproto.TransferChunksResponse.deserializeBinary = function(bytes) { + var reader = new jspb.BinaryReader(bytes); + var msg = new proto.logproto.TransferChunksResponse; + return proto.logproto.TransferChunksResponse.deserializeBinaryFromReader(msg, reader); +}; + + +/** + * Deserializes binary data (in protobuf wire format) from the + * given reader into the given message object. + * @param {!proto.logproto.TransferChunksResponse} msg The message object to deserialize into. + * @param {!jspb.BinaryReader} reader The BinaryReader to use. + * @return {!proto.logproto.TransferChunksResponse} + */ +proto.logproto.TransferChunksResponse.deserializeBinaryFromReader = function(msg, reader) { + while (reader.nextField()) { + if (reader.isEndGroup()) { + break; + } + var field = reader.getFieldNumber(); + switch (field) { + default: + reader.skipField(); + break; + } + } + return msg; +}; + + +/** + * Serializes the message to binary data (in protobuf wire format). + * @return {!Uint8Array} + */ +proto.logproto.TransferChunksResponse.prototype.serializeBinary = function() { + var writer = new jspb.BinaryWriter(); + proto.logproto.TransferChunksResponse.serializeBinaryToWriter(this, writer); + return writer.getResultBuffer(); +}; + + +/** + * Serializes the given message to binary data (in protobuf wire + * format), writing to the given BinaryWriter. + * @param {!proto.logproto.TransferChunksResponse} message + * @param {!jspb.BinaryWriter} writer + * @suppress {unusedLocalVariables} f is only used for nested messages + */ +proto.logproto.TransferChunksResponse.serializeBinaryToWriter = function(message, writer) { + var f = undefined; +}; + + + + + +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.logproto.TailersCountRequest.prototype.toObject = function(opt_includeInstance) { + return proto.logproto.TailersCountRequest.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.logproto.TailersCountRequest} msg The msg instance to transform. + * @return {!Object} + * @suppress {unusedLocalVariables} f is only used for nested messages + */ +proto.logproto.TailersCountRequest.toObject = function(includeInstance, msg) { + var f, obj = { + + }; + + if (includeInstance) { + obj.$jspbMessageInstance = msg; + } + return obj; +}; +} + + +/** + * Deserializes binary data (in protobuf wire format). + * @param {jspb.ByteSource} bytes The bytes to deserialize. + * @return {!proto.logproto.TailersCountRequest} + */ +proto.logproto.TailersCountRequest.deserializeBinary = function(bytes) { + var reader = new jspb.BinaryReader(bytes); + var msg = new proto.logproto.TailersCountRequest; + return proto.logproto.TailersCountRequest.deserializeBinaryFromReader(msg, reader); +}; + + +/** + * Deserializes binary data (in protobuf wire format) from the + * given reader into the given message object. + * @param {!proto.logproto.TailersCountRequest} msg The message object to deserialize into. + * @param {!jspb.BinaryReader} reader The BinaryReader to use. + * @return {!proto.logproto.TailersCountRequest} + */ +proto.logproto.TailersCountRequest.deserializeBinaryFromReader = function(msg, reader) { + while (reader.nextField()) { + if (reader.isEndGroup()) { + break; + } + var field = reader.getFieldNumber(); + switch (field) { + default: + reader.skipField(); + break; + } + } + return msg; +}; + + +/** + * Serializes the message to binary data (in protobuf wire format). + * @return {!Uint8Array} + */ +proto.logproto.TailersCountRequest.prototype.serializeBinary = function() { + var writer = new jspb.BinaryWriter(); + proto.logproto.TailersCountRequest.serializeBinaryToWriter(this, writer); + return writer.getResultBuffer(); +}; + + +/** + * Serializes the given message to binary data (in protobuf wire + * format), writing to the given BinaryWriter. + * @param {!proto.logproto.TailersCountRequest} message + * @param {!jspb.BinaryWriter} writer + * @suppress {unusedLocalVariables} f is only used for nested messages */ -proto.logproto.Chunk.prototype.setData = function(value) { - return jspb.Message.setProto3BytesField(this, 1, value); +proto.logproto.TailersCountRequest.serializeBinaryToWriter = function(message, writer) { + var f = undefined; }; @@ -3806,8 +5073,8 @@ if (jspb.Message.GENERATE_TO_OBJECT) { * http://goto/soy-param-migration * @return {!Object} */ -proto.logproto.TransferChunksResponse.prototype.toObject = function(opt_includeInstance) { - return proto.logproto.TransferChunksResponse.toObject(opt_includeInstance, this); +proto.logproto.TailersCountResponse.prototype.toObject = function(opt_includeInstance) { + return proto.logproto.TailersCountResponse.toObject(opt_includeInstance, this); }; @@ -3816,13 +5083,13 @@ proto.logproto.TransferChunksResponse.prototype.toObject = function(opt_includeI * @param {boolean|undefined} includeInstance Deprecated. Whether to include * the JSPB instance for transitional soy proto support: * http://goto/soy-param-migration - * @param {!proto.logproto.TransferChunksResponse} msg The msg instance to transform. + * @param {!proto.logproto.TailersCountResponse} msg The msg instance to transform. * @return {!Object} * @suppress {unusedLocalVariables} f is only used for nested messages */ -proto.logproto.TransferChunksResponse.toObject = function(includeInstance, msg) { +proto.logproto.TailersCountResponse.toObject = function(includeInstance, msg) { var f, obj = { - + count: jspb.Message.getFieldWithDefault(msg, 1, 0) }; if (includeInstance) { @@ -3836,29 +5103,33 @@ proto.logproto.TransferChunksResponse.toObject = function(includeInstance, msg) /** * Deserializes binary data (in protobuf wire format). * @param {jspb.ByteSource} bytes The bytes to deserialize. - * @return {!proto.logproto.TransferChunksResponse} + * @return {!proto.logproto.TailersCountResponse} */ -proto.logproto.TransferChunksResponse.deserializeBinary = function(bytes) { +proto.logproto.TailersCountResponse.deserializeBinary = function(bytes) { var reader = new jspb.BinaryReader(bytes); - var msg = new proto.logproto.TransferChunksResponse; - return proto.logproto.TransferChunksResponse.deserializeBinaryFromReader(msg, reader); + var msg = new proto.logproto.TailersCountResponse; + return proto.logproto.TailersCountResponse.deserializeBinaryFromReader(msg, reader); }; /** * Deserializes binary data (in protobuf wire format) from the * given reader into the given message object. - * @param {!proto.logproto.TransferChunksResponse} msg The message object to deserialize into. + * @param {!proto.logproto.TailersCountResponse} msg The message object to deserialize into. * @param {!jspb.BinaryReader} reader The BinaryReader to use. - * @return {!proto.logproto.TransferChunksResponse} + * @return {!proto.logproto.TailersCountResponse} */ -proto.logproto.TransferChunksResponse.deserializeBinaryFromReader = function(msg, reader) { +proto.logproto.TailersCountResponse.deserializeBinaryFromReader = function(msg, reader) { while (reader.nextField()) { if (reader.isEndGroup()) { break; } var field = reader.getFieldNumber(); switch (field) { + case 1: + var value = /** @type {number} */ (reader.readUint32()); + msg.setCount(value); + break; default: reader.skipField(); break; @@ -3872,9 +5143,9 @@ proto.logproto.TransferChunksResponse.deserializeBinaryFromReader = function(msg * Serializes the message to binary data (in protobuf wire format). * @return {!Uint8Array} */ -proto.logproto.TransferChunksResponse.prototype.serializeBinary = function() { +proto.logproto.TailersCountResponse.prototype.serializeBinary = function() { var writer = new jspb.BinaryWriter(); - proto.logproto.TransferChunksResponse.serializeBinaryToWriter(this, writer); + proto.logproto.TailersCountResponse.serializeBinaryToWriter(this, writer); return writer.getResultBuffer(); }; @@ -3882,12 +5153,37 @@ proto.logproto.TransferChunksResponse.prototype.serializeBinary = function() { /** * Serializes the given message to binary data (in protobuf wire * format), writing to the given BinaryWriter. - * @param {!proto.logproto.TransferChunksResponse} message + * @param {!proto.logproto.TailersCountResponse} message * @param {!jspb.BinaryWriter} writer * @suppress {unusedLocalVariables} f is only used for nested messages */ -proto.logproto.TransferChunksResponse.serializeBinaryToWriter = function(message, writer) { +proto.logproto.TailersCountResponse.serializeBinaryToWriter = function(message, writer) { var f = undefined; + f = message.getCount(); + if (f !== 0) { + writer.writeUint32( + 1, + f + ); + } +}; + + +/** + * optional uint32 count = 1; + * @return {number} + */ +proto.logproto.TailersCountResponse.prototype.getCount = function() { + return /** @type {number} */ (jspb.Message.getFieldWithDefault(this, 1, 0)); +}; + + +/** + * @param {number} value + * @return {!proto.logproto.TailersCountResponse} returns this + */ +proto.logproto.TailersCountResponse.prototype.setCount = function(value) { + return jspb.Message.setProto3IntField(this, 1, value); }; @@ -3907,8 +5203,8 @@ if (jspb.Message.GENERATE_TO_OBJECT) { * http://goto/soy-param-migration * @return {!Object} */ -proto.logproto.TailersCountRequest.prototype.toObject = function(opt_includeInstance) { - return proto.logproto.TailersCountRequest.toObject(opt_includeInstance, this); +proto.logproto.GetChunkIDsRequest.prototype.toObject = function(opt_includeInstance) { + return proto.logproto.GetChunkIDsRequest.toObject(opt_includeInstance, this); }; @@ -3917,13 +5213,15 @@ proto.logproto.TailersCountRequest.prototype.toObject = function(opt_includeInst * @param {boolean|undefined} includeInstance Deprecated. Whether to include * the JSPB instance for transitional soy proto support: * http://goto/soy-param-migration - * @param {!proto.logproto.TailersCountRequest} msg The msg instance to transform. + * @param {!proto.logproto.GetChunkIDsRequest} msg The msg instance to transform. * @return {!Object} * @suppress {unusedLocalVariables} f is only used for nested messages */ -proto.logproto.TailersCountRequest.toObject = function(includeInstance, msg) { +proto.logproto.GetChunkIDsRequest.toObject = function(includeInstance, msg) { var f, obj = { - + matchers: jspb.Message.getFieldWithDefault(msg, 1, ""), + start: (f = msg.getStart()) && google_protobuf_timestamp_pb.Timestamp.toObject(includeInstance, f), + end: (f = msg.getEnd()) && google_protobuf_timestamp_pb.Timestamp.toObject(includeInstance, f) }; if (includeInstance) { @@ -3937,29 +5235,43 @@ proto.logproto.TailersCountRequest.toObject = function(includeInstance, msg) { /** * Deserializes binary data (in protobuf wire format). * @param {jspb.ByteSource} bytes The bytes to deserialize. - * @return {!proto.logproto.TailersCountRequest} + * @return {!proto.logproto.GetChunkIDsRequest} */ -proto.logproto.TailersCountRequest.deserializeBinary = function(bytes) { +proto.logproto.GetChunkIDsRequest.deserializeBinary = function(bytes) { var reader = new jspb.BinaryReader(bytes); - var msg = new proto.logproto.TailersCountRequest; - return proto.logproto.TailersCountRequest.deserializeBinaryFromReader(msg, reader); + var msg = new proto.logproto.GetChunkIDsRequest; + return proto.logproto.GetChunkIDsRequest.deserializeBinaryFromReader(msg, reader); }; /** * Deserializes binary data (in protobuf wire format) from the * given reader into the given message object. - * @param {!proto.logproto.TailersCountRequest} msg The message object to deserialize into. + * @param {!proto.logproto.GetChunkIDsRequest} msg The message object to deserialize into. * @param {!jspb.BinaryReader} reader The BinaryReader to use. - * @return {!proto.logproto.TailersCountRequest} + * @return {!proto.logproto.GetChunkIDsRequest} */ -proto.logproto.TailersCountRequest.deserializeBinaryFromReader = function(msg, reader) { +proto.logproto.GetChunkIDsRequest.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.setMatchers(value); + break; + case 2: + var value = new google_protobuf_timestamp_pb.Timestamp; + reader.readMessage(value,google_protobuf_timestamp_pb.Timestamp.deserializeBinaryFromReader); + msg.setStart(value); + break; + case 3: + var value = new google_protobuf_timestamp_pb.Timestamp; + reader.readMessage(value,google_protobuf_timestamp_pb.Timestamp.deserializeBinaryFromReader); + msg.setEnd(value); + break; default: reader.skipField(); break; @@ -3973,9 +5285,9 @@ proto.logproto.TailersCountRequest.deserializeBinaryFromReader = function(msg, r * Serializes the message to binary data (in protobuf wire format). * @return {!Uint8Array} */ -proto.logproto.TailersCountRequest.prototype.serializeBinary = function() { +proto.logproto.GetChunkIDsRequest.prototype.serializeBinary = function() { var writer = new jspb.BinaryWriter(); - proto.logproto.TailersCountRequest.serializeBinaryToWriter(this, writer); + proto.logproto.GetChunkIDsRequest.serializeBinaryToWriter(this, writer); return writer.getResultBuffer(); }; @@ -3983,16 +5295,138 @@ proto.logproto.TailersCountRequest.prototype.serializeBinary = function() { /** * Serializes the given message to binary data (in protobuf wire * format), writing to the given BinaryWriter. - * @param {!proto.logproto.TailersCountRequest} message + * @param {!proto.logproto.GetChunkIDsRequest} message * @param {!jspb.BinaryWriter} writer * @suppress {unusedLocalVariables} f is only used for nested messages */ -proto.logproto.TailersCountRequest.serializeBinaryToWriter = function(message, writer) { +proto.logproto.GetChunkIDsRequest.serializeBinaryToWriter = function(message, writer) { var f = undefined; + f = message.getMatchers(); + if (f.length > 0) { + writer.writeString( + 1, + f + ); + } + f = message.getStart(); + if (f != null) { + writer.writeMessage( + 2, + f, + google_protobuf_timestamp_pb.Timestamp.serializeBinaryToWriter + ); + } + f = message.getEnd(); + if (f != null) { + writer.writeMessage( + 3, + f, + google_protobuf_timestamp_pb.Timestamp.serializeBinaryToWriter + ); + } +}; + + +/** + * optional string matchers = 1; + * @return {string} + */ +proto.logproto.GetChunkIDsRequest.prototype.getMatchers = function() { + return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 1, "")); +}; + + +/** + * @param {string} value + * @return {!proto.logproto.GetChunkIDsRequest} returns this + */ +proto.logproto.GetChunkIDsRequest.prototype.setMatchers = function(value) { + return jspb.Message.setProto3StringField(this, 1, value); +}; + + +/** + * optional google.protobuf.Timestamp start = 2; + * @return {?proto.google.protobuf.Timestamp} + */ +proto.logproto.GetChunkIDsRequest.prototype.getStart = function() { + return /** @type{?proto.google.protobuf.Timestamp} */ ( + jspb.Message.getWrapperField(this, google_protobuf_timestamp_pb.Timestamp, 2)); +}; + + +/** + * @param {?proto.google.protobuf.Timestamp|undefined} value + * @return {!proto.logproto.GetChunkIDsRequest} returns this +*/ +proto.logproto.GetChunkIDsRequest.prototype.setStart = function(value) { + return jspb.Message.setWrapperField(this, 2, value); +}; + + +/** + * Clears the message field making it undefined. + * @return {!proto.logproto.GetChunkIDsRequest} returns this + */ +proto.logproto.GetChunkIDsRequest.prototype.clearStart = function() { + return this.setStart(undefined); +}; + + +/** + * Returns whether this field is set. + * @return {boolean} + */ +proto.logproto.GetChunkIDsRequest.prototype.hasStart = function() { + return jspb.Message.getField(this, 2) != null; +}; + + +/** + * optional google.protobuf.Timestamp end = 3; + * @return {?proto.google.protobuf.Timestamp} + */ +proto.logproto.GetChunkIDsRequest.prototype.getEnd = function() { + return /** @type{?proto.google.protobuf.Timestamp} */ ( + jspb.Message.getWrapperField(this, google_protobuf_timestamp_pb.Timestamp, 3)); +}; + + +/** + * @param {?proto.google.protobuf.Timestamp|undefined} value + * @return {!proto.logproto.GetChunkIDsRequest} returns this +*/ +proto.logproto.GetChunkIDsRequest.prototype.setEnd = function(value) { + return jspb.Message.setWrapperField(this, 3, value); +}; + + +/** + * Clears the message field making it undefined. + * @return {!proto.logproto.GetChunkIDsRequest} returns this + */ +proto.logproto.GetChunkIDsRequest.prototype.clearEnd = function() { + return this.setEnd(undefined); +}; + + +/** + * Returns whether this field is set. + * @return {boolean} + */ +proto.logproto.GetChunkIDsRequest.prototype.hasEnd = function() { + return jspb.Message.getField(this, 3) != null; }; +/** + * List of repeated fields within this message type. + * @private {!Array} + * @const + */ +proto.logproto.GetChunkIDsResponse.repeatedFields_ = [1]; + if (jspb.Message.GENERATE_TO_OBJECT) { @@ -4008,8 +5442,8 @@ if (jspb.Message.GENERATE_TO_OBJECT) { * http://goto/soy-param-migration * @return {!Object} */ -proto.logproto.TailersCountResponse.prototype.toObject = function(opt_includeInstance) { - return proto.logproto.TailersCountResponse.toObject(opt_includeInstance, this); +proto.logproto.GetChunkIDsResponse.prototype.toObject = function(opt_includeInstance) { + return proto.logproto.GetChunkIDsResponse.toObject(opt_includeInstance, this); }; @@ -4018,13 +5452,13 @@ proto.logproto.TailersCountResponse.prototype.toObject = function(opt_includeIns * @param {boolean|undefined} includeInstance Deprecated. Whether to include * the JSPB instance for transitional soy proto support: * http://goto/soy-param-migration - * @param {!proto.logproto.TailersCountResponse} msg The msg instance to transform. + * @param {!proto.logproto.GetChunkIDsResponse} msg The msg instance to transform. * @return {!Object} * @suppress {unusedLocalVariables} f is only used for nested messages */ -proto.logproto.TailersCountResponse.toObject = function(includeInstance, msg) { +proto.logproto.GetChunkIDsResponse.toObject = function(includeInstance, msg) { var f, obj = { - count: jspb.Message.getFieldWithDefault(msg, 1, 0) + chunkidsList: (f = jspb.Message.getRepeatedField(msg, 1)) == null ? undefined : f }; if (includeInstance) { @@ -4038,23 +5472,23 @@ proto.logproto.TailersCountResponse.toObject = function(includeInstance, msg) { /** * Deserializes binary data (in protobuf wire format). * @param {jspb.ByteSource} bytes The bytes to deserialize. - * @return {!proto.logproto.TailersCountResponse} + * @return {!proto.logproto.GetChunkIDsResponse} */ -proto.logproto.TailersCountResponse.deserializeBinary = function(bytes) { +proto.logproto.GetChunkIDsResponse.deserializeBinary = function(bytes) { var reader = new jspb.BinaryReader(bytes); - var msg = new proto.logproto.TailersCountResponse; - return proto.logproto.TailersCountResponse.deserializeBinaryFromReader(msg, reader); + var msg = new proto.logproto.GetChunkIDsResponse; + return proto.logproto.GetChunkIDsResponse.deserializeBinaryFromReader(msg, reader); }; /** * Deserializes binary data (in protobuf wire format) from the * given reader into the given message object. - * @param {!proto.logproto.TailersCountResponse} msg The message object to deserialize into. + * @param {!proto.logproto.GetChunkIDsResponse} msg The message object to deserialize into. * @param {!jspb.BinaryReader} reader The BinaryReader to use. - * @return {!proto.logproto.TailersCountResponse} + * @return {!proto.logproto.GetChunkIDsResponse} */ -proto.logproto.TailersCountResponse.deserializeBinaryFromReader = function(msg, reader) { +proto.logproto.GetChunkIDsResponse.deserializeBinaryFromReader = function(msg, reader) { while (reader.nextField()) { if (reader.isEndGroup()) { break; @@ -4062,8 +5496,8 @@ proto.logproto.TailersCountResponse.deserializeBinaryFromReader = function(msg, var field = reader.getFieldNumber(); switch (field) { case 1: - var value = /** @type {number} */ (reader.readUint32()); - msg.setCount(value); + var value = /** @type {string} */ (reader.readString()); + msg.addChunkids(value); break; default: reader.skipField(); @@ -4078,9 +5512,9 @@ proto.logproto.TailersCountResponse.deserializeBinaryFromReader = function(msg, * Serializes the message to binary data (in protobuf wire format). * @return {!Uint8Array} */ -proto.logproto.TailersCountResponse.prototype.serializeBinary = function() { +proto.logproto.GetChunkIDsResponse.prototype.serializeBinary = function() { var writer = new jspb.BinaryWriter(); - proto.logproto.TailersCountResponse.serializeBinaryToWriter(this, writer); + proto.logproto.GetChunkIDsResponse.serializeBinaryToWriter(this, writer); return writer.getResultBuffer(); }; @@ -4088,15 +5522,15 @@ proto.logproto.TailersCountResponse.prototype.serializeBinary = function() { /** * Serializes the given message to binary data (in protobuf wire * format), writing to the given BinaryWriter. - * @param {!proto.logproto.TailersCountResponse} message + * @param {!proto.logproto.GetChunkIDsResponse} message * @param {!jspb.BinaryWriter} writer * @suppress {unusedLocalVariables} f is only used for nested messages */ -proto.logproto.TailersCountResponse.serializeBinaryToWriter = function(message, writer) { +proto.logproto.GetChunkIDsResponse.serializeBinaryToWriter = function(message, writer) { var f = undefined; - f = message.getCount(); - if (f !== 0) { - writer.writeUint32( + f = message.getChunkidsList(); + if (f.length > 0) { + writer.writeRepeatedString( 1, f ); @@ -4105,20 +5539,39 @@ proto.logproto.TailersCountResponse.serializeBinaryToWriter = function(message, /** - * optional uint32 count = 1; - * @return {number} + * repeated string chunkIDs = 1; + * @return {!Array} */ -proto.logproto.TailersCountResponse.prototype.getCount = function() { - return /** @type {number} */ (jspb.Message.getFieldWithDefault(this, 1, 0)); +proto.logproto.GetChunkIDsResponse.prototype.getChunkidsList = function() { + return /** @type {!Array} */ (jspb.Message.getRepeatedField(this, 1)); }; /** - * @param {number} value - * @return {!proto.logproto.TailersCountResponse} returns this + * @param {!Array} value + * @return {!proto.logproto.GetChunkIDsResponse} returns this */ -proto.logproto.TailersCountResponse.prototype.setCount = function(value) { - return jspb.Message.setProto3IntField(this, 1, value); +proto.logproto.GetChunkIDsResponse.prototype.setChunkidsList = function(value) { + return jspb.Message.setField(this, 1, value || []); +}; + + +/** + * @param {string} value + * @param {number=} opt_index + * @return {!proto.logproto.GetChunkIDsResponse} returns this + */ +proto.logproto.GetChunkIDsResponse.prototype.addChunkids = function(value, opt_index) { + return jspb.Message.addToRepeatedField(this, 1, value, opt_index); +}; + + +/** + * Clears the list making it empty but non-null. + * @return {!proto.logproto.GetChunkIDsResponse} returns this + */ +proto.logproto.GetChunkIDsResponse.prototype.clearChunkidsList = function() { + return this.setChunkidsList([]); }; diff --git a/proto/logproto.proto b/proto/logproto.proto index 90078bf..6a8ce88 100644 --- a/proto/logproto.proto +++ b/proto/logproto.proto @@ -13,10 +13,12 @@ service Pusher { service Querier { rpc Query(QueryRequest) returns (stream QueryResponse) {}; + rpc QuerySample(SampleQueryRequest) returns (stream SampleQueryResponse) {}; rpc Label(LabelRequest) returns (LabelResponse) {}; rpc Tail(TailRequest) returns (stream TailResponse) {}; rpc Series(SeriesRequest) returns (SeriesResponse) {}; rpc TailersCount(TailersCountRequest) returns (TailersCountResponse) {}; + rpc GetChunkIDs(GetChunkIDsRequest) returns (GetChunkIDsResponse) {}; // GetChunkIDs returns ChunkIDs from the index store holding logs for given selectors and time-range. } service Ingester { @@ -37,6 +39,18 @@ message QueryRequest { google.protobuf.Timestamp end = 4 [(gogoproto.stdtime) = true, (gogoproto.nullable) = false]; Direction direction = 5; reserved 6; + repeated string shards = 7 [(gogoproto.jsontag) = "shards,omitempty"]; +} + +message SampleQueryRequest { + string selector = 1; + google.protobuf.Timestamp start = 2 [(gogoproto.stdtime) = true, (gogoproto.nullable) = false]; + google.protobuf.Timestamp end = 3 [(gogoproto.stdtime) = true, (gogoproto.nullable) = false]; + repeated string shards = 4 [(gogoproto.jsontag) = "shards,omitempty"]; +} + +message SampleQueryResponse { + repeated Series series = 1 [(gogoproto.customtype) = "Series", (gogoproto.nullable) = true]; } enum Direction { @@ -69,6 +83,17 @@ message EntryAdapter { string line = 2 [(gogoproto.jsontag) = "line"]; } +message Sample { + int64 timestamp = 1 [(gogoproto.jsontag) = "ts"]; + double value = 2 [(gogoproto.jsontag) = "value"]; + uint64 hash = 3 [(gogoproto.jsontag) = "hash"]; +} + +message Series { + string labels = 1 [(gogoproto.jsontag) = "labels"]; + repeated Sample samples = 2 [(gogoproto.nullable) = false, (gogoproto.jsontag) = "samples"]; +} + message TailRequest { string query = 1; reserved 2; @@ -86,6 +111,7 @@ message SeriesRequest { google.protobuf.Timestamp start = 1 [(gogoproto.stdtime) = true, (gogoproto.nullable) = false]; google.protobuf.Timestamp end = 2 [(gogoproto.stdtime) = true, (gogoproto.nullable) = false]; repeated string groups = 3; + repeated string shards = 4 [(gogoproto.jsontag) = "shards,omitempty"]; } message SeriesResponse { @@ -129,3 +155,13 @@ message TailersCountRequest { message TailersCountResponse { uint32 count = 1; } + +message GetChunkIDsRequest { + string matchers = 1; + google.protobuf.Timestamp start = 2 [(gogoproto.stdtime) = true, (gogoproto.nullable) = false]; + google.protobuf.Timestamp end = 3 [(gogoproto.stdtime) = true, (gogoproto.nullable) = false]; +} + +message GetChunkIDsResponse { + repeated string chunkIDs = 1; +}