- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 38 for compatible (0.4 sec)
-
internal/http/listener.go
func (listener *httpListener) Close() (err error) { listener.ctxCanceler() for i := range listener.listeners { listener.listeners[i].Close() } return nil } // Addr - net.Listener interface compatible method returns net.Addr. In case of multiple TCP listeners, it returns '0.0.0.0' as IP address. func (listener *httpListener) Addr() (addr net.Addr) { addr = listener.listeners[0].Addr() if len(listener.listeners) == 1 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 5.6K bytes - Viewed (0) -
operator/cmd/mesh/profile-dump.go
if err != nil { return "", err } return out2, nil } // Convert the generated YAML to pretty JSON. func yamlToPrettyJSON(yml string) (string, error) { // YAML objects are not completely compatible with JSON // objects. Let yaml.YAMLToJSON handle the edge cases and // we'll re-encode the result to pretty JSON. uglyJSON, err := yaml.YAMLToJSON([]byte(yml)) if err != nil { return "", err }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 7.1K bytes - Viewed (0) -
internal/dsync/lock-args.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package dsync //go:generate msgp -file $GOFILE // LockArgs is minimal required values for any dsync compatible lock operation. type LockArgs struct { // Unique ID of lock/unlock request. UID string // Resources contains single or multiple entries to be locked/unlocked. Resources []string
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 04:34:26 GMT 2024 - 1.7K bytes - Viewed (0) -
cmd/warm-backend-minio.go
) // optimalPartInfo - calculate the optimal part info for a given // object size. // // NOTE: Assumption here is that for any object to be uploaded to any S3 compatible // object storage it will have the following parameters as constants. // // maxPartsCount - 10000 // maxMultipartPutObjectSize - 5TiB func optimalPartSize(objectSize int64) (partSize int64, err error) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 3.8K bytes - Viewed (0) -
utils/utils.go
import ( "database/sql/driver" "fmt" "path/filepath" "reflect" "runtime" "strconv" "strings" "unicode" ) var gormSourceDir string func init() { _, file, _, _ := runtime.Caller(0) // compatible solution to get gorm source directory with various operating systems gormSourceDir = sourceDir(file) } func sourceDir(file string) string { dir := filepath.Dir(file) dir = filepath.Dir(dir)
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Mon Apr 22 06:43:02 GMT 2024 - 3.8K bytes - Viewed (0) -
internal/crypto/error.go
ee := Error{} ee.msg = e.Error() ee.cause = errors.Unwrap(e) return ee } // Unwrap the internal error. func (e Error) Unwrap() error { return e.cause } // Error 'error' compatible method. func (e Error) Error() string { if e.msg == "" { return "crypto: cause <nil>" } return e.msg } var ( // ErrInvalidEncryptionMethod indicates that the specified SSE encryption method
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 4.4K bytes - Viewed (0) -
cmd/encryption-v1.go
// SSEDAREPackageMetaSize - SSE dare package meta padding bytes. SSEDAREPackageMetaSize = 32 // 32 bytes ) // KMSKeyID returns in AWS compatible KMS KeyID() format. func (o *ObjectInfo) KMSKeyID() string { return kmsKeyIDFromMetadata(o.UserDefined) } // KMSKeyID returns in AWS compatible KMS KeyID() format. func (o *MultipartInfo) KMSKeyID() string { return kmsKeyIDFromMetadata(o.UserDefined) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 36.5K bytes - Viewed (0) -
istioctl/pkg/precheck/precheck.go
v, err := cli.GetKubernetesVersion() if err != nil { return nil, fmt.Errorf("failed to get the Kubernetes version: %v", err) } compatible, err := k8sversion.CheckKubernetesVersion(v) if err != nil { return nil, err } if !compatible { return []diag.Message{ msg.NewUnsupportedKubernetesVersion(&resource.Instance{Origin: clusterOrigin{}}, v.String(), fmt.Sprintf("1.%d", k8sversion.MinK8SVersion)),
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 02:57:30 GMT 2024 - 19.3K bytes - Viewed (0) -
cmd/signature-v4-utils.go
// Signature-V4 spec excludes Content-Length from signed headers list for signature calculation. // But some clients deviate from this rule. Hence we consider Content-Length for signature // calculation to be compatible with such clients. extractedSignedHeaders.Set(header, strconv.FormatInt(r.ContentLength, 10)) default: return nil, ErrUnsignedHeaders } } return extractedSignedHeaders, ErrNone }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Jan 31 18:56:45 GMT 2024 - 9K bytes - Viewed (0) -
cmd/api-router.go
statsCollectedHandler := collectAPIStats(handlerName, throttledHandler) // Call the final handler. statsCollectedHandler(w, r) } return handler } // registerAPIRouter - registers S3 compatible APIs. func registerAPIRouter(router *mux.Router) { // Initialize API. api := objectAPIHandlers{ ObjectAPI: newObjectLayerFn, } // API Router
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 04 18:05:56 GMT 2024 - 22.8K bytes - Viewed (0)