ingestor

package

v1.0.11 Latest Latest Go to latest Published: Feb 17, 2026 License: Apache-2.0 Imports: 11 Imported by: 0

Details

Rendered for

This section is empty.

View Source

var (
	PORT string = ":" + strconv.Itoa(options.Config.Port)

	Server net.ListenConfig
)

func IngestorData(pipe chan<- pipelines.LogEntry, wg *sync.WaitGroup, idLog string)

Function to read the received information

func Udp(ctx context.Context, pipe chan<- *pipelines.LogEntry, wg *sync.WaitGroup)

This section is empty.