k8sresourcewatcher

Documentation

Index

• Constants
• Variables
• type K8sResourceWatcher
  • func (w *K8sResourceWatcher) Init(properties *runtime.RawExtension, eh eventhandler.EventHandler) error
  • func (w *K8sResourceWatcher) New() sourcetypes.Source
  • func (w *K8sResourceWatcher) Parse(properties *runtime.RawExtension) (*types.Config, error)
  • func (w *K8sResourceWatcher) Run(ctx context.Context) error
  • func (w *K8sResourceWatcher) Type() string
• type MultiClustersGetter
  • func NewMultiClustersGetter(typ string) (MultiClustersGetter, error)

Constants

const (
	TypeClusterGateway       string = "cluster-gateway"
	TypeClusterGatewaySecret string = "cluster-gateway-secret"
)

Variables

var (
	MultiClusterConfigType string
)

Types

type K8sResourceWatcher

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

func (*K8sResourceWatcher) Init

func (w *K8sResourceWatcher) Init(properties *runtime.RawExtension, eh eventhandler.EventHandler) error

func (*K8sResourceWatcher) New

func (w *K8sResourceWatcher) New() sourcetypes.Source

func (*K8sResourceWatcher) Parse

func (w *K8sResourceWatcher) Parse(properties *runtime.RawExtension) (*types.Config, error)

func (*K8sResourceWatcher) Run

func (w *K8sResourceWatcher) Run(ctx context.Context) error

func (*K8sResourceWatcher) Type

func (w *K8sResourceWatcher) Type() string

type MultiClustersGetter

type MultiClustersGetter interface {
	GetDynamicClientAndMapper(ctx context.Context, cluster string) (dynamic.Interface, meta.RESTMapper, error)
}

func NewMultiClustersGetter

func NewMultiClustersGetter(typ string) (MultiClustersGetter, error)