NewServer returns a new instance of Server, set to accept requests on addr. It is the responsibility of the caller to register the exported ADS and LRS services on an appropriate gRPC server. Most usages should prefer StartServer() instead of this.
(addr string)
| 146 | // services on an appropriate gRPC server. Most usages should prefer |
| 147 | // StartServer() instead of this. |
| 148 | func NewServer(addr string) *Server { |
| 149 | s := &Server{ |
| 150 | XDSRequestChan: testutils.NewChannelWithSize(defaultChannelBufferSize), |
| 151 | LRSRequestChan: testutils.NewChannelWithSize(defaultChannelBufferSize), |
| 152 | NewConnChan: testutils.NewChannelWithSize(defaultChannelBufferSize), |
| 153 | XDSResponseChan: make(chan *Response, defaultChannelBufferSize), |
| 154 | LRSResponseChan: make(chan *Response, 1), // The server only ever sends one response. |
| 155 | LRSStreamOpenChan: testutils.NewChannelWithSize(defaultChannelBufferSize), |
| 156 | LRSStreamCloseChan: testutils.NewChannelWithSize(defaultChannelBufferSize), |
| 157 | Address: addr, |
| 158 | } |
| 159 | s.xdsServerV3 = &xdsServerV3{reqChan: s.XDSRequestChan, respChan: s.XDSResponseChan} |
| 160 | s.lrsServerV3 = &lrsServerV3{reqChan: s.LRSRequestChan, respChan: s.LRSResponseChan, streamOpenChan: s.LRSStreamOpenChan, streamCloseChan: s.LRSStreamCloseChan} |
| 161 | return s |
| 162 | } |
| 163 | |
| 164 | type xdsServerV3 struct { |
| 165 | reqChan *testutils.Channel |
no test coverage detected