Class: Julewire::GCP::Destination

Inherits:
Core::Destinations::Destination
  • Object
show all
Defined in:
lib/julewire/gcp/destination.rb

Instance Method Summary collapse

Constructor Details

#initialize(output:, name: :gcp, formatter: nil, encoder: Julewire::JsonEncoder.new, max_record_bytes: DEFAULT_MAX_RECORD_BYTES, close_output: false, on_drop: nil, on_failure: nil) ⇒ Destination

Returns a new instance of Destination.



6
7
8
9
10
11
12
13
14
15
16
17
18
19
 
# File 'lib/julewire/gcp/destination.rb', line 6

def initialize(output:, name: :gcp, formatter: nil, encoder: Julewire::JsonEncoder.new,
               max_record_bytes: DEFAULT_MAX_RECORD_BYTES, close_output: false, on_drop: nil,
               on_failure: nil)
  super(
    name: name,
    close_output: close_output,
    encoder: encoder,
    formatter: formatter || Formatter.new,
    max_record_bytes: max_record_bytes,
    on_drop: on_drop,
    on_failure: on_failure,
    output: output
  )
end