stream

Documentation

Index

• type Consumer
  • func NewConsumer() *Consumer
  • func (c *Consumer) Run() error
• type Event
  • func (e *Event) Format() string
• type Producer
  • func NewProducer(config *config.Config, consumer *Consumer) *Producer
  • func (p *Producer) BufferStatsCallback(*evntrace.EventTraceLogFile) uintptr
  • func (p *Producer) ProcessEventCallback(evt *tdh.EventRecord) uintptr
  • func (p *Producer) Start() error

Types

type Consumer

type Consumer struct {
	Queue chan *Event
	Quit  chan struct{}
}

func NewConsumer

func NewConsumer() *Consumer

func (*Consumer) Run

func (c *Consumer) Run() error

type Event

type Event struct {
	EType  event.EType
	Params []event.Param
}

func (*Event) Format

func (e *Event) Format() string

type Producer

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

func NewProducer

func NewProducer(config *config.Config, consumer *Consumer) *Producer

func (*Producer) BufferStatsCallback

func (p *Producer) BufferStatsCallback(*evntrace.EventTraceLogFile) uintptr

func (*Producer) ProcessEventCallback

func (p *Producer) ProcessEventCallback(evt *tdh.EventRecord) uintptr

func (*Producer) Start

func (p *Producer) Start() error