callback

type TestDDLCallback struct {
	*ddl.BaseCallback
	// We recommended to pass the domain parameter to the test ddl callback, it will ensure
	// domain to reload schema before your ddl stepping into the next state change.
	Do ddl.DomainReloader

	OnJobRunBeforeExported func(*model.Job)

	OnJobUpdatedExported atomic.Pointer[func(*model.Job)]

	OnGetJobBeforeExported  func(string)
	OnGetJobAfterExported   func(string, *model.Job)
	OnJobSchemaStateChanged func(int64)
	// contains filtered or unexported fields
}

type TestInterceptor struct {
	*ddl.BaseInterceptor

	OnGetInfoSchemaExported func(ctx sessionctx.Context, is infoschema.InfoSchema) infoschema.InfoSchema
}