- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 59 for supplied (0.21 sec)
-
cmd/bitrot-streaming.go
if b.canClose != nil { b.canClose.Wait() } return err } // newStreamingBitrotWriterBuffer returns streaming bitrot writer implementation. // The output is written to the supplied writer w. func newStreamingBitrotWriterBuffer(w io.Writer, algo BitrotAlgorithm, shardSize int64) io.Writer {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Jan 31 02:11:45 GMT 2024 - 5.8K bytes - Viewed (0) -
operator/cmd/mesh/shared.go
return ev == "true" || ev == "1" } func kubeBuilderInstalled() bool { ev := os.Getenv("KUBEBUILDER") return ev == "true" || ev == "1" } // Confirm waits for a user to confirm with the supplied message. func Confirm(msg string, writer io.Writer) bool { for { _, _ = fmt.Fprintf(writer, "%s ", msg) var response string _, err := fmt.Scanln(&response) if err != nil { return false }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 29 02:29:02 GMT 2024 - 5.1K bytes - Viewed (0) -
cmd/test-utils_test.go
removeRoots(erasureDisks) return nil, err } erasureDisks = append(erasureDisks, path) } return erasureDisks, nil } // Initialize object layer with the supplied disks, objectLayer is nil upon any error. func newTestObjectLayer(ctx context.Context, endpointServerPools EndpointServerPools) (newObject ObjectLayer, err error) { initAllSubsystems(ctx)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 17:26:51 GMT 2024 - 76.2K bytes - Viewed (0) -
cmd/api-errors.go
HTTPStatusCode: http.StatusBadRequest, }, ErrObjectLockInvalidHeaders: { Code: "InvalidRequest", Description: "x-amz-object-lock-retain-until-date and x-amz-object-lock-mode must both be supplied", HTTPStatusCode: http.StatusBadRequest, }, ErrObjectRestoreAlreadyInProgress: { Code: "RestoreAlreadyInProgress", Description: "Object restore is already in progress",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 91.4K bytes - Viewed (6) -
istioctl/pkg/writer/compare/sds/util.go
s.state = state return s } // Build takes the set fields from the builder and constructs the actual SecretItem // including generating the SecretMeta from the supplied cert data, if present func (s *secretItemBuilder) Build() (SecretItem, error) { result := SecretItem{ Name: s.name, Data: s.data, Source: s.source, Destination: s.dest,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Jun 06 15:14:48 GMT 2023 - 6.6K bytes - Viewed (0) -
cmd/erasure-decode.go
} // Decode reads from readers, reconstructs data if needed and writes the data to the writer. // A set of preferred drives can be supplied. In that case they will be used and the data reconstructed. func (e Erasure) Decode(ctx context.Context, writer io.Writer, readers []io.ReaderAt, offset, length, totalLength int64, prefer []bool) (written int64, derr error) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:44:59 GMT 2024 - 9.4K bytes - Viewed (0) -
operator/cmd/mesh/manifest_shared_test.go
var interceptorFunc = interceptor.Funcs{Patch: func( ctx context.Context, clnt client.WithWatch, obj client.Object, patch client.Patch, opts ...client.PatchOption, ) error { // Apply patches are supposed to upsert, but fake client fails if the object doesn't exist, // if an apply patch occurs for an object that doesn't yet exist, create it. if patch.Type() != types.ApplyPatchType { return clnt.Patch(ctx, obj, patch, opts...)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Feb 20 22:39:28 GMT 2024 - 11.7K bytes - Viewed (1) -
cmd/object-handlers.go
// header values specified in X-Amz-Metadata-Directive. func getCpObjMetadataFromHeader(ctx context.Context, r *http.Request, userMeta map[string]string) (map[string]string, error) { // Make a copy of the supplied metadata to avoid // to change the original one. defaultMeta := make(map[string]string, len(userMeta)) for k, v := range userMeta { // skip tier metadata when copying metadata from source object switch k {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 20:15:54 GMT 2024 - 125.2K bytes - Viewed (0) -
cni/pkg/plugin/plugin.go
K8S_POD_NAMESPACE types.UnmarshallableString // nolint: revive, stylecheck K8S_POD_INFRA_CONTAINER_ID types.UnmarshallableString // nolint: revive, stylecheck } // parseConfig parses the supplied configuration (and prevResult) from stdin. func parseConfig(stdin []byte) (*Config, error) { conf := Config{} if err := json.Unmarshal(stdin, &conf); err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 15:58:51 GMT 2024 - 10.5K bytes - Viewed (0) -
internal/bucket/replication/replication.go
} // regular object/metadata replication return rule.MetadataReplicate(obj) } return false } // HasActiveRules - returns whether replication policy has active rules // Optionally a prefix can be supplied. // If recursive is specified the function will also return true if any level below the // prefix has active rules. If no prefix is specified recursive is effectively true.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 8.9K bytes - Viewed (0)