- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 43 for atomic (0.27 sec)
-
common-protos/k8s.io/api/discovery/v1/generated.proto
message EndpointHints { // forZones indicates the zone(s) this endpoint should be consumed by to // enable topology aware routing. // +listType=atomic repeated ForZone forZones = 1; } // EndpointPort represents a Port used by an EndpointSlice // +structType=atomic message EndpointPort { // name represents the name of this port. All ports in an EndpointSlice must have a unique name.
Plain Text - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 8K bytes - Viewed (0) -
common/scripts/metallb-native.yaml
are ANDed. type: object type: object x-kubernetes-map-type: atomic type: array ipAddressPools: description: The list of IPAddressPools to advertise via this advertisement, selected by name. items:
Others - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Feb 23 23:56:31 GMT 2024 - 63.9K 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 May 01 22:53:12 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 12.5K bytes - Viewed (0) -
cni/pkg/nodeagent/net_test.go
// See the License for the specific language governing permissions and // limitations under the License. package nodeagent import ( "context" "errors" "net/netip" "runtime" "sync/atomic" "testing" "time" "golang.org/x/sys/unix" corev1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/types" "k8s.io/apimachinery/pkg/util/intstr"
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 16.4K bytes - Viewed (0) -
common-protos/k8s.io/api/core/v1/generated.proto
// +listType=atomic // +optional repeated string matchLabelKeys = 8; } // TypedLocalObjectReference contains enough information to let you locate the // typed referenced object inside the same namespace. // +structType=atomic message TypedLocalObjectReference { // APIGroup is the group for the resource being referenced.
Plain Text - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 255.8K bytes - Viewed (0) -
common-protos/k8s.io/api/storage/v1/generated.proto
// most one token is empty string. To receive a new token after expiry, // RequiresRepublish can be used to trigger NodePublishVolume periodically. // // +optional // +listType=atomic repeated TokenRequest tokenRequests = 6; // requiresRepublish indicates the CSI driver wants `NodePublishVolume` // being periodically called to reflect any possible change in the mounted
Plain Text - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 24.7K bytes - Viewed (0) -
cni/pkg/nodeagent/server.go
Stop() } type Server struct { ctx context.Context kubeClient kube.Client handlers K8sHandlers dataplane MeshDataplane isReady *atomic.Value cniServerStopFunc func() } func NewServer(ctx context.Context, ready *atomic.Value, pluginSocket string, args AmbientArgs) (*Server, error) { client, err := buildKubeClient(args.KubeConfig) if err != nil {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 7.2K bytes - Viewed (0) -
cni/pkg/nodeagent/server_test.go
} } } func (wg *WaitGroup) Add(i int32) { select { case <-wg.done: panic("use of an already closed WaitGroup") default: } atomic.AddInt32(&wg.count, i) } func (wg *WaitGroup) Done() { i := atomic.AddInt32(&wg.count, -1) if i == 0 { close(wg.done) } } func (wg *WaitGroup) C() <-chan struct{} { return wg.done
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 7.8K bytes - Viewed (0) -
cni/pkg/nodeagent/healthServer.go
_ = http.ListenAndServe(":"+constants.ReadinessPort, router) }() return } func initRouter(router *http.ServeMux) (installReady *atomic.Value, watchReady *atomic.Value) { installReady = &atomic.Value{} watchReady = &atomic.Value{} installReady.Store(false) watchReady.Store(false) router.HandleFunc(constants.LivenessEndpoint, healthz) router.HandleFunc(constants.ReadinessEndpoint, readyz(installReady, watchReady)) return
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Mon Apr 15 01:29:35 GMT 2024 - 1.8K bytes - Viewed (0) -
cni/pkg/nodeagent/fakes_test.go
return &fakeFileFakeFds{File: f, fd: 0} } type fakeIptablesDeps struct { AddRouteErr error AddInpodMarkIPRuleCnt atomic.Int32 DelInpodMarkIPRuleCnt atomic.Int32 AddLoopbackRoutesCnt atomic.Int32 DelLoopbackRoutesCnt atomic.Int32 } var _ iptables.NetlinkDependencies = &fakeIptablesDeps{} func (r *fakeIptablesDeps) AddInpodMarkIPRule(cfg *iptables.Config) error {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 3.9K bytes - Viewed (0)