var v3_4_31 … var v3_5_0 … var v3_5_13 … var DefaultFeatureSupportChecker … type FeatureSupportChecker … type defaultFeatureSupportChecker … func newDefaultFeatureSupportChecker() *defaultFeatureSupportChecker { … } // Supports can check the featue from anywhere without storage if it was cached before. func (f *defaultFeatureSupportChecker) Supports(feature storage.Feature) bool { … } // CheckClient accepts client and calculate the support per endpoint and caches it. func (f *defaultFeatureSupportChecker) CheckClient(ctx context.Context, c client, feature storage.Feature) { … } func (f *defaultFeatureSupportChecker) checkClient(ctx context.Context, c client) { … } func (f *defaultFeatureSupportChecker) clientSupportsRequestWatchProgress(ctx context.Context, c client, ep string) error { … } type client … // endpointSupportsRequestWatchProgress evaluates whether RequestWatchProgress supported by current version of etcd endpoint. // Based on this issues: // - https://github.com/etcd-io/etcd/issues/15220 - Fixed in etcd v3.4.25+ and v3.5.8+ // - https://github.com/etcd-io/etcd/issues/17507 - Fixed in etcd v3.4.31+ and v3.5.13+ func endpointSupportsRequestWatchProgress(ctx context.Context, c client, endpoint string) (bool, error) { … }
Codebase Browser
kubernetes