- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for pluginwatcher (0.54 sec)
-
pkg/kubelet/pluginmanager/cache/types.go
See the License for the specific language governing permissions and limitations under the License. */ package cache import "time" // PluginHandler is an interface a client of the pluginwatcher API needs to implement in // order to consume plugins // The PluginHandler follows the simple following state machine: // // +--------------------------------------+
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 14:21:15 UTC 2024 - 3.1K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/reconciler/reconciler_test.go
registerapi "k8s.io/kubelet/pkg/apis/pluginregistration/v1" "k8s.io/kubernetes/pkg/kubelet/pluginmanager/cache" "k8s.io/kubernetes/pkg/kubelet/pluginmanager/operationexecutor" "k8s.io/kubernetes/pkg/kubelet/pluginmanager/pluginwatcher" ) const ( // reconcilerLoopSleepDuration is the amount of time the reconciler loop // waits between successive executions reconcilerLoopSleepDuration time.Duration = 1 * time.Nanosecond ) var (
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 14:21:15 UTC 2024 - 10.5K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/plugin_manager_test.go
"k8s.io/apimachinery/pkg/util/wait" "k8s.io/client-go/tools/record" registerapi "k8s.io/kubelet/pkg/apis/pluginregistration/v1" "k8s.io/kubernetes/pkg/kubelet/config" "k8s.io/kubernetes/pkg/kubelet/pluginmanager/pluginwatcher" ) var ( socketDir string supportedVersions = []string{"v1beta1", "v1beta2"} ) type fakePluginHandler struct { events []string sync.RWMutex }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 4.4K 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/volume/csi/csi_plugin.go
p := &csiPlugin{ host: nil, } return []volume.VolumePlugin{p} } // volume.VolumePlugin methods var _ volume.VolumePlugin = &csiPlugin{} // RegistrationHandler is the handler which is fed to the pluginwatcher API. type RegistrationHandler struct { } // TODO (verult) consider using a struct instead of global variables // csiDrivers map keep track of all registered CSI drivers on the node and their // corresponding sockets
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 29.2K bytes - Viewed (0) -
pkg/kubelet/kubelet_getters.go
} // getPluginsRegistrationDir returns the full path to the directory under which // plugins socket should be placed to be registered. // More information is available about plugin registration in the pluginwatcher // module func (kl *Kubelet) getPluginsRegistrationDir() string { return filepath.Join(kl.getRootDir(), config.DefaultKubeletPluginsRegistrationDirName) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 09 00:48:07 UTC 2024 - 17.9K bytes - Viewed (0) -
hack/update-codegen.sh
"staging/src/k8s.io/kubelet/pkg/apis/dra" "staging/src/k8s.io/kubelet/pkg/apis/pluginregistration" "pkg/kubelet/pluginmanager/pluginwatcher/example_plugin_apis" ) kube::log::status "Generating protobuf bindings for ${#apis[@]} targets" if [[ "${DBG_CODEGEN}" == 1 ]]; then kube::log::status "DBG: generating protobuf bindings for:"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 15:15:31 UTC 2024 - 29.2K 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)