- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 29 for vmss (0.18 sec)
-
cmd/peer-rest-server.go
localStorageInfoRPC = grid.NewSingleHandler[*grid.MSS, *grid.JSON[madmin.StorageInfo]](grid.HandlerStorageInfo, grid.NewMSS, madminStorageInfo.NewJSON) makeBucketRPC = grid.NewSingleHandler[*grid.MSS, grid.NoPayload](grid.HandlerMakeBucket, grid.NewMSS, grid.NewNoPayload)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 51.8K bytes - Viewed (0) -
internal/grid/types.go
type Recycler interface { Recycle() } // MSS is a map[string]string that can be serialized. // It is not very efficient, but it is only used for easy parameter passing. type MSS map[string]string // Get returns the value for the given key. func (m *MSS) Get(key string) string { if m == nil { return "" } return (*m)[key] } // Set a key, value pair. func (m *MSS) Set(key, value string) { if m == nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 01 23:42:09 GMT 2024 - 15.4K bytes - Viewed (0) -
internal/grid/types_test.go
t.Errorf("%d bytes left over after Skip(): %q", len(left), left) } if !reflect.DeepEqual(v, v2) { t.Errorf("MSS: %v != %v", v, v2) } } func TestMarshalUnmarshalMSSNil(t *testing.T) { v := MSS(nil) bts, err := v.MarshalMsg(nil) if err != nil { t.Fatal(err) } v2 := MSS(make(map[string]string, 1)) left, err := v2.UnmarshalMsg(bts) if err != nil { t.Fatal(err) } if len(left) != 0 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 3.7K bytes - Viewed (0) -
cmd/peer-s3-client.go
conn := client.gridConn() if conn == nil { return madmin.HealResultItem{}, nil } mss := grid.NewMSSWith(map[string]string{ peerS3Bucket: bucket, peerS3BucketDeleted: strconv.FormatBool(opts.Remove), }) _, err := healBucketRPC.Call(ctx, conn, mss) // Initialize heal result info return madmin.HealResultItem{ Type: madmin.HealItemBucket, Bucket: bucket,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.8K bytes - Viewed (0) -
internal/grid/trace.go
// If the context contains a TraceParamsKey, add it to the trace path. v := ctx.Value(TraceParamsKey{}) // Should match SingleHandler.Call checks. switch typed := v.(type) { case *MSS: trace.Path += typed.ToQuery() case map[string]string: m := MSS(typed) trace.Path += m.ToQuery() case *URLValues: trace.Path += typed.Values().Encode() case *NoPayload, *Bytes:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 02 22:54:54 GMT 2024 - 4K bytes - Viewed (0) -
internal/grid/README.md
These must provide `msgp` serialization and deserialization. In the examples we use a `MSS` type, which is a `map[string]string` that is `msgp` serializable. ```go handler := func(request *grid.MSS) (*grid.MSS, *grid.RemoteErr) { fmt.Println("Got request with field", request["myfield"]) // Do something with payload
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 9.4K bytes - Viewed (0) -
ci/official/utilities/setup_macos.sh
# Libtensorflow archives) to GCS buckets. TFCI Mac VMs need to authenticate as # a service account that has the right permissions to be able to do so. set +x if [[ -n "${GOOGLE_APPLICATION_CREDENTIALS:-}" ]]; then # Python 3.12 removed the module `imp` which is needed by gcloud CLI so we set # `CLOUDSDK_PYTHON` to Python 3.11 which is the system Python on TFCI Mac # VMs. export CLOUDSDK_PYTHON=$(which python3.11)
Shell Script - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Thu Feb 15 15:23:28 GMT 2024 - 6.2K bytes - Viewed (0) -
android/guava/src/com/google/common/reflect/Parameter.java
* the Android flavor of Guava). The field is declared with a type of {@code Object} to avoid * compatibility problems on Android VMs. The corresponding accessor method, however, can have the * more specific return type as long as users are careful to guard calls to it with version checks * or reflection: Android VMs ignore the types of elements that aren't used. */
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Nov 16 15:12:31 GMT 2023 - 4.3K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/internal/impl/DefaultSession.java
final MavenSession ms = nonNull(getMavenSession()); final MavenSession mss; if (repoSession != ms.getRepositorySession()) { mss = new MavenSession(repoSession, ms.getRequest(), ms.getResult()); } else { mss = ms; } return newSession(mss, repositories); }
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Tue Apr 23 12:55:57 GMT 2024 - 7.9K bytes - Viewed (0) -
architecture/security/istio-agent.md
|FILE_MOUNTED_CERTS|completely disable CA path, exclusively use certs mounted into the pod with set certificate file locations| |CREDENTIAL_FETCHER_TYPE|allows using custom credential fetcher, for VMs with existing identity| |CREDENTIAL_IDENTITY_PROVIDER|just used to control the audience for VMs with existing identity| |PROXY_XDS_VIA_AGENT|use istio-agent to proxy XDS. True for all use cases now, likely can be always-on now or soon|
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Aug 22 16:45:50 GMT 2023 - 7.2K bytes - Viewed (1)