longops

type Base ¶

type Base struct {
	// Run is the Run on which the long operation is to be performed.
	Run *run.Run
	// Op defines what long operation to perform.
	Op *run.OngoingLongOps_Op
	// IsCancelRequested quickly checks whether the current long operation is
	// supposed to be be cancelled.
	IsCancelRequested func() bool
	// contains filtered or unexported fields
}

Base houses shared bits of all long operations.

Base is a single use object.

type ExecutePostActionOp ¶

type ExecutePostActionOp struct {
	*Base
	GFactory    gerrit.Factory
	RunNotifier *run.Notifier
	QM          *quota.Manager
}

ExecutePostActionOp executes a PostAction.

func (op *ExecutePostActionOp) Do(ctx context.Context) (*eventpb.LongOpCompleted, error)

type ExecuteTryjobsOp ¶

type ExecuteTryjobsOp struct {
	*Base
	Env         *common.Env
	RunNotifier *run.Notifier
	Backend     execute.TryjobBackend
}

ExecuteTryjobsOp executes the Tryjob Requirement for the given Run.

func (op *ExecuteTryjobsOp) Do(ctx context.Context) (*eventpb.LongOpCompleted, error)

type Operation ¶

type Operation interface {
	Do(context.Context) (*eventpb.LongOpCompleted, error)
}

Operation defines the interface for long operation implementation.

type PostGerritMessageOp ¶

type PostGerritMessageOp struct {
	// All public fields must be set.
	*Base
	GFactory gerrit.Factory
	Env      *common.Env
	// contains filtered or unexported fields
}

PostGerritMessageOp posts the given message to gerrit.

PostGerritMessageOp is a single-use object.

func (op *PostGerritMessageOp) Do(ctx context.Context) (*eventpb.LongOpCompleted, error)

type PostStartMessageOp ¶

type PostStartMessageOp struct {
	*Base
	GFactory gerrit.Factory
	Env      *common.Env
	// contains filtered or unexported fields
}

PostStartMessageOp posts a start message on each of the Run CLs.

PostStartMessageOp is a single-use object.

func (op *PostStartMessageOp) Do(ctx context.Context) (*eventpb.LongOpCompleted, error)

type ResetTriggersOp ¶

type ResetTriggersOp struct {
	*Base
	GFactory  gerrit.Factory
	CLMutator *changelist.Mutator
	// Concurrency is the number of CLs that will be reset concurrently.
	//
	// Default is 8.
	Concurrency int
	// contains filtered or unexported fields
}

ResetTriggersOp resets the triggers for the provided CLs.

ResetTriggersOp keeps retrying on lease error and transient failure for each CL till the long op deadline is exceeded or reset either succeeds or fails non-transiently.

ResetTriggersOp doesn't obey longop's cancellation request because if this long op is left half-done, for example, triggers on half of the CLs are untouched, a new Run may be created for those CLs.

ResetTriggersOp is a single-use object.

func (op *ResetTriggersOp) Do(ctx context.Context) (*eventpb.LongOpCompleted, error)