Function agentInitCmd

cli/ctl/agent_check.go:270–310

(cmd *cobra.Command, cmds []AgentCmdExecute)

}

func agentInitCmd(cmd *cobra.Command, cmds []AgentCmdExecute) {
	conn := agentGetConn(cmd)
	if conn == nil {
		return
	}
	defer conn.Close()
	name := ""
	groupID := agentParamData.GroupID
	clusterID := agentParamData.ClusterID
	teamID := agentParamData.TeamID
	k8sWatchPolicy := agent.KubernetesWatchPolicy(agentParamData.K8SWatchPolicy)
	grpcBufferSize := agentParamData.GRPCBufferSize * 1024 * 1024
	fmt.Printf("request trisolaris(%s), params(%+v)\n", conn.Target(), agentParamData)
	c := agent.NewSynchronizerClient(conn)
	reqData := &agent.SyncRequest{
		CtrlIp:                &agentParamData.CtrlIP,
		CtrlMac:               &agentParamData.CtrlMac,
		CurrentGrpcBufferSize: &grpcBufferSize,
		AgentGroupIdRequest:   &groupID,
		KubernetesClusterId:   &clusterID,
		KubernetesWatchPolicy: &k8sWatchPolicy,
		ProcessName:           &name,
		TeamId:                &teamID,
	}
	var response *agent.SyncResponse
	var err error
	response, err = c.Sync(context.Background(), reqData)
	if err != nil {
		fmt.Println(err)
		return
	}
	if agentParamData.GRPCBufferSize == 0 {
		fmt.Printf("revision: %s\n", response.GetRevision())
	} else {
		fmt.Printf("current grpc buffer size (byte): %d\n", grpcBufferSize)
	}

	for _, cmd := range cmds {
		cmd(response)
	}
}

func AgpidAgentResponse(cmd *cobra.Command) {
	conn := agentGetConn(cmd)