Interface BatchStrategy

pkg/logger/store.go:78–80

BatchStrategy accumulates individual log requests and emits batches. Run reads from in, batches records according to its policy, and writes batches to out. Run MUST close out when in is closed and all remaining records have been flushed. Run MUST respect ctx cancellation.

// batches to out. Run MUST close out when in is closed and all remaining
// records have been flushed. Run MUST respect ctx cancellation.
type BatchStrategy interface {
	Run(ctx context.Context, in <-chan LogRequest, out chan<- []LogRequest)
}

type Store interface {
	Store(logUrl *url.URL, batch []LogRequest) error