Create a new instance of PlugWrapper
source plug instance
Optional
retryOptions: RetryOptionsoptions for job retry operations
Optional
postConsumeOptions: PostConsumeOptionsoptions for post consume operations
Return the status of the stream in a standard format
check object as defined in the draft standard https://datatracker.ietf.org/doc/html/draft-inadarei-api-health-check-05
Component identification
Metrics registry for this component
Component name
A component is any part of the system that has a own identity and can be monitored for error handling. The only requirement is to emit an error event when something goes wrong, to have a name and unique component identifier.