- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 40 for accordion (0.35 sec)
-
internal/bucket/lifecycle/error.go
package lifecycle import ( "fmt" ) // Error is the generic type for any error happening during tag // parsing. type Error struct { err error } // Errorf - formats according to a format specifier and returns // the string as a value that satisfies error of type tagging.Error func Errorf(format string, a ...interface{}) error { return Error{err: fmt.Errorf(format, a...)} }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 1.3K bytes - Viewed (0) -
cni/pkg/plugin/sidecar_iptables_linux.go
// See the License for the specific language governing permissions and // limitations under the License. // This is a sample chained plugin that supports multiple CNI versions. It // parses prevResult according to the cniVersion package plugin import ( "fmt" "github.com/containernetworking/plugins/pkg/ns" "istio.io/istio/pkg/log" "istio.io/istio/tools/istio-iptables/pkg/cmd"
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 18 17:36:41 GMT 2024 - 2.5K bytes - Viewed (0) -
cmd/admin-heal-ops.go
delete(ahs.healSeqMap, path) } b, err := json.Marshal(&hsp) return b, toAdminAPIErr(GlobalContext, err) } // LaunchNewHealSequence - launches a background routine that performs // healing according to the healSequence argument. For each heal // sequence, state is stored in the `globalAllHealState`, which is a // map of the heal path to `healSequence` which holds state about the // heal sequence. //
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.1K bytes - Viewed (1) -
istioctl/pkg/internaldebug/internal-debug.go
namespace, serviceAccount, kubeClient, multixds.DefaultOptions) if respErr != nil { return xdsResponses, respErr } _, _ = fmt.Fprint(writer, "error: according to below command list, please check all supported internal debug commands\n") return xdsResponses, nil } func HandlerForDebugErrors(kubeClient kube.CLIClient, centralOpts *clioptions.CentralControlPlaneOptions,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 04:16:55 GMT 2024 - 6.9K bytes - Viewed (0) -
src/archive/zip/struct.go
// If only the MS-DOS date is present, the timezone is assumed to be UTC. // // When writing, an extended timestamp (which is timezone-agnostic) is // always emitted. The legacy MS-DOS date field is encoded according to the // location of the Modified time. Modified time.Time // ModifiedTime is an MS-DOS-encoded time. // // Deprecated: Use Modified instead. ModifiedTime uint16
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/api-router.go
} // objectAPIHandler implements and provides http handlers for S3 API. type objectAPIHandlers struct { ObjectAPI func() ObjectLayer } // getHost tries its best to return the request host. // According to section 14.23 of RFC 2616 the Host header // can include the port number if the default value of 80 is not used. func getHost(r *http.Request) string { if r.URL.IsAbs() { return r.URL.Host } return r.Host }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 04 18:05:56 GMT 2024 - 22.8K bytes - Viewed (0) -
migrator/migrator.go
}) } // CurrentDatabase returns current database name func (m Migrator) CurrentDatabase() (name string) { m.DB.Raw("SELECT DATABASE()").Row().Scan(&name) return } // ReorderModels reorder models according to constraint dependencies func (m Migrator) ReorderModels(values []interface{}, autoAdd bool) (results []interface{}) { type Dependency struct { *gorm.Statement Depends []*schema.Schema } var (
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Fri Apr 26 07:15:49 GMT 2024 - 29K bytes - Viewed (0) -
cmd/site-replication.go
if !ok { return } z.s3Peer.DeleteBucket(context.Background(), pathJoin(minioMetaBucket, bucketMetaPrefix, deletedBucketsPrefix, bucket), DeleteBucketOptions{}) } // healBucket creates/deletes the bucket according to latest state across clusters participating in site replication. func (c *SiteReplicationSys) healBucket(ctx context.Context, objAPI ObjectLayer, bucket string, info srStatusInfo) error { bs := info.BucketStats[bucket]
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) -
internal/event/target/mqtt.go
return target.initOnce.Do(target.initMQTT) } func (target *MQTTTarget) initMQTT() error { args := target.args // Using hex here, to make sure we avoid 23 // character limit on client_id according to // MQTT spec. clientID := fmt.Sprintf("%x", time.Now().UnixNano()) options := mqtt.NewClientOptions(). SetClientID(clientID). SetCleanSession(true). SetUsername(args.User).
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 8.2K bytes - Viewed (0) -
cmd/bucket-object-lock.go
} if errors.Is(err, errInvalidArgument) { return r, err } return r, err } return config.ToRetention(), nil } // enforceRetentionForDeletion checks if it is appropriate to remove an // object according to locking configuration when this is lifecycle/ bucket quota asking. func enforceRetentionForDeletion(ctx context.Context, objInfo ObjectInfo) (locked bool) { if objInfo.DeleteMarker { return false }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 13.2K bytes - Viewed (0)