Documentation ¶
Index ¶
- type Service
- func (s *Service) AddInfluxdbDatabase(w http.ResponseWriter, r *http.Request)
- func (s *Service) AddInfluxdbMetric(w http.ResponseWriter, r *http.Request)
- func (s *Service) AddInfluxdbMetricRoute(w http.ResponseWriter, r *http.Request)
- func (s *Service) AddInfluxdbNode(w http.ResponseWriter, r *http.Request)
- func (s *Service) AddTask(w http.ResponseWriter, r *http.Request)
- func (s *Service) Open() error
- func (s *Service) SendToInfluxdb(w http.ResponseWriter, r *http.Request)
- func (s *Service) SendToKafka(w http.ResponseWriter, r *http.Request)
- func (s *Service) SetInfluxdbService(is *influxdb.Service)
- func (s *Service) SetKafkaService(ks *kafka.Service)
- type Statistics
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Service ¶
func (*Service) AddInfluxdbDatabase ¶
func (s *Service) AddInfluxdbDatabase(w http.ResponseWriter, r *http.Request)
func (*Service) AddInfluxdbMetric ¶
func (s *Service) AddInfluxdbMetric(w http.ResponseWriter, r *http.Request)
func (*Service) AddInfluxdbMetricRoute ¶
func (s *Service) AddInfluxdbMetricRoute(w http.ResponseWriter, r *http.Request)
func (*Service) AddInfluxdbNode ¶
func (s *Service) AddInfluxdbNode(w http.ResponseWriter, r *http.Request)
func (*Service) SendToInfluxdb ¶
func (s *Service) SendToInfluxdb(w http.ResponseWriter, r *http.Request)
func (*Service) SendToKafka ¶
func (s *Service) SendToKafka(w http.ResponseWriter, r *http.Request)
func (*Service) SetInfluxdbService ¶
func (*Service) SetKafkaService ¶
Click to show internal directories.
Click to hide internal directories.