Documentation ¶
Index ¶
- Constants
- Variables
- type KubeFinder
- func (k *KubeFinder) IsExternalIP(ctx context.Context, ip string) (bool, error)
- func (k *KubeFinder) ResolveIPToExternalAccessService(ctx context.Context, ip string, port int) (*corev1.Service, bool, error)
- func (k *KubeFinder) ResolveIPToPod(ctx context.Context, ip string) (*corev1.Pod, error)
- func (k *KubeFinder) ResolveIPToService(ctx context.Context, ip string) (*corev1.Service, bool, error)
- func (k *KubeFinder) ResolveIstioWorkloadToPod(ctx context.Context, workload string, namespace string) (*corev1.Pod, error)
- func (k *KubeFinder) ResolvePodByName(ctx context.Context, name string, namespace string) (*corev1.Pod, error)
- func (k *KubeFinder) ResolveServiceAddressToIps(ctx context.Context, fqdn string) ([]string, types.NamespacedName, error)
- func (k *KubeFinder) ResolveServiceToPods(ctx context.Context, svc *corev1.Service) ([]corev1.Pod, error)
Constants ¶
View Source
const (
IstioCanonicalNameLabelKey = "service.istio.io/canonical-name"
)
Variables ¶
View Source
var ErrFoundMoreThanOnePod = errors.Errorf("ip belongs to more than one pod")
View Source
var ErrFoundMoreThanOneService = errors.Errorf("ip belongs to more than one service")
View Source
var ErrNoPodFound = errors.Errorf("no pod found")
Functions ¶
This section is empty.
Types ¶
type KubeFinder ¶
type KubeFinder struct {
// contains filtered or unexported fields
}
func NewKubeFinder ¶
func (*KubeFinder) IsExternalIP ¶
func (*KubeFinder) ResolveIPToExternalAccessService ¶
func (*KubeFinder) ResolveIPToPod ¶
func (*KubeFinder) ResolveIPToService ¶
func (*KubeFinder) ResolveIstioWorkloadToPod ¶
func (*KubeFinder) ResolvePodByName ¶
func (*KubeFinder) ResolveServiceAddressToIps ¶
func (k *KubeFinder) ResolveServiceAddressToIps(ctx context.Context, fqdn string) ([]string, types.NamespacedName, error)
func (*KubeFinder) ResolveServiceToPods ¶
Click to show internal directories.
Click to hide internal directories.