in galog.go [610:624]
func (lg *logger) RegisterBackend(ctx context.Context, backend Backend) {
backendQueue := &BackendQueue{
cancel: make(chan bool),
bus: make(chan *LogEntry),
tickerFrequency: lg.retryFrequency,
ticker: time.NewTicker(lg.retryFrequency),
backend: backend,
}
lg.queuesMutex.Lock()
lg.queues[backend.ID()] = backendQueue
lg.queuesMutex.Unlock()
go lg.runBackend(ctx, backend, backendQueue)
}