join

func DaemonSetPods(ctx context.Context,
	src daemonset.Controller, dst pod.Publisher) (pod.Controller, error)

func DaemonSetPodsWith(ctx context.Context,
	srcController daemonset.Controller,
	dstController pod.Publisher,
	filterFn func(...*extv1beta1.DaemonSet) filter.ComparableFilter) (pod.Controller, error)

func DeploymentPods(ctx context.Context,
	src deployment.Controller, dst pod.Publisher) (pod.Controller, error)

func DeploymentPodsWith(ctx context.Context,
	srcController deployment.Controller,
	dstController pod.Publisher,
	filterFn func(...*extv1beta1.Deployment) filter.ComparableFilter) (pod.Controller, error)

func IngressPods(ctx context.Context, srcbase ingress.Controller, svcbase service.Controller, dstbase pod.Controller) (pod.Controller, error)

func IngressServices(ctx context.Context,
	src ingress.Controller, dst service.Publisher) (service.Controller, error)

func IngressServicesWith(ctx context.Context,
	srcController ingress.Controller,
	dstController service.Publisher,
	filterFn func(...*extv1beta1.Ingress) filter.ComparableFilter) (service.Controller, error)

func RCPods(ctx context.Context,
	src replicationcontroller.Controller, dst pod.Publisher) (pod.Controller, error)

func RCPodsWith(ctx context.Context,
	srcController replicationcontroller.Controller,
	dstController pod.Publisher,
	filterFn func(...*corev1.ReplicationController) filter.ComparableFilter) (pod.Controller, error)

func RSPods(ctx context.Context,
	src replicaset.Controller, dst pod.Publisher) (pod.Controller, error)

func RSPodsWith(ctx context.Context,
	srcController replicaset.Controller,
	dstController pod.Publisher,
	filterFn func(...*extv1beta1.ReplicaSet) filter.ComparableFilter) (pod.Controller, error)

func ServicePods(ctx context.Context,
	src service.Controller, dst pod.Publisher) (pod.Controller, error)

func ServicePodsWith(ctx context.Context,
	srcController service.Controller,
	dstController pod.Publisher,
	filterFn func(...*corev1.Service) filter.ComparableFilter) (pod.Controller, error)