submission

Documentation

Index

• type Options
• type Submitter
  • func New(conn *grpc.ClientConn, opts *Options) Submitter

Types

type Options

type Options struct {
	MaxDelay       time.Duration
	MaxStored      int
	ChanBufferSize int
}

type Submitter

type Submitter interface {
	AddEvent(*ippb.Event)
	AddAggregate(*ippb.Aggregate)
	Close()
}

A Submitter sends events to a remote iprep collector, trying to keep the overall request rate under control. To do so, the Submitter will perform local aggregation of events before sending them to the remote server. Options can control the maximum time delay and the overall memory impact of the submission queue.

func New

func New(conn *grpc.ClientConn, opts *Options) Submitter

New creates a new Submitter pointing at the specified collector addr.