Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for name (0.33 sec)

  1. internal/event/target/kafka.go

    	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 {
    	return target.ID().String()
    }
    
    // Store returns any underlying store if set.
    func (target *KafkaTarget) Store() event.TargetStore {
    	return target.store
    }
    
    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

    	}
    	for _, b := range h.kconfig.Brokers {
    		if _, err := xnet.ParseHost(b.String()); err != nil {
    			return err
    		}
    	}
    	return nil
    }
    
    // Name returns the name of the target
    func (h *Target) Name() string {
    	return "minio-kafka-audit"
    }
    
    // Endpoint - return kafka target
    func (h *Target) Endpoint() string {
    	return "kafka"
    }
    
    // String - kafka string
    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