@@ -60,7 +60,7 @@ func main() {
60
60
61
61
config := types.ControllerConfig {
62
62
GatewayURL : os .Getenv ("OPENFAAS_URL" ),
63
- PrintResponse : true ,
63
+ PrintResponse : false ,
64
64
RebuildInterval : time .Second * 10 ,
65
65
UpstreamTimeout : time .Second * 15 ,
66
66
}
@@ -95,10 +95,10 @@ func bindEvents(c *vim25.Client, controller *types.Controller) error {
95
95
cancel ()
96
96
}
97
97
}()
98
+ <- ctx .Done ()
99
+ // done := make(chan bool)
98
100
99
- done := make (chan bool )
100
-
101
- <- done
101
+ // <-done
102
102
103
103
// controller.Invoke()
104
104
@@ -129,6 +129,12 @@ func makeRecv(controller *types.Controller, m *event.Manager) func(managedObject
129
129
func handleEvent (event vtypes.BaseEvent , m * event.Manager ) (string , string , error ) {
130
130
eventType := reflect .TypeOf (event ).Elem ().Name ()
131
131
132
+ gotEvent := event .GetEvent ()
133
+ if gotEvent .Vm != nil {
134
+ log .Printf ("VM: %s" , gotEvent .Vm .Vm .Reference ().String ())
135
+ }
136
+ log .Printf ("UserName: %s" , gotEvent .UserName )
137
+
132
138
category , err := m .EventCategory (context .Background (), event )
133
139
if err != nil {
134
140
return "" , "" , errors .Wrap (err , "error retrieving event category" )
@@ -139,16 +145,21 @@ func handleEvent(event vtypes.BaseEvent, m *event.Manager) (string, string, erro
139
145
topic := convertToTopic (eventType )
140
146
141
147
message , _ := json .Marshal (OutboundEvent {
142
- Topic : topic ,
143
- Category : category ,
148
+ Topic : topic ,
149
+ Category : category ,
150
+ CreatedTime : gotEvent .CreatedTime ,
151
+ UserName : gotEvent .UserName ,
144
152
})
145
153
146
154
return topic , string (message ), nil
147
155
}
148
156
149
157
type OutboundEvent struct {
150
- Topic string
151
- Category string
158
+ Topic string `json:"topic,omitempty"`
159
+ Category string `json:"category,omitempty"`
160
+
161
+ UserName string `json:"userName,omitempty"`
162
+ CreatedTime time.Time `json:"createdTime,omitempty"`
152
163
}
153
164
154
165
func newVCenterClient (ctx context.Context , vcenterURL string , insecure bool ) (* govmomi.Client , error ) {
0 commit comments