- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 24 for cfgs (0.2 sec)
-
istioctl/pkg/describe/describe.go
var cfgs []*config.Config for _, cfg := range configs { cfg := cfg labels := cfg.Spec.(Workloader).GetSelector().GetMatchLabels() selector := klabels.SelectorFromSet(labels) if selector.Matches(podsLabels) { cfgs = append(cfgs, cfg) } } return cfgs }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 50.4K bytes - Viewed (0) -
cni/pkg/iptables/nldeps.go
type NetlinkDependencies interface { AddInpodMarkIPRule(cfg *Config) error DelInpodMarkIPRule(cfg *Config) error AddLoopbackRoutes(cfg *Config) error DelLoopbackRoutes(cfg *Config) error } func RealNlDeps() NetlinkDependencies { return &realDeps{} } type realDeps struct{} func (r *realDeps) AddInpodMarkIPRule(cfg *Config) error { return AddInpodMarkIPRule(cfg) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 1.6K bytes - Viewed (0) -
cni/pkg/iptables/iptables_linux.go
) func AddInpodMarkIPRule(cfg *Config) error { err := forEachInpodMarkIPRule(cfg, netlink.RuleAdd) if errors.Is(err, unix.EEXIST) { log.Debugf("Ignoring exists error adding inpod mark ip rule: %v", err) return nil } return err } func DelInpodMarkIPRule(cfg *Config) error { return forEachInpodMarkIPRule(cfg, netlink.RuleDel) } func forEachInpodMarkIPRule(cfg *Config, f func(*netlink.Rule) error) error {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 3.3K bytes - Viewed (0) -
cni/pkg/repair/repaircontroller.go
pods kclient.Client[*corev1.Pod] queue controllers.Queue cfg config.RepairConfig events kclient.EventRecorder repairedPods map[types.NamespacedName]types.UID } func NewRepairController(client kube.Client, cfg config.RepairConfig) (*Controller, error) { c := &Controller{ cfg: cfg, client: client, events: kclient.NewEventRecorder(client, "cni-repair"),
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Feb 10 00:31:55 GMT 2024 - 10.4K bytes - Viewed (0) -
cni/pkg/install/install_test.go
t.Fatal(err) } } cfg := &config.InstallConfig{ MountedCNINetDir: tempDir, CNIConfName: c.cniConfName, ChainedCNIPlugin: c.chainedCNIPlugin, } err := checkValidCNIConfig(cfg, filepath.Join(tempDir, c.cniConfigFilename)) if (c.expectedFailure && err == nil) || (!c.expectedFailure && err != nil) {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 11.1K bytes - Viewed (0) -
cni/pkg/plugin/sidecar_iptables_linux.go
cfg := config.DefaultConfig() cfg.CNIMode = true cfg.NetworkNamespace = netns cfg.ProxyPort = rdrct.targetPort cfg.ProxyUID = rdrct.noRedirectUID cfg.ProxyGID = rdrct.noRedirectGID cfg.InboundInterceptionMode = rdrct.redirectMode cfg.OutboundIPRangesInclude = rdrct.includeIPCidrs cfg.InboundPortsExclude = rdrct.excludeInboundPorts cfg.InboundPortsInclude = rdrct.includeInboundPorts
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 18 17:36:41 GMT 2024 - 2.5K bytes - Viewed (0) -
cni/pkg/iptables/iptables_unspecified.go
import ( "errors" ) func AddInpodMarkIPRule(cfg *Config) error { return errors.New("not implemented on this platform") } func DelInpodMarkIPRule(cfg *Config) error { return errors.New("not implemented on this platform") } func AddLoopbackRoutes(cfg *Config) error { return errors.New("not implemented on this platform") } func DelLoopbackRoutes(cfg *Config) error {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 1K bytes - Viewed (0) -
cni/pkg/repair/repair.go
func StartRepair(ctx context.Context, cfg config.RepairConfig) { if !cfg.Enabled { repairLog.Info("CNI repair is disable.") return } repairLog.Info("Start CNI race condition repair.") client, err := clientSetup() if err != nil { repairLog.Fatalf("CNI repair could not construct clientSet: %s", err) } rc, err := NewRepairController(client, cfg) if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue May 23 17:08:31 GMT 2023 - 1.5K bytes - Viewed (0) -
cni/pkg/nodeagent/server.go
if err != nil { return nil, fmt.Errorf("error initializing kube client: %w", err) } cfg := &iptables.Config{ RestoreFormat: true, RedirectDNS: args.DNSCapture, EnableIPv6: args.EnableIPv6, } log.Debug("creating ipsets in the node netns") set, err := createHostsideProbeIpset(cfg.EnableIPv6) if err != nil { return nil, fmt.Errorf("error initializing hostside probe ipset: %w", err) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 7.2K bytes - Viewed (0) -
istioctl/pkg/kubeinject/kubeinject.go
if !exists { return nil, fmt.Errorf("missing configuration map key %q", configMapKey) } cfg, err := mesh.ApplyMeshConfigDefaults(configYaml) if err != nil { err = multierror.Append(err, fmt.Errorf("istioctl version %s cannot parse mesh config. Install istioctl from the latest Istio release", version.Info.Version)) } return cfg, err } // grabs the raw values from the ConfigMap. These are encoded as JSON.
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 29 02:29:02 GMT 2024 - 21.6K bytes - Viewed (0)