controllers

Documentation

Index

• func ParsePortConfigService(str string) client.ObjectKey
• type ConfigMapReconciler
  • func (r *ConfigMapReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ConfigMapReconciler) SetupWithManager(mgr ctrl.Manager) (err error)
  • func (r *ConfigMapReconciler) TriggerReconcile()
• type EndpointsReconciler
  • func (r *EndpointsReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *EndpointsReconciler) SetupWithManager(mgr ctrl.Manager) (err error)
• type PodInfo
• type PortConfig
• type PortConfigService
  • func (s PortConfigService) String() string
• type PortConfigs
• type PortConfigsBySessionID
• type PortsByServiceAndSessionID

Functions

func ParsePortConfigService

func ParsePortConfigService(str string) client.ObjectKey

Types

type ConfigMapReconciler

type ConfigMapReconciler struct {
	client.Client

	Scheme *runtime.Scheme
	Logger logr.Logger

	Ports *sync.Map

	PodInfo PodInfo
	// contains filtered or unexported fields
}

func (*ConfigMapReconciler) Reconcile

func (r *ConfigMapReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*ConfigMapReconciler) SetupWithManager

func (r *ConfigMapReconciler) SetupWithManager(mgr ctrl.Manager) (err error)

func (*ConfigMapReconciler) TriggerReconcile

func (r *ConfigMapReconciler) TriggerReconcile()

type EndpointsReconciler

type EndpointsReconciler struct {
	client.Client

	Cache  cache.Cache
	Scheme *runtime.Scheme
	Logger logr.Logger
	// contains filtered or unexported fields
}

func (*EndpointsReconciler) Reconcile

func (r *EndpointsReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*EndpointsReconciler) SetupWithManager

func (r *EndpointsReconciler) SetupWithManager(mgr ctrl.Manager) (err error)

type PodInfo

type PodInfo struct {
	Name      string `json:"name,omitempty"`
	Namespace string `json:"namespace,omitempty"`
	IP        string `json:"ip,omitempty"`
}

type PortConfig

type PortConfig struct {
	Name       string            `json:"name,omitempty"`
	Address    string            `json:"address,omitempty"`
	Port       int               `json:"port,omitempty"`
	TargetPort int               `json:"targetPort,omitempty"`
	Service    PortConfigService `json:"service,omitempty"`
	SessionID  string            `json:"sessionID,omitempty"`
}

type PortConfigService

type PortConfigService struct {
	Name      string `json:"name,omitempty"`
	Namespace string `json:"namespace,omitempty"`
}

func (PortConfigService) String

func (s PortConfigService) String() string

type PortConfigs

type PortConfigs []PortConfig

type PortConfigsBySessionID

type PortConfigsBySessionID map[string]PortConfigs

type PortsByServiceAndSessionID

type PortsByServiceAndSessionID map[string]PortConfigsBySessionID