notifierKafka

Documentation

Index

• Variables
• func ConfigProcess(instance string)
• type NotifierKafka
  • func New(instance string, handler mdata.NotifierHandler) *NotifierKafka
  • func (c *NotifierKafka) Send(sc mdata.SavedChunk)
  • func (c *NotifierKafka) Stop()

Variables

var Enabled bool

var FlagSet *flag.FlagSet

Functions

func ConfigProcess

func ConfigProcess(instance string)

Types

type NotifierKafka

type NotifierKafka struct {
	StopChan chan int
	// contains filtered or unexported fields
}

func New

func New(instance string, handler mdata.NotifierHandler) *NotifierKafka

func (*NotifierKafka) Send

func (c *NotifierKafka) Send(sc mdata.SavedChunk)

func (*NotifierKafka) Stop

func (c *NotifierKafka) Stop()

Stop will initiate a graceful stop of the Consumer (permanent)

NOTE: receive on StopChan to block until this process completes