Stream Processing Service API Overview¶

EnOS™ Stream Processing Service provides query and management of stream processing jobs for application developers. For more information about the EnOS Stream Processing service, see Stream Processing.

For detailed information about EnOS™ APIs, see About EnOS API.

To get started with calling an EnOS API quickly, see Get Started with EnOS API.

Refer to the table below for the list of APIs, and whether they can be used by EnOS™ Cloud and EnOS™ Edge.

API List¶

API Name	Description	EnOS Cloud	EnOS Edge
Get Stage State	Get the intermediate state data of a specified operator in a stream processing pipeline.	√	×
Delete Stage State	Delete the intermediate state data of a specified operator in a stream processing pipeline.	√	×
List Pipelines	Get the list of stream processing pipelines in the organization by pages.	√	×
Get Pipeline Details	Get the details of a specific stream processing pipeline.	√	×
Operate Pipeline	Save, release, start, pause, and stop a stream processing pipeline.	√	×
Get Pipeline Offset and Lag	Get the Kafka Offset and Lag of a specific stream processing pipeline.	√	×
Reset Pipeline Offset	Reset the Kafka Offset of a specific stream processing pipeline.	√	×