Unlock 30% off on Manual Testing Annual Plans this Holiday Season.

Copied to Clipboard!

How to use updateStatus method of run Package

Best Keploy code snippet using run.updateStatus

run.go

Source:run.go

...105func (r *Run) Discard() error {106	if !r.Discardable() {107		return ErrRunDiscardNotAllowed108	}109	r.updateStatus(RunDiscarded)110	return nil111}112// Cancel run.113func (r *Run) Cancel() error {114	if !r.Cancelable() {115		return ErrRunCancelNotAllowed116	}117	r.updateStatus(RunCanceled)118	return nil119}120func (r *Run) ForceCancelAvailableAt() time.Time {121	if r.status != RunCanceled {122		return time.Time{}123	}124	canceledAt, err := r.StatusTimestamp(r.status)125	if err != nil {126		panic("no corresponding timestamp found for canceled status")127	}128	// Run can be forcefully cancelled after a cool-off period of ten seconds129	return canceledAt.Add(10 * time.Second)130}131// ForceCancel updates the state of a run to reflect it having been forcefully132// cancelled.133func (r *Run) ForceCancel() error {134	if !r.ForceCancelable() {135		return ErrRunForceCancelNotAllowed136	}137	return r.updateStatus(RunForceCanceled)138}139// Cancelable determines whether run can be cancelled.140func (r *Run) Cancelable() bool {141	switch r.Status() {142	case RunPending, RunPlanQueued, RunPlanning, RunApplyQueued, RunApplying:143		return true144	default:145		return false146	}147}148// Confirmable determines whether run can be confirmed.149func (r *Run) Confirmable() bool {150	switch r.Status() {151	case RunPlanned:152		return true153	default:154		return false155	}156}157// Discardable determines whether run can be discarded.158func (r *Run) Discardable() bool {159	switch r.Status() {160	case RunPending, RunPlanned:161		return true162	default:163		return false164	}165}166// ForceCancelable determines whether a run can be forcibly cancelled.167func (r *Run) ForceCancelable() bool {168	availAt := r.ForceCancelAvailableAt()169	if availAt.IsZero() {170		return false171	}172	return CurrentTimestamp().After(availAt)173}174// Active determines whether run is currently the active run on a workspace,175// i.e. it is neither finished nor pending176func (r *Run) Active() bool {177	if r.Done() || r.Status() == RunPending {178		return false179	}180	return true181}182// Done determines whether run has reached an end state, e.g. applied,183// discarded, etc.184func (r *Run) Done() bool {185	switch r.Status() {186	case RunApplied, RunPlannedAndFinished, RunDiscarded, RunCanceled, RunErrored:187		return true188	default:189		return false190	}191}192func (r *Run) Speculative() bool {193	return r.speculative194}195func (r *Run) ApplyRun() error {196	return r.updateStatus(RunApplyQueued)197}198func (r *Run) EnqueuePlan() error {199	return r.updateStatus(RunPlanQueued)200}201func (r *Run) StatusTimestamp(status RunStatus) (time.Time, error) {202	for _, rst := range r.statusTimestamps {203		if rst.Status == status {204			return rst.Timestamp, nil205		}206	}207	return time.Time{}, ErrStatusTimestampNotFound208}209// CanLock determines whether requestor can replace run lock210func (r *Run) CanLock(requestor Identity) error {211	if _, ok := requestor.(*Run); ok {212		// run can replace lock held by different run213		return nil214	}215	return ErrWorkspaceAlreadyLocked216}217// CanUnlock determines whether requestor can unlock run lock218func (r *Run) CanUnlock(requestor Identity, force bool) error {219	if force {220		// TODO: only grant admin user force unlock always granted221		return nil222	}223	if _, ok := requestor.(*Run); ok {224		// runs can unlock other run locks225		return nil226	}227	return ErrWorkspaceLockedByDifferentUser228}229// Start a run job230func (r *Run) Start() error {231	switch r.status {232	case RunPlanQueued:233		r.updateStatus(RunPlanning)234	case RunApplyQueued:235		r.updateStatus(RunApplying)236	case RunPlanning, RunApplying:237		return ErrJobAlreadyClaimed238	default:239		return fmt.Errorf("run cannot be started: invalid status: %s", r.Status())240	}241	return nil242}243// Finish updates the run to reflect its plan having finished. An event is244// returned reflecting the run's new status.245func (r *Run) Finish(opts JobFinishOptions) (*Event, error) {246	if opts.Errored {247		if err := r.updateStatus(RunErrored); err != nil {248			return nil, err249		}250		return &Event{Payload: r, Type: EventRunErrored}, nil251	}252	switch r.status {253	case RunPlanning:254		r.updateStatus(RunPlanned)255		return r.plan.Finish()256	case RunApplying:257		r.updateStatus(RunApplied)258		return &Event{Payload: r, Type: EventRunApplied}, nil259	default:260		return nil, fmt.Errorf("run cannot be finished: invalid status: %s", r.status)261	}262}263// ToJSONAPI assembles a JSON-API DTO.264func (r *Run) ToJSONAPI(req *http.Request) any {265	dto := &jsonapi.Run{266		ID: r.ID(),267		Actions: &jsonapi.RunActions{268			IsCancelable:      r.Cancelable(),269			IsConfirmable:     r.Confirmable(),270			IsForceCancelable: r.ForceCancelable(),271			IsDiscardable:     r.Discardable(),272		},273		CreatedAt:              r.CreatedAt(),274		ForceCancelAvailableAt: r.ForceCancelAvailableAt(),275		HasChanges:             r.plan.HasChanges(),276		IsDestroy:              r.IsDestroy(),277		Message:                r.Message(),278		Permissions: &jsonapi.RunPermissions{279			CanForceCancel:  true,280			CanApply:        true,281			CanCancel:       true,282			CanDiscard:      true,283			CanForceExecute: true,284		},285		PositionInQueue:  0,286		Refresh:          r.Refresh(),287		RefreshOnly:      r.RefreshOnly(),288		ReplaceAddrs:     r.ReplaceAddrs(),289		Source:           DefaultConfigurationSource,290		Status:           string(r.Status()),291		StatusTimestamps: &jsonapi.RunStatusTimestamps{},292		TargetAddrs:      r.TargetAddrs(),293		// Relations294		Apply: r.apply.ToJSONAPI(req).(*jsonapi.Apply),295		Plan:  r.plan.ToJSONAPI(req).(*jsonapi.Plan),296		// Hardcoded anonymous user until authorization is introduced297		CreatedBy: &jsonapi.User{298			ID:       DefaultUserID,299			Username: DefaultUsername,300		},301		ConfigurationVersion: &jsonapi.ConfigurationVersion{302			ID: r.configurationVersionID,303		},304	}305	if r.workspace != nil {306		dto.Workspace = r.workspace.ToJSONAPI(req).(*jsonapi.Workspace)307	} else {308		dto.Workspace = &jsonapi.Workspace{309			ID: r.workspaceID,310		}311	}312	for _, rst := range r.StatusTimestamps() {313		switch rst.Status {314		case RunPending:315			dto.StatusTimestamps.PlanQueueableAt = &rst.Timestamp316		case RunPlanQueued:317			dto.StatusTimestamps.PlanQueuedAt = &rst.Timestamp318		case RunPlanning:319			dto.StatusTimestamps.PlanningAt = &rst.Timestamp320		case RunPlanned:321			dto.StatusTimestamps.PlannedAt = &rst.Timestamp322		case RunPlannedAndFinished:323			dto.StatusTimestamps.PlannedAndFinishedAt = &rst.Timestamp324		case RunApplyQueued:325			dto.StatusTimestamps.ApplyQueuedAt = &rst.Timestamp326		case RunApplying:327			dto.StatusTimestamps.ApplyingAt = &rst.Timestamp328		case RunApplied:329			dto.StatusTimestamps.AppliedAt = &rst.Timestamp330		case RunErrored:331			dto.StatusTimestamps.ErroredAt = &rst.Timestamp332		case RunCanceled:333			dto.StatusTimestamps.CanceledAt = &rst.Timestamp334		case RunForceCanceled:335			dto.StatusTimestamps.ForceCanceledAt = &rst.Timestamp336		case RunDiscarded:337			dto.StatusTimestamps.DiscardedAt = &rst.Timestamp338		}339	}340	return dto341}342// updateStatus transitions the state - changes to a run are made only via this343// method.344func (r *Run) updateStatus(status RunStatus) error {345	switch status {346	case RunPending:347		r.plan.updateStatus(JobPending)348		r.apply.updateStatus(JobPending)349	case RunPlanQueued:350		r.plan.updateStatus(JobQueued)351	case RunPlanning:352		r.plan.updateStatus(JobRunning)353	case RunPlanned, RunPlannedAndFinished:354		r.plan.updateStatus(JobFinished)355		r.apply.updateStatus(JobUnreachable)356	case RunApplyQueued:357		r.apply.updateStatus(JobQueued)358	case RunApplying:359		r.apply.updateStatus(JobRunning)360	case RunApplied:361		r.apply.updateStatus(JobFinished)362	case RunErrored:363		switch r.Status() {364		case RunPlanning:365			r.plan.updateStatus(JobErrored)366			r.apply.updateStatus(JobUnreachable)367		case RunApplying:368			r.apply.updateStatus(JobErrored)369		}370	case RunCanceled:371		switch r.Status() {372		case RunPlanQueued, RunPlanning:373			r.plan.updateStatus(JobCanceled)374			r.apply.updateStatus(JobUnreachable)375		case RunApplyQueued, RunApplying:376			r.apply.updateStatus(JobCanceled)377		}378	}379	r.status = status380	r.statusTimestamps = append(r.statusTimestamps, RunStatusTimestamp{381		Status:    status,382		Timestamp: CurrentTimestamp(),383	})384	// set job reflecting new status385	r.setJob()386	return nil387}388// setupEnv invokes the necessary steps before a plan or apply can proceed.389func (r *Run) setupEnv(env Environment) error {390	if err := env.RunFunc(r.downloadConfig); err != nil {...

