boot

type Agent struct {
	Args       *Args
	EnvProfile bool
	LogFile    *os.File
	LogExpire  time.Duration
	BeatFreQ   time.Duration

	LogL    *LogLauncher
	ConfigL *ProfileLauncher
	SignalL *SignalLauncher

	LFunc     []LauncherFunc
	Launchers []AgentLauncher

	Context context.Context
	Cancel  context.CancelFunc
	Wg      *sync.WaitGroup

	Handlers []common.AgentHandler

	SigBus *SignalBus
	// contains filtered or unexported fields
}

type AgentLauncher interface {
	Init(agent *Agent) error
	Run() error
	Stop()
	Shutdown()
}

type App struct {
	AppId        string        `yaml:"appId"`
	Namespaces   []string      `yaml:"namespace"`
	Secret       string        `yaml:"secret"`
	Syntax       string        `yaml:"syntax"`
	PollInterval time.Duration `yaml:"pollInterval"`
	InOneFile    string        `yaml:"inOneFile"`
}

type Args struct {
	LogFile    *string
	ConfigFile *string
	Pprof      *bool
	// contains filtered or unexported fields
}

type Client struct {
	Type      string        `yaml:"pollOrWatch"`
	AllInOne  bool          `yaml:"allInOne"`
	LogExpire time.Duration `yaml:"logExpire"`
	Ip        string        `yaml:"ip"`
	BeatFreQ  time.Duration `yaml:"beatFreq"`
}

type DataChan chan struct{}

type LauncherFunc func(*Agent) error

type LogLauncher struct {
	LogExpire time.Duration
	Logfile   *os.File
	// contains filtered or unexported fields
}

type Profile struct {
	Client *Client `yaml:"client"`
	Server *Server `yaml:"server"`
	Apps   []*App  `yaml:"apps"`
}

type ProfileLauncher struct {
	FromEnvVar    bool
	Profile       *Profile
	ProfileUpdate bool
	// contains filtered or unexported fields
}

type Server struct {
	Address string `yaml:"address"`
	Cluster string `yaml:"cluster"`
}

type SignalBus struct {
	StopS    chan struct{}
	RestartS chan struct{}
}

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