feat: 30.2 — unified api surface

generated/fila/v1/AckError.ts

@@ -0,0 +1,13 @@
+// Original file: proto/fila/v1/service.proto
+
+import type { AckErrorCode as _fila_v1_AckErrorCode, AckErrorCode__Output as _fila_v1_AckErrorCode__Output } from '../../fila/v1/AckErrorCode';
+
+export interface AckError {
+  'code'?: (_fila_v1_AckErrorCode);
+  'message'?: (string);
+}
+
+export interface AckError__Output {
+  'code': (_fila_v1_AckErrorCode__Output);
+  'message': (string);
+}

generated/fila/v1/AckErrorCode.ts

@@ -0,0 +1,20 @@
+// Original file: proto/fila/v1/service.proto
+
+export const AckErrorCode = {
+  ACK_ERROR_CODE_UNSPECIFIED: 'ACK_ERROR_CODE_UNSPECIFIED',
+  ACK_ERROR_CODE_MESSAGE_NOT_FOUND: 'ACK_ERROR_CODE_MESSAGE_NOT_FOUND',
+  ACK_ERROR_CODE_STORAGE: 'ACK_ERROR_CODE_STORAGE',
+  ACK_ERROR_CODE_PERMISSION_DENIED: 'ACK_ERROR_CODE_PERMISSION_DENIED',
+} as const;
+
+export type AckErrorCode =
+  | 'ACK_ERROR_CODE_UNSPECIFIED'
+  | 0
+  | 'ACK_ERROR_CODE_MESSAGE_NOT_FOUND'
+  | 1
+  | 'ACK_ERROR_CODE_STORAGE'
+  | 2
+  | 'ACK_ERROR_CODE_PERMISSION_DENIED'
+  | 3
+
+export type AckErrorCode__Output = typeof AckErrorCode[keyof typeof AckErrorCode]

generated/fila/v1/AckMessage.ts

@@ -0,0 +1,12 @@
+// Original file: proto/fila/v1/service.proto
+
+
+export interface AckMessage {
+  'queue'?: (string);
+  'messageId'?: (string);
+}
+
+export interface AckMessage__Output {
+  'queue': (string);
+  'messageId': (string);
+}

generated/fila/v1/AckRequest.ts

@@ -1,12 +1,11 @@
 // Original file: proto/fila/v1/service.proto
 
+import type { AckMessage as _fila_v1_AckMessage, AckMessage__Output as _fila_v1_AckMessage__Output } from '../../fila/v1/AckMessage';
 
 export interface AckRequest {
-  'queue'?: (string);
-  'messageId'?: (string);
+  'messages'?: (_fila_v1_AckMessage)[];
 }
 
 export interface AckRequest__Output {
-  'queue': (string);
-  'messageId': (string);
+  'messages': (_fila_v1_AckMessage__Output)[];
 }

generated/fila/v1/AckResponse.ts

@@ -1,8 +1,11 @@
 // Original file: proto/fila/v1/service.proto
 
+import type { AckResult as _fila_v1_AckResult, AckResult__Output as _fila_v1_AckResult__Output } from '../../fila/v1/AckResult';
 
 export interface AckResponse {
+  'results'?: (_fila_v1_AckResult)[];
 }
 
 export interface AckResponse__Output {
+  'results': (_fila_v1_AckResult__Output)[];
 }

generated/fila/v1/AckResult.ts

@@ -0,0 +1,16 @@
+// Original file: proto/fila/v1/service.proto
+
+import type { AckSuccess as _fila_v1_AckSuccess, AckSuccess__Output as _fila_v1_AckSuccess__Output } from '../../fila/v1/AckSuccess';
+import type { AckError as _fila_v1_AckError, AckError__Output as _fila_v1_AckError__Output } from '../../fila/v1/AckError';
+
+export interface AckResult {
+  'success'?: (_fila_v1_AckSuccess | null);
+  'error'?: (_fila_v1_AckError | null);
+  'result'?: "success"|"error";
+}
+
+export interface AckResult__Output {
+  'success'?: (_fila_v1_AckSuccess__Output | null);
+  'error'?: (_fila_v1_AckError__Output | null);
+  'result'?: "success"|"error";
+}

generated/fila/v1/AckSuccess.ts

@@ -0,0 +1,8 @@
+// Original file: proto/fila/v1/service.proto
+
+
+export interface AckSuccess {
+}
+
+export interface AckSuccess__Output {
+}

