Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Pool ¶
type Pool struct {
// contains filtered or unexported fields
}
Pool represents a connection pool for namespace/appID separation of sidecars to schedulers.
func (*Pool) AddConnection ¶ added in v1.16.0
func (p *Pool) AddConnection(req *schedulerv1pb.WatchJobsRequestInitial, stream schedulerv1pb.Scheduler_WatchJobsServer) context.Context
AddConnection adds a new connection to the pool. It returns a context and an error.
func (*Pool) Trigger ¶ added in v1.16.0
func (p *Pool) Trigger(ctx context.Context, job *internalsv1pb.JobEvent) api.TriggerResponseResult
Trigger triggers a job event to the pool. It returns a response result. If the context is cancelled (e.g., during engine shutdown from a quorum change), Trigger returns UNDELIVERABLE immediately instead of blocking forever waiting for the daprd to respond.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.