()
| 203 | } |
| 204 | |
| 205 | func AgentCheckRegisterCommand() *cobra.Command { |
| 206 | trisolarisCmd := &cobra.Command{ |
| 207 | Use: "trisolaris.agent-check", |
| 208 | Short: "pull grpc data from deepflow-server", |
| 209 | } |
| 210 | trisolarisCmd.PersistentFlags().Int32VarP(&agentParamData.K8SWatchPolicy, "kwp", "", 0, "agent k8s watch policy: 0.normal 1.only 2.disabled") |
| 211 | trisolarisCmd.PersistentFlags().Uint64VarP(&agentParamData.GRPCBufferSize, "size", "", 0, "agent current grpc buffer size, Unit: MB") |
| 212 | trisolarisCmd.PersistentFlags().StringVarP(&agentParamData.CtrlIP, "cip", "", "", "agent ctrl ip") |
| 213 | trisolarisCmd.PersistentFlags().StringVarP(&agentParamData.CtrlMac, "cmac", "", "", "agent ctrl mac") |
| 214 | trisolarisCmd.PersistentFlags().StringVarP(&agentParamData.GroupID, "gid", "", "", "agent group ID") |
| 215 | trisolarisCmd.PersistentFlags().StringVarP(&agentParamData.TeamID, "tid", "", "", "agent team ID") |
| 216 | trisolarisCmd.PersistentFlags().StringVarP(&agentParamData.ClusterID, "cid", "", "", "agent k8s cluster ID") |
| 217 | trisolarisCmd.PersistentFlags().StringVarP(&agentParamData.PluginType, "ptype", "", "wasm", "request plugin type") |
| 218 | trisolarisCmd.PersistentFlags().StringVarP(&agentParamData.PluginName, "pname", "", "", "request plugin name") |
| 219 | cmds := agentRegiterCommand() |
| 220 | for _, handler := range cmds { |
| 221 | trisolarisCmd.AddCommand(handler) |
| 222 | } |
| 223 | |
| 224 | return trisolarisCmd |
| 225 | } |
| 226 | |
| 227 | func agentGetConn(cmd *cobra.Command) *grpc.ClientConn { |
| 228 | server := common.GetServerInfo(cmd) |
no test coverage detected