| 23 | } |
| 24 | |
| 25 | type ServerOptions struct { |
| 26 | WriteWait time.Duration |
| 27 | PongWait time.Duration |
| 28 | PingPeriod time.Duration |
| 29 | MaxMessageSize int64 |
| 30 | ReadBufferSize int |
| 31 | WriteBufferSize int |
| 32 | BroadcastSize int |
| 33 | } |
| 34 | |
| 35 | func NewServer(b []*Bucket, o Operator, options ServerOptions) *Server { |
| 36 | s := new(Server) |
nothing calls this directly
no outgoing calls
no test coverage detected