notifierKafka

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 30, 2020 License: AGPL-3.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var Enabled bool
View Source
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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL