- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 35 for partille (0.32 sec)
-
cni/pkg/nodeagent/error.go
// See the License for the specific language governing permissions and // limitations under the License. package nodeagent import ( "errors" "fmt" ) var ErrPartialAdd = errors.New("partial add error") type PartialAddError struct { inner error } func (e *PartialAddError) Error() string { return fmt.Sprintf("%s: %v", ErrPartialAdd.Error(), e.inner) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 1K bytes - Viewed (0) -
internal/config/cache/remote.go
Size int64 `json:"size,omitempty" msg:",omitempty"` // Full size of the object Data []byte `json:"data,omitempty" msg:",omitempty"` // Data can container full data of the object or partial } // WriteHeaders writes the response headers for conditional requests func (oi ObjectInfo) WriteHeaders(w http.ResponseWriter, preamble, statusCode func()) { preamble() if !oi.ModTime.IsZero() {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Nov 22 21:46:17 GMT 2023 - 3.7K bytes - Viewed (0) -
cni/pkg/nodeagent/server_test.go
podIP := netip.MustParseAddr("99.9.9.1") podIPs := []netip.Addr{podIP} fakeCtx := context.Background() server.On("AddPodToMesh", fakeCtx, pod, podIPs, "", ).Return(errors.New("not partial error")) server.Start(fakeCtx) fakeClientSet := fake.NewSimpleClientset(pod) m := meshDataplane{ kubeClient: fakeClientSet, netServer: server, }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 7.8K bytes - Viewed (0) -
cmd/object-api-utils.go
} // Returns the part file name which matches the partNumber and etag. func getPartFile(entriesTrie *trie.Trie, partNumber int, etag string) (partFile string) { for _, match := range entriesTrie.PrefixMatch(fmt.Sprintf("%.5d.%s.", partNumber, etag)) { partFile = match break } return partFile } func partNumberToRangeSpec(oi ObjectInfo, partNumber int) *HTTPRangeSpec { if oi.Size == 0 || len(oi.Parts) == 0 { return nil
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 11 11:55:34 GMT 2024 - 35.6K bytes - Viewed (1) -
src/archive/zip/struct.go
func (fi headerFileInfo) Info() (fs.FileInfo, error) { return fi, nil } func (fi headerFileInfo) String() string { return fs.FormatFileInfo(fi) } // FileInfoHeader creates a partially-populated [FileHeader] from an // fs.FileInfo. // Because fs.FileInfo's Name method returns only the base name of // the file it describes, it may be necessary to modify the Name field
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Oct 13 18:36:46 GMT 2023 - 12.1K bytes - Viewed (0) -
cmd/object-api-datatypes.go
} // the current version of an object is accounted towards objects count if o.IsLatest { ts.NumObjects = 1 } return ts } // ToObjectInfo converts a replication object info to a partial ObjectInfo // do not rely on this function to give you correct ObjectInfo, this // function is merely and optimization. func (ri ReplicateObjectInfo) ToObjectInfo() ObjectInfo { return ObjectInfo{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 20.8K bytes - Viewed (0) -
cmd/site-replication.go
ErrDetail: fmt.Sprintf("unable to update peer targets on local: %v", err), }, nil } } // set partial error message if remote site updates failed for few cases if len(errs) > 0 { successMsg = fmt.Sprintf("%s\n- partially failed for few remote sites as they could be down/unreachable at the moment", successMsg) } result := madmin.ReplicateEditStatus{ Success: true,
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) -
cni/pkg/nodeagent/net_test.go
// no calls to ztunnel if iptables failed assert.Equal(t, ztunnelServer.addedPods.Load(), 0) // error is not partial error if errors.Is(err, ErrPartialAdd) { t.Fatal("expected not a partial error") } } func TestConstructInitialSnap(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() setupLogging()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 16.4K bytes - Viewed (0) -
tests/embedded_struct_test.go
t.Errorf("embedded struct's value should be scanned correctly") } DB.Save(&EngadgetPost{BasePost: BasePost{Title: "engadget_news"}, Author: &Author{Name: "Edward"}}) DB.Save(&EngadgetPost{BasePost: BasePost{Title: "engadget_article"}, Author: &Author{Name: "George"}}) var egNews EngadgetPost if err := DB.First(&egNews, "title = ?", "engadget_news").Error; err != nil { t.Errorf("no error should happen when query with embedded struct, but got %v", err)
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Thu Oct 26 03:58:13 GMT 2023 - 7.3K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
return fmt.Errorf("no online drives found for set with endpoints %s", set.getEndpoints()) } // However many we ask, versions must exist on ~50% listingQuorum := (set.setDriveCount + 1) / 2 // How to resolve partial results. resolver := metadataResolutionParams{ dirQuorum: listingQuorum, // make sure to capture all quorum ratios objQuorum: listingQuorum, // make sure to capture all quorum ratios bucket: bi.Name, }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 41.5K bytes - Viewed (1)