- Sort Score
- Result 10 results
- Languages All
Results 281 - 290 of 1,425 for Func (0.05 sec)
-
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) -
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) -
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) -
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) -
cni/pkg/plugin/sidecar_redirect.go
invalidDrop bool } type annotationValidationFunc func(value string) error type annotationParam struct { key string defaultVal string validator annotationValidationFunc } func alwaysValidFunc(value string) error { return nil } // validateInterceptionMode validates the interceptionMode annotation func validateInterceptionMode(mode string) error { switch mode {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Fri Jan 26 20:34:28 UTC 2024 - 10.6K bytes - Viewed (0) -
api/go1.11.txt
pkg regexp/syntax, method (Op) String() string pkg runtime/trace, func IsEnabled() bool pkg runtime/trace, func Log(context.Context, string, string) pkg runtime/trace, func Logf(context.Context, string, string, ...interface{}) pkg runtime/trace, func NewTask(context.Context, string) (context.Context, *Task) pkg runtime/trace, func StartRegion(context.Context, string) *Region pkg runtime/trace, func WithRegion(context.Context, string, func())
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Wed Aug 22 03:48:56 UTC 2018 - 25K bytes - Viewed (0) -
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) -
internal/s3select/sql/utils.go
return e.strippedPathExpr } func (e *JSONPathElement) String() string { switch { case e.Key != nil: return e.Key.String() case e.Index != nil: return fmt.Sprintf("[%d]", *e.Index) case e.ObjectWildcard: return ".*" case e.ArrayWildcard: return "[*]" } return "" } // String removes double quotes in quoted identifiers func (i *Identifier) String() string { if i.Unquoted != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Nov 10 16:12:50 UTC 2021 - 3.6K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/endpoint.go
return false } return true } func retrieveEndpointStatus(ep *endpoint.LbEndpoint) core.HealthStatus { return ep.GetHealthStatus() } func retrieveEndpointPort(ep *endpoint.LbEndpoint) uint32 { return ep.GetEndpoint().GetAddress().GetSocketAddress().GetPortValue() } func retrieveEndpointAddresses(ep *endpoint.LbEndpoint) []string {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Mon Jul 22 09:57:29 UTC 2024 - 6.1K bytes - Viewed (0) -
internal/s3select/jstream/decoder.go
func (d *Decoder) Pos() int { return int(d.pos) } // Err returns the most recent decoder error if any, or nil func (d *Decoder) Err() error { return d.err } // MaxDepth will set the maximum recursion depth. // If the maximum depth is exceeded, ErrMaxDepth is returned. // Less than or 0 means no limit (default). func (d *Decoder) MaxDepth(n int) *Decoder { d.maxDepth = n return d }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 13.5K bytes - Viewed (0)