Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KafkaMessage ¶
type KafkaMessage struct { Ingest string `json:"ingest"` IngestID string `json:"ingestId"` Timestamp string `json:"timestamp"` Payload string `json:"payload"` Metadata map[string]interface{} `json:"metadata"` }
KafkaMessage defines the message structure
type KafkaOperations ¶
type KafkaOperations interface {
PayloadQueue() chan<- *Payload
}
KafkaOperations defines operations for kafka messaging
type KafkaService ¶
type KafkaService struct {
// contains filtered or unexported fields
}
KafkaService implements kafka message functionality
func NewKafkaService ¶
func NewKafkaService(sp sarama.SyncProducer) *KafkaService
NewKafkaService will instantiate an instance using the producer provided
func (*KafkaService) PayloadQueue ¶
func (k *KafkaService) PayloadQueue() chan<- *Payload
PayloadQueue provides access to load a payload object into the queue for sending
Click to show internal directories.
Click to hide internal directories.