Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for Value (0.14 sec)

  1. internal/event/target/kafka.go

    	if err != nil {
    		return nil, err
    	}
    
    	return &sarama.ProducerMessage{
    		Topic: target.args.Topic,
    		Key:   sarama.StringEncoder(key),
    		Value: sarama.ByteEncoder(data),
    	}, nil
    }
    
    // Close - closes underneath kafka connection.
    func (target *KafkaTarget) Close() error {
    	close(target.quitCh)
    
    	if target.producer != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Feb 20 08:16:35 GMT 2024
    - 13K bytes
    - Viewed (0)
  2. internal/logger/target/kafka/kafka.go

    	status int32
    
    	totalMessages  int64
    	failedMessages int64
    
    	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.
    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)
Back to top