- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for Post (0.32 sec)
-
internal/event/name_test.go
{ObjectCreatedAll, "s3:ObjectCreated:*"}, {ObjectCreatedCompleteMultipartUpload, "s3:ObjectCreated:CompleteMultipartUpload"}, {ObjectCreatedCopy, "s3:ObjectCreated:Copy"}, {ObjectCreatedPost, "s3:ObjectCreated:Post"}, {ObjectCreatedPut, "s3:ObjectCreated:Put"}, {ObjectRemovedAll, "s3:ObjectRemoved:*"}, {ObjectRemovedDelete, "s3:ObjectRemoved:Delete"}, {ObjectRemovedDeleteAllVersions, "s3:ObjectRemoved:DeleteAllVersions"},
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:11:10 GMT 2024 - 7.4K bytes - Viewed (0) -
cni/pkg/nodeagent/server.go
} // Create hostprobe rules now, in the host netns // Later we will reuse this same configurator inside the pod netns for adding other rules iptablesConfigurator.DeleteHostRules() if err := iptablesConfigurator.CreateHostRulesForHealthChecks(&HostProbeSNATIP, &HostProbeSNATIPV6); err != nil { return nil, fmt.Errorf("error initializing the host rules for health checks: %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) -
cmd/consolelogger.go
func (sys *HTTPConsoleLoggerSys) SetNodeName(nodeName string) { if !globalIsDistErasure { sys.nodeName = "" return } host, err := xnet.ParseHost(globalLocalNodeName) if err != nil { logger.FatalIf(err, "Unable to start console logging subsystem") } sys.nodeName = host.Name } // HasLogListeners returns true if console log listeners are registered // for this node or peers
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 5.5K bytes - Viewed (0) -
cmd/warm-backend-minio.go
opts := &minio.Options{ Creds: creds, Secure: u.Scheme == "https", Transport: globalRemoteTargetTransport, TrailingHeaders: true, } client, err := minio.New(u.Host, opts) if err != nil { return nil, err } client.SetAppInfo(fmt.Sprintf("minio-tier-%s", tier), ReleaseTag) core := &minio.Core{Client: client} return &warmBackendMinIO{ warmBackendS3{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 3.8K bytes - Viewed (0) -
internal/logger/target/console/console.go
requestID = "\nRequestID: " + entry.RequestID } var remoteHost string if entry.RemoteHost != "" { remoteHost = "\nRemoteHost: " + entry.RemoteHost } var host string if entry.Host != "" { host = "\nHost: " + entry.Host } var userAgent string if entry.UserAgent != "" { userAgent = "\nUserAgent: " + entry.UserAgent } if len(entry.Trace.Variables) > 0 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 3.9K bytes - Viewed (0) -
cni/pkg/nodeagent/options.go
HostProbeSNATIPV6 = netip.MustParseAddr(env.RegisterStringVar("HOST_PROBE_SNAT_IPV6", DefaultHostProbeSNATIPV6, "").Get()) ) const ( // to reliably identify kubelet healthprobes from inside the pod (versus standard kube-proxy traffic, // since the IP is normally the same), we SNAT identified host probes in the host netns to a fixed // APIPA/"link-local" IP.
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 2K bytes - Viewed (0) -
cni/pkg/nodeagent/cni-watcher_test.go
}, Status: corev1.PodStatus{ PodIP: fakePodIP, }, } ns := &corev1.Namespace{ObjectMeta: metav1.ObjectMeta{Name: "funkyns"}} client := kube.NewFakeClient(ns, pod) // We are expecting at most 1 calls to the mock, wait for them wg, waitForMockCalls := NewWaitForNCalls(t, 1) fs := &fakeServer{testWG: wg} fs.On("AddPodToMesh", ctx, pod, util.GetPodIPsIfPresent(pod), valid.Netns,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu May 02 21:29:40 GMT 2024 - 5.4K bytes - Viewed (0) -
cni/pkg/constants/constants.go
// Exposed for testing constants var ( CNIBinDir = "/opt/cni/bin" HostCNIBinDir = "/host/opt/cni/bin" ServiceAccountPath = "/var/run/secrets/kubernetes.io/serviceaccount" // Well-known subpath we will mount any needed host-mounts under, // to preclude shadowing or breaking any pod-internal mounts HostMountsPath = "/host"
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 2.7K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/endpoint.go
"istio.io/istio/pilot/pkg/networking/util" ) type EndpointFilter struct { Address string Port uint32 Cluster string Status string } // Verify returns true if the passed host matches the filter fields func (e *EndpointFilter) Verify(ep *endpoint.LbEndpoint, cluster string) bool { if e.Address == "" && e.Port == 0 && e.Cluster == "" && e.Status == "" { return true }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sun Apr 21 17:42:54 GMT 2024 - 5.6K bytes - Viewed (0) -
cni/pkg/config/config.go
type Config struct { InstallConfig InstallConfig RepairConfig RepairConfig } // InstallConfig struct defines the Istio CNI installation options type InstallConfig struct { // Location of the CNI config files in the host's filesystem CNINetDir string // Location of the CNI config files in the container's filesystem (mount location of the CNINetDir) MountedCNINetDir string // Name of the CNI config file CNIConfName string
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 5.5K bytes - Viewed (0)