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

package tcp

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

Index

Package Files

config.go input.go

func NewInput Uses

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

NewInput creates a new TCP input

type Input Uses

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

Input for TCP connection

func (*Input) Run Uses

func (p *Input) Run()

Run start a TCP input

func (*Input) Stop Uses

func (p *Input) Stop()

Stop stops TCP server

func (*Input) Wait Uses

func (p *Input) Wait()

Wait stop the current server

Package tcp imports 12 packages (graph) and is imported by 11 packages. Updated 2019-07-29. Refresh now. Tools for package owners.