MCPcopy
hub / github.com/nats-io/nats.go / DeleteStream

Method DeleteStream

jsm.go:1180–1209  ·  view source on GitHub ↗

DeleteStream deletes a Stream.

(name string, opts ...JSOpt)

Source from the content-addressed store, hash-verified

1178
1179// DeleteStream deletes a Stream.
1180func (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
1211type apiMsgGetRequest struct {
1212 Seq uint64 `json:"seq,omitempty"`

Callers 2

DeleteKeyValueMethod · 0.95
DeleteObjectStoreMethod · 0.95

Calls 5

apiSubjMethod · 0.95
apiRequestWithContextMethod · 0.95
checkStreamNameFunction · 0.85
getJSContextOptsFunction · 0.85
IsMethod · 0.45

Tested by

no test coverage detected