placement

Documentation

Index

• type HostInfo
• type PlacementTables
• type Service
  • func New(opts ServiceOpts) (*Service, error)
  • func (p *Service) GetPlacementTables() (*PlacementTables, error)
  • func (p *Service) MonitorLeadership(ctx context.Context) error
  • func (p *Service) ReportDaprStatus(stream placementv1pb.Placement_ReportDaprStatusServer) error
  • func (p *Service) Run(ctx context.Context) error
• type ServiceOpts
  • func (o *ServiceOpts) SetMaxAPILevel(apiLevel int)
  • func (o *ServiceOpts) SetMinAPILevel(apiLevel int)

Types

type HostInfo

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

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 New

func New(opts ServiceOpts) (*Service, error)

New 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(ctx context.Context) error

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

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

type ServiceOpts

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

func (o *ServiceOpts) SetMaxAPILevel(apiLevel int)

func (*ServiceOpts) SetMinAPILevel

func (o *ServiceOpts) SetMinAPILevel(apiLevel int)