aggregator

Documentation

Index

• type Aggregator
  • func NewAggregator(server tetragon.FineGuidanceSensors_GetEventsServer, ...) (*Aggregator, error)
  • func (a *Aggregator) GetEventChannel() chan *tetragon.GetEventsResponse
  • func (a *Aggregator) Start()

Types

type Aggregator

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

func NewAggregator

func NewAggregator(
	server tetragon.FineGuidanceSensors_GetEventsServer,
	options *tetragon.AggregationOptions,
) (*Aggregator, error)

func (*Aggregator) GetEventChannel

func (a *Aggregator) GetEventChannel() chan *tetragon.GetEventsResponse

func (*Aggregator) Start

func (a *Aggregator) Start()