Fix truncating and buffering backends integration.
Kubernetes-commit: 20fb0b5eb180fb4cb9be18ab3fc8cd259c7f7bf0
This commit is contained in:
parent
473c11dfcb
commit
0da9a3f4a0
|
|
@ -102,6 +102,7 @@ type bufferedBackend struct {
|
||||||
var _ audit.Backend = &bufferedBackend{}
|
var _ audit.Backend = &bufferedBackend{}
|
||||||
|
|
||||||
// NewBackend returns a buffered audit backend that wraps delegate backend.
|
// NewBackend returns a buffered audit backend that wraps delegate backend.
|
||||||
|
// Buffered backend automatically runs and shuts down the delegate backend.
|
||||||
func NewBackend(delegate audit.Backend, config BatchConfig) audit.Backend {
|
func NewBackend(delegate audit.Backend, config BatchConfig) audit.Backend {
|
||||||
var throttle flowcontrol.RateLimiter
|
var throttle flowcontrol.RateLimiter
|
||||||
if config.ThrottleEnable {
|
if config.ThrottleEnable {
|
||||||
|
|
|
||||||
|
|
@ -62,6 +62,7 @@ type backend struct {
|
||||||
var _ audit.Backend = &backend{}
|
var _ audit.Backend = &backend{}
|
||||||
|
|
||||||
// NewBackend returns a new truncating backend, using configuration passed in the parameters.
|
// NewBackend returns a new truncating backend, using configuration passed in the parameters.
|
||||||
|
// Truncate backend automatically runs and shut downs the delegate backend.
|
||||||
func NewBackend(delegateBackend audit.Backend, config Config, groupVersion schema.GroupVersion) audit.Backend {
|
func NewBackend(delegateBackend audit.Backend, config Config, groupVersion schema.GroupVersion) audit.Backend {
|
||||||
return &backend{
|
return &backend{
|
||||||
delegateBackend: delegateBackend,
|
delegateBackend: delegateBackend,
|
||||||
|
|
@ -128,12 +129,11 @@ func truncate(e *auditinternal.Event) *auditinternal.Event {
|
||||||
}
|
}
|
||||||
|
|
||||||
func (b *backend) Run(stopCh <-chan struct{}) error {
|
func (b *backend) Run(stopCh <-chan struct{}) error {
|
||||||
// Nothing to do here
|
return b.delegateBackend.Run(stopCh)
|
||||||
return nil
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func (b *backend) Shutdown() {
|
func (b *backend) Shutdown() {
|
||||||
// Nothing to do here
|
b.delegateBackend.Shutdown()
|
||||||
}
|
}
|
||||||
|
|
||||||
func (b *backend) calcSize(e *auditinternal.Event) (int64, error) {
|
func (b *backend) calcSize(e *auditinternal.Event) (int64, error) {
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue