submission

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(conn *grpc.ClientConn, opts *Options) Submitter