Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 286 for rubble (0.22 sec)

  1. internal/bucket/lifecycle/rule.go

    	}
    	if !r.Prefix.set {
    		return r.Filter.Validate()
    	}
    	return nil
    }
    
    func (r Rule) validateTransition() error {
    	return r.Transition.Validate()
    }
    
    func (r Rule) validateNoncurrentTransition() error {
    	return r.NoncurrentVersionTransition.Validate()
    }
    
    // GetPrefix - a rule can either have prefix under <rule></rule>, <filter></filter>
    // or under <filter><and></and></filter>. This method returns the prefix from the
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Nov 21 17:48:06 GMT 2023
    - 5K bytes
    - Viewed (0)
  2. internal/bucket/lifecycle/rule_test.go

                                  <Status></Status>
    	                    </Rule>`,
    			expectedErr: errEmptyRuleStatus,
    		},
    		{ // Rule with invalid status
    			inputXML: ` <Rule>
    			                  <ID>rule with invalid status</ID>
                                  <Status>OK</Status>
    	                    </Rule>`,
    			expectedErr: errInvalidRuleStatus,
    		},
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Nov 22 21:42:39 GMT 2023
    - 4.1K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/collect/MinMaxPriorityQueue.java

        // comparisons with toTrickle, but in some cases we will need to bubble it
        // all the way up again.
        int vacated = heap.fillHoleAt(index);
        // Try to see if toTrickle can be bubbled up min levels.
        int bubbledTo = heap.bubbleUpAlternatingLevels(vacated, toTrickle);
        if (bubbledTo == vacated) {
          // Could not bubble toTrickle up min levels, try moving
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 22 21:19:52 GMT 2024
    - 34K bytes
    - Viewed (0)
  4. istioctl/pkg/util/formatting/formatter_test.go

    		"Error [B1] (SoapBubble) Explosion accident: the bubble is too big\n" +
    			"Warning [C1] (GrandCastle) Collapse danger: the castle is too old",
    	))
    }
    
    func TestFormatter_PrintLogWithColor(t *testing.T) {
    	g := NewWithT(t)
    
    	firstMsg := diag.NewMessage(
    		diag.NewMessageType(diag.Error, "B1", "Explosion accident: %v"),
    		diag.MockResource("SoapBubble"),
    		"the bubble is too big",
    	)
    	secondMsg := diag.NewMessage(
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Tue Oct 31 14:48:28 GMT 2023
    - 4.1K bytes
    - Viewed (0)
  5. cmd/signature-v2.go

    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"crypto/hmac"
    	"crypto/sha1"
    	"crypto/subtle"
    	"encoding/base64"
    	"fmt"
    	"net/http"
    	"net/url"
    	"sort"
    	"strconv"
    	"strings"
    
    	xhttp "github.com/minio/minio/internal/http"
    
    	"github.com/minio/minio/internal/auth"
    )
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 12.2K bytes
    - Viewed (0)
  6. cmd/sftp-server.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"context"
    	"crypto/subtle"
    	"errors"
    	"fmt"
    	"net"
    	"os"
    	"strconv"
    	"strings"
    	"time"
    
    	"github.com/minio/minio/internal/logger"
    	xsftp "github.com/minio/pkg/v2/sftp"
    	"github.com/pkg/sftp"
    	"golang.org/x/crypto/ssh"
    )
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 5.6K bytes
    - Viewed (0)
  7. cni/pkg/plugin/sidecar_intercept_rule_mgr.go

    Ben Leggett <******@****.***> 1707525115 -0500
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Sat Feb 10 00:31:55 GMT 2024
    - 940 bytes
    - Viewed (0)
  8. internal/bucket/replication/replication.go

    	if len(c.Rules) == 0 {
    		return false
    	}
    	for _, rule := range c.Rules {
    		if rule.Status == Disabled {
    			continue
    		}
    		if len(prefix) > 0 && len(rule.Filter.Prefix) > 0 {
    			// incoming prefix must be in rule prefix
    			if !recursive && !strings.HasPrefix(prefix, rule.Filter.Prefix) {
    				continue
    			}
    			// If recursive, we can skip this rule if it doesn't match the tested prefix or level below prefix
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Mar 28 17:44:56 GMT 2024
    - 8.9K bytes
    - Viewed (0)
  9. okhttp-testing-support/src/main/kotlin/okhttp3/TestUtilJvm.kt

      }
    
      /**
       * Okio buffers are internally implemented as a linked list of arrays. Usually this implementation
       * detail is invisible to the caller, but subtle use of certain APIs may depend on these internal
       * structures.
       *
       * We make such subtle calls in [okhttp3.internal.ws.MessageInflater] because we try to read a
       * compressed stream that is terminated in a web socket frame even though the DEFLATE stream is
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Thu Apr 11 22:09:35 GMT 2024
    - 4.3K bytes
    - Viewed (0)
  10. internal/bucket/lifecycle/lifecycle_test.go

    			expectedParsingErr:    nil,
    			expectedValidationErr: nil,
    		},
    		// Lifecycle with empty Filter tag
    		{
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Mar 09 06:41:22 GMT 2024
    - 45.6K bytes
    - Viewed (0)
Back to top