Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for send (0.12 sec)

  1. internal/event/target/kafka.go

    	if target.store != nil {
    		return target.store.Put(eventData)
    	}
    	if err := target.init(); err != nil {
    		return err
    	}
    	return target.send(eventData)
    }
    
    // send - sends an event to the kafka.
    func (target *KafkaTarget) send(eventData event.Event) error {
    	if target.producer == nil {
    		return store.ErrNotConnected
    	}
    	msg, err := target.toProducerMessage(eventData)
    	if err != 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

    	return nil
    }
    
    // IsOnline returns true if the target is online.
    func (h *Target) IsOnline(_ context.Context) bool {
    	return atomic.LoadInt32(&h.status) == statusOnline
    }
    
    // Send log message 'e' to kafka target.
    func (h *Target) Send(ctx context.Context, entry interface{}) error {
    	if h.store != nil {
    		// save the entry to the queue store which will be replayed to the target.
    		return h.store.Put(entry)
    	}
    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