Variable PreprocessStreamResponse

Type Declaration

• create: function

  • create(
        base?: {
            dbRequest?: {
                delete?: { entity?: string[]; id?: string[] };
                get?: { entity?: string; id?: string };
                list?: {
                    cursor?: string;
                    entity?: string;
                    filters?: {
                        field?: (...) | (...);
                        op?: (...) | (...);
                        value?: (...) | (...);
                    }[];
                    pageSize?: number;
                };
                opId?: bigint;
                update?: {
                    entity?: string[];
                    entityData?: { fields?: (...)
                    | (...) }[];
                    id?: string[];
                };
                upsert?: {
                    data?: { [key: string]: any }[];
                    entity?: string[];
                    entityData?: { fields?: (...) | (...) }[];
                    id?: string[];
                };
            };
            processId?: number;
        },
    ): PreprocessStreamResponse

    Parameters

    • Optionalbase: {
          dbRequest?: {
              delete?: { entity?: string[]; id?: string[] };
              get?: { entity?: string; id?: string };
              list?: {
                  cursor?: string;
                  entity?: string;
                  filters?: {
                      field?: (...) | (...);
                      op?: (...) | (...);
                      value?: (...) | (...);
                  }[];
                  pageSize?: number;
              };
              opId?: bigint;
              update?: {
                  entity?: string[];
                  entityData?: { fields?: (...)
                  | (...) }[];
                  id?: string[];
              };
              upsert?: {
                  data?: { [key: string]: any }[];
                  entity?: string[];
                  entityData?: { fields?: (...) | (...) }[];
                  id?: string[];
              };
          };
          processId?: number;
      }

    Returns PreprocessStreamResponse

• decode: function

  • decode(
        input: Uint8Array<ArrayBufferLike> | Reader,
        length?: number,
    ): PreprocessStreamResponse

    Parameters

    • input: Uint8Array<ArrayBufferLike> | Reader
    • Optionallength: number

    Returns PreprocessStreamResponse

• encode: function

  • encode(message: PreprocessStreamResponse, writer?: Writer): Writer

    Parameters

    • message: PreprocessStreamResponse
    • Optionalwriter: Writer

    Returns Writer

• fromJSON: function

  • fromJSON(object: any): PreprocessStreamResponse

    Parameters

    • object: any

    Returns PreprocessStreamResponse

• fromPartial: function

  • fromPartial(
        object: {
            dbRequest?: {
                delete?: { entity?: string[]; id?: string[] };
                get?: { entity?: string; id?: string };
                list?: {
                    cursor?: string;
                    entity?: string;
                    filters?: {
                        field?: string;
                        op?: DBRequest_DBOperator;
                        value?: { values?: ... };
                    }[];
                    pageSize?: number;
                };
                opId?: bigint;
                update?: {
                    entity?: string[];
                    entityData?: { fields?: { [key: ...]: ... } }[];
                    id?: string[];
                };
                upsert?: {
                    data?: { [key: string]: any }[];
                    entity?: string[];
                    entityData?: { fields?: { [key: ...]: ... } }[];
                    id?: string[];
                };
            };
            processId?: number;
        },
    ): PreprocessStreamResponse

    Parameters

    • object: {
          dbRequest?: {
              delete?: { entity?: string[]; id?: string[] };
              get?: { entity?: string; id?: string };
              list?: {
                  cursor?: string;
                  entity?: string;
                  filters?: {
                      field?: string;
                      op?: DBRequest_DBOperator;
                      value?: { values?: ... };
                  }[];
                  pageSize?: number;
              };
              opId?: bigint;
              update?: {
                  entity?: string[];
                  entityData?: { fields?: { [key: ...]: ... } }[];
                  id?: string[];
              };
              upsert?: {
                  data?: { [key: string]: any }[];
                  entity?: string[];
                  entityData?: { fields?: { [key: ...]: ... } }[];
                  id?: string[];
              };
          };
          processId?: number;
      }

    Returns PreprocessStreamResponse

• toJSON: function

  • toJSON(message: PreprocessStreamResponse): unknown

    Parameters

    • message: PreprocessStreamResponse

    Returns unknown