Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var KafkaGroupId string
Functions ¶
func HyperauthConsumer ¶
func HyperauthConsumer()
Types ¶
type Consumer ¶
type Consumer struct {
// contains filtered or unexported fields
}
Consumer represents a Sarama consumer group consumer
func (*Consumer) Cleanup ¶
func (consumer *Consumer) Cleanup(sarama.ConsumerGroupSession) error
Cleanup is run at the end of a session, once all ConsumeClaim goroutines have exited
func (*Consumer) ConsumeClaim ¶
func (consumer *Consumer) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
ConsumeClaim must start a consumer loop of ConsumerGroupClaim's Messages().
type TopicEvent ¶
type TopicEvent struct {
Type string `json:"type"`
UserName string `json:"userName"`
UserId string `json:"userId"`
Time float32 `json:"time"`
RealmId string `json:"realmId"`
ClientId string `json:"clientId"`
SessionId string `json:"sessionId"`
IpAddress string `json:"ipAddress"`
Error string `json:"error"`
Details map[string]string `json:"details"`
}
Source Files
Click to show internal directories.
Click to hide internal directories.