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

Method CreateOrUpdateStream

jetstream/jetstream.go:144–144  ·  view source on GitHub ↗

CreateOrUpdateStream creates a stream with the given config. If stream already exists, it will be updated (if possible).

(ctx context.Context, cfg StreamConfig)

Source from the content-addressed store, hash-verified

142 // CreateOrUpdateStream creates a stream with the given config. If stream
143 // already exists, it will be updated (if possible).
144 CreateOrUpdateStream(ctx context.Context, cfg StreamConfig) (Stream, error)
145
146 // Stream fetches [StreamInfo] and returns a [Stream] interface for a given stream name.
147 // If stream does not exist, ErrStreamNotFound is returned.

Callers 2

TestCreateOrUpdateStreamFunction · 0.65

Implementers 1

jetStreamjetstream/jetstream.go

Calls

no outgoing calls

Tested by 2

TestCreateOrUpdateStreamFunction · 0.52