- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 90 for tabling (0.17 sec)
-
cmd/object-api-deleteobject_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" "crypto/md5" "encoding/hex" "strings" "testing" ) // Wrapper for calling DeleteObject tests for both Erasure multiple disks and single node setup. func TestDeleteObject(t *testing.T) { ExecObjectLayerTest(t, testDeleteObject) } // Unit test for DeleteObject in general.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Dec 23 15:46:00 GMT 2022 - 3.9K bytes - Viewed (0) -
cmd/object_api_suite_test.go
data []byte } func (r *testOneByteReadNoEOF) Read(p []byte) (n int, err error) { if r.eof { return 0, io.EOF } n = copy(p, r.data) r.eof = true return n, nil } // Wrapper for calling testMakeBucket for both Erasure and FS. func TestMakeBucket(t *testing.T) { ExecObjectLayerTest(t, testMakeBucket) } // Tests validate bucket creation.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 32.3K bytes - Viewed (0) -
cmd/tier-journal.go
jd.file = nil // reset to allow subsequent reopen when file/disk is available. } return err } // Close closes the active journal and renames it to read-only for pending // deletes processing. Note: calling Close on a closed journal is a no-op. func (jd *tierDiskJournal) Close() error { jd.Lock() defer jd.Unlock() if jd.file == nil { // already closed return nil } var ( f *os.File
Go - Registered: Sun Feb 25 19:28:16 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 7.4K bytes - Viewed (0) -
internal/logger/target/kafka/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.3K bytes - Viewed (1) -
buildscripts/gen-ldflags.go
ldflagsStr += " -X github.com/minio/minio/cmd.GOROOT=" + os.Getenv("GOROOT") return ldflagsStr } // genReleaseTag prints release tag to the console for easy git tagging. func releaseTag(version string) (string, time.Time) { relPrefix := "DEVELOPMENT" if prefix := os.Getenv("MINIO_RELEASE"); prefix != "" { relPrefix = prefix } relSuffix := ""
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jun 16 23:10:48 GMT 2022 - 3.3K bytes - Viewed (0) -
docs/sts/custom-token-identity.go
} minioClient, err := minio.New(stsEndpointURL.Host, copts) if err != nil { log.Fatalf("Error initializing client: ", err) } // Use minIO Client object normally like the regular client. 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 May 27 00:58:09 GMT 2022 - 3.4K bytes - Viewed (0) -
cmd/metrics-v2.go
proxiedHeadRequestsTotal MetricName = "proxied_head_requests_total" proxiedPutTaggingRequestsTotal MetricName = "proxied_put_tagging_requests_total" proxiedGetTaggingRequestsTotal MetricName = "proxied_get_tagging_requests_total" proxiedDeleteTaggingRequestsTotal MetricName = "proxied_delete_tagging_requests_total" proxiedGetRequestsFailures MetricName = "proxied_get_requests_failures"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 22:01:31 GMT 2024 - 132.6K bytes - Viewed (0) -
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-handlers.go
// ObjectTagSet key value tags type ObjectTagSet struct { Tags []tags.Tag `xml:"Tag"` } type objectTagging struct { XMLName xml.Name `xml:"Tagging"` TagSet *ObjectTagSet `xml:"TagSet"` } // GetObjectTaggingHandler - GET object tagging func (api objectAPIHandlers) GetObjectTaggingHandler(w http.ResponseWriter, r *http.Request) { ctx := newContext(r, w, "GetObjectTagging")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 20:15:54 GMT 2024 - 125.2K bytes - Viewed (0) -
cmd/object-api-getobjectinfo_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "bytes" "context" "testing" ) // Wrapper for calling GetObjectInfo tests for both Erasure multiple disks and single node setup. func TestGetObjectInfo(t *testing.T) { ExecObjectLayerTest(t, testGetObjectInfo) } // Testing GetObjectInfo().
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Dec 23 15:46:00 GMT 2022 - 5.6K bytes - Viewed (0)