Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BatchSender ¶
type BatchSender[T batch.Message] struct { AddToBatchFn func(context.Context, *batch.WALMessage[T]) error SendFn func(context.Context) error // contains filtered or unexported fields }
func NewBatchSender ¶
func NewBatchSender[T batch.Message]() *BatchSender[T]
func (*BatchSender[T]) AddToBatch ¶
func (m *BatchSender[T]) AddToBatch(ctx context.Context, msg *batch.WALMessage[T]) error
func (*BatchSender[T]) Close ¶
func (m *BatchSender[T]) Close()
func (*BatchSender[T]) GetWALMessages ¶
func (m *BatchSender[T]) GetWALMessages() []*batch.WALMessage[T]
Source Files
Click to show internal directories.
Click to hide internal directories.