- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 33 for Meyers (0.21 sec)
-
cmd/site-replication.go
}) } if err != nil { return errSRServiceAccount(fmt.Errorf("unable to create service account on %s: %v", ourName, err)) } peers := make(map[string]madmin.PeerInfo, len(arg.Peers)) for dID, pi := range arg.Peers { if c.state.Peers != nil { if existingPeer, ok := c.state.Peers[dID]; ok { // retain existing ReplicateILMExpiry of peer if its already set // and incoming arg has it false. it could be default false
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 184.2K bytes - Viewed (1) -
cmd/net.go
host, err := xnet.ParseHost(serverAddr) if err != nil { return config.ErrInvalidAddressFlag(err) } // 0.0.0.0 is a wildcard address and refers to local network // addresses. I.e, 0.0.0.0:9000 like ":9000" refers to port // 9000 on localhost. if host.Name != "" && host.Name != net.IPv4zero.String() && host.Name != net.IPv6zero.String() {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 26 15:00:38 GMT 2024 - 9.3K bytes - Viewed (0) -
cmd/metacache-entries.go
} return other, other.isDir() == e.isDir() } eVers, eErr := e.xlmeta() oVers, oErr := other.xlmeta() if eErr != nil || oErr != nil { return nil, false } // check both fileInfo's have same number of versions, if not skip // the `other` entry. if len(eVers.versions) != len(oVers.versions) { eTime := eVers.latestModtime() oTime := oVers.latestModtime() if !eTime.Equal(oTime) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:43:43 GMT 2024 - 23.2K bytes - Viewed (0) -
cmd/peer-rest-client.go
_, err = loadSvcActRPC.Call(context.Background(), client.gridConn(), grid.NewMSSWith(map[string]string{ peerRESTUser: accessKey, })) return err } // LoadGroup - send load group command to peers. func (client *peerRESTClient) LoadGroup(group string) error { _, err := loadGroupRPC.Call(context.Background(), client.gridConn(), grid.NewMSSWith(map[string]string{ peerRESTGroup: group, })) return err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.8K bytes - Viewed (0) -
cmd/consolelogger.go
if err != nil { logger.FatalIf(err, "Unable to start console logging subsystem") } sys.nodeName = host.Name } // HasLogListeners returns true if console log listeners are registered // for this node or peers func (sys *HTTPConsoleLoggerSys) HasLogListeners() bool { return sys != nil && sys.pubsub.Subscribers() > 0 } // Subscribe starts console logging for this node.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 5.5K bytes - Viewed (0) -
cmd/erasure-metadata.go
func (fi *FileInfo) TierFreeVersionID() string { return fi.Metadata[ReservedMetadataPrefixLower+tierFVID] } // SetTierFreeVersion sets fi as a free-version. This method is used by // lower layers to indicate a free-version. func (fi *FileInfo) SetTierFreeVersion() { if fi.Metadata == nil { fi.Metadata = make(map[string]string) } fi.Metadata[ReservedMetadataPrefixLower+tierFVMarker] = "" }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 19.2K bytes - Viewed (1) -
cmd/test-utils_test.go
} } } // ExecObjectLayerAPITest - executes object layer API tests. // Creates single node and Erasure ObjectLayer instance, registers the specified API end points and runs test for both the layers. func ExecObjectLayerAPITest(t *testing.T, objAPITest objAPITestType, endpoints []string) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() // reset globals.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 17:26:51 GMT 2024 - 76.2K bytes - Viewed (0) -
cmd/peer-rest-server.go
m.VariableLabels[serverName] = globalLocalNodeName res = append(res, &m) return true }) return aoMetricsGroup.NewWith(res), nil } // GetPeerMetrics gets the metrics to be federated across peers. func (s *peerRESTServer) GetPeerMetrics(_ *grid.MSS) (*grid.Array[*MetricV2], *grid.RemoteErr) { res := make([]*MetricV2, 0, len(peerMetricsGroups)) populateAndPublish(peerMetricsGroups, func(m MetricV2) bool {
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) -
cmd/endpoint-ellipses.go
} } setCounts = []uint64{} for setCount := range newSetCounts { setCounts = append(setCounts, setCount) } // Not necessarily needed but it ensures to the readers // eyes that we prefer a sorted setCount slice for the // subsequent function to figure out the right common // divisor, it avoids loops. sort.Slice(setCounts, func(i, j int) bool { return setCounts[i] < setCounts[j] })
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 14.7K bytes - Viewed (0) -
cmd/peer-s3-client.go
func newPeerS3Clients(endpoints EndpointServerPools) (peers []peerS3Client) { nodes := endpoints.GetNodes() peers = make([]peerS3Client, len(nodes)) for i, node := range nodes { if node.IsLocal { peers[i] = &localPeerS3Client{node: node} } else { peers[i] = newPeerS3Client(node) } peers[i].SetPools(node.Pools) } return peers } // Returns a peer S3 client.
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)