logtail.go

package main

import (
	"fmt"

	czmq "github.com/zeromq/goczmq"
)

func main() {
	serverCert, _ := czmq.NewCertFromFile("/etc/curve.d/example_curve_server_cert")
	serverKey := serverCert.PublicText()

	client := czmq.NewSock(czmq.SUB)
	defer client.Destroy()

	clientCert, _ := czmq.NewCertFromFile("/etc/curve.d/example_curve_client_cert")
	defer clientCert.Destroy()

	clientCert.Apply(client)
	client.SetCurveServerkey(serverKey)
	client.SetSubscribe("")

	client.Connect("tcp://127.0.0.1:24445")

	for {
		msg, _, _ := client.RecvFrame()
		fmt.Printf("\n%s\n", string(msg))
	}
}