service_test.go

Source:service_test.go

1// Copyright 2020 Google LLC2//3// Licensed under the Apache License, Version 2.0 (the "License");4// you may not use this file except in compliance with the License.5// You may obtain a copy of the License at6//7//     https://www.apache.org/licenses/LICENSE-2.08//9// Unless required by applicable law or agreed to in writing, software10// distributed under the License is distributed on an "AS IS" BASIS,11// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.12// See the License for the specific language governing permissions and13package wire14import (15	"errors"16	"fmt"17	"testing"18	"time"19	"cloud.google.com/go/pubsublite/internal/test"20)21const receiveStatusTimeout = 5 * time.Second22type testStatusChangeReceiver struct {23	// Status change notifications are fired asynchronously, so a channel receives24	// the statuses.25	statusC    chan serviceStatus26	lastStatus serviceStatus27	name       string28}29func newTestStatusChangeReceiver(name string) *testStatusChangeReceiver {30	return &testStatusChangeReceiver{31		statusC: make(chan serviceStatus, 1),32		name:    name,33	}34}35func (sr *testStatusChangeReceiver) Handle() interface{} { return sr }36func (sr *testStatusChangeReceiver) OnStatusChange(handle serviceHandle, status serviceStatus, err error) {37	sr.statusC <- status38}39func (sr *testStatusChangeReceiver) VerifyStatus(t *testing.T, want serviceStatus) {40	select {41	case status := <-sr.statusC:42		if status <= sr.lastStatus {43			t.Errorf("%s: Duplicate service status: %d, last status: %d", sr.name, status, sr.lastStatus)44		}45		if status != want {46			t.Errorf("%s: Got service status: %d, want: %d", sr.name, status, want)47		}48		sr.lastStatus = status49	case <-time.After(receiveStatusTimeout):50		t.Errorf("%s: Did not receive status within %v", sr.name, receiveStatusTimeout)51	}52}53func (sr *testStatusChangeReceiver) VerifyNoStatusChanges(t *testing.T) {54	select {55	case status := <-sr.statusC:56		t.Errorf("%s: Unexpected service status: %d", sr.name, status)57	default:58	}59}60type testService struct {61	receiver *testStatusChangeReceiver62	abstractService63}64func newTestService(name string) *testService {65	receiver := newTestStatusChangeReceiver(name)66	ts := &testService{receiver: receiver}67	ts.AddStatusChangeReceiver(receiver.Handle(), receiver.OnStatusChange)68	return ts69}70func (ts *testService) Start() { ts.UpdateStatus(serviceStarting, nil) }71func (ts *testService) Stop()  { ts.UpdateStatus(serviceTerminating, nil) }72func (ts *testService) UpdateStatus(targetStatus serviceStatus, err error) {73	ts.mu.Lock()74	defer ts.mu.Unlock()75	ts.unsafeUpdateStatus(targetStatus, err)76}77func TestServiceUpdateStatusIsLinear(t *testing.T) {78	err1 := errors.New("error1")79	err2 := errors.New("error2")80	service := newTestService("service")81	service.UpdateStatus(serviceStarting, nil)82	service.receiver.VerifyStatus(t, serviceStarting)83	service.UpdateStatus(serviceActive, nil)84	service.UpdateStatus(serviceActive, nil)85	service.receiver.VerifyStatus(t, serviceActive)86	service.UpdateStatus(serviceTerminating, err1)87	service.UpdateStatus(serviceStarting, nil)88	service.UpdateStatus(serviceTerminating, nil)89	service.receiver.VerifyStatus(t, serviceTerminating)90	service.UpdateStatus(serviceTerminated, err2)91	service.UpdateStatus(serviceTerminated, nil)92	service.receiver.VerifyStatus(t, serviceTerminated)93	// Verify that the first error is not clobbered by the second.94	if got, want := service.Error(), err1; !test.ErrorEqual(got, want) {95		t.Errorf("service.Error(): got (%v), want (%v)", got, want)96	}97}98func TestServiceCheckServiceStatus(t *testing.T) {99	for _, tc := range []struct {100		status  serviceStatus101		wantErr error102	}{103		{104			status:  serviceUninitialized,105			wantErr: ErrServiceUninitialized,106		},107		{108			status:  serviceStarting,109			wantErr: ErrServiceStarting,110		},111		{112			status:  serviceActive,113			wantErr: nil,114		},115		{116			status:  serviceTerminating,117			wantErr: ErrServiceStopped,118		},119		{120			status:  serviceTerminated,121			wantErr: ErrServiceStopped,122		},123	} {124		t.Run(fmt.Sprintf("Status=%v", tc.status), func(t *testing.T) {125			s := newTestService("service")126			s.UpdateStatus(tc.status, nil)127			if gotErr := s.unsafeCheckServiceStatus(); !test.ErrorEqual(gotErr, tc.wantErr) {128				t.Errorf("service.unsafeCheckServiceStatus(): got (%v), want (%v)", gotErr, tc.wantErr)129			}130		})131	}132}133func TestServiceAddRemoveStatusChangeReceiver(t *testing.T) {134	receiver1 := newTestStatusChangeReceiver("receiver1")135	receiver2 := newTestStatusChangeReceiver("receiver2")136	receiver3 := newTestStatusChangeReceiver("receiver3")137	service := new(testService)138	service.AddStatusChangeReceiver(receiver1.Handle(), receiver1.OnStatusChange)139	service.AddStatusChangeReceiver(receiver2.Handle(), receiver2.OnStatusChange)140	service.AddStatusChangeReceiver(receiver3.Handle(), receiver3.OnStatusChange)141	t.Run("All receivers", func(t *testing.T) {142		service.UpdateStatus(serviceActive, nil)143		receiver1.VerifyStatus(t, serviceActive)144		receiver2.VerifyStatus(t, serviceActive)145		receiver3.VerifyStatus(t, serviceActive)146	})147	t.Run("receiver1 removed", func(t *testing.T) {148		service.RemoveStatusChangeReceiver(receiver1.Handle())149		service.UpdateStatus(serviceTerminating, nil)150		receiver1.VerifyNoStatusChanges(t)151		receiver2.VerifyStatus(t, serviceTerminating)152		receiver3.VerifyStatus(t, serviceTerminating)153	})154	t.Run("receiver2 removed", func(t *testing.T) {155		service.RemoveStatusChangeReceiver(receiver2.Handle())156		service.UpdateStatus(serviceTerminated, nil)157		receiver1.VerifyNoStatusChanges(t)158		receiver2.VerifyNoStatusChanges(t)159		receiver3.VerifyStatus(t, serviceTerminated)160	})161}162type testCompositeService struct {163	receiver *testStatusChangeReceiver164	compositeService165}166func newTestCompositeService(name string) *testCompositeService {167	receiver := newTestStatusChangeReceiver(name)168	ts := &testCompositeService{receiver: receiver}169	ts.AddStatusChangeReceiver(receiver.Handle(), receiver.OnStatusChange)170	ts.init()171	return ts172}173func (ts *testCompositeService) AddServices(services ...service) error {174	ts.mu.Lock()175	defer ts.mu.Unlock()176	return ts.unsafeAddServices(services...)177}178func (ts *testCompositeService) RemoveService(service service) {179	ts.mu.Lock()180	defer ts.mu.Unlock()181	ts.unsafeRemoveService(service)182}183func (ts *testCompositeService) DependenciesLen() int {184	ts.mu.Lock()185	defer ts.mu.Unlock()186	return len(ts.dependencies)187}188func (ts *testCompositeService) RemovedLen() int {189	ts.mu.Lock()190	defer ts.mu.Unlock()191	return len(ts.removed)192}193func TestCompositeServiceNormalStop(t *testing.T) {194	child1 := newTestService("child1")195	child2 := newTestService("child2")196	child3 := newTestService("child3")197	parent := newTestCompositeService("parent")198	if err := parent.AddServices(child1, child2); err != nil {199		t.Errorf("AddServices() got err: %v", err)200	}201	t.Run("Starting", func(t *testing.T) {202		wantState := serviceUninitialized203		if child1.Status() != wantState {204			t.Errorf("child1: current service status: got %d, want %d", child1.Status(), wantState)205		}206		if child2.Status() != wantState {207			t.Errorf("child2: current service status: got %d, want %d", child2.Status(), wantState)208		}209		parent.Start()210		child1.receiver.VerifyStatus(t, serviceStarting)211		child2.receiver.VerifyStatus(t, serviceStarting)212		parent.receiver.VerifyStatus(t, serviceStarting)213		// child3 is added after Start() and should be automatically started.214		if child3.Status() != wantState {215			t.Errorf("child3: current service status: got %d, want %d", child3.Status(), wantState)216		}217		if err := parent.AddServices(child3); err != nil {218			t.Errorf("AddServices() got err: %v", err)219		}220		child3.receiver.VerifyStatus(t, serviceStarting)221	})222	t.Run("Active", func(t *testing.T) {223		// parent service is active once all children are active.224		child1.UpdateStatus(serviceActive, nil)225		child2.UpdateStatus(serviceActive, nil)226		parent.receiver.VerifyNoStatusChanges(t)227		child3.UpdateStatus(serviceActive, nil)228		child1.receiver.VerifyStatus(t, serviceActive)229		child2.receiver.VerifyStatus(t, serviceActive)230		child3.receiver.VerifyStatus(t, serviceActive)231		parent.receiver.VerifyStatus(t, serviceActive)232		if err := parent.WaitStarted(); err != nil {233			t.Errorf("compositeService.WaitStarted() got err: %v", err)234		}235	})236	t.Run("Stopping", func(t *testing.T) {237		parent.Stop()238		child1.receiver.VerifyStatus(t, serviceTerminating)239		child2.receiver.VerifyStatus(t, serviceTerminating)240		child3.receiver.VerifyStatus(t, serviceTerminating)241		parent.receiver.VerifyStatus(t, serviceTerminating)242		// parent service is terminated once all children have terminated.243		child1.UpdateStatus(serviceTerminated, nil)244		child2.UpdateStatus(serviceTerminated, nil)245		parent.receiver.VerifyNoStatusChanges(t)246		child3.UpdateStatus(serviceTerminated, nil)247		child1.receiver.VerifyStatus(t, serviceTerminated)248		child2.receiver.VerifyStatus(t, serviceTerminated)249		child3.receiver.VerifyStatus(t, serviceTerminated)250		parent.receiver.VerifyStatus(t, serviceTerminated)251		if err := parent.WaitStopped(); err != nil {252			t.Errorf("compositeService.WaitStopped() got err: %v", err)253		}254	})255}256func TestCompositeServiceErrorDuringStartup(t *testing.T) {257	child1 := newTestService("child1")258	child2 := newTestService("child2")259	parent := newTestCompositeService("parent")260	if err := parent.AddServices(child1, child2); err != nil {261		t.Errorf("AddServices() got err: %v", err)262	}263	t.Run("Starting", func(t *testing.T) {264		parent.Start()265		parent.receiver.VerifyStatus(t, serviceStarting)266		child1.receiver.VerifyStatus(t, serviceStarting)267		child2.receiver.VerifyStatus(t, serviceStarting)268	})269	t.Run("Terminating", func(t *testing.T) {270		// child1 now errors.271		wantErr := errors.New("err during startup")272		child1.UpdateStatus(serviceTerminated, wantErr)273		child1.receiver.VerifyStatus(t, serviceTerminated)274		// This causes parent and child2 to start terminating.275		parent.receiver.VerifyStatus(t, serviceTerminating)276		child2.receiver.VerifyStatus(t, serviceTerminating)277		// parent has terminated once child2 has terminated.278		child2.UpdateStatus(serviceTerminated, nil)279		child2.receiver.VerifyStatus(t, serviceTerminated)280		parent.receiver.VerifyStatus(t, serviceTerminated)281		if gotErr := parent.WaitStarted(); !test.ErrorEqual(gotErr, wantErr) {282			t.Errorf("compositeService.WaitStarted() got err: (%v), want err: (%v)", gotErr, wantErr)283		}284	})285}286func TestCompositeServiceErrorWhileActive(t *testing.T) {287	child1 := newTestService("child1")288	child2 := newTestService("child2")289	parent := newTestCompositeService("parent")290	if err := parent.AddServices(child1, child2); err != nil {291		t.Errorf("AddServices() got err: %v", err)292	}293	t.Run("Starting", func(t *testing.T) {294		parent.Start()295		child1.receiver.VerifyStatus(t, serviceStarting)296		child2.receiver.VerifyStatus(t, serviceStarting)297		parent.receiver.VerifyStatus(t, serviceStarting)298	})299	t.Run("Active", func(t *testing.T) {300		child1.UpdateStatus(serviceActive, nil)301		child2.UpdateStatus(serviceActive, nil)302		child1.receiver.VerifyStatus(t, serviceActive)303		child2.receiver.VerifyStatus(t, serviceActive)304		parent.receiver.VerifyStatus(t, serviceActive)305		if err := parent.WaitStarted(); err != nil {306			t.Errorf("compositeService.WaitStarted() got err: %v", err)307		}308	})309	t.Run("Terminating", func(t *testing.T) {310		// child2 now errors.311		wantErr := errors.New("err while active")312		child2.UpdateStatus(serviceTerminating, wantErr)313		child2.receiver.VerifyStatus(t, serviceTerminating)314		// This causes parent and child1 to start terminating.315		child1.receiver.VerifyStatus(t, serviceTerminating)316		parent.receiver.VerifyStatus(t, serviceTerminating)317		// parent has terminated once both children have terminated.318		child1.UpdateStatus(serviceTerminated, nil)319		child2.UpdateStatus(serviceTerminated, nil)320		child1.receiver.VerifyStatus(t, serviceTerminated)321		child2.receiver.VerifyStatus(t, serviceTerminated)322		parent.receiver.VerifyStatus(t, serviceTerminated)323		if gotErr := parent.WaitStopped(); !test.ErrorEqual(gotErr, wantErr) {324			t.Errorf("compositeService.WaitStopped() got err: (%v), want err: (%v)", gotErr, wantErr)325		}326	})327}328func TestCompositeServiceRemoveService(t *testing.T) {329	child1 := newTestService("child1")330	child2 := newTestService("child2")331	parent := newTestCompositeService("parent")332	if err := parent.AddServices(child1, child2); err != nil {333		t.Errorf("AddServices() got err: %v", err)334	}335	t.Run("Starting", func(t *testing.T) {336		parent.Start()337		child1.receiver.VerifyStatus(t, serviceStarting)338		child2.receiver.VerifyStatus(t, serviceStarting)339		parent.receiver.VerifyStatus(t, serviceStarting)340	})341	t.Run("Active", func(t *testing.T) {342		child1.UpdateStatus(serviceActive, nil)343		child2.UpdateStatus(serviceActive, nil)344		child1.receiver.VerifyStatus(t, serviceActive)345		child2.receiver.VerifyStatus(t, serviceActive)346		parent.receiver.VerifyStatus(t, serviceActive)347	})348	t.Run("Remove service", func(t *testing.T) {349		if got, want := parent.DependenciesLen(), 2; got != want {350			t.Errorf("compositeService.dependencies: got len %d, want %d", got, want)351		}352		if got, want := parent.RemovedLen(), 0; got != want {353			t.Errorf("compositeService.removed: got len %d, want %d", got, want)354		}355		// Removing child1 should stop it, but leave everything else active.356		parent.RemoveService(child1)357		if got, want := parent.DependenciesLen(), 1; got != want {358			t.Errorf("compositeService.dependencies: got len %d, want %d", got, want)359		}360		if got, want := parent.RemovedLen(), 1; got != want {361			t.Errorf("compositeService.removed: got len %d, want %d", got, want)362		}363		child1.receiver.VerifyStatus(t, serviceTerminating)364		child2.receiver.VerifyNoStatusChanges(t)365		parent.receiver.VerifyNoStatusChanges(t)366		// After child1 has terminated, it should be removed.367		child1.UpdateStatus(serviceTerminated, nil)368		child1.receiver.VerifyStatus(t, serviceTerminated)369		child2.receiver.VerifyNoStatusChanges(t)370		parent.receiver.VerifyNoStatusChanges(t)371		if got, want := parent.Status(), serviceActive; got != want {372			t.Errorf("compositeService.Status() got %v, want %v", got, want)373		}374	})375	t.Run("Terminating", func(t *testing.T) {376		// Now stop the composite service.377		parent.Stop()378		child2.receiver.VerifyStatus(t, serviceTerminating)379		parent.receiver.VerifyStatus(t, serviceTerminating)380		child2.UpdateStatus(serviceTerminated, nil)381		child2.receiver.VerifyStatus(t, serviceTerminated)382		parent.receiver.VerifyStatus(t, serviceTerminated)383		if err := parent.WaitStopped(); err != nil {384			t.Errorf("compositeService.WaitStopped() got err: %v", err)385		}386		if got, want := parent.DependenciesLen(), 1; got != want {387			t.Errorf("compositeService.dependencies: got len %d, want %d", got, want)388		}389		if got, want := parent.RemovedLen(), 0; got != want {390			t.Errorf("compositeService.removed: got len %d, want %d", got, want)391		}392	})393}394func TestCompositeServiceTree(t *testing.T) {395	leaf1 := newTestService("leaf1")396	leaf2 := newTestService("leaf2")397	intermediate1 := newTestCompositeService("intermediate1")398	if err := intermediate1.AddServices(leaf1, leaf2); err != nil {399		t.Errorf("intermediate1.AddServices() got err: %v", err)400	}401	leaf3 := newTestService("leaf3")402	leaf4 := newTestService("leaf4")403	intermediate2 := newTestCompositeService("intermediate2")404	if err := intermediate2.AddServices(leaf3, leaf4); err != nil {405		t.Errorf("intermediate2.AddServices() got err: %v", err)406	}407	root := newTestCompositeService("root")408	if err := root.AddServices(intermediate1, intermediate2); err != nil {409		t.Errorf("root.AddServices() got err: %v", err)410	}411	wantErr := errors.New("fail")412	t.Run("Starting", func(t *testing.T) {413		// Start trickles down the tree.414		root.Start()415		leaf1.receiver.VerifyStatus(t, serviceStarting)416		leaf2.receiver.VerifyStatus(t, serviceStarting)417		leaf3.receiver.VerifyStatus(t, serviceStarting)418		leaf4.receiver.VerifyStatus(t, serviceStarting)419		intermediate1.receiver.VerifyStatus(t, serviceStarting)420		intermediate2.receiver.VerifyStatus(t, serviceStarting)421		root.receiver.VerifyStatus(t, serviceStarting)422	})423	t.Run("Active", func(t *testing.T) {424		// serviceActive notification trickles up the tree.425		leaf1.UpdateStatus(serviceActive, nil)426		leaf2.UpdateStatus(serviceActive, nil)427		leaf3.UpdateStatus(serviceActive, nil)428		leaf4.UpdateStatus(serviceActive, nil)429		leaf1.receiver.VerifyStatus(t, serviceActive)430		leaf2.receiver.VerifyStatus(t, serviceActive)431		leaf3.receiver.VerifyStatus(t, serviceActive)432		leaf4.receiver.VerifyStatus(t, serviceActive)433		intermediate1.receiver.VerifyStatus(t, serviceActive)434		intermediate2.receiver.VerifyStatus(t, serviceActive)435		root.receiver.VerifyStatus(t, serviceActive)436		if err := root.WaitStarted(); err != nil {437			t.Errorf("compositeService.WaitStarted() got err: %v", err)438		}439	})440	t.Run("Leaf fails", func(t *testing.T) {441		leaf1.UpdateStatus(serviceTerminated, wantErr)442		leaf1.receiver.VerifyStatus(t, serviceTerminated)443		// Leaf service failure should trickle up the tree and across to all other444		// leaves, causing them all to start terminating.445		leaf2.receiver.VerifyStatus(t, serviceTerminating)446		leaf3.receiver.VerifyStatus(t, serviceTerminating)447		leaf4.receiver.VerifyStatus(t, serviceTerminating)448		intermediate1.receiver.VerifyStatus(t, serviceTerminating)449		intermediate2.receiver.VerifyStatus(t, serviceTerminating)450		root.receiver.VerifyStatus(t, serviceTerminating)451	})452	t.Run("Terminated", func(t *testing.T) {453		// serviceTerminated notification trickles up the tree.454		leaf2.UpdateStatus(serviceTerminated, nil)455		leaf3.UpdateStatus(serviceTerminated, nil)456		leaf4.UpdateStatus(serviceTerminated, nil)457		leaf2.receiver.VerifyStatus(t, serviceTerminated)458		leaf3.receiver.VerifyStatus(t, serviceTerminated)459		leaf4.receiver.VerifyStatus(t, serviceTerminated)460		intermediate1.receiver.VerifyStatus(t, serviceTerminated)461		intermediate2.receiver.VerifyStatus(t, serviceTerminated)462		root.receiver.VerifyStatus(t, serviceTerminated)463		if gotErr := root.WaitStopped(); !test.ErrorEqual(gotErr, wantErr) {464			t.Errorf("compositeService.WaitStopped() got err: (%v), want err: (%v)", gotErr, wantErr)465		}466	})467}468func TestCompositeServiceAddServicesErrors(t *testing.T) {469	child1 := newTestService("child1")470	parent := newTestCompositeService("parent")471	if err := parent.AddServices(child1); err != nil {472		t.Errorf("AddServices(child1) got err: %v", err)473	}474	child2 := newTestService("child2")475	child2.Start()476	if gotErr, wantErr := parent.AddServices(child2), errChildServiceStarted; !test.ErrorEqual(gotErr, wantErr) {477		t.Errorf("AddServices(child2) got err: (%v), want err: (%v)", gotErr, wantErr)478	}479	parent.Stop()480	child3 := newTestService("child3")481	if gotErr, wantErr := parent.AddServices(child3), ErrServiceStopped; !test.ErrorEqual(gotErr, wantErr) {482		t.Errorf("AddServices(child3) got err: (%v), want err: (%v)", gotErr, wantErr)483	}484}...

