Search Options

Results per page
Sort
Preferred Languages
Advance

Results 721 - 730 of 1,425 for Func (0.04 sec)

  1. src/bufio/export_test.go

    )
    
    var IsSpace = isSpace
    
    const DefaultBufSize = defaultBufSize
    
    func (s *Scanner) MaxTokenSize(n int) {
    	if n < utf8.UTFMax || n > 1e9 {
    		panic("bad max token size")
    	}
    	if n < len(s.buf) {
    		s.buf = make([]byte, n)
    	}
    	s.maxTokenSize = n
    }
    
    // ErrOrEOF is like Err, but returns EOF. Used to test a corner case.
    func (s *Scanner) ErrOrEOF() error {
    	return s.err
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Nov 02 17:17:44 UTC 2017
    - 597 bytes
    - Viewed (0)
  2. cmd/post-policy_test.go

    	retStr += conditionStr
    	retStr += "}"
    
    	return []byte(retStr)
    }
    
    // Wrapper
    func TestPostPolicyReservedBucketExploit(t *testing.T) {
    	ExecObjectLayerTestWithDirs(t, testPostPolicyReservedBucketExploit)
    }
    
    // testPostPolicyReservedBucketExploit is a test for the exploit fixed in PR
    // #16849
    func testPostPolicyReservedBucketExploit(obj ObjectLayer, instanceType string, dirs []string, t TestErrHandler) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 22 23:07:14 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  3. internal/logger/target/console/console.go

    	output io.Writer
    }
    
    // Validate - validate if the tty can be written to
    func (c *Target) Validate() error {
    	return nil
    }
    
    // Endpoint returns the backend endpoint
    func (c *Target) Endpoint() string {
    	return ""
    }
    
    func (c *Target) String() string {
    	return "console"
    }
    
    // Send log message 'e' to console
    func (c *Target) Send(e interface{}) error {
    	entry, ok := e.(log.Entry)
    	if !ok {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  4. internal/s3select/sql/stringfuncs.go

    		if len(parts) == 1 {
    			return "", false
    		}
    		res = parts[1]
    	}
    	return res, true
    }
    
    func dropRune(text string) (res string, ok bool) {
    	r := []rune(text)
    	if len(r) == 0 {
    		return "", false
    	}
    	return string(r[1:]), true
    }
    
    func evalSQLSubstring(s string, startIdx, length int) (res string, err error) {
    	rs := []rune(s)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 4.2K bytes
    - Viewed (0)
  5. cmd/healthcheck-handler.go

    package cmd
    
    import (
    	"context"
    	"net/http"
    	"strconv"
    	"time"
    
    	xhttp "github.com/minio/minio/internal/http"
    	"github.com/minio/minio/internal/kms"
    )
    
    const unavailable = "offline"
    
    func checkHealth(w http.ResponseWriter) ObjectLayer {
    	objLayer := newObjectLayerFn()
    	if objLayer == nil {
    		w.Header().Set(xhttp.MinIOServerStatus, unavailable)
    		writeResponse(w, http.StatusServiceUnavailable, nil, mimeNone)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 26 07:44:34 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  6. cmd/httprange.go

    func (h *HTTPRangeSpec) String(resourceSize int64) string {
    	if h == nil {
    		return ""
    	}
    	off, length, err := h.GetOffsetLength(resourceSize)
    	if err != nil {
    		return ""
    	}
    	return fmt.Sprintf("%d-%d", off, off+length-1)
    }
    
    // ToHeader returns the Range header value.
    func (h *HTTPRangeSpec) ToHeader() (string, error) {
    	if h == nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 09 08:44:07 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  7. internal/config/lambda/parse.go

    	"github.com/minio/minio/internal/config/lambda/target"
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/pkg/v3/env"
    	xnet "github.com/minio/pkg/v3/net"
    )
    
    const (
    	logSubsys = "notify"
    )
    
    func logOnceIf(ctx context.Context, err error, id string, errKind ...interface{}) {
    	logger.LogOnceIf(ctx, logSubsys, err, id, errKind...)
    }
    
    // ErrTargetsOffline - Indicates single/multiple target failures.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6K bytes
    - Viewed (0)
  8. istioctl/pkg/describe/describe_test.go

       Match: /prefix*
    `,
    		},
    	}
    
    	for i, c := range cases {
    		t.Run(fmt.Sprintf("case %d %s", i, strings.Join(c.args, " ")), func(t *testing.T) {
    			verifyExecAndK8sConfigTestCaseTestOutput(t, c)
    		})
    	}
    }
    
    func TestGetRevisionFromPodAnnotation(t *testing.T) {
    	cases := []struct {
    		anno klabels.Set
    
    		expected string
    	}{
    		{
    			anno: klabels.Set{
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 01 20:04:20 UTC 2024
    - 30.8K bytes
    - Viewed (0)
  9. internal/event/target/redis.go

    	quitCh     chan struct{}
    }
    
    // ID - returns target ID.
    func (target *RedisTarget) ID() event.TargetID {
    	return target.id
    }
    
    // Name - returns the Name of the target.
    func (target *RedisTarget) Name() string {
    	return target.ID().String()
    }
    
    // Store returns any underlying store if set.
    func (target *RedisTarget) Store() event.TargetStore {
    	return target.store
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  10. cni/pkg/nodeagent/netns.go

    	netns io.Closer
    	fd    uintptr
    	inode uint64
    }
    
    func (n *NetnsWithFd) Close() error {
    	if n.netns == nil {
    		return nil
    	}
    
    	ret := n.netns.Close()
    	// set fd to invalid value, so if something uses it by mistake it will err
    	uintZero := uintptr(0)
    	n.fd = ^uintZero
    	return ret
    }
    
    func (n *NetnsWithFd) Fd() uintptr {
    	return n.fd
    }
    
    func (n *NetnsWithFd) Inode() uint64 {
    	return n.inode
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jan 26 20:34:28 UTC 2024
    - 1.2K bytes
    - Viewed (0)
Back to top