filter

Documentation

Index

• func GetDynamicResourceInformer(gvr schema.GroupVersionResource) informers.GenericInformer
• func GetFilters() map[string]Filter
• func IsBelongToSameGroup(targetNodeName string, epNodeName string) bool
• func MessageFilter(content interface{}, targetNode string)
• func Register(f Filter)
• type Filter

Functions

func GetDynamicResourceInformer

func GetDynamicResourceInformer(gvr schema.GroupVersionResource) informers.GenericInformer

func GetFilters

func GetFilters() map[string]Filter

GetFilters gets filter map

func IsBelongToSameGroup

func IsBelongToSameGroup(targetNodeName string, epNodeName string) bool

func MessageFilter

func MessageFilter(content interface{}, targetNode string)

MessageFilter filter message according to specify policy

func Register

func Register(f Filter)

Register register filter

Types

type Filter

type Filter interface {
	Name() string
	NeedFilter(content interface{}) bool
	FilterResource(targetNode string, obj runtime.Object)
}

Filter interface