PurgeStream purges messages on a Stream.
(stream string, opts ...JSOpt)
| 1475 | |
| 1476 | // PurgeStream purges messages on a Stream. |
| 1477 | func (js *js) PurgeStream(stream string, opts ...JSOpt) error { |
| 1478 | if err := checkStreamName(stream); err != nil { |
| 1479 | return err |
| 1480 | } |
| 1481 | var req *StreamPurgeRequest |
| 1482 | var ok bool |
| 1483 | for _, opt := range opts { |
| 1484 | // For PurgeStream, only request body opt is relevant |
| 1485 | if req, ok = opt.(*StreamPurgeRequest); ok { |
| 1486 | break |
| 1487 | } |
| 1488 | } |
| 1489 | return js.purgeStream(stream, req) |
| 1490 | } |
| 1491 | |
| 1492 | func (js *js) purgeStream(stream string, req *StreamPurgeRequest, opts ...JSOpt) error { |
| 1493 | o, cancel, err := getJSContextOpts(js.opts, opts...) |
nothing calls this directly
no test coverage detected