kube

Documentation

Index

• func AddApplicationProtocolController(mgr manager.Manager, triggerPush func() error) error
• func AddDubboAuthorizationPolicyController(mgr manager.Manager, triggerPush func() error) error
• func AddMetaRouterController(mgr manager.Manager, triggerPush func() error) error
• func AddNamespaceController(mgr manager.Manager, aerakiAddr, aerakiPort string) error
• func AddRedisDestinationController(mgr manager.Manager, triggerPush func() error) error
• func AddRedisServiceController(mgr manager.Manager, triggerPush func() error) error
• func AddServiceEntryController(mgr manager.Manager) error
• func GetBootstrapConfig(address, portValue string) string
• func NewManager(kubeConfig *rest.Config, namespace string, leaderElection bool, ...) (manager.Manager, error)
• type BootstrapConfig
• type DubboController
  • func (r *DubboController) Reconcile(_ context.Context, request reconcile.Request) (reconcile.Result, error)
• type MetaProtocolController
  • func (r *MetaProtocolController) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
• type MetaRouterController
  • func (r *MetaRouterController) Reconcile(_ context.Context, request reconcile.Request) (reconcile.Result, error)
• type RedisController
  • func (r *RedisController) Reconcile(_ context.Context, request reconcile.Request) (reconcile.Result, error)

Functions

func AddApplicationProtocolController

func AddApplicationProtocolController(mgr manager.Manager, triggerPush func() error) error

AddApplicationProtocolController adds ApplicationProtocolController

func AddDubboAuthorizationPolicyController

func AddDubboAuthorizationPolicyController(mgr manager.Manager, triggerPush func() error) error

AddDubboAuthorizationPolicyController adds DubboAuthorizationPolicyController

func AddMetaRouterController

func AddMetaRouterController(mgr manager.Manager, triggerPush func() error) error

AddMetaRouterController adds MetaRouterController

func AddNamespaceController

func AddNamespaceController(mgr manager.Manager, aerakiAddr, aerakiPort string) error

AddNamespaceController adds namespaceController

func AddRedisDestinationController

func AddRedisDestinationController(mgr manager.Manager, triggerPush func() error) error

AddRedisDestinationController adds RedisDestinationControlle

func AddRedisServiceController

func AddRedisServiceController(mgr manager.Manager, triggerPush func() error) error

AddRedisServiceController adds RedisServiceController

func AddServiceEntryController

func AddServiceEntryController(mgr manager.Manager) error

AddServiceEntryController adds serviceEntryController

func GetBootstrapConfig

func GetBootstrapConfig(address, portValue string) string

GetBootstrapConfig gets the ConfigMap to be generated under the namespace

func NewManager

func NewManager(kubeConfig *rest.Config, namespace string, leaderElection bool,
	leaderElectionID string) (manager.Manager, error)

NewManager create a manager to manager all crd controllers.

Types

type BootstrapConfig

type BootstrapConfig struct {
	Address   string
	PortValue string
}

BootstrapConfig stores RDS config for Aeraki

type DubboController

type DubboController struct {
	// contains filtered or unexported fields
}

DubboController control DubboAuthorizationPolicy

func (*DubboController) Reconcile

func (r *DubboController) Reconcile(_ context.Context, request reconcile.Request) (reconcile.Result, error)

Reconcile will try to trigger once mcp push.

type MetaProtocolController

type MetaProtocolController struct {
	client.Client
	// contains filtered or unexported fields
}

MetaProtocolController control ApplicationProtocol

func (*MetaProtocolController) Reconcile

func (r *MetaProtocolController) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

Reconcile will try to trigger once mcp push.

type MetaRouterController

type MetaRouterController struct {
	client.Client
	// contains filtered or unexported fields
}

MetaRouterController control ApplicationProtocol

func (*MetaRouterController) Reconcile

func (r *MetaRouterController) Reconcile(_ context.Context, request reconcile.Request) (reconcile.Result, error)

Reconcile will try to trigger once mcp push.

type RedisController

type RedisController struct {
	// contains filtered or unexported fields
}

RedisController control RedisService or RedisDestination

func (*RedisController) Reconcile

func (r *RedisController) Reconcile(_ context.Context, request reconcile.Request) (reconcile.Result, error)

Reconcile will try to trigger once mcp push.