Documentation
¶
Overview ¶
Package agent is the package that contains those implementations to obtain metadata in the specific node, any other component wants to get those data should import this package rather than get directly.
Index ¶
- type MetaAgent
- func (a *MetaAgent) GetUnstructured(ctx context.Context, gvr metav1.GroupVersionResource, namespace, name string) (*unstructured.Unstructured, error)
- func (a *MetaAgent) Run(ctx context.Context)
- func (a *MetaAgent) SetCNCFetcher(c cnc.CNCFetcher)
- func (a *MetaAgent) SetCNRFetcher(c cnr.CNRFetcher)
- func (a *MetaAgent) SetKubeletConfigFetcher(k kubeletconfig.KubeletConfigFetcher)
- func (a *MetaAgent) SetMetricFetcher(m types.MetricsFetcher)
- func (a *MetaAgent) SetNodeFetcher(n node.NodeFetcher)
- func (a *MetaAgent) SetObjectFetcher(gvr metav1.GroupVersionResource, f ObjectFetcher)
- func (a *MetaAgent) SetPodFetcher(p pod.PodFetcher)
- type ObjectFetcher
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MetaAgent ¶
type MetaAgent struct {
sync.Mutex
// those fetchers provide a dynamic way to collect meta info;
// actually, those fetchers call be set by self-defined implementations
pod.PodFetcher
node.NodeFetcher
types.MetricsFetcher
cnr.CNRFetcher
cnc.CNCFetcher
kubeletconfig.KubeletConfigFetcher
// ObjectFetchers provide a way to expand fetcher for objects
ObjectFetchers sync.Map
// machine info is fetched from once and stored in meta-server
*machine.KatalystMachineInfo
AgentConf *metaserver.AgentConfiguration
// contains filtered or unexported fields
}
MetaAgent contains all those implementations for metadata running in this agent.
func NewMetaAgent ¶
func NewMetaAgent(conf *config.Configuration, clientSet *client.GenericClientSet, emitter metrics.MetricEmitter) (*MetaAgent, error)
NewMetaAgent returns the instance of MetaAgent.
func (*MetaAgent) GetUnstructured ¶ added in v0.3.0
func (a *MetaAgent) GetUnstructured(ctx context.Context, gvr metav1.GroupVersionResource, namespace, name string, ) (*unstructured.Unstructured, error)
func (*MetaAgent) SetCNCFetcher ¶ added in v0.3.0
func (a *MetaAgent) SetCNCFetcher(c cnc.CNCFetcher)
func (*MetaAgent) SetCNRFetcher ¶
func (a *MetaAgent) SetCNRFetcher(c cnr.CNRFetcher)
func (*MetaAgent) SetKubeletConfigFetcher ¶ added in v0.3.0
func (a *MetaAgent) SetKubeletConfigFetcher(k kubeletconfig.KubeletConfigFetcher)
func (*MetaAgent) SetMetricFetcher ¶
func (a *MetaAgent) SetMetricFetcher(m types.MetricsFetcher)
func (*MetaAgent) SetNodeFetcher ¶
func (a *MetaAgent) SetNodeFetcher(n node.NodeFetcher)
func (*MetaAgent) SetObjectFetcher ¶ added in v0.3.0
func (a *MetaAgent) SetObjectFetcher(gvr metav1.GroupVersionResource, f ObjectFetcher)
func (*MetaAgent) SetPodFetcher ¶
func (a *MetaAgent) SetPodFetcher(p pod.PodFetcher)
type ObjectFetcher ¶ added in v0.3.0
type ObjectFetcher interface {
// GetUnstructured returns those latest cUnstructured
GetUnstructured(ctx context.Context, namespace, name string) (*unstructured.Unstructured, error)
}
ObjectFetcher is used to get object information.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.