provider

Documentation

Index

• func RegisterSource(s SourceFactory)
• func RegisterTarget(t TargetFactory)
• type Source
• type SourceFactory
  • func GetSourceFactory(name v1.RuleEndpointTypeDef) (SourceFactory, bool)
• type Target
• type TargetFactory
  • func GetTargetFactory(name v1.RuleEndpointTypeDef) (TargetFactory, bool)

Functions

func RegisterSource

func RegisterSource(s SourceFactory)

RegisterSource register module

func RegisterTarget

func RegisterTarget(t TargetFactory)

RegisterSource register module

Types

type Source

type Source interface {
	Name() string
	RegisterListener(handle listener.Handle) error
	UnregisterListener()
	Forward(Target, interface{}) (interface{}, error)
}

type SourceFactory

type SourceFactory interface {
	Type() v1.RuleEndpointTypeDef
	GetSource(ep *v1.RuleEndpoint, sourceResource map[string]string) Source
}

func GetSourceFactory

func GetSourceFactory(name v1.RuleEndpointTypeDef) (SourceFactory, bool)

get source map

type Target

type Target interface {
	Name() string
	GoToTarget(data map[string]interface{}, stop chan struct{}) (interface{}, error)
}

type TargetFactory

type TargetFactory interface {
	Type() v1.RuleEndpointTypeDef
	GetTarget(ep *v1.RuleEndpoint, targetResource map[string]string) Target
}

func GetTargetFactory

func GetTargetFactory(name v1.RuleEndpointTypeDef) (TargetFactory, bool)

get source map