hbcache

package

v3.0.0-beta13 Latest Latest Go to latest Published: Jan 20, 2026 License: Apache-2.0 Imports: 7 Imported by: 0

Details

Package hbcache manage []cluster.HeartbeatStream cache localnode

This cache will be populated from:

The cache must be started with Start(ctx). It is stopped when ctx is done

This section is empty.

This section is empty.

func DropPeer(peer string)

DropPeer drop a node from cache

func Heartbeats() ([]daemonsubsystem.HeartbeatStream, bool)

Heartbeats retrieves the current list of heartbeat streams and their status, returning a boolean indicating changes since last cammand call.

func SetHeartbeats(hbs []daemonsubsystem.HeartbeatStream, changed bool)

SetHeartbeats updates the heartbeats status cache

can be used from a heartbeat controller

type T struct {
	// contains filtered or unexported fields
}

func New(drainDuration time.Duration) *T

func (t *T) Start(ctx context.Context) error

func (t *T) Stop() error