Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PlacementTables ¶
type Service ¶ added in v0.2.0
type Service struct {
// contains filtered or unexported fields
}
Service updates the Dapr runtimes with distributed hash tables for stateful entities.
func New ¶ added in v1.15.0
func New(opts ServiceOpts) (*Service, error)
New returns a new placement service.
func (*Service) GetPlacementTables ¶ added in v1.12.0
func (p *Service) GetPlacementTables() (*PlacementTables, error)
GetPlacementTables returns the current placement host infos.
func (*Service) MonitorLeadership ¶ added in v1.0.0
MonitorLeadership is used to monitor leadership changes in the Raft cluster so we can update the leadership status of the Placement server
func (*Service) ReportDaprStatus ¶ added in v0.2.0
func (p *Service) ReportDaprStatus(stream placementv1pb.Placement_ReportDaprStatusServer) error
ReportDaprStatus gets a heartbeat report from different Dapr hosts.
type ServiceOpts ¶ added in v1.15.0
type ServiceOpts struct {
MaxAPILevel *uint32
MinAPILevel uint32
SecProvider security.Provider
Port int
ListenAddress string
Healthz healthz.Healthz
KeepAliveTime time.Duration
KeepAliveTimeout time.Duration
DisseminateTimeout time.Duration
Raft raft.Options
}
ServiceOpts contains options for the New method.
func (*ServiceOpts) SetMaxAPILevel ¶ added in v1.15.0
func (o *ServiceOpts) SetMaxAPILevel(apiLevel int)
func (*ServiceOpts) SetMinAPILevel ¶ added in v1.15.0
func (o *ServiceOpts) SetMinAPILevel(apiLevel int)
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.