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
 
# 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
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

#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

.prepare(statement) ⇒ Object 



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

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

.prepared_query(statement, params: nil) ⇒ Object 



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

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

Instance Method Details

#accept_result(result) ⇒ Object 



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

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

#cancel! ⇒ Object 



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

def cancel! = RequestOps.cancel!(self)

#cancelled? ⇒ Boolean

Returns:

  • (Boolean) 


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

def cancelled? = @cancelled

#dispatched! ⇒ Object 



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

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

#finish! ⇒ Object 



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

def finish! = RequestOps.finish!(self)

#operation ⇒ Object 



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

def operation = :query

#query_boundary! ⇒ Object 



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

def query_boundary! = RequestOps.query_boundary!(self)

#query_boundary_seen? ⇒ Boolean

Returns:

  • (Boolean) 


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

def query_boundary_seen? = @query_boundary_seen

#queued! ⇒ Object 



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

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

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



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

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

#reject!(error) ⇒ Object 



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

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

#settled? ⇒ Boolean

Returns:

  • (Boolean) 


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

def settled? = @settled

#wait ⇒ Object 



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

def wait = RequestOps.wait(self)