- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 19 for pluginwatcher (0.35 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/plugin_manager.go
"k8s.io/kubernetes/pkg/kubelet/pluginmanager/cache" "k8s.io/kubernetes/pkg/kubelet/pluginmanager/metrics" "k8s.io/kubernetes/pkg/kubelet/pluginmanager/operationexecutor" "k8s.io/kubernetes/pkg/kubelet/pluginmanager/pluginwatcher" "k8s.io/kubernetes/pkg/kubelet/pluginmanager/reconciler" ) // PluginManager runs a set of asynchronous loops that figure out which plugins // need to be registered/deregistered and makes it so.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 01 05:56:33 UTC 2022 - 4.3K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/pluginwatcher/example_handler.go
limitations under the License. */ package pluginwatcher import ( "context" "errors" "fmt" "net" "reflect" "sync" "time" "google.golang.org/grpc" "google.golang.org/grpc/credentials/insecure" "k8s.io/klog/v2" registerapi "k8s.io/kubelet/pkg/apis/pluginregistration/v1" "k8s.io/kubernetes/pkg/kubelet/pluginmanager/pluginwatcher/example_plugin_apis/v1beta1"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 16 12:00:49 UTC 2023 - 4.6K 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/pluginwatcher/plugin_watcher_others.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 ( "os" "github.com/fsnotify/fsnotify" ) func getStat(event fsnotify.Event) (os.FileInfo, error) { return os.Stat(event.Name) } func getSocketPath(socketPath string) string {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 01 00:26:37 UTC 2023 - 842 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/pluginmanager/pluginwatcher/plugin_watcher_others_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 ( "os" "testing" "github.com/fsnotify/fsnotify" "github.com/stretchr/testify/assert" ) func TestGetStat(t *testing.T) { event := fsnotify.Event{Name: "name", Op: fsnotify.Create}
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_windows_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 ( "os" "testing" "github.com/fsnotify/fsnotify" "github.com/stretchr/testify/assert" ) func TestGetStatWindows(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 01 00:26:37 UTC 2023 - 1.2K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/pluginwatcher/example_plugin_apis/v1beta2/api.proto
See the License for the specific language governing permissions and limitations under the License. */ syntax = "proto3"; package v1beta2; option go_package = "k8s.io/kubernetes/pkg/kubelet/pluginmanager/pluginwatcher/example_plugin_apis/v1beta2"; 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/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)