📶
Streamer
  • Introduction
  • Event Actor
    • Overview
    • State Machine
    • Event Filter
    • Worker Thread
    • Message Wrapper
    • Synchronous Communication
  • Special actors
    • Combiner
    • Pool
    • Renamer
    • Uploader/Downloader
    • Pipeliner
  • Event Broker
    • Broker
    • Configuration
Powered by GitBook
On this page
  1. Event Actor

Worker Thread

A Worker Thread is the unit of code doing real data processing on the event data received. It receives the events from the filter and may generate some output events afterward. A work thread may or may not emit output events depending on its internal design.

type WorkerThread struct {
	Name          string
	Groupid       string
	Concurrency   int
	MsgBroker     *MessageWrapper
	LatestMessage *Message
	Log           *log.LogWraper
}
PreviousEvent FilterNextMessage Wrapper

Last updated 1 year ago