- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 1,254 for ctan (0.06 sec)
-
cni/pkg/install/cniconfig_test.go
// Call with goroutine to test fsnotify watcher parent, cancel := context.WithCancel(context.Background()) defer cancel() resultChan, errChan := make(chan string, 1), make(chan error, 1) go func(resultChan chan string, errChan chan error, ctx context.Context, cniConfName, mountedCNINetDir string, chained bool) { result, err := getCNIConfigFilepath(ctx, cniConfName, mountedCNINetDir, chained) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 21 18:32:01 UTC 2024 - 15.4K bytes - Viewed (0) -
pkg/kube/multicluster/secretcontroller_test.go
func (t *testController) ConfigClusterHandler() testHandler { return t.component.clusters["config"] } func (t *testController) Run(stop chan struct{}) { assert.NoError(t.t, t.controller.Run(stop)) t.client.RunAndWait(stop) } func TestListRemoteClusters(t *testing.T) { stop := make(chan struct{}) c := buildTestController(t, false) c.AddSecret("s0", "c0") c.AddSecret("s1", "c1") c.Run(stop) // before sync
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 17.6K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/tools/internal/typesinternal/errorcode.go
// InvalidChanAssign occurs when a chan assignment is invalid. // // Per the spec, a value x is assignable to a channel type T if: // "x is a bidirectional channel value, T is a channel type, x's type V and // T have identical element types, and at least one of V or T is not a // defined type." // // Example: // type T1 chan int // type T2 chan int // // var x T1
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 03 02:38:00 UTC 2024 - 34K bytes - Viewed (0) -
src/vendor/golang.org/x/net/nettest/conntest.go
} // testBasicIO tests that the data sent on c1 is properly received on c2. func testBasicIO(t *testing.T, c1, c2 net.Conn) { want := make([]byte, 1<<20) rand.New(rand.NewSource(0)).Read(want) dataCh := make(chan []byte) go func() { rd := bytes.NewReader(want) if err := chunkedCopy(c1, rd); err != nil { t.Errorf("unexpected c1.Write error: %v", err) } if err := c1.Close(); err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 12.2K bytes - Viewed (0) -
src/go/types/predicates.go
if y, ok := y.(*Map); ok { return c.identical(x.key, y.key, p) && c.identical(x.elem, y.elem, p) } case *Chan: // Two channel types are identical if they have identical value types // and the same direction. if y, ok := y.(*Chan); ok { return x.dir == y.dir && c.identical(x.elem, y.elem, p) } case *Named: // Two named types are identical if their type names originate
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:01:18 UTC 2024 - 17.6K bytes - Viewed (0) -
internal/logger/target/kafka/kafka.go
wg sync.WaitGroup // Channel of log entries. // Reading logCh must hold read lock on logChMu (to avoid read race) // Sending a value on logCh must hold read lock on logChMu (to avoid closing) logCh chan interface{} logChMu sync.RWMutex // store to persist and replay the logs to the target // to avoid missing events when the target is down. store store.Store[interface{}] storeCtxCancel context.CancelFunc
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Jun 02 03:03:39 UTC 2024 - 10.2K bytes - Viewed (0) -
internal/event/target/nats.go
} clientID := u.String() connOpts := []stan.Option{stan.NatsURL(addressURL)} if n.Streaming.MaxPubAcksInflight > 0 { connOpts = append(connOpts, stan.MaxPubAcksInflight(n.Streaming.MaxPubAcksInflight)) } if n.UserCredentials != "" { connOpts = append(connOpts, stan.NatsOptions(nats.UserCredentials(n.UserCredentials))) } return stan.Connect(n.Streaming.ClusterID, clientID, connOpts...) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 12.8K bytes - Viewed (0) -
pilot/pkg/xds/bench_test.go
b.Run("key", func(b *testing.B) { key := makeCacheKey(1) for n := 0; n < b.N; n++ { _ = key.Key() } }) b.Run("insert", func(b *testing.B) { c := model.NewXdsCache() stop := make(chan struct{}) defer close(stop) c.Run(stop) for n := 0; n < b.N; n++ { key := makeCacheKey(n) req := &model.PushRequest{Start: zeroTime.Add(time.Duration(n))} c.Add(key, req, res) } })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 22 18:13:40 UTC 2024 - 19.7K bytes - Viewed (0) -
cmd/kube-scheduler/app/server.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 19:11:24 UTC 2024 - 14.3K bytes - Viewed (0) -
cmd/metacache-walk.go
return err })) } // WalkDirHandler - remote caller to list files and folders in a requested directory path. func (s *storageRESTServer) WalkDirHandler(ctx context.Context, payload []byte, _ <-chan []byte, out chan<- []byte) (gerr *grid.RemoteErr) { var opts WalkDirOptions _, err := opts.UnmarshalMsg(payload) if err != nil { return grid.NewRemoteErr(err) } if !s.checkID(opts.DiskID) {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Jun 01 05:17:37 UTC 2024 - 12.4K bytes - Viewed (0)