streamer

Documentation

Index

• func Worker(cfg *config.AppConfig, inP pipe.Pipe) bool
• type Streamer

Functions

func Worker

func Worker(cfg *config.AppConfig, inP pipe.Pipe) bool

Worker : Initializer function

Types

type Streamer

type Streamer struct {
	BytesWritten int64
	BytesRead    int64
	// contains filtered or unexported fields
}

Streamer struct defines common properties of Event streamer worker