response_test.go

Source:response_test.go

1package monitoringplugin2import (3	"bytes"4	"github.com/stretchr/testify/assert"5	"os"6	"os/exec"7	"regexp"8	"strconv"9	"strings"10	"testing"11)12func TestOKResponse(t *testing.T) {13	defaultMessage := "OKTest"14	if os.Getenv("EXECUTE_PLUGIN") == "1" {15		r := NewResponse(defaultMessage)16		r.OutputAndExit()17	}18	cmd := exec.Command(os.Args[0], "-test.run=TestOKResponse")19	cmd.Env = append(os.Environ(), "EXECUTE_PLUGIN=1")20	var outputB bytes.Buffer21	cmd.Stdout = &outputB22	err := cmd.Run()23	if err != nil {24		if exitError, ok := err.(*exec.ExitError); ok {25			t.Error("OkResponse is expected to return exit status 0, but exited with exit code " + strconv.Itoa(exitError.ExitCode()))26		} else {27			t.Error("cmd.Run() Command resulted in an error that can not be converted to exec.ExitEror! error: " + err.Error())28		}29		return30	}31	output := outputB.String()32	match, err := regexp.MatchString("^OK: "+defaultMessage+"\n$", output)33	if err != nil {34		t.Error(err.Error())35	}36	if !match {37		t.Error("ok result output message did not match to the expected regex")38	}39	return40}41func TestWARNINGResponse(t *testing.T) {42	failureResponse(t, 1)43	return44}45func TestCRITICALResponse(t *testing.T) {46	failureResponse(t, 2)47	return48}49func TestUNKNOWNResponse(t *testing.T) {50	failureResponse(t, 3)51	return52}53func TestStatusHierarchy(t *testing.T) {54	r := NewResponse("")55	if r.statusCode != OK {56		t.Error("status code is supposed to be OK when a new Response is created")57	}58	r.UpdateStatus(WARNING, "")59	if r.statusCode != WARNING {60		t.Error("status code did not update from OK to WARNING after UpdateStatus(WARNING) is called!")61	}62	r.UpdateStatus(OK, "")63	if r.statusCode != WARNING {64		t.Error("status code did change from WARNING to " + strconv.Itoa(r.statusCode) + " after UpdateStatus(OK) was called! The function should not affect the status code, because WARNING is worse than OK")65	}66	r.UpdateStatus(CRITICAL, "")67	if r.statusCode != CRITICAL {68		t.Error("status code did not update from WARNING to CRITICAL after UpdateStatus(WARNING) is called!")69	}70	r.UpdateStatus(OK, "")71	if r.statusCode != CRITICAL {72		t.Error("status code did change from CRITICAL to " + strconv.Itoa(r.statusCode) + " after UpdateStatus(OK) was called! The function should not affect the status code, because CRITICAL is worse than OK")73	}74	r.UpdateStatus(WARNING, "")75	if r.statusCode != CRITICAL {76		t.Error("status code did change from CRITICAL to " + strconv.Itoa(r.statusCode) + " after UpdateStatus(WARNING) was called! The function should not affect the status code, because CRITICAL is worse than WARNING")77	}78	r.UpdateStatus(UNKNOWN, "")79	if r.statusCode != CRITICAL {80		t.Error("status code did change from CRITICAL to " + strconv.Itoa(r.statusCode) + " after UpdateStatus(UNKNOWN) was called! The function should not affect the status code, because CRITICAL is worse than UNKNOWN")81	}82	r = NewResponse("")83	r.UpdateStatus(UNKNOWN, "")84	if r.statusCode != UNKNOWN {85		t.Error("status code did not update from OK to UNKNOWN after UpdateStatus(UNKNOWN) is called!")86	}87	r.UpdateStatus(WARNING, "")88	if r.statusCode != UNKNOWN {89		t.Error("status code did change from UNKNOWN to " + strconv.Itoa(r.statusCode) + " after UpdateStatus(WARNING) was called! The function should not affect the status code, because UNKNOWN is worse than WARNING")90	}91	r.UpdateStatus(CRITICAL, "")92	if r.statusCode != CRITICAL {93		t.Error("status code is did not change from UNKNOWN to CRITICAL after UpdateStatus(CRITICAL) was called! The function should affect the status code, because CRITICAL is worse than UNKNOWN")94	}95}96func TestOutputMessages(t *testing.T) {97	defaultMessage := "default"98	if os.Getenv("EXECUTE_PLUGIN") == "1" {99		r := NewResponse(defaultMessage)100		r.UpdateStatus(0, "message1")101		r.UpdateStatus(0, "message2")102		r.UpdateStatus(0, "message3")103		r.UpdateStatus(0, "message4")104		r.OutputAndExit()105		return106	}107	if os.Getenv("EXECUTE_PLUGIN") == "2" {108		r := NewResponse(defaultMessage)109		r.UpdateStatus(1, "message1")110		r.UpdateStatus(0, "message2")111		r.UpdateStatus(0, "message3")112		r.UpdateStatus(0, "message4")113		r.SetOutputDelimiter(" / ")114		r.OutputAndExit()115		return116	}117	cmd := exec.Command(os.Args[0], "-test.run=TestOutputMessages")118	cmd.Env = append(os.Environ(), "EXECUTE_PLUGIN=1")119	var outputB bytes.Buffer120	cmd.Stdout = &outputB121	err := cmd.Run()122	if err != nil {123		t.Error("an error occurred during cmd.Run(), but the Response was expected to exit with exit code 0")124		return125	}126	output := outputB.String()127	match, err := regexp.MatchString("^OK: "+defaultMessage+"\nmessage1\nmessage2\nmessage3\nmessage4\n$", output)128	if err != nil {129		t.Error(err.Error())130	}131	if !match {132		t.Error("output did not match to the expected regex")133	}134	cmd = exec.Command(os.Args[0], "-test.run=TestOutputMessages")135	cmd.Env = append(os.Environ(), "EXECUTE_PLUGIN=2")136	var outputB2 bytes.Buffer137	cmd.Stdout = &outputB2138	err = cmd.Run()139	if err != nil {140		if exitError, ok := err.(*exec.ExitError); ok {141			if exitError.ExitCode() != 1 {142				t.Error("the command is expected to return exit status 1, but exited with exit code " + strconv.Itoa(exitError.ExitCode()))143			}144		} else {145			t.Errorf("cmd.Run() Command resulted in an error that can not be converted to exec.ExitEror! error: " + err.Error())146		}147	} else {148		t.Error("the command exited with exitcode 0 but is expected to exit with exitcode 1")149	}150	output = outputB2.String()151	match, err = regexp.MatchString("^WARNING: message1 / message2 / message3 / message4\n$", output)152	if err != nil {153		t.Error(err.Error())154	}155	if !match {156		t.Error("output did not match to the expected regex")157	}158}159func TestResponse_UpdateStatusIf(t *testing.T) {160	r := NewResponse("")161	r.UpdateStatusIf(false, 1, "")162	assert.True(t, r.statusCode == 0)163	r.UpdateStatusIf(true, 1, "")164	assert.True(t, r.statusCode == 1)165}166func TestResponse_UpdateStatusIfNot(t *testing.T) {167	r := NewResponse("")168	r.UpdateStatusIfNot(true, 1, "")169	assert.True(t, r.statusCode == 0)170	r.UpdateStatusIfNot(false, 1, "")171	assert.True(t, r.statusCode == 1)172}173func TestString2StatusCode(t *testing.T) {174	assert.True(t, String2StatusCode("ok") == 0)175	assert.True(t, String2StatusCode("OK") == 0)176	assert.True(t, String2StatusCode("Ok") == 0)177	assert.True(t, String2StatusCode("warning") == 1)178	assert.True(t, String2StatusCode("WARNING") == 1)179	assert.True(t, String2StatusCode("Warning") == 1)180	assert.True(t, String2StatusCode("critical") == 2)181	assert.True(t, String2StatusCode("CRITICAL") == 2)182	assert.True(t, String2StatusCode("Critical") == 2)183	assert.True(t, String2StatusCode("unknown") == 3)184	assert.True(t, String2StatusCode("UNKNOWN") == 3)185	assert.True(t, String2StatusCode("Unknown") == 3)186}187func TestOutputPerformanceData(t *testing.T) {188	p1 := NewPerformanceDataPoint("label1", 10).189		SetUnit("%").190		SetMin(0).191		SetMax(100).192		SetThresholds(193			NewThresholds(0, 80, 0, 90))194	p2 := NewPerformanceDataPoint("label2", 20).195		SetUnit("%").196		SetMin(0).197		SetMax(100).198		SetThresholds(199			NewThresholds(0, 80, 0, 90))200	p3 := NewPerformanceDataPoint("label3", 30).201		SetUnit("%").202		SetMin(0).203		SetMax(100).204		SetThresholds(205			NewThresholds(0, 80, 0, 90))206	defaultMessage := "OKTest"207	if os.Getenv("EXECUTE_PLUGIN") == "1" {208		r := NewResponse(defaultMessage)209		err := r.AddPerformanceDataPoint(p1)210		if err != nil {211			r.UpdateStatus(3, "error during add performance data point")212		}213		err = r.AddPerformanceDataPoint(p2)214		if err != nil {215			r.UpdateStatus(3, "error during add performance data point")216		}217		err = r.AddPerformanceDataPoint(p3)218		if err != nil {219			r.UpdateStatus(3, "error during add performance data point")220		}221		r.OutputAndExit()222	}223	cmd := exec.Command(os.Args[0], "-test.run=TestOutputPerformanceData")224	cmd.Env = append(os.Environ(), "EXECUTE_PLUGIN=1")225	var outputB bytes.Buffer226	cmd.Stdout = &outputB227	err := cmd.Run()228	if err != nil {229		t.Error("cmd.Run() returned an exitcode != 0, but exit code 0 was expected")230	}231	output := outputB.String()232	if !strings.HasPrefix(output, "OK: "+defaultMessage+" | ") {233		t.Error("output did not match the expected regex")234	}235}236func TestOutputPerformanceDataThresholdsExceeded(t *testing.T) {237	p1 := NewPerformanceDataPoint("label1", 10).238		SetUnit("%").239		SetMin(0).240		SetMax(100).241		SetThresholds(242			NewThresholds(0, 80, 0, 90))243	p2 := NewPerformanceDataPoint("label2", 20).244		SetUnit("%").245		SetMin(0).246		SetMax(100).247		SetThresholds(248			NewThresholds(0, 80, 0, 90))249	p3 := NewPerformanceDataPoint("label3", 85).250		SetUnit("%").251		SetMin(0).252		SetMax(100).253		SetThresholds(254			NewThresholds(0, 80, 0, 90))255	defaultMessage := "OKTest"256	if os.Getenv("EXECUTE_PLUGIN") == "1" {257		r := NewResponse(defaultMessage)258		err := r.AddPerformanceDataPoint(p1)259		if err != nil {260			r.UpdateStatus(3, "error during add performance data point")261		}262		err = r.AddPerformanceDataPoint(p2)263		if err != nil {264			r.UpdateStatus(3, "error during add performance data point")265		}266		err = r.AddPerformanceDataPoint(p3)267		if err != nil {268			r.UpdateStatus(3, "error during add performance data point")269		}270		r.OutputAndExit()271	}272	cmd := exec.Command(os.Args[0], "-test.run=TestOutputPerformanceDataThresholdsExceeded")273	cmd.Env = append(os.Environ(), "EXECUTE_PLUGIN=1")274	var outputB bytes.Buffer275	cmd.Stdout = &outputB276	err := cmd.Run()277	if err == nil {278		t.Error("cmd.Run() returned an exitcode = 0, but exit code 1 was expected")279	} else if err.Error() != "exit status 1" {280		t.Error("cmd.Run() returned an exitcode != 1, but exit code 1 was expected")281	}282	output := outputB.String()283	if !strings.HasPrefix(output, "WARNING: label3 is outside of WARNING threshold | ") {284		t.Error("output did not match the expected regex")285	}286}287func failureResponse(t *testing.T, exitCode int) {288	var status string289	switch exitCode {290	case 0:291		t.Error("exitcode in failureResponse function cannot be 0, because it is not meant to be used for a successful cmd")292		return293	case 1:294		status = "WARNING"295	case 2:296		status = "CRITICAL"297	default:298		status = "UNKNOWN"299	}300	message := status + "Test"301	if os.Getenv("EXECUTE_PLUGIN") == "1" {302		r := NewResponse("")303		r.UpdateStatus(exitCode, message)304		r.OutputAndExit()305	}306	cmd := exec.Command(os.Args[0], "-test.run=Test"+status+"Response")307	cmd.Env = append(os.Environ(), "EXECUTE_PLUGIN=1")308	var outputB bytes.Buffer309	cmd.Stdout = &outputB310	err := cmd.Run()311	if err != nil {312		if exitError, ok := err.(*exec.ExitError); ok {313			if exitError.ExitCode() != exitCode {314				t.Error(status + " Response is expected to return exit status " + strconv.Itoa(exitCode) + ", but exited with exit code " + strconv.Itoa(exitError.ExitCode()))315			}316		} else {317			t.Errorf("cmd.Run() Command resulted in an error that can not be converted to exec.ExitEror! error: " + err.Error())318		}319	} else {320		t.Error("the command exited with exitcode 0 but is expected to exit with exitcode " + strconv.Itoa(exitCode))321	}322	output := outputB.String()323	match, err := regexp.MatchString("^"+status+": "+message+"\n$", output)324	if err != nil {325		t.Error(err.Error())326	}327	if !match {328		t.Error(status + " result output message did not match to the expected regex")329	}330	return331}332func TestResponse_SortOutputMessagesByStatus(t *testing.T) {333	r := NewResponse("defaultMessage")334	r.UpdateStatus(OK, "message1")335	r.UpdateStatus(WARNING, "message2")336	r.UpdateStatus(UNKNOWN, "message3")337	r.UpdateStatus(CRITICAL, "message4")338	r.UpdateStatus(WARNING, "message5")339	r.UpdateStatus(CRITICAL, "message6")340	r.UpdateStatus(UNKNOWN, "message7")341	r.UpdateStatus(OK, "message8")342	r.validate()343	for x, message := range r.outputMessages {344		for _, m := range r.outputMessages[x:] {345			assert.True(t, message.Status >= m.Status || message.Status == CRITICAL, "sorting did not work")346		}347	}348}349func TestResponse_InvalidCharacter(t *testing.T) {350	r := NewResponse("checked")351	r.UpdateStatus(WARNING, "test|")352	r.validate()353	res := r.GetInfo()354	assert.True(t, res.RawOutput == "WARNING: test")355}356func TestResponse_InvalidCharacterReplace(t *testing.T) {357	r := NewResponse("checked")358	r.UpdateStatus(OK, "test|2")359	err := r.SetInvalidCharacterBehavior(InvalidCharacterReplace, "-")360	assert.NoError(t, err)361	r.validate()362	res := r.GetInfo()363	assert.True(t, res.RawOutput == "OK: checked\ntest-2")364}365func TestResponse_InvalidCharacterReplaceError(t *testing.T) {366	r := NewResponse("checked")367	r.UpdateStatus(OK, "test|")368	err := r.SetInvalidCharacterBehavior(InvalidCharacterReplace, "")369	assert.Error(t, err)370}371func TestResponse_InvalidCharacterRemoveMessage(t *testing.T) {372	r := NewResponse("checked")373	r.UpdateStatus(OK, "test|")374	err := r.SetInvalidCharacterBehavior(InvalidCharacterRemoveMessage, "")375	assert.NoError(t, err)376	r.validate()377	res := r.GetInfo()378	assert.True(t, res.RawOutput == "OK: checked")379}380func TestResponse_InvalidCharacterReplaceWithError(t *testing.T) {381	r := NewResponse("checked")382	r.UpdateStatus(WARNING, "test|")383	err := r.SetInvalidCharacterBehavior(InvalidCharacterReplaceWithError, "")384	assert.NoError(t, err)385	r.validate()386	res := r.GetInfo()387	assert.True(t, res.RawOutput == "WARNING: output message contains invalid character")388}389func TestResponse_InvalidCharacterReplaceWithErrorMultipleMessages(t *testing.T) {390	r := NewResponse("checked")391	r.UpdateStatus(WARNING, "test|")392	r.UpdateStatus(WARNING, "test|2")393	err := r.SetInvalidCharacterBehavior(InvalidCharacterReplaceWithError, "")394	assert.NoError(t, err)395	r.validate()396	res := r.GetInfo()397	assert.True(t, res.RawOutput == "WARNING: output message contains invalid character")398}399func TestResponse_InvalidCharacterReplaceWithErrorAndSetUnknown(t *testing.T) {400	r := NewResponse("checked")401	r.UpdateStatus(WARNING, "test|")402	err := r.SetInvalidCharacterBehavior(InvalidCharacterReplaceWithErrorAndSetUNKNOWN, "")403	assert.NoError(t, err)404	r.validate()405	res := r.GetInfo()406	assert.True(t, res.RawOutput == "UNKNOWN: output message contains invalid character")407}408func TestResponse_InvalidCharacterReplaceWithErrorAndSetUnknownMultipleMessages(t *testing.T) {409	r := NewResponse("checked")410	r.UpdateStatus(WARNING, "test|")411	r.UpdateStatus(WARNING, "test|2")412	err := r.SetInvalidCharacterBehavior(InvalidCharacterReplaceWithErrorAndSetUNKNOWN, "")413	assert.NoError(t, err)414	r.validate()415	res := r.GetInfo()416	assert.True(t, res.RawOutput == "UNKNOWN: output message contains invalid character")417}418func TestResponse_InvalidCharacterDefaultMessage(t *testing.T) {419	r := NewResponse("test|")420	r.validate()421	res := r.GetInfo()422	assert.True(t, res.RawOutput == "OK: test")423}...

