onyx.messaging.protocols.status-publisher — org.onyxplatform/onyx 0.14.2

PStatusPublisher clj protocol

new-replica-version! clj

(new-replica-version! this)

block! clj

(block! this)

watermarks clj

(watermarks this)

set-heartbeat! clj

(set-heartbeat! this)

completed? clj

(completed? this)

get-session-id clj

(get-session-id this)

offer-ready-reply! clj

(offer-ready-reply! this replica-version epoch)

get-short-circuit clj

(get-short-circuit this)

get-ticket clj

(get-ticket this)

blocked? clj

(blocked? this)

set-completed! clj

(set-completed! this completed?)

get-heartbeat clj

(get-heartbeat this)

unblock! clj

(unblock! this)

start clj

(start this)

offer-barrier-status! clj

(offer-barrier-status! this replica-version epoch opts)

set-watermarks! clj

(set-watermarks! this watermarks)

set-short-id! clj

(set-short-id! this short-id)

checkpoint? clj

(checkpoint? this)

get-short-id clj

(get-short-id this)

stop clj

(stop this)

set-checkpoint! clj

(set-checkpoint! this checkpointing?)

set-session-id! clj

(set-session-id! this session-id ticket short-circuit)

info clj

(info this)