- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 32 for Sync (0.15 sec)
-
istioctl/pkg/waypoint/waypoint.go
List(context.Background(), metav1.ListOptions{}) if err != nil { return err } for _, gw := range waypoints.Items { names = append(names, gw.Name) } } var wg sync.WaitGroup var mu sync.Mutex for _, name := range names { wg.Add(1) go func(name string) { defer wg.Done() if err := kubeClient.GatewayAPI().GatewayV1().Gateways(namespace).
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Mon Apr 22 20:20:40 GMT 2024 - 15K bytes - Viewed (0) -
manifests/charts/istio-control/istio-discovery/templates/revision-tags.yaml
- key: istio.io/rev operator: In values: - "{{ $tagName }}" {{- /* When the tag is "default" we want to create webhooks for the default revision */}} {{- /* These webhooks should be kept in sync with istio-discovery/templates/mutatingwebhook.yaml */}} {{- if (eq $tagName "default") }} {{- /* Case 1: Namespace selector enabled, and object selector is not injected */}}
Others - Registered: Wed Mar 20 22:53:08 GMT 2024 - Last Modified: Wed Jul 12 18:12:47 GMT 2023 - 4.4K bytes - Viewed (1) -
cni/pkg/install/install_test.go
// See the License for the specific language governing permissions and // limitations under the License. package install import ( "context" "os" "path/filepath" "sync/atomic" "testing" "time" "istio.io/istio/cni/pkg/config" testutils "istio.io/istio/pilot/test/util" "istio.io/istio/pkg/file" "istio.io/istio/pkg/test/util/assert" "istio.io/istio/pkg/util/sets" )
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 11.1K bytes - Viewed (0) -
cni/pkg/log/uds.go
package log import ( "encoding/json" "fmt" "io" "net/http" "strings" "sync" "time" "istio.io/istio/cni/pkg/constants" "istio.io/istio/pkg/log" "istio.io/istio/pkg/network" "istio.io/istio/pkg/uds" ) var pluginLog = log.RegisterScope("cni", "CNI network plugin") type UDSLogger struct { mu sync.Mutex loggingServer *http.Server } type cniLog struct {
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Wed Nov 29 01:05:12 GMT 2023 - 3.3K bytes - Viewed (0) -
cni/test/install_cni.go
// limitations under the License. package install import ( "bytes" "context" "errors" "fmt" "os" "path/filepath" "strings" "sync" "sync/atomic" "testing" "time" "github.com/google/go-cmp/cmp" "github.com/spf13/viper" "istio.io/istio/cni/pkg/config" "istio.io/istio/cni/pkg/constants" "istio.io/istio/cni/pkg/install"
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 12.5K bytes - Viewed (0) -
cni/cmd/istio-cni/main.go
return err } defer func() { // Log sync will send logs to install-cni container via UDS. // We don't need a timeout here because underlying the log pkg already handles it. // this may fail, but it should be safe to ignore according // to https://github.com/uber-go/zap/issues/328 _ = log.Sync() }() // TODO: implement plugin version
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Tue Jan 16 02:37:48 GMT 2024 - 1.8K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
// See the License for the specific language governing permissions and // limitations under the License. package nodeagent import ( "context" "errors" "fmt" "io" "net" "os" "sync" "time" "golang.org/x/sys/unix" "google.golang.org/protobuf/proto" v1 "k8s.io/api/core/v1" "istio.io/istio/pkg/monitoring" "istio.io/istio/pkg/spiffe" "istio.io/istio/pkg/zdsapi" ) var (
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
istioctl/pkg/writer/pilot/status.go
"istio.io/istio/istioctl/pkg/multixds" "istio.io/istio/pilot/pkg/model" xdsresource "istio.io/istio/pilot/pkg/xds/v3" "istio.io/istio/pkg/log" ) // XdsStatusWriter enables printing of sync status using multiple xdsapi.DiscoveryResponse Istiod responses type XdsStatusWriter struct { Writer io.Writer Namespace string InternalDebugAllIstiod bool }
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 04:16:55 GMT 2024 - 6.1K bytes - Viewed (0) -
operator/cmd/mesh/shared.go
// limitations under the License. // Package mesh contains types and functions. package mesh import ( "fmt" "io" "os" "strings" "sync" "time" "sigs.k8s.io/controller-runtime/pkg/client" controllruntimelog "sigs.k8s.io/controller-runtime/pkg/log" "istio.io/istio/istioctl/pkg/install/k8sversion" "istio.io/istio/operator/pkg/apis/istio/v1alpha1"
Go - Registered: Wed Mar 20 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 5.3K bytes - Viewed (0) -
cni/pkg/install/install.go
// See the License for the specific language governing permissions and // limitations under the License. package install import ( "context" "fmt" "os" "path/filepath" "sync/atomic" "istio.io/istio/cni/pkg/config" "istio.io/istio/cni/pkg/constants" "istio.io/istio/cni/pkg/util" "istio.io/istio/pkg/file" "istio.io/istio/pkg/log" "istio.io/istio/pkg/util/sets" )
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Thu Feb 08 18:52:24 GMT 2024 - 10.8K bytes - Viewed (0)