httpevents

Documentation

Index

• Constants
• type HTTPInput
  • func (t *HTTPInput) Start() error
  • func (t *HTTPInput) Stop() error
• type HTTPInputConfig
  • func NewHTTPInputConfig(operatorID string) *HTTPInputConfig
  • func (c HTTPInputConfig) Build(ctx operator.BuildContext) ([]operator.Operator, error)

Constants

const (
	DefaultTimeout     = time.Second * 20
	DefaultIdleTimeout = time.Second * 60
	DefaultMaxBodySize = 10000000 // 10 megabyte
)

Types

type HTTPInput

type HTTPInput struct {
	helper.InputOperator
	// contains filtered or unexported fields
}

HTTPInput is an operator that listens for log entries over http.

func (*HTTPInput) Start

func (t *HTTPInput) Start() error

Start will start listening for log entries over http.

func (*HTTPInput) Stop

func (t *HTTPInput) Stop() error

Stop will stop listening 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           tcp.TLSConfig   `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.