handler

Documentation

Index

• type FrameHandler
  • func NewFrameHandler(index int, runType string, publisher reader.InterfaceReader, ...) *FrameHandler
  • func (f *FrameHandler) Run(wg *sync.WaitGroup, ctx context.Context)

Types

type FrameHandler

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

func NewFrameHandler

func NewFrameHandler(
	index int,
	runType string,
	publisher reader.InterfaceReader,
	analyzer parser.InterfaceParser,
	subscriber writer.InterfaceWriter,
	runLog *logger.Logger) *FrameHandler

func (*FrameHandler) Run

func (f *FrameHandler) Run(wg *sync.WaitGroup, ctx context.Context)