- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 88 for kind (0.17 sec)
-
internal/http/check_port_test.go
port := l.Addr().(*net.TCPAddr).Port testCases := []struct { host string port int expectedErr error }{ {"", port, fmt.Errorf("listen tcp :%v: bind: address already in use", port)}, {"127.0.0.1", port, fmt.Errorf("listen tcp 127.0.0.1:%v: bind: address already in use", port)}, } for _, testCase := range testCases { err := CheckPortAvailability(testCase.host, strconv.Itoa(testCase.port), TCPOptions{}) switch {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 03 21:12:25 GMT 2023 - 1.9K bytes - Viewed (0) -
internal/bucket/replication/filter.go
// This filter has tags configured but this object // does not have any tag, skip this object if len(tagsMap) == 0 { return false } // Both filter and object have tags, find a match, // skip this object otherwise for k, cv := range f.cachedTags { v, ok := tagsMap[k] if ok && v == cv { return true } } return false
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) -
cmd/data-usage.go
ctx, done := context.WithTimeout(context.Background(), 2*time.Second) ok := cache.load(ctx, er, bucket+slashSeparator+dataUsageCacheName) == nil done() if ok { root := cache.find(bucket) if root == nil { // We dont have usage information for this bucket in this // set, go to the next set continue }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 5.6K bytes - Viewed (0) -
cmd/streaming-signature-v4.go
} input := bufio.NewScanner(bytes.NewReader(valueBuffer.Bytes())) for input.Scan() { line := strings.TrimSpace(input.Text()) if line == "" { continue } // Find first separator. idx := strings.IndexByte(line, trailerKVSeparator[0]) if idx <= 0 || idx >= len(line) { if cr.debug { fmt.Printf("index, ':' not found in %q\n", line) } return errMalformedEncoding
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 18.2K bytes - Viewed (0) -
cmd/format-erasure.go
g.Go(func() (err error) { storageDisks[index], err = newStorageAPI(endpoints[index], opts) return err }, index) } return storageDisks, g.Wait() } // formatErasureV3ThisEmpty - find out if '.This' field is empty // in any of the input `formats`, if yes return true. func formatErasureV3ThisEmpty(formats []*formatErasureV3) bool { for _, format := range formats { if format == nil { continue
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 23.2K bytes - Viewed (0) -
cmd/storage-rest-client.go
xhttp.DrainBody(respBody) return toStorageErr(err) != errDiskNotFound } } conn := gm.Connection(endpoint.GridHost()).Subroute(endpoint.Path) if conn == nil { return nil, fmt.Errorf("unable to find connection for %s in targets: %v", endpoint.GridHost(), gm.Targets()) } client := &storageRESTClient{ endpoint: endpoint, restClient: restClient, gridConn: conn,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 26.1K bytes - Viewed (0) -
cmd/erasure-multipart.go
// // Therefore, we adjust all ETags sent by the client to match what is stored // on the backend. kind, _ := crypto.IsEncrypted(fi.Metadata) var objectEncryptionKey []byte switch kind { case crypto.SSEC: if checksumType.IsSet() { if opts.EncryptFn == nil { return oi, crypto.ErrMissingCustomerKey }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 43K bytes - Viewed (0) -
cmd/generic-handlers_contrib.go
* * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package cmd import ( "net/http" "strings" )
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 30 15:50:39 GMT 2021 - 995 bytes - Viewed (0) -
internal/config/identity/openid/rsa-sha3_contrib.go
// // Unless required by applicable law or agreed to in writing, software // distributed under the License is distributed on an "AS IS" BASIS, // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. //go:build !fips // +build !fips package openid import ( "crypto"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Nov 05 19:20:08 GMT 2021 - 1.7K bytes - Viewed (0) -
internal/config/identity/openid/ecdsa-sha3_contrib.go
// // http://www.apache.org/licenses/LICENSE-2.0 // Unless required by applicable law or agreed to in writing, software // distributed under the License is distributed on an "AS IS" BASIS, // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. //go:build !fips // +build !fips package openid import ( "crypto"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Nov 05 19:20:08 GMT 2021 - 1.8K bytes - Viewed (0)