- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of about 10,000 for gather (0.2 sec)
-
staging/src/k8s.io/apiserver/pkg/registry/generic/matcher.go
http://www.apache.org/licenses/LICENSE-2.0 Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, 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 generic import ( metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 03 06:33:43 UTC 2017 - 1.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/predicates/object/matcher.go
) type ObjectSelectorProvider interface { // GetObjectSelector gets the webhook ObjectSelector field. GetParsedObjectSelector() (labels.Selector, error) } // Matcher decides if a request selected by the ObjectSelector. type Matcher struct { } func matchObject(obj runtime.Object, selector labels.Selector) bool { if obj == nil { return false } accessor, err := meta.Accessor(obj) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 26 00:41:14 UTC 2022 - 1.8K bytes - Viewed (0) -
pilot/pkg/keycertbundle/watcher.go
KeyPem []byte CABundle []byte } type Watcher struct { mutex sync.RWMutex bundle KeyCertBundle watcherID int32 watchers map[int32]chan struct{} } func NewWatcher() *Watcher { return &Watcher{ watchers: make(map[int32]chan struct{}), } } // AddWatcher returns channel to receive the updated items. func (w *Watcher) AddWatcher() (int32, chan struct{}) { ch := make(chan struct{}, 1)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 05 14:00:18 UTC 2023 - 2.6K bytes - Viewed (0) -
misc/chrome/gophertool/gopher.js
Brad Fitzpatrick <******@****.***> 1436570231 -0600
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat Jul 11 14:36:33 UTC 2015 - 1.2K bytes - Viewed (0) -
platforms/core-execution/hashing/src/main/java/org/gradle/internal/hash/Hasher.java
*/ void putInt(int value); /** * Feed a long value byte into the hasher. */ void putLong(long value); /** * Feed a double value into the hasher. */ void putDouble(double value); /** * Feed a boolean value into the hasher. */ void putBoolean(boolean value); /** * Feed a string into the hasher. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Jan 11 11:14:18 UTC 2024 - 2.2K bytes - Viewed (0) -
pkg/kube/inject/watcher.go
// simplifying injector based controllers. type WatcherMulticast struct { handlers []func(*Config, string) error impl Watcher Get func() WebhookConfig } func NewMulticast(impl Watcher, getter func() WebhookConfig) *WatcherMulticast { res := &WatcherMulticast{ impl: impl, Get: getter, } impl.SetHandler(func(c *Config, s string) error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 5.9K bytes - Viewed (0) -
misc/chrome/gophertool/gopher.png
gopher.png...
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 23 21:05:18 UTC 2011 - 5.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/matchconditions/matcher.go
return v.Expression } func (v *MatchCondition) ReturnTypes() []*cel.Type { return []*cel.Type{cel.BoolType} } var _ Matcher = &matcher{} // matcher evaluates compiled cel expressions and determines if they match the given request or not type matcher struct { filter celplugin.Filter failPolicy v1.FailurePolicyType matcherType string matcherKind string objectName string }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 24 14:46:11 UTC 2023 - 5K bytes - Viewed (0) -
pkg/config/mesh/watcher.go
func NewFixedWatcher(mesh *meshconfig.MeshConfig) Watcher { iw := internalWatcher{} iw.MeshConfig.Store(mesh) return &iw } // NewFileWatcher creates a new Watcher for changes to the given mesh config file. Returns an error // if the given file does not exist or failed during parsing. func NewFileWatcher(fileWatcher filewatcher.FileWatcher, filename string, multiWatch bool) (Watcher, error) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Dec 20 18:33:38 UTC 2023 - 7.4K bytes - Viewed (0) -
pkg/util/filesystem/watcher.go
} // Initialize watcher, fall back to no-op var ( eventsCh chan fsnotify.Event errorCh chan error watcher watchAddRemover ) if w, err := fsnotify.NewWatcher(); err != nil { errorHandler(fmt.Errorf("error creating file watcher, falling back to poll at interval %s: %w", pollInterval, err)) watcher = noopWatcher{} } else { watcher = w eventsCh = w.Events errorCh = w.Errors
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 14 23:09:15 UTC 2024 - 5.7K bytes - Viewed (0)