- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 87 for layout (0.28 sec)
-
cni/pkg/nodeagent/ztunnelserver.go
r := &zdsapi.WorkloadRequest{ Payload: &zdsapi.WorkloadRequest_Add{ Add: &zdsapi.AddWorkload{ WorkloadInfo: podToWorkload(pod), Uid: uid, }, }, } log.Infof("About to send added pod: %s to ztunnel: %+v", uid, r) data, err := proto.Marshal(r) if err != nil { return err } fd := int(netns.Fd()) resp, err := latestConn.send(ctx, data, &fd) if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
cmd/api-response.go
Value: item.Value, }); err != nil { return err } } return e.EncodeToken(start.End()) } // ObjectInternalInfo contains some internal information about a given // object, it will printed in listing calls with enabled metadata. type ObjectInternalInfo struct { K int // Data blocks M int // Parity blocks } // Object container for object metadata
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 33.3K bytes - Viewed (2) -
cmd/iam-store.go
} func newUserIdentity(cred auth.Credentials) UserIdentity { return UserIdentity{Version: 1, Credentials: cred, UpdatedAt: UTCNow()} } // GroupInfo contains info about a group type GroupInfo struct { Version int `json:"version"` Status string `json:"status"` Members []string `json:"members"` UpdatedAt time.Time `json:"updatedAt,omitempty"` }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Apr 27 10:04:10 GMT 2024 - 75.2K bytes - Viewed (2) -
cmd/encryption-v1.go
_, err := sio.DecryptedSize(uint64(part.Size)) if err != nil { return false } } } // Further check if this object is uploaded using multipart mechanism // by the user and it is not about Erasure internally splitting the // object into parts in PutObject() return len(o.ETag) != 32 } // ParseSSECopyCustomerRequest parses the SSE-C header fields of the provided request.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 36.5K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
} const ( poolMetaName = "pool.bin" poolMetaFormat = 1 poolMetaVersionV1 = 1 poolMetaVersion = poolMetaVersionV1 ) // Init() initializes pools and saves additional information about them // in 'pool.bin', this is eventually used for decommissioning the pool. func (z *erasureServerPools) Init(ctx context.Context) error { // Load rebalance metadata if present err := z.loadRebalanceMeta(ctx)
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) -
cmd/storage-rest-server.go
} logger.Fatal(config.ErrUnableToWriteInBackend(err).Hint(hint), "Unable to initialize backend") case errors.Is(err, errDiskAccessDenied): // Show a descriptive error with a hint about how to fix it. var username string if u, err := user.Current(); err == nil { username = u.Username } else { username = "<your-username>" } var hint string if endpoint.URL != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 44.8K bytes - Viewed (0) -
cmd/xl-storage.go
attr := "user.total_writes" data := make([]byte, 8) binary.LittleEndian.PutUint64(data, writeCount) return xattr.LSet(s.formatFile, attr, data) } // DiskInfo provides current information about disk space usage, // total free inodes and underlying filesystem. func (s *xlStorage) DiskInfo(_ context.Context, _ DiskInfoOptions) (info DiskInfo, err error) { info, err = s.diskInfoCache.Get()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 84.7K bytes - Viewed (0) -
istioctl/pkg/ztunnelconfig/ztunnelconfig.go
Long: "A group of commands used to update or retrieve Ztunnel configuration from a Ztunnel instance.", Example: ` # Retrieve summary about workload configuration istioctl x ztunnel-config workload # Retrieve summary about certificates istioctl x ztunnel-config certificates`, Aliases: []string{"zc"}, } configCmd.AddCommand(logCmd(ctx)) configCmd.AddCommand(workloadConfigCmd(ctx))
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 01 13:11:40 GMT 2024 - 22.2K bytes - Viewed (0) -
cmd/tier-handlers.go
case storageclass.STANDARD, storageclass.RRS: writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, errTierReservedName), r.URL) return } // Refresh from the disk in case we had missed notifications about edits from peers. if err := globalTierConfigMgr.Reload(ctx, objAPI); err != nil { writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } err = globalTierConfigMgr.Add(ctx, cfg, ignoreInUse)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 15 19:52:44 GMT 2024 - 7.5K bytes - Viewed (0) -
internal/s3select/message.go
// It contains information about the progress of a query that has started but has not yet completed. // // Header specification: // Progress messages contain three headers, as follows: // https://docs.aws.amazon.com/AmazonS3/latest/API/images/s3select-frame-diagram-progress.png // // Payload specification: // Progress message payload is an XML document containing information about the progress of a request.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Aug 30 15:26:43 GMT 2022 - 15.2K bytes - Viewed (0)