Delegate Stream Endpoint
Plug any streaming technology using producer and consumer delegates.
Custom Transport
Use this endpoint to integrate proprietary brokers without changing core runtime.
Connection Metadata and Contracts
Use ConnectionMetadata for transport setup values, and delegate message contracts (ProducedMessageRequest, ProducedMessageResult, ConsumedMessage) to standardize payload handoff. TypeScript/JavaScript structured callbacks accept PascalCase members such as Endpoint, Payload, TrackingId, ConnectionMetadata, IsSuccess, ResponsePayload, and TimestampUtc in the public docs surface.
Feature Usage Samples
How to use snippets for Delegate Stream Endpoint.
Switch between C#, Java, Python, TypeScript, and JavaScript to see the native SDK shape for this sample.
Licensing note: every runnable sample requires a valid runner key via WithRunnerKey("...") or config key LoadStrike:RunnerKey.
Delegate Stream Endpoint
var endpoint = new DelegateStreamEndpointDefinition
{
Name = "custom-stream",
Mode = TrafficEndpointMode.Produce,
TrackingField = TrackingFieldSelector.Parse("header:X-Correlation-Id"),
ProduceAsync = (request, _) => Task.FromResult(new ProducedMessageResult { IsSuccess = true })
};import com.loadstrike.runtime.DelegateStreamEndpointDefinition;
import com.loadstrike.runtime.LoadStrikeCorrelation.TrackingFieldSelector;
import com.loadstrike.runtime.LoadStrikeTransports;
var endpoint = new DelegateStreamEndpointDefinition();
endpoint.name = "custom-stream";
endpoint.mode = LoadStrikeTransports.TrafficEndpointMode.Produce;
endpoint.trackingField = TrackingFieldSelector.parse("header:X-Correlation-Id");
endpoint.produceAsync = request -> {
var result = new LoadStrikeTransports.ProducedMessageResult();
result.isSuccess = true;
return result;
};from loadstrike_sdk import (
DelegateStreamEndpointDefinition,
ProducedMessageResult,
TrackingFieldSelector,
)
endpoint = DelegateStreamEndpointDefinition(
name="custom-stream",
mode="Produce",
tracking_field=TrackingFieldSelector.parse("header:X-Correlation-Id"),
produce_async=lambda request: ProducedMessageResult(is_success=True),
)import { DelegateStreamEndpointDefinition, TrackingFieldSelector } from "@loadstrike/loadstrike-sdk";
const endpoint = new DelegateStreamEndpointDefinition({
name: "custom-stream",
mode: "Produce",
trackingField: TrackingFieldSelector.parse("header:X-Correlation-Id"),
produceAsync: async () => ({ isSuccess: true })
});const { DelegateStreamEndpointDefinition, TrackingFieldSelector } = require("@loadstrike/loadstrike-sdk");
const endpoint = new DelegateStreamEndpointDefinition({
name: "custom-stream",
mode: "Produce",
trackingField: TrackingFieldSelector.parse("header:X-Correlation-Id"),
produceAsync: async () => ({ isSuccess: true })
});Use
Use delegate streams when you need to plug in a transport that LoadStrike does not ship as a built-in adapter.
Implement the send and receive delegates so LoadStrike can drive correlation with your own transport API using the same request, result, and message contract shape across all supported SDKs.
Diagram
