func()

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
}