- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 476 for npipe (0.15 sec)
-
cmd/kubeadm/app/constants/constants_windows.go
const ( // CRISocketContainerd is the containerd CRI endpoint CRISocketContainerd = "npipe:////./pipe/containerd-containerd" // CRISocketCRIO is the cri-o CRI endpoint // NOTE: this is a placeholder as CRI-O does not support Windows CRISocketCRIO = "npipe:////./pipe/cri-o" // CRISocketDocker is the cri-dockerd CRI endpoint CRISocketDocker = "npipe:////./pipe/cri-dockerd" // DefaultCRISocket defines the default CRI socket
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 12 15:15:45 UTC 2022 - 1.1K bytes - Viewed (0) -
cmd/kubeadm/app/apis/kubeadm/v1beta4/defaults_windows.go
DefaultCACertPath = "C:/etc/kubernetes/pki/ca.crt" // DefaultContainerRuntimeURLScheme defines default socket url prefix DefaultContainerRuntimeURLScheme = "npipe"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 20 11:33:30 UTC 2023 - 879 bytes - Viewed (0) -
cmd/kubeadm/app/util/runtime/runtime_windows.go
func isExistingSocket(path string) bool { u, err := url.Parse(path) if err != nil { // should not happen, since we are trying to access known / hardcoded sockets return false } // the dial path must be without "npipe://" _, err = winio.DialPipe(u.Path, nil) if err != nil { return false } return true
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 12 15:15:45 UTC 2022 - 1K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/util_windows_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 cmd
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 09:45:16 UTC 2023 - 687 bytes - Viewed (0) -
cmd/kubeadm/app/apis/kubeadm/v1beta3/defaults_windows.go
DefaultCACertPath = "C:/etc/kubernetes/pki/ca.crt" // DefaultContainerRuntimeURLScheme defines default socket url prefix DefaultContainerRuntimeURLScheme = "npipe"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 03 19:15:03 UTC 2022 - 879 bytes - Viewed (0) -
pkg/kubelet/util/util_windows.go
limitations under the License. */ package util import ( "fmt" "path/filepath" "strings" "syscall" "time" ) const npipeProtocol = "npipe" // LocalEndpoint returns the full path to a named pipe at the given endpoint - unlike on unix, we can't use sockets. func LocalEndpoint(path, file string) (string, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 08:58:18 UTC 2024 - 3K bytes - Viewed (0) -
pkg/kubelet/util/util_windows_test.go
}{ { path: "/var/lib/kubelet/pod-resources", file: "kube.sock", // this is not the default, but it's not relevant here expectError: false, expectedFullPath: `npipe://\\.\pipe\kubelet-pod-resources`, }, } for _, test := range tests { fullPath, err := LocalEndpoint(test.path, test.file) if test.expectError { assert.NotNil(t, err, "expected error") continue }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 08:58:18 UTC 2024 - 3.1K bytes - Viewed (0) -
cmd/kubelet/app/options/options.go
fs.StringVar(&c.ImageServiceEndpoint, "image-service-endpoint", c.ImageServiceEndpoint, "The endpoint of container image service. If not specified, it will be the same with --container-runtime-endpoint by default. Unix Domain Socket are supported on Linux, while npipe and tcp endpoints are supported on Windows. Examples...
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 07:00:05 UTC 2024 - 41.6K bytes - Viewed (0) -
pkg/kubelet/apis/config/types.go
// +optional LocalStorageCapacityIsolation bool // ContainerRuntimeEndpoint is the endpoint of container runtime. // unix domain sockets supported on Linux while npipes and tcp endpoints are supported for windows. // Examples:'unix:///path/to/runtime.sock', 'npipe:////./pipe/runtime' ContainerRuntimeEndpoint string // ImageServiceEndpoint is the endpoint of container image service.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 05 21:10:42 UTC 2024 - 35.1K bytes - Viewed (0) -
src/io/pipe.go
a.Lock() defer a.Unlock() return a.err } // ErrClosedPipe is the error used for read or write operations on a closed pipe. var ErrClosedPipe = errors.New("io: read/write on closed pipe") // A pipe is the shared pipe structure underlying PipeReader and PipeWriter. type pipe struct { wrMu sync.Mutex // Serializes Write operations wrCh chan []byte rdCh chan int once sync.Once // Protects closing done
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Oct 18 19:34:35 UTC 2023 - 5.1K bytes - Viewed (0)