Validate that the session filters events
(t *testing.T)
| 24 | |
| 25 | // Validate that the session filters events |
| 26 | func TestSession_Insert(t *testing.T) { |
| 27 | _, cancel := context.WithCancel(context.Background()) |
| 28 | defer cancel() |
| 29 | infoLevel := new(LogLevel) |
| 30 | *infoLevel = Info |
| 31 | warnLevel := new(LogLevel) |
| 32 | *warnLevel = Warn |
| 33 | for _, test := range []struct { |
| 34 | name string |
| 35 | filters StreamingFilters |
| 36 | expectLog bool |
| 37 | }{ |
| 38 | { |
| 39 | name: "none", |
| 40 | expectLog: true, |
| 41 | }, |
| 42 | { |
| 43 | name: "level", |
| 44 | filters: StreamingFilters{ |
| 45 | Level: infoLevel, |
| 46 | }, |
| 47 | expectLog: true, |
| 48 | }, |
| 49 | { |
| 50 | name: "filtered out level", |
| 51 | filters: StreamingFilters{ |
| 52 | Level: warnLevel, |
| 53 | }, |
| 54 | expectLog: false, |
| 55 | }, |
| 56 | { |
| 57 | name: "events", |
| 58 | filters: StreamingFilters{ |
| 59 | Events: []LogEventType{HTTP}, |
| 60 | }, |
| 61 | expectLog: true, |
| 62 | }, |
| 63 | { |
| 64 | name: "filtered out event", |
| 65 | filters: StreamingFilters{ |
| 66 | Events: []LogEventType{Cloudflared}, |
| 67 | }, |
| 68 | expectLog: false, |
| 69 | }, |
| 70 | { |
| 71 | name: "sampling", |
| 72 | filters: StreamingFilters{ |
| 73 | Sampling: 0.9999999, |
| 74 | }, |
| 75 | expectLog: true, |
| 76 | }, |
| 77 | { |
| 78 | name: "sampling (invalid negative)", |
| 79 | filters: StreamingFilters{ |
| 80 | Sampling: -1.0, |
| 81 | }, |
| 82 | expectLog: true, |
| 83 | }, |
nothing calls this directly
no test coverage detected