Skip to content

Commit

Permalink
Update protobuf definitions to loki 2.4.2
Browse files Browse the repository at this point in the history 
Change-type: minor
  • Loading branch information
@Page-
Page- committed Oct 30, 2024
1 parent caf9794 commit c7e7b79
Show file tree
Hide file tree
Showing 5 changed files with 2,278 additions and 387 deletions.
102 changes: 102 additions & 0 deletions proto/compiled/logproto_grpc_pb.d.ts
View file
Original file line number Diff line number Diff line change
Expand Up @@ -96,10 +96,12 @@ export class PusherClient extends grpc.Client implements IPusherClient {
interface IQuerierService
extends grpc.ServiceDefinition<grpc.UntypedServiceImplementation> {
query: IQuerierService_IQuery;
querySample: IQuerierService_IQuerySample;
label: IQuerierService_ILabel;
tail: IQuerierService_ITail;
series: IQuerierService_ISeries;
tailersCount: IQuerierService_ITailersCount;
getChunkIDs: IQuerierService_IGetChunkIDs;
}

interface IQuerierService_IQuery
Expand All @@ -115,6 +117,19 @@ interface IQuerierService_IQuery
responseSerialize: grpc.serialize<logproto_pb.QueryResponse>;
responseDeserialize: grpc.deserialize<logproto_pb.QueryResponse>;
}
interface IQuerierService_IQuerySample
extends grpc.MethodDefinition<
logproto_pb.SampleQueryRequest,
logproto_pb.SampleQueryResponse
> {
path: '/logproto.Querier/QuerySample';
requestStream: false;
responseStream: true;
requestSerialize: grpc.serialize<logproto_pb.SampleQueryRequest>;
requestDeserialize: grpc.deserialize<logproto_pb.SampleQueryRequest>;
responseSerialize: grpc.serialize<logproto_pb.SampleQueryResponse>;
responseDeserialize: grpc.deserialize<logproto_pb.SampleQueryResponse>;
}
interface IQuerierService_ILabel
extends grpc.MethodDefinition<
logproto_pb.LabelRequest,
Expand Down Expand Up @@ -167,6 +182,19 @@ interface IQuerierService_ITailersCount
responseSerialize: grpc.serialize<logproto_pb.TailersCountResponse>;
responseDeserialize: grpc.deserialize<logproto_pb.TailersCountResponse>;
}
interface IQuerierService_IGetChunkIDs
extends grpc.MethodDefinition<
logproto_pb.GetChunkIDsRequest,
logproto_pb.GetChunkIDsResponse
> {
path: '/logproto.Querier/GetChunkIDs';
requestStream: false;
responseStream: false;
requestSerialize: grpc.serialize<logproto_pb.GetChunkIDsRequest>;
requestDeserialize: grpc.deserialize<logproto_pb.GetChunkIDsRequest>;
responseSerialize: grpc.serialize<logproto_pb.GetChunkIDsResponse>;
responseDeserialize: grpc.deserialize<logproto_pb.GetChunkIDsResponse>;
}

export const QuerierService: IQuerierService;

Expand All @@ -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
Expand All @@ -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 {
Expand All @@ -203,6 +239,15 @@ export interface IQuerierClient {
metadata?: grpc.Metadata,
options?: Partial<grpc.CallOptions>,
): grpc.ClientReadableStream<logproto_pb.QueryResponse>;
querySample(
request: logproto_pb.SampleQueryRequest,
options?: Partial<grpc.CallOptions>,
): grpc.ClientReadableStream<logproto_pb.SampleQueryResponse>;
querySample(
request: logproto_pb.SampleQueryRequest,
metadata?: grpc.Metadata,
options?: Partial<grpc.CallOptions>,
): grpc.ClientReadableStream<logproto_pb.SampleQueryResponse>;
label(
request: logproto_pb.LabelRequest,
callback: (
Expand Down Expand Up @@ -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<grpc.CallOptions>,
callback: (
error: grpc.ServiceError | null,
response: logproto_pb.GetChunkIDsResponse,
) => void,
): grpc.ClientUnaryCall;
}

export class QuerierClient extends grpc.Client implements IQuerierClient {
Expand All @@ -301,6 +370,15 @@ export class QuerierClient extends grpc.Client implements IQuerierClient {
metadata?: grpc.Metadata,
options?: Partial<grpc.CallOptions>,
): grpc.ClientReadableStream<logproto_pb.QueryResponse>;
public querySample(
request: logproto_pb.SampleQueryRequest,
options?: Partial<grpc.CallOptions>,
): grpc.ClientReadableStream<logproto_pb.SampleQueryResponse>;
public querySample(
request: logproto_pb.SampleQueryRequest,
metadata?: grpc.Metadata,
options?: Partial<grpc.CallOptions>,
): grpc.ClientReadableStream<logproto_pb.SampleQueryResponse>;
public label(
request: logproto_pb.LabelRequest,
callback: (
Expand Down Expand Up @@ -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<grpc.CallOptions>,
callback: (
error: grpc.ServiceError | null,
response: logproto_pb.GetChunkIDsResponse,
) => void,
): grpc.ClientUnaryCall;
}

interface IIngesterService
Expand Down
66 changes: 66 additions & 0 deletions proto/compiled/logproto_grpc_pb.js
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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');
Expand Down Expand Up @@ -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');
Expand Down Expand Up @@ -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,
Expand Down Expand Up @@ -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);
Expand Down
Loading

0 comments on commit c7e7b79

Please sign in to comment.