kubelatte-ce

1
package audit
2

3
import (
4
	"gitverse.ru/ktrntrsv/kubelatte-ce/pkg/operator/utils"
5
)
6

7
var listening = false
8

9
var AuditStub = func() {
10
	if !listening {
11
		go listenChannels()
12
	}
13
}
14

15
func listenChannels() {
16
	for {
17
		select {
18
		case <-utils.EventStartedLeader:
19
		case <-utils.EventWithHashCh:
20
		}
21
	}
22
}
23