modes

Documentation

Index

• Variables
• func ConsumeStdin(ch chan models.Message)
• func ConsumeStdinAndForwardToPort(ip string, port string)
• func FollowFiles(ch chan models.Message, files []string)
• func GenerateRandomData(jsonFormat bool, numPerSec int, ch chan models.Message, ctx context.Context)
• func ProduceMessageString(ch chan models.Message, line string, mt models.LogType, ...)
• func ProduceMessageStringTimestamped(ch chan models.Message, line string, mt models.LogType, ...)
• func ReadFiles(ch chan models.Message, files []string)
• func StartCmd(ch chan models.Message, cmdStr string, args []string)
• func StartSocketServers(ch chan models.Message, ip string, ports []string)
• func UtilsCutByLineNumber(file string, count int, offset int, outFile string)
• func UtilsCutByString(file string, start string, end string, caseInsensitive bool, outFile string, ...)

Variables

var DisableANSICodeStripping = false

var FallthroughGlobal = false

Functions

func ConsumeStdin

func ConsumeStdin(ch chan models.Message)

func ConsumeStdinAndForwardToPort

func ConsumeStdinAndForwardToPort(ip string, port string)

func FollowFiles

func FollowFiles(ch chan models.Message, files []string)

func GenerateRandomData

func GenerateRandomData(jsonFormat bool, numPerSec int, ch chan models.Message, ctx context.Context)

func ProduceMessageString

func ProduceMessageString(ch chan models.Message, line string, mt models.LogType, mo *models.MessageOrigin)

func ProduceMessageStringTimestamped

func ProduceMessageStringTimestamped(ch chan models.Message, line string, mt models.LogType, mo *models.MessageOrigin, ts time.Time)

func ReadFiles

func ReadFiles(ch chan models.Message, files []string)

func StartCmd

func StartCmd(ch chan models.Message, cmdStr string, args []string)

func StartSocketServers

func StartSocketServers(ch chan models.Message, ip string, ports []string)

func UtilsCutByLineNumber

func UtilsCutByLineNumber(file string, count int, offset int, outFile string)

func UtilsCutByString

func UtilsCutByString(file string, start string, end string, caseInsensitive bool, outFile string, dateFormat string, searchOffset int)