(event common.ChangePayload)
| 374 | } |
| 375 | |
| 376 | func (w *Worker) handleEnterpriseEvent(event common.ChangePayload) { |
| 377 | enterprise, ok := event.Payload.(params.Enterprise) |
| 378 | if !ok { |
| 379 | slog.DebugContext(w.ctx, "invalid payload type for enterprise event", "payload", event.Payload) |
| 380 | return |
| 381 | } |
| 382 | w.handleEntityEvent(enterprise, event.Operation) |
| 383 | } |
| 384 | |
| 385 | func (w *Worker) handlePoolEvent(event common.ChangePayload) { |
| 386 | pool, ok := event.Payload.(params.Pool) |
no test coverage detected