batchsender

type BatchSender ¶

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

BatchSender is a helper struct that batches items and sends them in batches of batchSize or after batchTimeout.

- If item is already a slice, it will be sent directly - Otherwise, it will be added to the current batch - If the current batch has reached the batch size, it will be sent immediately - Otherwise, a timer will be started to send the current batch after the batch timeout

func NewBatchSender(sendFn func(any)) *BatchSender

func (bs *BatchSender) Close()

func (bs *BatchSender) Flush()

func (bs *BatchSender) Send(item any)