Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Update protobuf definitions to loki 2.4.2 #13

Merged
merged 1 commit into from
Nov 18, 2024
Merged

Update protobuf definitions to loki 2.4.2 #13

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
102 changes: 102 additions & 0 deletions proto/compiled/logproto_grpc_pb.d.ts
View file
Open in desktop
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
Open in desktop
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