hh

package
v0.0.0-...-077b43f Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 27, 2017 License: Apache-2.0 Imports: 0 Imported by: 5

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL