(event string)
| 42 | } |
| 43 | |
| 44 | func (b *block) insert(event string) bool { |
| 45 | b.mu.Lock() |
| 46 | defer b.mu.Unlock() |
| 47 | if b.frozen { |
| 48 | return false |
| 49 | } |
| 50 | b.events = append(b.events, event) |
| 51 | b.count.Add(1) |
| 52 | b.bytes.Add(uint64(len(event))) |
| 53 | return true |
| 54 | } |
| 55 | |
| 56 | func initTunnel(ctx context.Context, tunnelID uuid.UUID, endpoint string) (_ *websocket.Conn, finalErr error) { |
| 57 | slog.Debug("dialing tunnel websocket", "tunnelID", tunnelID, "role", tunnel.Role_INSERT) |