Versions in this module Expand all Collapse all v0 v0.0.4 Aug 6, 2023 Changes in this version + const ContentTypeJson + const HeaderContentType + func NewNatsMessagingSourceConnectorGenereator() pluginapi.SourceConnectorGenerator + type NatsMessagingSourceConnector struct + func (n *NatsMessagingSourceConnector) BindPipeline(process pluginapi.PipelineProcess) error + func (n *NatsMessagingSourceConnector) Reload() error + func (n *NatsMessagingSourceConnector) Start() error + func (n *NatsMessagingSourceConnector) Stop() error + type NatsMessagingSourceConnectorGenereator struct + func (n *NatsMessagingSourceConnectorGenereator) GenerateSourceConnectorInstance(req pluginapi.SourceConnectorGenerateRequest) (pluginapi.SourceConnector, error) + func (n *NatsMessagingSourceConnectorGenereator) InitializeSubGeneratorInstance(req pluginapi.CommonSourceConnectorGenerateRequest) (pluginapi.SourceConnectorGenerator, error) + func (n *NatsMessagingSourceConnectorGenereator) OriginalGeneratorNames() []string + func (n *NatsMessagingSourceConnectorGenereator) Startup() error + func (n *NatsMessagingSourceConnectorGenereator) Stop() error
Go to main page