- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for shend (0.19 sec)
-
cni/cmd/istio-cni/main.go
if err := runPlugin(); err != nil { os.Exit(1) } } func runPlugin() error { if err := log.Configure(plugin.GetLoggingOptions("")); err != nil { 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
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 30 13:56:46 GMT 2024 - 1.9K bytes - Viewed (0) -
cni/pkg/config/config.go
CNIBinSourceDir string // Directories into which to copy the CNI binaries CNIBinTargetDirs []string // The HTTP port for monitoring MonitoringPort int // The UDS server address that CNI plugin will send log to. LogUDSAddress string // The watch server socket address that CNI plugin will forward CNI events to. CNIEventAddress string // The ztunnel server socket address that the ztunnel will connect to.
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/README.md
Plain Text - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.3K bytes - Viewed (0) -
cmd/storage-rest-server.go
out <- resp } }() ui, err := s.getStorage().NSScanner(ctx, *params.Cache, updates, madmin.HealScanMode(params.ScanMode), nil) wg.Wait() if err != nil { return grid.NewRemoteErr(err) } // Send final response. resp := storageNSScannerRPC.NewResponse() resp.Final = &ui out <- resp return nil } // MakeVolHandler - make a volume.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 44.8K bytes - Viewed (0) -
cmd/storage-rest-client.go
if errors.Is(err, io.EOF) { err = nil } break } stat = append(stat, st) } return stat, toStorageErr(err) } // ReadMultiple will read multiple files and send each back as response. // Files are read and returned in the given order. // The resp channel is closed before the call returns. // Only a canceled context or network errors returns an error.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 26.1K bytes - Viewed (0) -
cni/pkg/iptables/iptables.go
"--ctmask", fmt.Sprintf("0x%x", InpodRestoreMask), ) // CLI: -A ISTIO_OUTPUT ! -o lo -p udp -m udp --dport 53 -j REDIRECT --to-port 15053 // // DESC: If this is a UDP DNS request to a non-localhost resolver, send it to ztunnel DNS proxy port if redirectDNS { iptablesBuilder.AppendRule( iptableslog.UndefinedCommand, ChainInpodOutput, iptablesconstants.NAT, "!", "-o", "lo", "-p", "udp", "-m", "udp",
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 19.6K bytes - Viewed (0) -
cmd/erasure-multipart.go
// However, in case of encryption, the persisted part ETags don't match // what we have sent to the client during PutObjectPart. The reason is // that ETags are encrypted. Hence, the client will send a list of complete // part ETags of which non can match the ETag of any part. For example // ETag (client): 30902184f4e62dd8f98f0aaff810c626
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 43K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
if err != nil { return nil, err } defer done(&err) return p.storage.StatInfoFile(ctx, volume, path, glob) } // ReadMultiple will read multiple files and send each files as response. // Files are read and returned in the given order. // The resp channel is closed before the call returns. // Only a canceled context will return an error.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0) -
cmd/erasure-object.go
// the content implicitly for all versions, we can // avoid triggering another MRF heal for offline drives. if len(versions) == 0 { // Whether a disk was initially or becomes offline // during this upload, send it to the MRF list. for i := 0; i < len(onlineDisks); i++ { if onlineDisks[i] != nil && onlineDisks[i].IsOnline() { continue } er.addPartial(bucket, object, fi.VersionID) break
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 76.9K bytes - Viewed (2) -
cmd/xl-storage.go
logger.GetReqInfo(ctx).AppendTags("disk", s.String()) storageLogOnceIf(ctx, err, partPath) } return err } } return nil } // ReadMultiple will read multiple files and send each back as response. // Files are read and returned in the given order. // The resp channel is closed before the call returns. // Only a canceled context will return an error.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 84.7K bytes - Viewed (0)