Class: PgPipeline::Request

Inherits:
Object
  • Object
show all
Defined in:
lib/pg_pipeline/request.rb

Direct Known Subclasses

PrepareRequest, PreparedQueryRequest

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(sql:, params: nil) ⇒ Request

Returns a new instance of Request.



11
12
13
14
15
16
17
18
19
20
21
22
23
24
 
# File 'lib/pg_pipeline/request.rb', line 11

def initialize(sql:, params: nil)
  @sql = RequestOps.snapshot_sql(sql)
  @params = RequestOps.snapshot_params(params)
  @state = :new
  @cancelled = false
  @settled = false
  @result_seen = false
  @query_boundary_seen = false
  @result = nil
  @error = nil
  @waiter = nil
  @waiter_scheduler = nil
  @type_map = nil
end

Instance Attribute Details

#cancelled ⇒ Object

Returns the value of attribute cancelled.



8
9
10
 
# File 'lib/pg_pipeline/request.rb', line 8

def cancelled
  @cancelled
end

#error ⇒ Object

Returns the value of attribute error.



8
9
10
 
# File 'lib/pg_pipeline/request.rb', line 8

def error
  @error
end

#params ⇒ Object (readonly)

Returns the value of attribute params.



7
8
9
 
# File 'lib/pg_pipeline/request.rb', line 7

def params
  @params
end

#query_boundary_seen ⇒ Object

Returns the value of attribute query_boundary_seen.



8
9
10
 
# File 'lib/pg_pipeline/request.rb', line 8

def query_boundary_seen
  @query_boundary_seen
end

#result ⇒ Object

Returns the value of attribute result.



8
9
10
 
# File 'lib/pg_pipeline/request.rb', line 8

def result
  @result
end

#result_seen ⇒ Object

Returns the value of attribute result_seen.



8
9
10
 
# File 'lib/pg_pipeline/request.rb', line 8

def result_seen
  @result_seen
end

#settled ⇒ Object

Returns the value of attribute settled.



8
9
10
 
# File 'lib/pg_pipeline/request.rb', line 8

def settled
  @settled
end

#sql ⇒ Object (readonly)

Returns the value of attribute sql.



7
8
9
 
# File 'lib/pg_pipeline/request.rb', line 7

def sql
  @sql
end

#state ⇒ Object

Returns the value of attribute state.



8
9
10
 
# File 'lib/pg_pipeline/request.rb', line 8

def state
  @state
end

#type_map ⇒ Object

Returns the value of attribute type_map.



8
9
10
 
# File 'lib/pg_pipeline/request.rb', line 8

def type_map
  @type_map
end

#waiter ⇒ Object

Returns the value of attribute waiter.



8
9
10
 
# File 'lib/pg_pipeline/request.rb', line 8

def waiter
  @waiter
end

#waiter_scheduler ⇒ Object

Returns the value of attribute waiter_scheduler.



8
9
10
 
# File 'lib/pg_pipeline/request.rb', line 8

def waiter_scheduler
  @waiter_scheduler
end

Class Method Details

.build(sql, params) ⇒ Object 



26
27
28
29
30
 
# File 'lib/pg_pipeline/request.rb', line 26

def self.build(sql, params)
  request = allocate
  request.__send__(:init_query, sql, params)
  request
end

.prepare(statement) ⇒ Object 



32
 
# File 'lib/pg_pipeline/request.rb', line 32

def self.prepare(statement) = PrepareRequest.new(statement)

.prepared_query(statement, params: nil) ⇒ Object 



34
35
36
 
# File 'lib/pg_pipeline/request.rb', line 34

def self.prepared_query(statement, params: nil)
  PreparedQueryRequest.build(statement, params)
end

Instance Method Details

#accept_result(result) ⇒ Object 



42
 
# File 'lib/pg_pipeline/request.rb', line 42

def accept_result(result) = RequestOps.accept_result(self, result)

#cancel! ⇒ Object 



47
 
# File 'lib/pg_pipeline/request.rb', line 47

def cancel! = RequestOps.cancel!(self)

#cancelled? ⇒ Boolean

Returns:

  • (Boolean) 


51
 
# File 'lib/pg_pipeline/request.rb', line 51

def cancelled? = @cancelled

#dispatched! ⇒ Object 



41
 
# File 'lib/pg_pipeline/request.rb', line 41

def dispatched! = RequestOps.transition!(self, :queued, :dispatched)

#finish! ⇒ Object 



45
 
# File 'lib/pg_pipeline/request.rb', line 45

def finish! = RequestOps.finish!(self)

#operation ⇒ Object 



38
 
# File 'lib/pg_pipeline/request.rb', line 38

def operation = :query

#query_boundary! ⇒ Object 



44
 
# File 'lib/pg_pipeline/request.rb', line 44

def query_boundary! = RequestOps.query_boundary!(self)

#query_boundary_seen? ⇒ Boolean

Returns:

  • (Boolean) 


50
 
# File 'lib/pg_pipeline/request.rb', line 50

def query_boundary_seen? = @query_boundary_seen

#queued! ⇒ Object 



40
 
# File 'lib/pg_pipeline/request.rb', line 40

def queued! = RequestOps.transition!(self, :new, :queued)

#record_error!(error, result: nil) ⇒ Object 



43
 
# File 'lib/pg_pipeline/request.rb', line 43

def record_error!(error, result: nil) = RequestOps.record_error!(self, error, result)

#reject!(error) ⇒ Object 



46
 
# File 'lib/pg_pipeline/request.rb', line 46

def reject!(error) = RequestOps.reject!(self, error)

#settled? ⇒ Boolean

Returns:

  • (Boolean) 


52
 
# File 'lib/pg_pipeline/request.rb', line 52

def settled? = @settled

#wait ⇒ Object 



48
 
# File 'lib/pg_pipeline/request.rb', line 48

def wait = RequestOps.wait(self)