Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 1,387 for funcs (0.04 sec)

  1. istioctl/pkg/writer/envoy/configdump/listener.go

    	}
    
    	return addrs
    }
    
    func retrieveListenerPort(l *listener.Listener) uint32 {
    	return l.Address.GetSocketAddress().GetPortValue()
    }
    
    func (c *ConfigWriter) PrintRemoteListenerSummary() error {
    	w, listeners, err := c.setupListenerConfigWriter()
    	if err != nil {
    		return err
    	}
    	// Sort by port, addr, type
    	sort.Slice(listeners, func(i, j int) bool {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Nov 29 12:37:14 UTC 2023
    - 18.1K bytes
    - Viewed (0)
  2. clause/where.go

    const (
    	AndWithSpace = " AND "
    	OrWithSpace  = " OR "
    )
    
    // Where where clause
    type Where struct {
    	Exprs []Expression
    }
    
    // Name where clause name
    func (where Where) Name() string {
    	return "WHERE"
    }
    
    // Build build where clause
    func (where Where) Build(builder Builder) {
    	if len(where.Exprs) == 1 {
    		if andCondition, ok := where.Exprs[0].(AndConditions); ok {
    			where.Exprs = andCondition.Exprs
    		}
    	}
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Apr 25 12:22:53 UTC 2024
    - 5.1K bytes
    - Viewed (0)
  3. schema/schema_test.go

    	}
    
    	for i := range fields {
    		checkSchemaField(t, user, &fields[i], func(f *schema.Field) {
    			f.Creatable = true
    			f.Updatable = true
    			f.Readable = true
    		})
    	}
    }
    
    type CustomizeTable struct{}
    
    func (CustomizeTable) TableName() string {
    	return "customize"
    }
    
    func TestCustomizeTableName(t *testing.T) {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Jun 20 12:19:31 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  4. istioctl/pkg/proxyconfig/proxyconfig.go

    	}
    	return debug, err
    }
    
    func setupPodConfigdumpWriter(kubeClient kube.CLIClient, podName, podNamespace string, includeEds bool, out io.Writer) (*configdump.ConfigWriter, error) {
    	debug, err := extractConfigDump(kubeClient, podName, podNamespace, includeEds)
    	if err != nil {
    		return nil, err
    	}
    	return setupConfigdumpEnvoyConfigWriter(debug, out)
    }
    
    func readFile(filename string) ([]byte, error) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Oct 24 15:53:49 UTC 2024
    - 50.6K bytes
    - Viewed (0)
  5. internal/s3select/json/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 errInvalidJSONType(err error) *s3Error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 1.6K bytes
    - Viewed (0)
  6. cmd/config.go

    func (sys *ConfigSys) Init(objAPI ObjectLayer) error {
    	if objAPI == nil {
    		return errInvalidArgument
    	}
    
    	return initConfig(objAPI)
    }
    
    // NewConfigSys - creates new config system object.
    func NewConfigSys() *ConfigSys {
    	return &ConfigSys{}
    }
    
    // Initialize and load config from remote etcd or local config directory
    func initConfig(objAPI ObjectLayer) (err error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 23 10:07:06 UTC 2023
    - 6K bytes
    - Viewed (0)
  7. internal/cachevalue/cache.go

    }
    
    // New allocates a new cached value instance. Tt must be initialized with
    // `.TnitOnce`.
    func New[T any]() *Cache[T] {
    	return &Cache[T]{}
    }
    
    // NewFromFunc allocates a new cached value instance and initializes it with an
    // update function, making it ready for use.
    func NewFromFunc[T any](ttl time.Duration, opts Opts, update func(ctx context.Context) (T, error)) *Cache[T] {
    	return &Cache[T]{
    		ttl:      ttl,
    		updateFn: update,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 12:50:46 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  8. istioctl/pkg/admin/istiodconfig.go

    	client       *ControlzClient
    	outputFormat string
    }
    
    func (ga *getAllLogLevelsState) run(out io.Writer) error {
    	type scopeLogLevel struct {
    		ScopeName   string `json:"scope_name"`
    		LogLevel    string `json:"log_level"`
    		Description string `json:"description"`
    	}
    	allScopes, err := ga.client.GetScopes()
    	sort.Slice(allScopes, func(i, j int) bool {
    		return allScopes[i].Name < allScopes[j].Name
    	})
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Sat Apr 13 05:23:38 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  9. src/bufio/bufio_test.go

    type bufReader struct {
    	name string
    	fn   func(*Reader) string
    }
    
    var bufreaders = []bufReader{
    	{"1", func(b *Reader) string { return reads(b, 1) }},
    	{"2", func(b *Reader) string { return reads(b, 2) }},
    	{"3", func(b *Reader) string { return reads(b, 3) }},
    	{"4", func(b *Reader) string { return reads(b, 4) }},
    	{"5", func(b *Reader) string { return reads(b, 5) }},
    	{"7", func(b *Reader) string { return reads(b, 7) }},
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Nov 01 21:52:12 UTC 2024
    - 51.6K bytes
    - Viewed (0)
  10. cmd/batch-job-common-types_gen.go

    	return
    }
    
    // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
    func (z BatchJobKV) Msgsize() (s int) {
    	s = 1 + 4 + msgp.StringPrefixSize + len(z.Key) + 6 + msgp.StringPrefixSize + len(z.Value)
    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *BatchJobNotification) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Dec 02 10:51:33 UTC 2023
    - 21.9K bytes
    - Viewed (0)
Back to top