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) SetSchedulerInfo ¶ added in v1.18.0
SetSchedulerInfo publishes the scheduler cluster size and this scheduler's index into the pool. The update fans out through the namespaces loop to every connection loop so concurrency gate shares stay in sync with membership changes.
func (*Pool) Trigger ¶ added in v1.16.0
func (p *Pool) Trigger(job *internalsv1pb.JobEvent, fn func(api.TriggerResponseResult))
Trigger triggers a job event to the pool. It returns a response result.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.