Documentation ¶ Index ¶ func NewLogStreamUseCase(context *app.Context) domain.LogStreamUseCase func NewPool(maxWorkers int, subscriptionRepo *domain.SubscriptionsRepository, ...) logDistributionWorkerPool Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ func NewLogStreamUseCase ¶ func NewLogStreamUseCase(context *app.Context) domain.LogStreamUseCase TODO: use log plugin func NewPool ¶ func NewPool(maxWorkers int, subscriptionRepo *domain.SubscriptionsRepository, logPlugins *[]app.LogPlugin, logger domain.Logger) logDistributionWorkerPool Types ¶ This section is empty. Source Files ¶ View all Source files log_distribution_worker.go logstream_usecase.go Click to show internal directories. Click to hide internal directories.