generated/fila/v1/ConsumeResponse.ts

@@ -3,11 +3,9 @@
 import type { Message as _fila_v1_Message, Message__Output as _fila_v1_Message__Output } from '../../fila/v1/Message';
 
 export interface ConsumeResponse {
-  'message'?: (_fila_v1_Message | null);
   'messages'?: (_fila_v1_Message)[];
 }
 
 export interface ConsumeResponse__Output {
-  'message': (_fila_v1_Message__Output | null);
   'messages': (_fila_v1_Message__Output)[];
 }

generated/fila/v1/EnqueueError.ts

@@ -0,0 +1,13 @@
+// Original file: proto/fila/v1/service.proto
+
+import type { EnqueueErrorCode as _fila_v1_EnqueueErrorCode, EnqueueErrorCode__Output as _fila_v1_EnqueueErrorCode__Output } from '../../fila/v1/EnqueueErrorCode';
+
+export interface EnqueueError {
+  'code'?: (_fila_v1_EnqueueErrorCode);
+  'message'?: (string);
+}
+
+export interface EnqueueError__Output {
+  'code': (_fila_v1_EnqueueErrorCode__Output);
+  'message': (string);
+}

generated/fila/v1/EnqueueErrorCode.ts

@@ -0,0 +1,23 @@
+// Original file: proto/fila/v1/service.proto
+
+export const EnqueueErrorCode = {
+  ENQUEUE_ERROR_CODE_UNSPECIFIED: 'ENQUEUE_ERROR_CODE_UNSPECIFIED',
+  ENQUEUE_ERROR_CODE_QUEUE_NOT_FOUND: 'ENQUEUE_ERROR_CODE_QUEUE_NOT_FOUND',
+  ENQUEUE_ERROR_CODE_STORAGE: 'ENQUEUE_ERROR_CODE_STORAGE',
+  ENQUEUE_ERROR_CODE_LUA: 'ENQUEUE_ERROR_CODE_LUA',
+  ENQUEUE_ERROR_CODE_PERMISSION_DENIED: 'ENQUEUE_ERROR_CODE_PERMISSION_DENIED',
+} as const;
+
+export type EnqueueErrorCode =
+  | 'ENQUEUE_ERROR_CODE_UNSPECIFIED'
+  | 0
+  | 'ENQUEUE_ERROR_CODE_QUEUE_NOT_FOUND'
+  | 1
+  | 'ENQUEUE_ERROR_CODE_STORAGE'
+  | 2
+  | 'ENQUEUE_ERROR_CODE_LUA'
+  | 3
+  | 'ENQUEUE_ERROR_CODE_PERMISSION_DENIED'
+  | 4
+
+export type EnqueueErrorCode__Output = typeof EnqueueErrorCode[keyof typeof EnqueueErrorCode]

generated/fila/v1/EnqueueMessage.ts

@@ -0,0 +1,14 @@
+// Original file: proto/fila/v1/service.proto
+
+
+export interface EnqueueMessage {
+  'queue'?: (string);
+  'headers'?: ({[key: string]: string});
+  'payload'?: (Buffer | Uint8Array | string);
+}
+
+export interface EnqueueMessage__Output {
+  'queue': (string);
+  'headers': ({[key: string]: string});
+  'payload': (Buffer);
+}

generated/fila/v1/EnqueueRequest.ts

@@ -1,14 +1,11 @@
 // Original file: proto/fila/v1/service.proto
 
+import type { EnqueueMessage as _fila_v1_EnqueueMessage, EnqueueMessage__Output as _fila_v1_EnqueueMessage__Output } from '../../fila/v1/EnqueueMessage';
 
 export interface EnqueueRequest {
-  'queue'?: (string);
-  'headers'?: ({[key: string]: string});
-  'payload'?: (Buffer | Uint8Array | string);
+  'messages'?: (_fila_v1_EnqueueMessage)[];
 }
 
 export interface EnqueueRequest__Output {
-  'queue': (string);
-  'headers': ({[key: string]: string});
-  'payload': (Buffer);
+  'messages': (_fila_v1_EnqueueMessage__Output)[];
 }

generated/fila/v1/EnqueueResponse.ts

@@ -1,10 +1,11 @@
 // Original file: proto/fila/v1/service.proto
 
