- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for CTX (0.14 sec)
-
cmd/erasure-multipart.go
func (er erasureObjects) NewMultipartUpload(ctx context.Context, bucket, object string, opts ObjectOptions) (*NewMultipartUploadResult, error) { if !opts.NoAuditLog { auditObjectErasureSet(ctx, object, &er) } return er.newMultipartUpload(ctx, bucket, object, opts) } // renamePart - renames multipart part to its relevant location under uploadID.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 43K bytes - Viewed (0) -
cni/pkg/nodeagent/server.go
ConstructInitialSnapshot(ambientPods []*corev1.Pod) error Start(ctx context.Context) // IsPodInMesh(ctx context.Context, pod *metav1.ObjectMeta, netNs string) (bool, error) AddPodToMesh(ctx context.Context, pod *corev1.Pod, podIPs []netip.Addr, netNs string) error RemovePodFromMesh(ctx context.Context, pod *corev1.Pod) error DelPodFromMesh(ctx context.Context, pod *corev1.Pod) error Stop() } type Server struct {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 7.2K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
ctx, done, err := p.TrackDiskHealth(ctx, storageMetricStatVol, volume) if err != nil { return vol, err } defer done(&err) return xioutil.WithDeadline[VolInfo](ctx, globalDriveConfig.GetMaxTimeout(), func(ctx context.Context) (result VolInfo, err error) { return p.storage.StatVol(ctx, volume) }) } func (p *xlStorageDiskIDCheck) DeleteVol(ctx context.Context, volume string, forceDelete bool) (err error) {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0) -
cmd/storage-rest-client.go
for _, version := range versions { version.EncodeMsg(encoder) } storageLogIf(ctx, encoder.Flush()) errs = make([]error, len(versions)) respBody, err := client.call(ctx, storageRESTMethodDeleteVersions, values, &buffer, -1) defer xhttp.DrainBody(respBody) if err != nil { if contextCanceled(ctx) { err = ctx.Err() } for i := range errs { errs[i] = err } return errs }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 26.1K bytes - Viewed (0) -
cmd/erasure-object.go
} return false } func readAllXL(ctx context.Context, disks []StorageAPI, bucket, object string, readData, inclFreeVers, allParts bool) ([]FileInfo, []error) { rawFileInfos, errs := readAllRawFileInfo(ctx, disks, bucket, object, readData) return pickLatestQuorumFilesInfo(ctx, rawFileInfos, errs, bucket, object, readData, inclFreeVers, allParts) }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 76.9K bytes - Viewed (2) -
cmd/iam-store.go
saveUserIdentity(ctx context.Context, name string, userType IAMUserType, u UserIdentity, opts ...options) error saveGroupInfo(ctx context.Context, group string, gi GroupInfo) error deletePolicyDoc(ctx context.Context, policyName string) error deleteMappedPolicy(ctx context.Context, name string, userType IAMUserType, isGroup bool) error deleteUserIdentity(ctx context.Context, name string, userType IAMUserType) error
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Apr 27 10:04:10 GMT 2024 - 75.2K bytes - Viewed (2) -
istioctl/pkg/ztunnelconfig/ztunnelconfig.go
Aliases: []string{"zc"}, } configCmd.AddCommand(logCmd(ctx)) configCmd.AddCommand(workloadConfigCmd(ctx)) configCmd.AddCommand(certificatesConfigCmd(ctx)) configCmd.AddCommand(servicesCmd(ctx)) configCmd.AddCommand(policiesCmd(ctx)) configCmd.AddCommand(allCmd(ctx)) configCmd.AddCommand(connectionsCmd(ctx)) return configCmd } type Command struct { Name string }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Wed May 01 13:11:40 GMT 2024 - 22.2K bytes - Viewed (0) -
cmd/xl-storage.go
} func (s *xlStorage) readMetadata(ctx context.Context, itemPath string) ([]byte, error) { return xioutil.WithDeadline[[]byte](ctx, globalDriveConfig.GetMaxTimeout(), func(ctx context.Context) ([]byte, error) { buf, _, err := s.readMetadataWithDMTime(ctx, itemPath) return buf, err }) }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 84.7K bytes - Viewed (0) -
cni/pkg/nodeagent/net_test.go
true, ).Return(nil) err := netServer.AddPodToMesh(ctx, &corev1.Pod{ObjectMeta: podMeta}, podIPs, "fakenetns") assert.NoError(t, err) assert.Equal(t, 1, ztunnelServer.addedPods.Load()) } func TestServerRemovePod(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() setupLogging() fixture := getTestFixure(ctx) netServer := fixture.netServer
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 16.4K bytes - Viewed (0) -
istioctl/pkg/waypoint/waypoint.go
waypointName = constants.DefaultNamespaceWaypoint enrollNamespace bool ) const waitTimeout = 90 * time.Second func Cmd(ctx cli.Context) *cobra.Command { makeGateway := func(forApply bool) (*gateway.Gateway, error) { ns := ctx.NamespaceOrDefault(ctx.Namespace()) if ctx.Namespace() == "" && !forApply { ns = "" } // If a user sets the waypoint name to an empty string, set it to the default namespace waypoint name.
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Wed May 01 16:16:40 GMT 2024 - 15.2K bytes - Viewed (0)