- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 113 for Dapper (0.21 sec)
-
cmd/erasure-server-pool.go
atTotal := uint64(0) for _, pool := range serverPools { atTotal += pool.Available if atTotal > choose && pool.Available > 0 { return pool.Index } } // Should not happen, but print values just in case. storageLogIf(ctx, fmt.Errorf("reached end of serverPools (total: %v, atTotal: %v, choose: %v)", total, atTotal, choose)) return -1 }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 80.5K bytes - Viewed (0) -
cmd/object-handlers.go
w.Header().Set(xhttp.LastModified, lastModified) w.Header().Del(xhttp.ContentType) if _, ok := opts.ObjectAttributes[xhttp.Checksum]; ok { chkSums := objInfo.decryptChecksums(0) // AWS does not appear to append part number on this API call. switch { case chkSums["CRC32"] != "": OA.Checksum = new(objectAttributesChecksum) OA.Checksum.ChecksumCRC32 = strings.Split(chkSums["CRC32"], "-")[0]
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) -
istioctl/pkg/util/clusters/wrapper.go
"istio.io/istio/pkg/util/protomarshal" ) // Wrapper is a wrapper around the Envoy Clusters // It has extra helper functions for handling any/struct/marshal protobuf pain type Wrapper struct { *admin.Clusters } // MarshalJSON is a custom marshaller to handle protobuf pain func (w *Wrapper) MarshalJSON() ([]byte, error) { return protomarshal.Marshal(w) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Nov 03 08:41:32 GMT 2022 - 1.2K bytes - Viewed (0) -
istioctl/pkg/util/configdump/secret.go
extapi "github.com/envoyproxy/go-control-plane/envoy/extensions/transport_sockets/tls/v3" anypb "google.golang.org/protobuf/types/known/anypb" ) // GetSecretConfigDump retrieves a secret dump from a config dump wrapper func (w *Wrapper) GetSecretConfigDump() (*admin.SecretsConfigDump, error) { secretDumpAny, err := w.getSection(secrets) if err != nil { return nil, err } secretDump := &admin.SecretsConfigDump{}
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Feb 25 04:09:53 GMT 2023 - 2.2K bytes - Viewed (0) -
istioctl/pkg/authz/analyzer_test.go
"istio.io/istio/istioctl/pkg/util/configdump" ) func TestNewAnalyzer(t *testing.T) { tests := []struct { name string input *configdump.Wrapper wantErr error }{ { name: "Test1", input: &configdump.Wrapper{ ConfigDump: &envoy_admin.ConfigDump{ Configs: []*anypb.Any{ { TypeUrl: "type.googleapis.com/envoy.admin.v3.ListenersConfigDump", }, },
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sun Apr 21 17:42:54 GMT 2024 - 2.8K bytes - Viewed (0) -
istioctl/pkg/authz/authz.go
func getConfigDumpFromFile(filename string) (*configdump.Wrapper, error) { file, err := os.Open(filename) if err != nil { return nil, err } defer func() { if err := file.Close(); err != nil { log.Errorf("failed to close %s: %s", filename, err) } }() data, err := io.ReadAll(file) if err != nil { return nil, err } envoyConfig := &configdump.Wrapper{}
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 5K bytes - Viewed (0) -
misc/ios/go_ios_exec.go
os.RemoveAll(appdir) if err := assembleApp(appdir, os.Args[1]); err != nil { return 1, err } // This wrapper uses complicated machinery to run iOS binaries. It // works, but only when running one binary at a time. // Use a file lock to make sure only one wrapper is running at a time. // // The lock file is never deleted, to avoid concurrent locks on distinct // files with the same path.
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Apr 11 16:34:30 GMT 2022 - 23.4K bytes - Viewed (0) -
cmd/xl-storage_unix_test.go
// returns file mode creation mask. func getUmask() int { mask := syscall.Umask(0) syscall.Umask(mask) return mask } // Tests if the directory and file creations happen with proper umask. func TestIsValidUmaskVol(t *testing.T) { tmpPath := t.TempDir() testCases := []struct { volName string expectedUmask int }{ {"is-this-valid", getUmask()}, }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Jul 25 19:37:26 GMT 2022 - 3.4K bytes - Viewed (0) -
istioctl/pkg/describe/describe.go
StructValue: s, }, }, } } func (v *myProtoValue) keyAsString(key string) string { s := v.keyAsStruct(key) return s.GetStringValue() } func getIstioRBACPolicies(cd *configdump.Wrapper, port int32) ([]string, error) { hcm, err := getInboundHTTPConnectionManager(cd, port) if err != nil || hcm == nil { return []string{}, err }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 50.4K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/configdump.go
Stdout io.Writer configDump *configdump.Wrapper } // includeConfigType is a flag to indicate whether to include the config type in the output var includeConfigType bool func SetPrintConfigTypeInSummary(p bool) { includeConfigType = p } // Prime loads the config dump into the writer ready for printing func (c *ConfigWriter) Prime(b []byte) error { w := &configdump.Wrapper{} err := w.UnmarshalJSON(b) if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Feb 29 20:46:41 GMT 2024 - 7.4K bytes - Viewed (0)