-
Notifications
You must be signed in to change notification settings - Fork 184
/
handler.go
87 lines (70 loc) · 2.46 KB
/
handler.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
package logger
import (
k8sV1 "k8s.io/api/core/v1"
"k8s.io/klog"
"github.com/submariner-io/admiral/pkg/log"
submV1 "github.com/submariner-io/submariner/pkg/apis/submariner.io/v1"
"github.com/submariner-io/submariner/pkg/event"
)
type Handler struct {
event.HandlerBase
}
func NewHandler() event.Handler {
return &Handler{}
}
func (l *Handler) GetName() string {
return "logger"
}
func (l *Handler) GetNetworkPlugins() []string {
return []string{event.AnyNetworkPlugin}
}
func (l *Handler) TransitionToNonGateway() error {
klog.V(log.DEBUG).Info("The current node is no longer a Gateway")
return nil
}
func (l *Handler) TransitionToGateway() error {
klog.V(log.DEBUG).Info("The current node has become a Gateway")
return nil
}
func (l *Handler) LocalEndpointCreated(endpoint *submV1.Endpoint) error {
klog.V(log.DEBUG).Infof("A new Endpoint for the local cluster has been created: %#v", endpoint.Spec)
return nil
}
func (l *Handler) LocalEndpointUpdated(endpoint *submV1.Endpoint) error {
klog.V(log.DEBUG).Infof("The Endpoint for the local cluster has been updated: %#v", endpoint.Spec)
return nil
}
func (l *Handler) LocalEndpointRemoved(endpoint *submV1.Endpoint) error {
klog.V(log.DEBUG).Infof("The Endpoint for the local cluster has been removed: %#v", endpoint.Spec)
return nil
}
func (l *Handler) RemoteEndpointCreated(endpoint *submV1.Endpoint) error {
klog.V(log.DEBUG).Infof("A new Endpoint for remote cluster %q has been created: %#v",
endpoint.Spec.ClusterID, endpoint.Spec)
return nil
}
func (l *Handler) RemoteEndpointUpdated(endpoint *submV1.Endpoint) error {
klog.V(log.DEBUG).Infof("A new Endpoint for remote cluster %q has been updated: %#v",
endpoint.Spec.ClusterID, endpoint.Spec)
return nil
}
func (l *Handler) RemoteEndpointRemoved(endpoint *submV1.Endpoint) error {
klog.V(log.DEBUG).Infof("A new Endpoint for remote cluster %q has been removed: %#v",
endpoint.Spec.ClusterID, endpoint.Spec)
return nil
}
func (l *Handler) NodeCreated(node *k8sV1.Node) error {
klog.V(log.DEBUG).Infof("A Node with name %q and addresses %#v has been added to the cluster",
node.Name, node.Status.Addresses)
return nil
}
func (l *Handler) NodeUpdated(node *k8sV1.Node) error {
klog.V(log.DEBUG).Infof("A Node with name %q and addresses %#v has been updated",
node.Name, node.Status.Addresses)
return nil
}
func (l *Handler) NodeRemoved(node *k8sV1.Node) error {
klog.V(log.DEBUG).Infof("A Node with name %q has been removed",
node.Name)
return nil
}