- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for pluginHandlers (0.36 sec)
-
pkg/kubelet/pluginmanager/operationexecutor/operation_executor.go
} func (oe *operationExecutor) RegisterPlugin( socketPath string, timestamp time.Time, pluginHandlers map[string]cache.PluginHandler, actualStateOfWorld ActualStateOfWorldUpdater) error { generatedOperation := oe.operationGenerator.GenerateRegisterPluginFunc(socketPath, timestamp, pluginHandlers, actualStateOfWorld) return oe.pendingOperations.Run( socketPath, generatedOperation) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 04 06:56:50 UTC 2023 - 4.4K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/operationexecutor/operation_generator.go
type OperationGenerator interface { // Generates the RegisterPlugin function needed to perform the registration of a plugin GenerateRegisterPluginFunc( socketPath string, timestamp time.Time, pluginHandlers map[string]cache.PluginHandler, actualStateOfWorldUpdater ActualStateOfWorldUpdater) func() error // Generates the UnregisterPlugin function needed to perform the unregistration of a plugin GenerateUnregisterPluginFunc(
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 14:21:15 UTC 2024 - 7.1K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/reconciler/reconciler.go
stopCh) } func (rc *reconciler) AddHandler(pluginType string, pluginHandler cache.PluginHandler) { rc.Lock() defer rc.Unlock() rc.handlers[pluginType] = pluginHandler } func (rc *reconciler) getHandlers() map[string]cache.PluginHandler { rc.RLock() defer rc.RUnlock() var copyHandlers = make(map[string]cache.PluginHandler) for pluginType, handler := range rc.handlers {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Dec 18 04:27:38 UTC 2022 - 6.2K bytes - Viewed (0) -
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
fakeRecorder, )) reconciler := NewReconciler( oex, reconcilerLoopSleepDuration, dsw, asw, ) reconciler.AddHandler(registerapi.DevicePlugin, cache.PluginHandler(di)) // Start the reconciler to fill ASW. stopChan := make(chan struct{}) defer close(stopChan) go reconciler.Run(stopChan) socketPath := filepath.Join(socketDir, "plugin.sock")
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/cm/devicemanager/plugin/v1beta1/handler.go
api "k8s.io/kubelet/pkg/apis/deviceplugin/v1beta1" v1helper "k8s.io/kubernetes/pkg/apis/core/v1/helper" "k8s.io/kubernetes/pkg/kubelet/pluginmanager/cache" ) func (s *server) GetPluginHandler() cache.PluginHandler { if f, err := os.Create(s.socketDir + "DEPRECATION"); err != nil { klog.ErrorS(err, "Failed to create deprecation file at socket dir", "path", s.socketDir) } else { f.Close()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 14:21:15 UTC 2024 - 3.3K bytes - Viewed (0) -
pkg/kubelet/cm/container_manager_stub.go
} c := v1.ResourceList{ v1.ResourceEphemeralStorage: *resource.NewQuantity( int64(0), resource.BinarySI), } return c } func (cm *containerManagerStub) GetPluginRegistrationHandler() cache.PluginHandler { return nil } func (cm *containerManagerStub) GetDevicePluginResourceCapacity() (v1.ResourceList, v1.ResourceList, []string) { return cm.extendedPluginResources, cm.extendedPluginResources, []string{} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 15 02:26:59 UTC 2023 - 5.9K bytes - Viewed (0) -
pkg/kubelet/cm/fake_container_manager.go
c := v1.ResourceList{ v1.ResourceEphemeralStorage: *resource.NewQuantity( int64(0), resource.BinarySI), } return c } func (cm *FakeContainerManager) GetPluginRegistrationHandler() cache.PluginHandler { cm.Lock() defer cm.Unlock() cm.CalledFunctions = append(cm.CalledFunctions, "GetPluginRegistrationHandler") return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 17:33:04 UTC 2023 - 7.4K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/types.go
// and inactive device plugin resources previously registered on the node. GetCapacity() (v1.ResourceList, v1.ResourceList, []string) GetWatcherHandler() cache.PluginHandler // GetDevices returns information about the devices assigned to pods and containers GetDevices(podUID, containerName string) ResourceDeviceInstances
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 27 13:02:15 UTC 2023 - 5K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/plugin/v1beta1/server.go
"k8s.io/kubernetes/pkg/kubelet/metrics" "k8s.io/kubernetes/pkg/kubelet/pluginmanager/cache" ) // Server interface provides methods for Device plugin registration server. type Server interface { cache.PluginHandler Start() error Stop() error SocketPath() string } type server struct { socketName string socketDir string mutex sync.Mutex wg sync.WaitGroup grpc *grpc.Server
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jan 27 02:10:25 UTC 2024 - 5.4K bytes - Viewed (0)