abstract class PlaceOS::Resource(T)

• PlaceOS::Resource(T)
• Reference
• Object

Overview

Internally abstracts data event streams.

Defined in:

placeos-resource.cr

Constant Summary

Log = ::Log.for(self)

Constructors

• .new(processed_buffer_size : Int32 = 64, channel_buffer_size : Int32 = 64)

Instance Method Summary

• #errors : Array(Error)

  Errors generated while processing resources Mainly for inspection while testing.

• #on_reconnect

  Callback called when changefeed is reconnected

• #process_resource(action : Action, resource : T) : Result
• #processed : Deque(Event(T))

  Buffer of recently processed elements NOTE: rw lock?

• #start : self
• #startup_finished? : Bool

  Expose the status of whether the initial load of resources has completed.

• #stop : self

Constructor Detail

Instance Method Detail