class Karma::Replication::Poller

Defined in:

replication/poller.cr

Constructors

Class Method Summary

Instance Method Summary

Constructor Detail

def self.new(cluster : Cluster, host : String, port : Int32, limit : Int32 = 1000, interval : Time::Span = 1.second, token : String | Nil = nil) #

[View source]

Class Method Detail

def self.build?(cluster : Cluster) : Poller | Nil #

[View source]

Instance Method Detail

def host : String #

[View source]
def limit : Int32 #

[View source]
def poll_once : UInt64 #

[View source]
def port : Int32 #

[View source]
def start! : Nil #

[View source]
def stop! : Nil #

[View source]