How to use Kill method of validation Package

...34	AddMintedCoins(amount *big.Int)35	AddPenaltyBurntCoins(addr common.Address, amount *big.Int)36	AddInviteBurntCoins(addr common.Address, amount *big.Int, tx *types.Transaction)37	AddFeeBurntCoins(addr common.Address, feeAmount *big.Int, burntRate float32, tx *types.Transaction)38	AddKilledBurntCoins(addr common.Address, amount *big.Int)39	AddBurnTxBurntCoins(addr common.Address, tx *types.Transaction)40	AfterKillIdentity(addr common.Address, appState *appstate.AppState)41	AfterAddStake(addr common.Address, amount *big.Int)42	AddActivationTxBalanceTransfer(tx *types.Transaction, amount *big.Int)43	AddKillTxStakeTransfer(tx *types.Transaction, amount *big.Int)44	AddKillInviteeTxStakeTransfer(tx *types.Transaction, amount *big.Int)45}46type collectorStub struct {47}48func NewStatsCollector() StatsCollector {49	return &collectorStub{}50}51func (c *collectorStub) EnableCollecting() {52	// do nothing53}54func (c *collectorStub) SetValidation(validation *statsTypes.ValidationStats) {55	// do nothing56}57func SetValidation(c StatsCollector, validation *statsTypes.ValidationStats) {58	if c == nil {59		return60	}61	c.SetValidation(validation)62}63func (c *collectorStub) SetMinScoreForInvite(score float32) {64	// do nothing65}66func SetMinScoreForInvite(c StatsCollector, score float32) {67	if c == nil {68		return69	}70	c.SetMinScoreForInvite(score)71}72func (c *collectorStub) SetAuthors(authors *types.ValidationAuthors) {73	// do nothing74}75func SetAuthors(c StatsCollector, authors *types.ValidationAuthors) {76	if c == nil {77		return78	}79	c.SetAuthors(authors)80}81func (c *collectorStub) SetTotalReward(amount *big.Int) {82	// do nothing83}84func SetTotalReward(c StatsCollector, amount *big.Int) {85	if c == nil {86		return87	}88	c.SetTotalReward(amount)89}90func (c *collectorStub) SetTotalValidationReward(amount *big.Int, share *big.Int) {91	// do nothing92}93func SetTotalValidationReward(c StatsCollector, amount *big.Int, share *big.Int) {94	if c == nil {95		return96	}97	c.SetTotalValidationReward(amount, share)98}99func (c *collectorStub) SetTotalFlipsReward(amount *big.Int, share *big.Int) {100	// do nothing101}102func SetTotalFlipsReward(c StatsCollector, amount *big.Int, share *big.Int) {103	if c == nil {104		return105	}106	c.SetTotalFlipsReward(amount, share)107}108func (c *collectorStub) SetTotalInvitationsReward(amount *big.Int, share *big.Int) {109	// do nothing110}111func SetTotalInvitationsReward(c StatsCollector, amount *big.Int, share *big.Int) {112	if c == nil {113		return114	}115	c.SetTotalInvitationsReward(amount, share)116}117func (c *collectorStub) SetTotalFoundationPayouts(amount *big.Int) {118	// do nothing119}120func SetTotalFoundationPayouts(c StatsCollector, amount *big.Int) {121	if c == nil {122		return123	}124	c.SetTotalFoundationPayouts(amount)125}126func (c *collectorStub) SetTotalZeroWalletFund(amount *big.Int) {127	// do nothing128}129func SetTotalZeroWalletFund(c StatsCollector, amount *big.Int) {130	if c == nil {131		return132	}133	c.SetTotalZeroWalletFund(amount)134}135func (c *collectorStub) AddValidationReward(addr common.Address, age uint16, balance *big.Int, stake *big.Int) {136	// do nothing137}138func AddValidationReward(c StatsCollector, addr common.Address, age uint16, balance *big.Int, stake *big.Int) {139	if c == nil {140		return141	}142	c.AddValidationReward(addr, age, balance, stake)143}144func (c *collectorStub) AddFlipsReward(addr common.Address, balance *big.Int, stake *big.Int,145	rewardedStrongFlipCids [][]byte, rewardedWeakFlipCids [][]byte) {146	// do nothing147}148func AddFlipsReward(c StatsCollector, addr common.Address, balance *big.Int, stake *big.Int,149	rewardedStrongFlipCids [][]byte, rewardedWeakFlipCids [][]byte) {150	if c == nil {151		return152	}153	c.AddFlipsReward(addr, balance, stake, rewardedStrongFlipCids, rewardedWeakFlipCids)154}155func (c *collectorStub) AddInvitationsReward(addr common.Address, balance *big.Int, stake *big.Int, age uint16,156	txHash *common.Hash, isSavedInviteWinner bool) {157	// do nothing158}159func AddInvitationsReward(c StatsCollector, addr common.Address, balance *big.Int, stake *big.Int, age uint16,160	txHash *common.Hash, isSavedInviteWinner bool) {161	if c == nil {162		return163	}164	c.AddInvitationsReward(addr, balance, stake, age, txHash, isSavedInviteWinner)165}166func (c *collectorStub) AddFoundationPayout(addr common.Address, balance *big.Int) {167	// do nothing168}169func AddFoundationPayout(c StatsCollector, addr common.Address, balance *big.Int) {170	if c == nil {171		return172	}173	c.AddFoundationPayout(addr, balance)174}175func (c *collectorStub) AddZeroWalletFund(addr common.Address, balance *big.Int) {176	// do nothing177}178func AddZeroWalletFund(c StatsCollector, addr common.Address, balance *big.Int) {179	if c == nil {180		return181	}182	c.AddZeroWalletFund(addr, balance)183}184func (c *collectorStub) AddProposerReward(addr common.Address, balance *big.Int, stake *big.Int) {185	// do nothing186}187func AddProposerReward(c StatsCollector, addr common.Address, balance *big.Int, stake *big.Int) {188	if c == nil {189		return190	}191	c.AddProposerReward(addr, balance, stake)192}193func (c *collectorStub) AddFinalCommitteeReward(addr common.Address, balance *big.Int, stake *big.Int) {194	// do nothing195}196func AddFinalCommitteeReward(c StatsCollector, addr common.Address, balance *big.Int, stake *big.Int) {197	if c == nil {198		return199	}200	c.AddFinalCommitteeReward(addr, balance, stake)201}202func (c *collectorStub) CompleteCollecting() {203	// do nothing204}205func (c *collectorStub) AfterSubPenalty(addr common.Address, amount *big.Int, appState *appstate.AppState) {206	// do nothing207}208func AfterSubPenalty(c StatsCollector, addr common.Address, amount *big.Int, appState *appstate.AppState) {209	if c == nil {210		return211	}212	c.AfterSubPenalty(addr, amount, appState)213}214func (c *collectorStub) BeforeClearPenalty(addr common.Address, appState *appstate.AppState) {215	// do nothing216}217func BeforeClearPenalty(c StatsCollector, addr common.Address, appState *appstate.AppState) {218	if c == nil {219		return220	}221	c.BeforeClearPenalty(addr, appState)222}223func (c *collectorStub) BeforeSetPenalty(addr common.Address, appState *appstate.AppState) {224	// do nothing225}226func BeforeSetPenalty(c StatsCollector, addr common.Address, appState *appstate.AppState) {227	if c == nil {228		return229	}230	c.BeforeSetPenalty(addr, appState)231}232func (c *collectorStub) AfterBalanceUpdate(addr common.Address, appState *appstate.AppState) {233	// do nothing234}235func AfterBalanceUpdate(c StatsCollector, addr common.Address, appState *appstate.AppState) {236	if c == nil {237		return238	}239	c.AfterBalanceUpdate(addr, appState)240}241func (c *collectorStub) AddMintedCoins(amount *big.Int) {242	// do nothing243}244func AddMintedCoins(c StatsCollector, amount *big.Int) {245	if c == nil {246		return247	}248	c.AddMintedCoins(amount)249}250func (c *collectorStub) AddPenaltyBurntCoins(addr common.Address, amount *big.Int) {251	// do nothing252}253func AddPenaltyBurntCoins(c StatsCollector, addr common.Address, amount *big.Int) {254	if c == nil {255		return256	}257	c.AddPenaltyBurntCoins(addr, amount)258}259func (c *collectorStub) AddInviteBurntCoins(addr common.Address, amount *big.Int, tx *types.Transaction) {260	// do nothing261}262func AddInviteBurntCoins(c StatsCollector, addr common.Address, amount *big.Int, tx *types.Transaction) {263	if c == nil {264		return265	}266	c.AddInviteBurntCoins(addr, amount, tx)267}268func (c *collectorStub) AddFeeBurntCoins(addr common.Address, feeAmount *big.Int, burntRate float32,269	tx *types.Transaction) {270	// do nothing271}272func AddFeeBurntCoins(c StatsCollector, addr common.Address, feeAmount *big.Int, burntRate float32,273	tx *types.Transaction) {274	if c == nil {275		return276	}277	c.AddFeeBurntCoins(addr, feeAmount, burntRate, tx)278}279func (c *collectorStub) AddKilledBurntCoins(addr common.Address, amount *big.Int) {280	// do nothing281}282func AddKilledBurntCoins(c StatsCollector, addr common.Address, amount *big.Int) {283	if c == nil {284		return285	}286	c.AddKilledBurntCoins(addr, amount)287}288func (c *collectorStub) AddBurnTxBurntCoins(addr common.Address, tx *types.Transaction) {289	// do nothing290}291func AddBurnTxBurntCoins(c StatsCollector, addr common.Address, tx *types.Transaction) {292	if c == nil {293		return294	}295	c.AddBurnTxBurntCoins(addr, tx)296}297func (c *collectorStub) AfterKillIdentity(addr common.Address, appState *appstate.AppState) {298	// do nothing299}300func AfterKillIdentity(c StatsCollector, addr common.Address, appState *appstate.AppState) {301	if c == nil {302		return303	}304	c.AfterKillIdentity(addr, appState)305}306func (c *collectorStub) AfterAddStake(addr common.Address, amount *big.Int) {307	// do nothing308}309func AfterAddStake(c StatsCollector, addr common.Address, amount *big.Int) {310	if c == nil {311		return312	}313	c.AfterAddStake(addr, amount)314}315func (c *collectorStub) AddActivationTxBalanceTransfer(tx *types.Transaction, amount *big.Int) {316	// do nothing317}318func AddActivationTxBalanceTransfer(c StatsCollector, tx *types.Transaction, amount *big.Int) {319	if c == nil {320		return321	}322	c.AddActivationTxBalanceTransfer(tx, amount)323}324func (c *collectorStub) AddKillTxStakeTransfer(tx *types.Transaction, amount *big.Int) {325	// do nothing326}327func AddKillTxStakeTransfer(c StatsCollector, tx *types.Transaction, amount *big.Int) {328	if c == nil {329		return330	}331	c.AddKillTxStakeTransfer(tx, amount)332}333func (c *collectorStub) AddKillInviteeTxStakeTransfer(tx *types.Transaction, amount *big.Int) {334	// do nothing335}336func AddKillInviteeTxStakeTransfer(c StatsCollector, tx *types.Transaction, amount *big.Int) {337	if c == nil {338		return339	}340	c.AddKillInviteeTxStakeTransfer(tx, amount)341}...

...14var Username					string15var Password					string16var MinutesInPastToQuery			int17var CronString					string18var NumberOfCrashesBeforeKill			int19var DelayedActionCronString			string20var DelayedActionMinutesInPastToQuery		int21var DelayedActionNumberOfCrashesBeforeKill	int22var DelayedActionOrgsGuid			[]string23var DelayedActionSpacesGuid			[]string24var DelayedActionAppsGuid			[]string25var SkipSslValidation				bool26var DryRun					bool27type response struct{28	ApiAddress				string29	Username				string30	MinutesInPastToQuery			int31	CronString				string32	NumberOfCrashesBeforeKill		int33	DelayedActionCronString			string34	DelayedActionMinutesInPastToQuery	int35	DelayedActionNumberOfCrashesBeforeKill	int36	DelayedActionOrgsGuid			[]string37	DelayedActionSpacesGuid			[]string38	DelayedActionAppsGuid			[]string39	SkipSslValidation			bool40	DryRun					bool41}42func rootHandler(w http.ResponseWriter, req *http.Request) {43	w.Header().Set("Content-Type", "application/json")44	w.WriteHeader(http.StatusOK)45	json.NewEncoder(w).Encode(response{46		ApiAddress: ApiAddress,47		Username: Username,48		MinutesInPastToQuery: MinutesInPastToQuery,49		CronString: CronString,50		NumberOfCrashesBeforeKill: NumberOfCrashesBeforeKill,51		DelayedActionCronString: DelayedActionCronString,52		DelayedActionNumberOfCrashesBeforeKill: DelayedActionNumberOfCrashesBeforeKill,53		DelayedActionMinutesInPastToQuery: DelayedActionMinutesInPastToQuery,54		DelayedActionOrgsGuid: DelayedActionOrgsGuid,55		DelayedActionSpacesGuid: DelayedActionSpacesGuid,56		DelayedActionAppsGuid: DelayedActionAppsGuid,57		SkipSslValidation: SkipSslValidation,58		DryRun: DryRun,59	})60}61func init() {62	fail := false63	if "" == os.Getenv("ApiAddress") {64		fmt.Fprintln(os.Stderr, "Environmental variable 'ApiAddress' not set")65		fail = true66	} else {67		ApiAddress = os.Getenv("ApiAddress")68	}69	if "" == os.Getenv("CFServiceAccountUsername") {70		fmt.Fprintln(os.Stderr, "Environmental variable 'CFServiceAccountUsername' not set")71		fail = true72	} else {73		Username = os.Getenv("CFServiceAccountUsername")74	}75	if "" == os.Getenv("CFServiceAccountPassword") {76		fmt.Fprintln(os.Stderr, "Environmental variable 'CFServiceAccountPassword' not set")77		fail = true78	} else {79		Password = os.Getenv("CFServiceAccountPassword")80	}81	var err error82	if "" == os.Getenv("CronString") {83		fmt.Fprintln(os.Stderr, "Environmental variable 'CronString' not set")84		fail = true85	} else {86		CronString = os.Getenv("CronString")87	}88	DelayedActionCronString = os.Getenv("DelayedActionCronString")89	MinutesInPastToQuery, err = strconv.Atoi(os.Getenv("MinutesInPastToQuery"))90	if err != nil {91		fmt.Fprintln(os.Stderr, "Can not parse environmental variable 'MinutesInPastToQuery' to an int")92		fail = true93	}94	DelayedActionMinutesInPastToQuery, err = strconv.Atoi(os.Getenv("DelayedActionMinutesInPastToQuery"))95	if err != nil {96		fmt.Fprintln(os.Stderr, "Can not parse environmental variable 'DelayedActionMinutesInPastToQuery' to an int")97	}98	DelayedActionNumberOfCrashesBeforeKill, err = strconv.Atoi(os.Getenv("DelayedActionNumberOfCrashesBeforeKill"))99	if err != nil {100		fmt.Fprintln(os.Stderr, "Can not parse environmental variable 'DelayedActionNumberOfCrashesBeforeKill' to an int")101	}102	NumberOfCrashesBeforeKill, err = strconv.Atoi(os.Getenv("NumberOfCrashesBeforeKill"))103	if err != nil {104		fmt.Fprintln(os.Stderr, "Can not parse environmental variable 'NumberOfCrashesBeforeKill' to an int")105		fail = true106	}107	SkipSslValidation, err = strconv.ParseBool(os.Getenv("SkipSslValidation"))108	if err != nil {109		fmt.Fprintln(os.Stderr, "Can not parse environmental variable 'SkipSslValidation' to a boolean")110	}111	DryRun, err = strconv.ParseBool(os.Getenv("DryRun"))112	if err != nil {113		fmt.Fprintln(os.Stderr, "Can not parse environmental variable 'DryRun' to a boolean")114	}115	DelayedActionOrgsGuid = strings.Split(strings.Replace(os.Getenv("DelayedActionOrgsGuid"), " ", "", -1), ",")116	DelayedActionSpacesGuid = strings.Split(strings.Replace(os.Getenv("DelayedActionSpacesGuid"), " ", "", -1), ",")117	DelayedActionAppsGuid = strings.Split(strings.Replace(os.Getenv("DelayedActionAppsGuid"), " ", "", -1), ",")118	if fail {119		os.Exit(1)120	}121}122func stringInSlice(a string, list []string) bool {123        for _, b := range list {124                if b == a {125                        return true126                }127        }128	return false129}130func task(banner string,131		localNumberOfCrashesBeforeKill int,132		localMinutesInPastToQuery int,133		localDelayedActionOrgsGuid []string,134		localDelayedActionSpacesGuid []string,135		localDelayedActionAppsGuid []string) {136	fmt.Println(banner)137	c := &cfclient.Config {138		ApiAddress:		ApiAddress,139		Username:		Username,140		Password:		Password,141		SkipSslValidation:	SkipSslValidation,142	}143	client, err := cfclient.NewClient(c)144	if err != nil {145		fmt.Fprintln(os.Stderr, err)146		os.Exit(2)147	}148	var AppEventQuerys = []cfclient.AppEventQuery {149		cfclient.AppEventQuery {150			Filter: "timestamp",151			Operator: ">=",152			Value: time.Now().Add(time.Duration(-localMinutesInPastToQuery) * time.Minute).UTC().Format(time.RFC3339),153		},154	}155	aeea, err := client.ListAppEventsByQuery("app.crash", AppEventQuerys)156	if err != nil {157		fmt.Fprintln(os.Stderr, err)158		os.Exit(3)159	}160	var crashes = map[string]int{}161	for _, i := range aeea {162		crashes[i.Actor]++163	}164	for appGuid, crashCount := range crashes {165		a, _ := client.GetAppByGuid(appGuid)166		if a.State == "STARTED" {167			s, _ := client.GetSpaceByGuid(a.SpaceGuid)168			o, _ := client.GetOrgByGuid(a.SpaceData.Entity.OrganizationGuid)169			fmt.Printf("Org: %v, space: %v, app: %v, has crashed %v times in the past %v minutes ", o.Name, s.Name, a.Name, crashCount, MinutesInPastToQuery)170			if crashCount >= localNumberOfCrashesBeforeKill {171				if !DryRun {172					//kinda had to do guids since app names and space names can be reused173					if stringInSlice(appGuid, localDelayedActionOrgsGuid) ||174							stringInSlice(a.SpaceGuid, localDelayedActionSpacesGuid) ||175							stringInSlice(a.SpaceData.Entity.OrganizationGuid, DelayedActionOrgsGuid) {176						fmt.Println("... is in a DelayedAction org, space, or app. ")177					} else {178						aur := cfclient.AppUpdateResource{State: "STOPPED"}179						_, err := client.UpdateApp(appGuid, aur)180						if err != nil {181							fmt.Fprintln(os.Stderr, err)182						}183						fmt.Println("...killing!")184					}185				} else {186					fmt.Println("...Lucky this is a dry run")187				}188			} else {189				fmt.Println("letting this app live.... for now")190			}191		}192	}193}194func typicalTask() {195	task("Regularly Scheduled task", NumberOfCrashesBeforeKill, MinutesInPastToQuery, DelayedActionOrgsGuid, DelayedActionSpacesGuid, DelayedActionAppsGuid)196}197func delayedAction() {198	task("DelayedAction task", DelayedActionNumberOfCrashesBeforeKill, DelayedActionMinutesInPastToQuery, []string{}, []string{}, []string{})199}200func main() {201	port := os.Getenv("PORT")202	if len(port) < 1 {203		port = "8080"204	}205	c := cron.New()206	c.AddFunc(CronString, func() {typicalTask()})207	c.AddFunc(DelayedActionCronString, func() {delayedAction()})208	c.Start()209	http.HandleFunc("/", rootHandler)210	http.ListenAndServe(":"+port, nil)211}...

1package internal2import (3	"context"4	"fmt"5	"github.com/nathanhack/sibyl/core"6	"github.com/nathanhack/sibyl/core/database"7	"github.com/sirupsen/logrus"8	"time"9)10type StockValidator struct {11	killCtx             context.Context12	kill                context.CancelFunc13	doneCtx             context.Context14	done                context.CancelFunc15	db                  *database.SibylDatabase16	stockCache          *StockCache17	optionSymbolGrabber *OptionSymbolGrabber18	running             bool19}20func NewStockValidator(db *database.SibylDatabase, stockCache *StockCache, optionSymbolGrabber *OptionSymbolGrabber) *StockValidator {21	killCtx, kill := context.WithCancel(context.Background())22	doneCtx, done := context.WithCancel(context.Background())23	return &StockValidator{24		killCtx:             killCtx,25		kill:                kill,26		doneCtx:             doneCtx,27		done:                done,28		db:                  db,29		stockCache:          stockCache,30		optionSymbolGrabber: optionSymbolGrabber,31	}32}33func (sv *StockValidator) Run() error {34	if sv.running {35		return fmt.Errorf("StockValidator is already running")36	}37	sv.running = true38	go func(sqg *StockValidator) {39		onceDailyDeadline, onceDailyDeadlineCancel := context.WithDeadline(context.Background(), time.Now().Add(15*time.Second))40		ticker := time.NewTicker(1 * time.Second)41		symbolCache := make(map[core.StockSymbolType]bool)42	mainLoop:43		for {44			select {45			case <-sv.killCtx.Done():46				break mainLoop47			case <-onceDailyDeadline.Done():48				onceDailyDeadlineCancel()49				onceDailyDeadline, onceDailyDeadlineCancel = context.WithDeadline(context.Background(), tomorrowAt6AM())50				now := core.NewDateTypeFromTime(time.Now())51				for _, stock := range sv.stockCache.GetAllStocks() {52					if stock.ValidationStatus == core.ValidationPending ||53						(stock.ValidationStatus != core.ValidationInvalid && stock.ValidationTimestamp.IsZero()) ||54						(stock.ValidationStatus == core.ValidationValid && stock.ValidationTimestamp.Before(now)) {55						symbolCache[stock.Symbol] = true56					}57				}58			case <-ticker.C:59				startTime := time.Now()60				agent, err := sv.db.GetAgent(sv.killCtx)61				if err != nil {62					logrus.Errorf("StockValidator: could not retrieve agent: %v", err)63					continue64				}65				for _, stock := range sv.stockCache.GetValidationStatus(core.ValidationPending) {66					symbolCache[stock.Symbol] = true67				}68				//now we do a cursor check if there's any work to do69				// if not we bail this round70				if len(symbolCache) == 0 {71					continue72				}73				updatedChan := make(chan updated, len(symbolCache))74				runningCount := 075				ctx, cancel := context.WithCancel(sv.killCtx)76				for stock := range symbolCache {77					runningCount++78					go validateStock(ctx, agent, sv.stockCache, stock, updatedChan)79				}80				//we clear out the cache for the next round81				symbolCache = make(map[core.StockSymbolType]bool)82				// now we will issue an updated if we get a true from the updateChan83			updateLoop:84				for runningCount > 0 {85					select {86					case <-sv.killCtx.Done():87						break updateLoop88					case update := <-updatedChan:89						if update.Updated {90							sv.optionSymbolGrabber.RequestUpdate <- update.Stock91						}92						runningCount--93					case <-time.After(6 * time.Hour):94						//a fail safe this should take 6 hours to complete95						logrus.Errorf("StockValidator: had an issue getting all the result for stock validation in a timely manor")96						break updateLoop97					}98				}99				cancel()100				logrus.Infof("StockValidator: finished a round in %v", time.Since(startTime))101			}102		}103		sqg.done() //signal this is finished104	}(sv)105	return nil106}107type updated struct {108	Stock   core.StockSymbolType109	Updated bool110}111func validateStock(ctx context.Context, agent core.SibylAgent, stockCache *StockCache, stock core.StockSymbolType, updatedChan chan updated) {112	good, hasOptions, exchange, exchangeDescription, name, err := agent.VerifyStockSymbol(ctx, stock)113	if err != nil {114		logrus.Errorf("StockValidator: had the following error: %v", err)115		updatedChan <- updated{116			Stock:   stock,117			Updated: false,118		}119		return120	}121	if good {122		logrus.Infof("StockValidator: the stock %v was valid", stock)123		optionstatus := core.OptionsDisabled124		if hasOptions {125			optionstatus = core.OptionsEnabled126		}127		for _, err := range []error{128			stockCache.UpdateOptionStatus(stock, optionstatus),129			stockCache.UpdateExchange(stock, exchange),130			stockCache.UpdateExchangeDescription(stock, exchangeDescription),131			stockCache.UpdateName(stock, name),132			stockCache.UpdateValidationStatus(stock, core.ValidationValid),133			stockCache.UpdateValidationTimestamp(stock, core.NewDateTypeFromTime(time.Now())),134		} {135			if err != nil {136				logrus.Errorf("StockValidator: failed to update stock %v: %v", stock, err)137				updatedChan <- updated{138					Stock:   stock,139					Updated: false,140				}141				return142			}143		}144	} else {145		logrus.Infof("StockValidator: the stock %v was NOT valid", stock)146		for _, err := range []error{147			stockCache.UpdateValidationStatus(stock, core.ValidationInvalid),148			stockCache.UpdateValidationTimestamp(stock, core.NewDateTypeFromTime(time.Now())),149		} {150			if err != nil {151				logrus.Errorf("StockValidator: failed to update stock %v: %v", stock, err)152				updatedChan <- updated{153					Stock:   stock,154					Updated: false,155				}156				return157			}158		}159	}160	updatedChan <- updated{161		Stock:   stock,162		Updated: true,163	}164}165func (sv *StockValidator) Stop(waitUpTo time.Duration) {166	//next stop the quoter167	logrus.Infof("Waiting for StockValidator to finish")168	startTime := time.Now()169	sv.kill()170	select {171	case <-sv.doneCtx.Done():172		logrus.Infof("StockValidator finished in %v", time.Since(startTime))173	case <-time.After(waitUpTo):174		logrus.Errorf("StockValidator failed to gracefully finish in %v", time.Since(startTime))175	}176}...

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

1import (2type User struct {3}4func main() {5    u := User{"", 0}6    validate := validator.New()7    err := validate.Struct(u)8    if err != nil {9        fmt.Println(err)10        for _, e := range err.(validator.ValidationErrors) {11            fmt.Println(e)12        }13    }14}15import (16type User struct {17}18func main() {19    u := User{"", 0}20    validate := validator.New()21    err := validate.Struct(u)22    if err != nil {23        fmt.Println(err)24        for _, e := range err.(validator.ValidationErrors) {25            fmt.Println(e)26        }27    }28}29import (30type User struct {31}32func main() {33    u := User{"", 0}34    validate := validator.New()35    err := validate.Struct(u)36    if err != nil {37        fmt.Println(err)38        for _, e := range err.(validator.ValidationErrors) {39            fmt.Println(e)40        }41    }42}

1import (2func main() {3    fmt.Println("Hello, playground")4    v := validation.Validation{}5    v.Kill()6}7import "fmt"8type Validation struct {9}10func (v *Validation) Kill() {11    fmt.Println("Validation: Killed")12}

1import (2func main() {3	v := validation.Validation{}4	v.Kill()5	fmt.Println("End of main")6}7import (8type Validation struct {9}10func (v *Validation) Kill() {11	fmt.Println("Killed")12}13import (14func main() {15	v := validation.Validation{}16	v.Kill()17	fmt.Println("End of main")18}19import (20type Validation struct {21}22func (v *Validation) Kill() {23	fmt.Println("Killed")24}25import (26func main() {27	v := validation.Validation{}28	v.Kill()29	fmt.Println("End of main")30}31import (32type Validation struct {33}34func (v *Validation) Kill() {35	fmt.Println("Killed")36}37import (38func main() {39	v := validation.Validation{}40	v.Kill()41	fmt.Println("End of main")42}43import (44type Validation struct {45}46func (v *Validation) Kill() {47	fmt.Println("Killed")48}49import (50func main() {51	v := validation.Validation{}52	v.Kill()53	fmt.Println("End of main")54}55import (56type Validation struct {57}58func (v *Validation) Kill() {59	fmt.Println("Killed")60}61import (

1import "fmt"2func main() {3  fmt.Println("Hello, World!")4}5import "fmt"6func main() {7  fmt.Println("Hello, World!")8}9import "fmt"10func main() {11  fmt.Println("Hello, World!")12}13import "fmt"14func main() {15  fmt.Println("Hello, World!")16}17import "fmt"18func main() {19  fmt.Println("Hello, World!")20}21import "fmt"22func main() {23  fmt.Println("Hello, World!")24}25import "fmt"26func main() {27  fmt.Println("Hello, World!")28}29import "fmt"30func main() {31  fmt.Println("Hello, World!")32}33import "fmt"34func main() {35  fmt.Println("Hello, World!")36}

1import (2func main() {3    fmt.Println("Enter a number")4    fmt.Scanln(&x)5    v := validation.Validation{}6    v.Kill(x)7}8import (9type Validation struct {10}11func (v Validation) Kill(x int) {12    if x == 0 {13        fmt.Println("Zero is not allowed")14        os.Exit(1)15    }16}17import (18func main() {

1import "fmt"2import "github.com/GoLangTutorials/Validation"3func main() {4    fmt.Println(validation.Kill("abc"))5}6import "fmt"7import "github.com/GoLangTutorials/Validation"8func main() {9    fmt.Println(validation.Kill("abc"))10}11func Kill(name string) string {12}13import "fmt"14import "github.com/GoLangTutorials/Validation"15func main() {16    fmt.Println(validation.Kill("abc"))17}18import "fmt"19import "github.com/GoLangTutorials/Validation"20func main() {21    fmt.Println(validation.Kill("abc"))22}