How to use Kill method of validation Package

Best Gauge code snippet using validation.Kill

collector.go

Source:collector.go Github

copy

Full Screen

...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}...

Full Screen

Full Screen

main.go

Source:main.go Github

copy

Full Screen

...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}...

Full Screen

Full Screen

stockValidator.go

Source:stockValidator.go Github

copy

Full Screen

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}...

Full Screen

Full Screen

Kill

Using AI Code Generation

copy

Full Screen

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}

Full Screen

Full Screen

Kill

Using AI Code Generation

copy

Full Screen

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}

Full Screen

Full Screen

Kill

Using AI Code Generation

copy

Full Screen

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}

Full Screen

Full Screen

Kill

Using AI Code Generation

copy

Full Screen

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 (

Full Screen

Full Screen

Kill

Using AI Code Generation

copy

Full Screen

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}

Full Screen

Full Screen

Kill

Using AI Code Generation

copy

Full Screen

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() {

Full Screen

Full Screen

Kill

Using AI Code Generation

copy

Full Screen

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}

Full Screen

Full Screen

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.

LambdaTest Learning Hubs:

YouTube

You could also refer to video tutorials over LambdaTest YouTube channel to get step by step demonstration from industry experts.

Run Gauge automation tests on LambdaTest cloud grid

Perform automation testing on 3000+ real desktop and mobile devices online.

... View sample repo... View DocumentationSign up Free
›
_

Most used method in

Try LambdaTest Now !!

Get 100 minutes of automation test minutes FREE!!

...
Sign up with GoogleSign up with Email
Next-Gen App & Browser Testing Cloud

Was this article helpful?

Helpful

NotHelpful