- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 20 for added (0.13 sec)
-
docs/debugging/inspect/export.go
// Read metadata CRC (added in v2, ignore if not found) b = nbuf } _, e = msgp.CopyToJSON(buf, bytes.NewReader(v)) if e != nil { return nil, e } data = b case 3: v, b, e := msgp.ReadBytesZC(b) if e != nil { return nil, e } if _, nbuf, e := msgp.ReadUint32Bytes(b); e == nil { // Read metadata CRC (added in v2, ignore if not found) b = nbuf }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 08 15:58:02 GMT 2022 - 9.1K bytes - Viewed (0) -
operator/cmd/mesh/manifest-diff.go
"changed paths with the value changes shown as OLD-VALUE -> NEW-VALUE.\n" + "List order changes are shown as [OLD-INDEX->NEW-INDEX], with ? used where a list item is added or\n" + "removed.", Args: func(cmd *cobra.Command, args []string) error { if len(args) != 2 { return fmt.Errorf("diff requires two files or directories") } return nil },
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 5.8K bytes - Viewed (0) -
cmd/tier-sweeper.go
// 3. If bucket versioning is enabled and // a. version id is specified, remove its remote object. // b. version id is not specified, nothing to be done (a delete marker is added). delTier := false switch { case !os.Versioned, os.Suspended: // 1, 2.a, 2.b delTier = true case os.Versioned && os.VersionID != "": // 3.a delTier = true } if delTier { return jentry{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 4.7K bytes - Viewed (0) -
internal/grid/msg.go
FlagPayloadIsErr // FlagPayloadIsZero means that payload is 0-length slice and not nil. FlagPayloadIsZero // FlagSubroute indicates that the message has subroute. // Subroute will be 32 bytes long and added before any CRC. FlagSubroute ) // This struct cannot be changed and retain backwards compatibility. // If changed, endpoint version must be bumped. // //msgp:tuple message type message struct {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 28 19:22:29 GMT 2023 - 7.3K bytes - Viewed (0) -
internal/config/dns/operator_dns.go
e := Error{bucket, err} if strings.Contains(err.Error(), "invalid bucket name") { return ErrInvalidBucketName(e) } return e } // Delete - Removes DNS entries added in Put(). func (c *OperatorDNS) Delete(bucket string) error { ctx, cancel := context.WithTimeout(context.Background(), defaultOperatorContextTimeout) defer cancel() e, err := c.endpoint(bucket, true) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 06 16:56:10 GMT 2023 - 6.6K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
defer EventTotals.With(eventTypeTag.Value(event.Event.String())).Increment() switch event.Event { case controllers.EventAdd: // pod was added to our cache // we get here in 2 cases: // 1. new pod was created on our node // 2. we were restarted and current existing pods are added to our cache // We have no good way to distinguish between these two cases from here. But we don't need to!
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 9.6K bytes - Viewed (0) -
src/cmd/cgo/internal/cgotest/overlaydir.go
// license that can be found in the LICENSE file. package cgotest import ( "io" "os" "path/filepath" "strings" ) // OverlayDir makes a minimal-overhead copy of srcRoot in which new files may be added. func OverlayDir(dstRoot, srcRoot string) error { dstRoot = filepath.Clean(dstRoot) if err := os.MkdirAll(dstRoot, 0777); err != nil { return err } srcRoot, err := filepath.Abs(srcRoot) if err != nil {
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon May 22 20:56:09 GMT 2023 - 1.7K bytes - Viewed (0) -
cmd/site-replication_test.go
{Endpoint: "minio3:9000", Name: "minio3", DeploymentID: "dep3"}, }, set.CreateStringSet("dep1", "dep2", "dep3"), set.CreateStringSet("dep1"), []string{"minio2", "minio3"}, }, // Test2: new site added that is not in replicated setup {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jun 20 00:53:08 GMT 2023 - 2.2K bytes - Viewed (0) -
internal/event/targetlist_test.go
} return nil } func (target ExampleTarget) IsActive() (bool, error) { return false, errors.New("not connected to target server/service") } // FlushQueueStore - No-Op. Added for interface compatibility func (target ExampleTarget) FlushQueueStore() error { return nil } func TestTargetListAdd(t *testing.T) { targetListCase1 := NewTargetList(context.Background())
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Dec 05 10:16:33 GMT 2023 - 6.1K bytes - Viewed (0) -
istioctl/pkg/clioptions/doc.go
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. // Package clioptions contains flags which can be added to istioctl commands.
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Jul 13 01:59:17 GMT 2022 - 683 bytes - Viewed (0)