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) Singleton() bool
  • func (w *K8sResourceWatcher) Type() string
• type MultiClustersGetter
  • func NewMultiClustersGetter(typ string) (MultiClustersGetter, error)

Constants

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

Variables

var (
	// MultiClusterConfigType .
	MultiClusterConfigType string
)

Types

type K8sResourceWatcher

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

K8sResourceWatcher watches k8s resources.

func (*K8sResourceWatcher) Init

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

Init .

func (*K8sResourceWatcher) New

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

New .

func (*K8sResourceWatcher) Parse

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

Parse .

func (*K8sResourceWatcher) Run

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

Run .

func (*K8sResourceWatcher) Singleton

func (w *K8sResourceWatcher) Singleton() bool

Singleton .

func (*K8sResourceWatcher) Type

func (w *K8sResourceWatcher) Type() string

Type .

type MultiClustersGetter

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

MultiClustersGetter .

func NewMultiClustersGetter

func NewMultiClustersGetter(typ string) (MultiClustersGetter, error)

NewMultiClustersGetter new a MultiClustersGetter