Interface PeerManager

scheduler/resource/standard/peer_manager.go:36–60

PeerManager is the interface used for peer manager.

// PeerManager is the interface used for peer manager.
type PeerManager interface {
	// Load returns peer for a key.
	Load(string) (*Peer, bool)

	// Store sets peer.
	Store(*Peer)

	// LoadOrStore returns peer the key if present.
	// Otherwise, it stores and returns the given peer.
	// The loaded result is true if the peer was loaded, false if stored.
	LoadOrStore(*Peer) (*Peer, bool)

	// Delete deletes peer for a key.
	Delete(string)

	// DeleteAllByHostID deletes all peers by host id.
	DeleteAllByHostID(string)

	// Range calls f sequentially for each key and value present in the map.
	// If f returns false, range stops the iteration.
	Range(f func(any, any) bool)

	// Try to reclaim peer.
	RunGC(context.Context) error
}

// peerManager contains content for peer manager.
type peerManager struct {