Search Options

Results per page
Sort
Preferred Languages
Advance

Results 901 - 910 of 1,384 for funcs (0.02 sec)

  1. istioctl/pkg/util/common.go

    // CommandParseError distinguishes an error parsing istioctl CLI arguments from an error processing
    type CommandParseError struct {
    	Err error
    }
    
    func (c CommandParseError) Error() string {
    	return c.Err.Error()
    }
    
    // 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)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Jun 15 15:02:17 UTC 2023
    - 1.6K bytes
    - Viewed (0)
  2. cni/pkg/repair/repair.go

    package repair
    
    import (
    	"context"
    
    	"istio.io/istio/cni/pkg/config"
    	"istio.io/istio/cni/pkg/scopes"
    	"istio.io/istio/pkg/kube"
    )
    
    var repairLog = scopes.CNIAgent
    
    func StartRepair(ctx context.Context, cfg config.RepairConfig) {
    	if !cfg.Enabled {
    		repairLog.Info("CNI repair controller is disabled")
    		return
    	}
    	repairLog.Info("starting CNI sidecar repair controller")
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jun 28 19:12:54 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  3. cmd/bucket-replication-utils_gen.go

    }
    
    // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
    func (z MRFReplicateEntry) Msgsize() (s int) {
    	s = 1 + 2 + msgp.StringPrefixSize + len(z.Bucket) + 2 + msgp.StringPrefixSize + len(z.Object) + 3 + msgp.IntSize
    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *ReplicateDecision) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Mar 21 17:21:35 UTC 2024
    - 61.1K bytes
    - Viewed (0)
  4. internal/handlers/proxy_test.go

    package handlers
    
    import (
    	"net/http"
    	"testing"
    )
    
    type headerTest struct {
    	key      string // header key
    	val      string // header val
    	expected string // expected result
    }
    
    func TestGetScheme(t *testing.T) {
    	headers := []headerTest{
    		{xForwardedProto, "https", "https"},
    		{xForwardedProto, "http", "http"},
    		{xForwardedProto, "HTTP", "http"},
    		{xForwardedScheme, "https", "https"},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Dec 22 00:56:55 UTC 2023
    - 3.2K bytes
    - Viewed (0)
  5. internal/ioutil/read_file.go

    // A successful call returns err == nil, not err == EOF.
    // Because ReadFile reads the whole file, it does not treat an EOF from Read
    // as an error to be reported.
    func ReadFileWithFileInfo(name string) ([]byte, fs.FileInfo, error) {
    	f, err := OsOpenFile(name, readMode, 0o666)
    	if err != nil {
    		return nil, nil, err
    	}
    	defer f.Close()
    
    	st, err := f.Stat()
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Dec 09 18:17:51 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  6. cmd/namespace-lock_test.go

    // following test. Adding new code before this test or changing its
    // position will cause the line number to change and the test to FAIL
    // Tests getSource().
    func TestGetSource(t *testing.T) {
    	currentSource := func() string { return getSource(2) }
    	gotSource := currentSource()
    	// Hard coded line number, 35, in the "expectedSource" value
    	expectedSource := "[namespace-lock_test.go:35:TestGetSource()]"
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 23 18:58:53 UTC 2021
    - 3.1K bytes
    - Viewed (0)
  7. src/archive/tar/reader.go

    	default:
    		return n, err
    	}
    }
    
    func (fr *regFileReader) WriteTo(w io.Writer) (int64, error) {
    	return io.Copy(w, struct{ io.Reader }{fr})
    }
    
    // logicalRemaining implements fileState.logicalRemaining.
    func (fr regFileReader) logicalRemaining() int64 {
    	return fr.nb
    }
    
    // physicalRemaining implements fileState.physicalRemaining.
    func (fr regFileReader) physicalRemaining() int64 {
    	return fr.nb
    }
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Mar 08 01:59:14 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  8. cmd/http-tracer.go

    // redact LDAP password if part of string
    func redactLDAPPwd(s string) string {
    	parts := ldapPwdRegex.FindStringSubmatch(s)
    	if len(parts) > 3 {
    		return parts[1] + "LDAPPassword=*REDACTED*" + parts[3]
    	}
    	return s
    }
    
    // getOpName sanitizes the operation name for mc
    func getOpName(name string) (op string) {
    	op = strings.TrimPrefix(name, "github.com/minio/minio/cmd.")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 6K bytes
    - Viewed (0)
  9. internal/logger/audit.go

    // SetAuditEntry sets Audit info in the context.
    func SetAuditEntry(ctx context.Context, audit *audit.Entry) context.Context {
    	if ctx == nil {
    		LogIf(context.Background(), "audit", fmt.Errorf("context is nil"))
    		return nil
    	}
    	return context.WithValue(ctx, contextAuditKey, audit)
    }
    
    // GetAuditEntry returns Audit entry if set.
    func GetAuditEntry(ctx context.Context) *audit.Entry {
    	if ctx != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  10. cni/pkg/log/uds_test.go

    	"os"
    	"path/filepath"
    	"strings"
    	"testing"
    	"time"
    
    	"istio.io/istio/cni/pkg/constants"
    	istiolog "istio.io/istio/pkg/log"
    	"istio.io/istio/pkg/ptr"
    	"istio.io/istio/pkg/test/util/assert"
    )
    
    func TestUDSLog(t *testing.T) {
    	// Start UDS log server
    	udsSockDir := t.TempDir()
    	udsSock := filepath.Join(udsSockDir, "cni.sock")
    	logger := NewUDSLogger(istiolog.DebugLevel)
    	stop := make(chan struct{})
    	defer close(stop)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Jun 12 16:26:28 UTC 2024
    - 4.1K bytes
    - Viewed (0)
Back to top