pool

Documentation

Index

• type JobEvent
• type Pool
  • func New(cron api.Interface) *Pool
  • func (p *Pool) Add(req *schedulerv1pb.WatchJobsRequestInitial, ...) error
  • func (p *Pool) Run(ctx context.Context) error
  • func (p *Pool) Send(ctx context.Context, job *JobEvent) api.TriggerResponseResult

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 New

func New(cron api.Interface) *Pool

func (*Pool) Add

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

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) api.TriggerResponseResult

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