Function NewServer

agent/boundarylogproxy/proxy.go:65–72

NewServer creates a new boundary log proxy server.

(logger slog.Logger, socketPath string, registerer prometheus.Registerer)

// NewServer creates a new boundary log proxy server.
func NewServer(logger slog.Logger, socketPath string, registerer prometheus.Registerer) *Server {
	return &Server{
		logger:     logger.Named("boundary-log-proxy"),
		socketPath: socketPath,
		metrics:    newMetrics(registerer),
		logs:       make(chan *agentproto.ReportBoundaryLogsRequest, logBufferSize),
	}
}

// Start begins listening for connections on the Unix socket, and handles new
// connections in a separate goroutine. Incoming logs from connections are