messaging

Documentation

Index

• Constants
• func NewNatsMessagingSourceConnectorGenereator() pluginapi.SourceConnectorGenerator
• type NatsMessagingSourceConnector
  • 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
  • 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

Constants

const (
	HeaderContentType = "Content-Type"

	ContentTypeJson = "application/json"
)

Functions

func NewNatsMessagingSourceConnectorGenereator

func NewNatsMessagingSourceConnectorGenereator() pluginapi.SourceConnectorGenerator

Types

type NatsMessagingSourceConnector

type NatsMessagingSourceConnector struct {
	// contains filtered or unexported fields
}

func (*NatsMessagingSourceConnector) BindPipeline

func (n *NatsMessagingSourceConnector) BindPipeline(process pluginapi.PipelineProcess) error

func (*NatsMessagingSourceConnector) Reload

func (n *NatsMessagingSourceConnector) Reload() error

func (*NatsMessagingSourceConnector) Start

func (n *NatsMessagingSourceConnector) Start() error

func (*NatsMessagingSourceConnector) Stop

func (n *NatsMessagingSourceConnector) Stop() error

type NatsMessagingSourceConnectorGenereator

type NatsMessagingSourceConnectorGenereator struct {
	// contains filtered or unexported fields
}

func (*NatsMessagingSourceConnectorGenereator) GenerateSourceConnectorInstance

func (n *NatsMessagingSourceConnectorGenereator) GenerateSourceConnectorInstance(req pluginapi.SourceConnectorGenerateRequest) (pluginapi.SourceConnector, error)

func (*NatsMessagingSourceConnectorGenereator) InitializeSubGeneratorInstance

func (n *NatsMessagingSourceConnectorGenereator) InitializeSubGeneratorInstance(req pluginapi.CommonSourceConnectorGenerateRequest) (pluginapi.SourceConnectorGenerator, error)

func (*NatsMessagingSourceConnectorGenereator) OriginalGeneratorNames

func (n *NatsMessagingSourceConnectorGenereator) OriginalGeneratorNames() []string

func (*NatsMessagingSourceConnectorGenereator) Startup

func (n *NatsMessagingSourceConnectorGenereator) Startup() error

func (*NatsMessagingSourceConnectorGenereator) Stop

func (n *NatsMessagingSourceConnectorGenereator) Stop() error