placement

Documentation

Index

• type HostInfo
• type PlacementTables
• type Service
  • func NewPlacementService(raftNode *raft.Server) *Service
  • func (p *Service) GetPlacementTables() (*PlacementTables, error)
  • func (p *Service) MonitorLeadership(parentCtx context.Context) error
  • func (p *Service) ReportDaprStatus(stream placementv1pb.Placement_ReportDaprStatusServer) error
  • func (p *Service) Run(ctx context.Context, port string, sec security.Handler) error

Types

type HostInfo

type HostInfo struct {
	Name       string   `json:"name,omitempty"`
	AppID      string   `json:"appId,omitempty"`
	ActorTypes []string `json:"actorTypes,omitempty"`
	UpdatedAt  int64    `json:"updatedAt,omitempty"`
}

type PlacementTables

type PlacementTables struct {
	HostList     []HostInfo `json:"hostList,omitempty"`
	TableVersion uint64     `json:"tableVersion,omitempty"`
}

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) GetPlacementTables

func (p *Service) GetPlacementTables() (*PlacementTables, error)

GetPlacementTables returns the current placement host infos.

func (*Service) MonitorLeadership

func (p *Service) MonitorLeadership(parentCtx context.Context) error

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(ctx context.Context, port string, sec security.Handler) error

Run starts the placement service gRPC server. Blocks until the service is closed and all connections are drained.