Search Options

Results per page
Sort
Preferred Languages
Advance

Results 401 - 410 of 1,425 for Func (0.03 sec)

  1. internal/lock/lock_windows.go

    	// paths or paths containing .. elements. For now,
    	// \\server\share paths are not converted to
    	// \\?\UNC\server\share paths because the rules for doing so
    	// are less well-specified.
    	if len(path) >= 2 && path[:2] == `\\` {
    		// Don't canonicalize UNC paths.
    		return path
    	}
    	if !filepath.IsAbs(path) {
    		// Relative path
    		return path
    	}
    
    	const prefix = `\\?`
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 18 18:08:15 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  2. cmd/metrics.go

    			closer.Close()
    		}
    	})
    }
    
    // NoAuthMiddleware no auth middle ware.
    func NoAuthMiddleware(h http.Handler) http.Handler {
    	return h
    }
    
    // AuthMiddleware checks if the bearer token is valid and authorized.
    func AuthMiddleware(h http.Handler) http.Handler {
    	return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    		tc, ok := r.Context().Value(mcontext.ContextTraceKey).(*mcontext.TraceCtxt)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  3. docs/debugging/reorder-disks/main.go

    		}
    		result[s[2]] = s[9]
    	}
    
    	if err := scanner.Err(); err != nil {
    		return nil, err
    	}
    
    	return result, nil
    }
    
    func getDiskUUIDMap() (map[string]string, error) {
    	result := make(map[string]string)
    	err := filepath.Walk("/dev/disk/by-uuid/",
    		func(path string, info os.FileInfo, err error) error {
    			if err != nil {
    				return err
    			}
    			realPath, err := filepath.EvalSymlinks(path)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  4. schema/naming_test.go

    	}
    }
    
    type CustomReplacer struct {
    	f func(string) string
    }
    
    func (r CustomReplacer) Replace(name string) string {
    	return r.f(name)
    }
    
    func TestCustomReplacer(t *testing.T) {
    	ns := NamingStrategy{
    		TablePrefix:   "public.",
    		SingularTable: true,
    		NameReplacer: CustomReplacer{
    			func(name string) string {
    				replaced := "REPLACED_" + strings.ToUpper(name)
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Tue May 30 02:00:48 UTC 2023
    - 7K bytes
    - Viewed (0)
  5. cmd/signature-v2_test.go

    package cmd
    
    import (
    	"context"
    	"fmt"
    	"net/http"
    	"net/url"
    	"os"
    	"sort"
    	"testing"
    )
    
    // Tests for 'func TestResourceListSorting(t *testing.T)'.
    func TestResourceListSorting(t *testing.T) {
    	sortedResourceList := make([]string, len(resourceList))
    	copy(sortedResourceList, resourceList)
    	sort.Strings(sortedResourceList)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 14 10:08:40 UTC 2022
    - 8K bytes
    - Viewed (0)
  6. internal/event/rules_test.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 event
    
    import (
    	"reflect"
    	"testing"
    )
    
    func TestNewPattern(t *testing.T) {
    	testCases := []struct {
    		prefix         string
    		suffix         string
    		expectedResult string
    	}{
    		{"", "", ""},
    		{"*", "", "*"},
    		{"", "*", "*"},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 8.8K bytes
    - Viewed (0)
  7. internal/crypto/sse.go

    // and no Type.
    func IsRequested(h http.Header) (Type, bool) {
    	switch {
    	case S3.IsRequested(h):
    		return S3, true
    	case S3KMS.IsRequested(h):
    		return S3KMS, true
    	case SSEC.IsRequested(h):
    		return SSEC, true
    	default:
    		return nil, false
    	}
    }
    
    // Requested returns whether any type of encryption is requested.
    func Requested(h http.Header) bool {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 30 15:26:43 UTC 2022
    - 4.4K bytes
    - Viewed (0)
  8. internal/grid/types_test.go

    	}
    	if !reflect.DeepEqual(v, v2) {
    		t.Errorf("MSS: %v != %v", v, v2)
    	}
    }
    
    func BenchmarkMarshalMsgMSS(b *testing.B) {
    	v := MSS{"abc": "def", "ghi": "jkl"}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgMSS(b *testing.B) {
    	v := MSS{"abc": "def", "ghi": "jkl"}
    	bts := make([]byte, 0, v.Msgsize())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Nov 21 01:09:35 UTC 2023
    - 3.7K bytes
    - Viewed (0)
  9. cni/pkg/util/podutil.go

    func PodRedirectionActive(pod *corev1.Pod) bool {
    	return pod.GetAnnotations()[annotation.AmbientRedirection.Name] == constants.AmbientRedirectionEnabled
    }
    
    func podHasSidecar(pod *corev1.Pod) bool {
    	if _, f := pod.GetAnnotations()[annotation.SidecarStatus.Name]; f {
    		return true
    	}
    	return false
    }
    
    func IsZtunnelPod(systemNs string, pod *corev1.Pod) bool {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  10. cmd/encryption-v1.go

    	return encrypted, nil
    }
    
    type (
    	objectMetaEncryptFn func(baseKey string, data []byte) []byte
    	objectMetaDecryptFn func(baseKey string, data []byte) ([]byte, error)
    )
    
    // metadataEncrypter returns a function that will read data from input,
    // encrypt it using the provided key and return the result.
    // 0 sized inputs are passed through.
    func metadataEncrypter(key crypto.ObjectKey) objectMetaEncryptFn {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:06:08 UTC 2024
    - 37.2K bytes
    - Viewed (0)
Back to top