Search Options

Results per page
Sort
Preferred Languages
Advance

Results 571 - 580 of 1,387 for funcs (0.03 sec)

  1. cni/pkg/install/cniconfig.go

    	"sort"
    	"strings"
    
    	"github.com/containernetworking/cni/libcni"
    
    	"istio.io/istio/cni/pkg/config"
    	"istio.io/istio/cni/pkg/plugin"
    	"istio.io/istio/cni/pkg/util"
    	"istio.io/istio/pkg/file"
    )
    
    func createCNIConfigFile(ctx context.Context, cfg *config.InstallConfig) (string, error) {
    	pluginConfig := plugin.Config{
    		PluginLogLevel:    cfg.PluginLogLevel,
    		CNIAgentRunDir:    cfg.CNIAgentRunDir,
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 01 18:38:14 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  2. cni/pkg/iptables/iptables_unspecified.go

    package iptables
    
    import (
    	"errors"
    )
    
    func AddInpodMarkIPRule(cfg *Config) error {
    	return errors.New("not implemented on this platform")
    }
    
    func DelInpodMarkIPRule(cfg *Config) error {
    	return errors.New("not implemented on this platform")
    }
    
    func AddLoopbackRoutes(cfg *Config) error {
    	return errors.New("not implemented on this platform")
    }
    
    func DelLoopbackRoutes(cfg *Config) error {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jan 26 20:34:28 UTC 2024
    - 1K bytes
    - Viewed (0)
  3. cmd/tier_gen.go

    package cmd
    
    // Code generated by github.com/tinylib/msgp DO NOT EDIT.
    
    import (
    	"github.com/minio/madmin-go/v3"
    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *TierConfigMgr) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, err = dc.ReadMapHeader()
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	for zb0001 > 0 {
    		zb0001--
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 20 00:53:08 UTC 2023
    - 4K bytes
    - Viewed (0)
  4. cmd/warm-backend.go

    const (
    	_ tierOp = iota
    	tierGet
    	tierPut
    	tierDelete
    )
    
    func (op tierOp) String() string {
    	switch op {
    	case tierGet:
    		return "GET"
    	case tierPut:
    		return "PUT"
    	case tierDelete:
    		return "DELETE"
    	}
    	return "UNKNOWN"
    }
    
    type tierPermErr struct {
    	Op  tierOp
    	Err error
    }
    
    func (te tierPermErr) Error() string {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 4K bytes
    - Viewed (0)
  5. istioctl/pkg/kubeinject/kubeinject_test.go

    		},
    	}
    
    	kubeInject := InjectCommand(cli.NewFakeContext(nil))
    	for i, c := range cases {
    		t.Run(fmt.Sprintf("case %d %s", i, strings.Join(c.Args, " ")), func(t *testing.T) {
    			testutil.VerifyOutput(t, kubeInject, c)
    			cleanUpKubeInjectTestEnv()
    		})
    	}
    }
    
    func cleanUpKubeInjectTestEnv() {
    	meshConfigFile = ""
    	injectConfigFile = ""
    	valuesFile = ""
    	inFilename = ""
    	iopFilename = ""
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Jun 15 15:02:17 UTC 2023
    - 3.4K bytes
    - Viewed (0)
  6. src/cmd/asm/internal/lex/lex_test.go

    		}
    	}
    }
    
    // lines joins the arguments together as complete lines.
    func lines(a ...string) string {
    	return strings.Join(a, "\n") + "\n"
    }
    
    // drain returns a single string representing the processed input tokens.
    func drain(input *Input) string {
    	var buf strings.Builder
    	for {
    		tok := input.Next()
    		if tok == scanner.EOF {
    			return buf.String()
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Aug 29 07:48:38 UTC 2023
    - 5.8K bytes
    - Viewed (0)
  7. internal/s3select/message.go

    // https://docs.aws.amazon.com/AmazonS3/latest/API/images/s3select-frame-diagram-frame-overview.png
    // hence the calculation is made accordingly.
    func totalByteLength(headerLength, payloadLength int) int {
    	return 4 + 4 + 4 + headerLength + payloadLength + 4
    }
    
    func genMessage(header, payload []byte) []byte {
    	headerLength := len(header)
    	payloadLength := len(payload)
    	totalLength := totalByteLength(headerLength, payloadLength)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 30 15:26:43 UTC 2022
    - 15.2K bytes
    - Viewed (0)
  8. tests/embedded_struct_test.go

    	}
    }
    
    type Content struct {
    	Content interface{} `gorm:"type:String"`
    }
    
    func (c Content) Value() (driver.Value, error) {
    	// mssql driver with issue on handling null bytes https://github.com/denisenkom/go-mssqldb/issues/530,
    	b, err := json.Marshal(c)
    	return string(b[:]), err
    }
    
    func (c *Content) Scan(src interface{}) error {
    	var value Content
    	str, ok := src.(string)
    	if !ok {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed May 08 04:07:58 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  9. cmd/streaming-signature-v4.go

    // Read - implements `io.Reader`, which transparently decodes
    // the incoming AWS Signature V4 streaming signature.
    func (cr *s3ChunkedReader) Read(buf []byte) (n int, err error) {
    	if cr.err != nil {
    		if cr.debug {
    			fmt.Printf("s3ChunkedReader: Returning err: %v (%T)\n", cr.err, cr.err)
    		}
    		return 0, cr.err
    	}
    	defer func() {
    		if err != nil && err != io.EOF {
    			if cr.debug {
    				fmt.Println("Read err:", err)
    			}
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 16 23:13:47 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  10. cmd/auth-handler_test.go

    	"net/url"
    	"os"
    	"testing"
    	"time"
    
    	"github.com/minio/minio/internal/auth"
    	"github.com/minio/pkg/v3/policy"
    )
    
    type nullReader struct{}
    
    func (r *nullReader) Read(b []byte) (int, error) {
    	return len(b), nil
    }
    
    // Test get request auth type.
    func TestGetRequestAuthType(t *testing.T) {
    	type testCase struct {
    		req   *http.Request
    		authT authType
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 15.4K bytes
    - Viewed (0)
Back to top