services/boot/check.go

   1 package main
   2
   3 import (
   4         "context"
   5         "time"
   6 )
   7
   8 func waitCheck(ctx context.Context, timeout time.Duration, check func(ctx context.Context) error) error {
   9         ctx, _ = context.WithTimeout(ctx, timeout)
  10         var err error
  11         for err = check(ctx); err != nil && ctx.Err() == nil; err = check(ctx) {
  12                 time.Sleep(time.Second)
  13         }
  14         return err
  15 }