- Sort Score
- Result 10 results
- Languages All
Results 11 - 16 of 16 for pluginwatcher (1.93 sec)
-
pkg/kubelet/pluginmanager/pluginwatcher/example_plugin_apis/v1beta1/api.proto
See the License for the specific language governing permissions and limitations under the License. */ syntax = "proto3"; package v1beta1; option go_package = "k8s.io/kubernetes/pkg/kubelet/pluginmanager/pluginwatcher/example_plugin_apis/v1beta1"; import "github.com/gogo/protobuf/gogoproto/gogo.proto"; option (gogoproto.goproto_stringer_all) = false; option (gogoproto.stringer_all) = true;
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 23 17:31:18 UTC 2023 - 1.4K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/pluginwatcher/plugin_watcher_windows.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 pluginwatcher import ( "github.com/fsnotify/fsnotify" "k8s.io/kubernetes/pkg/kubelet/util" "os" ) func getStat(event fsnotify.Event) (os.FileInfo, error) { fi, err := os.Stat(event.Name)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 01 00:26:37 UTC 2023 - 1.1K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/pluginwatcher/plugin_watcher.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 pluginwatcher import ( "fmt" "os" "strings" "github.com/fsnotify/fsnotify" "k8s.io/klog/v2" "k8s.io/kubernetes/pkg/kubelet/pluginmanager/cache" "k8s.io/kubernetes/pkg/kubelet/util"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 01 00:26:37 UTC 2023 - 6.1K bytes - Viewed (0) -
pkg/kubelet/cm/dra/plugin/plugin.go
return nil, errors.New("timed out waiting for gRPC connection to be ready") } p.conn = conn return p.conn, nil } // RegistrationHandler is the handler which is fed to the pluginwatcher API. type RegistrationHandler struct { controller *nodeResourcesController } // NewPluginHandler returns new registration handler. // // Must only be called once per process because it manages global state.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 19 16:27:05 UTC 2024 - 6.2K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/pluginwatcher/plugin_watcher_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 pluginwatcher import ( "flag" "fmt" "os" "path/filepath" "sync" "testing" "time" "github.com/stretchr/testify/require" "k8s.io/apimachinery/pkg/util/wait" "k8s.io/klog/v2"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 04 06:56:50 UTC 2023 - 8K bytes - Viewed (0) -
pkg/kubelet/cm/container_manager.go
// GetPodCgroupRoot returns the cgroup which contains all pods. GetPodCgroupRoot() string // GetPluginRegistrationHandler returns a plugin registration handler // The pluginwatcher's Handlers allow to have a single module for handling // registration. GetPluginRegistrationHandler() cache.PluginHandler
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:13 UTC 2024 - 9K bytes - Viewed (0)