handler

Documentation

Index

• func Init(opt option.EventHandlers) ([]component.EventHandler, error)
• func NewKubeMultiClusterEventHandler(clustersMgr *k8smanager.ClusterManager) (component.EventHandler, error)
• func NewKubeSingleClusterEventHandler(ctrlMgr ctrlmanager.Manager, converter component.Converter) (component.EventHandler, error)
• func NewLogEventHandler() (component.EventHandler, error)
• type KubeMultiClusterEventHandler
  • func (h *KubeMultiClusterEventHandler) AddConfigEntry(e *types2.ConfigEvent)
  • func (h *KubeMultiClusterEventHandler) AddInstance(event *types2.ServiceEvent)
  • func (h *KubeMultiClusterEventHandler) AddService(event *types2.ServiceEvent)
  • func (h *KubeMultiClusterEventHandler) ChangeConfigEntry(e *types2.ConfigEvent)
  • func (h *KubeMultiClusterEventHandler) DeleteConfigEntry(e *types2.ConfigEvent)
  • func (h *KubeMultiClusterEventHandler) DeleteInstance(event *types2.ServiceEvent)
  • func (h *KubeMultiClusterEventHandler) DeleteService(event *types2.ServiceEvent)
  • func (h *KubeMultiClusterEventHandler) ReplaceAccessorInstances(event *types2.ServiceEvent, ...)
  • func (h *KubeMultiClusterEventHandler) ReplaceInstances(event *types2.ServiceEvent)
• type KubeSingleClusterEventHandler
  • func (h *KubeSingleClusterEventHandler) AddConfigEntry(e *types.ConfigEvent)
  • func (h *KubeSingleClusterEventHandler) AddInstance(e *types.ServiceEvent)
  • func (h *KubeSingleClusterEventHandler) AddService(e *types.ServiceEvent)
  • func (h *KubeSingleClusterEventHandler) ChangeConfigEntry(e *types.ConfigEvent)
  • func (h *KubeSingleClusterEventHandler) DeleteConfigEntry(e *types.ConfigEvent)
  • func (h *KubeSingleClusterEventHandler) DeleteInstance(e *types.ServiceEvent)
  • func (h *KubeSingleClusterEventHandler) DeleteService(event *types.ServiceEvent)
  • func (h *KubeSingleClusterEventHandler) ReplaceAccessorInstances(e *types.ServiceEvent, getScopedServices func(s string) map[string]struct{})
  • func (h *KubeSingleClusterEventHandler) ReplaceInstances(event *types.ServiceEvent)
• type LogEventHandler
  • func (h *LogEventHandler) AddConfigEntry(e *types.ConfigEvent)
  • func (h *LogEventHandler) AddInstance(e *types.ServiceEvent)
  • func (h *LogEventHandler) AddService(e *types.ServiceEvent)
  • func (h *LogEventHandler) ChangeConfigEntry(e *types.ConfigEvent)
  • func (h *LogEventHandler) DeleteConfigEntry(e *types.ConfigEvent)
  • func (h *LogEventHandler) DeleteInstance(e *types.ServiceEvent)
  • func (h *LogEventHandler) DeleteService(e *types.ServiceEvent)
  • func (h *LogEventHandler) ReplaceAccessorInstances(e *types.ServiceEvent, getScopedServices func(s string) map[string]struct{})
  • func (h *LogEventHandler) ReplaceInstances(e *types.ServiceEvent)

Functions

func Init

func Init(opt option.EventHandlers) ([]component.EventHandler, error)

Init the handler initialization

func NewKubeMultiClusterEventHandler

func NewKubeMultiClusterEventHandler(clustersMgr *k8smanager.ClusterManager) (component.EventHandler, error)

NewKubeMultiClusterEventHandler ...

func NewKubeSingleClusterEventHandler

func NewKubeSingleClusterEventHandler(ctrlMgr ctrlmanager.Manager, converter component.Converter) (component.EventHandler, error)

NewKubeSingleClusterEventHandler ...

func NewLogEventHandler

func NewLogEventHandler() (component.EventHandler, error)

NewLogEventHandler ...

Types

type KubeMultiClusterEventHandler

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

KubeMultiClusterEventHandler it used for synchronizing the component which has been send by the adapter client to a kubernetes cluster which has an istio controller there. It usually uses a CRD group to depict both registered services and instances.

func (*KubeMultiClusterEventHandler) AddConfigEntry

func (h *KubeMultiClusterEventHandler) AddConfigEntry(e *types2.ConfigEvent)

AddConfigEntry ...

func (*KubeMultiClusterEventHandler) AddInstance

func (h *KubeMultiClusterEventHandler) AddInstance(event *types2.ServiceEvent)

AddInstance ...

func (*KubeMultiClusterEventHandler) AddService

func (h *KubeMultiClusterEventHandler) AddService(event *types2.ServiceEvent)

AddService ...

