controllers

package

v0.1.1 Latest Latest Go to latest Published: Jun 2, 2025 License: Apache-2.0 Imports: 33 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/apache/dubbo-kubernetes

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func InboundTagsForPod(zone string, pod *kube_core.Pod, name string) map[string]string
func InboundTagsForService(zone string, pod *kube_core.Pod, svc *kube_core.Service, ...) map[string]string
func ProbesFor(pod *kube_core.Pod) (*mesh_proto.Dataplane_Probes, error)
func ProtocolTagFor(svc *kube_core.Service, svcPort *kube_core.ServicePort) string
func ServiceToPodsMapper(l logr.Logger, client kube_client.Client) kube_handler.MapFunc
type Endpoint
type EndpointsByService
- func (e EndpointsByService) Services() []string
type InboundConverter
- func (i *InboundConverter) InboundInterfacesFor(ctx context.Context, zone string, pod *kube_core.Pod, ...) ([]*mesh_proto.Dataplane_Networking_Inbound, error)
type NameExtractor
- func (n *NameExtractor) Name(ctx context.Context, pod *kube_core.Pod) (string, string, error)
type PodConverter
- func (p *PodConverter) EgressFor(ctx context.Context, zoneEgress *mesh_proto.ZoneEgress, pod *kube_core.Pod, ...) error
- func (p *PodConverter) IngressFor(ctx context.Context, zoneIngress *mesh_proto.ZoneIngress, pod *kube_core.Pod, ...) error
- func (p *PodConverter) OutboundInterfacesFor(ctx context.Context, pod *kube_core.Pod, others []*mesh_k8s.Dataplane, ...) ([]*mesh_proto.Dataplane_Networking_Outbound, error)
- func (p *PodConverter) PodToDataplane(ctx context.Context, dataplane *mesh_k8s.Dataplane, pod *kube_core.Pod, ...) error
- func (p *PodConverter) PodToEgress(ctx context.Context, zoneEgress *mesh_k8s.ZoneEgress, pod *kube_core.Pod, ...) error
- func (p *PodConverter) PodToIngress(ctx context.Context, zoneIngress *mesh_k8s.ZoneIngress, pod *kube_core.Pod, ...) error
type PodReconciler
- func (r *PodReconciler) Reconcile(ctx context.Context, req kube_ctrl.Request) (kube_ctrl.Result, error)
- func (r *PodReconciler) SetupWithManager(mgr kube_ctrl.Manager, maxConcurrentReconciles int) error
type ServiceReconciler
- func (r *ServiceReconciler) Reconcile(ctx context.Context, req kube_ctrl.Request) (kube_ctrl.Result, error)
- func (r *ServiceReconciler) SetupWithManager(mgr kube_ctrl.Manager) error

Constants ¶

View Source

const (
	CreatedDubboDataplaneReason          = "CreatedDubboDataplane"
	UpdatedDubboDataplaneReason          = "UpdatedDubboDataplane"
	FailedToGenerateDubboDataplaneReason = "FailedToGenerateDubboDataplane"
)

Variables ¶

View Source

var NodePortAddressPriority = []kube_core.NodeAddressType{
	kube_core.NodeExternalIP,
	kube_core.NodeInternalIP,
}

Functions ¶

func InboundTagsForPod ¶

func InboundTagsForPod(zone string, pod *kube_core.Pod, name string) map[string]string

func InboundTagsForService ¶

func InboundTagsForService(zone string, pod *kube_core.Pod, svc *kube_core.Service, svcPort *kube_core.ServicePort) map[string]string

func ProbesFor ¶

func ProbesFor(pod *kube_core.Pod) (*mesh_proto.Dataplane_Probes, error)

func ProtocolTagFor ¶

func ProtocolTagFor(svc *kube_core.Service, svcPort *kube_core.ServicePort) string

ProtocolTagFor infers service protocol from a `<port>.service.dubbo.io/protocol` annotation or `appProtocol`.

func ServiceToPodsMapper ¶

func ServiceToPodsMapper(l logr.Logger, client kube_client.Client) kube_handler.MapFunc

