Envelope

declare function makeRequest<Rpc extends Any>(options: {
  readonly address: EntityAddress;
  readonly headers: Headers;
  readonly payload: Payload<Rpc>;
  readonly requestId: Snowflake;
  readonly sampled?: boolean;
  readonly spanId?: string;
  readonly tag: Tag<Rpc>;
  readonly traceId?: string;
}): Request<Rpc>;

declare class AckChunk extends {
  [key: string]: any;
} {
  [key: string]: any;
  constructor(...args: [props?: {
    [key: string]: any;
  }, options?: MakeOptions]);
  readonly [TypeId]: typeof TypeId;
  withRequestId(requestId: Snowflake): AckChunk;
}

type Envelope<R extends Rpc.Any> = Request<R> | AckChunk | Interrupt;

declare class Interrupt extends {
  [key: string]: any;
} {
  [key: string]: any;
  constructor(...args: [props?: {
    [key: string]: any;
  }, options?: MakeOptions]);
  readonly [TypeId]: typeof TypeId;
  withRequestId(requestId: Snowflake): Interrupt;
}

interface Request<in out Rpc extends Rpc.Any> {
  readonly _tag: "Request";
  readonly [TypeId]: typeof TypeId;
  readonly address: EntityAddress;
  readonly headers: Headers;
  readonly payload: Payload<Rpc>;
  readonly requestId: Snowflake;
  readonly sampled?: boolean;
  readonly spanId?: string;
  readonly tag: Tag<Rpc>;
  readonly traceId?: string;
}

declare function primaryKey<R extends Any>(envelope: Envelope<R>): string | null;

declare function primaryKeyByAddress(options: {
  readonly address: EntityAddress;
  readonly id: string;
  readonly tag: string;
}): string;

declare function isEnvelope(u: unknown): u is Envelope<any>;

declare const EnvelopeFromSelf: Schema.Schema<Envelope.Any, Envelope.Any>;

declare const PartialEncoded: Schema.Union<
  [
    Schema.Struct<{
      _tag: Schema.Literal<["Request"]>;
      address: typeof EntityAddress;
      headers: Schema.Schema<Headers.Headers, ReadonlyRecord<string, string>>;
      payload: typeof Schema.Unknown;
      requestId: Schema.Schema<Snowflake, string>;
      sampled: Schema.optional<typeof Schema.Boolean>;
      spanId: Schema.optional<typeof Schema.String>;
      tag: typeof Schema.String;
      traceId: Schema.optional<typeof Schema.String>;
    }>,
    typeof AckChunk,
    typeof Interrupt,
  ]
>;

declare const PartialEncodedArray: Schema.Schema<
  Array<Envelope.PartialEncoded>,
  Array<Envelope.Encoded>
>;

declare const PartialEncodedFromSelf: Schema.Union<
  [
    Schema.Struct<{
      _tag: Schema.Literal<["Request"]>;
      address: Schema.Schema<EntityAddress>;
      headers: Schema.Schema<Headers.Headers>;
      payload: typeof Schema.Unknown;
      requestId: Schema.Schema<Snowflake>;
      sampled: Schema.optional<typeof Schema.Boolean>;
      spanId: Schema.optional<typeof Schema.String>;
      tag: typeof Schema.String;
      traceId: Schema.optional<typeof Schema.String>;
    }>,
    Schema.Schema<AckChunk>,
    Schema.Schema<Interrupt>,
  ]
>;

declare const PartialEncodedRequest: Schema.Struct<{
  _tag: Schema.Literal<["Request"]>;
  address: typeof EntityAddress;
  headers: Schema.Schema<Headers.Headers, ReadonlyRecord<string, string>>;
  payload: typeof Schema.Unknown;
  requestId: Schema.Schema<Snowflake, string>;
  sampled: Schema.optional<typeof Schema.Boolean>;
  spanId: Schema.optional<typeof Schema.String>;
  tag: typeof Schema.String;
  traceId: Schema.optional<typeof Schema.String>;
}>;

declare const PartialEncodedRequestFromSelf: Schema.Struct<{
  _tag: Schema.Literal<["Request"]>;
  address: Schema.Schema<EntityAddress>;
  headers: Schema.Schema<Headers.Headers>;
  payload: typeof Schema.Unknown;
  requestId: Schema.Schema<Snowflake>;
  sampled: Schema.optional<typeof Schema.Boolean>;
  spanId: Schema.optional<typeof Schema.String>;
  tag: typeof Schema.String;
  traceId: Schema.optional<typeof Schema.String>;
}>;

declare const RequestFromSelf: Schema.Schema<Request.Any, Request.Any>;

declare const TypeId: unique symbol;

type TypeId = typeof TypeId;