DeleteStream deletes a Stream.
(name string, opts ...JSOpt)
| 1178 | |
| 1179 | // DeleteStream deletes a Stream. |
| 1180 | func (js *js) DeleteStream(name string, opts ...JSOpt) error { |
| 1181 | if err := checkStreamName(name); err != nil { |
| 1182 | return err |
| 1183 | } |
| 1184 | o, cancel, err := getJSContextOpts(js.opts, opts...) |
| 1185 | if err != nil { |
| 1186 | return err |
| 1187 | } |
| 1188 | if cancel != nil { |
| 1189 | defer cancel() |
| 1190 | } |
| 1191 | |
| 1192 | dsSubj := js.apiSubj(fmt.Sprintf(apiStreamDeleteT, name)) |
| 1193 | r, err := js.apiRequestWithContext(o.ctx, dsSubj, nil) |
| 1194 | if err != nil { |
| 1195 | return err |
| 1196 | } |
| 1197 | var resp streamDeleteResponse |
| 1198 | if err := json.Unmarshal(r.Data, &resp); err != nil { |
| 1199 | return err |
| 1200 | } |
| 1201 | |
| 1202 | if resp.Error != nil { |
| 1203 | if errors.Is(resp.Error, ErrStreamNotFound) { |
| 1204 | return ErrStreamNotFound |
| 1205 | } |
| 1206 | return resp.Error |
| 1207 | } |
| 1208 | return nil |
| 1209 | } |
| 1210 | |
| 1211 | type apiMsgGetRequest struct { |
| 1212 | Seq uint64 `json:"seq,omitempty"` |
no test coverage detected