func (*KubeMultiClusterEventHandler) ChangeConfigEntry

func (h *KubeMultiClusterEventHandler) ChangeConfigEntry(e *types2.ConfigEvent)

ChangeConfigEntry ...

func (*KubeMultiClusterEventHandler) DeleteConfigEntry

func (h *KubeMultiClusterEventHandler) DeleteConfigEntry(e *types2.ConfigEvent)

DeleteConfigEntry ...

func (*KubeMultiClusterEventHandler) DeleteInstance

func (h *KubeMultiClusterEventHandler) DeleteInstance(event *types2.ServiceEvent)

DeleteInstance ...

func (*KubeMultiClusterEventHandler) DeleteService

func (h *KubeMultiClusterEventHandler) DeleteService(event *types2.ServiceEvent)

DeleteService we assume we need to remove the service Spec part of AppMeshConfig after received a service deleted notification.

func (*KubeMultiClusterEventHandler) ReplaceAccessorInstances

func (h *KubeMultiClusterEventHandler) ReplaceAccessorInstances(
	event *types2.ServiceEvent,
	getScopedServices func(s string) map[string]struct{})

ReplaceAccessorInstances ...

func (*KubeMultiClusterEventHandler) ReplaceInstances

func (h *KubeMultiClusterEventHandler) ReplaceInstances(event *types2.ServiceEvent)

ReplaceInstances ...

type KubeSingleClusterEventHandler

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

KubeSingleClusterEventHandler ...

func (*KubeSingleClusterEventHandler) AddConfigEntry

func (h *KubeSingleClusterEventHandler) AddConfigEntry(e *types.ConfigEvent)

AddConfigEntry ...

func (*KubeSingleClusterEventHandler) AddInstance

func (h *KubeSingleClusterEventHandler) AddInstance(e *types.ServiceEvent)

AddInstance ...

func (*KubeSingleClusterEventHandler) AddService

func (h *KubeSingleClusterEventHandler) AddService(e *types.ServiceEvent)

AddService ...

func (*KubeSingleClusterEventHandler) ChangeConfigEntry

func (h *KubeSingleClusterEventHandler) ChangeConfigEntry(e *types.ConfigEvent)

ChangeConfigEntry ...

func (*KubeSingleClusterEventHandler) DeleteConfigEntry

func (h *KubeSingleClusterEventHandler) DeleteConfigEntry(e *types.ConfigEvent)

DeleteConfigEntry ...

func (*KubeSingleClusterEventHandler) DeleteInstance

func (h *KubeSingleClusterEventHandler) DeleteInstance(e *types.ServiceEvent)

DeleteInstance ...

func (*KubeSingleClusterEventHandler) DeleteService

func (h *KubeSingleClusterEventHandler) DeleteService(event *types.ServiceEvent)

DeleteService ...

func (*KubeSingleClusterEventHandler) ReplaceAccessorInstances

func (h *KubeSingleClusterEventHandler) ReplaceAccessorInstances(
	e *types.ServiceEvent,
	getScopedServices func(s string) map[string]struct{})

ReplaceAccessorInstances ...

func (*KubeSingleClusterEventHandler) ReplaceInstances

func (h *KubeSingleClusterEventHandler) ReplaceInstances(event *types.ServiceEvent)

ReplaceInstances ...

type LogEventHandler

type LogEventHandler struct {
}

LogEventHandler Using printing the event's information as a simple handling logic.

func (*LogEventHandler) AddConfigEntry

func (h *LogEventHandler) AddConfigEntry(e *types.ConfigEvent)

AddConfigEntry ...

func (*LogEventHandler) AddInstance

func (h *LogEventHandler) AddInstance(e *types.ServiceEvent)

AddInstance ...

func (*LogEventHandler) AddService

func (h *LogEventHandler) AddService(e *types.ServiceEvent)

AddService ...

func (*LogEventHandler) ChangeConfigEntry

func (h *LogEventHandler) ChangeConfigEntry(e *types.ConfigEvent)

ChangeConfigEntry ...

func (*LogEventHandler) DeleteConfigEntry

func (h *LogEventHandler) DeleteConfigEntry(e *types.ConfigEvent)

DeleteConfigEntry ...

func (*LogEventHandler) DeleteInstance

func (h *LogEventHandler) DeleteInstance(e *types.ServiceEvent)

DeleteInstance ...

func (*LogEventHandler) DeleteService

func (h *LogEventHandler) DeleteService(e *types.ServiceEvent)

DeleteService ...

func (*LogEventHandler) ReplaceAccessorInstances

func (h *LogEventHandler) ReplaceAccessorInstances(e *types.ServiceEvent, getScopedServices func(s string) map[string]struct{})

ReplaceAccessorInstances ...

func (*LogEventHandler) ReplaceInstances

func (h *LogEventHandler) ReplaceInstances(e *types.ServiceEvent)

ReplaceInstances ...