pool

Documentation

Index

• type Options
• type Pool
  • func New(opts Options) *Pool
  • func (p *Pool) AddConnection(req *schedulerv1pb.WatchJobsRequestInitial, ...) context.Context
  • func (p *Pool) Run(ctx context.Context) error
  • func (p *Pool) Trigger(job *internalsv1pb.JobEvent, fn func(api.TriggerResponseResult))

Types

type Options

type Options struct {
	Cron api.Interface
}

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(opts Options) *Pool

func (*Pool) AddConnection

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) Run

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

func (*Pool) Trigger

func (p *Pool) Trigger(job *internalsv1pb.JobEvent, fn func(api.TriggerResponseResult))

Trigger triggers a job event to the pool. It returns a response result.