Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BatchHandler ¶
type BatchHandler struct {
// contains filtered or unexported fields
}
BatchHandler processes event batches and writes them to storage
func NewBatchHandler ¶
func NewBatchHandler(writer *storage.Writer) *BatchHandler
NewBatchHandler creates a new batch handler with the given storage writer
func (*BatchHandler) ProcessBatch ¶
func (h *BatchHandler) ProcessBatch(ctx context.Context, envelopes []*messaging.EventEnvelope) error
ProcessBatch unmarshals, groups, and writes events by type
Source Files
Click to show internal directories.
Click to hide internal directories.