connector

type Connector interface {
	Send(message *Message, opts *SendOptions) error
	RequestReply(request *Message, opts *SendOptions, then ReplyHandler) error
	Close() error
}

type ConnectorError func(message string) error

type JSONSerializer struct{}

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

type Message struct {
	ID         string
	Type       string
	Port       string
	Path       string
	Variables  map[string]string
	Parameters map[string][]string
	Headers    map[string]string
	Payload    []byte
}

type MessageHeaders map[string]interface{}

type MessageSerializer interface {
	Serialize(msg *Message) ([]byte, error)
}

type ReplyHandler func(reply []byte, headers MessageHeaders, err error)

type SendOptions struct {
	Topic          string
	Partition      int
	ReplyTopic     string
	ReplyPartition int
	Passthrough    bool
}

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

type YAMLSerializer struct{}