- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 101 for slate (0.6 sec)
-
src/archive/zip/writer_test.go
if f.method == Deflate { var buf bytes.Buffer w, err := flate.NewWriter(&buf, flate.BestSpeed) if err != nil { t.Fatalf("flate.NewWriter err = %v", err) } _, err = w.Write(f.content) if err != nil { t.Fatalf("flate Write err = %v", err) } err = w.Close() if err != nil { t.Fatalf("flate Writer.Close err = %v", err) } compressedContent = buf.Bytes()
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Sep 15 19:04:06 GMT 2023 - 14.1K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/connections.go
return r } return cmp.Compare(a.Info.Namespace, b.Info.Namespace) }) workloads = slices.FilterInPlace(workloads, func(state WorkloadState) bool { if filter.Namespace != "" && filter.Namespace != state.Info.Namespace { return false } return true }) out, err := json.MarshalIndent(workloads, "", " ") if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Apr 22 15:39:28 GMT 2024 - 3.3K bytes - Viewed (0) -
cmd/admin-handlers-site-replication.go
// SRStateEdit - PUT /minio/admin/v3/site-replication/state/edit // // used internally to tell current cluster to update site replication state func (a adminAPIHandlers) SRStateEdit(w http.ResponseWriter, r *http.Request) { ctx := r.Context() objectAPI, _ := validateAdminReq(ctx, w, r, policy.SiteReplicationOperationAction) if objectAPI == nil { return } var state madmin.SRStateEditReq
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 15 09:40:39 GMT 2024 - 19.4K bytes - Viewed (0) -
cni/pkg/repair/repair_test.go
false, }, { "Testing broken pod (in waiting state) with only ExitCode check", config.RepairConfig{ SidecarAnnotation: "sidecar.istio.io/status", InitContainerName: constants.ValidationContainerName, InitExitCode: 126, }, brokenPodWaiting, true, }, { "Testing broken pod (in terminating state) with only ExitCode check", config.RepairConfig{
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Oct 24 03:31:28 GMT 2023 - 10.6K bytes - Viewed (0) -
src/archive/zip/writer.go
func (w *Writer) CreateHeader(fh *FileHeader) (io.Writer, error) { if err := w.prepare(fh); err != nil { return nil, err } // The ZIP format has a sad state of affairs regarding character encoding. // Officially, the name and comment fields are supposed to be encoded // in CP-437 (which is mostly compatible with ASCII), unless the UTF-8
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Thu Apr 04 14:28:57 GMT 2024 - 19.3K bytes - Viewed (0) -
cmd/object-api-interface.go
} // DeleteMarkerReplicationStatus - returns replication status of delete marker from DeleteReplication state in ObjectOptions func (o *ObjectOptions) DeleteMarkerReplicationStatus() replication.StatusType { return o.DeleteReplication.CompositeReplicationStatus() } // VersionPurgeStatus - returns version purge status from DeleteReplication state in ObjectOptions func (o *ObjectOptions) VersionPurgeStatus() VersionPurgeStatusType {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 17K bytes - Viewed (0) -
cmd/erasure-sets.go
for i, format := range formats { drive := endpoints.GetString(i) state := madmin.DriveStateCorrupt switch { case format != nil: state = madmin.DriveStateOk case sErrs[i] == errUnformattedDisk: state = madmin.DriveStateMissing case sErrs[i] == errDiskNotFound: state = madmin.DriveStateOffline } beforeDrives[i] = madmin.HealDriveInfo{ UUID: func() string {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 37.7K bytes - Viewed (5) -
internal/kms/kes.go
for _, endpoint := range c.client.Endpoints { client := kes.Client{ Endpoints: []string{endpoint}, HTTPClient: c.client.HTTPClient, } // 1. Get stats for the KES instance state, err := client.Status(ctx) if err != nil { results = append(results, VerifyResult{Status: "offline", Endpoint: endpoint}) continue } // 2. Generate a new key using the KMS.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 16 15:43:39 GMT 2024 - 14.9K bytes - Viewed (0) -
cmd/lock-rest-client.go
type lockRESTClient struct { connection *grid.Connection } // IsOnline - returns whether REST client failed to connect or not. func (c *lockRESTClient) IsOnline() bool { return c.connection.State() == grid.StateConnected } // Not a local locker func (c *lockRESTClient) IsLocal() bool { return false } // Close - marks the client as closed. func (c *lockRESTClient) Close() error { return nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Nov 24 17:07:14 GMT 2023 - 3.3K bytes - Viewed (0) -
internal/config/config.go
continue } return false, Errorf("key '%s', cannot have empty value", kv[0]) } _, ok := kvs.Lookup(Enable) // Check if state is required _, enableRequired := defaultKVS[subSys].Lookup(Enable) if !ok && enableRequired { // implicit state "on" if not specified. kvs.Set(Enable, EnableOn) } var currKVS KVS ck, ok := c[subSys][tgt] if !ok {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Mar 02 05:11:03 GMT 2024 - 37.3K bytes - Viewed (0)