updateStatus

Using AI Code Generation

1func (r *RunReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error) {2	ctx := context.Background()3	log := r.Log.WithValues("run", req.NamespacedName)4	return ctrl.Result{}, nil5}6func (r *RunReconciler) SetupWithManager(mgr ctrl.Manager) error {7		Complete(r)8}9func (r *RunReconciler) updateStatus(ctx context.Context, run *examplev1alpha1.Run, status examplev1alpha1.RunStatus) error {10	if err := r.Status().Update(ctx, run); err != nil {11	}12}13type RunStatus struct {

updateStatus

Using AI Code Generation

1import (2type run struct {3}4func (r *run) updateStatus(status string) {5}6func main() {7	r := run{status: "new"}8	fmt.Println(r.status)9	go func() {10		time.Sleep(3 * time.Second)11		r.updateStatus("updated")12	}()13	time.Sleep(5 * time.Second)14	fmt.Println(r.status)15}

updateStatus

Using AI Code Generation

1import "fmt"2func main() {3    fmt.Println("Hello, World!")4}5import "fmt"6func main() {7    fmt.Println("Hello, World!")8}

updateStatus

Using AI Code Generation

1import (2func main() {3	run := Run{}4	run.updateStatus()5	fmt.Println(run.Status)6}7import (8func main() {9	run := Run{}10	run.updateStatus()11	fmt.Println(run.Status)12}13import (14func main() {15	run := Run{}16	run.updateStatus()17	fmt.Println(run.Status)18}19import (20func main() {21	run := Run{}22	run.updateStatus()23	fmt.Println(run.Status)24}25import (26func main() {27	run := Run{}28	run.updateStatus()29	fmt.Println(run.Status)30}31import (32func main() {33	run := Run{}34	run.updateStatus()35	fmt.Println(run.Status)36}37import (38func main() {39	run := Run{}40	run.updateStatus()41	fmt.Println(run.Status)42}43import (44func main() {45	run := Run{}46	run.updateStatus()47	fmt.Println(run.Status)48}49import (50func main() {51	run := Run{}52	run.updateStatus()53	fmt.Println(run.Status)54}55import (56func main() {57	run := Run{}58	run.updateStatus()59	fmt.Println(run.Status)60}61import (62func main() {63	run := Run{}64	run.updateStatus()65	fmt.Println(run.Status)66}

updateStatus

Using AI Code Generation

1import (2func main() {3	run := new(Run)4	run.updateStatus("Running")5	fmt.Println(run.status)6	time.Sleep(5 * time.Second)7	run.updateStatus("Completed")8	fmt.Println(run.status)9}10import (11func main() {12	run := new(Run)13	run.updateStatus("Running")14	fmt.Println(run.status)15	time.Sleep(5 * time.Second)16	run.updateStatus("Completed")17	fmt.Println(run.status)18}19import (20func main() {21	run := new(Run)22	run.updateStatus("Running")23	fmt.Println(run.status)24	time.Sleep(5 * time.Second)25	run.updateStatus("Completed")26	fmt.Println(run.status)27}28import (29func main() {30	run := new(Run)31	run.updateStatus("Running")32	fmt.Println(run.status)33	time.Sleep(5 * time.Second)34	run.updateStatus("Completed")35	fmt.Println(run.status)36}37import (38func main() {39	run := new(Run)40	run.updateStatus("Running")41	fmt.Println(run.status)42	time.Sleep(5 * time.Second)43	run.updateStatus("Completed")44	fmt.Println(run.status)45}46import (47func main() {48	run := new(Run)49	run.updateStatus("Running")50	fmt.Println(run.status)51	time.Sleep(5 * time.Second)52	run.updateStatus("Completed")53	fmt.Println(run.status)54}55import (56func main() {57	run := new(Run)58	run.updateStatus("Running")59	fmt.Println(run.status)60	time.Sleep(5 * time.Second)61	run.updateStatus("Completed")62	fmt.Println(run.status)63}

updateStatus

Using AI Code Generation

1import (2func main() {3	r := new(run)4	r.updateStatus("running")5	time.Sleep(5 * time.Second)6	r.updateStatus("done")7}8import (9func main() {10	r := new(run)11	r.updateStatus("running")12	time.Sleep(5 * time.Second)13	r.updateStatus("done")14}15import (16func main() {17	r := new(run)18	r.updateStatus("running")19	time.Sleep(5 * time.Second)20	r.updateStatus("done")21}22import (23func main() {24	r := new(run)25	r.updateStatus("running")26	time.Sleep(5 * time.Second)27	r.updateStatus("done")28}29import (30func main() {31	r := new(run)32	r.updateStatus("running")33	time.Sleep(5 * time.Second)34	r.updateStatus("done")35}36import (37func main() {38	r := new(run)39	r.updateStatus("running")40	time.Sleep(5 * time.Second)41	r.updateStatus("done")42}43import (44func main() {45	r := new(run)46	r.updateStatus("running")47	time.Sleep(5 * time.Second)48	r.updateStatus("done")49}50import (51func main() {52	r := new(run)53	r.updateStatus("running")54	time.Sleep(5 * time.Second)55	r.updateStatus("done")56}57import (58func main() {

updateStatus

Using AI Code Generation

1func main() {2    r := Run{}3    r.updateStatus()4}5import "1.go"6func main() {7    r := Run{}8    r.updateStatus()9}10import "2.go"11func main() {12    r := Run{}13    r.updateStatus()14}15import "3.go"16func main() {17    r := Run{}18    r.updateStatus()19}20import "4.go"21func main() {22    r := Run{}23    r.updateStatus()24}25import "5.go"26func main() {27    r := Run{}28    r.updateStatus()29}30import "6.go"31func main() {32    r := Run{}33    r.updateStatus()34}35import "7.go"36func main() {37    r := Run{}38    r.updateStatus()39}40import "8.go"41func main() {42    r := Run{}43    r.updateStatus()44}45import "9.go"46func main() {47    r := Run{}48    r.updateStatus()49}50import "10.go"51func main() {52    r := Run{}53    r.updateStatus()54}55import "11.go"56func main() {57    r := Run{}58    r.updateStatus()59}60import "12.go"61func main() {62    r := Run{}63    r.updateStatus()64}65import "13.go"66func main() {67    r := Run{}68    r.updateStatus()69}70import "14.go"71func main() {72    r := Run{}73    r.updateStatus()74}75import "15.go"76func main() {77    r := Run{}78    r.updateStatus()79}80import "16.go"81func main() {82    r := Run{}83    r.updateStatus()84}

updateStatus

Using AI Code Generation

1import (2func main() {3 r := run{}4 r.updateStatus(2)5 fmt.Println(r.status)6}

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.