Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewConsumer ¶
func NewConsumer() *kafka.Reader
Types ¶
type AuthHeader ¶
type AuthHeader struct { Identity Identity `json:"identity"` Entitlements Entitlements `json:"entitlements"` }
type Entitlements ¶
type Entitlements struct {
CostManagement CostMgmt `json:"cost_management"`
}
type KafkaEvent ¶
type KafkaEvent struct { Offset int64 Partition int Topic string EventType string `json:"event_type"` ResourceID int `json:"resource_id"` SourceID int `json:"source_id"` AuthType string `json:"authtype"` AuthHeader *AuthHeader `json:"auth_header"` EncodedAuth string }
func GetMsgData ¶
func GetMsgData(m *kafka.Message) KafkaEvent
Click to show internal directories.
Click to hide internal directories.