github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-27 05:27:21 +00:00
Code Issues Projects Releases Wiki Activity

Cache encoder for auditlog backend

Browse Source
This commit is contained in:
wojtekt 2019-10-03 16:38:47 +02:00
parent 90f487190a
commit 3ad42fb8ca
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
staging/src/k8s.io/apiserver/plugin/pkg/audit/log/backend.go
View File

@ -44,18 +44,18 @@ var AllowedFormats = []string{
} }
type backend struct { type backend struct {
out io.Writer out io.Writer
format string format string
groupVersion schema.GroupVersion encoder runtime.Encoder
} }
var _ audit.Backend = &backend{} var _ audit.Backend = &backend{}
func NewBackend(out io.Writer, format string, groupVersion schema.GroupVersion) audit.Backend { func NewBackend(out io.Writer, format string, groupVersion schema.GroupVersion) audit.Backend {
return &backend{ return &backend{
out: out, out: out,
format: format, format: format,
groupVersion: groupVersion, encoder: audit.Codecs.LegacyCodec(groupVersion),
} }
} }
@ -73,7 +73,7 @@ func (b *backend) logEvent(ev *auditinternal.Event) bool {
case FormatLegacy: case FormatLegacy:
line = audit.EventString(ev) + "\n" line = audit.EventString(ev) + "\n"
case FormatJson: case FormatJson:
bs, err := runtime.Encode(audit.Codecs.LegacyCodec(b.groupVersion), ev) bs, err := runtime.Encode(b.encoder, ev)
if err != nil { if err != nil {
audit.HandlePluginError(PluginName, err, ev) audit.HandlePluginError(PluginName, err, ev)
return false return false