stream

Documentation

Index

• type StreamingApp
  • func NewStreamingApp() *StreamingApp
  • func (app *StreamingApp) Run(mWg *sync.WaitGroup)

Types

type StreamingApp

type StreamingApp struct {
	// contains filtered or unexported fields
}

func NewStreamingApp

func NewStreamingApp() *StreamingApp

func (*StreamingApp) Run

func (app *StreamingApp) Run(mWg *sync.WaitGroup)

Run is method which running the streaming part of app