Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 65 for decision (0.25 sec)

  1. cmd/bucket-replication-utils_test.go

    }{
    	{ // 1.
    		name: "empty string",
    		dsc:  "",
    		expDsc: ReplicateDecision{
    			targetsMap: map[string]replicateTargetDecision{},
    		},
    		expErr: nil,
    	},
    
    	{ // 2.
    		name:   "replicate decision for one target",
    		dsc:    "arn:minio:replication::id:bucket=true;false;arn:minio:replication::id:bucket;id",
    		expErr: nil,
    		expDsc: ReplicateDecision{
    			targetsMap: map[string]replicateTargetDecision{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Aug 08 20:27:40 GMT 2023
    - 9.3K bytes
    - Viewed (0)
  2. cmd/object-multipart-handlers.go

    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	_, isEncrypted := crypto.IsEncrypted(mi.UserDefined)
    
    	// Read compression metadata preserved in the init multipart for the decision.
    	_, isCompressed := mi.UserDefined[ReservedMetadataPrefix+"compression"]
    	// Compress only if the compression is enabled during initial multipart.
    	var idxCb func() []byte
    	if isCompressed {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 28 17:44:56 GMT 2024
    - 39K bytes
    - Viewed (0)
  3. cmd/bucket-replication.go

    		})
    		return
    	}
    	dsc, err := parseReplicateDecision(ctx, bucket, dobj.ReplicationState.ReplicateDecisionStr)
    	if err != nil {
    		replLogOnceIf(ctx, fmt.Errorf("unable to parse replication decision parameters for bucket: %s, err: %s, decision: %s",
    			bucket, err, dobj.ReplicationState.ReplicateDecisionStr), dobj.ReplicationState.ReplicateDecisionStr)
    		sendEvent(eventArgs{
    			BucketName: bucket,
    			Object: ObjectInfo{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 112.2K bytes
    - Viewed (1)
  4. cmd/object-api-datatypes.go

    	// internal representation of version purge status
    	VersionPurgeStatusInternal string
    	VersionPurgeStatus         VersionPurgeStatusType
    
    	replicationDecision string // internal representation of replication decision for use by DeleteObject handler
    	// The total count of all versions of this object
    	NumVersions int
    	//  The modtime of the successor object version if any
    	SuccessorModTime time.Time
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 20.8K bytes
    - Viewed (0)
  5. cmd/bucket-replication-utils.go

    		}
    	}
    	return b.String()
    }
    
    // ResyncDecision is a struct representing a map with target's individual resync decisions
    type ResyncDecision struct {
    	targets map[string]ResyncTargetDecision
    }
    
    // Empty returns true if no targets with resync decision present
    func (r ResyncDecision) Empty() bool {
    	return r.targets == nil
    }
    
    func (r ResyncDecision) mustResync() bool {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 26.2K bytes
    - Viewed (0)
  6. cmd/object-api-interface.go

    // CheckPreconditionFn returns true if precondition check failed.
    type CheckPreconditionFn func(o ObjectInfo) bool
    
    // EvalMetadataFn validates input objInfo and GetObjectInfo error and returns an updated metadata and replication decision if any
    type EvalMetadataFn func(o *ObjectInfo, gerr error) (ReplicateDecision, error)
    
    // EvalRetentionBypassFn validates input objInfo and GetObjectInfo error and returns an error if retention bypass is not allowed.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 17K bytes
    - Viewed (0)
  7. operator/cmd/mesh/operator-common.go

    imagePullSecrets:
    {{- range .ImagePullSecrets }}
    - {{ . }}
    {{- end }}
    {{- end }}
    revision: {{if .Revision }} {{.Revision}} {{else}} "" {{end}}
    `
    
    	tv := struct {
    		IstioNamespace    string
    		WatchedNamespaces string
    		Hub               string
    		Tag               string
    		ImagePullSecrets  []string
    		Revision          string
    	}{
    		IstioNamespace:    ocArgs.istioNamespace,
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sat Dec 17 02:25:04 GMT 2022
    - 3.8K bytes
    - Viewed (0)
  8. internal/amztime/iso8601_time.go

    const (
    	iso8601TimeFormat     = "2006-01-02T15:04:05.000Z"    // Reply date format with millisecond precision.
    	iso8601TimeFormatLong = "2006-01-02T15:04:05.000000Z" // Reply date format with nanosecond precision.
    )
    
    // ISO8601Format converts time 't' into ISO8601 time format expected in AWS S3 spec.
    //
    // This function is needed to avoid a Go's float64 precision bug, where Go avoids
    // padding the extra '0' before the timezone.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Jan 16 23:38:33 GMT 2023
    - 1.9K bytes
    - Viewed (0)
  9. istioctl/pkg/multixds/gather.go

    		retval.Resources = append(retval.Resources, response.Resources...)
    	}
    
    	return &retval, nil
    }
    
    func makeSan(istioNamespace, revision string) string {
    	if revision == "" {
    		return fmt.Sprintf("istiod.%s.svc", istioNamespace)
    	}
    	return fmt.Sprintf("istiod-%s.%s.svc", revision, istioNamespace)
    }
    
    // AllRequestAndProcessXds returns all XDS responses from 1 central or 1..N K8s cluster-based XDS servers
    // nolint: lll
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Mar 08 08:38:19 GMT 2024
    - 13.6K bytes
    - Viewed (0)
  10. istioctl/pkg/checkinject/checkinject.go

    		}
    		row.Cells = append(row.Cells, table.NewCell(wa.Name), table.NewCell(wa.Revision))
    		if wa.Injected {
    			row.Cells = append(row.Cells, table.NewCell("✔", color.FgGreen))
    		} else {
    			row.Cells = append(row.Cells, table.NewCell("✘", color.FgRed))
    		}
    		row.Cells = append(row.Cells, table.NewCell(wa.Reason))
    		return row
    	})
    	w.AddHeader("WEBHOOK", "REVISION", "INJECTED", "REASON")
    	injectedTotal := 0
    	for _, ws := range was {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sat Apr 13 05:23:38 GMT 2024
    - 9.3K bytes
    - Viewed (0)
Back to top