consumer

Documentation

Index

• Variables
• func HyperauthConsumer()
• func NewTLSConfig(clientCertFile, clientKeyFile, caCertFile string) (*tls.Config, error)
• type Consumer
  • func (consumer *Consumer) Cleanup(sarama.ConsumerGroupSession) error
  • func (consumer *Consumer) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
  • func (consumer *Consumer) Setup(sarama.ConsumerGroupSession) error
• type TopicEvent

Variables

var KafkaGroupId string

Functions

func HyperauthConsumer

func HyperauthConsumer()

func NewTLSConfig

func NewTLSConfig(clientCertFile, clientKeyFile, caCertFile string) (*tls.Config, error)

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().

func (*Consumer) Setup

func (consumer *Consumer) Setup(sarama.ConsumerGroupSession) error

Setup is run at the beginning of a new session, before ConsumeClaim

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"`
}