httpd

Documentation

Index

• type Service
  • func New(config util.HTTPdConfig) (*Service, error)
  • 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

Types

type Service

type Service struct {
	*util.HTTPd
	// contains filtered or unexported fields
}

func New

func New(config util.HTTPdConfig) (*Service, error)

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) AddTask

func (s *Service) AddTask(w http.ResponseWriter, r *http.Request)

func (*Service) Open

func (s *Service) Open() error

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 (s *Service) SetInfluxdbService(is *influxdb.Service)

func (*Service) SetKafkaService

func (s *Service) SetKafkaService(ks *kafka.Service)

type Statistics

type Statistics struct {
	KafkaReceived        uint64
	KafkaReceivedFail    uint64
	KafkaSendSuccess     uint64
	KafkaSendFail        uint64
	InfluxdbReceived     uint64
	InfluxdbReceivedFail uint64
	InfluxdbSendSuccess  uint64
	InfluxdbSendFail     uint64
}