Types ¶

type Endpoint ¶

type Endpoint struct {
	Address  string
	Port     uint32
	Instance string
}

type EndpointsByService ¶

type EndpointsByService map[string][]Endpoint

func (EndpointsByService) Services ¶

func (e EndpointsByService) Services() []string

type InboundConverter ¶

type InboundConverter struct {
	NameExtractor NameExtractor
}

func (*InboundConverter) InboundInterfacesFor ¶

func (i *InboundConverter) InboundInterfacesFor(ctx context.Context, zone string, pod *kube_core.Pod, services []*kube_core.Service) ([]*mesh_proto.Dataplane_Networking_Inbound, error)

type NameExtractor ¶

type NameExtractor struct {
	ReplicaSetGetter kube_client.Reader
	JobGetter        kube_client.Reader
}

func (*NameExtractor) Name ¶

func (n *NameExtractor) Name(ctx context.Context, pod *kube_core.Pod) (string, string, error)

type PodConverter ¶

type PodConverter struct {
	ServiceGetter     kube_client.Reader
	NodeGetter        kube_client.Reader
	ResourceConverter k8s_common.Converter
	InboundConverter  InboundConverter
	Zone              string
}

func (*PodConverter) EgressFor ¶

func (p *PodConverter) EgressFor(
	ctx context.Context,
	zoneEgress *mesh_proto.ZoneEgress,
	pod *kube_core.Pod,
	services []*kube_core.Service,
) error

func (*PodConverter) IngressFor ¶

func (p *PodConverter) IngressFor(
	ctx context.Context, zoneIngress *mesh_proto.ZoneIngress, pod *kube_core.Pod, services []*kube_core.Service,
) error

func (*PodConverter) OutboundInterfacesFor ¶

func (p *PodConverter) OutboundInterfacesFor(
	ctx context.Context,
	pod *kube_core.Pod,
	others []*mesh_k8s.Dataplane,
	reachableServices []string,
) ([]*mesh_proto.Dataplane_Networking_Outbound, error)

func (*PodConverter) PodToDataplane ¶

func (p *PodConverter) PodToDataplane(
	ctx context.Context,
	dataplane *mesh_k8s.Dataplane,
	pod *kube_core.Pod,
	ns *kube_core.Namespace,
	services []*kube_core.Service,
	others []*mesh_k8s.Dataplane,
) error

func (*PodConverter) PodToEgress ¶

func (p *PodConverter) PodToEgress(ctx context.Context, zoneEgress *mesh_k8s.ZoneEgress, pod *kube_core.Pod, services []*kube_core.Service) error

func (*PodConverter) PodToIngress ¶

func (p *PodConverter) PodToIngress(ctx context.Context, zoneIngress *mesh_k8s.ZoneIngress, pod *kube_core.Pod, services []*kube_core.Service) error

type PodReconciler ¶

type PodReconciler struct {
	kube_client.Client
	kube_record.EventRecorder
	Scheme                       *kube_runtime.Scheme
	Log                          logr.Logger
	PodConverter                 PodConverter
	ResourceConverter            k8s_common.Converter
	SystemNamespace              string
	IgnoredServiceSelectorLabels []string
}

PodReconciler reconciles a Pod object

func (*PodReconciler) Reconcile ¶

func (r *PodReconciler) Reconcile(ctx context.Context, req kube_ctrl.Request) (kube_ctrl.Result, error)

func (*PodReconciler) SetupWithManager ¶

func (r *PodReconciler) SetupWithManager(mgr kube_ctrl.Manager, maxConcurrentReconciles int) error

type ServiceReconciler ¶

type ServiceReconciler struct {
	kube_client.Client
	Log logr.Logger
}

func (*ServiceReconciler) Reconcile ¶

func (r *ServiceReconciler) Reconcile(ctx context.Context, req kube_ctrl.Request) (kube_ctrl.Result, error)

func (*ServiceReconciler) SetupWithManager ¶

func (r *ServiceReconciler) SetupWithManager(mgr kube_ctrl.Manager) error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL