Documentation
¶
Index ¶
Constants ¶
View Source
const ( DefaultTimeout = time.Second * 20 DefaultIdleTimeout = time.Second * 60 DefaultMaxBodySize = 10000000 // 10 megabyte )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type HTTPInput ¶
type HTTPInput struct {
helper.InputOperator
// contains filtered or unexported fields
}
HTTPInput is an operator that listens for log entries over http.
type HTTPInputConfig ¶
type HTTPInputConfig struct {
helper.InputConfig `yaml:",inline"`
ListenAddress string `json:"listen_address,omitempty" yaml:"listen_address,omitempty"`
TLS *helper.TLSServerConfig `json:"tls,omitempty" yaml:"tls,omitempty"`
IdleTimeout helper.Duration `json:"idle_timeout,omitempty" yaml:"idle_timeout,omitempty"`
ReadTimeout helper.Duration `json:"read_timeout,omitempty" yaml:"read_timeout,omitempty"`
WriteTimeout helper.Duration `json:"write_timeout,omitempty" yaml:"write_timeout,omitempty"`
MaxHeaderSize helper.ByteSize `json:"max_header_size,omitempty" yaml:"max_header_size,omitempty"`
MaxBodySize helper.ByteSize `json:"max_body_size,omitempty" yaml:"max_body_size,omitempty"`
AuthConfig authConfig `json:"auth,omitempty" yaml:"auth,omitempty"`
}
HTTPInputConfig is the configuration of a http input operator.
func NewHTTPInputConfig ¶
func NewHTTPInputConfig(operatorID string) *HTTPInputConfig
NewHTTPInputConfig creates a new HTTP input config with default values
func (HTTPInputConfig) Build ¶
func (c HTTPInputConfig) Build(ctx operator.BuildContext) ([]operator.Operator, error)
Build will build a http input operator.
Source Files
Click to show internal directories.
Click to hide internal directories.