medium / singleflight

sf_base.go

type NodeStat struct {
   // NodeData []byte // omit it for this example
   NodeID    string
   Timestamp time.Time
}

type App struct {}

func (a *App) GetNodeStatSync(nodeID string) (*NodeStat, error) {
   collectedAt := time.Now()

   // Add some time for workload emulation.
   time.Sleep(10 * time.Second)

   return &NodeStat{
      NodeID:    nodeID,
      Timestamp: collectedAt,
   }, nil
}