| 22 | func (cfg *WebSocketConfig) fillDefaults() {} |
| 23 | |
| 24 | type WebSocket struct { |
| 25 | Cfg *WebSocketConfig |
| 26 | |
| 27 | Fields []baker.FieldIndex |
| 28 | |
| 29 | fieldByName func(string) (baker.FieldIndex, bool) |
| 30 | totaln int64 |
| 31 | } |
| 32 | |
| 33 | func NewWebSocket(cfg baker.OutputParams) (baker.Output, error) { |
| 34 | log.WithFields(log.Fields{"fn": "NewWebSocket", "idx": cfg.Index}).Info("Initializing") |
nothing calls this directly
no outgoing calls
no test coverage detected