Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var (
AclAuthorizerRegex = regroup.MustCompile(
`^\[(?P<date>\d{4}-\d{2}-\d{2} \d{2}:\d{2}:\d{2},\d+)\] (?P<level>[A-Z]+) Principal = User:\S+CN=(?P<serviceName>[a-z0-9-.]+)\.(?P<namespace>[a-z0-9-.]+),\S+ is (?P<access>\S+) Operation = (?P<operation>\S+) from host = (?P<host>\S+) on resource = Topic:LITERAL:(?P<topic>.+) for request = (?P<request>\S+) with resourceRefCount = (?P<resourceRefCount>\d+) \(kafka\.authorizer\.logger\)$`,
)
)
View Source
var (
KafkaOperationToAclOperationBMap = bimap.NewBiMapFromMap(kafkaOperationToAclOperation)
)
Functions ¶
func KafkaOpFromText ¶
func KafkaOpFromText(text string) (v1alpha3.KafkaOperation, error)
Types ¶
type AuthorizerRecord ¶
type AuthorizerRecord struct {
Date string `regroup:"date"`
Level string `regroup:"level"`
ServiceName string `regroup:"serviceName"`
Namespace string `regroup:"namespace"`
Access string `regroup:"access"`
Operation string `regroup:"operation"`
Host string `regroup:"host"`
Topic string `regroup:"topic"`
Request string `regroup:"request"`
ResourceRefCount int `regroup:"resourceRefCount"`
}
func (AuthorizerRecord) ToIntent ¶
func (r AuthorizerRecord) ToIntent(serverName string, serverNamespace string) (v1alpha3.ClientIntents, error)
type Mapper ¶
type Mapper struct {
// contains filtered or unexported fields
}
func (*Mapper) LoadIntents ¶
func (*Mapper) MapKafkaAuthorizerLogs ¶
Source Files
Click to show internal directories.
Click to hide internal directories.