- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 28 for tabling (0.2 sec)
-
istioctl/pkg/clioptions/central.go
InsecureSkipVerify bool // XDSSAN is the expected Subject Alternative Name of the XDS server XDSSAN string // Plaintext forces plain text communication (for talking to port 15010) Plaintext bool // GCP project number or ID to use for XDS calls, if any. GCPProject string // Istiod address. For MCP may be different than Xds. IstiodAddr string }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Jun 06 03:39:27 GMT 2022 - 3.2K bytes - Viewed (0) -
internal/cachevalue/cache.go
// The returned value can no longer be modified once returned. // Should be set before calling Get(). updateFn func() (T, error) // ttl for a cached value. ttl time.Duration opts Opts // Once can be used to initialize values for lazy initialization. // Should be set before calling Get(). Once sync.Once // Managed values. valErr atomic.Pointer[struct { v T e error }]
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 01 16:00:42 GMT 2024 - 4.2K bytes - Viewed (0) -
internal/config/certs.go
// Read certificate file. var data []byte if data, err = os.ReadFile(certFile); err != nil { return nil, err } // Trimming leading and tailing white spaces. data = bytes.TrimSpace(data) // Parse all certs in the chain. current := data for len(current) > 0 { var pemBlock *pem.Block if pemBlock, current = pem.Decode(current); pemBlock == nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 3.8K bytes - Viewed (0) -
internal/bucket/lifecycle/error.go
// parsing. type Error struct { err error } // Errorf - formats according to a format specifier and returns // the string as a value that satisfies error of type tagging.Error func Errorf(format string, a ...interface{}) error { return Error{err: fmt.Errorf(format, a...)} } // Unwrap the internal error. func (e Error) Unwrap() error { return e.err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 1.3K bytes - Viewed (0) -
internal/lsync/lrwmutex.go
} // NewLRWMutex - initializes a new lsync RW mutex. func NewLRWMutex() *LRWMutex { return &LRWMutex{} } // Lock holds a write lock on lm. // // If the lock is already in use, the calling go routine // blocks until the mutex is available. func (lm *LRWMutex) Lock() { const isWriteLock = true lm.lockLoop(context.Background(), lm.id, lm.source, math.MaxInt64, isWriteLock) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 4.8K bytes - Viewed (0) -
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/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)