@@ -216,7 +216,5 @@ func logQuery(level log.LogQueryLevel, request *restful.Request) *es.QueryResult
|
|||||||
param.Size = 10
|
param.Size = 10
|
||||||
}
|
}
|
||||||
|
|
||||||
glog.Infof("LogQuery with %v", param)
|
|
||||||
|
|
||||||
return es.Query(param)
|
return es.Query(param)
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -474,6 +474,7 @@ func syncFluentbitCRDOutputWithConfigMap(outputs []fb.OutputPlugin) error {
|
|||||||
|
|
||||||
crdcs, scheme, err := createCRDClientSet()
|
crdcs, scheme, err := createCRDClientSet()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
glog.Errorln(err)
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -482,12 +483,14 @@ func syncFluentbitCRDOutputWithConfigMap(outputs []fb.OutputPlugin) error {
|
|||||||
|
|
||||||
fluentbit, err := crdclient.Get("fluent-bit")
|
fluentbit, err := crdclient.Get("fluent-bit")
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
glog.Errorln(err)
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
fluentbit.Spec.Output = enabledOutputs
|
fluentbit.Spec.Output = enabledOutputs
|
||||||
_, err = crdclient.Update("fluent-bit", fluentbit)
|
_, err = crdclient.Update("fluent-bit", fluentbit)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
glog.Errorln(err)
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user