Core API Documentation

Welcome to the FastData Streaming Engine developer reference. Our high-performance asynchronous API allows you to ingest, parse, and route large volumes of structural JSON/gRPC data packets in real-time with sub-millisecond latency.

Current SDK Version: v4.2.1-stable

Quick Start

To begin routing data streaming channels through your local agent, initialize the engine using our official Python/Go CLI wrappers:

$ pip install fastdata-core-streaming
$ fastdata-cli init --token=fd_live_xxxxxx

Stream Initialization (gRPC Transport)

For high-throughput workloads, we strictly recommend using the asynchronous gRPC transport layer. It maintains a persistent HTTP/2 connection matrix to minimize connection overhead.

import grpc
import fastdata_pb2
import fastdata_pb2_grpc

def run_stream():
    channel = grpc.insecure_channel('localhost:50005')
    stub = fastdata_pb2_grpc.DataStreamStub(channel)
    
    # Establish persistent biological async chunk routing
    responses = stub.OpenChannel(fastdata_pb2.StreamRequest(client_id="node_prod_1"))
    for response in responses:
        print(f"Data packet payload received: {response.payload_size} bytes")

Network Architecture Specs

By default, the daemon processes internal binary transport structures using the following schemas:

• Keep-Alive: Timeout established at 300s to prevent routing dropouts.
• Encryption Matrix: TLS 1.3 enforced end-to-end for all outbound processing gates.
• Payload Limits: Maximum chunk package size restricted to 64MB per dynamic request framing.