Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for from (0.13 sec)

  1. internal/event/target/kafka.go

    	}
    	msg, err := target.toProducerMessage(eventData)
    	if err != nil {
    		return err
    	}
    	_, _, err = target.producer.SendMessage(msg)
    	return err
    }
    
    // SendFromStore - reads an event from store and sends it to Kafka.
    func (target *KafkaTarget) SendFromStore(key store.Key) error {
    	if err := target.init(); err != nil {
    		return err
    	}
    
    	// If batch is enabled, the event will be batched in memory
    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

    		h.wg.Add(1)
    		defer h.wg.Done()
    
    	}
    	h.logChMu.RUnlock()
    
    	if logCh == nil {
    		return
    	}
    
    	// Create a routine which sends json logs received
    	// from an internal channel.
    	for entry := range logCh {
    		h.logEntry(entry)
    	}
    }
    
    func (h *Target) logEntry(entry interface{}) {
    	atomic.AddInt64(&h.totalMessages, 1)
    	if err := h.send(entry); err != nil {
    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