Search Options

Results per page
Sort
Preferred Languages
Advance

Results 211 - 220 of 1,209 for structs (0.26 sec)

  1. internal/event/target/nats.go

    	PingInterval    int64     `json:"pingInterval"`
    	QueueDir        string    `json:"queueDir"`
    	QueueLimit      uint64    `json:"queueLimit"`
    	JetStream       struct {
    		Enable bool `json:"enable"`
    	} `json:"jetStream"`
    	Streaming struct {
    		Enable             bool   `json:"enable"`
    		ClusterID          string `json:"clusterID"`
    		Async              bool   `json:"async"`
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  2. src/bytes/bytes_test.go

    	out := slices.Collect(seq)
    	out1 := slices.Collect(seq)
    	if !slices.Equal(sliceOfString(out), sliceOfString(out1)) {
    		t.Fatalf("inconsistent seq:\n%s\n%s", out, out1)
    	}
    	return out
    }
    
    type LinesTest struct {
    	a string
    	b []string
    }
    
    var linesTests = []LinesTest{
    	{a: "abc\nabc\n", b: []string{"abc\n", "abc\n"}},
    	{a: "abc\r\nabc", b: []string{"abc\r\n", "abc"}},
    	{a: "abc\r\n", b: []string{"abc\r\n"}},
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Aug 19 19:09:04 UTC 2024
    - 61.2K bytes
    - Viewed (0)
  3. internal/bucket/lifecycle/filter_test.go

    	"github.com/dustin/go-humanize"
    )
    
    // TestUnsupportedFilters checks if parsing Filter xml with
    // unsupported elements returns appropriate errors
    func TestUnsupportedFilters(t *testing.T) {
    	testCases := []struct {
    		inputXML    string
    		expectedErr error
    	}{
    		{ // Filter with And tags
    			inputXML: ` <Filter>
    						<And>
    							<Prefix>key-prefix</Prefix>
    						</And>
    						</Filter>`,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Feb 27 00:01:20 UTC 2024
    - 7.2K bytes
    - Viewed (0)
  4. cmd/background-heal-ops.go

    //	path: 'bucket/' or '/bucket/' => Heal bucket
    //	path: 'bucket/object' => Heal object
    type healTask struct {
    	bucket    string
    	object    string
    	versionID string
    	opts      madmin.HealOpts
    	// Healing response will be sent here
    	respCh chan healResult
    }
    
    // healResult represents a healing result with a possible error
    type healResult struct {
    	result madmin.HealResultItem
    	err    error
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  5. cni/pkg/log/uds_test.go

    )
    
    func TestUDSLog(t *testing.T) {
    	// Start UDS log server
    	udsSockDir := t.TempDir()
    	udsSock := filepath.Join(udsSockDir, "cni.sock")
    	logger := NewUDSLogger(istiolog.DebugLevel)
    	stop := make(chan struct{})
    	defer close(stop)
    	assert.NoError(t, logger.StartUDSLogServer(udsSock, stop))
    
    	// Configure log to tee to UDS server
    	stdout := os.Stdout
    	r, w, _ := os.Pipe()
    	os.Stdout = w
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Jun 12 16:26:28 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  6. src/archive/tar/reader_test.go

    	tr := NewReader(f)
    	_, err = tr.Read([]byte{})
    	if err == nil || err != io.EOF {
    		t.Errorf("Unexpected error: %v, wanted %v", err, io.EOF)
    	}
    
    }
    
    type reader struct{ io.Reader }
    type readSeeker struct{ io.ReadSeeker }
    type readBadSeeker struct{ io.ReadSeeker }
    
    func (rbs *readBadSeeker) Seek(int64, int) (int64, error) { return 0, fmt.Errorf("illegal seek") }
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Oct 03 15:48:09 UTC 2024
    - 46.9K bytes
    - Viewed (0)
  7. cni/pkg/nodeagent/fakes_test.go

    	f.addedPods.Add(1)
    	return f.addError
    }
    
    func (f *fakeZtunnel) Close() error {
    	return nil
    }
    
    // fakeNs is a mock struct for testing
    type fakeNs struct {
    	closed *atomic.Bool
    	fd     uintptr
    	inode  uint64
    }
    
    func newFakeNs(fd uintptr) *fakeNs {
    	// the fake inode is the fd! magic.
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jun 28 23:33:46 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  8. cmd/bucket-targets.go

    	defaultHealthCheckReloadDuration = 30 * time.Minute
    )
    
    type arnTarget struct {
    	Client      *TargetClient
    	lastRefresh time.Time
    }
    
    // arnErrs represents number of errors seen for a ARN and if update is in progress
    // to refresh remote targets from bucket metadata.
    type arnErrs struct {
    	count            int64
    	updateInProgress bool
    	bucket           string
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  9. ci/official/containers/linux_arm64/builder.devtoolset/gcc9-fixups.patch

    diff --git a/iconv/gconv.h b/iconv/gconv.h
    index 3f9112e..8e60197 100644
    --- a/iconv/gconv.h
    +++ b/iconv/gconv.h
    @@ -174,7 +174,7 @@ typedef struct __gconv_info
     {
       size_t __nsteps;
       struct __gconv_step *__steps;
    -  __extension__ struct __gconv_step_data __data __flexarr;
    +  __extension__ struct __gconv_step_data __data[0];
     } *__gconv_t;
     
     #endif /* gconv.h */
    diff --git a/include/libc-symbols.h b/include/libc-symbols.h
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Mon Sep 18 14:52:45 UTC 2023
    - 8.9K bytes
    - Viewed (0)
  10. cmd/namespace-lock.go

    	return &nsMutex
    }
    
    // nsLock - provides primitives for locking critical namespace regions.
    type nsLock struct {
    	ref int32
    	*lsync.LRWMutex
    }
    
    // nsLockMap - namespace lock map, provides primitives to Lock,
    // Unlock, RLock and RUnlock.
    type nsLockMap struct {
    	// Indicates if namespace is part of a distributed setup.
    	isDistErasure bool
    	lockMap       map[string]*nsLock
    	lockMapMutex  sync.Mutex
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 9.2K bytes
    - Viewed (0)
Back to top