Connect any data source, combine them in real-time and instantly get low-latency gRPC and REST APIs.
⚡ All with just a simple configuration! ⚡️

Overview

This repository is a typescript wrapper over gRPC APIs that are automatically generated when you run Dozer.

Installation

yarn add @dozerjs/dozer

Methods

Count()

Count query returns number of records in particular source.

import { ApiClient } from "@dozerjs/dozer";

const flightsClient = new ApiClient('flights');
flightsClient.count().then(count => {
    console.log(count);
});

Query(query = string | null)

Query method is used to fetch records from cache. Reference to gRPC method is here

import { ApiClient } from "@dozerjs/dozer";

const flightsClient = new ApiClient('flights');
flightsClient.query().then(([fields, records]) => {
    console.log(fields, records);
});

Also, client supports query parameter, which allows to filter, sort and paginate. More about you can find here

import { Order } from "@dozerjs/dozer/lib/esm/query_helper";

let query = {
    orderBy: {
        start: Order.ASC
    }
}
flightsClient.query(query).then(([fields, records]) => {
    console.log(fields, records);
});

OnEvent(eventType: EventType = EventType.ALL)

Other available option is to use events streams method onEvent. It connects to the gRPC stream and sends changes to the client. This method has eventType parameter, which is used to determine what type of changes will be streamed. Available options are ALL, INSERT_ONLY, UPDATE_ONLY, DELETE_ONLY.

import { ApiClient } from "@dozerjs/dozer";
import { EventType } from "@dozerjs/dozer/lib/esm/generated/protos/types";

let flightsClient = new ApiClient("flights");
let stream = flightsClient.onEvent(EventType.INSERT_ONLY);
stream.on('data', (response) => {
    console.log(response);
});