streamer

Documentation

Index

• func Worker(cfg *config.AppConfig, inP pipe.Pipe, outPipes *map[string]pipe.Pipe) bool
• type Streamer
  • func (s *Streamer) StreamTable(consumer pipe.Consumer) bool

Functions

func Worker

func Worker(cfg *config.AppConfig, inP pipe.Pipe, outPipes *map[string]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

func (*Streamer) StreamTable

func (s *Streamer) StreamTable(consumer pipe.Consumer) bool

StreamTable attempts to acquire a lock on a table partition and streams events from that table partition while periodically updating its state of the last kafka offset consumed