+import type { EnqueueResult as _fila_v1_EnqueueResult, EnqueueResult__Output as _fila_v1_EnqueueResult__Output } from '../../fila/v1/EnqueueResult';
 
 export interface EnqueueResponse {
-  'messageId'?: (string);
+  'results'?: (_fila_v1_EnqueueResult)[];
 }
 
 export interface EnqueueResponse__Output {
-  'messageId': (string);
+  'results': (_fila_v1_EnqueueResult__Output)[];
 }

generated/fila/v1/EnqueueResult.ts

@@ -0,0 +1,15 @@
+// Original file: proto/fila/v1/service.proto
+
+import type { EnqueueError as _fila_v1_EnqueueError, EnqueueError__Output as _fila_v1_EnqueueError__Output } from '../../fila/v1/EnqueueError';
+
+export interface EnqueueResult {
+  'messageId'?: (string);
+  'error'?: (_fila_v1_EnqueueError | null);
+  'result'?: "messageId"|"error";
+}
+
+export interface EnqueueResult__Output {
+  'messageId'?: (string);
+  'error'?: (_fila_v1_EnqueueError__Output | null);
+  'result'?: "messageId"|"error";
+}

generated/fila/v1/FilaService.ts

@@ -4,14 +4,14 @@ import type * as grpc from '@grpc/grpc-js'
 import type { MethodDefinition } from '@grpc/proto-loader'
 import type { AckRequest as _fila_v1_AckRequest, AckRequest__Output as _fila_v1_AckRequest__Output } from '../../fila/v1/AckRequest';
 import type { AckResponse as _fila_v1_AckResponse, AckResponse__Output as _fila_v1_AckResponse__Output } from '../../fila/v1/AckResponse';
-import type { BatchEnqueueRequest as _fila_v1_BatchEnqueueRequest, BatchEnqueueRequest__Output as _fila_v1_BatchEnqueueRequest__Output } from '../../fila/v1/BatchEnqueueRequest';
-import type { BatchEnqueueResponse as _fila_v1_BatchEnqueueResponse, BatchEnqueueResponse__Output as _fila_v1_BatchEnqueueResponse__Output } from '../../fila/v1/BatchEnqueueResponse';
 import type { ConsumeRequest as _fila_v1_ConsumeRequest, ConsumeRequest__Output as _fila_v1_ConsumeRequest__Output } from '../../fila/v1/ConsumeRequest';
 import type { ConsumeResponse as _fila_v1_ConsumeResponse, ConsumeResponse__Output as _fila_v1_ConsumeResponse__Output } from '../../fila/v1/ConsumeResponse';
 import type { EnqueueRequest as _fila_v1_EnqueueRequest, EnqueueRequest__Output as _fila_v1_EnqueueRequest__Output } from '../../fila/v1/EnqueueRequest';
 import type { EnqueueResponse as _fila_v1_EnqueueResponse, EnqueueResponse__Output as _fila_v1_EnqueueResponse__Output } from '../../fila/v1/EnqueueResponse';
 import type { NackRequest as _fila_v1_NackRequest, NackRequest__Output as _fila_v1_NackRequest__Output } from '../../fila/v1/NackRequest';
 import type { NackResponse as _fila_v1_NackResponse, NackResponse__Output as _fila_v1_NackResponse__Output } from '../../fila/v1/NackResponse';
