Documentation
¶
Index ¶
- func BadRequest(res http.ResponseWriter)
- func InternalServerError(res http.ResponseWriter)
- func MethodNotAllowed(res http.ResponseWriter)
- func TooLarge(res http.ResponseWriter)
- type ServiceHTTP
- func (s *ServiceHTTP) Collect(pipeline.Collector) error
- func (s *ServiceHTTP) Description() string
- func (s *ServiceHTTP) Init(context pipeline.Context) (int, error)
- func (s *ServiceHTTP) ServeHTTP(w http.ResponseWriter, r *http.Request)
- func (s *ServiceHTTP) Start(c pipeline.Collector) error
- func (s *ServiceHTTP) StartService(context pipeline.PipelineContext) error
- func (s *ServiceHTTP) Stop() error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BadRequest ¶ added in v1.4.0
func BadRequest(res http.ResponseWriter)
func InternalServerError ¶ added in v1.4.0
func InternalServerError(res http.ResponseWriter)
func MethodNotAllowed ¶ added in v1.4.0
func MethodNotAllowed(res http.ResponseWriter)
func TooLarge ¶ added in v1.4.0
func TooLarge(res http.ResponseWriter)
Types ¶
type ServiceHTTP ¶
type ServiceHTTP struct {
DumpDataKeepFiles int
DumpData bool // would dump the received data to a local file, which is only used to valid data by the developers.
Format string
Address string
Path string
ReadTimeoutSec int
ShutdownTimeoutSec int
MaxBodySize int64
UnlinkUnixSock bool
FieldsExtend bool
DisableUncompress bool
Tags map[string]string // todo for v2
// params below works only for version v2
QueryParams []string
HeaderParams []string
QueryParamPrefix string
HeaderParamPrefix string
// contains filtered or unexported fields
}
ServiceHTTP ...
func (*ServiceHTTP) Collect ¶
func (s *ServiceHTTP) Collect(pipeline.Collector) error
Collect takes in an accumulator and adds the metrics that the Input gathers. This is called every "interval"
func (*ServiceHTTP) Init ¶
func (s *ServiceHTTP) Init(context pipeline.Context) (int, error)
Init ...
func (*ServiceHTTP) ServeHTTP ¶
func (s *ServiceHTTP) ServeHTTP(w http.ResponseWriter, r *http.Request)
func (*ServiceHTTP) Start ¶
func (s *ServiceHTTP) Start(c pipeline.Collector) error
Start starts the ServiceInput's service, whatever that may be
func (*ServiceHTTP) StartService ¶ added in v1.4.0
func (s *ServiceHTTP) StartService(context pipeline.PipelineContext) error
StartService start the ServiceInput's service by plugin runner v2
func (*ServiceHTTP) Stop ¶
func (s *ServiceHTTP) Stop() error
Stop stops the services and closes any necessary channels and connections
Source Files
Click to show internal directories.
Click to hide internal directories.