Nfsv4TcpClient.d.ts 1.4 KB

1234567891011121314151617181920212223242526272829303132333435363738394041
  1. /// <reference types="node" />
  2. import * as stream from 'node:stream';
  3. import { Nfsv4CompoundRequest, Nfsv4CompoundResponse, Nfsv4Request } from '../messages';
  4. import type { Nfsv4Client } from './types';
  5. export interface Nfsv4TcpClientOpts {
  6. host?: string;
  7. port?: number;
  8. timeout?: number;
  9. debug?: boolean;
  10. logger?: Pick<typeof console, 'log' | 'error'>;
  11. }
  12. export declare class Nfsv4TcpClient implements Nfsv4Client {
  13. static fromDuplex(duplex: stream.Duplex, opts?: Nfsv4TcpClientOpts): Nfsv4TcpClient;
  14. readonly host: string;
  15. readonly port: number;
  16. readonly timeout: number;
  17. debug: boolean;
  18. logger: Pick<typeof console, 'log' | 'error'>;
  19. private socket;
  20. private connected;
  21. private connecting;
  22. private xid;
  23. private seqid;
  24. private pendingRequests;
  25. private readonly rmDecoder;
  26. private readonly rpcDecoder;
  27. private readonly nfsDecoder;
  28. private readonly nfsEncoder;
  29. constructor(opts?: Nfsv4TcpClientOpts);
  30. private nextXid;
  31. connect(): Promise<void>;
  32. protected setSocket(socket: stream.Duplex): void;
  33. private onData;
  34. private onRpcMessage;
  35. private onClose;
  36. compound(request: Nfsv4CompoundRequest): Promise<Nfsv4CompoundResponse>;
  37. compound(operations: Nfsv4Request[], tag?: string, minorversion?: number): Promise<Nfsv4CompoundResponse>;
  38. null(): Promise<void>;
  39. close(): void;
  40. isConnected(): boolean;
  41. }