alexlebens/external-snapshotter
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Add event scheme

Browse Source 
This PR adds the event scheme
This commit is contained in:
Jing Xu
2018-09-13 11:37:06 -07:00
parent 1f658f29f7
commit 2141247565
2 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
cmd/csi-snapshotter/main.go
View File

@@ -26,6 +26,7 @@ import (
"github.com/golang/glog" "github.com/golang/glog"
"k8s.io/client-go/kubernetes" "k8s.io/client-go/kubernetes"
"k8s.io/client-go/kubernetes/scheme"
"k8s.io/client-go/rest" "k8s.io/client-go/rest"
"k8s.io/client-go/tools/clientcmd" "k8s.io/client-go/tools/clientcmd"
@@ -33,6 +34,7 @@ import (
"github.com/kubernetes-csi/external-snapshotter/pkg/controller" "github.com/kubernetes-csi/external-snapshotter/pkg/controller"
clientset "github.com/kubernetes-csi/external-snapshotter/pkg/client/clientset/versioned" clientset "github.com/kubernetes-csi/external-snapshotter/pkg/client/clientset/versioned"
snapshotscheme "github.com/kubernetes-csi/external-snapshotter/pkg/client/clientset/versioned/scheme"
informers "github.com/kubernetes-csi/external-snapshotter/pkg/client/informers/externalversions" informers "github.com/kubernetes-csi/external-snapshotter/pkg/client/informers/externalversions"
apiextensionsclient "k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset" apiextensionsclient "k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset"
) )
@@ -97,6 +99,9 @@ func main() {
os.Exit(1) os.Exit(1)
} }
// Add Snapshot types to the defualt Kubernetes so events can be logged for them
snapshotscheme.AddToScheme(scheme.Scheme)
// Connect to CSI. // Connect to CSI.
csiConn, err := connection.New(*csiAddress, *connectionTimeout) csiConn, err := connection.New(*csiAddress, *connectionTimeout)
if err != nil { if err != nil {

1
pkg/controller/snapshot_controller_base.go
View File

@@ -84,6 +84,7 @@ func NewCSISnapshotController(
snapshotNameUUIDLength int, snapshotNameUUIDLength int,
) *csiSnapshotController { ) *csiSnapshotController {
broadcaster := record.NewBroadcaster() broadcaster := record.NewBroadcaster()
broadcaster.StartLogging(glog.Infof)
broadcaster.StartRecordingToSink(&corev1.EventSinkImpl{Interface: client.Core().Events(v1.NamespaceAll)}) broadcaster.StartRecordingToSink(&corev1.EventSinkImpl{Interface: client.Core().Events(v1.NamespaceAll)})
var eventRecorder record.EventRecorder var eventRecorder record.EventRecorder
eventRecorder = broadcaster.NewRecorder(scheme.Scheme, v1.EventSource{Component: fmt.Sprintf("csi-snapshotter %s", snapshotterName)}) eventRecorder = broadcaster.NewRecorder(scheme.Scheme, v1.EventSource{Component: fmt.Sprintf("csi-snapshotter %s", snapshotterName)})