Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var Enabled bool
View Source
var FlagSet *flag.FlagSet
View Source
var SHA256 scram.HashGeneratorFcn = sha256.New
View Source
var SHA512 scram.HashGeneratorFcn = sha512.New
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
type XDGSCRAMClient ¶
type XDGSCRAMClient struct {
*scram.Client
*scram.ClientConversation
scram.HashGeneratorFcn
}
func (*XDGSCRAMClient) Begin ¶
func (x *XDGSCRAMClient) Begin(userName, password, authzID string) (err error)
func (*XDGSCRAMClient) Done ¶
func (x *XDGSCRAMClient) Done() bool
Source Files
Click to show internal directories.
Click to hide internal directories.