- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 23 for calling (0.18 sec)
-
cni/pkg/nodeagent/net.go
err = addPodToHostNSIpset(pod, podIPs, &s.hostsideProbeIPSet) if err != nil { log.Errorf("failed to add pod to ipset: %s/%s %v", pod.Namespace, pod.Name, err) return err } log.Debug("calling CreateInpodRules") if err := s.netnsRunner(openNetns, func() error { return s.iptablesConfigurator.CreateInpodRules(&HostProbeSNATIP) }); err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.2K bytes - Viewed (1) -
docs/sts/assume-role.go
if err != nil { log.Fatalf("Error initializing client: %v", err) } // Use minIO Client object normally like the regular client. if bucketToList == "" { bucketToList = minioUsername } fmt.Printf("Calling list objects on bucket named `%s` with temp creds:\n===\n", bucketToList) objCh := minioClient.ListObjects(context.Background(), bucketToList, minio.ListObjectsOptions{}) for obj := range objCh { if obj.Err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 12 16:09:55 GMT 2024 - 4K bytes - Viewed (1) -
cmd/object-api-listobjects_test.go
} } } } }) } } // Wrapper for calling ListObjectsOnVersionedBuckets tests for both // Erasure multiple disks and single node setup. func TestListObjectsOnVersionedBuckets(t *testing.T) { ExecObjectLayerTest(t, testListObjectsOnVersionedBuckets) } // Wrapper for calling ListObjects tests for both Erasure multiple // disks and single node setup.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 11:07:40 GMT 2024 - 73.1K bytes - Viewed (0) -
cmd/post-policy_test.go
if parts[i].Name == objectName+"/upload.txt" { t.Errorf("Test %s: Failed to stop post policy handler from writing to minioMetaBucket", instanceType) } } } } // Wrapper for calling TestPostPolicyBucketHandler tests for both Erasure multiple disks and single node setup. func TestPostPolicyBucketHandler(t *testing.T) { ExecObjectLayerTest(t, testPostPolicyBucketHandler) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:45:54 GMT 2024 - 29.6K bytes - Viewed (0) -
internal/rest/client.go
_ int32 // For 64 bits alignment lastConn int64 // HealthCheckFn is the function set to test for health. // If not set the client will not keep track of health. // Calling this returns true or false if the target // is online or offline. HealthCheckFn func() bool // HealthCheckRetryUnit will be used to calculate the exponential // backoff when trying to reconnect to an offline node
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 14.4K bytes - Viewed (0) -
cni/pkg/nodeagent/net_test.go
assert.NoError(t, err) fakeIPSetDeps.AssertExpectations(t) } // for tests that call `runtime.GC()` - we have no control over when the GC is actually scheduled, // and it is flake-prone to check for closure after calling it, this retries for a bit to make // sure the netns is closed eventually. func assertNSClosed(t *testing.T, closed *atomic.Bool) { for i := 0; i < 5; i++ { if closed.Load() { return }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 16.4K bytes - Viewed (0) -
internal/grid/handlers.go
func (h *SingleHandler[Req, Resp]) AllowCallRequestPool(b bool) *SingleHandler[Req, Resp] { h.callReuseReq = b return h } // IgnoreNilConn will ignore nil connections when calling. // This will make Call return nil instead of ErrDisconnected when the connection is nil. // This may only be set ONCE before use. func (h *SingleHandler[Req, Resp]) IgnoreNilConn() *SingleHandler[Req, Resp] {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 27.1K bytes - Viewed (0) -
cmd/sts-handlers_test.go
Options: cr.STSAssumeRoleOptions{ AccessKey: accessKey, SecretKey: secretKey, Location: "", }, } value, err := assumeRole.Retrieve() if err != nil { c.Fatalf("err calling assumeRole: %v", err) } minioClient, err := minio.New(s.endpoint, &minio.Options{ Creds: cr.NewStaticV4(value.AccessKeyID, value.SecretAccessKey, value.SessionToken), Secure: s.secure,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 15:50:16 GMT 2024 - 85.7K bytes - Viewed (0) -
src/builtin/builtin.go
// that point, the program is terminated with a non-zero exit code. This // termination sequence is called panicking and can be controlled by the // built-in function recover. // // Starting in Go 1.21, calling panic with a nil interface value or an // untyped nil causes a run-time error (a different panic). // The GODEBUG setting panicnil=1 disables the run-time error. func panic(v any)
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Thu Apr 11 20:22:45 GMT 2024 - 12.7K bytes - Viewed (0) -
cmd/storage-rest-server.go
copy(tmp, b) h.block <- tmp return len(b), h.err } // CloseWithError will close the stream and return the specified error. // This can be done several times, but only the first error will be sent. // After calling this the stream should not be written to. func (h *httpStreamResponse) CloseWithError(err error) { if h.done == nil { return } h.done <- err h.err = err // Indicates that the response is done.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 44.8K bytes - Viewed (0)