Go - Bucket.On()

import (
  "context"
  "fmt"

  "github.com/nitrictech/go-sdk/nitric/storage"
  "github.com/nitrictech/go-sdk/nitric"
)

func main() {
  assets := nitric.NewBucket("assets")

  readableAssets, err := nitric.NewBucket("assets").Allow(nitric.BucketRead)
  if err != nil {
    return
  }

  assets.On(storage.DeleteNotification, "*", func(ctx *storage.Ctx) {
    fmt.Printf("a file named %s was deleted\n", ctx.Request.Key())
  })

  assets.On(storage.WriteNotification, "/images/cat", func(ctx *storage.Ctx) {
    fmt.Printf("a cat image was written")
  })

  assets.On(storage.WriteNotification, "/images/dog", func(ctx *storage.Ctx) error {
    dogImage, err := readableAssets.Read(context.TODO(), ctx.Request.Key())
    if err != nil {
      return err
    }

    fmt.Println(dogImage)

    return nil
  })

  if err := nitric.Run(); err != nil {
    fmt.Println(err)
  }
}