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 { SendMessageFn func(context.Context, *batch.WALMessage[T]) error CloseFn func() // contains filtered or unexported fields }
func NewBatchSender ¶
func NewBatchSender[T batch.Message]() *BatchSender[T]
func (*BatchSender[T]) Close ¶
func (m *BatchSender[T]) Close()
func (*BatchSender[T]) GetWALMessages ¶
func (m *BatchSender[T]) GetWALMessages() []*batch.WALMessage[T]
func (*BatchSender[T]) SendMessage ¶ added in v0.5.0
func (m *BatchSender[T]) SendMessage(ctx context.Context, msg *batch.WALMessage[T]) error
Source Files
Click to show internal directories.
Click to hide internal directories.