Versions in this module Expand all Collapse all v0 v0.0.1 Jul 2, 2024 Changes in this version + var App = AgentBootstrap + 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 struct + AM *agent.Manager + Customizers map[string][]Customizer + Hooks []Runnable + LSM *logstream.Manager + MasterMaintainer *master.K8sNodeMasterMaintainer + PM *pipeline.Manager + StaticTasks []*collecttask.CollectTask + StopHooks []Runnable + TM *manager.TransferManager + func (b *AgentBootstrap) AddCustomizer(name string, customizer Customizer) + func (b *AgentBootstrap) AddStopComponents(components ...StopComponent) + func (b *AgentBootstrap) Bootstrap() error + type Customizer func(obj interface{}) (interface{}, error) + type Runnable func() + type StopComponent interface + Stop func()