- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 44 for repair (0.17 sec)
-
cni/pkg/repair/repair.go
// limitations under the License. package repair import ( "context" "istio.io/istio/cni/pkg/config" "istio.io/istio/pkg/kube" "istio.io/istio/pkg/log" ) var repairLog = log.RegisterScope("repair", "CNI race condition repair") func StartRepair(ctx context.Context, cfg config.RepairConfig) { if !cfg.Enabled { repairLog.Info("CNI repair is disable.") return }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue May 23 17:08:31 GMT 2023 - 1.5K bytes - Viewed (0) -
cni/pkg/repair/repair_test.go
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. package repair import ( "fmt" "strings" "testing" "time" corev1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" klabels "k8s.io/apimachinery/pkg/labels" "k8s.io/apimachinery/pkg/runtime"
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Oct 24 03:31:28 GMT 2023 - 10.6K bytes - Viewed (0) -
cni/pkg/repair/repair_test_helpers.go
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. package repair import ( corev1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "istio.io/istio/tools/istio-iptables/pkg/constants" ) type makePodArgs struct { PodName string
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri May 12 17:39:53 GMT 2023 - 4.7K bytes - Viewed (0) -
cni/pkg/constants/constants.go
AmbientIPv6 = "ambient-ipv6" // Repair RepairEnabled = "repair-enabled" RepairDeletePods = "repair-delete-pods" RepairRepairPods = "repair-repair-pods" RepairLabelPods = "repair-label-pods" RepairLabelKey = "repair-broken-pod-label-key" RepairLabelValue = "repair-broken-pod-label-value" RepairNodeName = "repair-node-name"
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 2.7K bytes - Viewed (0) -
cni/pkg/repair/repaircontroller.go
// We will get an event every time the pod changes. The repair is not instantaneous, though -- it will only recover // once the pod restarts (in CrashLoopBackoff), which can take some time. // We don't want to constantly try to apply the iptables rules, which is unneeded and will fail. // Instead, we track which UIDs we repaired and skip them if already repaired. //
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Sat Feb 10 00:31:55 GMT 2024 - 10.4K bytes - Viewed (0) -
cni/pkg/config/config.go
AmbientDNSCapture bool // Whether ipv6 is enabled for ambient capture AmbientIPv6 bool } // RepairConfig struct defines the Istio CNI race repair configuration type RepairConfig struct { // Whether to enable CNI race repair Enabled bool // The node name that the CNI DaemonSet runs on NodeName string // Key and value for broken pod label LabelKey string LabelValue string
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 5.5K bytes - Viewed (0) -
cni/pkg/repair/monitoring.go
podsRepaired = monitoring.NewSum( "istio_cni_repair_pods_repaired_total", "Total number of pods repaired by repair controller", )
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Wed Dec 20 22:14:13 GMT 2023 - 1K bytes - Viewed (0) -
cni/pkg/cmd/root.go
registerBooleanParameter(constants.AmbientEnabled, false, "Whether ambient controller is enabled") // Repair registerBooleanParameter(constants.RepairEnabled, true, "Whether to enable race condition repair or not") registerBooleanParameter(constants.RepairDeletePods, false, "Controller will delete pods when detecting pod broken by race condition")
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.5K bytes - Viewed (0) -
cmd/xl-storage-format-v2.go
} x.versions = x.versions[:versions] x.data = data x.metaV = metaV if err = x.data.validate(); err != nil { x.data.repair() storageLogIf(GlobalContext, fmt.Errorf("xlMetaV2.loadIndexed: data validation failed: %v. %d entries after repair", err, x.data.entries())) } return decodeVersions(buf, versions, func(i int, hdr, meta []byte) error { ver := &x.versions[i]
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Apr 23 05:07:37 GMT 2024 - 63.6K bytes - Viewed (1) -
cni/pkg/repair/netns.go
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. package repair import ( "fmt" "math" "net" "strconv" netns "github.com/containernetworking/plugins/pkg/ns" "github.com/prometheus/procfs" "github.com/vishvananda/netlink" "golang.org/x/sys/unix"
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Wed Dec 20 22:14:13 GMT 2023 - 4.8K bytes - Viewed (0)