Open Sidebar
Close Sidebar
CrystalDoc.info
Source code
Shards.info
nats
v1.2.2
NATS
Client
ClientClosed
Data
State
Data
Error
Headers
JetStream
API
Message
V1
APIError
ClusterInfo
Consumer
Sequence
ConsumerConfig
AckPolicy
DeliverPolicy
ReplayPolicy
ConsumerListResponse
Consumers
ErrorResponse
Error
ExternalStream
NanosecondsConverter
PeerInfo
PubAck
Stream
StreamConfig
DiscardPolicy
Placement
Republish
RetentionPolicy
Storage
StreamGetMsgResponse
Message
Base64Data
HeadersConverter
StreamListResponse
Streams
PurgeStreamResponse
StreamSource
StreamSourceInfo
StreamState
Client
NAKBackoff
Consumers
Error
Errors
ExternalStream
Message
InvalidJetStreamMessage
Placement
PullSubscription
Streams
StreamSource
KV
Bucket
Client
Entry
Operation
Error
InvalidKeyname
KeyEmptyError
KeyError
Watch
Iterator
Message
Headers
NotAReply
NUID
Objects
Bucket
Client
ObjectInfo
Watch
Error
KeyError
ServerInfo
ServerNotRespondingToPings
Subscription
MessageChannel
UnknownCommand
Built with Crystal 1.9.2
2023-10-08 18:32:57 UTC
struct
NATS::JetStream::API::V1::PeerInfo
NATS::JetStream::API::V1::PeerInfo
NATS::JetStream::API::Message
Struct
Value
Object
Defined in:
jetstream.cr
Constructors
.new
(pull : JSON::PullParser)
Instance Method Summary
#active
: Time::Span
#current?
: Bool
#lag
: UInt64
#name
: String
#offline?
: Bool
Constructor methods inherited from struct
NATS::JetStream::API::Message
new(pull : JSON::PullParser)
new
Constructor Detail
def self.
new
(pull : JSON::PullParser)
#
[
View source
]
Instance Method Detail
def
active
: Time::Span
#
[
View source
]
def
current?
: Bool
#
[
View source
]
def
lag
: UInt64
#
[
View source
]
def
name
: String
#
[
View source
]
def
offline?
: Bool
#
[
View source
]