Class: Svix::StreamingSinkTransformation

Inherits:
Object
  • Object
show all
Defined in:
lib/svix/api/streaming_sink_transformation.rb

Instance Method Summary collapse

Constructor Details

#initialize(client) ⇒ StreamingSinkTransformation

Returns a new instance of StreamingSinkTransformation.



8
9
10
 
# File 'lib/svix/api/streaming_sink_transformation.rb', line 8

def initialize(client)
  @client = client
end

Instance Method Details

#get(stream_id, sink_id) ⇒ Object 



12
13
14
15
16
17
18
 
# File 'lib/svix/api/streaming_sink_transformation.rb', line 12

def get(stream_id, sink_id)
  res = @client.execute_request(
    "GET",
    "/api/v1/stream/#{stream_id}/sink/#{sink_id}/transformation"
  )
  SinkTransformationOut.deserialize(res)
end

#patch(stream_id, sink_id, sink_transform_in) ⇒ Object 



20
21
22
23
24
25
26
27
 
# File 'lib/svix/api/streaming_sink_transformation.rb', line 20

def patch(stream_id, sink_id, sink_transform_in)
  res = @client.execute_request(
    "PATCH",
    "/api/v1/stream/#{stream_id}/sink/#{sink_id}/transformation",
    body: sink_transform_in
  )
  EmptyResponse.deserialize(res)
end