batcher

type Batcher[T any] struct {
	Do         func(ctx context.Context, channelID int, val *Msg[T])
	OnComplete func(lastMessage *T, totalCount int)
	Sharding   func(key string) int
	Key        func(data *T) string
	HookFunc   func(triggerID string, messages map[string][]*T, totalCount int, lastMessage *T)
	// contains filtered or unexported fields
}

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

type Msg[T any] struct {
	// contains filtered or unexported fields
}

type Option func(c *Config)