msgqueue

package module

v0.0.0-...-06d1302 Latest Latest Go to latest Published: Jun 6, 2017 License: BSD-2-Clause Imports: 6 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

func GenerateTopic(msg interface{}) string

GenerateTopic Unmarshaled JSON and extracts the app name and hour to create a topic

func ParseActivityLog(msg *[]byte) interface{}

ParseActivityLog takes a string of bytes and returns json with type interface{} This is designed to handle dynamic json structure

type Kafka struct {
	Brokers        []string
	ConsumerTopics []string
	ConsumerGroup  string
	OffsetInitial  string
}

Kafka stores the necessary values to setup of Kafka consumer and/or producer

func (k *Kafka) ProduceMessage(message *ProducerMessage) *sarama.ProducerMessage

ProduceMessage creates a message that can be sent to AsyncProducer Input

func (k *Kafka) SetupConsumer() *KafkaConsumer

SetupConsumer initializes a new consumer

func (k *Kafka) SetupProducer() *KafkaProducer

SetupProducer initializes a new consumer

type KafkaConsumer struct {
	Consumer *cluster.Consumer
}

KafkaConsumer is a sarama-cluster Consumer

type KafkaProducer struct {
	Producer sarama.AsyncProducer
}

KafkaProducer is a sarama AsyncProducer

type ProducerMessage struct {
	Topic   string
	Message string
}

ProducerMessage defines the fields for creating a message to be consumed by a producer