Index

A C D I
All Classes and Interfaces|All Packages

A

ai.pipestream.connector - package ai.pipestream.connector

API_KEY_HEADER - Static variable in class ai.pipestream.connector.ConnectorApiKeyInterceptor

Header carrying the datasource API key.

apiKey() - Static method in class ai.pipestream.connector.ConnectorApiKeyContext

The calling request's api key, or "" when the header was absent.

C

callWith(String, String, Callable) - Static method in class ai.pipestream.connector.ConnectorApiKeyContext

Runs body with the given credentials bound, for in-process callers that bypass the gRPC server (tests, internal replays).

ConnectorApiKeyContext - Class in ai.pipestream.connector

Holds the connector call credentials captured from gRPC metadata by ConnectorApiKeyInterceptor, exposing them to the handler thread.

ConnectorApiKeyInterceptor - Class in ai.pipestream.connector

Captures the x-api-key and x-datasource-id gRPC metadata headers into the call Context, where handlers read them via ConnectorApiKeyContext.apiKey() / ConnectorApiKeyContext.datasourceId().

ConnectorApiKeyInterceptor() - Constructor for class ai.pipestream.connector.ConnectorApiKeyInterceptor

CDI.

D

DATASOURCE_ID_HEADER - Static variable in class ai.pipestream.connector.ConnectorApiKeyInterceptor

Header carrying the datasource id.

datasourceId() - Static method in class ai.pipestream.connector.ConnectorApiKeyContext

The calling request's datasource id, or "" when the header was absent.

I

interceptCall(ServerCall, Metadata, ServerCallHandler) - Method in class ai.pipestream.connector.ConnectorApiKeyInterceptor

A C D I
All Classes and Interfaces|All Packages