RpcMessageEncoder.d.ts 1.4 KB

12345678910111213141516171819202122232425262728
  1. import { Reader } from '@jsonjoy.com/buffers/lib/Reader';
  2. import { RpcOpaqueAuth, RpcMessage } from './messages';
  3. import type { IWriter, IWriterGrowable } from '@jsonjoy.com/util/lib/buffers';
  4. export declare class RpcMessageEncoder<W extends IWriter & IWriterGrowable = IWriter & IWriterGrowable> {
  5. readonly writer: W;
  6. constructor(writer?: W);
  7. encodeCall(xid: number, prog: number, vers: number, proc: number, cred: RpcOpaqueAuth, verf: RpcOpaqueAuth, params?: Reader | Uint8Array): Uint8Array;
  8. encodeAcceptedReply(xid: number, verf: RpcOpaqueAuth, acceptStat: number, mismatchInfo?: {
  9. low: number;
  10. high: number;
  11. }, results?: Reader | Uint8Array): Uint8Array;
  12. encodeRejectedReply(xid: number, rejectStat: number, mismatchInfo?: {
  13. low: number;
  14. high: number;
  15. }, authStat?: number): Uint8Array;
  16. encodeMessage(msg: RpcMessage): Uint8Array;
  17. writeMessage(msg: RpcMessage): void;
  18. writeCall(xid: number, prog: number, vers: number, proc: number, cred: RpcOpaqueAuth, verf: RpcOpaqueAuth, params?: Reader | Uint8Array): void;
  19. writeAcceptedReply(xid: number, verf: RpcOpaqueAuth, acceptStat: number, mismatchInfo?: {
  20. low: number;
  21. high: number;
  22. }, results?: Reader | Uint8Array): void;
  23. writeRejectedReply(xid: number, rejectStat: number, mismatchInfo?: {
  24. low: number;
  25. high: number;
  26. }, authStat?: number): void;
  27. private writeOpaqueAuth;
  28. }