Class: QuicknodeSdk::Streams

Inherits:
NativeDelegator show all
Defined in:
lib/quicknode_sdk/clients/streams.rb,
sig/quicknode_sdk.rbs

Instance Method Summary collapse

Methods inherited from NativeDelegator

#method_missing, #respond_to_missing?

Constructor Details

#initialize ⇒ Streams

Returns a new instance of Streams.

Parameters:

  • native (Object) 


118
 
# File 'sig/quicknode_sdk.rbs', line 118

def initialize: (untyped native) -> void

Dynamic Method Handling

This class handles dynamic methods through the method_missing method in the class QuicknodeSdk::NativeDelegator

Instance Method Details

#activate_stream ⇒ void

This method returns an undefined value.

Parameters:

  • id: (String) 


126
 
# File 'sig/quicknode_sdk.rbs', line 126

def activate_stream: (id: String) -> void

#create_stream ⇒ Object

Parameters:

  • name: (String)
  • network: (String)
  • dataset: (String)
  • region: (String)
  • start_range: (Integer)
  • end_range: (Integer)
  • destination_attributes: (DestinationAttributes)
  • dataset_batch_size: (Integer)
  • elastic_batch_enabled: (Boolean)
  • plan: (String)
  • threshold_fetch_buffer: (Integer)
  • max_batch_size: (Integer)
  • max_buffer_range_size: (Integer)
  • max_buffer_processing_workers: (Integer)
  • keep_distance_from_tip: (Integer)
  • filter_function: (String)
  • filter_language: (String)
  • include_stream_metadata: (String)
  • product_type: (String)
  • status: (String)
  • notification_email: (String)
  • charge_min_cap: (Integer)
  • fix_block_reorgs: (Integer)
  • extra_destinations: (Array[DestinationAttributes])

Returns:

  • (Object) 


120
 
# File 'sig/quicknode_sdk.rbs', line 120

def create_stream: (name: String, network: String, dataset: String, region: String, start_range: Integer, end_range: Integer, destination_attributes: DestinationAttributes, dataset_batch_size: Integer, elastic_batch_enabled: bool, ?plan: String, ?threshold_fetch_buffer: Integer, ?max_batch_size: Integer, ?max_buffer_range_size: Integer, ?max_buffer_processing_workers: Integer, ?keep_distance_from_tip: Integer, ?filter_function: String, ?filter_language: String, ?include_stream_metadata: String, ?product_type: String, ?status: String, ?notification_email: String, ?charge_min_cap: Integer, ?fix_block_reorgs: Integer, ?extra_destinations: Array[DestinationAttributes]) -> untyped

#delete_all_streams ⇒ void

This method returns an undefined value.



122
 
# File 'sig/quicknode_sdk.rbs', line 122

def delete_all_streams: () -> void

#delete_stream ⇒ void

This method returns an undefined value.

Parameters:

  • id: (String) 


125
 
# File 'sig/quicknode_sdk.rbs', line 125

def delete_stream: (id: String) -> void

#get_enabled_count ⇒ Object

Parameters:

  • stream_type: (String)

Returns:

  • (Object) 


129
 
# File 'sig/quicknode_sdk.rbs', line 129

def get_enabled_count: (?stream_type: String) -> untyped

#get_stream ⇒ Object

Parameters:

  • id: (String)

Returns:

  • (Object) 


123
 
# File 'sig/quicknode_sdk.rbs', line 123

def get_stream: (id: String) -> untyped

#list_streams ⇒ Object

Parameters:

  • stream_type: (String)
  • offset: (Integer)
  • limit: (Integer)
  • order_by: (String)
  • order_direction: (String)

Returns:

  • (Object) 


121
 
# File 'sig/quicknode_sdk.rbs', line 121

def list_streams: (?stream_type: String, ?offset: Integer, ?limit: Integer, ?order_by: String, ?order_direction: String) -> untyped

#pause_stream ⇒ void

This method returns an undefined value.

Parameters:

  • id: (String) 


127
 
# File 'sig/quicknode_sdk.rbs', line 127

def pause_stream: (id: String) -> void

#test_filter ⇒ Object

Parameters:

  • network: (String)
  • dataset: (String)
  • block: (String)
  • filter_function: (String)
  • filter_language: (String)

Returns:

  • (Object) 


128
 
# File 'sig/quicknode_sdk.rbs', line 128

def test_filter: (network: String, dataset: String, block: String, filter_function: String, ?filter_language: String) -> untyped

#update_stream ⇒ Object

Parameters:

  • id: (String)
  • name: (String)
  • network: (String)
  • dataset: (String)
  • region: (String)
  • start_range: (Integer)
  • end_range: (Integer)
  • destination_attributes: (DestinationAttributes)
  • plan: (String)
  • threshold_fetch_buffer: (Integer)
  • dataset_batch_size: (Integer)
  • max_batch_size: (Integer)
  • max_buffer_range_size: (Integer)
  • max_buffer_processing_workers: (Integer)
  • keep_distance_from_tip: (Integer)
  • filter_function: (String)
  • filter_language: (String)
  • include_stream_metadata: (String)
  • notification_email: (String)
  • charge_min_cap: (Integer)
  • fix_block_reorgs: (Integer)
  • elastic_batch_enabled: (Boolean)
  • status: (String)
  • memo: (String)
  • extra_destinations: (Array[DestinationAttributes])

Returns:

  • (Object) 


124
 
# File 'sig/quicknode_sdk.rbs', line 124

def update_stream: (id: String, ?name: String, ?network: String, ?dataset: String, ?region: String, ?start_range: Integer, ?end_range: Integer, ?destination_attributes: DestinationAttributes, ?plan: String, ?threshold_fetch_buffer: Integer, ?dataset_batch_size: Integer, ?max_batch_size: Integer, ?max_buffer_range_size: Integer, ?max_buffer_processing_workers: Integer, ?keep_distance_from_tip: Integer, ?filter_function: String, ?filter_language: String, ?include_stream_metadata: String, ?notification_email: String, ?charge_min_cap: Integer, ?fix_block_reorgs: Integer, ?elastic_batch_enabled: bool, ?status: String, ?memo: String, ?extra_destinations: Array[DestinationAttributes]) -> untyped