gkampitakis

func main() {
  for {
    ticker := time.NewTicker(1 * time.Second)
    // do something with the ticker
    _ = <-ticker.C
    // stop the ticker to release associated resources
    ticker.Stop()
  }
}

gkampitakis

func main() {
  for {
    ticker := time.NewTicker(1 * time.Second)
    // do something with the ticker
    _ = <-ticker.C
  }
}

gkampitakis

func processManyFiles(files []string) error {
  for _, file := range files {
    err := process(file)
    if err != nil {
      return err 
    }
  }
  
  return nil
}

gkampitakis

func processManyFiles(files []string) error {
  for _, file := range files {
    f, err := os.Open(file)
    if err != nil {
      return err 
    }
    defer f.Close()
    
    process(f)
  }

gkampitakis

func runJobs(cancel <-chan struct{}) {
  for {
    go func() {
      // create a 1Gb slice
      bigSlice := make([]byte, 1_000_000_000)
      
      // do some work with the data
      _ = bigSlice
      
      // wait until a cancellation signal is received

gkampitakis

func readFileDetails(name string) []byte{
  data, err := os.ReadFile(name)
  if err != nil {
    return err
  }
  
  return data[5:10]
}

// not holding reference to underlying memory anymore

gkampitakis

var cache = map[int]int{}

func main() {
  for i:=0; ; i++ {
    // max items cache can hold is 1_000_000
    if len(cache) >= 1_000_000 {
      delete(cache, i-len(cache))
    }
    
    cache[i] = i

gkampitakis

var cache = map[int]int{}

func main() {
  // keep allocating memory indifinitely
  for i:=0; ; i++ {
    cache[i] = i
  }
}

gkampitakis

package main

import (
	"fmt"
	"io"
	"log"
	"net/http"
	"sync/atomic"
	"time"
)

gkampitakis

import { Options, pinoHttp } from 'pino-http';
import { formatError } from '@elastic/ecs-helpers';

// Taken as it is from @elastic/ecs-pino-format
function bindings(bindingsObject: Record<string, unknown>) {
  const { pid, hostname, ...ecsBindings } = bindingsObject;

  if (pid !== undefined) {
    ecsBindings.process = { pid };
  }