Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Options ¶
type Options struct {
Namespace string
AppID string
Actors actors.Interface
Channels *channels.Channels
WFEngine wfengine.Interface
WorkflowSpec *config.WorkflowSpec
Addresses []string
Security security.Handler
Healthz healthz.Healthz
SchedulerStreams uint
// PlacementAddresses are the placement service addresses this daprd was
// configured with, reported to the schedulers so they can detect a
// placement service outside the well-known service name.
PlacementAddresses []string
// ActorAddress is the daprd internal gRPC host:port reported on
// WatchJobs streams, so schedulers route actor reminder triggers to
// the placement owner host.
ActorAddress string
}
type Scheduler ¶ added in v1.15.0
type Scheduler struct {
// contains filtered or unexported fields
}
Scheduler manages the connection to the cluster of schedulers.
func (*Scheduler) Leadership ¶ added in v1.19.0
func (s *Scheduler) Leadership() *leadership.Leadership
Leadership returns the store tracking the scheduler placement leader as observed on the WatchHosts stream.
func (*Scheduler) ReloadActorTypes ¶ added in v1.15.6
Directories
¶
| Path | Synopsis |
|---|---|
|
internal
|
|
|
Package leadership tracks the scheduler placement leader as observed on the WatchHosts stream, for consumers (the actor placement client) which need to connect to the current leader and react to leadership changes.
|
Package leadership tracks the scheduler placement leader as observed on the WatchHosts stream, for consumers (the actor placement client) which need to connect to the current leader and react to leadership changes. |
Click to show internal directories.
Click to hide internal directories.