mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-09-15 06:01:50 +00:00
Add err judgment
This commit is contained in:
@@ -180,7 +180,10 @@ func (c *realRecyclerClient) Event(eventtype, message string) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (c *realRecyclerClient) WatchPod(name, namespace string, stopChannel chan struct{}) (<-chan watch.Event, error) {
|
func (c *realRecyclerClient) WatchPod(name, namespace string, stopChannel chan struct{}) (<-chan watch.Event, error) {
|
||||||
podSelector, _ := fields.ParseSelector("metadata.name=" + name)
|
podSelector, err := fields.ParseSelector("metadata.name=" + name)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
options := metav1.ListOptions{
|
options := metav1.ListOptions{
|
||||||
FieldSelector: podSelector.String(),
|
FieldSelector: podSelector.String(),
|
||||||
Watch: true,
|
Watch: true,
|
||||||
|
Reference in New Issue
Block a user