| 272 | } |
| 273 | |
| 274 | func (d *Driver) SetupNatsServer(logger g.LoggerType) (err error) { |
| 275 | natsAddr, err := net.ResolveTCPAddr("tcp", d.config.NatsBind) |
| 276 | if err != nil { |
| 277 | return fmt.Errorf("failed to parse Nats address. addr %v err %v", |
| 278 | d.config.NatsBind, err) |
| 279 | } |
| 280 | nOpts := gnatsd.Options{ |
| 281 | Host: natsAddr.IP.String(), |
| 282 | Port: natsAddr.Port, |
| 283 | MaxPayload: g.NatsMaxPayload, |
| 284 | //HTTPPort: 8199, |
| 285 | LogFile: "/opt/log", |
| 286 | Debug: true, |
| 287 | } |
| 288 | //logger.Debug("Starting nats streaming server", "addr", natsAddr) |
| 289 | sOpts := stand.GetDefaultOptions() |
| 290 | sOpts.ID = common.DefaultClusterID |
| 291 | s, err := stand.RunServerWithOpts(sOpts, &nOpts) |
| 292 | if err != nil { |
| 293 | return err |
| 294 | } |
| 295 | |
| 296 | logger.Info("Setup nats server", "addr", d.config.NatsBind) |
| 297 | |
| 298 | d.stand = s |
| 299 | return nil |
| 300 | } |
| 301 | |
| 302 | func (d *Driver) PluginInfo() (*base.PluginInfoResponse, error) { |
| 303 | return pluginInfo, nil |