Search Options

Results per page
Sort
Preferred Languages
Advance

Results 291 - 300 of 1,387 for funcs (0.04 sec)

  1. internal/config/lambda/event/targetidset.go

    // IsEmpty returns true if the set is empty.
    func (set TargetIDSet) IsEmpty() bool {
    	return len(set) != 0
    }
    
    // Clone - returns copy of this set.
    func (set TargetIDSet) Clone() TargetIDSet {
    	setCopy := NewTargetIDSet()
    	for k, v := range set {
    		setCopy[k] = v
    	}
    	return setCopy
    }
    
    // add - adds TargetID to the set.
    func (set TargetIDSet) add(targetID TargetID) {
    	set[targetID] = struct{}{}
    }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  2. cni/pkg/iptables/nldeps.go

    }
    
    func (r *realDeps) DelLoopbackRoutes(cfg *Config) error {
    	return DelLoopbackRoutes(cfg)
    }
    
    type emptyDeps struct{}
    
    func EmptyNlDeps() NetlinkDependencies {
    	return &emptyDeps{}
    }
    
    func (r *emptyDeps) AddInpodMarkIPRule(cfg *Config) error {
    	return nil
    }
    
    func (r *emptyDeps) DelInpodMarkIPRule(cfg *Config) error {
    	return nil
    }
    
    func (r *emptyDeps) AddLoopbackRoutes(cfg *Config) error {
    	return nil
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jan 26 20:34:28 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  3. cni/pkg/install/install.go

    }
    
    // NewInstaller returns an instance of Installer with the given config
    func NewInstaller(cfg *config.InstallConfig, isReady *atomic.Value) *Installer {
    	return &Installer{
    		cfg:                cfg,
    		kubeconfigFilepath: filepath.Join(cfg.CNIAgentRunDir, constants.CNIPluginKubeconfName),
    		isReady:            isReady,
    	}
    }
    
    func (in *Installer) installAll(ctx context.Context) (sets.String, error) {
    	// Install binaries
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Aug 09 21:33:51 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  4. cmd/xl-storage-errors.go

    	"errors"
    	"os"
    	"runtime"
    	"syscall"
    )
    
    // No space left on device error
    func isSysErrNoSpace(err error) bool {
    	return errors.Is(err, syscall.ENOSPC)
    }
    
    // Invalid argument, unsupported flags such as O_DIRECT
    func isSysErrInvalidArg(err error) bool {
    	return errors.Is(err, syscall.EINVAL)
    }
    
    // Input/output error
    func isSysErrIO(err error) bool {
    	return errors.Is(err, syscall.EIO)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Mar 06 16:56:29 UTC 2023
    - 3.8K bytes
    - Viewed (0)
  5. internal/s3select/errors.go

    	cause      error
    }
    
    func (err *s3Error) Cause() error {
    	return err.cause
    }
    
    func (err *s3Error) ErrorCode() string {
    	return err.code
    }
    
    func (err *s3Error) ErrorMessage() string {
    	return err.message
    }
    
    func (err *s3Error) HTTPStatusCode() int {
    	return err.statusCode
    }
    
    func (err *s3Error) Error() string {
    	return err.message
    }
    
    func errMalformedXML(err error) *s3Error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Mar 14 16:48:36 UTC 2022
    - 4.3K bytes
    - Viewed (0)
  6. cni/pkg/ipset/nldeps_linux.go

    package ipset
    
    import (
    	"errors"
    	"fmt"
    	"net"
    	"net/netip"
    	"strings"
    
    	"github.com/vishvananda/netlink"
    	"golang.org/x/sys/unix"
    )
    
    func RealNlDeps() NetlinkIpsetDeps {
    	return &realDeps{}
    }
    
    type realDeps struct{}
    
    func (m *realDeps) ipsetIPHashCreate(name string, v6 bool) error {
    	var family uint8
    
    	if v6 {
    		family = unix.AF_INET6
    	} else {
    		family = unix.AF_INET
    	}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Jul 18 23:53:18 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  7. src/cmd/cgo/ast_go118.go

    import (
    	"go/ast"
    	"go/token"
    )
    
    func (f *File) walkUnexpected(x interface{}, context astContext, visit func(*File, interface{}, astContext)) {
    	switch n := x.(type) {
    	default:
    		error_(token.NoPos, "unexpected type %T in walk", x)
    		panic("unexpected type")
    
    	case *ast.IndexListExpr:
    		f.walk(&n.X, ctxExpr, visit)
    		f.walk(n.Indices, ctxExpr, visit)
    	}
    }
    
    func funcTypeTypeParams(n *ast.FuncType) *ast.FieldList {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Nov 30 21:45:10 UTC 2022
    - 730 bytes
    - Viewed (0)
  8. internal/s3select/sql/evaluate.go

    			return nil, err
    		}
    		res[i] = *v
    	}
    	return FromArray(res), nil
    }
    
    const floatCmpTolerance = 0.000001
    
    func (e *In) evalInNode(r Record, lhs *Value, tableAlias string) (*Value, error) {
    	// Compare two values in terms of in-ness.
    	var cmp func(a, b Value) bool
    	cmp = func(a, b Value) bool {
    		// Convert if needed.
    		inferTypesForCmp(&a, &b)
    
    		if a.Equals(b) {
    			return true
    		}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 12K bytes
    - Viewed (0)
  9. misc/linkcheck/linkcheck.go

    	}
    	if crawled[url] {
    		return
    	}
    	crawled[url] = true
    
    	wg.Add(1)
    	go func() {
    		urlq <- url
    	}()
    }
    
    func addProblem(url, errmsg string) {
    	msg := fmt.Sprintf("Error on %s: %s (from %s)", url, errmsg, linkSources[url])
    	if *verbose {
    		log.Print(msg)
    	}
    	problems = append(problems, msg)
    }
    
    func crawlLoop() {
    	for url := range urlq {
    		if err := doCrawl(url); err != nil {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Oct 06 15:53:04 UTC 2021
    - 3.9K bytes
    - Viewed (0)
  10. cni/pkg/nodeagent/ztunnelserver_test.go

    	}
    	return m, fdss
    }
    
    func sendAck(c *net.UnixConn) {
    	ack := &zdsapi.WorkloadResponse{
    		Payload: &zdsapi.WorkloadResponse_Ack{
    			Ack: &zdsapi.Ack{},
    		},
    	}
    	data, err := proto.Marshal(ack)
    	if err != nil {
    		panic(err)
    	}
    	err = c.SetWriteDeadline(time.Now().Add(time.Second))
    	if err != nil {
    		panic(err)
    	}
    	c.Write(data)
    }
    
    func sendHello(c *net.UnixConn) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Apr 12 21:47:31 UTC 2024
    - 8.6K bytes
    - Viewed (0)
Back to top