Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
Service updates the Dapr runtimes with distributed hash tables for stateful entities.
func NewPlacementService ¶
NewPlacementService returns a new placement service.
func (*Service) MonitorLeadership ¶
func (p *Service) MonitorLeadership()
MonitorLeadership is used to monitor if we acquire or lose our role as the leader in the Raft cluster. There is some work the leader is expected to do, so we must react to changes
reference: https://github.com/hashicorp/consul/blob/master/agent/consul/leader.go
func (*Service) ReportDaprStatus ¶
func (p *Service) ReportDaprStatus(stream placementv1pb.Placement_ReportDaprStatusServer) error
ReportDaprStatus gets a heartbeat report from different Dapr hosts.
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
Package placement is an implementation of Consistent Hashing and Consistent Hashing With Bounded Loads.
|
Package placement is an implementation of Consistent Hashing and Consistent Hashing With Bounded Loads. |
Click to show internal directories.
Click to hide internal directories.