Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. 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)
  2. internal/event/target/postgresql.go

    // PostgreSQLTarget - PostgreSQL target.
    type PostgreSQLTarget struct {
    	initOnce once.Init
    
    	id         event.TargetID
    	args       PostgreSQLArgs
    	updateStmt *sql.Stmt
    	deleteStmt *sql.Stmt
    	insertStmt *sql.Stmt
    	db         *sql.DB
    	store      store.Store[event.Event]
    	firstPing  bool
    	connString string
    	loggerOnce logger.LogOnce
    	quitCh     chan struct{}
    }
    
    // ID - returns target ID.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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)
  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. 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)
  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. schema/constraint_test.go

    package schema_test
    
    import (
    	"reflect"
    	"sync"
    	"testing"
    
    	"gorm.io/gorm/schema"
    	"gorm.io/gorm/utils/tests"
    )
    
    type UserCheck struct {
    	Name  string `gorm:"check:name_checker,name <> 'jinzhu'"`
    	Name2 string `gorm:"check:name <> 'jinzhu'"`
    	Name3 string `gorm:"check:,name <> 'jinzhu'"`
    }
    
    func TestParseCheck(t *testing.T) {
    	user, err := schema.Parse(&UserCheck{}, &sync.Map{}, schema.NamingStrategy{})
    	if err != nil {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Sun Feb 04 07:49:19 UTC 2024
    - 2.2K bytes
    - Viewed (0)
Back to top