internal

Documentation

Index

• type JobEvent
• type Pool
  • func NewPool() *Pool
  • func (p *Pool) Add(req *schedulerv1pb.WatchJobsRequestInitial, ...)
  • func (p *Pool) Run(ctx context.Context) error
  • func (p *Pool) Send(ctx context.Context, job *JobEvent) error

Types

type JobEvent

type JobEvent struct {
	Name     string
	Data     *anypb.Any
	Metadata *schedulerv1pb.JobMetadata
}

JobEvent is a triggered job event.

type Pool

type Pool struct {
	// contains filtered or unexported fields
}

Pool represents a connection pool for namespace/appID separation of sidecars to schedulers.

func NewPool

func NewPool() *Pool

func (*Pool) Add

func (p *Pool) Add(req *schedulerv1pb.WatchJobsRequestInitial, stream schedulerv1pb.Scheduler_WatchJobsServer)

Add adds a connection to the pool for a given namespace/appID.

func (*Pool) Run

func (p *Pool) Run(ctx context.Context) error

func (*Pool) Send

func (p *Pool) Send(ctx context.Context, job *JobEvent) error

Send is a blocking function that sends a job trigger to a correct job recipient.