messaging

Documentation

Index

• Constants
• func NewNatsMessagingTargetConnectorGenerator() pluginapi.TargetConnectorGenerator
• type NatsMessagingTargetConnector
  • func (n *NatsMessagingTargetConnector) InvokeFlow(s, d pluginapi.Model) error
  • func (n *NatsMessagingTargetConnector) Reload() error
  • func (n *NatsMessagingTargetConnector) Start() error
  • func (n *NatsMessagingTargetConnector) Stop() error
• type NatsMessagingTargetConnectorGenerator
  • func (n *NatsMessagingTargetConnectorGenerator) GenerateTargetConnectorInstance(req pluginapi.TargetConnectorGenerateRequest) (pluginapi.TargetConnector, error)
  • func (n *NatsMessagingTargetConnectorGenerator) InitializeSubGeneratorInstance(req pluginapi.CommonTargetConnectorGenerateRequest) (pluginapi.TargetConnectorGenerator, error)
  • func (n *NatsMessagingTargetConnectorGenerator) OriginalGeneratorNames() []string
  • func (n *NatsMessagingTargetConnectorGenerator) Startup() error
  • func (n *NatsMessagingTargetConnectorGenerator) Stop() error

Constants

const (
	HeaderContentType = "Content-Type"

	ContentTypeJson = "application/json"
)

Functions

func NewNatsMessagingTargetConnectorGenerator

func NewNatsMessagingTargetConnectorGenerator() pluginapi.TargetConnectorGenerator

Types

type NatsMessagingTargetConnector

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

func (*NatsMessagingTargetConnector) InvokeFlow

func (n *NatsMessagingTargetConnector) InvokeFlow(s, d pluginapi.Model) error

func (*NatsMessagingTargetConnector) Reload

func (n *NatsMessagingTargetConnector) Reload() error

func (*NatsMessagingTargetConnector) Start

func (n *NatsMessagingTargetConnector) Start() error

func (*NatsMessagingTargetConnector) Stop

func (n *NatsMessagingTargetConnector) Stop() error

type NatsMessagingTargetConnectorGenerator

type NatsMessagingTargetConnectorGenerator struct {
}

func (*NatsMessagingTargetConnectorGenerator) GenerateTargetConnectorInstance

func (n *NatsMessagingTargetConnectorGenerator) GenerateTargetConnectorInstance(req pluginapi.TargetConnectorGenerateRequest) (pluginapi.TargetConnector, error)

func (*NatsMessagingTargetConnectorGenerator) InitializeSubGeneratorInstance

func (n *NatsMessagingTargetConnectorGenerator) InitializeSubGeneratorInstance(req pluginapi.CommonTargetConnectorGenerateRequest) (pluginapi.TargetConnectorGenerator, error)

func (*NatsMessagingTargetConnectorGenerator) OriginalGeneratorNames

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

func (*NatsMessagingTargetConnectorGenerator) Startup

func (n *NatsMessagingTargetConnectorGenerator) Startup() error

func (*NatsMessagingTargetConnectorGenerator) Stop

func (n *NatsMessagingTargetConnectorGenerator) Stop() error