- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 170 for gofunc (0.16 sec)
-
staging/src/k8s.io/apiserver/pkg/admission/configuration/configuration_manager.go
lock sync.RWMutex } func newPoller(get getFunc) *poller { p := poller{ get: get, interval: defaultInterval, failureThreshold: defaultFailureThreshold, bootstrapRetries: defaultBootstrapRetries, bootstrapGracePeriod: defaultBootstrapGraceperiod, } return &p } func (a *poller) lastError(err error) { a.lock.Lock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Nov 06 02:02:38 UTC 2017 - 4.3K bytes - Viewed (0) -
src/internal/coverage/cformat/fmt_test.go
q.go:20: f2 75.0% total (statements) 62.5%`) gotFuncs := strings.TrimSpace(b4.String()) if wantFuncs != gotFuncs { t.Errorf("emit funcs: got:\n%s\nwant:\n%s\n", gotFuncs, wantFuncs) } if false { t.Logf("text is %s\n", b1.String()) t.Logf("perc is %s\n", b2.String()) t.Logf("perc2 is %s\n", b3.String()) t.Logf("funcs is %s\n", b4.String()) } } func TestEmptyPackages(t *testing.T) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 23 11:36:57 UTC 2023 - 3.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/kmsv2/grpc_service.go
} func recordMetricsInterceptor(providerName string) grpc.UnaryClientInterceptor { return func(ctx context.Context, method string, req, reply interface{}, cc *grpc.ClientConn, invoker grpc.UnaryInvoker, opts ...grpc.CallOption) error { start := NowFunc() respErr := invoker(ctx, method, req, reply, cc, opts...) elapsed := NowFunc().Sub(start)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 23:18:16 UTC 2023 - 4.6K bytes - Viewed (0) -
pkg/registry/certificates/certificates/strategy_test.go
tc := tc t.Run(k, func(t *testing.T) { obj := tc.obj Strategy.PrepareForCreate(tc.ctx, obj) if !reflect.DeepEqual(obj, tc.expectedObj) { t.Errorf("object diff: %s", cmp.Diff(obj, tc.expectedObj)) } }) } } func TestStatusUpdate(t *testing.T) { now := metav1.Now() later := metav1.NewTime(now.Add(time.Hour)) nowFunc = func() metav1.Time { return now } defer func() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 15 14:34:53 UTC 2024 - 7.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/rest/resttest/resttest.go
meta.SetGeneration(1) } type AssignFunc func([]runtime.Object) []runtime.Object type EmitFunc func(runtime.Object, string) error type GetFunc func(context.Context, runtime.Object) (runtime.Object, error) type InitWatchFunc func() type InjectErrFunc func(err error) type IsErrorFunc func(err error) bool type CreateFunc func(context.Context, runtime.Object) error type SetRVFunc func(uint64)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 55.8K bytes - Viewed (0) -
pkg/apis/certificates/fuzzer/fuzzer.go
*/ package fuzzer import ( "time" fuzz "github.com/google/gofuzz" runtimeserializer "k8s.io/apimachinery/pkg/runtime/serializer" "k8s.io/client-go/util/certificate/csr" "k8s.io/kubernetes/pkg/apis/certificates" api "k8s.io/kubernetes/pkg/apis/core" ) // Funcs returns the fuzzer functions for the certificates api group. var Funcs = func(codecs runtimeserializer.CodecFactory) []interface{} { return []interface{}{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 02 03:38:15 UTC 2021 - 1.6K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/intstr/instr_fuzz.go
See the License for the specific language governing permissions and limitations under the License. */ package intstr import ( fuzz "github.com/google/gofuzz" ) // Fuzz satisfies fuzz.Interface func (intstr *IntOrString) Fuzz(c fuzz.Continue) { if intstr == nil { return } if c.RandBool() { intstr.Type = Int c.Fuzz(&intstr.IntVal) intstr.StrVal = "" } else {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 24 19:47:49 UTC 2021 - 1K bytes - Viewed (0) -
pkg/apis/flowcontrol/fuzzer/fuzzer.go
*/ package fuzzer import ( fuzz "github.com/google/gofuzz" runtimeserializer "k8s.io/apimachinery/pkg/runtime/serializer" "k8s.io/kubernetes/pkg/apis/flowcontrol" "k8s.io/utils/ptr" ) // Funcs returns the fuzzer functions for the flowcontrol api group. var Funcs = func(codecs runtimeserializer.CodecFactory) []interface{} { return []interface{}{ func(obj *flowcontrol.LimitedPriorityLevelConfiguration, c fuzz.Continue) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 1.7K bytes - Viewed (0) -
pkg/apis/scheduling/fuzzer/fuzzer.go
*/ package fuzzer import ( "github.com/google/gofuzz" runtimeserializer "k8s.io/apimachinery/pkg/runtime/serializer" "k8s.io/kubernetes/pkg/apis/core" "k8s.io/kubernetes/pkg/apis/scheduling" ) // Funcs returns the fuzzer functions for the scheduling api group. var Funcs = func(codecs runtimeserializer.CodecFactory) []interface{} { return []interface{}{ func(s *scheduling.PriorityClass, c fuzz.Continue) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 08 10:11:23 UTC 2022 - 1.1K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/tests/materialize_passthrough_op.mlir
{Tinputs = ["tfdtype$DT_FLOAT", "tfdtype$DT_FLOAT"], Toutputs = ["tfdtype$DT_FLOAT"], device = "", mlir_module = "\0Afunc.func @main(%arg0 : tensor<10xf32>, %arg1 : tensor<10xf32>) -> tensor<10x10xf32> {\0A %add = \22tf.Add\22(%arg0, %arg1) : (tensor<10xf32>, tensor<10xf32>) -> tensor<10xf32>\0A %ret = \22magic.op\22(%add, %add) : (tensor<10xf32>, tensor<10xf32>) -> tensor<10x10xf32>\0A func.return %ret : tensor<10x10xf32>\0A}\0A", name = "MlirPassthroughOp"} : (tensor<10xf32>, tensor<10xf32>) -> tensor<10x10xf32>...
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Mar 30 10:34:48 UTC 2022 - 1.2K bytes - Viewed (0)