placement

Documentation

Index

• Constants
• type HostInfo
• type PlacementServiceOpts
• type PlacementTables
• type Service
  • func NewPlacementService(opts PlacementServiceOpts) *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) error

Constants

const (
	GRPCContextKeyAcceptVNodes = "dapr-accept-vnodes"
)

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"`
	APILevel   uint32   `json:"apiLevel"`
}

type PlacementServiceOpts

type PlacementServiceOpts struct {
	RaftNode    *raft.Server
	MaxAPILevel *uint32
	MinAPILevel uint32
	SecProvider security.Provider
}

PlacementServiceOpts contains options for the NewPlacementService method.

type PlacementTables

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

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(opts PlacementServiceOpts) *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) error

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