Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KafkaLibrary ¶
type KafkaLibrary struct{}
KafkaLibrary ...
func (*KafkaLibrary) GetStateFull ¶
func (kafka *KafkaLibrary) GetStateFull() *StateFullFormat
GetStateFull ...
func (*KafkaLibrary) InitConsumer ¶
func (kafka *KafkaLibrary) InitConsumer() (sarama.Consumer, error)
InitConsumer ...
type KafkaLibraryInterface ¶
type KafkaLibraryInterface interface { GetStateFull() *StateFullFormat InitConsumer() (sarama.Consumer, error) }
KafkaLibraryInterface ...
type StateFullFormat ¶
type StateFullFormat struct { Payload *entity.LoggerRequest `json:"payload"` Function string `json:"__function"` }
StateFullFormat ...
Click to show internal directories.
Click to hide internal directories.