struct

NATS::JetStream::StreamSource

Inherits NATS::JetStream::Entity < JSON::Serializable < Struct < Value < Object

Constructors

new(pull : JSON::PullParser)
Source
new(name : String, opt_start_seq : UInt64 | Nil = nil, opt_start_time : Time | Nil = nil, filter_subject : Nil | String = nil, subject_transforms : Nil | Array(NATS::JetStream::SubjectTransform) = nil, external : NATS::JetStream::ExternalStream | Nil = nil, consumer : NATS::JetStream::StreamSource::Consumer | Nil = nil)
Source

Instance methods

consumer
Source
external
Source
filter_subject
Source
name
Source
opt_start_seq
Source
opt_start_time
Source
subject_transforms
Source

Nested types