code: func (c *controllerAPI) CreateSink(ctx context.Context, w http.ResponseWriter, req *http.Request) {
  	var sink ct.Sink
  	if err := httphelper.DecodeJSON(req, &sink); err != nil {
  		respondWithError(w, err)
  		return
  	}
  
  	if err := schema.Validate(&sink); err != nil {
  		respondWithError(w, err)
  		return
  	}
  
  	if err := c.sinkRepo.Add(&sink); err != nil {
  		respondWithError(w, err)
  		return
  	}
  	httphelper.JSON(w, 200, &sink)
  }
docs: // Create a new sink