- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 63 for calling (0.83 sec)
-
cmd/bucket-handlers_test.go
package cmd import ( "bytes" "encoding/xml" "fmt" "io" "net/http" "net/http/httptest" "strconv" "testing" "github.com/minio/minio/internal/auth" ) // Wrapper for calling RemoveBucket HTTP handler tests for both Erasure multiple disks and single node setup. func TestRemoveBucketHandler(t *testing.T) { ExecObjectLayerAPITest(t, testRemoveBucketHandler, []string{"RemoveBucket"}) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 39.5K bytes - Viewed (2) -
internal/event/target/kafka_scram_client_contrib.go
// very first conversation step) and attempts to move the authentication // conversation forward. It returns a string to be sent to the server or an // error if the server message is invalid. Calling Step after a conversation // completes is also an error. func (x *XDGSCRAMClient) Step(challenge string) (response string, err error) { response, err = x.ClientConversation.Step(challenge) return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Nov 09 04:04:01 GMT 2023 - 3.2K bytes - Viewed (0) -
cmd/object-api-putobject_test.go
"github.com/minio/minio/internal/hash" "github.com/minio/minio/internal/ioutil" ) func md5Header(data []byte) map[string]string { return map[string]string{"etag": getMD5Hash(data)} } // Wrapper for calling PutObject tests for both Erasure multiple disks and single node setup. func TestObjectAPIPutObjectSingle(t *testing.T) { ExecExtendedObjectLayerTest(t, testObjectAPIPutObject) } // Tests validate correctness of PutObject.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 25.8K bytes - Viewed (0) -
internal/bucket/replication/filter.go
// Filter - a filter for a replication configuration Rule. type Filter struct { XMLName xml.Name `xml:"Filter" json:"Filter"` Prefix string And And Tag Tag // Caching tags, only once cachedTags map[string]string } // IsEmpty returns true if filter is not set func (f Filter) IsEmpty() bool { return f.And.isEmpty() && f.Tag.IsEmpty() && f.Prefix == "" }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Sep 28 18:25:46 GMT 2022 - 3.5K bytes - Viewed (2) -
internal/s3select/sql/jsondata/books.json
Json - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 1.9K bytes - Viewed (0) -
internal/http/dial_dnscache.go
// DialContextWithLookupHost is a helper function which returns `net.DialContext` function. // It randomly fetches an IP via custom LookupHost function and dials it by the given dial // function. LookupHost may implement an internal DNS caching implementation, lookupHost // input if nil then net.DefaultResolver.LookupHost is used. // // It dials one by one and returns first connected `net.Conn`.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Jul 03 19:30:51 GMT 2023 - 2.6K bytes - Viewed (0) -
cmd/xl-storage.go
// errors on a previous write(2) operation are reported only on the final close() that releases // the open file descriptor. // // Failing to check the return value when closing a file may lead to silent loss of data. // This can especially be observed with NFS and with disk quota. return w.Close() }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 84.7K bytes - Viewed (0) -
internal/bucket/lifecycle/filter.go
ObjectSizeGreaterThan int64 `xml:"ObjectSizeGreaterThan,omitempty"` ObjectSizeLessThan int64 `xml:"ObjectSizeLessThan,omitempty"` And And andSet bool Tag Tag tagSet bool // Caching tags, only once cachedTags map[string]string } // MarshalXML - produces the xml representation of the Filter struct // only one of Prefix, And and Tag should be present in the output.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 27 00:01:20 GMT 2024 - 6.2K bytes - Viewed (0) -
internal/config/cache/cache.go
Value: "", }, } // Config represents the subnet related configuration type Config struct { // Flag indicating whether cache is enabled. Enable bool `json:"enable"` // Endpoint for caching uses remote mcache server to // store and retrieve pre-condition check entities such as // Etag and ModTime of an object + version Endpoint string `json:"endpoint"`
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.6K bytes - Viewed (0) -
docs/sts/ldap.go
if err != nil { log.Fatalf("Error initializing client: ", err) } // Use minIO Client object normally like the regular client. if bucketToList == "" { bucketToList = ldapUsername } 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: Mon Sep 19 18:05:16 GMT 2022 - 4K bytes - Viewed (0)