Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 138 for Chan (0.15 sec)

  1. 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
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 10.1K bytes
    - Viewed (1)
  2. internal/event/target/postgresql.go

    	if p.QueueDir != "" {
    		if !filepath.IsAbs(p.QueueDir) {
    			return errors.New("queueDir path should be absolute")
    		}
    	}
    
    	if p.MaxOpenConnections < 0 {
    		return errors.New("maxOpenConnections cannot be less than zero")
    	}
    
    	return nil
    }
    
    // PostgreSQLTarget - PostgreSQL target.
    type PostgreSQLTarget struct {
    	initOnce once.Init
    
    	id         event.TargetID
    	args       PostgreSQLArgs
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 17:51:07 GMT 2024
    - 13.3K bytes
    - Viewed (0)
  3. cmd/globals.go

    	globalIsTLS bool
    
    	globalTLSCerts *certs.Manager
    
    	globalHTTPServer        *xhttp.Server
    	globalTCPOptions        xhttp.TCPOptions
    	globalHTTPServerErrorCh = make(chan error)
    	globalOSSignalCh        = make(chan os.Signal, 1)
    
    	// global Trace system to send HTTP request/response
    	// and Storage/OS calls info to registered listeners.
    	globalTrace = pubsub.New[madmin.TraceInfo, madmin.TraceType](8)
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 16.5K bytes
    - Viewed (0)
  4. istioctl/pkg/wait/wait.go

    	})
    	return g
    }
    
    type watcher struct {
    	resultsChan chan string
    	errorChan   chan error
    	ctx         context.Context
    }
    
    func withContext(ctx context.Context) *watcher {
    	return &watcher{
    		resultsChan: make(chan string, 1),
    		errorChan:   make(chan error, 1),
    		ctx:         ctx,
    	}
    }
    
    func (w *watcher) Go(f func(chan string) error) {
    	go func() {
    		if err := f(w.resultsChan); err != nil {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sat Feb 17 12:24:17 GMT 2024
    - 10.1K bytes
    - Viewed (0)
  5. cmd/metacache-entries.go

    // The entry not chosen will be discarded.
    // If the context is canceled the function will return the error,
    // otherwise the function will return nil.
    func mergeEntryChannels(ctx context.Context, in []chan metaCacheEntry, out chan<- metaCacheEntry, readQuorum int) error {
    	defer xioutil.SafeClose(out)
    	top := make([]*metaCacheEntry, len(in))
    	nDone := 0
    	ctxDone := ctx.Done()
    
    	// Use simpler forwarder.
    	if len(in) == 1 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:43:43 GMT 2024
    - 23.2K bytes
    - Viewed (0)
  6. internal/event/target/kafka.go

    	producer   sarama.SyncProducer
    	config     *sarama.Config
    	store      store.Store[event.Event]
    	batch      *store.Batch[string, *sarama.ProducerMessage]
    	loggerOnce logger.LogOnce
    	quitCh     chan struct{}
    }
    
    // ID - returns target ID.
    func (target *KafkaTarget) ID() event.TargetID {
    	return target.id
    }
    
    // Name - returns the Name of the target.
    func (target *KafkaTarget) Name() string {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Feb 20 08:16:35 GMT 2024
    - 13K bytes
    - Viewed (0)
  7. internal/event/target/nats.go

    	id         event.TargetID
    	args       NATSArgs
    	natsConn   *nats.Conn
    	stanConn   stan.Conn
    	jstream    nats.JetStream
    	store      store.Store[event.Event]
    	loggerOnce logger.LogOnce
    	quitCh     chan struct{}
    }
    
    // ID - returns target ID.
    func (target *NATSTarget) ID() event.TargetID {
    	return target.id
    }
    
    // Name - returns the Name of the target.
    func (target *NATSTarget) Name() string {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Feb 27 18:11:55 GMT 2024
    - 12.8K bytes
    - Viewed (0)
  8. cmd/batch-rotate.go

    // # optional flags based filtering criteria
    // # for all objects
    // flags:
    //   filter:
    //     newerThan: "7d" # match objects newer than this value (e.g. 7d10h31s)
    //     olderThan: "7d" # match objects older than this value (e.g. 7d10h31s)
    //     createdAfter: "date" # match objects created after "date"
    //     createdBefore: "date" # match objects created before "date"
    //     tags:
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.2K bytes
    - Viewed (0)
  9. src/builtin/builtin.go

    // constant. See the Go language specification's "Length and capacity" section for
    // details.
    func cap(v Type) int
    
    // The make built-in function allocates and initializes an object of type
    // slice, map, or chan (only). Like new, the first argument is a type, not a
    // value. Unlike new, make's return type is the same as the type of its
    // argument, not a pointer to it. The specification of the result depends on
    // the type:
    //
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Thu Apr 11 20:22:45 GMT 2024
    - 12.7K bytes
    - Viewed (0)
  10. cmd/notification.go

    			}
    			consolidatedReport.BucketStats[opts] = d
    		}
    	}
    	return consolidatedReport
    }
    
    func (sys *NotificationSys) collectPeerMetrics(ctx context.Context, peerChannels []<-chan MetricV2, g *errgroup.Group) <-chan MetricV2 {
    	ch := make(chan MetricV2)
    	var wg sync.WaitGroup
    	for index, err := range g.Wait() {
    		if err != nil {
    			if sys.peerClients[index] != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 12 18:13:36 GMT 2024
    - 44.5K bytes
    - Viewed (0)
Back to top