+import type { StreamEnqueueRequest as _fila_v1_StreamEnqueueRequest, StreamEnqueueRequest__Output as _fila_v1_StreamEnqueueRequest__Output } from '../../fila/v1/StreamEnqueueRequest';
+import type { StreamEnqueueResponse as _fila_v1_StreamEnqueueResponse, StreamEnqueueResponse__Output as _fila_v1_StreamEnqueueResponse__Output } from '../../fila/v1/StreamEnqueueResponse';
 
 export interface FilaServiceClient extends grpc.Client {
   Ack(argument: _fila_v1_AckRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_fila_v1_AckResponse__Output>): grpc.ClientUnaryCall;
@@ -23,15 +23,6 @@ export interface FilaServiceClient extends grpc.Client {
   ack(argument: _fila_v1_AckRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_fila_v1_AckResponse__Output>): grpc.ClientUnaryCall;
   ack(argument: _fila_v1_AckRequest, callback: grpc.requestCallback<_fila_v1_AckResponse__Output>): grpc.ClientUnaryCall;
 
-  BatchEnqueue(argument: _fila_v1_BatchEnqueueRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_fila_v1_BatchEnqueueResponse__Output>): grpc.ClientUnaryCall;
-  BatchEnqueue(argument: _fila_v1_BatchEnqueueRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_fila_v1_BatchEnqueueResponse__Output>): grpc.ClientUnaryCall;
-  BatchEnqueue(argument: _fila_v1_BatchEnqueueRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_fila_v1_BatchEnqueueResponse__Output>): grpc.ClientUnaryCall;
-  BatchEnqueue(argument: _fila_v1_BatchEnqueueRequest, callback: grpc.requestCallback<_fila_v1_BatchEnqueueResponse__Output>): grpc.ClientUnaryCall;
-  batchEnqueue(argument: _fila_v1_BatchEnqueueRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_fila_v1_BatchEnqueueResponse__Output>): grpc.ClientUnaryCall;
-  batchEnqueue(argument: _fila_v1_BatchEnqueueRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_fila_v1_BatchEnqueueResponse__Output>): grpc.ClientUnaryCall;
-  batchEnqueue(argument: _fila_v1_BatchEnqueueRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_fila_v1_BatchEnqueueResponse__Output>): grpc.ClientUnaryCall;
-  batchEnqueue(argument: _fila_v1_BatchEnqueueRequest, callback: grpc.requestCallback<_fila_v1_BatchEnqueueResponse__Output>): grpc.ClientUnaryCall;
-
   Consume(argument: _fila_v1_ConsumeRequest, metadata: grpc.Metadata, options?: grpc.CallOptions): grpc.ClientReadableStream<_fila_v1_ConsumeResponse__Output>;
   Consume(argument: _fila_v1_ConsumeRequest, options?: grpc.CallOptions): grpc.ClientReadableStream<_fila_v1_ConsumeResponse__Output>;
   consume(argument: _fila_v1_ConsumeRequest, metadata: grpc.Metadata, options?: grpc.CallOptions): grpc.ClientReadableStream<_fila_v1_ConsumeResponse__Output>;
@@ -55,25 +46,30 @@ export interface FilaServiceClient extends grpc.Client {
   nack(argument: _fila_v1_NackRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_fila_v1_NackResponse__Output>): grpc.ClientUnaryCall;
   nack(argument: _fila_v1_NackRequest, callback: grpc.requestCallback<_fila_v1_NackResponse__Output>): grpc.ClientUnaryCall;
 
+  StreamEnqueue(metadata: grpc.Metadata, options?: grpc.CallOptions): grpc.ClientDuplexStream<_fila_v1_StreamEnqueueRequest, _fila_v1_StreamEnqueueResponse__Output>;
+  StreamEnqueue(options?: grpc.CallOptions): grpc.ClientDuplexStream<_fila_v1_StreamEnqueueRequest, _fila_v1_StreamEnqueueResponse__Output>;
+  streamEnqueue(metadata: grpc.Metadata, options?: grpc.CallOptions): grpc.ClientDuplexStream<_fila_v1_StreamEnqueueRequest, _fila_v1_StreamEnqueueResponse__Output>;
+  streamEnqueue(options?: grpc.CallOptions): grpc.ClientDuplexStream<_fila_v1_StreamEnqueueRequest, _fila_v1_StreamEnqueueResponse__Output>;
+
 }
 
 export interface FilaServiceHandlers extends grpc.UntypedServiceImplementation {
   Ack: grpc.handleUnaryCall<_fila_v1_AckRequest__Output, _fila_v1_AckResponse>;
 
-  BatchEnqueue: grpc.handleUnaryCall<_fila_v1_BatchEnqueueRequest__Output, _fila_v1_BatchEnqueueResponse>;
-
   Consume: grpc.handleServerStreamingCall<_fila_v1_ConsumeRequest__Output, _fila_v1_ConsumeResponse>;
 
   Enqueue: grpc.handleUnaryCall<_fila_v1_EnqueueRequest__Output, _fila_v1_EnqueueResponse>;
 
   Nack: grpc.handleUnaryCall<_fila_v1_NackRequest__Output, _fila_v1_NackResponse>;
 
+  StreamEnqueue: grpc.handleBidiStreamingCall<_fila_v1_StreamEnqueueRequest__Output, _fila_v1_StreamEnqueueResponse>;
+
 }
 
 export interface FilaServiceDefinition extends grpc.ServiceDefinition {
   Ack: MethodDefinition<_fila_v1_AckRequest, _fila_v1_AckResponse, _fila_v1_AckRequest__Output, _fila_v1_AckResponse__Output>
-  BatchEnqueue: MethodDefinition<_fila_v1_BatchEnqueueRequest, _fila_v1_BatchEnqueueResponse, _fila_v1_BatchEnqueueRequest__Output, _fila_v1_BatchEnqueueResponse__Output>
   Consume: MethodDefinition<_fila_v1_ConsumeRequest, _fila_v1_ConsumeResponse, _fila_v1_ConsumeRequest__Output, _fila_v1_ConsumeResponse__Output>
   Enqueue: MethodDefinition<_fila_v1_EnqueueRequest, _fila_v1_EnqueueResponse, _fila_v1_EnqueueRequest__Output, _fila_v1_EnqueueResponse__Output>
   Nack: MethodDefinition<_fila_v1_NackRequest, _fila_v1_NackResponse, _fila_v1_NackRequest__Output, _fila_v1_NackResponse__Output>
+  StreamEnqueue: MethodDefinition<_fila_v1_StreamEnqueueRequest, _fila_v1_StreamEnqueueResponse, _fila_v1_StreamEnqueueRequest__Output, _fila_v1_StreamEnqueueResponse__Output>
 }

generated/fila/v1/NackError.ts

@@ -0,0 +1,13 @@
+// Original file: proto/fila/v1/service.proto
+
+import type { NackErrorCode as _fila_v1_NackErrorCode, NackErrorCode__Output as _fila_v1_NackErrorCode__Output } from '../../fila/v1/NackErrorCode';
+
+export interface NackError {
+  'code'?: (_fila_v1_NackErrorCode);
+  'message'?: (string);
+}
+
+export interface NackError__Output {
+  'code': (_fila_v1_NackErrorCode__Output);
+  'message': (string);
+}

generated/fila/v1/NackErrorCode.ts

@@ -0,0 +1,20 @@
+// Original file: proto/fila/v1/service.proto
+
+export const NackErrorCode = {
+  NACK_ERROR_CODE_UNSPECIFIED: 'NACK_ERROR_CODE_UNSPECIFIED',
+  NACK_ERROR_CODE_MESSAGE_NOT_FOUND: 'NACK_ERROR_CODE_MESSAGE_NOT_FOUND',
+  NACK_ERROR_CODE_STORAGE: 'NACK_ERROR_CODE_STORAGE',
+  NACK_ERROR_CODE_PERMISSION_DENIED: 'NACK_ERROR_CODE_PERMISSION_DENIED',
+} as const;
+
+export type NackErrorCode =
+  | 'NACK_ERROR_CODE_UNSPECIFIED'
+  | 0
+  | 'NACK_ERROR_CODE_MESSAGE_NOT_FOUND'
+  | 1
+  | 'NACK_ERROR_CODE_STORAGE'
+  | 2
+  | 'NACK_ERROR_CODE_PERMISSION_DENIED'
+  | 3
+
+export type NackErrorCode__Output = typeof NackErrorCode[keyof typeof NackErrorCode]

generated/fila/v1/NackMessage.ts

@@ -0,0 +1,14 @@
+// Original file: proto/fila/v1/service.proto
+
+
+export interface NackMessage {
+  'queue'?: (string);
+  'messageId'?: (string);
+  'error'?: (string);
+}
+
+export interface NackMessage__Output {
+  'queue': (string);
+  'messageId': (string);
+  'error': (string);
+}

generated/fila/v1/NackRequest.ts

@@ -1,14 +1,11 @@
 // Original file: proto/fila/v1/service.proto
 
+import type { NackMessage as _fila_v1_NackMessage, NackMessage__Output as _fila_v1_NackMessage__Output } from '../../fila/v1/NackMessage';
 
 export interface NackRequest {
-  'queue'?: (string);
-  'messageId'?: (string);
-  'error'?: (string);
+  'messages'?: (_fila_v1_NackMessage)[];
 }
 
 export interface NackRequest__Output {
-  'queue': (string);
-  'messageId': (string);
-  'error': (string);
+  'messages': (_fila_v1_NackMessage__Output)[];
 }