beats: github.com/elastic/beats/filebeat/input/udp Index | Files

package udp

import "github.com/elastic/beats/filebeat/input/udp"

Index

Package Files

config.go input.go

func NewInput Uses

func NewInput(
    cfg *common.Config,
    outlet channel.Connector,
    context input.Context,
) (input.Input, error)

NewInput creates a new udp input

type Input Uses

type Input struct {
    sync.Mutex
    // contains filtered or unexported fields
}

Input defines a udp input to receive event on a specific host:port.

func (*Input) Run Uses

func (p *Input) Run()

Run starts and start the UDP server and read events from the socket

func (*Input) Stop Uses

func (p *Input) Stop()

Stop stops the UDP input

func (*Input) Wait Uses

func (p *Input) Wait()

Wait suspends the UDP input

Package udp imports 11 packages (graph) and is imported by 11 packages. Updated 2019-08-10. Refresh now. Tools for package owners.