bootstrap

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
  • func (b *AgentBootstrap) AddCustomizer(name string, customizer Customizer)
  • func (b *AgentBootstrap) AddStopComponents(components ...StopComponent)
  • func (b *AgentBootstrap) Bootstrap() error
• type Customizer
• type Runnable
• type StopComponent

Variables

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 Runnable

type Runnable func()

type StopComponent

type StopComponent interface {
	Stop()
}