in pkg/flink/auth.go [37:43]
func (auth Auth) GetCA() ([]byte, error) { cert, err := ioutil.ReadFile(auth.CaCertPath) if err != nil { return nil, errors.Wrap(err, "failed to read k8s CA cert from configured path") } return cert, nil }