consumer

Documentation

Overview

Package consumer will have config details of kafka topic and also have the functionality of consuming the events from the kafka on corresponding topics

Index

• Variables
• func Consume(ctx context.Context, topicName string)
• func EventSubscriber(event interface{})
• func SubscribeCtrlMsgQueue(topicName string)

Variables

var (
	// In Channel
	In chan<- interface{}
	// Out Channel
	Out <-chan interface{}
	// CtrlMsgRecvQueue is the channel for receiving
	// internal messages read from intercomm message bus queue
	CtrlMsgRecvQueue chan<- interface{}
	// CtrlMsgProcQueue is the channel for processing
	// internal messages received from intercomm messae bus queue
	CtrlMsgProcQueue <-chan interface{}
)

Functions

func Consume

func Consume(ctx context.Context, topicName string)

Consume create a consumer for message bus the topic can be defined inside configuration file config.toml

func EventSubscriber

func EventSubscriber(event interface{})

EventSubscriber consume messages from PMB

func SubscribeCtrlMsgQueue

func SubscribeCtrlMsgQueue(topicName string)

SubscribeCtrlMsgQueue creates a consumer for the kafka topic