reserver

type Reserver ¶

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

Reserver is a JobHandler. It mark those bk jobs as reserved and then pass them to the next handler.

In the future, we may: - use reserver as an actor to centralize posting reservation updates. - use reserver as a periodic worker to keep reserveration expiration up-to-date.

func New(logger *zap.Logger, agentClient *api.AgentClient, nextHandler model.ManyJobHandler, enabled bool) *Reserver

func (r *Reserver) HandleMany(ctx context.Context, jobs []*api.AgentScheduledJob) error

func (r *Reserver) Pause(pause bool)