kafkamapper

Documentation

Index

• Variables
• func KafkaOpFromText(text string) (v2alpha1.KafkaOperation, error)
• type AuthorizerRecord
  • func (r AuthorizerRecord) ToIntent(serverName string, serverNamespace string) (v2alpha1.ClientIntents, error)
• type Mapper
  • func NewMapper() (*Mapper, error)
  • func (m *Mapper) LoadIntents(ctx context.Context, serverName string, serverNamespace string) ([]v2alpha1.ClientIntents, error)
  • func (m *Mapper) MapKafkaAuthorizerLogs(ctx context.Context, serverName string, serverNamespace string, ...) error

Variables

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\)$`,
	)
)

var (
	KafkaOperationToAclOperationBMap = bimap.NewBiMapFromMap(kafkaOperationToAclOperation)
)

Functions

func KafkaOpFromText

func KafkaOpFromText(text string) (v2alpha1.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) (v2alpha1.ClientIntents, error)

type Mapper

type Mapper struct {
	// contains filtered or unexported fields
}

func NewMapper

func NewMapper() (*Mapper, error)

func (*Mapper) LoadIntents

func (m *Mapper) LoadIntents(ctx context.Context, serverName string, serverNamespace string) ([]v2alpha1.ClientIntents, error)

func (*Mapper) MapKafkaAuthorizerLogs

func (m *Mapper) MapKafkaAuthorizerLogs(ctx context.Context, serverName string, serverNamespace string, mapperFn func(r AuthorizerRecord) error) error