(endpoint string)
| 82 | } |
| 83 | |
| 84 | func (f *HttpTubeFactory) getEndpoint(endpoint string) (*endpointHandler, bool) { |
| 85 | f.mu.RLock() |
| 86 | defer f.mu.RUnlock() |
| 87 | e, ok := f.endpoints[endpoint] |
| 88 | return e, ok |
| 89 | } |
| 90 | |
| 91 | func (f *HttpTubeFactory) Handle(ctx context.Context, endpoint string, record Record) error { |
| 92 | e, ok := f.getEndpoint(endpoint) |