placement

Documentation

Index

• type Service
  • func NewPlacementService(raftNode *raft.Server) *Service
  • func (p *Service) MonitorLeadership()
  • func (p *Service) ReportDaprStatus(stream placementv1pb.Placement_ReportDaprStatusServer) error
  • func (p *Service) Run(port string, certChain *dapr_credentials.CertChain)
  • func (p *Service) Shutdown()

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

func NewPlacementService(raftNode *raft.Server) *Service

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.

func (*Service) Run

func (p *Service) Run(port string, certChain *dapr_credentials.CertChain)

Run starts the placement service gRPC server.

func (*Service) Shutdown

func (p *Service) Shutdown()

Shutdown close all server connections.