Class: Ksql::Api::CloseQuery

Inherits:
Object
  • Object
show all
Defined in:
lib/ksql/api/close_query.rb

Constant Summary collapse

Headers =
{ 'Accept' => 'application/json' }.freeze

Class Method Summary collapse

Class Method Details

.build(id, headers:) ⇒ Ksql::Connection::Request

Build the ksqlDB /close-query request

Parameters:

  • id (String)

    Query ID

  • headers (Hash)

    Request headers

Returns:



16
17
18
19
20
21
22
23
# File 'lib/ksql/api/close_query.rb', line 16

def self.build(id, headers:)
  ::Ksql::Connection::Request.new(
    { queryId: id },
    '/close-query',
    Headers.merge(headers),
    :post
  )
end