- Sort Score
- Result 10 results
- Languages All
Results 51 - 56 of 56 for uniqBy (0.41 sec)
-
docs/bucket/notifications/README.md
print("Connected with result code "+str(rc)) # qos level is set to 1 client.subscribe("minio", 1) def on_message(client, userdata, msg): print(msg.payload) # client_id is a randomly generated unique ID for the mqtt broker to identify the connection. client = mqtt.Client(client_id="myclientid",clean_session=False) client.on_connect = on_connect client.on_message = on_message client.connect("localhost",1883,60)
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 84K bytes - Viewed (2) -
cmd/endpoint.go
if err != nil { continue } if host.String() == peer.String() { return endpoint.GridHost() } } } return "" } // Hostnames - returns list of unique hostnames func (l EndpointServerPools) Hostnames() []string { foundSet := set.NewStringSet() for _, ep := range l { for _, endpoint := range ep.Endpoints { if foundSet.Contains(endpoint.Hostname()) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 34.1K bytes - Viewed (0) -
docs/distributed/DESIGN.md
> http://host1/export6 > http://host2/export6 > http://host1/export7 > http://host2/export7 > http://host1/export8 > http://host2/export8 ``` *A noticeable trait of this expansion is that it chooses unique hosts such the setup provides maximum protection and availability.* - Choosing an erasure set for the object is decided during `PutObject()`, object names are used to find the right erasure set using the following pseudo code.
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Aug 15 23:04:20 GMT 2023 - 8K bytes - Viewed (0) -
docs/lambda/README.md
# Object Lambda
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 04 19:15:28 GMT 2023 - 7.6K bytes - Viewed (0) -
cmd/prepare-storage.go
m[err.Error()]++ } }() // Cleans up tmp directory of the local disk. func bgFormatErasureCleanupTmp(diskPath string) { // Need to move temporary objects left behind from previous run of minio // server to a unique directory under `minioMetaTmpBucket-old` to clean // up `minioMetaTmpBucket` for the current run. // // /disk1/.minio.sys/tmp-old/ // |__ 33a58b40-aecc-4c9f-a22f-ff17bfa33b62 // |__ e870a2c1-d09c-450c-a69c-6eaa54a89b3e
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 11.1K bytes - Viewed (0) -
internal/bucket/lifecycle/lifecycle_test.go
if err != nil { t.Fatalf("Expected parsing to succeed but failed with %v", err) } for _, rule := range lc.Rules { if rule.ID == "" { t.Fatalf("Expected all rules to have a unique id assigned %#v", rule) } } } func TestFilterAndSetPredictionHeaders(t *testing.T) { lc := Lifecycle{ Rules: []Rule{ { ID: "rule-1", Status: "Enabled",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:11:10 GMT 2024 - 53.2K bytes - Viewed (0)