forwarder

Documentation

Index

• func CreateHeaders(transactionID string, originSystem string, bookmark string) map[string]string
• type Forwarder
  • func (f Forwarder) SendMessage(transactionID string, originSystem string, bookmark string, ...) error
• type QueueForwarder

Functions

func CreateHeaders

func CreateHeaders(transactionID string, originSystem string, bookmark string) map[string]string

CreateHeaders returns the relevant map with all the necessary kafka.FTMessage headers according to the specified transaction ID and origin system.

Types

type Forwarder

type Forwarder struct {
	Producer    kafkaProducer
	MessageType string
}

A Forwarder facilitates sending a message to Kafka via kafka.Producer.

func (Forwarder) SendMessage

func (f Forwarder) SendMessage(transactionID string, originSystem string, bookmark string, platformVersion string, uuid string, annotations interface{}, publication []string) error

SendMessage marshals an annotations payload using the outputMessage format and sends it to a Kafka.

type QueueForwarder

type QueueForwarder interface {
	SendMessage(transactionID string, originSystem string, bookmark string, platformVersion string, uuid string, annotations interface{}, publication []string) error
}

QueueForwarder is the interface implemented by types that can send annotation messages to a queue.