Search Options

Results per page
Sort
Preferred Languages
Advance

Results 951 - 960 of 1,384 for funcs (0.02 sec)

  1. cmd/server-main_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"context"
    	"reflect"
    	"testing"
    )
    
    func TestServerConfigFile(t *testing.T) {
    	for _, testcase := range []struct {
    		config      string
    		expectedErr bool
    		hash        string
    	}{
    		{
    			config:      "testdata/config/1.yaml",
    			expectedErr: false,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Dec 07 09:33:56 UTC 2023
    - 3.1K bytes
    - Viewed (0)
  2. cmd/metacache-manager.go

    	trash   map[string]metacache // Recently deleted lists.
    }
    
    const metacacheMaxEntries = 5000
    
    // initManager will start async saving the cache.
    func (m *metacacheManager) initManager() {
    	// Add a transient bucket.
    	// Start saver when object layer is ready.
    	go func() {
    		objAPI := newObjectLayerFn()
    		for objAPI == nil {
    			time.Sleep(time.Second)
    			objAPI = newObjectLayerFn()
    		}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 25 00:44:15 UTC 2022
    - 5.2K bytes
    - Viewed (0)
  3. cmd/xl-storage-format-v1_gen.go

    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *BitrotAlgorithm) DecodeMsg(dc *msgp.Reader) (err error) {
    	{
    		var zb0001 uint
    		zb0001, err = dc.ReadUint()
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		(*z) = BitrotAlgorithm(zb0001)
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    func (z BitrotAlgorithm) EncodeMsg(en *msgp.Writer) (err error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 41.2K bytes
    - Viewed (0)
  4. api/next/66626.txt

    pkg go/types, method (*Interface) EmbeddedTypes() iter.Seq[Type] #66626
    pkg go/types, method (*Interface) ExplicitMethods() iter.Seq[*Func] #66626
    pkg go/types, method (*Interface) Methods() iter.Seq[*Func] #66626
    pkg go/types, method (*MethodSet) Methods() iter.Seq[*Selection] #66626
    pkg go/types, method (*Named) Methods() iter.Seq[*Func] #66626
    pkg go/types, method (*Scope) Children() iter.Seq[*Scope] #66626
    pkg go/types, method (*Struct) Fields() iter.Seq[*Var] #66626
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Jul 31 22:54:09 UTC 2024
    - 743 bytes
    - Viewed (0)
  5. cmd/metacache-server-pool.go

    	"github.com/minio/minio/internal/grid"
    	xioutil "github.com/minio/minio/internal/ioutil"
    )
    
    func renameAllBucketMetacache(epPath string) error {
    	// Rename all previous `.minio.sys/buckets/<bucketname>/.metacache` to
    	// to `.minio.sys/tmp/` for deletion.
    	return readDirFn(pathJoin(epPath, minioMetaBucket, bucketMetaPrefix), func(name string, typ os.FileMode) error {
    		if typ == os.ModeDir {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  6. cmd/scannermetric_string.go

    // Code generated by "stringer -type=scannerMetric -trimprefix=scannerMetric data-scanner-metric.go"; DO NOT EDIT.
    
    package cmd
    
    import "strconv"
    
    func _() {
    	// An "invalid array index" compiler error signifies that the constant values have changed.
    	// Re-run the stringer command to generate them again.
    	var x [1]struct{}
    	_ = x[scannerMetricReadMetadata-0]
    	_ = x[scannerMetricCheckMissing-1]
    	_ = x[scannerMetricSaveUsage-2]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 25 05:15:31 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  7. cmd/bitrot_test.go

    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"context"
    	"io"
    	"testing"
    )
    
    func testBitrotReaderWriterAlgo(t *testing.T, bitrotAlgo BitrotAlgorithm) {
    	tmpDir := t.TempDir()
    
    	volume := "testvol"
    	filePath := "testfile"
    
    	disk, err := newLocalXLStorage(tmpDir)
    	if err != nil {
    		t.Fatal(err)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  8. istioctl/pkg/util/configdump/util.go

    	ecds      configTypeURL = "type.googleapis.com/envoy.admin.v3.EcdsConfigDump"
    )
    
    // getSection takes a TypeURL and returns the types.Any from the config dump corresponding to that URL
    func (w *Wrapper) getSection(sectionTypeURL configTypeURL) (*anypb.Any, error) {
    	var dumpAny *anypb.Any
    	for _, conf := range w.Configs {
    		if conf.TypeUrl == string(sectionTypeURL) {
    			dumpAny = conf
    		}
    	}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Sun Dec 24 08:16:26 UTC 2023
    - 2.1K bytes
    - Viewed (0)
  9. cmd/admin-bucket-handlers.go

    // ----------
    // Places a quota configuration on the specified bucket. The quota
    // specified in the quota configuration will be applied by default
    // to enforce total quota for the specified bucket.
    func (a adminAPIHandlers) PutBucketQuotaConfigHandler(w http.ResponseWriter, r *http.Request) {
    	ctx := r.Context()
    
    	objectAPI, _ := validateAdminReq(ctx, w, r, policy.SetBucketQuotaAdminAction)
    	if objectAPI == nil {
    		return
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 33.2K bytes
    - Viewed (0)
  10. internal/ringbuffer/ring_buffer_test.go

    		t.Errorf("Read error: got %T, want testError1", err)
    	}
    }
    
    func TestRingBufferCloseErrorUnblocks(t *testing.T) {
    	const sz = 100
    	rb := New(sz).SetBlocking(true)
    
    	testCancel := func(fn func()) {
    		t.Helper()
    		defer timeout(5 * time.Second)()
    		rb.Reset()
    		done := make(chan struct{})
    		go func() {
    			defer close(done)
    			time.Sleep(10 * time.Millisecond)
    			fn()
    		}()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 26.8K bytes
    - Viewed (0)
Back to top