Search Options

Results per page
Sort
Preferred Languages
Advance

Results 531 - 540 of 1,387 for funcs (0.04 sec)

  1. cmd/xl-storage.go

    }
    
    // Implements stringer compatible interface.
    func (s *xlStorage) String() string {
    	return s.drivePath
    }
    
    func (s *xlStorage) Hostname() string {
    	return s.endpoint.Host
    }
    
    func (s *xlStorage) Endpoint() Endpoint {
    	return s.endpoint
    }
    
    func (s *xlStorage) Close() error {
    	s.immediatePurgeCancel()
    	return nil
    }
    
    func (s *xlStorage) IsOnline() bool {
    	return true
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
  2. schema/schema_helper_test.go

    				}
    			}
    
    			if !found {
    				t.Errorf("schema %v failed to found primary key: %v", s, field)
    			}
    		}
    	})
    }
    
    func checkSchemaField(t *testing.T, s *schema.Schema, f *schema.Field, fc func(*schema.Field)) {
    	t.Run("CheckField/"+f.Name, func(t *testing.T) {
    		if fc != nil {
    			fc(f)
    		}
    
    		if f.TagSettings == nil {
    			if f.Tag != "" {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Fri Dec 15 08:31:23 UTC 2023
    - 7.5K bytes
    - Viewed (0)
  3. istioctl/pkg/writer/envoy/configdump/cluster.go

    	_, _ = fmt.Fprintln(c.Stdout, string(out))
    	return nil
    }
    
    func (c *ConfigWriter) setupClusterConfigWriter() (*tabwriter.Writer, []*cluster.Cluster, error) {
    	clusters, err := c.retrieveSortedClusterSlice()
    	if err != nil {
    		return nil, nil, err
    	}
    	w := new(tabwriter.Writer).Init(c.Stdout, 0, 8, 5, ' ', 0)
    	return w, clusters, nil
    }
    
    func (c *ConfigWriter) retrieveSortedClusterSlice() ([]*cluster.Cluster, error) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu May 11 05:38:17 UTC 2023
    - 5.9K bytes
    - Viewed (0)
  4. src/archive/zip/writer.go

    type countWriter struct {
    	w     io.Writer
    	count int64
    }
    
    func (w *countWriter) Write(p []byte) (int, error) {
    	n, err := w.w.Write(p)
    	w.count += int64(n)
    	return n, err
    }
    
    type nopCloser struct {
    	io.Writer
    }
    
    func (w nopCloser) Close() error {
    	return nil
    }
    
    type writeBuf []byte
    
    func (b *writeBuf) uint8(v uint8) {
    	(*b)[0] = v
    	*b = (*b)[1:]
    }
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Sep 23 14:32:33 UTC 2024
    - 19.4K bytes
    - Viewed (0)
  5. internal/kms/secret-key.go

    // from a single key.
    type secretKey struct {
    	keyID string
    	key   []byte
    }
    
    // Version returns the version of the builtin KMS.
    func (secretKey) Version(ctx context.Context) (string, error) { return "v1", nil }
    
    // APIs returns an error since the builtin KMS does not provide a list of APIs.
    func (secretKey) APIs(ctx context.Context) ([]madmin.KMSAPI, error) {
    	return nil, ErrNotSupported
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Aug 18 06:43:03 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  6. istioctl/pkg/writer/compare/sds/writer_test.go

    		},
    	}
    	for _, tt := range tests {
    		t.Run(tt.name, func(t *testing.T) {
    			w := &bytes.Buffer{}
    			mockWriter := NewSDSWriter(w, tt.format)
    			err := mockWriter.PrintSecretItems(tt.items)
    			if err != nil {
    				t.Errorf("error printing secret items: %v", err)
    			}
    			checkOutput(t, w.String(), tt.expected, tt.unexpected)
    		})
    	}
    }
    
    func TestSDSWriterSecretDiff(t *testing.T) {
    	tests := []struct {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri May 29 20:42:01 UTC 2020
    - 4.9K bytes
    - Viewed (0)
  7. api/go1.21.txt

    pkg slices, func Reverse[$0 interface{ ~[]$1 }, $1 interface{}]($0) #58565
    pkg slices, func Sort[$0 interface{ ~[]$1 }, $1 cmp.Ordered]($0) #60091
    pkg slices, func SortFunc[$0 interface{ ~[]$1 }, $1 interface{}]($0, func($1, $1) int) #60091
    pkg slices, func SortStableFunc[$0 interface{ ~[]$1 }, $1 interface{}]($0, func($1, $1) int) #60091
    pkg strings, func ContainsFunc(string, func(int32) bool) bool #54386
    pkg sync, func OnceFunc(func()) func() #56102
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Aug 07 09:39:17 UTC 2023
    - 25.6K bytes
    - Viewed (0)
  8. istioctl/pkg/writer/envoy/configdump/ecds.go

    	"text/tabwriter"
    
    	core "github.com/envoyproxy/go-control-plane/envoy/config/core/v3"
    	"sigs.k8s.io/yaml"
    
    	"istio.io/istio/pkg/util/protomarshal"
    )
    
    const typeURLPrefix = "type.googleapis.com/"
    
    func (c *ConfigWriter) PrintEcds(outputFormat string) error {
    	if c.configDump == nil {
    		return fmt.Errorf("config writer has not been primed")
    	}
    
    	dump, err := c.configDump.GetEcdsConfigDump()
    	if err != nil {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Sat Jan 14 02:41:27 UTC 2023
    - 2.6K bytes
    - Viewed (0)
  9. istioctl/pkg/util/configdump/listener.go

    	listener "github.com/envoyproxy/go-control-plane/envoy/config/listener/v3"
    
    	v3 "istio.io/istio/pilot/pkg/xds/v3"
    )
    
    // GetDynamicListenerDump retrieves a listener dump with just dynamic active listeners in it
    func (w *Wrapper) GetDynamicListenerDump(stripVersions bool) (*admin.ListenersConfigDump, error) {
    	listenerDump, err := w.GetListenerConfigDump()
    	if err != nil {
    		return nil, err
    	}
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Nov 03 08:41:32 UTC 2022
    - 2.5K bytes
    - Viewed (0)
  10. internal/s3select/json/reader.go

    	return dstRec, nil
    }
    
    // Close - closes underlying reader.
    func (r *Reader) Close() error {
    	// Close the input.
    	err := r.readCloser.Close()
    	for range r.valueCh {
    		// Drain values so we don't leak a goroutine.
    		// Since we have closed the input, it should fail rather quickly.
    	}
    	return err
    }
    
    // NewReader - creates new JSON reader using readCloser.
    func NewReader(readCloser io.ReadCloser, args *ReaderArgs) *Reader {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 3.2K bytes
    - Viewed (0)
Back to top