Documentation
¶
Index ¶
- Variables
- func CreateContainerEngine() (cri.ContainerEngine, error)
- func InitCollectTaskManager(rs *registry.Service, staticTasks []*collecttask.CollectTask) (*collecttask.Manager, error)
- func InitContainerdEngine() (cri.ContainerEngine, error)
- func InitDockerEngine() (cri.ContainerEngine, error)
- func InitK8sClientsetInCluster() (*kubernetes.Clientset, error)
- func SetupConfigForK8s()
- type AgentBootstrap
- type Customizer
- type Runnable
- type StopComponent
Constants ¶
This section is empty.
Variables ¶
View Source
var ( App = AgentBootstrap{ Customizers: make(map[string][]Customizer), } )
Functions ¶
func CreateContainerEngine ¶
func CreateContainerEngine() (cri.ContainerEngine, error)
func InitCollectTaskManager ¶
func InitCollectTaskManager(rs *registry.Service, staticTasks []*collecttask.CollectTask) (*collecttask.Manager, error)
func InitContainerdEngine ¶
func InitContainerdEngine() (cri.ContainerEngine, error)
func InitDockerEngine ¶
func InitDockerEngine() (cri.ContainerEngine, error)
func InitK8sClientsetInCluster ¶
func InitK8sClientsetInCluster() (*kubernetes.Clientset, error)
func SetupConfigForK8s ¶
func SetupConfigForK8s()
Types ¶
type AgentBootstrap ¶
type AgentBootstrap struct {
StopHooks []Runnable
Hooks []Runnable
Customizers map[string][]Customizer
StaticTasks []*collecttask.CollectTask
LSM *logstream.Manager
PM *pipeline.Manager
TM *manager.TransferManager
AM *agent.Manager
MasterMaintainer *master.K8sNodeMasterMaintainer
// contains filtered or unexported fields
}
func (*AgentBootstrap) AddCustomizer ¶
func (b *AgentBootstrap) AddCustomizer(name string, customizer Customizer)
func (*AgentBootstrap) AddStopComponents ¶
func (b *AgentBootstrap) AddStopComponents(components ...StopComponent)
func (*AgentBootstrap) Bootstrap ¶
func (b *AgentBootstrap) Bootstrap() error
type Customizer ¶
type Customizer func(obj interface{}) (interface{}, error)
type StopComponent ¶
type StopComponent interface {
Stop()
}
Source Files
Click to show internal directories.
Click to hide internal directories.