ksr

type Deps struct {
	infra.PluginDeps
	ServiceLabel servicelabel.ReaderAPI
	// Kubeconfig with k8s cluster address and access credentials to use.
	KubeConfig config.PluginConfig
	// broker is used to propagate changes into a key-value datastore.
	// contiv-ksr uses ETCD as datastore.
	Publish *kvdbsync.Plugin
	// Prometheus used to publish statistics
	Prometheus *prometheus.Plugin
}

type DsItems map[string]interface{}

type EndpointsReflector struct {
	Reflector
}

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

type K8sClientGetter func(*kubernetes.Clientset) rest.Interface

type K8sListWatcher interface {
	// NewListWatchFromClient creates a new ListWatch from the specified client, resource, namespace and field selector.
	NewListWatchFromClient(c cache.Getter, resource string, namespace string,
		fieldSelector fields.Selector) *cache.ListWatch

	// NewInformer returns a Store and a Controller for populating the store
	// while also providing event notifications.
	NewInformer(lw cache.ListerWatcher, objType runtime.Object, resyncPeriod time.Duration,
		h cache.ResourceEventHandler) (cache.Store, cache.Controller)
}

type K8sToProtoConverter func(interface{}) (interface{}, string, bool)

type KeyProtoValBroker interface {
	// Put <data> to ETCD or to any other key-value based data source.
	Put(key string, data proto.Message, opts ...datasync.PutOption) error

	// Delete data under the <key> in ETCD or in any other key-value based data
	// source.
	Delete(key string, opts ...datasync.DelOption) (existed bool, err error)

	// GetValue reads a value from etcd stored under the given key.
	GetValue(key string, reqObj proto.Message) (found bool, revision int64, err error)

	// List values stored in etcd under the given prefix.
	ListValues(prefix string) (keyval.ProtoKeyValIterator, error)
}

type NamespaceReflector struct {
	Reflector
}

type NodeReflector struct {
	Reflector
	// contains filtered or unexported fields
}

type Option func(*Plugin)

type Plugin struct {
	Deps

	StatusMonitor statuscheck.StatusReader

	StatsCollector StatsCollector
	// contains filtered or unexported fields
}

type PodReflector struct {
	Reflector
}

type PolicyReflector struct {
	Reflector
}

type ProtoAllocator func() proto.Message

type Reflector struct {
	// Each reflector gets a separate child logger.
	Log logging.Logger
	// A K8s client gets the appropriate REST client.
	K8sClientset *kubernetes.Clientset
	// K8s List-Watch watches for Kubernetes config changes.
	K8sListWatch K8sListWatcher
	// broker is the interface to a key-val data store.
	Broker KeyProtoValBroker
	// reflector registry
	*ReflectorRegistry
	// contains filtered or unexported fields
}

type ReflectorFunctions struct {
	EventHdlrFunc cache.ResourceEventHandlerFuncs

	ProtoAllocFunc ProtoAllocator
	K8s2NodeFunc   K8sToProtoConverter
	K8sClntGetFunc K8sClientGetter
}

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

type ServiceReflector struct {
	Reflector
}

type SfcPodReflector struct {
	Reflector
}

type StatsCollector struct {
	Log logging.Logger

	Prometheus prometheusplugin.API
	// contains filtered or unexported fields
}