Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 63 for Mosher (0.21 sec)

  1. internal/hash/checksum.go

    }
    
    // Matches returns whether given content matches c.
    func (c Checksum) Matches(content []byte) error {
    	if len(c.Encoded) == 0 {
    		return nil
    	}
    	hasher := c.Type.Hasher()
    	_, err := hasher.Write(content)
    	if err != nil {
    		return err
    	}
    	sum := hasher.Sum(nil)
    	if !bytes.Equal(sum, c.Raw) {
    		return ChecksumMismatch{
    			Want: c.Encoded,
    			Got:  base64.StdEncoding.EncodeToString(sum),
    		}
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 11.9K bytes
    - Viewed (0)
  2. cmd/iam.go

    			}
    		}
    	}
    
    	err := sys.store.DeletePolicy(ctx, policyName, !notifyPeers)
    	if err != nil {
    		return err
    	}
    
    	if !notifyPeers || sys.HasWatcher() {
    		return nil
    	}
    
    	// Notify all other MinIO peers to delete policy
    	for _, nerr := range globalNotificationSys.DeletePolicy(policyName) {
    		if nerr.Err != nil {
    			logger.GetReqInfo(ctx).SetTags("peerAddress", nerr.Host.String())
    			iamLogIf(ctx, nerr.Err)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 21:28:16 GMT 2024
    - 71.1K bytes
    - Viewed (1)
  3. cmd/untar.go

    				return err
    			}
    		}
    
    		header, err := tarReader.Next()
    		switch {
    
    		// if no more files are found return
    		case err == io.EOF:
    			wg.Wait()
    			return asyncErr
    
    		// return any other error
    		case err != nil:
    			wg.Wait()
    			extra := ""
    			if n > 0 {
    				extra = fmt.Sprintf(" after %d successful object(s)", n)
    			}
    			return fmt.Errorf("tar file error: %w%s", err, extra)
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 6K bytes
    - Viewed (0)
  4. cmd/erasure-object.go

    	if !dstOpts.NoAuditLog {
    		auditObjectErasureSet(ctx, dstObject, &er)
    	}
    
    	// This call shouldn't be used for anything other than metadata updates or adding self referential versions.
    	if !srcInfo.metadataOnly {
    		return oi, NotImplemented{}
    	}
    
    	if !dstOpts.NoLock {
    		lk := er.NewNSLock(dstBucket, dstObject)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
  5. internal/event/name.go

    // Name - event type enum.
    // Refer http://docs.aws.amazon.com/AmazonS3/latest/dev/NotificationHowTo.html#notification-how-to-event-types-and-destinations
    // for most basic values we have since extend this and its not really much applicable other than a reference point.
    // "s3:Replication:OperationCompletedReplication" is a MinIO extension.
    type Name int
    
    // Values of event Name
    const (
    	// Single event types (does not require expansion)
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:11:10 GMT 2024
    - 10.4K bytes
    - Viewed (0)
  6. docs/metrics/prometheus/README.md

    Prometheus sets the `Host` header to `domain:port` as part of HTTP operations against the MinIO metrics endpoint. For MinIO deployments behind a load balancer, reverse proxy, or other control plane (HAProxy, nginx, pfsense, opnsense, etc.), ensure the network service supports routing these requests to the deployment.
    
    ### 6. Configure Grafana
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 12 15:49:30 GMT 2024
    - 7.1K bytes
    - Viewed (0)
  7. cmd/erasure-server-pool.go

    // If the object exists, but the latest version is a delete marker, the index with it is still returned.
    // If the object does not exist ObjectNotFound error is returned.
    // If any other error is found, it is returned.
    // The check is skipped if there is only one pool, and 0, nil is always returned in that case.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  8. cmd/sts-handlers_test.go

    	// 5. Check that service account can be deleted.
    	c.assertSvcAccDeletion(ctx, s, userAdmClient, value.AccessKeyID, bucket)
    
    	// 6. Check that service account cannot be created for some other user.
    	c.mustNotCreateSvcAccount(ctx, globalActiveCred.AccessKey, userAdmClient)
    }
    
    func (s *TestSuiteIAM) TestLDAPSTSServiceAccountsWithUsername(c *check) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 15:50:16 GMT 2024
    - 85.7K bytes
    - Viewed (0)
  9. cmd/metrics.go

    	// Network Sent/Received Bytes (internode)
    	ch <- prometheus.MustNewConstMetric(
    		prometheus.NewDesc(
    			prometheus.BuildFQName(interNodeNamespace, "tx", "bytes_total"),
    			"Total number of bytes sent to the other peer nodes by current MinIO server instance",
    			nil, nil),
    		prometheus.CounterValue,
    		float64(connStats.internodeOutputBytes),
    	)
    
    	ch <- prometheus.MustNewConstMetric(
    		prometheus.NewDesc(
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 02 06:48:36 GMT 2024
    - 16.9K bytes
    - Viewed (0)
  10. cmd/metrics-v2.go

    		Help:      "Total number of bytes sent to the other peer nodes",
    		Type:      counterMetric,
    	}
    }
    
    func getInterNodeReceivedBytesMD() MetricDescription {
    	return MetricDescription{
    		Namespace: interNodeMetricNamespace,
    		Subsystem: trafficSubsystem,
    		Name:      receivedBytes,
    		Help:      "Total number of bytes received from other peer nodes",
    		Type:      counterMetric,
    	}
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 22:01:31 GMT 2024
    - 132.6K bytes
    - Viewed (0)
Back to top