Documentation ¶
Overview ¶
Package hh provides a hinted handoff service for Pub.
Hinted handoff is helpful for quick recovery from short term outages like server restarts or rebalancing.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Service ¶
type Service interface { // Start the hinted handoff service. Start() error // Stop the hinted handoff service. Stop() // Name returns the underlying implementation name. Name() string // Append add key/value byte slice to end of the buffer. Append(cluster, topic string, key, value []byte) error // Empty returns whether the buffer has no inflight entries. Empty(cluster, topic string) bool // FlushInflights flush all inflight entries inside buffer to final message storage. FlushInflights() // Inflights() returns all queues inflights messages count total. Inflights() int64 // AppendN returns all queues successfully appended messages count total. AppendN() int64 // DeliverN returns all queues successfully delivered messages count total. DeliverN() int64 // ResetCounters reset AppendN and DeliverN to 0. ResetCounters() }
var Default Service
Directories ¶
Path | Synopsis |
---|---|
Package disk implements a disk-backend hinted handoff which uses raft for replication.
|
Package disk implements a disk-backend hinted handoff which uses raft for replication. |
Package kafka implements a kafka-backend hinted handoff.
|
Package kafka implements a kafka-backend hinted handoff. |
Click to show internal directories.
Click to hide internal directories.