func (s *logServer) Log(stream pb.LogService_LogServer) error {
	var count int32
	for {
		message, err := stream.Recv()
		if err == io.EOF {
			return stream.SendAndClose(&pb.MLogMsgAck{Time: time.Now().Unix(), Count: count})
		} else if err != nil {
			return err
		}
		count++
		log.Printf("%s: level [%d]: %s", message.GetSource(), message.GetLevel(), message.GetMessage())
	}
}
Log messages to the console coming from workers
package cluster
import (
	"io"
	"log"
	"time"
	pb "github.com/go-sif/sif/internal/rpc"
)
type logServer struct {
}
func createLogServer() *logServer {
	return &logServer{}
}