- Sort Score
- Result 10 results
- Languages All
Results 151 - 160 of 1,731 for Dlog (0.08 sec)
-
pkg/proxy/node_test.go
package proxy import ( "strconv" "testing" v1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/klog/v2" ) func TestNodePodCIDRHandlerAdd(t *testing.T) { oldKlogOsExit := klog.OsExit defer func() { klog.OsExit = oldKlogOsExit }() klog.OsExit = customExit tests := []struct { name string oldNodePodCIDRs []string newNodePodCIDRs []string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Sep 10 16:50:29 UTC 2023 - 3.5K bytes - Viewed (0) -
pkg/controller/ttlafterfinished/ttlafterfinished_controller.go
} <-ctx.Done() } func (tc *Controller) addJob(logger klog.Logger, obj interface{}) { job := obj.(*batch.Job) logger.V(4).Info("Adding job", "job", klog.KObj(job)) if job.DeletionTimestamp == nil && needsCleanup(job) { tc.enqueue(logger, job) } } func (tc *Controller) updateJob(logger klog.Logger, old, cur interface{}) { job := cur.(*batch.Job)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 07 23:59:28 UTC 2024 - 10.4K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/state/state_mem.go
*/ package state import ( "sync" "k8s.io/klog/v2" ) type stateMemory struct { sync.RWMutex assignments ContainerMemoryAssignments machineState NUMANodeMap } var _ State = &stateMemory{} // NewMemoryState creates new State for keeping track of cpu/pod assignment func NewMemoryState() State { klog.InfoS("Initializing new in-memory state store") return &stateMemory{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 15 19:51:19 UTC 2021 - 3.2K bytes - Viewed (0) -
cmd/kubelet/app/server_linux.go
klog.ErrorS(err, "Unable to watch lockfile") watcher.Close() return err } go func() { select { case ev := <-watcher.Event: klog.InfoS("Inotify event", "event", ev) case err = <-watcher.Error: klog.ErrorS(err, "inotify watcher error") } close(done) watcher.Close() }() return nil } func isCgroup2UnifiedMode() bool {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 26 09:04:06 UTC 2022 - 1.4K bytes - Viewed (0) -
src/main/assemblies/extension/kibana/README.md
1. Click **Create index pattern** button 1. Input "fess\_log\*" to the textbox of **index pattern**. 1. Click **Next step**. 1. Set "requestedAt" to the **Time Filter field name**. 1. Click **Create index pattern**. 1. Click **Saved Objects**. 1. Click **Import** and select "fess\_log.ndjson" to import example settings. 1. Click **Dashboard**. 1. Select "fess\_log" dashboard. 1. (Change the period from upper right if you want to do.)
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Mon Aug 12 01:26:21 UTC 2019 - 1.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/routine_test.go
"net/http/httptest" "strings" "testing" "k8s.io/apimachinery/pkg/util/sets" "k8s.io/apiserver/pkg/endpoints/request" "k8s.io/klog/v2" ) func TestPropogatingPanic(t *testing.T) { var buf bytes.Buffer klog.SetOutput(&buf) klog.LogToStderr(false) defer klog.LogToStderr(true) panicMsg := "panic as designed" handler := http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { panic(panicMsg)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 16 10:22:16 UTC 2024 - 2.2K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/pv_controller_base.go
logger.V(3).Info("Could not sync claim", "PVC", klog.KObj(claim), "err", err) } else { logger.Error(err, "Could not sync volume", "PVC", klog.KObj(claim)) } } } // Unit test [5-5] [5-6] [5-7] // deleteClaim runs in worker thread and handles "claim deleted" event. func (ctrl *PersistentVolumeController) deleteClaim(ctx context.Context, claim *v1.PersistentVolumeClaim) { logger := klog.FromContext(ctx)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 29.5K bytes - Viewed (0) -
pkg/controller/ttl/ttl_controller.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.5K bytes - Viewed (0) -
cmd/import-boss/main.go
"github.com/spf13/pflag" "golang.org/x/tools/go/packages" "k8s.io/klog/v2" "sigs.k8s.io/yaml" ) const ( rulesFileName = ".import-restrictions" goModFile = "go.mod" ) func main() { klog.InitFlags(nil) pflag.CommandLine.AddGoFlagSet(flag.CommandLine) pflag.Parse() pkgs, err := loadPkgs(pflag.Args()...) if err != nil { klog.Errorf("failed to load packages: %v", err) } pkgs = massage(pkgs)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 16 12:36:49 UTC 2024 - 14.7K bytes - Viewed (0) -
pkg/volume/iscsi/iscsi_util.go
if err != nil { klog.Warningf("Warning: Failed to flush multipath device map: %s\nError: %v", mpathDevice, err) // Fall through -- keep deleting the block devices } klog.V(4).Infof("Flushed multipath device: %s", mpathDevice) } for _, deviceName := range deviceNames { err = deleteDevice(deviceName) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 22 12:53:01 UTC 2022 - 34.1K bytes - Viewed (0)