Class: Rubyists::Leopard::NatsJetstreamEndpoint

Inherits:
Struct
  • Object
show all
Defined in:
lib/leopard/nats_jetstream_endpoint.rb

Overview

Configuration for a Leopard JetStream pull-consumer endpoint.

Instance Attribute Summary collapse

Instance Attribute Details

#batchObject

Returns the value of attribute batch

Returns:

  • (Object)

    the current value of batch



6
7
8
# File 'lib/leopard/nats_jetstream_endpoint.rb', line 6

def batch
  @batch
end

#consumerObject

Returns the value of attribute consumer

Returns:

  • (Object)

    the current value of consumer



6
7
8
# File 'lib/leopard/nats_jetstream_endpoint.rb', line 6

def consumer
  @consumer
end

#durableObject

Returns the value of attribute durable

Returns:

  • (Object)

    the current value of durable



6
7
8
# File 'lib/leopard/nats_jetstream_endpoint.rb', line 6

def durable
  @durable
end

#fetch_timeoutObject

Returns the value of attribute fetch_timeout

Returns:

  • (Object)

    the current value of fetch_timeout



6
7
8
# File 'lib/leopard/nats_jetstream_endpoint.rb', line 6

def fetch_timeout
  @fetch_timeout
end

#handlerObject

Returns the value of attribute handler

Returns:

  • (Object)

    the current value of handler



6
7
8
# File 'lib/leopard/nats_jetstream_endpoint.rb', line 6

def handler
  @handler
end

#nak_delayObject

Returns the value of attribute nak_delay

Returns:

  • (Object)

    the current value of nak_delay



6
7
8
# File 'lib/leopard/nats_jetstream_endpoint.rb', line 6

def nak_delay
  @nak_delay
end

#nameObject

Returns the value of attribute name

Returns:

  • (Object)

    the current value of name



6
7
8
# File 'lib/leopard/nats_jetstream_endpoint.rb', line 6

def name
  @name
end

#streamObject

Returns the value of attribute stream

Returns:

  • (Object)

    the current value of stream



6
7
8
# File 'lib/leopard/nats_jetstream_endpoint.rb', line 6

def stream
  @stream
end

#subjectObject

Returns the value of attribute subject

Returns:

  • (Object)

    the current value of subject



6
7
8
# File 'lib/leopard/nats_jetstream_endpoint.rb', line 6

def subject
  @subject
end